fix: align the pkey in model to real database schema

model/actordumps/fevm_actor_dump.go

@@ -15,7 +15,7 @@ type FEVMActorDump struct {
 	// Height message was executed at.
 	Height int64 `pg:",pk,notnull,use_zero"`
 	// Actor address.
-	ActorID string `pg:",notnull"`
+	ActorID string `pg:",pk,notnull"`
 	// Actor Address in ETH.
 	EthAddress string `pg:",notnull"`
 	// Contract Bytecode.
@@ -25,7 +25,7 @@ type FEVMActorDump struct {
 	// Balance of EVM actor in attoFIL.
 	Balance string `pg:"type:numeric,notnull"`
 	// The next actor nonce that is expected to appear on chain.
-	Nonce uint64 `pg:",use_zero"`
+	Nonce uint64 `pg:",pk,use_zero"`
 	// Actor Name
 	ActorName string `pg:",notnull"`
 }

model/actors/market/dealstate.go

@@ -13,11 +13,11 @@ import (
 type MarketDealState struct {
 	Height           int64  `pg:",pk,notnull,use_zero"`
 	DealID           uint64 `pg:",pk,use_zero"`
-	SectorStartEpoch int64  `pg:",pk,use_zero"`
-	LastUpdateEpoch  int64  `pg:",pk,use_zero"`
-	SlashEpoch       int64  `pg:",pk,use_zero"`
+	SectorStartEpoch int64  `pg:",use_zero"`
+	LastUpdateEpoch  int64  `pg:",use_zero"`
+	SlashEpoch       int64  `pg:",use_zero"`
 
-	StateRoot string `pg:",notnull"`
+	StateRoot string `pg:",pk,notnull"`
 }
 
 func (ds *MarketDealState) Persist(ctx context.Context, s model.StorageBatch, _ model.Version) error {

model/blocks/drand.go

@@ -29,7 +29,7 @@ type DrandBlockEntrie struct {
 	// Round is the round number of randomness used.
 	Round uint64 `pg:",pk,use_zero"`
 	// Block is the CID of the block.
-	Block string `pg:",notnull"`
+	Block string `pg:",pk,notnull"`
 }
 
 func (dbe *DrandBlockEntrie) Persist(ctx context.Context, s model.StorageBatch, _ model.Version) error {

model/blocks/parent.go

@@ -14,7 +14,7 @@ import (
 type BlockParent struct {
 	Height int64  `pg:",pk,notnull,use_zero"`
 	Block  string `pg:",pk,notnull"`
-	Parent string `pg:",notnull"`
+	Parent string `pg:",pk,notnull"`
 }
 
 func (bp *BlockParent) Persist(ctx context.Context, s model.StorageBatch, _ model.Version) error {

model/chain/economics.go

@@ -15,7 +15,7 @@ import (
 type ChainEconomics struct {
 	tableName           struct{} `pg:"chain_economics"` // nolint: structcheck
 	Height              int64    `pg:",pk,notnull,use_zero"`
-	ParentStateRoot     string   `pg:",notnull"`
+	ParentStateRoot     string   `pg:",pk,notnull"`
 	CirculatingFil      string   `pg:"type:numeric,notnull"`
 	VestedFil           string   `pg:"type:numeric,notnull"`
 	MinedFil            string   `pg:"type:numeric,notnull"`

model/fevm/contract.go

@@ -15,7 +15,7 @@ type FEVMContract struct {
 	// Height message was executed at.
 	Height int64 `pg:",pk,notnull,use_zero"`
 	// Actor address.
-	ActorID string `pg:",notnull"`
+	ActorID string `pg:",pk,notnull"`
 	// Actor Address in ETH.
 	EthAddress string `pg:",notnull"`
 	// Contract Bytecode.
@@ -25,7 +25,7 @@ type FEVMContract struct {
 	// Balance of EVM actor in attoFIL.
 	Balance string `pg:"type:numeric,notnull"`
 	// The next actor nonce that is expected to appear on chain.
-	Nonce uint64 `pg:",use_zero"`
+	Nonce uint64 `pg:",pk,use_zero"`
 }
 
 func (f *FEVMContract) Persist(ctx context.Context, s model.StorageBatch, _ model.Version) error {

model/fevm/receipt.go

@@ -17,7 +17,7 @@ type FEVMReceipt struct {
 	// Message CID
 	Message string `pg:",use_zero"`
 	// Hash of transaction.
-	TransactionHash string `pg:",notnull"`
+	TransactionHash string `pg:",pk,notnull"`
 	// Integer of the transactions index position in the block.
 	TransactionIndex uint64 `pg:",use_zero"`
 	// Hash of the block where this transaction was in.

model/messages/vm.go

@@ -40,7 +40,7 @@ type VMMessage struct {
 	// Returns value of message receipt.
 	Returns string `pg:",type:jsonb"`
 	// Index indicating the order of the messages execution.
-	Index uint64 `pg:",notnull,use_zero"`
+	Index uint64 `pg:",pk,notnull,use_zero"`
 }
 
 func (v *VMMessage) Persist(ctx context.Context, s model.StorageBatch, _ model.Version) error {

schemas/v1/35_add_pkey_for_tables.go

@@ -0,0 +1,12 @@
+package v1
+
+func init() {
+	patches.Register(
+		35,
+		`
+		ALTER TABLE ONLY {{ .SchemaName | default "public"}}.drand_block_entries ADD CONSTRAINT drand_block_entries_pkey PRIMARY KEY (round, block);
+
+		ALTER TABLE {{ .SchemaName | default "public"}}.vm_messages DROP CONSTRAINT IF EXISTS vm_messages_pkey CASCADE, ADD PRIMARY KEY(height, state_root, cid, source, index)
+`,
+	)
+}