Feat/curve connector

src/amm/amm.controllers.ts

@@ -58,7 +58,10 @@ import {
   trade as plentyTrade,
   estimateGas as plentyEstimateGas,
 } from '../connectors/plenty/plenty.controllers';
-import { getInitializedChain, getConnector } from '../services/connection-manager';
+import {
+  getInitializedChain,
+  getConnector,
+} from '../services/connection-manager';
 import {
   Chain as Ethereumish,
   Nearish,
@@ -74,13 +77,15 @@ import { Tinyman } from '../connectors/tinyman/tinyman';
 import { Plenty } from '../connectors/plenty/plenty';
 
 export async function price(req: PriceRequest): Promise<PriceResponse> {
-  const chain = await getInitializedChain<Algorand | Ethereumish | Nearish | Tezosish>(
-    req.chain,
-    req.network
-  );
-  const connector: Uniswapish | RefAMMish | Tinyman | Plenty = await getConnector<
-    Uniswapish | RefAMMish | Tinyman | Plenty
-  >(req.chain, req.network, req.connector);
+  const chain = await getInitializedChain<
+    Algorand | Ethereumish | Nearish | Tezosish
+  >(req.chain, req.network);
+  const connector: Uniswapish | RefAMMish | Tinyman | Plenty =
+    await getConnector<Uniswapish | RefAMMish | Tinyman | Plenty>(
+      req.chain,
+      req.network,
+      req.connector
+    );
 
   if (connector instanceof Plenty) {
     return plentyPrice(<Tezosish>chain, connector, req);
@@ -95,13 +100,15 @@ export async function price(req: PriceRequest): Promise<PriceResponse> {
 }
 
 export async function trade(req: TradeRequest): Promise<TradeResponse> {
-  const chain = await getInitializedChain<Algorand | Ethereumish | Nearish | Tezosish>(
-    req.chain,
-    req.network
-  );
-  const connector: Uniswapish | RefAMMish | Tinyman | Plenty = await getConnector<
-    Uniswapish | RefAMMish | Tinyman | Plenty
-  >(req.chain, req.network, req.connector);
+  const chain = await getInitializedChain<
+    Algorand | Ethereumish | Nearish | Tezosish
+  >(req.chain, req.network);
+  const connector: Uniswapish | RefAMMish | Tinyman | Plenty =
+    await getConnector<Uniswapish | RefAMMish | Tinyman | Plenty>(
+      req.chain,
+      req.network,
+      req.connector
+    );
 
   if (connector instanceof Plenty) {
     return plentyTrade(<Tezosish>chain, connector, req);
@@ -180,13 +187,15 @@ export async function poolPrice(
 export async function estimateGas(
   req: NetworkSelectionRequest
 ): Promise<EstimateGasResponse> {
-  const chain = await getInitializedChain<Algorand | Ethereumish | Nearish | Tezosish>(
-    req.chain,
-    req.network
-  );
-  const connector: Uniswapish | RefAMMish | Tinyman | Plenty = await getConnector<
-    Uniswapish | RefAMMish | Plenty
-  >(req.chain, req.network, req.connector);
+  const chain = await getInitializedChain<
+    Algorand | Ethereumish | Nearish | Tezosish
+  >(req.chain, req.network);
+  const connector: Uniswapish | RefAMMish | Tinyman | Plenty =
+    await getConnector<Uniswapish | RefAMMish | Plenty>(
+      req.chain,
+      req.network,
+      req.connector
+    );
 
   if (connector instanceof Plenty) {
     return plentyEstimateGas(<Tezosish>chain, connector);

src/chains/avalanche/avalanche.ts

@@ -11,6 +11,7 @@ import { Ethereumish } from '../../services/common-interfaces';
 import { SushiswapConfig } from '../../connectors/sushiswap/sushiswap.config';
 import { ConfigManagerV2 } from '../../services/config-manager-v2';
 import { EVMController } from '../ethereum/evm.controllers';
+import { Curve } from '../../connectors/curve/curve';
 
 export class Avalanche extends EthereumBase implements Ethereumish {
   private static _instances: { [name: string]: Avalanche };
@@ -93,6 +94,13 @@ export class Avalanche extends EthereumBase implements Ethereumish {
         'avalanche',
         this._chain
       );
+    } else if (reqSpender === 'curve') {
+      const curve = Curve.getInstance('ethereum', this._chain);
+      if (!curve.ready()) {
+        curve.init();
+        throw Error('Curve not ready');
+      }
+      spender = curve.router;
     } else {
       spender = reqSpender;
     }

src/chains/chain.routes.ts

@@ -156,10 +156,8 @@ export namespace ChainRoutes {
         req: Request<{}, {}, NonceRequest>,
         res: Response<NonceResponse | string, {}>
       ) => {
-        if (req.body.chain === 'tezos')
-          validateTezosNonceRequest(req.body);
-        else
-          validateNonceRequest(req.body);
+        if (req.body.chain === 'tezos') validateTezosNonceRequest(req.body);
+        else validateNonceRequest(req.body);
         const chain = await getInitializedChain(
           req.body.chain,
           req.body.network

src/chains/ethereum/ethereum.ts

@@ -13,6 +13,7 @@ import { UniswapConfig } from '../../connectors/uniswap/uniswap.config';
 import { Perp } from '../../connectors/perp/perp';
 import { SushiswapConfig } from '../../connectors/sushiswap/sushiswap.config';
 import { OpenoceanConfig } from '../../connectors/openocean/openocean.config';
+import { Curve } from '../../connectors/curve/curve';
 
 // MKR does not match the ERC20 perfectly so we need to use a separate ABI.
 const MKR_ADDRESS = '0x9f8f72aa9304c8b593d555f12ef6589cc3a579a2';
@@ -196,6 +197,13 @@ export class Ethereum extends EthereumBase implements Ethereumish {
       spender = perp.perp.contracts.vault.address;
     } else if (reqSpender === 'openocean') {
       spender = OpenoceanConfig.config.routerAddress('ethereum', this._chain);
+    } else if (reqSpender === 'curve') {
+      const curve = Curve.getInstance('ethereum', this._chain);
+      if (!curve.ready()) {
+        curve.init();
+        throw Error('Curve not ready');
+      }
+      spender = curve.router;
     } else {
       spender = reqSpender;
     }

src/chains/ethereum/ethereum.validators.ts

@@ -62,6 +62,7 @@ export const validateSpender: Validator = mkValidator(
       val === 'vvs' ||
       val === 'pancakeswap' ||
       val === 'xsswap' ||
+      val === 'curve' ||
       isAddress(val))
 );
 

src/chains/polygon/polygon.ts

@@ -11,6 +11,7 @@ import { Ethereumish } from '../../services/common-interfaces';
 import { ConfigManagerV2 } from '../../services/config-manager-v2';
 import { OpenoceanConfig } from '../../connectors/openocean/openocean.config';
 import { EVMController } from '../ethereum/evm.controllers';
+import { Curve } from '../../connectors/curve/curve';
 
 export class Polygon extends EthereumBase implements Ethereumish {
   private static _instances: { [name: string]: Polygon };
@@ -86,6 +87,13 @@ export class Polygon extends EthereumBase implements Ethereumish {
       );
     } else if (reqSpender === 'openocean') {
       spender = OpenoceanConfig.config.routerAddress('polygon', this._chain);
+    } else if (reqSpender === 'curve') {
+      const curve = Curve.getInstance('ethereum', this._chain);
+      if (!curve.ready()) {
+        curve.init();
+        throw Error('Curve not ready');
+      }
+      spender = curve.router;
     } else {
       spender = reqSpender;
     }

src/connectors/connectors.routes.ts

@@ -19,6 +19,7 @@ import { XsswapConfig } from './xsswap/xsswap.config';
 import { ConnectorsResponse } from './connectors.request';
 import { DexalotCLOBConfig } from './dexalot/dexalot.clob.config';
 import { TinymanConfig } from './tinyman/tinyman.config';
+import { CurveConfig } from './curve/curveswap.config';
 import { PlentyConfig } from './plenty/plenty.config';
 import { KujiraConfig } from './kujira/kujira.config';
 
@@ -153,6 +154,12 @@ export namespace ConnectorsRoutes {
             chain_type: TinymanConfig.config.chainType,
             available_networks: TinymanConfig.config.availableNetworks,
           },
+          {
+            name: 'curve',
+            trading_type: CurveConfig.config.tradingTypes,
+            chain_type: CurveConfig.config.chainType,
+            available_networks: CurveConfig.config.availableNetworks,
+          },
           {
             name: 'plenty',
             trading_type: PlentyConfig.config.tradingTypes,