feat:add query queue task detail method

Author: muverystrong

api/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>top.bella</groupId>
         <artifactId>openai-java</artifactId>
-        <version>0.24.3</version>
+        <version>0.24.4</version>
     </parent>
     <packaging>jar</packaging>
     <artifactId>openai-api</artifactId>

client/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>top.bella</groupId>
         <artifactId>openai-java</artifactId>
-        <version>0.24.3</version>
+        <version>0.24.4</version>
     </parent>
     <packaging>jar</packaging>
 

client/src/main/java/com/theokanning/openai/client/OpenAiApi.java

@@ -412,6 +412,9 @@ public interface OpenAiApi {
     @POST("queue/{task_id}/complete")
     Single<String> completeTask(@Path("task_id") String taskId, @Body Map<String, Object> data);
 
+    @GET("queue/{task_id}")
+    Single<Task> getTask(@Path("task_id") String taskId);
+
     @POST("web/search")
     Single<WebSearchResponse> webSearch(@Body WebSearchRequest request);
 

example/pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.github.ke</groupId>
     <artifactId>example</artifactId>
-    <version>0.23.93</version>
+    <version>0.24.4</version>
     <name>example</name>
 
     <properties>

pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>top.bella</groupId>
     <artifactId>openai-java</artifactId>
-    <version>0.24.3</version>
+    <version>0.24.4</version>
     <packaging>pom</packaging>
     <description>openai java 版本</description>
     <name>openai-java</name>

service/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>top.bella</groupId>
         <artifactId>openai-java</artifactId>
-        <version>0.24.3</version>
+        <version>0.24.4</version>
     </parent>
     <packaging>jar</packaging>
 

service/src/main/java/com/theokanning/openai/service/OpenAiService.java

@@ -930,6 +930,10 @@ public String completeTask(String taskId, Map<String, Object> data) {
         return execute(api.completeTask(taskId, data));
     }
 
+    public Task getTask(String taskId) {
+        return execute(api.getTask(taskId));
+    }
+
     public static OpenAiApi buildApi(String token, Duration timeout, String baseUrl) {
         OkHttpClient client = defaultClient(token, timeout);
         Retrofit retrofit = defaultRetrofit(client, mapper, baseUrl);

service/src/test/java/com/theokanning/openai/service/QueueTest.java

@@ -4,15 +4,19 @@
 import com.theokanning.openai.queue.Register;
 import com.theokanning.openai.queue.Take;
 import com.theokanning.openai.queue.Task;
+import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
 
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
 import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.Mockito.when;
 
 /**
  * Queue operation tests Note: These tests are disabled as they require a custom queue service backend that implements the /v1/queue/* endpoints,
@@ -21,7 +25,13 @@
 @Disabled("Queue endpoints require custom backend service")
 public class QueueTest {
 
-    com.theokanning.openai.service.OpenAiService service = new OpenAiService();
+    @Mock
+    private OpenAiService service;
+
+    @BeforeEach
+    void setUp() {
+        MockitoAnnotations.openMocks(this);
+    }
 
     @Test
     void registerQueue() {
@@ -90,4 +100,28 @@ void completeTask() {
 
         assertNotNull(result);
     }
+
+    @Test
+    void getTask() {
+        String taskId = "test-task-id-123";
+        
+        // Create a mock Task object
+        Task expectedTask = Task.builder()
+                .taskId(taskId)
+                .queue("test-queue")
+                .status("pending")
+                .build();
+
+        // Mock the service call
+        when(service.getTask(taskId)).thenReturn(expectedTask);
+
+        // Execute the test
+        Task result = service.getTask(taskId);
+
+        // Verify the results
+        assertNotNull(result);
+        assertEquals(taskId, result.getTaskId());
+        assertEquals("test-queue", result.getQueue());
+        assertEquals("pending", result.getStatus());
+    }
 }