0x1::TransactionManager
TransactionManager
manages:
prologue
epilogue
epilogue_v2
block_prologue
use 0x1::Account;
use 0x1::Block;
use 0x1::BlockReward;
use 0x1::ChainId;
use 0x1::CoreAddresses;
use 0x1::Epoch;
use 0x1::Errors;
use 0x1::PackageTxnManager;
use 0x1::STC;
use 0x1::Signer;
use 0x1::Timestamp;
use 0x1::Token;
use 0x1::TransactionFee;
use 0x1::TransactionPublishOption;
use 0x1::TransactionTimeout;
use 0x1::Vector;
const EPROLOGUE_ACCOUNT_DOES_NOT_EXIST: u64 = 0;
const EPROLOGUE_BAD_CHAIN_ID: u64 = 6;
const EPROLOGUE_MODULE_NOT_ALLOWED: u64 = 7;
const EPROLOGUE_SCRIPT_NOT_ALLOWED: u64 = 8;
const EPROLOGUE_TRANSACTION_EXPIRED: u64 = 5;
const TXN_PAYLOAD_TYPE_PACKAGE: u8 = 1;
const TXN_PAYLOAD_TYPE_SCRIPT: u8 = 0;
const TXN_PAYLOAD_TYPE_SCRIPT_FUNCTION: u8 = 2;
prologue
The prologue is invoked at the beginning of every transaction It verifies:
public fun prologue<TokenType: store>(account: signer, txn_sender: address, txn_sequence_number: u64, txn_authentication_key_preimage: vector<u8>, txn_gas_price: u64, txn_max_gas_units: u64, txn_expiration_time: u64, chain_id: u8, txn_payload_type: u8, txn_script_or_package_hash: vector<u8>, txn_package_address: address)
public fun prologue<TokenType: store>(
account: signer,
txn_sender: address,
txn_sequence_number: u64,
txn_authentication_key_preimage: vector<u8>,
txn_gas_price: u64,
txn_max_gas_units: u64,
txn_expiration_time: u64,
chain_id: u8,
txn_payload_type: u8,
txn_script_or_package_hash: vector<u8>,
txn_package_address: address,
) {
// Can only be invoked by genesis account
assert!(
Signer::address_of(&account) == CoreAddresses::GENESIS_ADDRESS(),
Errors::requires_address(EPROLOGUE_ACCOUNT_DOES_NOT_EXIST),
);
// Check that the chain ID stored on-chain matches the chain ID
// specified by the transaction
assert!(ChainId::get() == chain_id, Errors::invalid_argument(EPROLOGUE_BAD_CHAIN_ID));
Account::txn_prologue<TokenType>(
&account,
txn_sender,
txn_sequence_number,
txn_authentication_key_preimage,
txn_gas_price,
txn_max_gas_units,
);
assert!(
TransactionTimeout::is_valid_transaction_timestamp(txn_expiration_time),
Errors::invalid_argument(EPROLOGUE_TRANSACTION_EXPIRED),
);
if (txn_payload_type == TXN_PAYLOAD_TYPE_PACKAGE) {
// stdlib upgrade is not affected by PublishOption
if (txn_package_address != CoreAddresses::GENESIS_ADDRESS()) {
assert!(
TransactionPublishOption::is_module_allowed(Signer::address_of(&account)),
Errors::invalid_argument(EPROLOGUE_MODULE_NOT_ALLOWED),
);
};
PackageTxnManager::package_txn_prologue_v2(
&account,
txn_sender,
txn_package_address,
txn_script_or_package_hash,
);
} else if (txn_payload_type == TXN_PAYLOAD_TYPE_SCRIPT) {
assert!(
TransactionPublishOption::is_script_allowed(
Signer::address_of(&account),
),
Errors::invalid_argument(EPROLOGUE_SCRIPT_NOT_ALLOWED),
);
};
// do nothing for TXN_PAYLOAD_TYPE_SCRIPT_FUNCTION
}
aborts_if Signer::address_of(account) != CoreAddresses::GENESIS_ADDRESS();
aborts_if !exists<ChainId::ChainId>(CoreAddresses::GENESIS_ADDRESS());
aborts_if ChainId::get() != chain_id;
aborts_if !exists<Account::Account>(txn_sender);
aborts_if Hash::sha3_256(txn_authentication_key_preimage) != global<Account::Account>(txn_sender).authentication_key;
aborts_if txn_gas_price * txn_max_gas_units > max_u64();
include Timestamp::AbortsIfTimestampNotExists;
include Block::AbortsIfBlockMetadataNotExist;
aborts_if txn_gas_price * txn_max_gas_units > 0 && !exists<Account::Balance<TokenType>>(txn_sender);
aborts_if txn_gas_price * txn_max_gas_units > 0 && StarcoinFramework::Token::spec_token_code<TokenType>() != StarcoinFramework::Token::spec_token_code<STC>();
aborts_if txn_gas_price * txn_max_gas_units > 0 && global<Account::Balance<TokenType>>(txn_sender).token.value < txn_gas_price * txn_max_gas_units;
aborts_if txn_gas_price * txn_max_gas_units > 0 && txn_sequence_number >= max_u64();
aborts_if txn_sequence_number < global<Account::Account>(txn_sender).sequence_number;
aborts_if txn_sequence_number != global<Account::Account>(txn_sender).sequence_number;
include TransactionTimeout::AbortsIfTimestampNotValid;
aborts_if !TransactionTimeout::spec_is_valid_transaction_timestamp(txn_expiration_time);
include TransactionPublishOption::AbortsIfTxnPublishOptionNotExistWithBool {
is_script_or_package: (txn_payload_type == TXN_PAYLOAD_TYPE_PACKAGE || txn_payload_type == TXN_PAYLOAD_TYPE_SCRIPT),
};
aborts_if txn_payload_type == TXN_PAYLOAD_TYPE_PACKAGE && txn_package_address != CoreAddresses::GENESIS_ADDRESS() && !TransactionPublishOption::spec_is_module_allowed(Signer::address_of(account));
aborts_if txn_payload_type == TXN_PAYLOAD_TYPE_SCRIPT && !TransactionPublishOption::spec_is_script_allowed(Signer::address_of(account));
include PackageTxnManager::CheckPackageTxnAbortsIfWithType{is_package: (txn_payload_type == TXN_PAYLOAD_TYPE_PACKAGE), sender:txn_sender, package_address: txn_package_address, package_hash: txn_script_or_package_hash};
epilogue
The epilogue is invoked at the end of transactions. It collects gas and bumps the sequence number
public fun epilogue<TokenType: store>(account: signer, txn_sender: address, txn_sequence_number: u64, txn_gas_price: u64, txn_max_gas_units: u64, gas_units_remaining: u64, txn_payload_type: u8, _txn_script_or_package_hash: vector<u8>, txn_package_address: address, success: bool)
public fun epilogue<TokenType: store>(
account: signer,
txn_sender: address,
txn_sequence_number: u64,
txn_gas_price: u64,
txn_max_gas_units: u64,
gas_units_remaining: u64,
txn_payload_type: u8,
_txn_script_or_package_hash: vector<u8>,
txn_package_address: address,
// txn execute success or fail.
success: bool,
) {
epilogue_v2<TokenType>(account, txn_sender, txn_sequence_number, Vector::empty(), txn_gas_price, txn_max_gas_units, gas_units_remaining, txn_payload_type, _txn_script_or_package_hash, txn_package_address, success)
}
pragma verify = false;
include CoreAddresses::AbortsIfNotGenesisAddress;
aborts_if Signer::address_of(account) != CoreAddresses::SPEC_GENESIS_ADDRESS();
aborts_if !exists<Account::Account>(txn_sender);
aborts_if !exists<Account::Balance<TokenType>>(txn_sender);
aborts_if txn_max_gas_units < gas_units_remaining;
aborts_if txn_sequence_number + 1 > max_u64();
aborts_if txn_gas_price * (txn_max_gas_units - gas_units_remaining) > max_u64();
include PackageTxnManager::AbortsIfPackageTxnEpilogue {
is_package: (txn_payload_type == TXN_PAYLOAD_TYPE_PACKAGE),
package_address: txn_package_address,
success: success,
};
epilogue_v2
The epilogue is invoked at the end of transactions. It collects gas and bumps the sequence number
public fun epilogue_v2<TokenType: store>(account: signer, txn_sender: address, txn_sequence_number: u64, txn_authentication_key_preimage: vector<u8>, txn_gas_price: u64, txn_max_gas_units: u64, gas_units_remaining: u64, txn_payload_type: u8, _txn_script_or_package_hash: vector<u8>, txn_package_address: address, success: bool)
public fun epilogue_v2<TokenType: store>(
account: signer,
txn_sender: address,
txn_sequence_number: u64,
txn_authentication_key_preimage: vector<u8>,
txn_gas_price: u64,
txn_max_gas_units: u64,
gas_units_remaining: u64,
txn_payload_type: u8,
_txn_script_or_package_hash: vector<u8>,
txn_package_address: address,
// txn execute success or fail.
success: bool,
) {
CoreAddresses::assert_genesis_address(&account);
Account::txn_epilogue_v2<TokenType>(
&account,
txn_sender,
txn_sequence_number,
txn_authentication_key_preimage,
txn_gas_price,
txn_max_gas_units,
gas_units_remaining,
);
if (txn_payload_type == TXN_PAYLOAD_TYPE_PACKAGE) {
PackageTxnManager::package_txn_epilogue(
&account,
txn_sender,
txn_package_address,
success,
);
}
}
block_prologue
Set the metadata for the current block and distribute transaction fees and block rewards. The runtime always runs this before executing the transactions in a block.
public fun block_prologue(account: signer, parent_hash: vector<u8>, timestamp: u64, author: address, auth_key_vec: vector<u8>, uncles: u64, number: u64, chain_id: u8, parent_gas_used: u64)
public fun block_prologue(
account: signer,
parent_hash: vector<u8>,
timestamp: u64,
author: address,
auth_key_vec: vector<u8>,
uncles: u64,
number: u64,
chain_id: u8,
parent_gas_used: u64,
) {
// Can only be invoked by genesis account
CoreAddresses::assert_genesis_address(&account);
// Check that the chain ID stored on-chain matches the chain ID
// specified by the transaction
assert!(ChainId::get() == chain_id, Errors::invalid_argument(EPROLOGUE_BAD_CHAIN_ID));
// deal with previous block first.
let txn_fee = TransactionFee::distribute_transaction_fees<STC>(&account);
// then deal with current block.
Timestamp::update_global_time(&account, timestamp);
Block::process_block_metadata(
&account,
parent_hash,
author,
timestamp,
uncles,
number,
);
let reward = Epoch::adjust_epoch(&account, number, timestamp, uncles, parent_gas_used);
// pass in previous block gas fees.
BlockReward::process_block_reward(&account, number, reward, author, auth_key_vec, txn_fee);
}
pragma verify = false;
pragma verify = false;
pragma aborts_if_is_strict = true;