Add v2 file contract resolutions

explorer/types.go

@@ -189,7 +189,6 @@ type V2FileContract struct {
 	ConfirmationIndex         *types.ChainIndex    `json:"confirmationIndex"`
 	ConfirmationTransactionID *types.TransactionID `json:"confirmationTransactionID"`
 
-	Resolution              *types.V2FileContractResolutionType
 	ResolutionIndex         *types.ChainIndex    `json:"resolutionIndex"`
 	ResolutionTransactionID *types.TransactionID `json:"resolutionTransactionID"`
 
@@ -210,6 +209,27 @@ type V2HostAnnouncement struct {
 	chain.V2HostAnnouncement
 }
 
+// A V2FileContractRenewal renews a file contract.
+type V2FileContractRenewal struct {
+	FinalRevision  V2FileContract `json:"finalRevision"`
+	NewContract    V2FileContract `json:"newContract"`
+	RenterRollover types.Currency `json:"renterRollover"`
+	HostRollover   types.Currency `json:"hostRollover"`
+
+	// signatures cover above fields
+	RenterSignature types.Signature `json:"renterSignature"`
+	HostSignature   types.Signature `json:"hostSignature"`
+}
+
+// A V2FileContractResolution closes a v2 file contract's payment channel.
+// There are four resolution types: renewwal, storage proof, finalization,
+// and expiration.
+type V2FileContractResolution struct {
+	Parent     V2FileContract `json:"parent"`
+	Type       string         `json:"string"`
+	Resolution any            `json:"resolution"`
+}
+
 // A V2Transaction is a V2 transaction that uses the wrapped types above.
 type V2Transaction struct {
 	ID types.TransactionID `json:"id"`
@@ -219,8 +239,9 @@ type V2Transaction struct {
 	SiafundInputs  []types.V2SiafundInput `json:"siafundInputs,omitempty"`
 	SiafundOutputs []SiafundOutput        `json:"siafundOutputs,omitempty"`
 
-	FileContracts         []V2FileContract         `json:"fileContracts,omitempty"`
-	FileContractRevisions []V2FileContractRevision `json:"fileContractRevisions,omitempty"`
+	FileContracts           []V2FileContract           `json:"fileContracts,omitempty"`
+	FileContractRevisions   []V2FileContractRevision   `json:"fileContractRevisions,omitempty"`
+	FileContractResolutions []V2FileContractResolution `json:"fileContractResolutions,omitempty"`
 
 	Attestations  []types.Attestation `json:"attestations,omitempty"`
 	ArbitraryData []byte              `json:"arbitraryData,omitempty"`
@@ -246,6 +267,7 @@ type Block struct {
 	ParentID     types.BlockID   `json:"parentID"`
 	Nonce        uint64          `json:"nonce"`
 	Timestamp    time.Time       `json:"timestamp"`
+	LeafIndex    uint64          `json:"leafIndex"`
 	MinerPayouts []SiacoinOutput `json:"minerPayouts"`
 	Transactions []Transaction   `json:"transactions"`
 

explorer/update.go

@@ -45,7 +45,8 @@ type (
 	// An UpdateState contains information relevant to the block being applied
 	// or reverted.
 	UpdateState struct {
-		Block types.Block
+		Block             types.Block
+		ChainIndexElement types.ChainIndexElement
 
 		Events      []Event
 		Metrics     Metrics
@@ -211,7 +212,8 @@ func applyChainUpdate(tx UpdateTx, cau chain.ApplyUpdate) error {
 	events := AppliedEvents(cau.State, cau.Block, cau)
 
 	state := UpdateState{
-		Block: cau.Block,
+		Block:             cau.Block,
+		ChainIndexElement: cau.ChainIndexElement(),
 
 		Events:      events,
 		TreeUpdates: treeUpdates,

go.sum

@@ -35,20 +35,6 @@ go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
 go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
 go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
-go.sia.tech/core v0.5.0 h1:feLC7DSCF+PhU157s/94106hFKyiGrGQ9HC3/dF/l7E=
-go.sia.tech/core v0.5.0/go.mod h1:P3C1BWa/7J4XgdzWuaYHBvLo2RzZ0UBaJM4TG1GWB2g=
-go.sia.tech/coreutils v0.5.0 h1:/xKxdw83iZy0jjLzI2NGHyG4azyjK5DJscxpkr6nIGQ=
-go.sia.tech/coreutils v0.5.0/go.mod h1:VYM4FcmlhVrpDGvglLHjRW+gitoaxPNLvp5mL2quilo=
-go.sia.tech/jape v0.12.1 h1:xr+o9V8FO8ScRqbSaqYf9bjj1UJ2eipZuNcI1nYousU=
-go.sia.tech/jape v0.12.1/go.mod h1:wU+h6Wh5olDjkPXjF0tbZ1GDgoZ6VTi4naFw91yyWC4=
-go.sia.tech/mux v1.3.0 h1:hgR34IEkqvfBKUJkAzGi31OADeW2y7D6Bmy/Jcbop9c=
-go.sia.tech/mux v1.3.0/go.mod h1:I46++RD4beqA3cW9Xm9SwXbezwPqLvHhVs9HLpDtt58=
-go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
-go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
-go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
-go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
-go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
-go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
 golang.org/x/crypto v0.28.0 h1:GBDwsMXVQi34v5CCYUm2jkJvu4cbtru2U4TN2PSyQnw=
 golang.org/x/crypto v0.28.0/go.mod h1:rmgy+3RHxRZMyY0jjAJShp2zgEdOqj2AO7U0pYmeQ7U=
 golang.org/x/mod v0.17.0 h1:zY54UmvipHiNd+pm+m0x9KhZ9hl1/7QNMyxXbc6ICqA=

internal/testutil/chain.go

@@ -178,7 +178,9 @@ func SignV2TransactionWithContracts(cs consensus.State, pk, renterPK, hostPK typ
 			r.RenterSignature = renterPK.SignHash(cs.RenewalSigHash(*r))
 			r.HostSignature = hostPK.SignHash(cs.RenewalSigHash(*r))
 		case *types.V2FileContractFinalization:
-			*r = types.V2FileContractFinalization(renterPK.SignHash(cs.ContractSigHash(txn.FileContractResolutions[i].Parent.V2FileContract)))
+			finalRevision := txn.FileContractResolutions[i].Parent.V2FileContract
+			finalRevision.RevisionNumber = types.MaxRevisionNumber
+			*r = types.V2FileContractFinalization(renterPK.SignHash(cs.ContractSigHash(finalRevision)))
 		}
 	}
 }

internal/testutil/check.go

@@ -197,6 +197,53 @@ func CheckV2Transaction(t *testing.T, expectTxn types.V2Transaction, gotTxn expl
 		CheckV2FC(t, expected.Revision, got.Revision)
 	}
 
+	Equal(t, "file contract resolutions", len(expectTxn.FileContractResolutions), len(gotTxn.FileContractResolutions))
+	for i := range expectTxn.FileContractResolutions {
+		expected := expectTxn.FileContractResolutions[i]
+		got := gotTxn.FileContractResolutions[i]
+
+		CheckV2FC(t, expected.Parent.V2FileContract, got.Parent)
+
+		switch v := expected.Resolution.(type) {
+		case *types.V2FileContractRenewal:
+			if gotV, ok := got.Resolution.(*explorer.V2FileContractRenewal); !ok {
+				t.Fatalf("expected V2FileContractRenewal, got %v", reflect.TypeOf(got.Resolution))
+			} else {
+				CheckV2FC(t, v.FinalRevision, gotV.FinalRevision)
+				CheckV2FC(t, v.NewContract, gotV.NewContract)
+
+				Equal(t, "type", "renewal", got.Type)
+				Equal(t, "renter rollover", v.RenterRollover, gotV.RenterRollover)
+				Equal(t, "host rollover", v.HostRollover, gotV.HostRollover)
+				Equal(t, "renter signature", v.RenterSignature, gotV.RenterSignature)
+				Equal(t, "host signature", v.HostSignature, gotV.HostSignature)
+			}
+		case *types.V2StorageProof:
+			if gotV, ok := got.Resolution.(*types.V2StorageProof); !ok {
+				t.Fatalf("expected V2StorageProof, got %v", reflect.TypeOf(got.Resolution))
+			} else {
+				Equal(t, "type", "storageProof", got.Type)
+				Equal(t, "proof index", v.ProofIndex, gotV.ProofIndex)
+				Equal(t, "leaf", v.Leaf, gotV.Leaf)
+				Equal(t, "proof", v.Proof, gotV.Proof)
+			}
+		case *types.V2FileContractFinalization:
+			if gotV, ok := got.Resolution.(*types.V2FileContractFinalization); !ok {
+				t.Fatalf("expected V2FileContractFinalization, got %v", reflect.TypeOf(got.Resolution))
+			} else {
+				Equal(t, "type", "finalization", got.Type)
+				Equal(t, "finalization signature", types.Signature(*v), types.Signature(*gotV))
+			}
+		case *types.V2FileContractExpiration:
+			Equal(t, "type", "expiration", got.Type)
+			if _, ok := got.Resolution.(*types.V2FileContractExpiration); !ok {
+				t.Fatalf("expected V2FileContractExpiration, got %v", reflect.TypeOf(got.Resolution))
+			}
+		default:
+			t.Fatalf("invalid resolution type: %v", reflect.TypeOf(got.Resolution))
+		}
+	}
+
 	Equal(t, "attestations", len(expectTxn.Attestations), len(gotTxn.Attestations))
 	for i := range expectTxn.Attestations {
 		expected := expectTxn.Attestations[i]

persist/sqlite/blocks.go

@@ -14,7 +14,7 @@ func (s *Store) Block(id types.BlockID) (result explorer.Block, err error) {
 	err = s.transaction(func(tx *txn) error {
 		var v2Height uint64
 		var v2Commitment types.Hash256
-		err := tx.QueryRow(`SELECT parent_id, nonce, timestamp, height, v2_height, v2_commitment FROM blocks WHERE id = ?`, encode(id)).Scan(decode(&result.ParentID), decode(&result.Nonce), decode(&result.Timestamp), &result.Height, decodeNull(&v2Height), decodeNull(&v2Commitment))
+		err := tx.QueryRow(`SELECT parent_id, nonce, timestamp, height, leaf_index, v2_height, v2_commitment FROM blocks WHERE id = ?`, encode(id)).Scan(decode(&result.ParentID), decode(&result.Nonce), decode(&result.Timestamp), &result.Height, decode(&result.LeafIndex), decodeNull(&v2Height), decodeNull(&v2Commitment))
 		if err != nil {
 			return fmt.Errorf("failed to get block: %w", err)
 		}

persist/sqlite/consensus.go

@@ -16,15 +16,15 @@ type updateTx struct {
 	tx *txn
 }
 
-func addBlock(tx *txn, b types.Block, height uint64) error {
+func addBlock(tx *txn, b types.Block, cie types.ChainIndexElement, height uint64) error {
 	// nonce is encoded because database/sql doesn't support uint64 with high bit set
 	var v2Height any
 	var v2Commitment any
 	if b.V2 != nil {
 		v2Height = encode(b.V2.Height)
 		v2Commitment = encode(b.V2.Commitment)
 	}
-	_, err := tx.Exec("INSERT INTO blocks(id, height, parent_id, nonce, timestamp, v2_height, v2_commitment) VALUES (?, ?, ?, ?, ?, ?, ?);", encode(b.ID()), height, encode(b.ParentID), encode(b.Nonce), encode(b.Timestamp), v2Height, v2Commitment)
+	_, err := tx.Exec("INSERT INTO blocks(id, height, parent_id, nonce, timestamp, leaf_index, v2_height, v2_commitment) VALUES (?, ?, ?, ?, ?, ?, ?, ?);", encode(b.ID()), height, encode(b.ParentID), encode(b.Nonce), encode(b.Timestamp), encode(cie.StateElement.LeafIndex), v2Height, v2Commitment)
 	return err
 }
 
@@ -1018,7 +1018,7 @@ func (ut *updateTx) Metrics(height uint64) (explorer.Metrics, error) {
 }
 
 func (ut *updateTx) ApplyIndex(state explorer.UpdateState) error {
-	if err := addBlock(ut.tx, state.Block, state.Metrics.Index.Height); err != nil {
+	if err := addBlock(ut.tx, state.Block, state.ChainIndexElement, state.Metrics.Index.Height); err != nil {
 		return fmt.Errorf("ApplyIndex: failed to add block: %w", err)
 	} else if err := updateMaturedBalances(ut.tx, false, state.Metrics.Index.Height); err != nil {
 		return fmt.Errorf("ApplyIndex: failed to update matured balances: %w", err)
@@ -1106,6 +1106,8 @@ func (ut *updateTx) RevertIndex(state explorer.UpdateState) error {
 		return fmt.Errorf("RevertIndex: failed to update balances: %w", err)
 	} else if _, err := updateFileContractElements(ut.tx, true, state.Block, state.FileContractElements); err != nil {
 		return fmt.Errorf("RevertIndex: failed to update file contract state: %w", err)
+	} else if _, err := updateV2FileContractElements(ut.tx, true, state.Block, state.V2FileContractElements); err != nil {
+		return fmt.Errorf("ApplyIndex: failed to add v2 file contracts: %w", err)
 	} else if err := deleteBlock(ut.tx, state.Block.ID()); err != nil {
 		return fmt.Errorf("RevertIndex: failed to delete block: %w", err)
 	} else if err := updateStateTree(ut.tx, state.TreeUpdates); err != nil {

persist/sqlite/init.sql

@@ -9,6 +9,7 @@ CREATE TABLE blocks (
 	parent_id BLOB NOT NULL,
 	nonce BLOB NOT NULL,
 	timestamp INTEGER NOT NULL,
+	leaf_index BLOB NOT NULL,
 
 	v2_height INTEGER,
 	v2_commitment BLOB
@@ -327,6 +328,37 @@ CREATE TABLE v2_transaction_file_contract_revisions (
 );
 CREATE INDEX v2_transaction_file_contract_revisions_transaction_id_index ON v2_transaction_file_contract_revisions(transaction_id);
 
+CREATE TABLE v2_transaction_file_contract_resolutions (
+    transaction_id INTEGER REFERENCES v2_transactions(id) ON DELETE CASCADE NOT NULL,
+    transaction_order INTEGER NOT NULL,
+    parent_contract_id INTEGER REFERENCES v2_file_contract_elements(id) ON DELETE CASCADE NOT NULL, -- add an index to all foreign keys
+
+    -- V2FileContractRenewal = 0, V2StorageProof = 1, V2FileContractFinalization = 2, V2FileContractExpiration = 3
+    resolution_type INTEGER NOT NULL,
+
+    -- V2FileContractRenewal
+    renewal_final_revision_contract_id INTEGER REFERENCES v2_file_contract_elements(id) ON DELETE CASCADE,
+    renewal_new_contract_id INTEGER REFERENCES v2_file_contract_elements(id) ON DELETE CASCADE,
+    renewal_renter_rollover BLOB,
+    renewal_host_rollover BLOB,
+    renewal_renter_signature BLOB,
+    renewal_host_signature BLOB,
+
+    -- V2StorageProof
+    storage_proof_proof_index BLOB,
+    storage_proof_leaf BLOB,
+    storage_proof_proof BLOB,
+
+    -- V2FileContractFinalization
+    finalization_signature BLOB,
+
+    -- V2FileContractExpiration
+    -- no fields
+
+    UNIQUE(transaction_id, transaction_order)
+);
+CREATE INDEX v2_transaction_file_contract_resolutions_transaction_id_index ON v2_transaction_file_contract_resolutions(transaction_id);
+
 CREATE TABLE v2_transaction_attestations (
 	transaction_id INTEGER REFERENCES v2_transactions(id) ON DELETE CASCADE NOT NULL,
 	transaction_order INTEGER NOT NULL,
@@ -423,7 +455,6 @@ CREATE TABLE v2_last_contract_revision (
     confirmation_index BLOB,
     confirmation_transaction_id BLOB REFERENCES v2_transactions(transaction_id),
 
-    resolution BLOB,
     resolution_index BLOB,
     resolution_transaction_id BLOB REFERENCES v2_transactions(transaction_id),