From 3713ba66a895734b169503b4702c3f9565fafa54 Mon Sep 17 00:00:00 2001
From: Vadym Barda <vadym@langchain.dev>
Date: Tue, 16 Jul 2024 09:18:22 -0400
Subject: [PATCH] sdk-js: add thread_id and if_exists to ThreadsClient.create
 (#1032)

---
 libs/sdk-js/src/client.mts | 9 ++++++++-
 libs/sdk-js/src/types.mts  | 1 +
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/libs/sdk-js/src/client.mts b/libs/sdk-js/src/client.mts
index 67dc945d9..733a6599b 100644
--- a/libs/sdk-js/src/client.mts
+++ b/libs/sdk-js/src/client.mts
@@ -19,6 +19,7 @@ import {
   RunsWaitPayload,
   StreamEvent,
   CronsCreatePayload,
+  OnConflictBehavior,
 } from "./types.mjs";
 
 interface ClientConfig {
@@ -323,10 +324,16 @@ class ThreadsClient extends BaseClient {
      * Metadata for the thread.
      */
     metadata?: Metadata;
+    threadId?: string;
+    ifExists?: OnConflictBehavior;
   }): Promise<Thread> {
     return this.fetch<Thread>(`/threads`, {
       method: "POST",
-      json: { metadata: payload?.metadata },
+      json: {
+        metadata: payload?.metadata,
+        thread_id: payload?.threadId,
+        if_exists: payload?.ifExists,
+      },
     });
   }
 
diff --git a/libs/sdk-js/src/types.mts b/libs/sdk-js/src/types.mts
index 50e702131..e7d1bdc09 100644
--- a/libs/sdk-js/src/types.mts
+++ b/libs/sdk-js/src/types.mts
@@ -2,6 +2,7 @@ import { Config, Metadata } from "./schema.js";
 
 export type StreamMode = "values" | "messages" | "updates" | "events" | "debug";
 export type MultitaskStrategy = "reject" | "interrupt" | "rollback" | "enqueue";
+export type OnConflictBehavior = "raise" | "do_nothing";
 export type StreamEvent =
   | "events"
   | "metadata"