from sanic import response
from base58 import b58encode, b58decode
from app.core._secrets import hot_pubkey, service_wallet, hot_seed
from app.core._blockchain.ton.platform import platform
from datetime import datetime, timedelta
from app.core.logger import make_log
from app.core._crypto.signer import Signer
import subprocess
import json


def get_git_info():
    branch_name = subprocess.check_output(["git", "branch", "--show-current"]).decode('utf-8').strip()
    commit_hash = subprocess.check_output(["git", "rev-parse", "HEAD"]).decode('utf-8').strip()
    return branch_name, commit_hash


async def s_api_v1_node(request):  # /api/v1/node
    return response.json({
        'id': b58encode(hot_pubkey).decode(),
        'node_address': service_wallet.address.to_string(1, 1, 1),
        'master_address': platform.address.to_string(1, 1, 1),
        'indexer_height': 0,
        'services': {
            service_key: {
                'status': service['status'],
                'delay': round((datetime.now() - service['timestamp']).total_seconds(), 3) if service['timestamp'] else -1,
            }
            for service_key, service in request.app.ctx.memory.known_states.items()
        }
    })


async def s_api_system_send_status(request):
    if not request.json:
        return response.json({'error': 'No data'}, status=400)

    message = request.json.get('message', '')
    signature = request.json.get('signature', '')
    if not message or not signature:
        return response.json({'error': 'No message or signature'}, status=400)

    message = b58decode(message)

    signer = Signer(hot_seed)
    if not signer.verify(message, signature):
        return response.json({'error': 'Invalid signature'}, status=400)

    message = json.loads(message)
    request.app.ctx.memory.known_states[
        message['service']
    ] = {
        'status': message['status'],
        'timestamp': datetime.now(),
    }
    make_log("Health", f"Service {message['service']} status: {message['status']}", level='info')
    return response.json({'message': 'Status received'})


async def s_api_system_version(request):
    branch_name, commit_hash = get_git_info()
    return response.json({
        "codebase_hash": commit_hash,
        "codebase_branch": branch_name,
    })