[Thread] Support retrieve thread

Author: qianmoQ

src/main/java/org/devlive/sdk/openai/DefaultApi.java

@@ -311,4 +311,11 @@ Single<AssistantsEntity> fetchUpdateAssistant(@Url String url,
     @POST
     Single<ThreadEntity> fetchCreateThread(@Url String url,
             @Body ThreadEntity configure);
+
+    /**
+     * Retrieves a thread.
+     * 检索线程。
+     */
+    @GET
+    Single<ThreadEntity> fetchRetrieveThread(@Url String url);
 }

src/main/java/org/devlive/sdk/openai/DefaultClient.java

@@ -346,6 +346,13 @@ public ThreadEntity createThread(ThreadEntity configure)
                 .blockingGet();
     }
 
+    public ThreadEntity retrieveThread(String threadId)
+    {
+        String url = String.format(ProviderUtils.getUrl(provider, UrlModel.FETCH_RETRIEVE_THREADS), threadId);
+        return this.api.fetchRetrieveThread(url)
+                .blockingGet();
+    }
+
     private ObjectMapper createObjectMapper()
     {
         ObjectMapper objectMapper = new ObjectMapper();

src/main/java/org/devlive/sdk/openai/model/UrlModel.java

@@ -24,5 +24,6 @@ public enum UrlModel
     FETCH_ASSISTANTS_FILES,
     FETCH_RETRIEVE_ASSISTANT,
     FETCH_RETRIEVE_ASSISTANT_FILE,
-    FETCH_THREADS;
+    FETCH_THREADS,
+    FETCH_RETRIEVE_THREADS;
 }

src/main/java/org/devlive/sdk/openai/utils/ProviderUtils.java

@@ -62,6 +62,7 @@ public static String getUrl(ProviderModel provider, UrlModel model)
         DEFAULT_PROVIDER.put(UrlModel.FETCH_RETRIEVE_ASSISTANT, "v1/assistants/%s");
         DEFAULT_PROVIDER.put(UrlModel.FETCH_RETRIEVE_ASSISTANT_FILE, "v1/assistants/%s/files/%s");
         DEFAULT_PROVIDER.put(UrlModel.FETCH_THREADS, "v1/threads");
+        DEFAULT_PROVIDER.put(UrlModel.FETCH_RETRIEVE_THREADS, "v1/threads/%s");
 
         AZURE_PROVIDER.put(UrlModel.FETCH_COMPLETIONS, "completions");
         AZURE_PROVIDER.put(UrlModel.FETCH_CHAT_COMPLETIONS, "chat/completions");

src/test/java/org/devlive/sdk/openai/ThreadTest.java

@@ -25,4 +25,11 @@ public void testCreateThread()
                 .build();
         Assert.assertNotNull(client.createThread(configure));
     }
+
+    @Test
+    public void testRetrieveThread()
+    {
+        String threadId = "thread_lsfBRIATCECds5WYLVXnVcpU";
+        Assert.assertNotNull(client.retrieveThread(threadId));
+    }
 }