Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add bulbaswap volume add fees #2072

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
112 changes: 112 additions & 0 deletions aggregators/bulbaswap/index.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,112 @@
import { ChainBlocks, FetchOptions, SimpleAdapter } from "../../adapters/types";
import { CHAIN } from "../../helpers/chains";
import { httpPost } from "../../utils/fetchURL";

const v2Fees = 0.0035;

// V2 endpoints
const v2Endpoints = "https://api.bulbaswap.io/v1/subgraph-apis/v2";

// V3 endpoints
const v3Endpoints = "https://api.bulbaswap.io/v1/subgraph-apis/v3";

// GraphQL queries
const factoryQuery = `{
uniswapFactory(id: "0x8D2A8b8F7d200d75Bf5F9E84e01F9272f90EFB8b") {
totalLiquidityUSD
totalVolumeUSD
txCount
}
uniswapDayDatas(first: 1, orderBy:date, orderDirection:desc) {
dailyVolumeUSD
date
}
}`;

const v3FactoryQuery = `{
factory(id: "0xFf8578C2949148A6F19b7958aE86CAAb2779CDDD") {
totalValueLockedUSD
totalVolumeUSD
totalFeesUSD
txCount
}
uniswapDayDatas(first: 1, orderBy: date, orderDirection: desc) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

could you use query by Id, because if data not up to date will collect incorrect data

volumeUSD
feesUSD
}
}`;

// V2 fetch function
const fetchV2Data = async () => {
const response = await httpPost(v2Endpoints, {
query: factoryQuery,
});

const totalVolume = response.data.uniswapFactory?.totalVolumeUSD || "0";
const dailyVolume = response.data.uniswapDayDatas[0]?.dailyVolumeUSD || "0";
const timestamp =
response.data.uniswapDayDatas[0]?.date || Math.floor(Date.now() / 1000);

const result = {
totalVolume,
dailyVolume,
dailyFees: (Number(dailyVolume) * v2Fees).toString(),
totalFees: (Number(totalVolume) * v2Fees).toString(),
timestamp,
};

return result;
};

// V3 fetch function
const fetchV3Data = async () => {
const response = await httpPost(v3Endpoints, {
query: v3FactoryQuery,
});

const factory = response.data.factory || {};
const dayData = response.data.uniswapDayDatas[0] || {};

return {
dailyVolume: dayData.volumeUSD || "0",
totalVolume: factory.totalVolumeUSD || "0",
dailyFees: dayData.feesUSD || "0",
totalFees: factory.totalFeesUSD || "0",
};
};

const fetch = async () => {
// Get V2 data
const v2Data = await fetchV2Data();

// Get V3 data
const v3Data = await fetchV3Data();

// Merge data
return {
timestamp: v2Data.timestamp,
totalVolume: (
Number(v2Data.totalVolume || 0) + Number(v3Data.totalVolume || 0)
).toString(),
dailyVolume: (
Number(v2Data.dailyVolume || 0) + Number(v3Data.dailyVolume || 0)
).toString(),
dailyFees: (
Number(v2Data.dailyFees || 0) + Number(v3Data.dailyFees || 0)
).toString(),
totalFees: (
Number(v2Data.totalFees || 0) + Number(v3Data.totalFees || 0)
).toString(),
};
};

const adapter: SimpleAdapter = {
adapter: {
[CHAIN.MORPH]: {
fetch,
start: 1729591543,
},
},
};

export default adapter;
3 changes: 2 additions & 1 deletion helpers/chains.ts
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@ export enum CHAIN {
JBC = "jbc",
ZKFAIR = "zkfair",
ZETA = "zeta",
ASTAR = 'astar',
ASTAR = "astar",
ASTAR_ZKEVM = "astrzk",
FILECOIN = "filecoin",
FRAXTAL = "fraxtal",
Expand Down Expand Up @@ -178,6 +178,7 @@ export enum CHAIN {
FUEL = "fuel",
REAL = "real",
CELESTIA = "celestia",
MORPH = "morph",
}

// Don´t use
Expand Down
Loading