fix(metadata): add nulability to schema for openai compatibility

Signed-off-by: Tomas Pilar <[email protected]>
i-am-bee · Jan 20, 2025 · f7804b7 · f7804b7
1 parent 2a8f729
commit f7804b7
Show file tree

Hide file tree

Showing 8 changed files with 11 additions and 10 deletions.
diff --git a/src/artifacts/artifacts.service.ts b/src/artifacts/artifacts.service.ts
@@ -93,7 +93,7 @@ export async function createArtifact(body: ArtifactCreateBody): Promise<Artifact
         thread: message && ref(message.thread),
         message: message && ref(message),
         sourceCode: body.source_code,
-        metadata: body.metadata,
+        metadata: body.metadata ?? undefined,
         accessToken: body.shared === true ? getToken() : undefined,
         name: body.name,
         description: body.description

diff --git a/src/assistants/assistants.service.ts b/src/assistants/assistants.service.ts
@@ -112,7 +112,7 @@ export async function createAssistant({
     instructions: instructions ?? undefined,
     name: name ?? undefined,
     description: description ?? undefined,
-    metadata,
+    metadata: metadata ?? undefined,
     topP: top_p ?? undefined,
     model: model ?? defaultAIProvider.createAssistantBackend().modelId,
     agent,

diff --git a/src/messages/messages.service.ts b/src/messages/messages.service.ts
@@ -156,7 +156,7 @@ export async function createMessageEntity({
     thread: ref(thread),
     role,
     content,
-    metadata,
+    metadata: metadata ?? undefined,
     attachments: _attachments,
     order
   });

diff --git a/src/runs/runs.service.ts b/src/runs/runs.service.ts
@@ -211,7 +211,7 @@ export async function createRun({
     tools: toolsParam?.map(createToolUsage) ?? assistant.tools,
     instructions: instructions ?? assistant.instructions,
     additionalInstructions: additionalInstructions ?? undefined,
-    metadata,
+    metadata: metadata ?? undefined,
     model: model ?? assistant.model,
     topP: top_p ?? assistant.topP,
     temperature: temperature ?? assistant.temperature,

diff --git a/src/schema.ts b/src/schema.ts
@@ -25,7 +25,8 @@ export const metadataSchema = {
   patternProperties: {
     '.*': { type: 'string', maxLength: 512 }
   },
-  additionalProperties: true
+  additionalProperties: true,
+  nullable: true
 } as const satisfies JSONSchema;
 
 export const createPaginationQuerySchema = <T extends readonly string[]>(

diff --git a/src/threads/threads.service.ts b/src/threads/threads.service.ts
@@ -57,7 +57,7 @@ export async function createThread({
 }: ThreadCreateBody): Promise<ThreadCreateResponse> {
   const thread = new Thread({
     toolResources: await createToolResources(tool_resources),
-    metadata
+    metadata: metadata ?? undefined
   });
   ORM.em.persist(thread);
   const threadMessages = await Promise.all(

diff --git a/src/tools/tools.service.ts b/src/tools/tools.service.ts
@@ -691,7 +691,7 @@ async function createCodeInterpreterTool(
       sourceCode: body.source_code,
       jsonSchema: customTool.inputSchema(),
       description: customTool.description,
-      metadata: body.metadata,
+      metadata: body.metadata ?? undefined,
       userDescription: body.user_description
     });
 
@@ -746,7 +746,7 @@ async function createOpenApiTool(
     name: body.name ?? schema.info.title,
     description: schema.info.description,
     apiKey: body.api_key ? encrypt(body.api_key) : undefined,
-    metadata: body.metadata,
+    metadata: body.metadata ?? undefined,
     userDescription: body.user_description
   });
 
@@ -762,7 +762,7 @@ async function createFunctionTool(
     name: body.name,
     description: body.description ?? '',
     parameters: body.parameters,
-    metadata: body.metadata,
+    metadata: body.metadata ?? undefined,
     userDescription: body.user_description
   });
 

diff --git a/src/users/users.service.ts b/src/users/users.service.ts
@@ -68,7 +68,7 @@ export async function createUser({
     externalId,
     email,
     name,
-    metadata,
+    metadata: metadata ?? undefined,
     defaultOrganization: ORM.em
       .getRepository(Organization)
       .getReference('placeholder', { wrapped: true }),