feat: generate types for foreign tables

soedirgo · soedirgo · commit 1a528378093e · 2024-03-22T12:40:56.000+07:00
diff --git a/src/lib/PostgresMetaForeignTables.ts b/src/lib/PostgresMetaForeignTables.ts
@@ -1,5 +1,5 @@
 import { literal } from 'pg-format'
-import { coalesceRowsToArray } from './helpers.js'
+import { coalesceRowsToArray, filterByList } from './helpers.js'
 import { columnsSql, foreignTablesSql } from './sql/index.js'
 import { PostgresMetaResult, PostgresForeignTable } from './types.js'
 
@@ -11,25 +11,37 @@ export default class PostgresMetaForeignTables {
   }
 
   async list(options: {
+    includedSchemas?: string[]
+    excludedSchemas?: string[]
     limit?: number
     offset?: number
     includeColumns: false
   }): Promise<PostgresMetaResult<(PostgresForeignTable & { columns: never })[]>>
   async list(options?: {
+    includedSchemas?: string[]
+    excludedSchemas?: string[]
     limit?: number
     offset?: number
     includeColumns?: boolean
   }): Promise<PostgresMetaResult<(PostgresForeignTable & { columns: unknown[] })[]>>
   async list({
+    includedSchemas,
+    excludedSchemas,
     limit,
     offset,
     includeColumns = true,
   }: {
+    includedSchemas?: string[]
+    excludedSchemas?: string[]
     limit?: number
     offset?: number
     includeColumns?: boolean
   } = {}): Promise<PostgresMetaResult<PostgresForeignTable[]>> {
     let sql = generateEnrichedForeignTablesSql({ includeColumns })
+    const filter = filterByList(includedSchemas, excludedSchemas)
+    if (filter) {
+      sql += ` where schema ${filter}`
+    }
     if (limit) {
       sql += ` limit ${limit}`
     }
diff --git a/src/lib/generators.ts b/src/lib/generators.ts
@@ -1,6 +1,7 @@
 import PostgresMeta from './PostgresMeta.js'
 import {
   PostgresColumn,
+  PostgresForeignTable,
   PostgresFunction,
   PostgresMaterializedView,
   PostgresRelationship,
@@ -14,6 +15,7 @@ import { PostgresMetaResult } from './types.js'
 export type GeneratorMetadata = {
   schemas: PostgresSchema[]
   tables: Omit<PostgresTable, 'columns'>[]
+  foreignTables: Omit<PostgresForeignTable, 'columns'>[]
   views: Omit<PostgresView, 'columns'>[]
   materializedViews: Omit<PostgresMaterializedView, 'columns'>[]
   columns: PostgresColumn[]
@@ -46,6 +48,15 @@ export async function getGeneratorMetadata(
     return { data: null, error: tablesError }
   }
 
+  const { data: foreignTables, error: foreignTablesError } = await pgMeta.foreignTables.list({
+    includedSchemas: includedSchemas.length > 0 ? includedSchemas : undefined,
+    excludedSchemas,
+    includeColumns: false,
+  })
+  if (foreignTablesError) {
+    return { data: null, error: foreignTablesError }
+  }
+
   const { data: views, error: viewsError } = await pgMeta.views.list({
     includedSchemas: includedSchemas.length > 0 ? includedSchemas : undefined,
     excludedSchemas,
@@ -104,6 +115,7 @@ export async function getGeneratorMetadata(
           (includedSchemas.length === 0 || includedSchemas.includes(name))
       ),
       tables,
+      foreignTables,
       views,
       materializedViews,
       columns,
diff --git a/src/server/server.ts b/src/server/server.ts
@@ -41,6 +41,7 @@ if (EXPORT_DOCS) {
   const [
     { data: schemas, error: schemasError },
     { data: tables, error: tablesError },
+    { data: foreignTables, error: foreignTablesError },
     { data: views, error: viewsError },
     { data: materializedViews, error: materializedViewsError },
     { data: columns, error: columnsError },
@@ -54,6 +55,11 @@ if (EXPORT_DOCS) {
         GENERATE_TYPES_INCLUDED_SCHEMAS.length > 0 ? GENERATE_TYPES_INCLUDED_SCHEMAS : undefined,
       includeColumns: false,
     }),
+    pgMeta.foreignTables.list({
+      includedSchemas:
+        GENERATE_TYPES_INCLUDED_SCHEMAS.length > 0 ? GENERATE_TYPES_INCLUDED_SCHEMAS : undefined,
+      includeColumns: false,
+    }),
     pgMeta.views.list({
       includedSchemas:
         GENERATE_TYPES_INCLUDED_SCHEMAS.length > 0 ? GENERATE_TYPES_INCLUDED_SCHEMAS : undefined,
@@ -86,6 +92,9 @@ if (EXPORT_DOCS) {
   if (tablesError) {
     throw new Error(tablesError.message)
   }
+  if (foreignTablesError) {
+    throw new Error(foreignTablesError.message)
+  }
   if (viewsError) {
     throw new Error(viewsError.message)
   }
@@ -113,6 +122,7 @@ if (EXPORT_DOCS) {
           GENERATE_TYPES_INCLUDED_SCHEMAS.includes(name)
       ),
       tables: tables!,
+      foreignTables: foreignTables!,
       views: views!,
       materializedViews: materializedViews!,
       columns: columns!,
diff --git a/src/server/templates/typescript.ts b/src/server/templates/typescript.ts
@@ -12,6 +12,7 @@ import type { GeneratorMetadata } from '../../lib/generators.js'
 export const apply = async ({
   schemas,
   tables,
+  foreignTables,
   views,
   materializedViews,
   columns,
@@ -23,7 +24,7 @@ export const apply = async ({
   detectOneToOneRelationships: boolean
 }): Promise<string> => {
   const columnsByTableId = Object.fromEntries<PostgresColumn[]>(
-    [...tables, ...views, ...materializedViews].map((t) => [t.id, []])
+    [...tables, ...foreignTables, ...views, ...materializedViews].map((t) => [t.id, []])
   )
   columns
     .filter((c) => c.table_id in columnsByTableId)
@@ -37,7 +38,7 @@ export type Database = {
   ${schemas
     .sort(({ name: a }, { name: b }) => a.localeCompare(b))
     .map((schema) => {
-      const schemaTables = tables
+      const schemaTables = [...tables, ...foreignTables]
         .filter((table) => table.schema === schema.name)
         .sort(({ name: a }, { name: b }) => a.localeCompare(b))
       const schemaViews = [...views, ...materializedViews]
diff --git a/test/db/00-init.sql b/test/db/00-init.sql
@@ -87,7 +87,7 @@ create extension postgres_fdw;
 create server foreign_server foreign data wrapper postgres_fdw options (host 'localhost', port '5432', dbname 'postgres');
 create user mapping for postgres server foreign_server options (user 'postgres', password 'postgres');
 create foreign table foreign_table (
-  id int8,
+  id int8 not null,
   name text,
   status user_status
 ) server foreign_server options (schema_name 'public', table_name 'users');
diff --git a/test/lib/foreign-tables.ts b/test/lib/foreign-tables.ts
@@ -22,71 +22,71 @@ test('list', async () => {
   const res = await pgMeta.foreignTables.list()
   expect(cleanNondetFromResponse(res).data?.find(({ name }) => name === 'foreign_table'))
     .toMatchInlineSnapshot(`
-    {
-      "columns": [
-        {
-          "check": null,
-          "comment": null,
-          "data_type": "bigint",
-          "default_value": null,
-          "enums": [],
-          "format": "int8",
-          "identity_generation": null,
-          "is_generated": false,
-          "is_identity": false,
-          "is_nullable": true,
-          "is_unique": false,
-          "is_updatable": true,
-          "name": "id",
-          "ordinal_position": 1,
-          "schema": "public",
-          "table": "foreign_table",
-        },
-        {
-          "check": null,
-          "comment": null,
-          "data_type": "text",
-          "default_value": null,
-          "enums": [],
-          "format": "text",
-          "identity_generation": null,
-          "is_generated": false,
-          "is_identity": false,
-          "is_nullable": true,
-          "is_unique": false,
-          "is_updatable": true,
-          "name": "name",
-          "ordinal_position": 2,
-          "schema": "public",
-          "table": "foreign_table",
-        },
-        {
-          "check": null,
-          "comment": null,
-          "data_type": "USER-DEFINED",
-          "default_value": null,
-          "enums": [
-            "ACTIVE",
-            "INACTIVE",
-          ],
-          "format": "user_status",
-          "identity_generation": null,
-          "is_generated": false,
-          "is_identity": false,
-          "is_nullable": true,
-          "is_unique": false,
-          "is_updatable": true,
-          "name": "status",
-          "ordinal_position": 3,
-          "schema": "public",
-          "table": "foreign_table",
-        },
-      ],
-      "comment": null,
-      "name": "foreign_table",
-      "schema": "public",
-    }
-  `)
+      {
+        "columns": [
+          {
+            "check": null,
+            "comment": null,
+            "data_type": "bigint",
+            "default_value": null,
+            "enums": [],
+            "format": "int8",
+            "identity_generation": null,
+            "is_generated": false,
+            "is_identity": false,
+            "is_nullable": false,
+            "is_unique": false,
+            "is_updatable": true,
+            "name": "id",
+            "ordinal_position": 1,
+            "schema": "public",
+            "table": "foreign_table",
+          },
+          {
+            "check": null,
+            "comment": null,
+            "data_type": "text",
+            "default_value": null,
+            "enums": [],
+            "format": "text",
+            "identity_generation": null,
+            "is_generated": false,
+            "is_identity": false,
+            "is_nullable": true,
+            "is_unique": false,
+            "is_updatable": true,
+            "name": "name",
+            "ordinal_position": 2,
+            "schema": "public",
+            "table": "foreign_table",
+          },
+          {
+            "check": null,
+            "comment": null,
+            "data_type": "USER-DEFINED",
+            "default_value": null,
+            "enums": [
+              "ACTIVE",
+              "INACTIVE",
+            ],
+            "format": "user_status",
+            "identity_generation": null,
+            "is_generated": false,
+            "is_identity": false,
+            "is_nullable": true,
+            "is_unique": false,
+            "is_updatable": true,
+            "name": "status",
+            "ordinal_position": 3,
+            "schema": "public",
+            "table": "foreign_table",
+          },
+        ],
+        "comment": null,
+        "name": "foreign_table",
+        "schema": "public",
+      }
+    `)
 })
 
 test('list without columns', async () => {
@@ -117,7 +117,7 @@ test('retrieve', async () => {
             "identity_generation": null,
             "is_generated": false,
             "is_identity": false,
-            "is_nullable": true,
+            "is_nullable": false,
             "is_unique": false,
             "is_updatable": true,
             "name": "id",
diff --git a/test/server/typegen.ts b/test/server/typegen.ts
@@ -36,6 +36,24 @@ test('typegen', async () => {
             Update: {}
             Relationships: []
           }
+          foreign_table: {
+            Row: {
+              id: number
+              name: string | null
+              status: Database["public"]["Enums"]["user_status"] | null
+            }
+            Insert: {
+              id: number
+              name?: string | null
+              status?: Database["public"]["Enums"]["user_status"] | null
+            }
+            Update: {
+              id?: number
+              name?: string | null
+              status?: Database["public"]["Enums"]["user_status"] | null
+            }
+            Relationships: []
+          }
           memes: {
             Row: {
               category: number | null
@@ -519,6 +537,24 @@ test('typegen w/ one-to-one relationships', async () => {
             Update: {}
             Relationships: []
           }
+          foreign_table: {
+            Row: {
+              id: number
+              name: string | null
+              status: Database["public"]["Enums"]["user_status"] | null
+            }
+            Insert: {
+              id: number
+              name?: string | null
+              status?: Database["public"]["Enums"]["user_status"] | null
+            }
+            Update: {
+              id?: number
+              name?: string | null
+              status?: Database["public"]["Enums"]["user_status"] | null
+            }
+            Relationships: []
+          }
           memes: {
             Row: {
               category: number | null
