genesis.py

import asyncio

from config import create_config
from hashing import blake2b_hash_link
from ops.account_ops import create_account
from ops.block_ops import save_block, set_latest_block_info, set_earliest_block_info
from ops.data_ops import get_home, make_folder
from ops.log_ops import get_logger
from ops.peer_ops import save_peer, get_public_ip
from ops.sqlite_ops import DbHandler


def create_indexers():
    acc_handler = DbHandler(db_file=f"{get_home()}/index/accounts.db")
    acc_handler.db_execute(query="CREATE TABLE IF NOT EXISTS acc_index(address TEXT, balance INTEGER, produced INTEGER, burned INTEGER)")
    acc_handler.db_execute(query="CREATE INDEX seek_index ON acc_index(address)")

    acc_handler.db_execute(query="CREATE TABLE IF NOT EXISTS totals_index(produced INTEGER, fees INTEGER, burned INTEGER)")
    acc_handler.db_execute("INSERT INTO totals_index VALUES (?,?,?)", (0,0,0,))
    acc_handler.close()

    #tx indexer moved

    block_handler = DbHandler(db_file=f"{get_home()}/index/blocks.db")
    block_handler.db_execute(
        query="CREATE TABLE IF NOT EXISTS block_index(block_hash TEXT, block_number INTEGER UNIQUE)")
    block_handler.db_execute(query="CREATE INDEX IF NOT EXISTS idx_block_hash ON block_index(block_hash)")
    block_handler.db_execute(query="CREATE INDEX IF NOT EXISTS idx_block_number ON block_index(block_number)")
    block_handler.close()


def make_folders():
    make_folder(f"{get_home()}/blocks")
    make_folder(f"{get_home()}/peers", strict=False)
    make_folder(f"{get_home()}/private", strict=False)
    make_folder(f"{get_home()}/index")
    make_folder(f"{get_home()}/index/producer_sets")
    make_folder(f"{get_home()}/index/transactions")

    create_indexers()


def make_genesis(address, balance, ip, port, timestamp, logger):
    config_ip = asyncio.run(get_public_ip(logger=logger))
    create_config(ip=config_ip)

    block_transactions = []
    block_hash = blake2b_hash_link(link_from=timestamp, link_to=block_transactions)

    genesis_block_message = {
        "block_number": 0,
        "parent_hash": None,
        "block_ip": ip,
        "block_creator": address,
        "block_hash": block_hash,
        "block_timestamp": timestamp,
        "block_transactions": block_transactions,
    }

    create_account(address=address, balance=balance)

    save_peer(ip=ip,
              address=address,
              port=port,
              peer_trust=50)

    save_block(block=genesis_block_message,
               logger=logger)

    set_earliest_block_info(earliest_block=genesis_block_message,
                            logger=logger)

    set_latest_block_info(latest_block=genesis_block_message,
                          logger=logger)



if __name__ == "__main__":
    logger = get_logger(file="genesis.log", logger_name="genesis_logger")

    input("Not supposed to be run directly, continue?\n")
    make_folders()
    make_genesis(
        address="ndo18c3afa286439e7ebcb284710dbd4ae42bdaf21b80137b",
        balance=1000000000000000000,
        ip="78.102.98.72",
        port=9173,
        timestamp=1669852800,
        logger=logger,
    )