report

type AppSyncPublisherErrors struct {
	Publish           atomic.Uint64 `json:"publish"`
	PersistentFailure atomic.Uint64 `json:"persistent"`
}

type AppSyncPublisherReport struct {
	State  AppSyncPublisherState  `json:"state"`
	Errors AppSyncPublisherErrors `json:"errors"`
}

type AppSyncPublisherState struct {
	MessagesPublished atomic.Uint64 `json:"messages_published"`
}

type BlockDownloaderErrors struct {
	BlockDownloadErrors   atomic.Int64 `json:"block_download"`
	BlockValidationErrors atomic.Int64 `json:"block_validation"`
}

type BlockDownloaderReport struct {
	State  BlockDownloaderState  `json:"state"`
	Errors BlockDownloaderErrors `json:"errors"`
}

type BlockDownloaderState struct {
	CurrentHeight                   atomic.Int64   `json:"syncer_current_height"`
	BlocksBehind                    atomic.Int64   `json:"syncer_blocks_behind"`
	AverageBlocksProcessedPerMinute atomic.Float64 `json:"average_blocks_processed_per_minute"`
}

type BlockMonitorErrors struct {
	BlockDownloadErrors   atomic.Int64 `json:"block_download"`
	BlockValidationErrors atomic.Int64 `json:"block_validation"`
	TxDownloadErrors      atomic.Int64 `json:"tx_download"`
}

type BlockMonitorReport struct {
	State  BlockMonitorState  `json:"state"`
	Errors BlockMonitorErrors `json:"errors"`
}

type BlockMonitorState struct {
	SyncerCurrentHeight    atomic.Int64  `json:"syncer_current_height"`
	TransactionsDownloaded atomic.Uint64 `json:"transactions_downloaded"`
	SyncerBlocksBehind     atomic.Int64  `json:"syncer_blocks_behind"`

	AverageBlocksProcessedPerMinute       atomic.Float64 `json:"average_blocks_processed_per_minute"`
	AverageTransactionDownloadedPerMinute atomic.Float64 `json:"average_transactions_downloaded_per_minute"`
}

type BundlerErrors struct {
	TurboError                  atomic.Uint64 `json:"turbo_error"`
	TurboMarshalError           atomic.Uint64 `json:"turbo_marshal_error"`
	BundrlError                 atomic.Uint64 `json:"bundrl_error"`
	BundrlMarshalError          atomic.Uint64 `json:"bundrl_marshal_error"`
	ConfirmationsSavedToDbError atomic.Uint64 `json:"confirmations_saved_to_db_error"`
	AdditionalFetchError        atomic.Uint64 `json:"additional_fetch_error"`
	PollerFetchError            atomic.Uint64 `json:"poller_fetch_error"`
}

type BundlerReport struct {
	State  BundlerState  `json:"state"`
	Errors BundlerErrors `json:"errors"`
}

type BundlerState struct {
	// Transactions that are pending, waiting to be bundled in the database
	PendingBundleItems atomic.Int64 `json:"pending_bundle_items"`

	// Counting bundles that come from the database
	BundlesFromNotifications  atomic.Uint64 `json:"bundles_from_notifications"`
	AdditionalFetches         atomic.Uint64 `json:"additional_fetches"`
	BundlesFromSelects        atomic.Uint64 `json:"bundles_from_selects"`
	RetriedBundlesFromSelects atomic.Uint64 `json:"retried_bundles_from_selects"`
	AllBundlesFromDb          atomic.Uint64 `json:"all_bundles_from_db"`

	// Counting bundles sent to bundlr.network
	BundlrSuccess atomic.Uint64 `json:"bundlr_success"`
	TurboSuccess  atomic.Uint64 `json:"turbo_success"`
	AllSuccess    atomic.Uint64 `json:"all_success"`

	// Counting properly saved confirmations that bundle is sent
	ConfirmationsSavedToDb atomic.Uint64 `json:"confirmations_saved_to_db"`
}

type CheckerErrors struct {
	IrysGetStatusError  atomic.Uint64 `json:"irys_check_state_error"`
	TurboGetStatusError atomic.Uint64 `json:"turbo_get_status_error"`
	DbStateUpdateError  atomic.Uint64 `json:"db_state_update_error"`
}

type CheckerReport struct {
	State  CheckerState  `json:"state"`
	Errors CheckerErrors `json:"errors"`
}

type CheckerState struct {
	BundlesTakenFromDb     atomic.Uint64 `json:"bundles_taken_from_db"`
	AllCheckedBundles      atomic.Uint64 `json:"all_checked_bundles"`
	FinishedBundles        atomic.Uint64 `json:"finished_bundles"`
	UnfinishedBundles      atomic.Uint64 `json:"unfinished_bundles"`
	IrysUnfinishedBundles  atomic.Uint64 `json:"irys_unfinished_bundles"`
	TurboUnfinishedBundles atomic.Uint64 `json:"turbo_unfinished_bundles"`
	DbStateUpdated         atomic.Uint64 `json:"db_state_updated"`
}

type ContractorErrors struct {
	DbContractInsert             atomic.Uint64 `json:"db_contract_interaction"`
	DbSourceInsert               atomic.Uint64 `json:"db_source_interaction"`
	DbLastTransactionBlockHeight atomic.Uint64 `json:"db_last_tx_block_height"`
	LoadPersistentContract       atomic.Uint64 `json:"load_persistent_contract"`
	LoadContract                 atomic.Uint64 `json:"load_contract"`
	LoadSource                   atomic.Uint64 `json:"load_source"`
	LoadInitState                atomic.Uint64 `json:"load_init_state"`
}

type ContractorReport struct {
	State  ContractorState  `json:"state"`
	Errors ContractorErrors `json:"errors"`
}

type ContractorState struct {
	FinishedHeight atomic.Uint64 `json:"finished_height"`

	AverageContractsSavedPerMinute atomic.Float64 `json:"average_contracts_saved_per_minute"`
	ContractsSaved                 atomic.Uint64  `json:"contracts_saved"`
}

type EvolverErrors struct {
	StoreDbError            atomic.Uint64 `json:"store_sources_saved_error"`
	PollerFetchError        atomic.Uint64 `json:"poller_fetch_error"`
	DownloaderDownlaodError atomic.Uint64 `json:"downloader_download_error"`
}

type EvolverReport struct {
	State  EvolverState  `json:"state"`
	Errors EvolverErrors `json:"errors"`
}

type EvolverState struct {
	// Counting missing evolved sources
	PollerSourcesFromSelects atomic.Uint64 `json:"poller_sources_from_selects"`

	// Counting evolved sources saved to db
	StoreSourcesSaved atomic.Uint64 `json:"store_sources_saved"`

	// Counting downloaded evolved sources
	DownloaderSourcesLoaded atomic.Uint64 `json:"downloader_sources_loaded"`
}

type ForwarderErrors struct {
	DbLastTransactionBlockHeight atomic.Uint64 `json:"db_last_transaction_block_height"`
	DbFetchL1Interactions        atomic.Uint64 `json:"db_getch_l1_interactions"`
	DbFetchL2Interactions        atomic.Uint64 `json:"db_getch_l2_interactions"`
}

type ForwarderReport struct {
	State  ForwarderState  `json:"state"`
	Errors ForwarderErrors `json:"errors"`
}

type ForwarderState struct {
	FinishedHeight      atomic.Uint64 `json:"finished_height"`
	L1Interactions      atomic.Uint64 `json:"l1_interactions"`
	L2Interactions      atomic.Uint64 `json:"l2_interactions"`
	CurrentSyncerHeight atomic.Uint64 `json:"current_syncer_height"`
	BlocksBehindSyncer  atomic.Uint64 `json:"blocks_behind_syncer"`
}

type GatewayErrors struct {
	DbError atomic.Uint64 `json:"db_error"`
}

type GatewayReport struct {
	State  GatewayState  `json:"state"`
	Errors GatewayErrors `json:"errors"`
}

type GatewayState struct {
	InteractionsReturned atomic.Uint64 `json:"interactions_returned"`
}

type InteractorErrors struct {
	SenderError    atomic.Int64 `json:"sender_error"`
	CheckerDbError atomic.Int64 `json:"checker_db_error"`
}

type InteractorReport struct {
	State  InteractorState  `json:"state"`
	Errors InteractorErrors `json:"errors"`
}

type InteractorState struct {
	CheckerDelay        atomic.Int64 `json:"checker_delay"`
	SenderSentDataItems atomic.Int64 `json:"sender_sent_data_items"`
}

type NetworkInfoErrors struct {
	NetworkInfoDownloadErrors atomic.Uint64 `json:"network_info_download"`
}

type NetworkInfoReport struct {
	State  NetworkInfoState  `json:"state"`
	Errors NetworkInfoErrors `json:"errors"`
}

type NetworkInfoState struct {
	ArweaveCurrentHeight            atomic.Uint64 `json:"arweave_current_height"`
	ArweaveLastNetworkInfoTimestamp atomic.Uint64 `json:"arweave_last_network_info_timestamp"`
}

type PeerErrors struct {
	PeerDownloadErrors atomic.Uint64 `json:"peer_download"`
}

type PeerReport struct {
	State  PeerState  `json:"state"`
	Errors PeerErrors `json:"errors"`
}

type PeerState struct {
	PeersBlacklisted atomic.Uint64 `json:"peers_blacklisted"`
	NumPeers         atomic.Uint64 `json:"num_peers"`
}

type RedisPublisherErrors struct {
	Publish           atomic.Uint64 `json:"publish"`
	PersistentFailure atomic.Uint64 `json:"persistent"`
}

type RedisPublisherReport struct {
	State  RedisPublisherState  `json:"state"`
	Errors RedisPublisherErrors `json:"errors"`
}

type RedisPublisherState struct {
	IsConnected                    atomic.Int64  `json:"is_connected"`
	LastSuccessfulMessageTimestamp atomic.Int64  `json:"last_successful_message_timestamp"`
	MessagesPublished              atomic.Uint64 `json:"messages_published"`
	PoolHits                       atomic.Uint32 `json:"pool_hits"`
	PoolIdleConns                  atomic.Uint32 `json:"pool_idle_conns"`
	PoolMisses                     atomic.Uint32 `json:"pool_misses"`
	PoolStaleConns                 atomic.Uint32 `json:"pool_stale_conns"`
	PoolTimeouts                   atomic.Uint32 `json:"pool_timeouts"`
	PoolTotalConns                 atomic.Uint32 `json:"pool_total_conns"`
}

type RelayerErrors struct {
	SequencerPermanentParsingError       atomic.Uint64 `json:"sequencer_permanent_parsing_error"`
	SequencerBlockDownloadError          atomic.Uint64 `json:"sequencer_block_download_error"`
	SequencerPermanentBlockDownloadError atomic.Uint64 `json:"sequencer_permanent_block_download_error"`

	PersistentArweaveFailedParsing atomic.Uint64 `json:"persistent_arweave_failed_parsing"`
	DbError                        atomic.Uint64 `json:"db_error"`
}

type RelayerReport struct {
	State  RelayerState  `json:"state"`
	Errors RelayerErrors `json:"errors"`
}

type RelayerState struct {
	// Source
	SequencerBlocksDownloaded                atomic.Uint64  `json:"sequencer_blocks_downloaded"`
	SequencerBlocksStreamed                  atomic.Uint64  `json:"sequencer_blocks_streamed"`
	SequencerBlocksCatchedUp                 atomic.Uint64  `json:"sequencer_blocks_catched_up"`
	AverageSequencerBlocksProcessedPerMinute atomic.Float64 `json:"average_sequencer_blocks_processed_per_minute"`

	// Decoder
	SequencerTransactionsDecoded atomic.Uint64 `json:"sequencer_transactions_decoded"`

	// Parser
	SequencerTransactionsParsed atomic.Uint64 `json:"sequencer_transactions_parsed"`

	// Store
	ArwaeveFinishedHeight   atomic.Int64  `json:"arweave_finished_height"`
	SequencerFinishedHeight atomic.Int64  `json:"sequencer_finished_height"`
	BundleItemsSaved        atomic.Uint64 `json:"bundle_items_saved"`

	AverageInteractionsSavedPerMinute atomic.Float64 `json:"average_interactions_saved_per_minute"`
	L1InteractionsSaved               atomic.Uint64  `json:"l1_interactions_saved"`
	L2InteractionsSaved               atomic.Uint64  `json:"l2_interactions_saved"`
	InteractionsSaved                 atomic.Uint64  `json:"interactions_saved"`
}

type Report struct {
	Run                   *RunReport                   `json:"run,omitempty"`
	Peer                  *PeerReport                  `json:"peer,omitempty"`
	Syncer                *SyncerReport                `json:"syncer,omitempty"`
	Contractor            *ContractorReport            `json:"contractor,omitempty"`
	Bundler               *BundlerReport               `json:"bundler,omitempty"`
	Sender                *SenderReport                `json:"sender,omitempty"`
	Checker               *CheckerReport               `json:"checker,omitempty"`
	Forwarder             *ForwarderReport             `json:"forwarder,omitempty"`
	Relayer               *RelayerReport               `json:"relayer,omitempty"`
	Gateway               *GatewayReport               `json:"gateway,omitempty"`
	Interactor            *InteractorReport            `json:"interactor,omitempty"`
	NetworkInfo           *NetworkInfoReport           `json:"network_info,omitempty"`
	BlockMonitor          *BlockMonitorReport          `json:"block_monitor,omitempty"`
	BlockDownloader       *BlockDownloaderReport       `json:"block_downloader,omitempty"`
	TransactionDownloader *TransactionDownloaderReport `json:"transaction_downloader,omitempty"`
	RedisPublishers       []RedisPublisherReport       `json:"redis_publishers,omitempty"`
	AppSyncPublisher      *AppSyncPublisherReport      `json:"appsync_publisher,omitempty"`
	Evolver               *EvolverReport               `json:"evolver,omitempty"`
	WarpySyncer           *WarpySyncerReport           `json:"warpy_syncer,omitempty"`
}

type RunErrors struct {
	NumWatchdogRestarts atomic.Uint64 `json:"num_watchdog_restarts"`
}

type RunReport struct {
	State  RunState  `json:"state"`
	Errors RunErrors `json:"errors"`
}

type RunState struct {
	StartTimestamp atomic.Int64  `json:"start_timestamp"`
	UpForSeconds   atomic.Uint64 `json:"up_for_seconds"`
}

type SenderErrors struct {
	TurboError                  atomic.Uint64 `json:"turbo_error"`
	TurboMarshalError           atomic.Uint64 `json:"turbo_marshal_error"`
	IrysError                   atomic.Uint64 `json:"irys_error"`
	IrysMarshalError            atomic.Uint64 `json:"irys_marshal_error"`
	ConfirmationsSavedToDbError atomic.Uint64 `json:"confirmations_saved_to_db_error"`
	AdditionalFetchError        atomic.Uint64 `json:"additional_fetch_error"`
	PollerFetchError            atomic.Uint64 `json:"poller_fetch_error"`
}

type SenderReport struct {
	State  SenderState  `json:"state"`
	Errors SenderErrors `json:"errors"`
}

type SenderState struct {
	// Transactions that are pending, waiting to be bundled in the database
	PendingBundleItems atomic.Int64 `json:"pending_bundle_items"`

	// Counting bundles that come from the database
	BundlesFromNotifications  atomic.Uint64 `json:"bundles_from_notifications"`
	AdditionalFetches         atomic.Uint64 `json:"additional_fetches"`
	BundlesFromSelects        atomic.Uint64 `json:"bundles_from_selects"`
	RetriedBundlesFromSelects atomic.Uint64 `json:"retried_bundles_from_selects"`
	AllBundlesFromDb          atomic.Uint64 `json:"all_bundles_from_db"`

	// Counting bundles sent to bundlr.network
	IrysSuccess  atomic.Uint64 `json:"irys_success"`
	TurboSuccess atomic.Uint64 `json:"turbo_success"`
	AllSuccess   atomic.Uint64 `json:"all_success"`

	// Counting properly saved confirmations that bundle is sent
	ConfirmationsSavedToDb atomic.Uint64 `json:"confirmations_saved_to_db"`
}

type SyncerErrors struct {
	DbInteractionInsert               atomic.Int64 `json:"db_interaction"`
	DbLastTransactionBlockHeightError atomic.Int64 `json:"db_last_tx_block_height"`
}

type SyncerReport struct {
	State  SyncerState  `json:"state"`
	Errors SyncerErrors `json:"errors"`
}

type SyncerState struct {
	FinishedHeight                    atomic.Int64   `json:"finished_height"`
	AverageInteractionsSavedPerMinute atomic.Float64 `json:"average_interactions_saved_per_minute"`
	InteractionsSaved                 atomic.Uint64  `json:"interactions_saved"`
	FailedInteractionParsing          atomic.Uint64  `json:"failed_interaction_parsing"`
}

type TransactionDownloaderErrors struct {
	Download                 atomic.Uint64 `json:"download"`
	DataDownload             atomic.Uint64 `json:"data_download"`
	PermanentDownloadFailure atomic.Uint64 `json:"permanent_download_failure"`
	Validation               atomic.Uint64 `json:"validation"`
}

type TransactionDownloaderReport struct {
	State  TransactionDownloaderState  `json:"state"`
	Errors TransactionDownloaderErrors `json:"errors"`
}

type TransactionDownloaderState struct {
	TransactionsDownloaded                atomic.Uint64  `json:"transactions_downloaded"`
	AverageTransactionDownloadedPerMinute atomic.Float64 `json:"average_transactions_downloaded_per_minute"`
}

type WarpySyncerErrors struct {
	BlockDownloaderFailures              atomic.Uint64 `json:"block_downloader_failures"`
	SyncerDeltaCheckTxFailures           atomic.Uint64 `json:"syncer_delta_check_tx_failures"`
	SyncerDeltaProcessTxPermanentError   atomic.Uint64 `json:"syncer_delta_process_tx_permanent_error"`
	SyncerDepositProcessTxPermanentError atomic.Uint64 `json:"syncer_deposit_process_tx_permanent_error"`
	SyncerDepositCheckTxFailures         atomic.Uint64 `json:"syncer_deposit_check_tx_failures"`
	WriterFailures                       atomic.Uint64 `json:"writer_failures"`
	StoreGetLastStateFailure             atomic.Uint64 `json:"store_get_last_state_failure"`
	StoreSaveLastStateFailure            atomic.Uint64 `json:"store_save_last_state_failure"`
	PollerDepositFetchError              atomic.Uint64 `json:"poller_deposit_fetch_error"`
	StoreDepositFailures                 atomic.Uint64 `json:"store_deposit_failures"`
	AssetsCalculatorFailures             atomic.Uint64 `json:"assets_calculator_failures"`
}

type WarpySyncerReport struct {
	State  WarpySyncerState  `json:"state"`
	Errors WarpySyncerErrors `json:"errors"`
}

type WarpySyncerState struct {
	BlockDownloaderCurrentHeight   atomic.Int64 `json:"block_downloader_current_height"`
	SyncerDeltaTxsProcessed        atomic.Int64 `json:"syncer_delta_txs_processed"`
	SyncerDeltaBlocksProcessed     atomic.Int64 `json:"syncer_delta_blocks_processed"`
	SyncerDepositTxsProcessed      atomic.Int64 `json:"syncer_deposit_txs_processed"`
	SyncerDepositBlocksProcessed   atomic.Int64 `json:"syncer_deposit_blocks_processed"`
	WriterInteractionsToWarpy      atomic.Int64 `json:"writer_interactions_to_warpy"`
	StoreLastSyncedBlockHeight     atomic.Int64 `json:"store_last_synced_block_height"`
	PollerDepositAssetsFromSelects atomic.Int64 `json:"poller_deposit_assets_from_selects"`
	StoreDepositRecordsSaved       atomic.Int64 `json:"store_deposit_records_saved"`
}