diff --git a/packages/runtime/src/services/database/migrations/migrations.001-init.ts b/packages/runtime/src/services/database/migrations/migrations.001-init.ts index 19b3594..74f93a9 100644 --- a/packages/runtime/src/services/database/migrations/migrations.001-init.ts +++ b/packages/runtime/src/services/database/migrations/migrations.001-init.ts @@ -26,7 +26,7 @@ const init: Migration = { table.text('text').nullable(); table.string('source').nullable(); table.string('sourceId').nullable(); - table.string('type').notNullable(); + table.string('type').nullable(); table.integer('typeVersion').nullable(); table.jsonb('metadata').nullable(); @@ -78,9 +78,9 @@ type DocumentRow = { text: string | null; source: string | null; sourceId: string | null; - type: string; + type: string | null; typeVersion: number | null; - metadata: unknown; + metadata: unknown | null; }; type DocumentChunkRow = { diff --git a/packages/runtime/src/services/documents/documents.schemas.ts b/packages/runtime/src/services/documents/documents.schemas.ts index db749f4..9f9fcee 100644 --- a/packages/runtime/src/services/documents/documents.schemas.ts +++ b/packages/runtime/src/services/documents/documents.schemas.ts @@ -14,9 +14,9 @@ const documentSchema = z text: z.string().nullable(), source: z.string().nullable(), sourceId: z.string().nullable(), - type: z.string(), + type: z.string().nullable(), typeVersion: z.int().nullable(), - metadata: z.unknown(), + metadata: z.unknown().nullable(), }) .meta({ id: 'Document' }); @@ -31,7 +31,7 @@ const documentUpsertSchema = z text: z.string().nullish(), source: z.string().nullish(), sourceId: z.string().nullish(), - type: z.string().optional(), + type: z.string().nullish(), typeVersion: z.int().nullish(), metadata: z.unknown().nullish(), }) diff --git a/packages/runtime/src/services/documents/documents.ts b/packages/runtime/src/services/documents/documents.ts index e24ba8b..55983c6 100644 --- a/packages/runtime/src/services/documents/documents.ts +++ b/packages/runtime/src/services/documents/documents.ts @@ -120,8 +120,6 @@ class DocumentsService extends EventEmitter { } as const; } else { await trx(tableNames.documents).insert({ - metadata: {}, - type: 'raw', ...document, content: base64ToMaybeBuffer(document.content), id, @@ -136,7 +134,7 @@ class DocumentsService extends EventEmitter { source: null, sourceId: null, typeVersion: null, - metadata: {}, + metadata: null, ...document, content: base64ToMaybeBuffer(document.content) || null, deletedAt: null,