@synfutures/sdks-aggregator

Oyster Aggregator

• Oyster Aggregator
  • Intruduction
  • Install
    • Initialization example
  • Example
    • Query single route
    • Query split route
    • Simulate mix swap
    • Simulate multi swap
    • Mix swap
    • Multi swap

Intruduction

Our aggregator contract is a smart contract that allows users to swap tokens using multiple pools. This package includes one plugin:

• aggregatorPlugin

Install

npm i @derivation-tech/context @derivation-tech/tx-plugin @synfutures/sdks-aggregator

Initialization example

// initialize the SDK
import { Context } from '@derivation-tech/context';
import { txPlugin } from '@derivation-tech/tx-plugin';
import { aggregatorPlugin, DefaultEthGasEstimator } from '@synfutures/sdks-aggregator';

ctx = new Context('base', { url: 'your rpc url' });
ctx.use(aggregatorPlugin());
ctx.use(txPlugin({ gasEstimator: new DefaultEthGasEstimator() }));

await ctx.init();

Example

Query single route

const usdc = await ctx.getTokenInfo('USDC');
const weth = await ctx.getTokenInfo('WETH');
const result = await ctx.aggregator.querySingleRoute({
    fromTokenAddress: usdc.address,
    toTokenAddress: weth.address,
    fromAmount: parseUnits('10000', usdc.decimals),
    excludePoolTypes: [],
});

Query split route

const usdc = await ctx.getTokenInfo('USDC');
const weth = await ctx.getTokenInfo('WETH');
const result = await ctx.aggregator.querySplitRoute({
    fromTokenAddress: usdc.address,
    toTokenAddress: weth.address,
    fromAmount: parseUnits('10000', usdc.decimals),
    excludePoolTypes: [],
    isDirect: true,
});

Simulate mix swap

const usdc = await ctx.getTokenInfo('USDC');
const weth = await ctx.getTokenInfo('WETH');

const fromToken = weth;
const toToken = usdc;
const fromAmount = parseUnits('0.001', fromToken.decimals);

const result = await ctx.aggregator.simulateMixSwap({
    fromTokenAddress: fromToken.address,
    toTokenAddress: toToken.address,
    fromTokenDecimals: fromToken.decimals,
    toTokenDecimals: toToken.decimals,
    fromAmount,
    excludePoolTypes: [],
    slippageInBps: 100, // 1%
});
console.log('priceImpact', result.priceImpact);
console.log('minReceivedAmount', result.minReceivedAmount.toString());
console.log('route', result.route);

Simulate multi swap

const usdc = await ctx.getTokenInfo('USDC');
const weth = await ctx.getTokenInfo('WETH');

const fromToken = usdc;
const toToken = weth;
const fromAmount = parseUnits('10', fromToken.decimals);

const result = await ctx.aggregator.simulateMultiSwap({
    fromTokenAddress: fromToken.address,
    toTokenAddress: toToken.address,
    fromTokenDecimals: fromToken.decimals,
    toTokenDecimals: toToken.decimals,
    fromAmount,
    excludePoolTypes: [],
    isDirect: true,
    slippageInBps: 100, // 1%
});
console.log('priceImpact', result.priceImpact);
console.log('minReceivedAmount', result.minReceivedAmount.toString());
console.log('route', result.route);

Mix swap

const signer = await ctx.getSigner('SIGNER_NAME');

const usdc = await ctx.getTokenInfo('USDC');
const weth = await ctx.getTokenInfo('WETH');
const fromToken = usdc;
const toToken = weth;
const fromTokenAmount = parseUnits('10', fromToken.decimals);
const result = await ctx.aggregator.querySingleRoute({
    fromTokenAddress: fromToken.address,
    toTokenAddress: toToken.address,
    fromAmount: fromTokenAmount,
    excludePoolTypes: [],
});

console.log(result.bestPoolPath[0]);
const approveTo = OYSTER_AGGREGATOR_ADDRESS[ctx.chainId];
console.log('approveTo', approveTo);

await ctx.erc20.approveIfNeeded(signer, fromToken.address, approveTo, fromTokenAmount);
const tx = await ctx.aggregator.mixSwap(
    {
        fromTokenAddress: fromToken.address,
        fromTokenAmount,
        toTokenAddress: toToken.address,
        bestPath: result.bestPath,
        bestPoolPath: result.bestPoolPath,
        bestAmount: result.bestAmount,
        slippageInBps: 100, // 1%
        broker: ZERO_ADDRESS,
        brokerFeeRate: ZERO,
        deadline: NULL_DDL,
    },
    { signer },
);

Multi swap

const signer = await ctx.getSigner('SIGNER_NAME');

const usdc = await ctx.getTokenInfo('USDC');
const weth = await ctx.getTokenInfo('WETH');
const fromToken = weth;
const toToken = usdc;
const fromTokenAmount = parseUnits('0.001', fromToken.decimals);
const result = await ctx.aggregator.querySplitRoute({
    fromTokenAddress: fromToken.address,
    toTokenAddress: toToken.address,
    fromAmount: fromTokenAmount,
    excludePoolTypes: [],
    isDirect: true,
});

console.log(result.bestPathInfo);
const approveTo = OYSTER_AGGREGATOR_ADDRESS[ctx.chainId];
console.log('approveTo', approveTo);

await ctx.erc20.approveIfNeeded(signer, fromToken.address, approveTo, fromTokenAmount);
const tx = await ctx.aggregator.multiSwap(
    {
        fromTokenAddress: fromToken.address,
        fromTokenAmount,
        toTokenAddress: toToken.address,
        bestPathInfo: result.bestPathInfo,
        bestAmount: result.bestAmount,
        slippageInBps: 100, // 1%
        broker: ZERO_ADDRESS,
        brokerFeeRate: ZERO,
        deadline: NULL_DDL,
    },
    { signer },
);