Implement CallResult External Object to use in Agent Object

Author: iroqueta

common/src/main/java/com/genexus/util/CallResult.java

@@ -0,0 +1,30 @@
+package com.genexus.util;
+
+import com.genexus.GXBaseCollection;
+import com.genexus.SdtMessages_Message;
+
+public class CallResult {
+	private boolean success = true;
+	private boolean fail;
+	private final GXBaseCollection<SdtMessages_Message> messages = new GXBaseCollection<>();
+
+	public boolean success() {
+		return success;
+	}
+
+	public void setFail() {
+		fail = true;
+		success =false;
+	}
+
+	public boolean fail() {
+		return fail;
+	}
+
+	public void addMessage(SdtMessages_Message message) {
+		messages.add(message);
+	}
+	public GXBaseCollection<SdtMessages_Message> getmessages() {
+		return messages;
+	}
+}

java/src/main/java/com/genexus/GXProcedure.java

@@ -260,11 +260,11 @@ protected void mockExecute() {
 		privateExecute( );
 	}
 
-	protected String callAssistant(String assistant, GXProperties properties, Object response) {
+	protected String callAssistant(String assistant, GXProperties properties, CallResult result) {
 		OpenAIRequest aiRequest = new OpenAIRequest();
 		aiRequest.setModel(String.format("saia:agent:%s", assistant));
 		aiRequest.setVariables(properties.getList());
-		OpenAIResponse aiResponse = SaiaService.call(aiRequest);
+		OpenAIResponse aiResponse = SaiaService.call(aiRequest, result);
 		if (aiResponse != null)
 			return aiResponse.getChoices().get(0).getMessage().getContent();
 		return "";

java/src/main/java/com/genexus/db/GXEmbedding.java

@@ -3,6 +3,7 @@
 import com.genexus.CommonUtil;
 import com.genexus.GXBaseCollection;
 import com.genexus.SdtMessages_Message;
+import com.genexus.util.CallResult;
 import com.genexus.util.saia.OpenAIRequest;
 import com.genexus.util.saia.OpenAIResponse;
 import com.genexus.util.saia.SaiaService;
@@ -75,7 +76,7 @@ public static List<Float> getEmbedding(String model, int dimensions, List<String
 		aiRequest.setModel(model);
 		aiRequest.setInput(inputList);
 		aiRequest.setDimension(dimensions);
-		OpenAIResponse aiResponse = SaiaService.call(aiRequest, true);
+		OpenAIResponse aiResponse = SaiaService.call(aiRequest, true, new CallResult());
 		if (aiResponse != null)
 			return aiResponse.getData().get(0).getEmbedding().stream()
 				.map(Double::floatValue)

java/src/main/java/com/genexus/util/saia/SaiaService.java

@@ -1,22 +1,24 @@
 package com.genexus.util.saia;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.genexus.SdtMessages_Message;
 import com.genexus.common.interfaces.SpecificImplementation;
 import com.genexus.diagnostics.core.ILogger;
 import com.genexus.diagnostics.core.LogManager;
 import com.genexus.internet.HttpClient;
 import org.json.JSONObject;
+import com.genexus.util.CallResult;
 
 public class SaiaService {
 	private static final ILogger logger = LogManager.getLogger(SaiaService.class);
 	private static final String apiKey = (String) SpecificImplementation.Application.getProperty("AI_PROVIDER_API_KEY", "");;
 	private static final String aiProvider = (String) SpecificImplementation.Application.getProperty("AI_PROVIDER", "");
 
-	public static OpenAIResponse call(OpenAIRequest request) {
-		return call(request, false);
+	public static OpenAIResponse call(OpenAIRequest request, CallResult result) {
+		return call(request, false, result);
 	}
 
-	public static OpenAIResponse call(OpenAIRequest request, boolean isEmbedding) {
+	public static OpenAIResponse call(OpenAIRequest request, boolean isEmbedding, CallResult result) {
 		try {
 			String jsonRequest = new ObjectMapper().writeValueAsString(request);
 
@@ -33,14 +35,28 @@ public static OpenAIResponse call(OpenAIRequest request, boolean isEmbedding) {
 				return new ObjectMapper().readValue(jsonResponse.toString(), OpenAIResponse.class);
 			}
 			else {
-				logger.error(String.format("Error calling Enterprise AI API, StatusCode: %d, ReasonLine: %s",
+				String errorDescription = String.format("Error calling Enterprise AI API, StatusCode: %d, ReasonLine: %s",
 					client.getStatusCode(),
-					client.getReasonLine()));
+					client.getReasonLine());
+				addResultMessage("SAIA_ERROR_CALL", (byte)1, errorDescription, result);
+				logger.error(errorDescription);
 			}
 		}
 		catch (Exception e) {
+			addResultMessage("SAIA_EXCEPTION", (byte)1, e.getMessage(), result);
 			logger.error("Calling Enterprise AI API Error", e);
 		}
 		return null;
 	}
+
+
+	private static void addResultMessage(String id, byte type, String description, CallResult result){
+		if (type == 1)
+			result.setFail();
+		SdtMessages_Message msg = new SdtMessages_Message();
+		msg.setgxTv_SdtMessages_Message_Id(id);
+		msg.setgxTv_SdtMessages_Message_Type(type);
+		msg.setgxTv_SdtMessages_Message_Description(description);
+
+	}
 }

java/src/test/java/com/genexus/assistant/Assistant.java

@@ -1,6 +1,7 @@
 package com.genexus.assistant;
 
 import com.genexus.*;
+import com.genexus.util.CallResult;
 
 public final  class Assistant extends GXProcedure
 {
@@ -32,7 +33,7 @@ protected void privateExecute( )
 		Gxproperties.set("&Parameter1", AV3Parameter1);
 		Gxproperties.set("&Parameter2", AV4Parameter2);
 		Gxproperties.set("$context", "Los Angeles");
-		AV5OutputVariable = callAssistant( "The weatherman", Gxproperties, null) ;
+		AV5OutputVariable = callAssistant( "The weatherman", Gxproperties, new CallResult()) ;
 		cleanup();
 	}