dexSimForSafeTrading

kitty · kitty · commit b18aa03d3239 · 2025-02-19T01:16:20.000-06:00
diff --git a/app/DexSimulator/.gitignore b/app/DexSimulator/.gitignore
@@ -0,0 +1,5 @@
+.key
+.dockerignore
+.env
+build
+data/*
diff --git a/app/DexSimulator/1inch_routeur.py b/app/DexSimulator/1inch_routeur.py
@@ -0,0 +1,21 @@
+import requests
+
+method = "get"
+apiUrl = "https://api.1inch.dev/swap/v6.0/1/quote"
+requestOptions = {
+      "headers": {
+  "Authorization": "Bearer wwBHIxQdQ0MeDKvYt3thRtZ1LXzsJFPm"
+},
+      "body": "",
+      "params": {}
+}
+
+# Prepare request components
+headers = requestOptions.get("headers", {})
+body = requestOptions.get("body", {})
+params = requestOptions.get("params", {})
+
+
+response = requests.get(apiUrl, headers=headers, params=params)
+
+print(response.json())
diff --git a/app/DexSimulator/README.md b/app/DexSimulator/README.md
diff --git a/app/DexSimulator/finding.md b/app/DexSimulator/finding.md
@@ -0,0 +1,13 @@
+'''bash
+curl -X POST \
+
+  -H "Content-Type: application/json" \
+
+  -d '{"query": "{ factories(first: 5) { id poolCount txCount totalVolumeUSD } bundles(first: 5) { id ethPriceUSD } }", "operationName": "Subgraphs", "variables": {}}' \
+
+  https://gateway.thegraph.com/api/{api-key}/subgraphs/id/5zvR82QoaXYFyDEKLZ9t6v9adgnptxYpKpSbxtgVENFV
+'''
+
+https://gateway.thegraph.com/api/[api-key]/subgraphs/id/5zvR82QoaXYFyDEKLZ9t6v9adgnptxYpKpSbxtgVENFV
+QmTZ8ejXJxRo7vDBS4uwqBeGoxLSWbhaA7oXa1RvxunLy7
+5zvR82QoaXYFyDEKLZ9t6v9adgnptxYpKpSbxtgVENFV
diff --git a/app/DexSimulator/hygdraDexSim/dataclass/__init__.py b/app/DexSimulator/hygdraDexSim/dataclass/__init__.py
@@ -0,0 +1 @@
+__all__ = ["chain", "transaction", "wallet", "action"]
diff --git a/app/DexSimulator/hygdraDexSim/dataclass/action.py b/app/DexSimulator/hygdraDexSim/dataclass/action.py
@@ -0,0 +1,8 @@
+from pydantic import BaseModel
+from enum import Enum
+
+
+# FastAPI Models
+class Action(str, Enum, BaseModel):
+    BUY: str = "BUY"
+    SELL: str = "SELL"
diff --git a/app/DexSimulator/hygdraDexSim/dataclass/chain.py b/app/DexSimulator/hygdraDexSim/dataclass/chain.py
@@ -0,0 +1,9 @@
+from pydantic import BaseModel
+from typing import Optional
+
+
+# FastAPI Models
+class Chain(BaseModel):
+    name: str
+    contract_address: str
+    # main_net: Optional[Chain]
diff --git a/app/DexSimulator/hygdraDexSim/dataclass/transaction.py b/app/DexSimulator/hygdraDexSim/dataclass/transaction.py
@@ -0,0 +1,10 @@
+from pydantic import BaseModel
+from hygdraDexSim.dataclass.action import Action
+
+
+# FastAPI Models
+class Transaction(BaseModel):
+    token_from: str
+    token_to: str
+    amount: float = 0
+    action: Action
diff --git a/app/DexSimulator/hygdraDexSim/dataclass/wallet.py b/app/DexSimulator/hygdraDexSim/dataclass/wallet.py
@@ -0,0 +1,10 @@
+from pydantic import BaseModel
+from hygdraDexSim.dataclass.chain import Chain
+
+
+# FastAPI Models
+class Wallet(BaseModel):
+    chain: Chain
+    address: str
+    pk : str
+    amount: float = 0
diff --git a/app/DexSimulator/hygdraDexSim/wallet/generate.py b/app/DexSimulator/hygdraDexSim/wallet/generate.py
diff --git a/app/DexSimulator/interface_api.py b/app/DexSimulator/interface_api.py
@@ -0,0 +1,80 @@
+# curl -X 'GET' \
+#  'https://api.1inch.dev/swap/v5.2/1/tokens' \
+#  -H 'accept: application/json' \
+#  -H 'Authorization: Bearer YOUR-API-KEY'
+
+import requests
+from web3 import Web3
+import asyncio 
+
+chainId = 56  # Chain ID for Binance Smart Chain (BSC)
+web3RpcUrl = "https://bsc-dataseed.binance.org"  # URL for BSC node
+headers = { "Authorization": "Bearer [YOUR_API_KEY]", "accept": "application/json" }
+walletAddress = "0x...xxx"  # Your wallet address
+privateKey = "0x...xxx"  # Your wallet's private key. NEVER SHARE THIS WITH ANYONE!
+
+swapParams = {
+    "src": "0x111111111117dc0aa78b770fa6a738034120c302",  # Token address of 1INCH
+    "dst": "0x1af3f329e8be154074d8769d1ffa4ee058b1dbc3",  # Token address of DAI
+    "amount": "100000000000000000",  # Amount of 1INCH to swap (in wei)
+    "from": walletAddress,
+    "slippage": 1,  # Maximum acceptable slippage percentage for the swap (e.g., 1 for 1%)
+    "disableEstimate": False,  # Set to True to disable estimation of swap details
+    "allowPartialFill": False,  # Set to True to allow partial filling of the swap order
+}
+
+apiBaseUrl = f"https://api.1inch.dev/swap/v6.0/{chainId}"
+web3 = Web3(web3RpcUrl)
+
+# Construct full API request URL
+def apiRequestUrl(methodName, queryParams):
+    return f"{apiBaseUrl}{methodName}?{'&'.join([f'{key}={value}' for key, value in queryParams.items()])}"
+
+# Function to check token allowance
+def checkAllowance(tokenAddress, walletAddress):
+    url = apiRequestUrl("/approve/allowance", {"tokenAddress": tokenAddress, "walletAddress": walletAddress})
+    response = requests.get(url, headers=headers)
+    data = response.json()
+    return data.get("allowance")
+
+# Sign and post a transaction, return its hash
+async def signAndSendTransaction(transaction, private_key):
+    signed_transaction = web3.eth.account.signTransaction(transaction, private_key)
+    return await broadCastRawTransaction(signed_transaction.rawTransaction)
+
+# Prepare approval transaction, considering gas limit
+async def buildTxForApproveTradeWithRouter(token_address, amount=None):
+    # Assuming you have defined apiRequestUrl() function to construct the URL
+    url = apiRequestUrl("/approve/transaction", {"tokenAddress": token_address, "amount": amount} if amount else {"tokenAddress": token_address})
+    response = requests.get(url, headers=headers)
+    transaction = response.json()
+
+    # Estimate gas limit
+    wallet_address = "YOUR_WALLET_ADDRESS"
+    gas_limit = web3.eth.estimateGas(transaction, from_address=wallet_address)
+
+    return {**transaction, "gas": gas_limit}
+
+allowance = checkAllowance(swapParams["src"], walletAddress)
+print("Allowance: ", allowance)
+
+transactionForSign = await buildTxForApproveTradeWithRouter(swapParams.src)
+
+ok = input("Do you want to send a transaction to approve trade with 1inch router? (y/n): ")
+if ok.lower() == "y":
+    # Sign and send the transaction for approval
+    approveTxHash = signAndSendTransaction(transactionForSign)
+    print("Approve tx hash: ", approveTxHash)
+
+
+def buildTxForSwap(swapParams):
+    url = apiRequestUrl("/swap", swapParams)
+    swapTransaction = requests.get(url,  headers={'Authorization': f'Bearer YOUR_API_KEY'}).json()["tx"]
+    return swapTransaction
+
+ok = input("Do you want to send a transaction to exchange with 1inch router? (y/n): ")
+if ok.lower() == "y":
+    # You need to implement the signAndSendTransaction function to sign and send the transaction
+    # Replace the following line with your actual implementation
+    swapTxHash = signAndSendTransaction(swapTransaction)
+    print("Swap tx hash: ", swapTxHash)
diff --git a/app/DexSimulator/main.py b/app/DexSimulator/main.py
@@ -0,0 +1,140 @@
+import time
+from oneinch_py import OneInchSwap, TransactionHelper, OneInchOracle
+import configparser
+
+
+config = configparser.ConfigParser()
+config.read('.key')
+
+# Set up configuration (use environmental variables for private key and RPC URLs in real applications)
+rpc_url = "https://bsc-pokt.nodies.app"
+binance_rpc = "https://binance.llamarpc.com"
+# json list extracted from rpc endpoint ?
+
+public_key = config["PUBLIC_KEY"]
+private_key = config["PRIVATE_KEY"]
+api_key = config["API_key"]
+# 1 Inch API key
+
+# Initialize objects for Ethereum and Binance chain
+exchange = OneInchSwap(api_key, public_key)
+bsc_exchange = OneInchSwap(api_key, public_key, chain='binance')
+helper = TransactionHelper(api_key, rpc_url, public_key, private_key)
+bsc_helper = TransactionHelper(api_key, binance_rpc, public_key, private_key, chain='binance')
+oracle = OneInchOracle(rpc_url, chain='ethereum')
+
+
+
+# See chains currently supported by the helper method:
+helper.chains
+# {"ethereum": "1", "binance": "56", "polygon": "137", "avalanche": "43114"}
+
+# Straight to business:
+# Get a swap and do the swap
+result = exchange.get_swap("USDT", "ETH", 10, 0.5) # get the swap transaction
+result = helper.build_tx(result) # prepare the transaction for signing, gas price defaults to fast.
+result = helper.sign_tx(result) # sign the transaction using your private key
+result = helper.broadcast_tx(result) #broadcast the transaction to the network and wait for the receipt. 
+
+## If you already have token addresses you can pass those in instead of token names to all OneInchSwap functions that require a token argument
+result = exchange.get_swap("0x7fc66500c84a76ad7e9c93437bfc5ac33e2ddae9", "0x43dfc4159d86f3a37a5a4b3d4580b888ad7d4ddd", 10, 0.5) 
+
+
+#USDT to ETH price on the Oracle. Note that you need to indicate the token decimal if it is anything other than 18.
+oracle.get_rate_to_ETH("0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48", src_token_decimal=6)
+
+# Get the rate between any two tokens.
+oracle.get_rate(src_token="0x6B175474E89094C44Da98b954EedeAC495271d0F", dst_token="0x111111111117dC0aa78b770fA6A738034120C302")
+
+exchange.health_check()
+# 'OK'
+
+# Address of the 1inch router that must be trusted to spend funds for the swap
+exchange.get_spender()
+
+# Generate data for calling the contract in order to allow the 1inch router to spend funds. Token symbol or address is required. If optional "amount" variable is not supplied (in ether), unlimited allowance is granted.
+exchange.get_approve("USDT")
+exchange.get_approve("0xdAC17F958D2ee523a2206206994597C13D831ec7", amount=100)
+
+# Get the number of tokens (in Wei) that the router is allowed to spend. Option "send address" variable. If not supplied uses address supplied when Initialization the exchange object. 
+exchange.get_allowance("USDT")
+exchange.get_allowance("0xdAC17F958D2ee523a2206206994597C13D831ec7", send_address="0x12345")
+
+# Token List is stored in memory
+exchange.tokens
+# {
+#  '1INCH': {'address': '0x111111111117dc0aa78b770fa6a738034120c302',
+#            'decimals': 18,
+#            'logoURI': 'https://tokens.1inch.exchange/0x111111111117dc0aa78b770fa6a738034120c302.png',
+#            'name': '1INCH Token',
+#            'symbol': '1INCH'},
+#   'ETH': {'address': '0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee',
+#          'decimals': 18,
+#          'logoURI': 'https://tokens.1inch.exchange/0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee.png',
+#          'name': 'Ethereum',
+#          'symbol': 'ETH'},
+#   ......
+# }
+
+# Returns the exchange rate of two tokens. 
+# Tokens can be provided as symbols or addresses
+# "amount" is supplied in ether
+# NOTE: When using custom tokens, the token decimal is assumed to be 18. If your custom token has a different decimal - please manually pass it to the function (decimal=x)
+# Also returns the "price" of more expensive token in the cheaper tokens. Optional variables can be supplied as **kwargs
+exchange.get_quote(from_token_symbol='ETH', to_token_symbol='USDT', amount=1)
+# (
+#     {
+#         "fromToken": {
+#             "symbol": "ETH",
+#             "name": "Ethereum",
+#             "decimals": 18,
+#             "address": "0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee",
+#             "logoURI": "https://tokens.1inch.io/0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee.png",
+#             "tags": ["native"],
+#         },
+#         "toToken": {
+#             "symbol": "USDT",
+#             "name": "Tether USD",
+#             "address": "0xdac17f958d2ee523a2206206994597c13d831ec7",
+#             "decimals": 6,
+#             "logoURI": "https://tokens.1inch.io/0xdac17f958d2ee523a2206206994597c13d831ec7.png",
+#             "tags": ["tokens"],
+#         ...
+#     Decimal("1076.503093"),
+# )
+
+# Creates the swap data for two tokens.
+# Tokens can be provided as symbols or addresses
+# Optional variables can be supplied as **kwargs
+# NOTE: When using custom tokens, the token decimal is assumed to be 18. If your custom token has a different decimal - please manually pass it to the function (decimal=x)
+
+exchange.get_swap(from_token_symbol='ETH', to_token_symbol='USDT', amount=1, slippage=0.5)
+# {
+#     "fromToken": {
+#         "symbol": "ETH",
+#         "name": "Ethereum",
+#         "decimals": 18,
+#         "address": "0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee",
+#         "logoURI": "https://tokens.1inch.io/0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee.png",
+#         "tags": ["native"],
+#     },
+#     "toToken": {
+#         "symbol": "USDT",
+#         "name": "Tether USD",
+#         "address": "0xdac17f958d2ee523a2206206994597c13d831ec7",
+#         "decimals": 6,
+#         "logoURI": "https://tokens.1inch.io/0xdac17f958d2ee523a2206206994597c13d831ec7.png",
+#         "tags": ["tokens"],
+#
+#     ...
+#
+#     ],
+#     "tx": {
+#         "from": "0x1d05aD0366ad6dc0a284C5fbda46cd555Fb4da27",
+#         "to": "0x1111111254fb6c44bac0bed2854e76f90643097d",
+#         "data": "0xe449022e00000000000000000000000000000000000000000000000006f05b59d3b20000000000000000000000000000000000000000000000000000000000001fed825a0000000000000000000000000000000000000000000000000000000000000060000000000000000000000000000000000000000000000000000000000000000140000000000000000000000011b815efb8f581194ae79006d24e0d814b7697f6cfee7c08",
+#         "value": "500000000000000000",
+#         "gas": 178993,
+#         "gasPrice": "14183370651",
+#     },
+# }
diff --git a/app/DexSimulator/setup,py b/app/DexSimulator/setup,py
@@ -0,0 +1,25 @@
+from setuptools import setup, find_packages
+from os import path
+
+# Read the content of requirements.txt
+with open('requirements.txt') as f:
+    required_packages = f.read().splitlines()
+
+setup(
+    name='hydraDexSim',
+    version='0.1',
+    description='Dex trading simulator based on uniswap for safe training and testing.',
+    long_description=open('README.md').read(),  # if you have a README file
+    long_description_content_type='text/markdown',
+    author='Bucamp Axle',
+    author_email='axle.bucamp@gmail.com',
+    packages=find_packages(),
+    include_package_data=True,  # if you want to include other non-Python files
+    install_requires=required_packages,  # This installs packages from requirements.txt
+    classifiers=[
+        'Programming Language :: Python :: 3',
+        'License :: GNU',
+        'Operating System :: OS Independent',
+    ],
+    python_requires='>=3.8',  # adjust based on your supported Python version
+)
diff --git a/app/DexSimulator/temp,py b/app/DexSimulator/temp,py
diff --git a/app/DexSimulator/test.py b/app/DexSimulator/test.py

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +.key
 +.dockerignore
 +.env
 +build
 +data/*
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+__all__ = ["chain", "transaction", "wallet", "action"]`