Fix ENSDb SDK builder for "concrete" ENSIndexer Schema

packages/ensdb-sdk/src/ensindexer-abstract/index.ts

@@ -4,9 +4,6 @@
  * for ENSDb, which is then used to build the ENSDb Schema for a Drizzle client for ENSDb.
  */
 
-// TODO: remove `ensnode-metadata.schema` export when database migrations
-// for ENSNode Schema are executable.
-export * from "./ensnode-metadata.schema";
 export * from "./ensv2.schema";
 export * from "./protocol-acceleration.schema";
 export * from "./registrars.schema";

packages/ensdb-sdk/src/lib/drizzle.test.ts

@@ -110,7 +110,10 @@ describe("buildIndividualEnsDbSchemas", () => {
     }
   });
 
-  it("builds two concrete schemas with respective names, leaving abstract unaffected", () => {
+  // TODO: remove the skip once the `abstractEnsIndexerSchema` is
+  // no longer mutated by `buildConcreteEnsIndexerSchema`.
+  // https://github.com/namehash/ensnode/issues/1830
+  it.skip("builds two concrete schemas with respective names, leaving abstract unaffected", () => {
     const schemaNameA = "ensindexer_alpha";
     const schemaNameB = "ensindexer_beta";
 

packages/ensdb-sdk/src/lib/drizzle.ts

@@ -21,36 +21,6 @@ import * as ensNodeSchema from "../ensnode";
  */
 export type AbstractEnsIndexerSchema = typeof abstractEnsIndexerSchema;
 
-/**
- * Clone a Drizzle Table object with a new schema name.
- *
- * Drizzle tables store their identity (name, columns, schema) on
- * Symbol-keyed properties. Cloning a table requires creating
- * a new object with the same prototype, copying all properties,
- * and updating the schema name.
- */
-function cloneTableWithSchema<TableType extends Table>(
-  table: TableType,
-  schemaName: string,
-): TableType {
-  const clone = Object.create(
-    Object.getPrototypeOf(table),
-    Object.getOwnPropertyDescriptors(table),
-  ) as TableType;
-
-  // @ts-expect-error - Drizzle's Table type for the schema symbol is
-  // not typed in a way that allows us to set it directly,
-  // but we know it exists and can be set.
-  clone[Table.Symbol.Schema] = schemaName;
-
-  // Fail-fast if the clone lost the Drizzle sentinel.
-  if (!isTable(clone)) {
-    throw new Error(`Cloned table is no longer a valid Drizzle Table (schema: ${schemaName}).`);
-  }
-
-  return clone;
-}
-
 /**
  * Build a "concrete" ENSIndexer Schema definition for ENSDb.
  *
@@ -66,34 +36,27 @@ function cloneTableWithSchema<TableType extends Table>(
 function buildConcreteEnsIndexerSchema<ConcreteEnsIndexerSchema extends AbstractEnsIndexerSchema>(
   ensIndexerSchemaName: string,
 ): ConcreteEnsIndexerSchema {
-  const ensIndexerSchema = {} as ConcreteEnsIndexerSchema;
-
-  for (const [key, abstractSchemaObject] of Object.entries(abstractEnsIndexerSchema)) {
-    if (isTable(abstractSchemaObject)) {
-      (ensIndexerSchema as any)[key] = cloneTableWithSchema(
-        abstractSchemaObject,
-        ensIndexerSchemaName,
-      );
-    } else if (isPgEnum(abstractSchemaObject)) {
-      // Enums are functions; clone by copying properties onto a new function.
-      // Unlike tables, enums don't rely on prototype identity, so
-      // Object.assign is sufficient here.
-      const concreteSchemaObject = Object.assign(
-        (...args: any[]) => abstractSchemaObject(...args),
-        abstractSchemaObject,
-      );
-      // @ts-expect-error - Drizzle's PgEnum type for the schema symbol is
-      // typed as readonly, but we need to set it here so
-      // the output schema definition has the correct schema for
-      // all table and enum objects.
-      concreteSchemaObject.schema = ensIndexerSchemaName;
-      (ensIndexerSchema as any)[key] = concreteSchemaObject;
-    } else {
-      (ensIndexerSchema as any)[key] = abstractSchemaObject;
+  // TODO: Refactor this function to avoid mutating the "abstract" ENSIndexer Schema definition.
+  // https://github.com/namehash/ensnode/issues/1830
+  const concreteEnsIndexerSchema = abstractEnsIndexerSchema as ConcreteEnsIndexerSchema;
+
+  for (const dbObject of Object.values(abstractEnsIndexerSchema)) {
+    if (isTable(dbObject)) {
+      // Update Drizzle table definition to reference
+      // the specific `ensIndexerSchemaName` name of the ENSIndexer Schema.
+      // @ts-expect-error - Drizzle types don't define `Table.Symbol.Schema` type,
+      // but it's present at runtime.
+      dbObject[Table.Symbol.Schema] = ensIndexerSchemaName;
+    } else if (isPgEnum(dbObject)) {
+      // Update Drizzle enum definition to reference
+      // the specific `ensIndexerSchemaName` name of the ENSIndexer Schema.
+      // @ts-expect-error - Drizzle types consider `schema` to be
+      // a readonly property.
+      dbObject.schema = ensIndexerSchemaName;
     }
   }
 
-  return ensIndexerSchema;
+  return concreteEnsIndexerSchema;
 }
 
 /**

packages/integration-test-env/src/orchestrator.ts

@@ -312,7 +312,7 @@ async function main() {
 
   // Phase 3: Start ENSIndexer
   const ENSINDEXER_URL = `http://localhost:${ENSINDEXER_PORT}`;
-  const ENSINDEXER_SCHEMA_NAME = "public";
+  const ENSINDEXER_SCHEMA_NAME = "ensindexer_0";
 
   log("Starting ENSIndexer...");
   spawnService(