Feat: Add STREAM emissions (#137)

* Add Streamflow adapter and protocol token emission

* add protocol id

---------

Co-authored-by: Reynardo Etenia Wongso <[email protected]>

Author: tatomir-streamflow

adapters/streamflow/index.ts

@@ -0,0 +1,76 @@
+import { CliffAdapterResult } from "../../types/adapters";
+
+type UnlockScheduleEntry = {
+  ts: number;
+  value: string;
+}
+
+type LabelStats = {
+  tokensLocked: string;
+  tokensDeposited: string;
+  tokensUnlocked: string;
+  total: number;
+  scheduled: number;
+  completed: number;
+  paused: number;
+  canceled: number;
+  active: number;
+  unlockSchedule: UnlockScheduleEntry[];
+}
+
+type StreamflowStats = {
+  byLabel: {
+    [labelName: string]: LabelStats;
+  };
+}
+
+type TokenInfo = {
+  decimals: number;
+}
+
+type StreamflowAPIResponse = {
+  stats: StreamflowStats;
+  info: TokenInfo;
+  defaultLabel: string;
+}
+
+export async function fetchStreamStats(mint: string): Promise<StreamflowAPIResponse> {
+  return await fetch(`https://api.streamflow.finance/v2/api/token-dashboards/SOLANA/${mint}`).then(r => r.json());
+}
+
+export async function processUnlockSchedules(mint: string): Promise<{ [labelName: string]: CliffAdapterResult[] }> {
+  const data = await fetchStreamStats(mint);
+  const result: { [labelName: string]: CliffAdapterResult[] } = {};
+  const tokenDecimals = data.info.decimals;
+
+  Object.entries(data.stats.byLabel).filter(([labelName]) => labelName !== data.defaultLabel).forEach(([labelName, labelStats]) => {
+    const unlockSchedule = labelStats.unlockSchedule;
+    
+    if (unlockSchedule.length === 0) {
+      result[labelName] = [];
+      return;
+    }
+    
+    let previousValue = 0;
+    const sections: CliffAdapterResult[] = [];
+    
+    unlockSchedule.forEach((entry) => {
+      const currentValue = parseFloat(entry.value) / 10 ** tokenDecimals;
+      const unlockAmount = currentValue - previousValue;
+      
+      if (unlockAmount > 0) {
+        sections.push({
+          type: "cliff",
+          start: entry.ts,
+          amount: unlockAmount,
+        });
+      }
+      
+      previousValue = currentValue;
+    });
+
+    result[labelName] = sections;
+  });
+
+  return result;
+}

protocols/streamflow.ts

@@ -0,0 +1,37 @@
+import { processUnlockSchedules } from "../adapters/streamflow";
+import { Protocol } from "../types/adapters";
+
+const STREAM_MINT = "STREAMribRwybYpMmSYoCsQUdr6MZNXEqHgm7p1gu9M";
+const CHAIN = "solana";
+
+async function createStreamflowProtocol(): Promise<Protocol> {
+  const unlockSchedules = await processUnlockSchedules(STREAM_MINT);
+
+  return {
+    ...unlockSchedules,
+    meta: {
+      sources: [
+        "https://app.streamflow.finance/project-dashboard/solana/mainnet/STREAMribRwybYpMmSYoCsQUdr6MZNXEqHgm7p1gu9M",
+        "https://docs.streamflow.finance/en/articles/9869372-stream-token",
+      ],
+      token: `${CHAIN}:${STREAM_MINT}`,
+      protocolIds: ["2608"],
+      notes: [
+        "Token unlock schedule data is fetched from the Streamflow Finance API",
+        "Data includes all labels and their respective unlock schedules",
+        "Sections are dynamically created based on the labels returned by the API",
+      ],
+      chain: CHAIN,
+    },
+    categories:
+    {
+        insiders:["Contributors"],
+        privateSale:["Investors"],
+        noncirculating:["Ecosystem"],
+    }
+  };
+}
+
+const streamflow = createStreamflowProtocol;
+
+export default streamflow;