Merge pull request #853 from constructive-io/devin/1773967756-export-meta-jsonb-array

feat: add jsonb[] type support in export-meta.ts and csv-to-pg parser

Author: pyramation

packages/csv-to-pg/src/parse.ts

@@ -458,6 +458,39 @@ const getCoercionFunc = (type: string, from: string[], opts: FieldOptions, field
         });
         return wrapValue(val, opts);
       };
+    case 'jsonb[]':
+      return (record: Record<string, unknown>): Node => {
+        const rawValue = record[from[0]];
+        if (isNullToken(rawValue)) {
+          return makeNullOrThrow(fieldName, rawValue, type, required, 'value is empty or null');
+        }
+        if (Array.isArray(rawValue)) {
+          if (rawValue.length === 0) {
+            return makeNullOrThrow(fieldName, rawValue, type, required, 'array is empty');
+          }
+          const elements = rawValue.map(el => JSON.stringify(el));
+          const arrayLiteral = psqlArray(elements);
+          if (isEmpty(arrayLiteral)) {
+            return makeNullOrThrow(fieldName, rawValue, type, required, 'failed to format array');
+          }
+          const val = nodes.aConst({
+            sval: ast.string({ sval: String(arrayLiteral) })
+          });
+          return wrapValue(val, opts);
+        }
+        // If it's a string, try to parse as JSON array
+        if (typeof rawValue === 'string') {
+          const parsed = parseJson(cleanseEmptyStrings(rawValue));
+          if (isEmpty(parsed)) {
+            return makeNullOrThrow(fieldName, rawValue, type, required, 'value is empty or null');
+          }
+          const val = nodes.aConst({
+            sval: ast.string({ sval: String(parsed) })
+          });
+          return wrapValue(val, opts);
+        }
+        return makeNullOrThrow(fieldName, rawValue, type, required, 'value is not an array');
+      };
     default:
       return (record: Record<string, unknown>): Node => {
         const rawValue = record[from[0]];

pgpm/core/src/export/export-meta.ts

@@ -3,7 +3,7 @@ import { Parser } from 'csv-to-pg';
 import { getPgPool } from 'pg-cache';
 import type { Pool } from 'pg';
 
-type FieldType = 'uuid' | 'uuid[]' | 'text' | 'text[]' | 'boolean' | 'image' | 'upload' | 'url' | 'jsonb' | 'int' | 'interval' | 'timestamptz';
+type FieldType = 'uuid' | 'uuid[]' | 'text' | 'text[]' | 'boolean' | 'image' | 'upload' | 'url' | 'jsonb' | 'jsonb[]' | 'int' | 'interval' | 'timestamptz';
 
 interface TableConfig {
   schema: string;
@@ -35,6 +35,8 @@ const mapPgTypeToFieldType = (udtName: string): FieldType => {
     case 'jsonb':
     case 'json':
       return 'jsonb';
+    case '_jsonb':
+      return 'jsonb[]';
     case 'int4':
     case 'int8':
     case 'int2':
@@ -855,7 +857,8 @@ const config: Record<string, TableConfig> = {
       use_rls: 'boolean',
       node_data: 'jsonb',
       grant_roles: 'text[]',
-      grant_privileges: 'jsonb',
+      fields: 'jsonb[]',
+      grant_privileges: 'jsonb[]',
       policy_type: 'text',
       policy_privileges: 'text[]',
       policy_role: 'text',