Fix: hasura

cmd/mempool/models/ballot.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // Ballot -
 type Ballot struct {
-	bun.BaseModel `bun:"ballots" comment:"ballot operation - is used to vote for a proposal in a given voting cycle."`
+	bun.BaseModel `bun:"table:ballots" comment:"ballot operation - is used to vote for a proposal in a given voting cycle."`
 	MempoolOperation
 	Period int64  `comment:"Voting period index, starting from zero, for which the ballot was submitted." json:"period"`
 	Ballot string `comment:"Vote, given in the ballot (yay, nay, or pass)."                               json:"ballot"`

cmd/mempool/models/delegation.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // Delegation -
 type Delegation struct {
-	bun.BaseModel `bun:"delegations" comment:"delegation operation - is used to delegate funds to a delegate (an implicit account registered as a baker)."`
+	bun.BaseModel `bun:"table:delegations" comment:"delegation operation - is used to delegate funds to a delegate (an implicit account registered as a baker)."`
 	MempoolOperation
 	Fee          int64  `comment:"Fee to a baker, produced block, in which the operation was included."                                                    json:"fee,string"`
 	Counter      int64  `bun:",pk"                                                                                                                         comment:"An account nonce which is used to prevent operation replay." json:"counter,string"`

cmd/mempool/models/double_baking.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // DoubleBaking -
 type DoubleBaking struct {
-	bun.BaseModel `bun:"double_bakings" comment:"double_baking operation - is used by bakers to provide evidence of double baking (baking two different blocks at the same height) by a baker."`
+	bun.BaseModel `bun:"table:double_bakings" comment:"double_baking operation - is used by bakers to provide evidence of double baking (baking two different blocks at the same height) by a baker."`
 
 	MempoolOperation
 	Bh1 DoubleBakingInfo `bun:"-" json:"bh1"`

cmd/mempool/models/double_endorsing.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // DoubleEndorsing -
 type DoubleEndorsing struct {
-	bun.BaseModel `bun:"double_endorsings" comment:"double_endorsing operation - is used by bakers to provide evidence of double endorsement (endorsing two different blocks at the same block height) by a baker."`
+	bun.BaseModel `bun:"table:double_endorsings" comment:"double_endorsing operation - is used by bakers to provide evidence of double endorsement (endorsing two different blocks at the same block height) by a baker."`
 
 	MempoolOperation
 	Op1Kind  string `bun:"op1_kind"  comment:"Kind of the first operation."                                                            json:"-"`

cmd/mempool/models/double_preendorsing.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // DoublePreendorsing -
 type DoublePreendorsing struct {
-	bun.BaseModel `bun:"double_preendorsings"`
+	bun.BaseModel `bun:"table:double_preendorsings"`
 
 	MempoolOperation
 	Op1Kind  string `bun:"op1_kind"  comment:"Kind of the first operation."                                                            json:"-"`

cmd/mempool/models/drain_delegate.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // DelegateDrain -
 type DelegateDrain struct {
-	bun.BaseModel `bun:"drain_delegate"`
+	bun.BaseModel `bun:"table:drain_delegate"`
 
 	MempoolOperation
 	ConsensusKey int64  `comment:"Consensus key that was used to sign Drain." json:"consensus_key"`

cmd/mempool/models/gas_stats.go

@@ -9,7 +9,7 @@ import (
 
 // GasStats -
 type GasStats struct {
-	bun.BaseModel `bun:"gas_stats"`
+	bun.BaseModel `bun:"table:gas_stats"`
 
 	Network        string `bun:",pk"                                                                            comment:"Identifies belonging network." json:"network"`
 	Hash           string `bun:",pk"                                                                            comment:"Hash of the operation."        json:"hash"`

cmd/mempool/models/increase_paid_storage.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // IncreasePaidStorage -
 type IncreasePaidStorage struct {
-	bun.BaseModel `bun:"increase_paid_storage"`
+	bun.BaseModel `bun:"table:increase_paid_storage"`
 
 	MempoolOperation
 }

cmd/mempool/models/mempool_operation.go

@@ -73,9 +73,11 @@ func SetInChain(ctx context.Context, db bun.IDB, network, hash, kind string, lev
 	}
 
 	if _, err := db.NewUpdate().Model(model).
-		Set("status = ?, level = ?, errors = NULL", StatusInChain, level).
 		Where("hash = ?", hash).
 		Where("network = ?", network).
+		Set("status = ?", StatusInChain).
+		Set("level = ?", level).
+		Set("errors = NULL").
 		Exec(ctx); err != nil {
 		if errors.Is(err, sql.ErrNoRows) {
 			return nil

cmd/mempool/models/nonce_revelation.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // NonceRevelation -
 type NonceRevelation struct {
-	bun.BaseModel `bun:"nonce_revelations" comment:"nonce_revelation operation - are used by the blockchain to create randomness."`
+	bun.BaseModel `bun:"table:nonce_revelations" comment:"nonce_revelation operation - are used by the blockchain to create randomness."`
 	MempoolOperation
 	Level int    `comment:"The height of the block from the genesis block, in which the operation was included." json:"level"`
 	Nonce string `comment:"Seed nonce hex."                                                                      json:"nonce"`

cmd/mempool/models/origination.go

@@ -8,7 +8,7 @@ import (
 
 // Origination -
 type Origination struct {
-	bun.BaseModel `bun:"originations" comment:"origination - deployment / contract creation operation."`
+	bun.BaseModel `bun:"table:originations" comment:"origination - deployment / contract creation operation."`
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`
 	Counter      int64  `bun:",pk"                                                                                    comment:"An account nonce which is used to prevent operation replay." json:"counter,string"`

cmd/mempool/models/preendorsement.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // Preendorsement -
 type Preendorsement struct {
-	bun.BaseModel `bun:"preendorsements"`
+	bun.BaseModel `bun:"table:preendorsements"`
 	MempoolOperation
 }
 

cmd/mempool/models/proposal.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // Proposal -
 type Proposal struct {
-	bun.BaseModel `bun:"proposals" comment:"proposal operation - is used by bakers (delegates) to submit and/or upvote proposals to amend the protocol."`
+	bun.BaseModel `bun:"table:proposals" comment:"proposal operation - is used by bakers (delegates) to submit and/or upvote proposals to amend the protocol."`
 	MempoolOperation
 	Period    int64  `comment:"Voting period index (starting from zero) for which the proposal was submitted (upvoted)." json:"period"`
 	Proposals string `bun:"proposals"                                                                                    comment:"Information about the submitted (upvoted) proposal." json:"proposal"`

cmd/mempool/models/register_global_constant.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // RegisterGlobalConstant -
 type RegisterGlobalConstant struct {
-	bun.BaseModel `bun:"register_global_constant" comment:"register_constant operation - is used to register a global constant - Micheline expression that can be reused by multiple smart contracts."`
+	bun.BaseModel `bun:"table:register_global_constant" comment:"register_constant operation - is used to register a global constant - Micheline expression that can be reused by multiple smart contracts."`
 	MempoolOperation
 	Source       string `comment:"Address of the account who has sent the operation."                                 json:"source"`
 	Fee          string `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee"`

cmd/mempool/models/reveal.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // Reveal -
 type Reveal struct {
-	bun.BaseModel `bun:"reveals" comment:"reveal operation - is used to reveal the public key associated with an account."`
+	bun.BaseModel `bun:"table:reveals" comment:"reveal operation - is used to reveal the public key associated with an account."`
 	MempoolOperation
 	Source       string `comment:"Address of the account who has sent the operation."                                 index:"reveal_source_idx"                                             json:"source"`
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/set_deposits_limit.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SetDepositsLimit -
 type SetDepositsLimit struct {
-	bun.BaseModel `bun:"set_deposits_limit"`
+	bun.BaseModel `bun:"table:set_deposits_limit"`
 
 	MempoolOperation
 	Fee          int64   `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_add_message.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SetDepositsLimit -
 type SmartRollupAddMessage struct {
-	bun.BaseModel `bun:"sr_add_messages"`
+	bun.BaseModel `bun:"table:sr_add_messages"`
 
 	MempoolOperation
 	Fee          int64    `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_cement.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupCement -
 type SmartRollupCement struct {
-	bun.BaseModel `bun:"sr_cement"`
+	bun.BaseModel `bun:"table:sr_cement"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_execute.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupExecute -
 type SmartRollupExecute struct {
-	bun.BaseModel `bun:"sr_execute"`
+	bun.BaseModel `bun:"table:sr_execute"`
 
 	MempoolOperation
 	Fee                int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_originate.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupOriginate -
 type SmartRollupOriginate struct {
-	bun.BaseModel `bun:"sr_originate"`
+	bun.BaseModel `bun:"table:sr_originate"`
 
 	MempoolOperation
 	Fee              int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_publish.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupPublish -
 type SmartRollupPublish struct {
-	bun.BaseModel `bun:"sr_publish"`
+	bun.BaseModel `bun:"table:sr_publish"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_recover_bond.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupRecoverBond -
 type SmartRollupRecoverBond struct {
-	bun.BaseModel `bun:"sr_recover_bond"`
+	bun.BaseModel `bun:"table:sr_recover_bond"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_refute.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupRefute -
 type SmartRollupRefute struct {
-	bun.BaseModel `bun:"sr_refute"`
+	bun.BaseModel `bun:"table:sr_refute"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/sr_timeout.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // SmartRollupTimeout -
 type SmartRollupTimeout struct {
-	bun.BaseModel `bun:"sr_timeout"`
+	bun.BaseModel `bun:"table:sr_timeout"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/transaction.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // Transaction -
 type Transaction struct {
-	bun.BaseModel `bun:"transactions"`
+	bun.BaseModel `bun:"table:transactions"`
 
 	MempoolOperation
 	Source       string `comment:"Address of the account who has sent the operation."                                 index:"transaction_source_idx"                                                                   json:"source"`

cmd/mempool/models/transfer_ticket.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TransferTicket -
 type TransferTicket struct {
-	bun.BaseModel `bun:"transfer_ticket"`
+	bun.BaseModel `bun:"table:transfer_ticket"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_commit.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupCommit -
 type TxRollupCommit struct {
-	bun.BaseModel `bun:"tx_rollup_commit"`
+	bun.BaseModel `bun:"table:tx_rollup_commit"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_dispatch_tickets.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupDispatchTickets -
 type TxRollupDispatchTickets struct {
-	bun.BaseModel `bun:"tx_rollup_dispatch_tickets"`
+	bun.BaseModel `bun:"table:tx_rollup_dispatch_tickets"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_finalize_commitment.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupFinalizeCommitment -
 type TxRollupFinalizeCommitment struct {
-	bun.BaseModel `bun:"tx_rollup_finalize_commitment"`
+	bun.BaseModel `bun:"table:tx_rollup_finalize_commitment"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_origination.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupOrigination -
 type TxRollupOrigination struct {
-	bun.BaseModel `bun:"tx_rollup_origination"`
+	bun.BaseModel `bun:"table:tx_rollup_origination"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_rejection.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupRejection -
 type TxRollupRejection struct {
-	bun.BaseModel `bun:"tx_rollup_rejection"`
+	bun.BaseModel `bun:"table:tx_rollup_rejection"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_remove_commitment.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupRemoveCommitment -
 type TxRollupRemoveCommitment struct {
-	bun.BaseModel `bun:"tx_rollup_remove_commitment"`
+	bun.BaseModel `bun:"table:tx_rollup_remove_commitment"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_return_bond.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupReturnBond -
 type TxRollupReturnBond struct {
-	bun.BaseModel `bun:"tx_rollup_return_bond"`
+	bun.BaseModel `bun:"table:tx_rollup_return_bond"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/tx_rollup_submit_batch.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // TxRollupSubmitBatch -
 type TxRollupSubmitBatch struct {
-	bun.BaseModel `bun:"tx_rollup_submit_batch"`
+	bun.BaseModel `bun:"table:tx_rollup_submit_batch"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/update_consensus_key.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // UpdateConsensusKey -
 type UpdateConsensusKey struct {
-	bun.BaseModel `bun:"update_consensus_key"`
+	bun.BaseModel `bun:"table:update_consensus_key"`
 
 	MempoolOperation
 	Fee          int64  `comment:"Fee to the baker, produced block, in which the operation was included (micro tez)." json:"fee,string"`

cmd/mempool/models/vdf_revelation.go

@@ -4,7 +4,7 @@ import "github.com/uptrace/bun"
 
 // VdfRevelation -
 type VdfRevelation struct {
-	bun.BaseModel `bun:"vdf_revelation"`
+	bun.BaseModel `bun:"table:vdf_revelation"`
 
 	MempoolOperation
 }

go.mod

@@ -5,7 +5,7 @@ go 1.21
 require (
 	github.com/btcsuite/btcutil v1.0.2
 	github.com/dipdup-io/workerpool v0.0.4
-	github.com/dipdup-net/go-lib v0.3.5
+	github.com/dipdup-net/go-lib v0.3.6
 	github.com/grafana/pyroscope-go v1.0.4
 	github.com/json-iterator/go v1.1.12
 	github.com/karlseguin/ccache v2.0.3+incompatible

go.sum

@@ -56,8 +56,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dipdup-io/workerpool v0.0.4 h1:m58fuFY3VIPRc+trWpjw2Lsm4FvIgtjP/4VRe79r+/s=
 github.com/dipdup-io/workerpool v0.0.4/go.mod h1:m6YMqx7M+fORTyabHD/auKymBRpbDax0t1aPZ1i7GZA=
-github.com/dipdup-net/go-lib v0.3.5 h1:UTH3mywL0Euyq/myFJwzbg7OPy5v9zhLa8gSCiHALLE=
-github.com/dipdup-net/go-lib v0.3.5/go.mod h1:oBDOSsM/F8fEnmuDnaJ6QA/cHH4lne49ASbsh8WXDe4=
+github.com/dipdup-net/go-lib v0.3.6 h1:ctas0AYDgN8gfKLvrIgRsMHqvH6wwmKJaNoEWA8YtrM=
+github.com/dipdup-net/go-lib v0.3.6/go.mod h1:UibJawy7ILP3jD+vG3ebNiRjv05+G6Wuv2HmGqaadTA=
 github.com/docker/distribution v2.8.2+incompatible h1:T3de5rq0dB1j30rp0sA2rER+m322EBzniBPB6ZIzuh8=
 github.com/docker/distribution v2.8.2+incompatible/go.mod h1:J2gT2udsDAN96Uj4KfcMRqY0/ypR+oyYUYmja8H+y+w=
 github.com/docker/docker v24.0.5+incompatible h1:WmgcE4fxyI6EEXxBRxsHnZXrO1pQ3smi0k/jho4HLeY=