Merge pull request #700 from WayneAl/master

add typus finance adapter

options/typus/getChainData.ts

@@ -0,0 +1,156 @@
+const apiUrl = "https://app.sentio.xyz/api/v1/insights/wayne/typus/query";
+
+const headers = {
+  "api-key": "UcELWyfhQjJcb26aSc59JvAYXU3x3eBGh",
+  "Content-Type": "application/json",
+};
+
+const requestData = {
+  timeRange: {
+    start: "1677918120",
+    end: "now",
+    step: 86400,
+    timezone: "UTC",
+  },
+  limit: 20,
+  queries: [
+    {
+      metricsQuery: {
+        query: "deliverySizeUSD",
+        id: "a",
+        labelSelector: {},
+        aggregate: {
+          op: "SUM",
+          grouping: ["coin_symbol"],
+        },
+        functions: [
+          {
+            name: "sum_over_time",
+            arguments: [
+              {
+                durationValue: {
+                  value: 1,
+                  unit: "d",
+                },
+              },
+            ],
+          },
+        ],
+        disabled: true,
+      },
+      dataSource: "METRICS",
+      sourceName: "",
+    },
+  ],
+  formulas: [
+    {
+      expression: "sum(a)",
+      alias: "Total",
+      id: "A",
+      disabled: false,
+      functions: [],
+    },
+  ],
+};
+
+export async function getDataFromSentio(
+  query: string,
+  start?: string,
+  end?: string,
+  step?: number
+): Promise<Value[]> {
+  if (start) {
+    requestData.timeRange.start = start;
+  }
+  if (end) {
+    requestData.timeRange.end = end;
+  }
+  if (step) {
+    requestData.timeRange.step = step;
+  }
+
+  requestData.queries[0].metricsQuery.query = query;
+
+  const jsonData = JSON.stringify(requestData);
+
+  let response = await fetch(apiUrl, {
+    method: "POST",
+    headers,
+    body: jsonData,
+  });
+
+  let data = await response.json();
+
+  let r: Value[] = data.results[0].matrix.samples[0].values;
+
+  return r;
+}
+
+interface Value {
+  timestamp: string;
+  value: number;
+}
+
+interface ChainData {
+  totalPremiumVolume: number;
+  dailyPremiumVolume: number;
+  totalNotionalVolume: number;
+  dailyNotionalVolume: number;
+  timestamp: string;
+}
+
+async function getChainData(timestamp: string): Promise<ChainData> {
+  let ts = Number(timestamp);
+  ts = ts - (ts % (24 * 60 * 60));
+  timestamp = ts.toString();
+
+  let deliverySizeUSDs = await getDataFromSentio(
+    "deliverySizeUSD",
+    "1677918120",
+    timestamp
+  );
+
+  let totalNotionalVolume = deliverySizeUSDs.reduce(
+    (acc, curr) => curr.value + acc,
+    0
+  );
+  let dailyNotionalVolume = 0;
+  let deliverySizeUSD = deliverySizeUSDs.find((v) => v.timestamp == timestamp);
+  if (deliverySizeUSD) {
+    dailyNotionalVolume = deliverySizeUSD.value;
+  }
+
+  // console.log(deliverySizeUSDs);
+
+  let premiumUSDs = await getDataFromSentio(
+    "premiumUSD",
+    "1677918120",
+    timestamp
+  );
+
+  let totalPremiumVolume = premiumUSDs.reduce(
+    (acc, curr) => curr.value + acc,
+    0
+  );
+  let dailyPremiumVolume = 0;
+  let premiumUSD = premiumUSDs.find((v) => v.timestamp == timestamp);
+  if (premiumUSD) {
+    dailyPremiumVolume = premiumUSD.value;
+  }
+
+  // console.log(premiumUSDs);
+
+  return {
+    timestamp,
+    totalNotionalVolume,
+    dailyNotionalVolume,
+    totalPremiumVolume,
+    dailyPremiumVolume,
+  };
+}
+
+export default getChainData;
+
+// (async () => {
+//   console.log(await getChainData("1689984000"));
+// })();

options/typus/index.ts

@@ -0,0 +1,22 @@
+import { CHAIN } from "../../helpers/chains";
+import { SimpleAdapter, ChainEndpoints } from "../../adapters/types";
+import getChainData from "./getChainData";
+
+const endpoints: ChainEndpoints = {
+  [CHAIN.SUI]:
+    "https://us-central1-aqueous-freedom-378103.cloudfunctions.net/mongodb",
+};
+
+const adapter: SimpleAdapter = {
+  adapter: Object.keys(endpoints).reduce((acc, chain) => {
+    return {
+      ...acc,
+      [chain]: {
+        fetch: async (ts: string) => await getChainData(ts),
+        start: async () => 1677918120,
+      },
+    };
+  }, {}),
+};
+
+export default adapter;