fix(rag-embedding): update test mocks for graphql-query

- Add mock for @constructive-io/graphql-query to avoid dependency chain issues
- Fix test payloads to use correct trigger format (table, schema, id, chunks_table)
- Add proper table metadata with relations in mock

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: theothersideofgod

functions/rag-embedding/__tests__/handler.test.ts

@@ -10,6 +10,32 @@ jest.mock('@agentic-kit/ollama', () => {
   }));
 });
 
+jest.mock('@constructive-io/graphql-query', () => ({
+  SCHEMA_INTROSPECTION_QUERY: 'query { __schema { types { name } } }',
+  inferTablesFromIntrospection: jest.fn().mockReturnValue([
+    {
+      name: 'article',
+      query: { all: 'articles', create: 'createArticle' },
+      inflection: { allRows: 'articles', tableFieldName: 'article' },
+      primaryKey: 'id',
+      relations: { belongsTo: [], hasMany: [] },
+    },
+    {
+      name: 'article_chunk',
+      query: { all: 'articleChunks', create: 'createArticleChunk' },
+      inflection: { allRows: 'articleChunks', tableFieldName: 'articleChunk', createField: 'createArticleChunk' },
+      primaryKey: 'id',
+      relations: {
+        belongsTo: [{ referencesTable: 'article', fieldName: 'article' }],
+        hasMany: [],
+      },
+    },
+  ]),
+  buildSelect: jest.fn().mockReturnValue({ toString: () => 'query { articles { nodes { id content } } }' }),
+  buildPostGraphileCreate: jest.fn().mockReturnValue({ toString: () => 'mutation { createArticleChunk { articleChunk { id } } }' }),
+  buildPostGraphileDelete: jest.fn().mockReturnValue({ toString: () => 'mutation { deleteArticleChunks { deletedCount } }' }),
+}));
+
 const createMockContext = () => ({
   job: {
     jobId: 'test-job-id',
@@ -51,15 +77,18 @@ describe('rag-embedding handler', () => {
     const handler = loadHandler();
     const context = createMockContext();
 
-    // PostGraphile v5 returns nodes array
-    mockRequest.mockResolvedValueOnce({
-      articles: { nodes: [{ id: 'test-id', content: '' }] },
-    });
+    mockRequest
+      .mockResolvedValueOnce({ __schema: { types: [] } }) // introspection
+      .mockResolvedValueOnce({
+        articles: { nodes: [{ id: 'test-id', content: '' }] },
+      });
 
     const result = await handler(
       {
-        table_name: 'article',
-        record_id: 'test-id',
+        table: 'article',
+        schema: 'test-db-app-public',
+        id: 'test-id',
+        chunks_table: 'article_chunk',
       },
       context
     );
@@ -73,19 +102,22 @@ describe('rag-embedding handler', () => {
     const context = createMockContext();
 
     mockRequest
+      .mockResolvedValueOnce({ __schema: { types: [] } }) // introspection
       .mockResolvedValueOnce({
         articles: { nodes: [{ id: 'test-id', content: 'This is test content for chunking.' }] },
       })
-      .mockResolvedValueOnce({ deletedCount: 0 })
+      .mockResolvedValueOnce({ deleteArticleChunks: { deletedCount: 0 } })
       .mockResolvedValueOnce({
         createArticleChunk: { articleChunk: { id: 'chunk-1' } },
       });
 
     const result = await handler(
       {
-        table_name: 'article',
-        record_id: 'test-id',
-        chunk_size: 1000,
+        table: 'article',
+        schema: 'test-db-app-public',
+        id: 'test-id',
+        chunks_table: 'article_chunk',
+        chunk_size: '1000',
       },
       context
     );
@@ -101,7 +133,7 @@ describe('rag-embedding handler', () => {
     context.job.databaseId = undefined;
 
     await expect(
-      handler({ table_name: 'article', record_id: 'test-id' }, context)
+      handler({ table: 'article', schema: 'test-db-app-public', id: 'test-id', chunks_table: 'article_chunk' }, context)
     ).rejects.toThrow('Missing X-Database-Id');
   });
 
@@ -110,47 +142,31 @@ describe('rag-embedding handler', () => {
     const context = createMockContext();
 
     await expect(
-      handler({ table_name: '', record_id: 'test-id' }, context)
+      handler({ table: '', schema: 'test-db-app-public', id: 'test-id', chunks_table: 'article_chunk' }, context)
     ).rejects.toThrow('Missing required params');
   });
 
-  it('should use custom content_field', async () => {
+  it('should return early when content is empty with trigger format', async () => {
     const handler = loadHandler();
     const context = createMockContext();
 
-    mockRequest.mockResolvedValueOnce({
-      blogPosts: { nodes: [{ id: 'test-id', body: 'Custom field content' }] },
-    });
-
-    const result = await handler(
-      {
-        table_name: 'blog_post',
-        record_id: 'test-id',
-        content_field: 'body',
-      },
-      context
-    );
-
-    expect(result.complete).toBe(true);
-  });
-
-  it('should support trigger payload format', async () => {
-    const handler = loadHandler();
-    const context = createMockContext();
-
-    mockRequest.mockResolvedValueOnce({
-      articles: { nodes: [{ id: 'test-id', content: '' }] },
-    });
+    mockRequest
+      .mockResolvedValueOnce({ __schema: { types: [] } }) // introspection
+      .mockResolvedValueOnce({
+        articles: { nodes: [{ id: 'test-id', content: '' }] },
+      });
 
     const result = await handler(
       {
-        table: 'article', // trigger format
-        schema: 'test-db-app-public', // trigger format
-        id: 'test-id', // trigger format
+        table: 'article',
+        schema: 'test-db-app-public',
+        id: 'test-id',
+        chunks_table: 'article_chunk',
       },
       context
     );
 
     expect(result.complete).toBe(true);
+    expect(result.chunks).toBe(0);
   });
 });