From d4e6eecb5d5024e567efc7505d52b6432a4efb1c Mon Sep 17 00:00:00 2001 From: i-norden Date: Thu, 13 Apr 2023 12:31:11 -0500 Subject: [PATCH] missing upsert clause for schema.TableIPLDBlock --- statediff/builder.go | 4 ++-- statediff/indexer/shared/schema/schema.go | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/statediff/builder.go b/statediff/builder.go index eca144d65..f16d71122 100644 --- a/statediff/builder.go +++ b/statediff/builder.go @@ -71,9 +71,9 @@ func StorageNodeAppender(nodes *[]types2.StorageLeafNode) types2.StorageNodeSink return nil } } -func IPLDMappingAppender(codeAndCodeHashes *[]types2.IPLD) types2.IPLDSink { +func IPLDMappingAppender(iplds *[]types2.IPLD) types2.IPLDSink { return func(c types2.IPLD) error { - *codeAndCodeHashes = append(*codeAndCodeHashes, c) + *iplds = append(*iplds, c) return nil } } diff --git a/statediff/indexer/shared/schema/schema.go b/statediff/indexer/shared/schema/schema.go index 151672790..b5bda6eec 100644 --- a/statediff/indexer/shared/schema/schema.go +++ b/statediff/indexer/shared/schema/schema.go @@ -23,6 +23,7 @@ var TableIPLDBlock = Table{ {Name: "key", Type: Dtext}, {Name: "data", Type: Dbytea}, }, + UpsertClause: OnConflict("block_number", "key"), } var TableNodeInfo = Table{