["0xe1288759446298f250c3bce5616706d25525ba7f"]{"snippet": "def committee_init(info, args):\n assert args['f'] == 'committee_init'\n sender = info['sender']\n addr = handle_lookup(sender)\n committee_members, _ = get('committee', 'members', [])\n assert not committee_members\n put(addr, 'committee', 'members', [addr])\n event('CommitteeInit', [addr])\n\n\ndef committee_add_member(info, args):\n assert args['f'] == 'committee_add_member'\n sender = info['sender']\n addr = handle_lookup(sender)\n committee_members, _ = get('committee', 'members', [])\n committee_members = set(committee_members)\n assert addr in committee_members\n\n user = args['a'][0]\n votes, _ = get('committee', 'proposal_add', [], user)\n votes = set(votes)\n votes.add(addr)\n votes = list(votes)\n event('CommitteeAddVote', [user, addr])\n\n if len(votes) >= len(committee_members) * 2 // 3:\n committee_members.add(user)\n put(addr, 'committee', 'members', list(committee_members))\n event('CommitteeAddMember', [user])\n votes = None\n put(addr, 'committee', 'proposal_add', votes, user)\n\n\ndef committee_remove_member(info, args):\n assert args['f'] == 'committee_remove_member'\n sender = info['sender']\n addr = handle_lookup(sender)\n committee_members, _ = get('committee', 'members', [])\n committee_members = set(committee_members)\n assert addr in committee_members\n\n user = args['a'][0]\n votes, _ = get('committee', 'proposal_remove', [], user)\n votes = set(votes)\n votes.add(addr)\n votes = list(votes)\n event('CommitteeRemoveVote', [user, addr])\n\n if len(votes) >= len(committee_members)*2//3:\n committee_members.remove(user)\n put(addr, 'committee', 'members', list(committee_members))\n event('CommitteeRemoveMember', [user])\n votes = None\n put(addr, 'committee', 'proposal_remove', votes, user)\n", "functions": ["committee_init", "committee_add_member", "committee_remove_member"]}{"functions": ["committee_init", "committee_add_member", "committee_remove_member"], "snippets": ["e5fb2b11848ff75c932891620723b60c8b1c8f3305c5307bf5a90e173d0911bd"], "votes": []}7{"snippets": ["e5fb2b11848ff75c932891620723b60c8b1c8f3305c5307bf5a90e173d0911bd"]}{"snippets": ["e5fb2b11848ff75c932891620723b60c8b1c8f3305c5307bf5a90e173d0911bd"]}{"snippets": ["e5fb2b11848ff75c932891620723b60c8b1c8f3305c5307bf5a90e173d0911bd"]}{"snippet": "def function_snippet(info, args):\n assert args['f'] == 'function_snippet'\n sender = info['sender']\n addr = handle_lookup(sender)\n snippet = args['a'][0]\n snippet_digest = hashlib.sha256(snippet.encode('utf8')).hexdigest()\n put(addr, 'function', 'snippet', {\n 'snippet': snippet,\n 'functions': []\n }, snippet_digest)\n event('NewFunctionSnippet', [snippet_digest])\n\n\ndef function_snippet_clear(info, args):\n assert args['f'] == 'function_snippet_clear'\n sender = info['sender']\n addr = handle_lookup(sender)\n snippet_digest = args['a'][0]\n snippet, _ = get('function', 'snippet', None, snippet_digest)\n assert snippet, \"Snippet not found: %s\" % snippet_digest\n assert snippet['functions'] == [], \"Snippet is not empty: %s\" % snippet\n put(addr, 'function', 'snippet', None, snippet_digest)\n event('RemoveFunctionSnippet', [snippet_digest, True])\n\n\ndef function_proposal(info, args):\n assert args['f'] == 'function_proposal'\n sender = info['sender']\n addr = handle_lookup(sender)\n func_names = args['a'][0]\n snippet_digests = args['a'][1]\n for func_name in func_names:\n assert set(func_name) <= set(string.ascii_lowercase+'_')\n assert not func_name.startswith('_')\n\n snippet_digests = args['a'][1]\n for snippet_digest in snippet_digests:\n assert set(snippet_digest) <= set(string.ascii_lowercase+string.digits)\n assert len(snippet_digest) == 64\n\n proposal_id, _ = get('function', 'proposal_count', 0)\n proposal_id += 1\n put(addr, 'function', 'proposal_count', proposal_id)\n\n put(addr, 'function', 'proposal', {\n 'functions': func_names,\n 'snippets': snippet_digests,\n 'votes': []\n }, '%s' % (proposal_id))\n event('FunctionProposal', [proposal_id, func_names])\n\n\ndef function_vote(info, args):\n assert args['f'] == 'function_vote'\n sender = info['sender']\n addr = handle_lookup(sender)\n committee_members, _ = get('committee', 'members', [])\n committee_members = set(committee_members)\n assert addr in committee_members\n\n proposal_id = args['a'][0]\n proposal, _ = get('function', 'proposal', None, '%s' % proposal_id)\n assert proposal\n votes = set(proposal['votes'])\n votes.add(addr)\n proposal['votes'] = list(votes)\n\n if len(votes) >= len(committee_members)*2//3:\n assert len(proposal['snippets']) > 0\n for snippet_hash in proposal['snippets']:\n assert set(snippet_hash) <= set(string.ascii_lowercase+string.digits)\n snippet, _ = get('function', 'snippet', None, snippet_hash)\n assert snippet, \"Snippet not found: %s\" % snippet_hash\n snippet['functions'].extend(proposal['functions'])\n put('', 'function', 'snippet', snippet, snippet_hash)\n\n assert len(proposal['functions']) > 0\n for func_name in proposal['functions']:\n put(addr, 'function', 'code', {\n 'snippets': proposal['snippets']\n }, func_name)\n event('NewFunctions', [proposal_id, proposal['functions']])\n else:\n put(addr, 'function', 'proposal', proposal, '%s' % proposal_id)\n event('FunctionVote', [proposal_id, addr])\n", "functions": ["function_vote", "function_snippet_clear", "function_snippet", "function_proposal"]}{"functions": ["committee_init", "committee_add_member", "committee_remove_member"], "snippets": ["e5fb2b11848ff75c932891620723b60c8b1c8f3305c5307bf5a90e173d0911bd"], "votes": []}{"functions": ["function_snippet", "function_snippet_clear", "function_proposal", "function_vote"], "snippets": ["3e4584c9f89cb04b4b9cc79182892e02c4de65883a0d70e9dee033303c445c5d"], "votes": []}{"snippets": ["3e4584c9f89cb04b4b9cc79182892e02c4de65883a0d70e9dee033303c445c5d"]}{"snippets": ["3e4584c9f89cb04b4b9cc79182892e02c4de65883a0d70e9dee033303c445c5d"]}{"snippets": ["3e4584c9f89cb04b4b9cc79182892e02c4de65883a0d70e9dee033303c445c5d"]}{"snippets": ["3e4584c9f89cb04b4b9cc79182892e02c4de65883a0d70e9dee033303c445c5d"]}{"functions": ["asset_create", "asset_update_ownership", "asset_update_functions"], "snippet": "def asset_create(info, args):\n assert args['f'] == 'asset_create'\n sender = info['sender']\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n addr = handle_lookup(sender)\n owner, _ = get('asset', 'owner', None, tick)\n assert not owner\n\n put(addr, 'asset', 'owner', addr, tick)\n put(addr, 'asset', 'functions', ['asset_update_ownership', 'asset_update_functions'], tick)\n\ndef asset_update_ownership(info, args):\n assert args['f'] == 'asset_update_ownership'\n sender = info['sender']\n tick = args['a'][0]\n receiver = args['a'][1]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n addr = handle_lookup(sender)\n\n owner, _ = get('asset', 'owner', None, tick)\n assert owner == addr\n functions, _ = get('asset', 'functions', None, tick)\n assert type(functions) is list\n assert functions\n put(receiver, 'asset', 'owner', receiver, tick)\n put(receiver, 'asset', 'functions', functions, tick)\n\n\ndef asset_update_functions(info, args):\n assert args['f'] == 'asset_update_functions'\n sender = info['sender']\n addr = handle_lookup(sender)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n functions = args['a'][1]\n assert type(functions) is list\n assert functions\n"}{"votes": [], "snippets": ["6999a31be16784d6ee05ef0c5cf310e2c92394c6d3a7b8eec662d3044352de24"], "functions": ["asset_create", "asset_update_ownership", "asset_update_functions"]}{"snippets": ["6999a31be16784d6ee05ef0c5cf310e2c92394c6d3a7b8eec662d3044352de24"]}{"snippets": ["6999a31be16784d6ee05ef0c5cf310e2c92394c6d3a7b8eec662d3044352de24"]}{"snippets": ["6999a31be16784d6ee05ef0c5cf310e2c92394c6d3a7b8eec662d3044352de24"]}{"functions": ["token_create", "token_mint_once", "token_mint", "token_burn", "token_transfer"], "snippet": "def token_create(info, args):\n assert args['f'] == 'token_create'\n sender = info['sender']\n addr = handle_lookup(sender)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n name = args['a'][1]\n assert type(name) is str\n decimal = int(args['a'][2])\n assert type(decimal) is int\n assert decimal >= 0 and decimal <= 18\n\n functions = ['token_transfer', 'token_mint_once', 'asset_update_ownership', 'asset_update_functions']\n if len(args['a']) == 4:\n functions = args['a'][3]\n assert type(functions) is list\n\n put(addr, tick, 'name', name)\n put(addr, tick, 'decimal', decimal)\n put(addr, 'asset', 'functions', functions, tick)\n\n\ndef token_mint_once(info, args):\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n value = int(args['a'][1])\n assert value > 0\n\n assert args['f'] == 'token_mint_once'\n functions, _ = get('asset', 'functions', [], tick)\n assert args['f'] in functions\n\n sender = info['sender']\n addr = handle_lookup(sender)\n\n total, _ = get(tick, 'total', None)\n assert total is None, \"Token already minted\"\n put(addr, tick, 'total', value)\n\n balance, _ = get(tick, 'balance', 0, addr)\n balance += value\n put(addr, tick, 'balance', balance, addr)\n\n\ndef token_mint(info, args):\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n assert args['f'] == 'token_mint'\n\n value = int(args['a'][1])\n assert value > 0\n sender = info['sender']\n addr = handle_lookup(sender)\n\n balance, _ = get(tick, 'balance', 0, addr)\n balance += value\n put(addr, tick, 'balance', balance, addr)\n\n total, _ = get(tick, 'total', 0)\n total += value\n put(addr, tick, 'total', total)\n\n\ndef token_burn(info, args):\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n assert args['f'] == 'token_burn'\n assert args['f'] in get('asset', 'functions', [], tick)\n\n value = int(args['a'][1])\n assert value > 0\n sender = info['sender']\n addr = handle_lookup(sender)\n\n balance = get(tick, 'balance', 0, addr)\n balance -= value\n assert balance >= 0\n\n total = get(tick, 'total', 0, addr)\n total -= value\n assert total >= 0\n\n put(addr, tick, 'balance', balance, addr)\n put(addr, tick, 'total', total)\n\n\ndef token_transfer(info, args):\n tick = args['a'][0]\n assert set(tick) <= set(string.ascii_uppercase+'_')\n\n assert args['f'] == 'token_transfer'\n assert args['f'] in get('asset', 'functions', [], tick)\n\n receiver = args['a'][1].lower()\n assert len(receiver) <= 42\n assert type(receiver) is str\n if len(receiver) == 42:\n assert receiver.startswith('0x')\n assert set(receiver[2:]) <= set(string.digits+'abcdef')\n else:\n assert len(receiver) > 4\n\n sender = info['sender']\n addr = handle_lookup(sender)\n\n value = int(args['a'][2])\n assert value > 0\n\n sender_balance, _ = get(tick, 'balance', 0, addr)\n assert sender_balance >= value\n sender_balance -= value\n put(addr, tick, 'balance', sender_balance, addr)\n receiver_balance, _ = get(tick, 'balance', 0, receiver)\n receiver_balance += value\n put(receiver, tick, 'balance', receiver_balance, receiver)\n event('Transfer', [tick, addr, receiver, value])\n\n\ndef token_send(info, args):\n assert args['f'] == 'token_send'\n\n\ndef token_accept(info, args):\n assert args['f'] == 'token_accept'\n"}{"votes": [], "snippets": ["2f364fa5ebb7de5ea49c6d5b882b4a0928ca90d3658e383d25350d69ab777a8a"], "functions": ["token_create", "token_mint_once", "token_mint", "token_burn", "token_transfer"]}{"snippets": ["2f364fa5ebb7de5ea49c6d5b882b4a0928ca90d3658e383d25350d69ab777a8a"]}{"snippets": ["2f364fa5ebb7de5ea49c6d5b882b4a0928ca90d3658e383d25350d69ab777a8a"]}{"snippets": ["2f364fa5ebb7de5ea49c6d5b882b4a0928ca90d3658e383d25350d69ab777a8a"]}{"snippets": ["2f364fa5ebb7de5ea49c6d5b882b4a0928ca90d3658e383d25350d69ab777a8a"]}{"snippets": ["2f364fa5ebb7de5ea49c6d5b882b4a0928ca90d3658e383d25350d69ab777a8a"]}{"functions": ["bridge_incoming_process", "bridge_incoming", "bridge_outgoing", "bridge_set_operator", "bridge_remove_operator", "bridge_set_outgoing_price"], "snippet": "\n# Elliptic Curve parameters for secp256k1\nP = 0xFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFEFFFFFC2F\nA = 0\nB = 7\nGx = 55066263022277343669578718895168534326250603453777594175500187360389116729240\nGy = 32670510020758816978083085130507043184471273380659243275938904335757337482424\nG = (Gx, Gy)\nN = 0xFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFEBAAEDCE6AF48A03BBFD25E8CD0364141\nK = 10**18\n\ndef _inverse_mod(k, p):\n if k == 0:\n raise\n return pow(k, p - 2, p)\n\ndef _is_on_curve(point):\n if point is None:\n return True\n x, y = point\n return (y * y - (x * x * x + A * x + B)) % P == 0\n\ndef _point_add(point1, point2):\n if point1 is None:\n return point2\n if point2 is None:\n return point1\n x1, y1 = point1\n x2, y2 = point2\n if x1 == x2 and y1 != y2:\n return None\n if x1 == x2:\n m = (3 * x1 * x1 + A) * _inverse_mod(2 * y1, P)\n else:\n m = (y2 - y1) * _inverse_mod(x2 - x1, P)\n m %= P\n x3 = (m * m - x1 - x2) % P\n y3 = (m * (x1 - x3) - y1) % P\n return (x3, y3)\n\ndef _scalar_mult(k, point):\n result = None\n addend = point\n while k:\n if k & 1:\n result = _point_add(result, addend)\n addend = _point_add(addend, addend)\n k >>= 1\n return result\n\ndef _ecdsa_verify(msg_hash_hex, signature_hex, public_key_hex):\n assert msg_hash_hex.startswith('0x')\n assert signature_hex.startswith('0x')\n assert public_key_hex.startswith('0x')\n r = int(signature_hex[2:66], 16)\n s = int(signature_hex[66:130], 16)\n if not (1 <= r < N and 1 <= s < N):\n return False\n point = (int(public_key_hex[2:66], 16), int(public_key_hex[66:], 16))\n # print(type(msg_hash_hex), msg_hash_hex)\n e = int(msg_hash_hex[2:], 16)\n w = _inverse_mod(s, N)\n u1 = (e * w) % N\n u2 = (r * w) % N\n q = _point_add(_scalar_mult(u1, G), _scalar_mult(u2, point))\n if q is None:\n return False\n x, y = q\n return r == x % N\n\ndef _ecdsa_recover(msg_hash_hex, signature_hex):\n assert msg_hash_hex.startswith('0x')\n assert signature_hex.startswith('0x')\n r = int(signature_hex[2:66], 16)\n s = int(signature_hex[66:130], 16)\n z = int(msg_hash_hex[2:], 16)\n\n if len(signature_hex[2:]) == 130:\n v = int(signature_hex[130:], 16)\n if v >= 27:\n recovery_id = v - 27\n else:\n recovery_id = v\n recovery_ids = [recovery_id]\n else:\n recovery_ids = [0, 1]\n\n for recovery_id in recovery_ids:\n for j in range(2):\n x = r + j * N\n if x >= P:\n continue\n\n y_squared = (pow(x, 3, P) + A * x + B) % P\n y = pow(y_squared, (P + 1) // 4, P)\n\n if y % 2 != recovery_id:\n y = P - y\n\n point = (x, y)\n if not _is_on_curve(point):\n continue\n\n r_inv = _inverse_mod(r, N)\n u1 = (-z * r_inv) % N\n u2 = (s * r_inv) % N\n\n q = _point_add(_scalar_mult(u1, G), _scalar_mult(u2, point))\n if q is None:\n continue\n\n public_key_hex = f\"0x{q[0]:064x}{q[1]:064x}\"\n if _ecdsa_verify(msg_hash_hex, signature_hex, public_key_hex):\n return public_key_hex\n\n return None\n\n\ndef _encode_uint256(value):\n return value.to_bytes(32, 'big')\n\ndef _encode_address(address_str):\n address_bytes = bytes.fromhex(address_str[2:])\n return b'\\x00' * (32 - len(address_bytes)) + address_bytes\n\ndef _encode_dynamic_bytes(data_hex):\n data_bytes = bytes.fromhex(data_hex)\n length = len(data_bytes)\n padded_length = (length + 31) // 32 * 32 # Calculate padded length for data\n return length.to_bytes(32, 'big') + data_bytes + b'\\x00' * (padded_length - length)\n\n# '{\"a\": [845300000000000000000000002, 8453, 43114, \"0x51055892893c17ae7db48a0c0f760145bfe9f1e5\", \"0x09ace2d19b0273a762b0fe22b9e5199505c778de\", 0, \"000000000000000000000000490537058bdddaae99dd4da8b5db5675936bfedf0000000000000000000000000000000000000000000000008ac7230489e80000\", \"0000000000000000000000000000000000000000000000000000000000000000\", \"034da1308a53b6586fed90af2bd4e48cc863913551cc41d6148f43441691e4fd1ea27a1e3daf2b4c1386d0426cc37a4423729204177740768970937c93d648961c\"], \"f\": \"bridge_incoming_process\", \"p\": \"zentest\"}'\ndef bridge_incoming_process(info, args):\n assert args['f'] == 'bridge_incoming_process'\n sender = info['sender']\n addr = handle_lookup(sender)\n print('bridge_incoming_process')\n\n txid = args['a'][0]\n source_chain_id = args['a'][1]\n dest_chain_id = args['a'][2]\n source_chain_sender = args['a'][3]\n dest_chain_recipient = args['a'][4]\n gas = args['a'][5]\n user_payload = args['a'][6]\n exsig = args['a'][7]\n signature = args['a'][8]\n\n encoded_txid = _encode_uint256(txid)\n encoded_source_chain_id = _encode_uint256(source_chain_id)\n encoded_dest_chain_id = _encode_uint256(dest_chain_id)\n encoded_source_chain_sender = _encode_address(source_chain_sender)\n encoded_dest_chain_recipient = _encode_address(dest_chain_recipient)\n offset_user_payload = 6 * 32\n encoded_offset_user_payload = _encode_uint256(offset_user_payload)\n\n header = b''.join([\n encoded_txid,\n encoded_source_chain_id,\n encoded_dest_chain_id,\n encoded_source_chain_sender,\n encoded_dest_chain_recipient,\n encoded_offset_user_payload,\n ])\n encoded_user_payload_data = _encode_dynamic_bytes(user_payload)\n\n encoded_data = b''.join([\n header,\n encoded_user_payload_data,\n ])\n print(f\"ABI Encoded Data (Pure Python): 0x{encoded_data.hex()}\")\n\n encoded_data_hash = keccak(encoded_data)\n x19_msg_prefix = b\"\\x19Ethereum Signed Message:\\n\" + str(len(encoded_data_hash)).encode('utf-8')\n x19_msg_hash = keccak(x19_msg_prefix + encoded_data_hash)\n print(f\"x19_msg (Pure Python): 0x{x19_msg_hash.hex()}\")\n\n print('x19', '0x'+x19_msg_hash.hex())\n print('signature', '0x'+signature)\n recovered_public_key = _ecdsa_recover('0x'+x19_msg_hash.hex(), '0x'+signature)\n print(f\"recovered public key: {recovered_public_key}\")\n if recovered_public_key:\n public_key_bytes = bytes.fromhex(recovered_public_key[2:])\n address_bytes = keccak(public_key_bytes)[-20:]\n address = '0x' + address_bytes.hex()\n print(f\"Recovered Ethereum address: {address}\")\n\n\ndef bridge_incoming(info, args):\n assert args['f'] == 'bridge_incoming'\n print('bridge_incoming', args)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n operator, _ = get(tick, 'incoming_operator', None)\n assert operator is not None, \"Bridge is not initialized\"\n sender = info['sender']\n assert sender == operator, \"Only the operator can perform this operation\"\n\n amount = int(args['a'][1])\n assert amount > 0\n\n receiver = args['a'][2].lower()\n assert len(receiver) <= 42\n assert type(receiver) is str\n if len(receiver) == 42:\n assert receiver.startswith('0x')\n assert set(receiver[2:]) <= set(string.digits+'abcdef')\n else:\n assert len(receiver) > 4\n\n balance, _ = get(tick, 'balance', 0, receiver)\n balance = int(balance)\n balance += amount\n put(receiver, tick, 'balance', balance, receiver)\n\n asset_owner, _ = get('asset', 'owner', None, tick)\n total, _ = get(tick, 'total', 0)\n total = int(total)\n total += amount\n put(asset_owner, tick, 'total', total)\n\n # call('trade_market_order', ['USDC', None, 'ZENT', 50 * 10**18 // 1000])\n # sender_balance, _ = get(tick_1, 'balance', 0, addr)\n print('tick', tick, 'balance', balance)\n # print('quote_value > 0', quote_value)\n\n if tick != 'USDC':\n return\n\n base_tick = 'ZENT'\n quote_tick = tick\n pair = '%s_%s' % (base_tick, quote_tick)\n addr = receiver\n quote_sum = 0\n quote_balance = balance\n base_value = 10**18 // 1000 * 50 # 50 bytes\n trade_sell_start, _ = get('trade', f'{pair}_sell_start', 1)\n # trade_buy_start, _ = get('trade', f'{pair}_buy_start', 1)\n\n # break until the base balance is enough\n trade_sell_id = trade_sell_start\n while True:\n sell, _ = get('trade', f'{pair}_sell', None, str(trade_sell_id))\n if sell is None:\n break\n\n price = sell[3]\n print(-sell[1], quote_balance * K // price, base_value)\n dx_base = min(-sell[1], quote_balance * K // price, base_value)\n dx_quote = dx_base * price // K\n if dx_base == 0 or dx_quote == 0:\n break\n sell[1] += dx_base\n sell[2] -= dx_quote\n\n if quote_balance - dx_quote < 0:\n break\n quote_balance -= dx_quote\n quote_sum += dx_quote\n\n if sell[1] == 0 or sell[1] // price == 0:\n if sell[4]:\n prev_sell, _ = get('trade', f'{pair}_sell', None, str(sell[4]))\n prev_sell[5] = sell[5]\n put(prev_sell[0], 'trade', f'{pair}_sell', prev_sell, str(sell[4]))\n\n if sell[5]:\n next_sell, _ = get('trade', f'{pair}_sell', None, str(sell[5]))\n next_sell[4] = sell[4]\n put(next_sell[0], 'trade', f'{pair}_sell', next_sell, str(sell[5]))\n\n if sell[4] is not None and sell[5] is None:\n trade_sell_start = sell[4]\n put(addr, 'trade', f'{pair}_sell_start', trade_sell_start)\n elif sell[4] is None and sell[5] is None:\n trade_sell_new, _ = get('trade', f'{pair}_sell_new', 1)\n trade_sell_start = trade_sell_new\n put(addr, 'trade', f'{pair}_sell_start', trade_sell_start)\n\n print(f'{pair}_sell_to_refund', sell)\n if sell[1] < 0:\n balance, _ = get(base_tick, 'balance', 0, sell[0])\n balance -= sell[1]\n assert balance >= 0\n put(sell[0], base_tick, 'balance', balance, sell[0])\n\n put(sell[0], 'trade', f'{pair}_sell', None, str(trade_sell_id))\n else:\n put(sell[0], 'trade', f'{pair}_sell', sell, str(trade_sell_id))\n\n balance, _ = get(quote_tick, 'balance', 0, sell[0])\n balance += dx_quote\n assert balance >= 0\n put(addr, quote_tick, 'balance', balance, sell[0])\n\n base_value -= dx_base\n assert base_value >= 0\n balance, _ = get(base_tick, 'balance', 0, addr)\n balance += dx_base\n assert balance >= 0\n put(addr, base_tick, 'balance', balance, addr)\n\n if sell[4] is None:\n break\n trade_sell_id = sell[4]\n\n balance, _ = get(quote_tick, 'balance', 0, addr)\n balance -= quote_sum\n assert balance >= 0\n put(addr, quote_tick, 'balance', balance, addr)\n\n\ndef bridge_outgoing(info, args):\n assert args['f'] == 'bridge_outgoing'\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n amount = int(args['a'][1])\n assert amount > 0\n\n chain = args['a'][2]\n assert chain in ['op-sepolia']\n\n sender = info['sender']\n\n\ndef bridge_set_operator(info, args):\n assert args['f'] == 'bridge_set_operator'\n print('bridge_set_operator', args)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n asset_owner, _ = get('asset', 'owner', None, tick)\n sender = info['sender']\n addr = handle_lookup(sender)\n print('bridge_set_operator', asset_owner, addr)\n assert addr == asset_owner, \"Only the asset owner can perform this operation\"\n\n operator = args['a'][1].lower()\n assert type(operator) is str\n assert len(operator) == 42\n assert operator.startswith('0x')\n assert set(operator[2:]) <= set(string.digits+'abcdef')\n\n put(addr, tick, 'incoming_operator', operator)\n\n\ndef bridge_remove_operator(info, args):\n assert args['f'] == 'bridge_remove_operator'\n print('bridge_remove_operator', args)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n asset_owner, _ = get('asset', 'owner', None, tick)\n sender = info['sender']\n addr = handle_lookup(sender)\n # print('bridge_remove_operator', asset_owner, addr)\n assert addr == asset_owner, \"Only the asset owner can perform this operation\"\n\n # operator = args['a'][1].lower()\n # assert type(operator) is str\n # assert len(operator) == 42\n # assert operator.startswith('0x')\n # assert set(operator[2:]) <= set(string.digits+'abcdef')\n\n put(addr, tick, 'incoming_operator', None)\n\ndef bridge_set_outgoing_price(info, args):\n assert args['f'] == 'bridge_set_outgoing_price'\n print('bridge_set_outgoing_price', args)\n"}{"votes": [], "snippets": ["7ede21d83bfa2f120f1dfe100b202f39985421e0617ed81956c96fd851080730"], "functions": ["bridge_incoming_process", "bridge_incoming", "bridge_outgoing", "bridge_set_operator", "bridge_remove_operator", "bridge_set_outgoing_price"]}{"snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"]}{"snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"]}{"snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"]}{"snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"]}{"snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"]}{"snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"]}{"functions": ["bridge_incoming_process", "bridge_incoming", "bridge_outgoing", "bridge_set_operator", "bridge_remove_operator", "bridge_set_outgoing_price"], "snippet": "\n# Elliptic Curve parameters for secp256k1\nP = 0xFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFEFFFFFC2F\nA = 0\nB = 7\nGx = 55066263022277343669578718895168534326250603453777594175500187360389116729240\nGy = 32670510020758816978083085130507043184471273380659243275938904335757337482424\nG = (Gx, Gy)\nN = 0xFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFEBAAEDCE6AF48A03BBFD25E8CD0364141\nK = 10**18\n\ndef _inverse_mod(k, p):\n if k == 0:\n raise\n return pow(k, p - 2, p)\n\ndef _is_on_curve(point):\n if point is None:\n return True\n x, y = point\n return (y * y - (x * x * x + A * x + B)) % P == 0\n\ndef _point_add(point1, point2):\n if point1 is None:\n return point2\n if point2 is None:\n return point1\n x1, y1 = point1\n x2, y2 = point2\n if x1 == x2 and y1 != y2:\n return None\n if x1 == x2:\n m = (3 * x1 * x1 + A) * _inverse_mod(2 * y1, P)\n else:\n m = (y2 - y1) * _inverse_mod(x2 - x1, P)\n m %= P\n x3 = (m * m - x1 - x2) % P\n y3 = (m * (x1 - x3) - y1) % P\n return (x3, y3)\n\ndef _scalar_mult(k, point):\n result = None\n addend = point\n while k:\n if k & 1:\n result = _point_add(result, addend)\n addend = _point_add(addend, addend)\n k >>= 1\n return result\n\ndef _ecdsa_verify(msg_hash_hex, signature_hex, public_key_hex):\n assert msg_hash_hex.startswith('0x')\n assert signature_hex.startswith('0x')\n assert public_key_hex.startswith('0x')\n r = int(signature_hex[2:66], 16)\n s = int(signature_hex[66:130], 16)\n if not (1 <= r < N and 1 <= s < N):\n return False\n point = (int(public_key_hex[2:66], 16), int(public_key_hex[66:], 16))\n # print(type(msg_hash_hex), msg_hash_hex)\n e = int(msg_hash_hex[2:], 16)\n w = _inverse_mod(s, N)\n u1 = (e * w) % N\n u2 = (r * w) % N\n q = _point_add(_scalar_mult(u1, G), _scalar_mult(u2, point))\n if q is None:\n return False\n x, y = q\n return r == x % N\n\ndef _ecdsa_recover(msg_hash_hex, signature_hex):\n assert msg_hash_hex.startswith('0x')\n assert signature_hex.startswith('0x')\n r = int(signature_hex[2:66], 16)\n s = int(signature_hex[66:130], 16)\n z = int(msg_hash_hex[2:], 16)\n\n if len(signature_hex[2:]) == 130:\n v = int(signature_hex[130:], 16)\n if v >= 27:\n recovery_id = v - 27\n else:\n recovery_id = v\n recovery_ids = [recovery_id]\n else:\n recovery_ids = [0, 1]\n\n for recovery_id in recovery_ids:\n for j in range(2):\n x = r + j * N\n if x >= P:\n continue\n\n y_squared = (pow(x, 3, P) + A * x + B) % P\n y = pow(y_squared, (P + 1) // 4, P)\n\n if y % 2 != recovery_id:\n y = P - y\n\n point = (x, y)\n if not _is_on_curve(point):\n continue\n\n r_inv = _inverse_mod(r, N)\n u1 = (-z * r_inv) % N\n u2 = (s * r_inv) % N\n\n q = _point_add(_scalar_mult(u1, G), _scalar_mult(u2, point))\n if q is None:\n continue\n\n public_key_hex = f\"0x{q[0]:064x}{q[1]:064x}\"\n if _ecdsa_verify(msg_hash_hex, signature_hex, public_key_hex):\n return public_key_hex\n\n return None\n\n\ndef _encode_uint256(value):\n return value.to_bytes(32, 'big')\n\ndef _encode_address(address_str):\n address_bytes = bytes.fromhex(address_str[2:])\n return b'\\x00' * (32 - len(address_bytes)) + address_bytes\n\ndef _encode_dynamic_bytes(data_hex):\n data_bytes = bytes.fromhex(data_hex)\n length = len(data_bytes)\n padded_length = (length + 31) // 32 * 32 # Calculate padded length for data\n return length.to_bytes(32, 'big') + data_bytes + b'\\x00' * (padded_length - length)\n\n# '{\"a\": [845300000000000000000000002, 8453, 43114, \"0x51055892893c17ae7db48a0c0f760145bfe9f1e5\", \"0x09ace2d19b0273a762b0fe22b9e5199505c778de\", 0, \"000000000000000000000000490537058bdddaae99dd4da8b5db5675936bfedf0000000000000000000000000000000000000000000000008ac7230489e80000\", \"0000000000000000000000000000000000000000000000000000000000000000\", \"034da1308a53b6586fed90af2bd4e48cc863913551cc41d6148f43441691e4fd1ea27a1e3daf2b4c1386d0426cc37a4423729204177740768970937c93d648961c\"], \"f\": \"bridge_incoming_process\", \"p\": \"zentest\"}'\ndef bridge_incoming_process(info, args):\n assert args['f'] == 'bridge_incoming_process'\n sender = info['sender']\n addr = handle_lookup(sender)\n print('bridge_incoming_process')\n\n txid = args['a'][0]\n source_chain_id = args['a'][1]\n dest_chain_id = args['a'][2]\n source_chain_sender = args['a'][3]\n dest_chain_recipient = args['a'][4]\n gas = args['a'][5]\n user_payload = args['a'][6]\n exsig = args['a'][7]\n signature = args['a'][8]\n\n encoded_txid = _encode_uint256(txid)\n encoded_source_chain_id = _encode_uint256(source_chain_id)\n encoded_dest_chain_id = _encode_uint256(dest_chain_id)\n encoded_source_chain_sender = _encode_address(source_chain_sender)\n encoded_dest_chain_recipient = _encode_address(dest_chain_recipient)\n offset_user_payload = 6 * 32\n encoded_offset_user_payload = _encode_uint256(offset_user_payload)\n\n header = b''.join([\n encoded_txid,\n encoded_source_chain_id,\n encoded_dest_chain_id,\n encoded_source_chain_sender,\n encoded_dest_chain_recipient,\n encoded_offset_user_payload,\n ])\n encoded_user_payload_data = _encode_dynamic_bytes(user_payload)\n\n encoded_data = b''.join([\n header,\n encoded_user_payload_data,\n ])\n print(f\"ABI Encoded Data (Pure Python): 0x{encoded_data.hex()}\")\n\n encoded_data_hash = keccak(encoded_data)\n x19_msg_prefix = b\"\\x19Ethereum Signed Message:\\n\" + str(len(encoded_data_hash)).encode('utf-8')\n x19_msg_hash = keccak(x19_msg_prefix + encoded_data_hash)\n print(f\"x19_msg (Pure Python): 0x{x19_msg_hash.hex()}\")\n\n print('x19', '0x'+x19_msg_hash.hex())\n print('signature', '0x'+signature)\n recovered_public_key = _ecdsa_recover('0x'+x19_msg_hash.hex(), '0x'+signature)\n print(f\"recovered public key: {recovered_public_key}\")\n if recovered_public_key:\n public_key_bytes = bytes.fromhex(recovered_public_key[2:])\n address_bytes = keccak(public_key_bytes)[-20:]\n address = '0x' + address_bytes.hex()\n print(f\"Recovered Ethereum address: {address}\")\n event('BridgeProcess', [address])\n\n\ndef bridge_incoming(info, args):\n assert args['f'] == 'bridge_incoming'\n print('bridge_incoming', args)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n operator, _ = get(tick, 'incoming_operator', None)\n assert operator is not None, \"Bridge is not initialized\"\n sender = info['sender']\n assert sender == operator, \"Only the operator can perform this operation\"\n\n amount = int(args['a'][1])\n assert amount > 0\n\n receiver = args['a'][2].lower()\n assert len(receiver) <= 42\n assert type(receiver) is str\n if len(receiver) == 42:\n assert receiver.startswith('0x')\n assert set(receiver[2:]) <= set(string.digits+'abcdef')\n else:\n assert len(receiver) > 4\n\n balance, _ = get(tick, 'balance', 0, receiver)\n balance = int(balance)\n balance += amount\n put(receiver, tick, 'balance', balance, receiver)\n\n asset_owner, _ = get('asset', 'owner', None, tick)\n total, _ = get(tick, 'total', 0)\n total = int(total)\n total += amount\n put(asset_owner, tick, 'total', total)\n\n # call('trade_market_order', ['USDC', None, 'ZENT', 50 * 10**18 // 1000])\n # sender_balance, _ = get(tick_1, 'balance', 0, addr)\n print('tick', tick, 'balance', balance)\n # print('quote_value > 0', quote_value)\n\n if tick != 'USDC':\n return\n\n base_tick = 'ZENT'\n quote_tick = tick\n pair = '%s_%s' % (base_tick, quote_tick)\n addr = receiver\n quote_sum = 0\n quote_balance = balance\n base_value = 10**18 // 1000 * 50 # 50 bytes\n trade_sell_start, _ = get('trade', f'{pair}_sell_start', 1)\n # trade_buy_start, _ = get('trade', f'{pair}_buy_start', 1)\n\n # break until the base balance is enough\n trade_sell_id = trade_sell_start\n while True:\n sell, _ = get('trade', f'{pair}_sell', None, str(trade_sell_id))\n if sell is None:\n break\n\n price = sell[3]\n print(-sell[1], quote_balance * K // price, base_value)\n dx_base = min(-sell[1], quote_balance * K // price, base_value)\n dx_quote = dx_base * price // K\n if dx_base == 0 or dx_quote == 0:\n break\n sell[1] += dx_base\n sell[2] -= dx_quote\n\n if quote_balance - dx_quote < 0:\n break\n quote_balance -= dx_quote\n quote_sum += dx_quote\n\n if sell[1] == 0 or sell[1] // price == 0:\n if sell[4]:\n prev_sell, _ = get('trade', f'{pair}_sell', None, str(sell[4]))\n prev_sell[5] = sell[5]\n put(prev_sell[0], 'trade', f'{pair}_sell', prev_sell, str(sell[4]))\n\n if sell[5]:\n next_sell, _ = get('trade', f'{pair}_sell', None, str(sell[5]))\n next_sell[4] = sell[4]\n put(next_sell[0], 'trade', f'{pair}_sell', next_sell, str(sell[5]))\n\n if sell[4] is not None and sell[5] is None:\n trade_sell_start = sell[4]\n put(addr, 'trade', f'{pair}_sell_start', trade_sell_start)\n elif sell[4] is None and sell[5] is None:\n trade_sell_new, _ = get('trade', f'{pair}_sell_new', 1)\n trade_sell_start = trade_sell_new\n put(addr, 'trade', f'{pair}_sell_start', trade_sell_start)\n\n print(f'{pair}_sell_to_refund', sell)\n if sell[1] < 0:\n balance, _ = get(base_tick, 'balance', 0, sell[0])\n balance -= sell[1]\n assert balance >= 0\n put(sell[0], base_tick, 'balance', balance, sell[0])\n\n put(sell[0], 'trade', f'{pair}_sell', None, str(trade_sell_id))\n else:\n put(sell[0], 'trade', f'{pair}_sell', sell, str(trade_sell_id))\n\n balance, _ = get(quote_tick, 'balance', 0, sell[0])\n balance += dx_quote\n assert balance >= 0\n put(addr, quote_tick, 'balance', balance, sell[0])\n\n base_value -= dx_base\n assert base_value >= 0\n balance, _ = get(base_tick, 'balance', 0, addr)\n balance += dx_base\n assert balance >= 0\n put(addr, base_tick, 'balance', balance, addr)\n\n if sell[4] is None:\n break\n trade_sell_id = sell[4]\n\n balance, _ = get(quote_tick, 'balance', 0, addr)\n balance -= quote_sum\n assert balance >= 0\n put(addr, quote_tick, 'balance', balance, addr)\n\n\ndef bridge_outgoing(info, args):\n assert args['f'] == 'bridge_outgoing'\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n amount = int(args['a'][1])\n assert amount > 0\n\n chain = args['a'][2]\n assert chain in ['op-sepolia']\n\n sender = info['sender']\n\n\ndef bridge_set_operator(info, args):\n assert args['f'] == 'bridge_set_operator'\n print('bridge_set_operator', args)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n asset_owner, _ = get('asset', 'owner', None, tick)\n sender = info['sender']\n addr = handle_lookup(sender)\n print('bridge_set_operator', asset_owner, addr)\n assert addr == asset_owner, \"Only the asset owner can perform this operation\"\n\n operator = args['a'][1].lower()\n assert type(operator) is str\n assert len(operator) == 42\n assert operator.startswith('0x')\n assert set(operator[2:]) <= set(string.digits+'abcdef')\n\n put(addr, tick, 'incoming_operator', operator)\n\n\ndef bridge_remove_operator(info, args):\n assert args['f'] == 'bridge_remove_operator'\n print('bridge_remove_operator', args)\n\n tick = args['a'][0]\n assert type(tick) is str\n assert len(tick) > 0 and len(tick) < 42\n assert tick[0] in string.ascii_uppercase\n assert set(tick) <= set(string.ascii_uppercase+string.digits+'_')\n\n asset_owner, _ = get('asset', 'owner', None, tick)\n sender = info['sender']\n addr = handle_lookup(sender)\n # print('bridge_remove_operator', asset_owner, addr)\n assert addr == asset_owner, \"Only the asset owner can perform this operation\"\n\n # operator = args['a'][1].lower()\n # assert type(operator) is str\n # assert len(operator) == 42\n # assert operator.startswith('0x')\n # assert set(operator[2:]) <= set(string.digits+'abcdef')\n\n put(addr, tick, 'incoming_operator', None)\n\ndef bridge_set_outgoing_price(info, args):\n assert args['f'] == 'bridge_set_outgoing_price'\n print('bridge_set_outgoing_price', args)\n"}{"votes": [], "snippets": ["974f8a6375317f63a3da19c10d15d1f6d2a64ea40c63681ba41ee297938d4f62"], "functions": ["bridge_incoming_process", "bridge_incoming", "bridge_outgoing", "bridge_set_operator", "bridge_remove_operator", "bridge_set_outgoing_price"]}