queries

Documentation

Index

• Variables

Variables

var (
	FirstUnprocessedBlock = `` /* 510-byte string literal not displayed */

	UnlockBlocksForProcessing = `` /* 153-byte string literal not displayed */

	// TakeXactLock acquires an exclusive lock (with lock ID $1), with custom semantics.
	// The lock is automatically unlocked at the end of the db transaction.
	TakeXactLock = `
    SELECT pg_advisory_xact_lock($1)`

	PickBlocksForProcessing = `` /* 2253-byte string literal not displayed */

	ProcessedSubrangeInfo = `` /* 946-byte string literal not displayed */

	IsBlockProcessedBySlowSync = `` /* 197-byte string literal not displayed */

	SoftEnqueueGapsInProcessedBlocks = `` /* 884-byte string literal not displayed */

	IndexingProgress = `` /* 143-byte string literal not displayed */

	ConsensusNodeHeightUpsert = `` /* 178-byte string literal not displayed */

	ConsensusBlockInsert = `` /* 148-byte string literal not displayed */

	ConsensusEpochUpsert = `` /* 275-byte string literal not displayed */

	ConsensusTransactionInsert = `` /* 200-byte string literal not displayed */

	ConsensusAccountNonceUpsert = `
    INSERT INTO chain.accounts(address, nonce)
    VALUES ($1, $2)
    ON CONFLICT (address) DO UPDATE
      SET nonce = $2`

	ConsensusCommissionsUpsert = `` /* 159-byte string literal not displayed */

	ConsensusEventInsert = `` /* 127-byte string literal not displayed */

	ConsensusAccountRelatedTransactionInsert = `
    INSERT INTO chain.accounts_related_transactions (account_address, tx_block, tx_index)
      VALUES ($1, $2, $3)`

	ConsensusAccountRelatedEventInsert = `` /* 146-byte string literal not displayed */

	ConsensusRuntimeUpsert = `` /* 316-byte string literal not displayed */

	ConsensusRuntimeSuspendedUpdate = `
    UPDATE chain.runtimes
      SET suspended = $2
      WHERE id = $1`

	ConsensusClaimedNodeInsert = `
    INSERT INTO chain.claimed_nodes (entity_id, node_id) VALUES ($1, $2)
      ON CONFLICT (entity_id, node_id) DO NOTHING`

	ConsensusEntityUpsert = `` /* 139-byte string literal not displayed */

	ConsensusNodeUpsert = `` /* 900-byte string literal not displayed */

	ConsensusRuntimeNodesUpsert = `
    INSERT INTO chain.runtime_nodes (runtime_id, node_id) VALUES ($1, $2)
      ON CONFLICT (runtime_id, node_id) DO NOTHING`

	ConsensusRuntimeNodesDelete = `
    DELETE FROM chain.runtime_nodes WHERE node_id = $1`

	ConsensusNodeDelete = `
    DELETE FROM chain.nodes WHERE id = $1`

	ConsensusEntityMetaUpsert = `` /* 138-byte string literal not displayed */

	ConsensusIncreaseGeneralBalanceUpsert = `` /* 180-byte string literal not displayed */

	ConsensusDecreaseGeneralBalanceUpsert = `
    UPDATE chain.accounts
    SET
      general_balance = general_balance - $2
    WHERE address = $1`

	ConsensusAddEscrowBalanceUpsert = `` /* 323-byte string literal not displayed */

	ConsensusAddDelegationsUpsert = `` /* 189-byte string literal not displayed */

	ConsensusTakeEscrowUpdateGuessRatio = `` /* 357-byte string literal not displayed */

	ConsensusTakeEscrowUpdateExact = `` /* 187-byte string literal not displayed */

	ConsensusDebondingStartEscrowBalanceUpdate = `` /* 332-byte string literal not displayed */

	ConsensusDebondingStartDelegationsUpdate = `
    UPDATE chain.delegations
      SET shares = shares - $3
        WHERE delegatee = $1 AND delegator = $2`

	ConsensusDebondingStartDebondingDelegationsInsert = `
    INSERT INTO chain.debonding_delegations (delegatee, delegator, shares, debond_end)
      VALUES ($1, $2, $3, $4)`

	ConsensusReclaimEscrowBalanceUpdate = `` /* 202-byte string literal not displayed */

	// Network upgrades delays debonding by 1 epoch.
	ConsensusDeleteDebondingDelegations = `` /* 267-byte string literal not displayed */

	ConsensusAllowanceChangeDelete = `
    DELETE FROM chain.allowances
      WHERE owner = $1 AND beneficiary = $2`

	ConsensusAllowanceOwnerUpsert = `
    INSERT INTO chain.accounts (address)
      VALUES ($1)
    ON CONFLICT (address) DO NOTHING`

	ConsensusAllowanceChangeUpdate = `` /* 179-byte string literal not displayed */

	ConsensusValidatorNodeResetVotingPowers = `
    UPDATE chain.nodes SET voting_power = 0`

	ConsensusValidatorNodeUpdateVotingPower = `
    UPDATE chain.nodes SET voting_power = $2
      WHERE id = $1`

	ConsensusCommitteeMemberInsert = `
    INSERT INTO chain.committee_members (node, valid_for, runtime, kind, role)
      VALUES ($1, $2, $3, $4, $5)`

	ConsensusCommitteeMembersTruncate = `
    TRUNCATE chain.committee_members`

	ConsensusProposalSubmissionInsert = `` /* 230-byte string literal not displayed */

	ConsensusProposalSubmissionCancelInsert = `` /* 138-byte string literal not displayed */

	ConsensusProposalExecutionsUpdate = `
    UPDATE chain.proposals
    SET executed = true
      WHERE id = $1`

	ConsensusProposalUpdate = `
    UPDATE chain.proposals
    SET state = $2
      WHERE id = $1`

	ConsensusProposalInvalidVotesUpdate = `
    UPDATE chain.proposals
    SET invalid_votes = $2
      WHERE id = $1`

	ConsensusVoteUpsert = `` /* 153-byte string literal not displayed */

	RuntimeBlockInsert = `` /* 261-byte string literal not displayed */

	RuntimeTransactionSignerInsert = `` /* 152-byte string literal not displayed */

	RuntimeRelatedTransactionInsert = `` /* 128-byte string literal not displayed */

	RuntimeAccountNumTxsUpsert = `` /* 193-byte string literal not displayed */

	// Recomputes the number of related transactions for all runtime account in runtime $1.
	// Inteded for use after fast-sync that ran up to height $2 (inclusive).
	RuntimeAccountNumTxsRecompute = `` /* 422-byte string literal not displayed */

	RuntimeTransactionInsert = `` /* 516-byte string literal not displayed */

	RuntimeEventInsert = `` /* 241-byte string literal not displayed */

	RuntimeMintInsert = `` /* 131-byte string literal not displayed */

	RuntimeBurnInsert = `` /* 131-byte string literal not displayed */

	RuntimeTransferInsert = `` /* 129-byte string literal not displayed */

	RuntimeNativeBalanceUpdate = `` /* 236-byte string literal not displayed */

	AddressPreimageInsert = `` /* 158-byte string literal not displayed */

	RuntimeEVMContractInsert = `` /* 130-byte string literal not displayed */

	RuntimeEVMContractRuntimeBytecodeUpsert = `` /* 189-byte string literal not displayed */

	RuntimeAccountGasForCallingUpsert = `` /* 214-byte string literal not displayed */

	// Recomputes the total gas used for calling every runtime contract in runtime $1.
	// Inteded for use after fast-sync that ran up to height $2 (inclusive).
	RuntimeAccountGasForCallingRecompute = `` /* 546-byte string literal not displayed */

	RuntimeEVMContractCodeAnalysisInsert = `` /* 149-byte string literal not displayed */

	RuntimeEVMContractCodeAnalysisSetIsContract = `
    UPDATE analysis.evm_contract_code
    SET is_contract = $3
    WHERE runtime = $1 AND contract_candidate = $2`

	RuntimeEVMContractCodeAnalysisStale = `` /* 612-byte string literal not displayed */

	RuntimeEVMContractCodeAnalysisStaleCount = `` /* 176-byte string literal not displayed */

	RuntimeEVMTokenBalanceUpdate = `` /* 248-byte string literal not displayed */

	RuntimeEVMTokenBalanceAnalysisUpsert = `` /* 274-byte string literal not displayed */

	RuntimeEVMTokenAnalysisStale = `` /* 616-byte string literal not displayed */

	RuntimeEVMTokenAnalysisStaleCount = `` /* 202-byte string literal not displayed */

	// Upserts a new EVM token, but the column values are treated as deltas (!) to the existing values.
	// NOTE: Passing a 0 for last_mutate round causes that field to not be updated, effectively signalling
	//       "this upsert does not create a need for a subsequent download of info from the EVM runtime".
	RuntimeEVMTokenDeltaUpsert = `` /* 366-byte string literal not displayed */

	// Upserts a new EVM token with information that was downloaded from the EVM runtime (as opposed to dead-reckoned).
	RuntimeEVMTokenDownloadedUpsert = `` /* 503-byte string literal not displayed */

	// Updates the total_supply of an EVM token with information that was downloaded from the EVM runtime (as opposed to dead-reckoned).
	RuntimeEVMTokenDownloadedTotalSupplyUpdate = `
    UPDATE chain.evm_tokens
    SET
      total_supply = $3
    WHERE
      runtime = $1 AND
      token_address = $2`

	// Updates the last_download_round of an EVM token.
	RuntimeEVMTokenDownloadRoundUpdate = `
    UPDATE chain.evm_tokens
    SET
      last_download_round = $3
    WHERE
      runtime = $1 AND
      token_address = $2`

	RuntimeEVMNFTUpdate = `` /* 277-byte string literal not displayed */

	RuntimeEVMNFTUpsert = `` /* 350-byte string literal not displayed */

	RuntimeEVMNFTAnalysisStale = `` /* 950-byte string literal not displayed */

	RuntimeEVMNFTAnalysisStaleCount = `` /* 170-byte string literal not displayed */

	RuntimeEVMTokenBalanceAnalysisStale = fmt.Sprintf(`
    WITH
    max_processed_round AS (
      SELECT MAX(height) AS height
      FROM analysis.processed_blocks
      WHERE analyzer = ($1::runtime)::text AND processed_time IS NOT NULL
    ),

    stale_evm_tokens AS (
      SELECT
        balance_analysis.token_address,
        balance_analysis.account_address,
        evm_tokens.token_type,
        COALESCE(evm_token_balances.balance, 0) AS balance, -- evm_token_balances entry can be absent in fast-sync mode
        token_preimage.context_identifier,
        token_preimage.context_version,
        token_preimage.address_data,
        account_preimage.context_identifier,
        account_preimage.context_version,
        account_preimage.address_data,
        max_processed_round.height AS download_round
      FROM max_processed_round,
      analysis.evm_token_balances AS balance_analysis
      -- No LEFT JOIN; we need to know the token's type to query its balance.
      -- We do not exclude tokens with type=0 (unsupported) so that we can move them off the DB index of stale tokens.
      JOIN chain.evm_tokens USING (runtime, token_address)
      LEFT JOIN chain.evm_token_balances USING (runtime, token_address, account_address)
      LEFT JOIN chain.address_preimages AS token_preimage ON
        token_preimage.address = balance_analysis.token_address
      LEFT JOIN chain.address_preimages AS account_preimage ON
        account_preimage.address = balance_analysis.account_address
      WHERE
        evm_tokens.token_type IS NOT NULL AND
        balance_analysis.runtime = $1 AND
        (
          balance_analysis.last_download_round IS NULL OR
          balance_analysis.last_mutate_round > balance_analysis.last_download_round
        )
    ),

    stale_native_tokens AS (
      SELECT
        balance_analysis.token_address,
        balance_analysis.account_address,
        %d AS token_type,
        COALESCE(balances.balance, 0) AS balance,
        '' AS token_context_identifier,
        -1 AS token_context_version,
        ''::BYTEA AS token_address_data,
        account_preimage.context_identifier,
        account_preimage.context_version,
        account_preimage.address_data,
        max_processed_round.height AS download_round
      FROM max_processed_round,
      analysis.evm_token_balances AS balance_analysis
      LEFT JOIN chain.runtime_sdk_balances AS balances ON (
        balances.runtime = balance_analysis.runtime AND
        balances.account_address = balance_analysis.account_address AND
        balances.symbol = $2
      )
      LEFT JOIN chain.address_preimages AS account_preimage ON
        account_preimage.address = balance_analysis.account_address
      WHERE
        balance_analysis.runtime = $1 AND
        balance_analysis.token_address = '%s' AND  -- Native token "address"
        (
          balance_analysis.last_download_round IS NULL OR
          balance_analysis.last_mutate_round > balance_analysis.last_download_round
        )
    )

    SELECT * FROM (
      SELECT * FROM stale_evm_tokens
      UNION ALL
      SELECT * FROM stale_native_tokens
    ) foo LIMIT $3`,
		common.TokenTypeNative,
		evm.NativeRuntimeTokenAddress,
	)

	RuntimeEVMTokenBalanceAnalysisStaleCount = `` /* 288-byte string literal not displayed */

	RuntimeEVMTokenBalanceAnalysisUpdate = `` /* 167-byte string literal not displayed */

	RuntimeEVMUnverfiedContracts = `` /* 399-byte string literal not displayed */

	RuntimeEVMVerifyContractUpdate = `` /* 226-byte string literal not displayed */

)