Update Observer tipset structure to include supplemental data.

filecoin-project · Nov 18, 2024 · d3bfd33 · d3bfd33
1 parent 4914105
commit d3bfd33
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 8 deletions.
diff --git a/observer/model.go b/observer/model.go
@@ -38,8 +38,10 @@ type supplementalData struct {
 }
 
 type tipSet struct {
-	Epoch int64  `json:"Epoch"`
-	Key   []byte `json:"Key"`
+	Epoch       int64  `json:"Epoch"`
+	Key         []byte `json:"Key"`
+	Commitments []byte `json:"Commitments"`
+	PowerTable  string `json:"PowerTable"`
 }
 
 func newMessage(timestamp time.Time, nn string, msg gpbft.GMessage) (*message, error) {
@@ -85,10 +87,12 @@ func newPayload(gp gpbft.Payload) payload {
 	value := make([]tipSet, len(gp.Value))
 	for i, v := range gp.Value {
 		value[i] = tipSet{
-			// The TipSet Commitments and PowerTable CID always match the Payload's
-			// SupplementalData for valid messages. Therefore, dropped for brevity.
-			Epoch: v.Epoch,
-			Key:   v.Key,
+			Epoch:      v.Epoch,
+			Key:        v.Key,
+			PowerTable: v.PowerTable.String(),
+		}
+		if v.Commitments != emptyCommitments {
+			value[i].Commitments = v.Commitments[:]
 		}
 	}
 	return payload{

diff --git a/observer/schema.sql b/observer/schema.sql
@@ -25,7 +25,9 @@ CREATE TABLE IF NOT EXISTS latest_messages (
     ),
     Value STRUCT(
       Epoch BIGINT,
-      Key BLOB
+      Key BLOB,
+      Commitments BLOB,
+      PowerTable VARCHAR
     )[]
   ),
   Signature BLOB,
@@ -49,7 +51,9 @@ CREATE TABLE IF NOT EXISTS latest_messages (
       ),
       Value STRUCT(
         Epoch BIGINT,
-        Key BLOB
+        Key BLOB,
+        Commitments BLOB,
+        PowerTable VARCHAR
       )[]
     ),
     Signers BIGINT[],