Skip to content

Commit 7670942

Browse files
Add complete client
Signed-off-by: Siri Varma Vegiraju <[email protected]>
1 parent d961edd commit 7670942

12 files changed

+386
-359
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
package io.dapr.ai.client;
2+
3+
import io.dapr.v1.DaprProtos;
4+
import reactor.core.publisher.Mono;
5+
6+
import java.util.ArrayList;
7+
import java.util.Collections;
8+
9+
public class DemoConversationAI {
10+
/**
11+
* The main method to start the client.
12+
*
13+
* @param args Input arguments (unused).
14+
* @throws InterruptedException If program has been interrupted.
15+
*/
16+
public static void main(String[] args) {
17+
try (DaprConversationClient client = new DaprConversationClient(null)) {
18+
DaprConversationInput daprConversationInput = new DaprConversationInput("11");
19+
Mono<DaprProtos.ConversationResponse> instanceId = client.converse("openai", new ArrayList<>(Collections.singleton(daprConversationInput)), null, null, null, false, 0.0d);
20+
System.out.printf("Started a new chaining model workflow with instance ID: %s%n", instanceId);
21+
DaprProtos.ConversationResponse response = instanceId.block();
22+
23+
System.out.println(response.getOutputsCount());
24+
25+
26+
} catch (Exception e) {
27+
throw new RuntimeException(e);
28+
}
29+
}
30+
}

sdk-ai/src/main/java/io/dapr/ai/client/ConversationClient.java

-131
This file was deleted.

sdk-ai/src/main/java/io/dapr/ai/client/ConversationInput.java

-73
This file was deleted.

sdk-ai/src/main/java/io/dapr/ai/client/ConversationRequest.java

-113
This file was deleted.

sdk-ai/src/main/java/io/dapr/ai/client/ConversationResponse.java

-4
This file was deleted.

sdk-ai/src/main/java/io/dapr/ai/client/DaprAIClient.java

-34
This file was deleted.

0 commit comments

Comments
 (0)