fix: fix queries for deployments

Author: PaulRBerg

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@sablier/deployments",
   "description": "Keeping track of Sablier deployments",
-  "version": "1.0.0-alpha.37",
+  "version": "1.0.0-alpha.38",
   "author": {
     "name": "Sablier Labs Ltd",
     "url": "https://sablier.com"

src/index.ts

@@ -6,3 +6,4 @@ export * from "./releases";
 export * from "./types";
 export * as contracts from "./contracts";
 export * as nativeTokens from "./native-tokens";
+export { default as queries } from "./queries";

src/queries.ts

@@ -1,6 +1,6 @@
 import type { Sablier } from "@src/types";
 import _ from "lodash";
-import { releases as allReleases, releasesByProtocol } from "./releases/data";
+import { releases as allReleases, releasesByProtocol } from "./releases";
 
 const contracts = {
   /**
@@ -81,23 +81,17 @@ const deployments = {
    * Get many deployments.
    * - no options           ⇒ all across all releases
    * - {release}            ⇒ that release's deployments
-   * - {release, chainId}   ⇒ single deployment
    */
-  get: (opts?: {
-    release?: Sablier.Release;
-    chainId?: number;
-  }): Sablier.Deployment[] | Sablier.Deployment | undefined => {
-    const { release, chainId } = opts || {};
-
-    if (release) {
-      if (chainId) {
-        return _.find(release.deployments, (d) => d.chainId === chainId);
-      }
-      return release.deployments;
-    }
-
+  getAll: (): Sablier.Deployment[] | undefined => {
     return allReleases.flatMap((r) => r.deployments);
   },
+  get: (opts: {
+    release: Sablier.Release;
+    chainId: number;
+  }): Sablier.Deployment | undefined => {
+    const { release, chainId } = opts || {};
+    return _.find(release.deployments, (d) => d.chainId === chainId);
+  },
 };
 
 const releases = {

src/releases/data.ts

@@ -1,2 +1,39 @@
-export * from "./data";
-export { default as queries } from "../queries";
+import _ from "lodash";
+import type { Sablier } from "../types";
+import airdrops from "./airdrops";
+import flow from "./flow";
+import legacy from "./legacy";
+import lockup from "./lockup";
+
+// All releases in a flat array
+export const releases = [...airdrops, ...flow, ...legacy, ...lockup];
+
+// Grouped by protocol
+export const releasesByProtocol = {
+  airdrops,
+  flow,
+  legacy,
+  lockup,
+};
+
+// Group by version
+function groupReleases<T extends Sablier.Version>(releases: Sablier.Release[]): Record<T, Sablier.Release> {
+  return _.reduce(
+    releases,
+    (result: Record<T, Sablier.Release>, release: Sablier.Release) => {
+      result[release.version as T] = release;
+      return result;
+    },
+    {} as Record<T, Sablier.Release>,
+  );
+}
+
+export const releasesByVersion = {
+  airdrops: groupReleases<Sablier.Version.Airdrops>(airdrops),
+  flow: groupReleases<Sablier.Version.Flow>(flow),
+  legacy: groupReleases<Sablier.Version.Legacy>(legacy),
+  lockup: groupReleases<Sablier.Version.Lockup>(lockup),
+};
+
+// Re-export individual collections
+export { airdrops, flow, legacy, lockup };