feat: poc optional specification of select clause

Author: Jipperism

src/graphql/schemas/resolvers/baseTypes.ts

@@ -14,6 +14,7 @@ import { GetOrdersArgs } from "../args/orderArgs.js";
 import { GetSalesArgs } from "../args/salesArgs.js";
 import { GetSignatureRequestArgs } from "../args/signatureRequestArgs.js";
 import { GetUserArgs } from "../args/userArgs.js";
+import { CachingDatabase } from "../../../types/kyselySupabaseCaching.js";
 
 export function DataResponse<TItem extends object>(
   TItemClass: ClassType<TItem>,
@@ -38,13 +39,19 @@ export function createBaseResolver<T extends ClassType>(
     readonly supabaseCachingService = container.resolve(SupabaseCachingService);
     readonly supabaseDataService = container.resolve(SupabaseDataService);
 
-    getMetadata(args: GetMetadataArgs, single: boolean = false) {
+    getMetadata(
+      args: GetMetadataArgs,
+      {
+        single = false,
+        select,
+      }: { single?: boolean; select?: (keyof CachingDatabase["metadata"])[] },
+    ) {
       console.debug(
         `[${entityFieldName}Resolver::getMetadata] Fetching metadata`,
       );
 
       try {
-        const queries = this.supabaseCachingService.getMetadata(args);
+        const queries = this.supabaseCachingService.getMetadata(args, select);
         if (single) {
           return queries.data.executeTakeFirst();
         }

src/graphql/schemas/resolvers/hyperboardResolver.ts

@@ -41,10 +41,12 @@ class HyperboardResolver extends HyperboardBaseResolver {
           where: { hypercert_id: { in: hypercertIds } },
         }).then((res) => res.data),
       ]);
-
-      const metadata = await this.getMetadata({
-        where: { hypercerts: { hypercert_id: { in: hypercertIds } } },
-      })
+      const metadata = await this.getMetadata(
+        {
+          where: { hypercerts: { hypercert_id: { in: hypercertIds } } },
+        },
+        { select: ["name", "uri"] },
+      )
         .then((res) => res.data)
         .then((res) =>
           res.map((metadata) => {
@@ -58,7 +60,6 @@ class HyperboardResolver extends HyperboardBaseResolver {
           }),
         )
         .then((res) => res.map((metadata) => _.omit(metadata, "image")));
-
       // Get a deduplicated list of all owners
       const ownerAddresses = _.uniq([
         ...fractions.map((x) => x?.owner_address),
@@ -72,7 +73,6 @@ class HyperboardResolver extends HyperboardBaseResolver {
             ) || [],
         ) || []),
       ]).filter((x) => !!x) as string[];
-
       const users = await this.getUsers({
         where: { address: { in: ownerAddresses } },
       }).then((res) => res.data);
@@ -129,7 +129,6 @@ class HyperboardResolver extends HyperboardBaseResolver {
             },
           };
         }) || [];
-
       return {
         data: hyperboardWithSections,
         count: count ? count : data?.length,

src/services/SupabaseCachingService.ts

@@ -56,9 +56,23 @@ export class SupabaseCachingService extends BaseSupabaseService<CachingDatabase>
     };
   }
 
-  getMetadata(args: GetMetadataArgs) {
+  getMetadata(
+    args: GetMetadataArgs,
+    select?: (keyof CachingDatabase["metadata"])[],
+  ) {
+    let data = this.db
+      .selectFrom("metadata")
+      .selectAll()
+      .$if(args.where?.hypercerts, (qb) =>
+        qb.innerJoin("claims", "claims.uri", "metadata.uri"),
+      );
+
+    if (select) {
+      data = data.clearSelect().select(select.map((s) => `metadata.${s}`));
+    }
+
     return {
-      data: this.handleGetData("metadata", args),
+      data,
       count: this.handleGetCount("metadata", args),
     };
   }