feat(pool): add swap functionality

Frontend/Configuration/ChainSettings.cs

@@ -4,4 +4,5 @@ public class ChainSettings
         public  int ChainId { get; set; }
         public  string TokenAddress { get; set; }
         public  UniswapSettings Uniswap { get; set; }
+        public string SwapRouterV2Address { get; set; }
     }
\ No newline at end of file

Frontend/Events/SwapEventDTO.cs

+using Nethereum.ABI.FunctionEncoding.Attributes;
+using Nethereum.Contracts;
+using System.Numerics;
+
+namespace Frontend.Events;
+
+[Event("Swap")]
+public class SwapEventDTO : IEventDTO
+{
+    [Parameter("uint256", "amountIn", 1, true)]
+    public BigInteger AmountIn { get; set; }
+
+    [Parameter("uint256", "amountOut", 2, true)]
+    public BigInteger AmountOut { get; set; }
+}
\ No newline at end of file

Frontend/Functions/FeeFunction.cs

+using Nethereum.ABI.FunctionEncoding.Attributes;
+using Nethereum.Contracts;
+
+namespace Frontend.Functions;
+
+[Function("fee", "uint24")]
+public class FeeFunction : FunctionMessage{
+
+}
\ No newline at end of file

Frontend/Functions/SwapExactInputSingleFunction.cs

+using System.Numerics;
+using Nethereum.ABI.FunctionEncoding.Attributes;
+using Nethereum.Contracts;
+using HexBigInteger = Nethereum.Hex.HexTypes.HexBigInteger;
+
+namespace Frontend.Functions;
+
+public class SwapExactInputSingleFunction : FunctionMessage
+{
+    [Parameter("address", "tokenIn", 1)]
+    public string TokenIn { get; set; }
+
+    [Parameter("address", "tokenOut", 2)]
+    public string TokenOut { get; set; }
+
+    [Parameter("uint256", "amountIn", 3)]
+    public BigInteger AmountIn { get; set; }
+
+    [Parameter("uint256", "amountOutMinimum", 4)]
+    public BigInteger AmountOutMinimum { get; set; }
+
+    [Parameter("address", "recipient", 5)]
+    public string Recipient { get; set; }
+
+    [Parameter("uint256", "deadline", 6)]
+    public HexBigInteger Deadline { get; set; }
+
+    [Parameter("uint24", "fee", 7)]
+    public uint Fee { get; set; }
+
+    [Parameter("uint160", "sqrtPriceLimitX96", 8)]
+    public BigInteger SqrtPriceLimitX96 { get; set; }
+}
\ No newline at end of file

Frontend/PoolV3Client.cs

 using System.Numerics;
 using Frontend.Functions;
+using Frontend.Events;
 using Nethereum.Contracts;
-using Nethereum.Contracts.Standards.ERC20.ContractDefinition;
+using Nethereum.Hex.HexTypes;
 using Nethereum.Web3;
 using Nethereum.Web3.Accounts;
 
-using Microsoft.Extensions.FileProviders.Physical;
-using Microsoft.AspNetCore.Mvc.RazorPages.Infrastructure;
+using Frontend.Configuration;
 namespace Frontend;
 
 public class PoolV3Client
 {
     private readonly Contract _pool;
     private readonly Web3 _web3;
+    private readonly ChainSettings _chainSettings;
 
-    private string? token0Address=null;
-    private string? token1Address=null;
+    private string? token0Address = null;
+    private string? token1Address = null;
+    private uint? poolFeeTier = null;
 
-
-    public PoolV3Client(string poolAddress, Web3 web3)
+    public PoolV3Client(string poolAddress, Web3 web3, ChainSettings chainSettings)
     {
 
         _pool = web3.Eth.GetContract(
@@ -33,6 +34,7 @@ public class PoolV3Client
             poolAddress
         );
         _web3 = web3;
+        _chainSettings = chainSettings;
     }
 
     public async Task<decimal> GetPairRatio()
@@ -54,29 +56,72 @@ public class PoolV3Client
     {
         return new BigInteger(Math.Sqrt(price) * Math.Pow(2, 96));
     }
-    public async Task<string> Token0Address(){
-        if(null == token0Address){
+    public async Task<string> Token0Address()
+    {
+        if (null == token0Address)
+        {
             var handler = _web3.Eth.GetContractQueryHandler<Token0Function>();
             var func = new Token0Function();
-            var result = await handler.QueryAsync<string>(_pool.Address, func); 
-            token0Address=result;
+            var result = await handler.QueryAsync<string>(_pool.Address, func);
+            token0Address = result;
         }
-        
+
         return token0Address;
     }
 
-     public async Task<string> Token1Address(){
-        if(null == token1Address){
+    public async Task<string> Token1Address()
+    {
+        if (null == token1Address)
+        {
             var handler = _web3.Eth.GetContractQueryHandler<Token1Function>();
             var func = new Token1Function();
-            var result = await handler.QueryAsync<string>(_pool.Address, func); 
-            token1Address=result;
+            var result = await handler.QueryAsync<string>(_pool.Address, func);
+            token1Address = result;
         }
-        
+
         return token1Address;
     }
 
-    public async Task swap(){
-        
+    public async Task<uint> getPoolFeeTier()
+    {
+        if (null == poolFeeTier)
+        {
+            var handler = _web3.Eth.GetContractQueryHandler<FeeFunction>();
+            var func = new FeeFunction();
+            var result = await handler.QueryAsync<int>(_pool.Address, func);
+            poolFeeTier = (uint)result;
+        }
+        return (uint)poolFeeTier;
+    }
+
+
+    /*
+    this function should swap the tokens in the pool
+    */
+    public async Task<decimal> SwapAsync(string fromTokenAddress, string toTokenAddress, decimal amount, Account account, decimal amountOutMinimum=0, uint sqrtPriceLimitX96=0)
+    {
+        var swapFunction = new SwapExactInputSingleFunction
+        {
+            TokenIn = fromTokenAddress,
+            TokenOut = toTokenAddress,
+            AmountIn = Web3.Convert.ToWei(amount),
+            AmountOutMinimum = Web3.Convert.ToWei(amountOutMinimum), // Set your minimum amount out
+            Recipient = account.Address,
+            Deadline = new HexBigInteger(DateTimeOffset.UtcNow.ToUnixTimeSeconds() + 90), // 1:30 minutes from now
+            Fee = await getPoolFeeTier(),
+            SqrtPriceLimitX96 = sqrtPriceLimitX96
+        };
+
+        var handler = _web3.Eth.GetContractTransactionHandler<SwapExactInputSingleFunction>();
+        var transactionReceipt = await handler.SendRequestAndWaitForReceiptAsync(_chainSettings.SwapRouterV2Address, swapFunction);
+        var swapEvent = transactionReceipt.DecodeAllEvents<SwapEventDTO>();
+        if (swapEvent.Count > 0)
+        {
+            var receivedAmount = swapEvent[0].Event.AmountOut;
+            return Web3.Convert.FromWei(receivedAmount);
+        }
+
+
+        throw new Exception("Swap event not found in transaction receipt");
     }
 }
\ No newline at end of file

Frontend/appsettings.json

@@ -12,7 +12,8 @@
       "UniswapV3Factory":"0x0227628f3F023bb0B980b67D528571c95c6DaC1c",
       "QuoterV2":"0xEd1f6473345F45b75F8179591dd5bA1888cf2FB3",
       "WethTokenAddress": "0xfff9976782d46cc05630d1f6ebab18b2324d6b14",
-      "RocEthPoolAddress": "0xF22CA6B27eaC677f132945C50Cd3499A9b8a6CBC"
+      "RocEthPoolAddress": "0xF22CA6B27eaC677f132945C50Cd3499A9b8a6CBC",
+      "SwapRouterV2Address": "0x3bFA4769FB09eefC5a80d6E87c3B9C650f7Ae48E"
     }
   },
   "AllowedHosts": "*",