Skip to content
This repository was archived by the owner on Mar 28, 2023. It is now read-only.

Commit de22242

Browse files
committed
feat: Save dispute update message to database
1 parent 3e0150c commit de22242

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

core/net.go

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -564,10 +564,27 @@ func (n *OpenBazaarNode) SendDisputeUpdate(peerID string, updateMessage *pb.Disp
564564
log.Errorf("failed to marshal the contract: %v", err)
565565
return err
566566
}
567+
568+
// Create the DISPUTE_UPDATE message
567569
m := pb.Message{
568570
MessageType: pb.Message_DISPUTE_UPDATE,
569571
Payload: a,
570572
}
573+
574+
// Save DISPUTE_UPDATE message to the database for this order for resending if necessary
575+
orderID0 := updateMessage.OrderId
576+
if orderID0 == "" {
577+
log.Errorf("failed fetching orderID")
578+
} else {
579+
err = n.Datastore.Messages().Put(
580+
fmt.Sprintf("%s-%d", orderID0, int(pb.Message_DISPUTE_UPDATE)),
581+
orderID0, pb.Message_DISPUTE_UPDATE, peerID, repo.Message{Msg: m},
582+
"", 0, []byte{})
583+
if err != nil {
584+
log.Errorf("failed putting message (%s-%d): %v", orderID0, int(pb.Message_DISPUTE_UPDATE), err)
585+
}
586+
}
587+
571588
return n.sendMessage(peerID, nil, m)
572589
}
573590

0 commit comments

Comments
 (0)