feat: reconcile OnChainDealID

application-research · May 30, 2023 · f0b3da7 · f0b3da7
1 parent f03a26d
commit f0b3da7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/core/delta-rpc.go b/core/delta-rpc.go
@@ -399,7 +399,7 @@ type DealStats_Deal struct {
 	PropCid             string `json:"propCid"`
 	DealUUID            string `json:"dealUuid"`
 	Miner               string `json:"miner"`
-	DealID              int64  `json:"dealId"`
+	DealID              uint   `json:"dealId"`
 	Failed              bool   `json:"failed"`
 	Verified            bool   `json:"verified"`
 	Slashed             bool   `json:"slashed"`

diff --git a/core/delta-watcher.go b/core/delta-watcher.go
@@ -114,6 +114,7 @@ func computeReplicationUpdates(dealStats DealStatsResponse) []db.Replication {
 			if len(deal.Deals) > 0 {
 				r.ProposalCid = deal.Deals[0].PropCid
 				r.DealUUID = deal.Deals[0].DealUUID
+				r.OnChainDealID = deal.Deals[0].DealID
 			}
 			if len(deal.PieceCommitments) > 0 {
 				r.ContentCommP = deal.PieceCommitments[0].Piece
@@ -134,6 +135,7 @@ func computeReplicationUpdates(dealStats DealStatsResponse) []db.Replication {
 			if len(deal.Deals) > 0 {
 				r.ProposalCid = deal.Deals[0].PropCid
 				r.DealUUID = deal.Deals[0].DealUUID
+				r.OnChainDealID = deal.Deals[0].DealID
 			}
 			toUpdate = append(toUpdate, r)