-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
67 changed files
with
862 additions
and
837 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
88 changes: 29 additions & 59 deletions
88
core/src/main/kotlin/io/holunda/connector/compose/ComposeFunction.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,74 +1,44 @@ | ||
| package io.holunda.connector.compose | ||
|
|
||
| import com.fasterxml.jackson.databind.* | ||
| import io.camunda.connector.api.annotation.* | ||
| import io.camunda.connector.api.outbound.* | ||
| import io.holunda.connector.common.* | ||
| import io.holunda.connector.generic.* | ||
| import mu.* | ||
| import org.apache.commons.text.* | ||
| import org.slf4j.* | ||
| import java.util.* | ||
|
|
||
| @OutboundConnector( | ||
| name = "gpt-compose", | ||
| inputVariables = ["inputJson", "description", "temperature", "type", "style", "tone", "length", "language", "sender", "customPrinciple", "constitutionalPrinciple", "model"], | ||
| type = "io.holunda.connector.compose:1" | ||
| name = "gpt-compose", | ||
| inputVariables = [ | ||
| "inputJson", | ||
| "description", | ||
| "temperature", | ||
| "type", | ||
| "style", | ||
| "tone", | ||
| "length", | ||
| "language", | ||
| "sender", | ||
| "customPrinciple", | ||
| "constitutionalPrinciple", | ||
| "model" | ||
| ], | ||
| type = "io.holunda:connector-compose:1" | ||
| ) | ||
| class ComposeFunction : OutboundConnectorFunction { | ||
|
|
||
| @Throws(Exception::class) | ||
| override fun execute(context: OutboundConnectorContext): Any { | ||
| LOG.info("Executing ComposeFunction") | ||
| val unescapedVariables = StringEscapeUtils.unescapeJson(context.variables) // TODO remove when Camunda fixes this in zeebe :P zeebe/issues/9859 | ||
| val connectorRequest = unescapedVariables.readFromJson<ComposeRequest>() | ||
| //val connectorRequest = context.bindVariables(ComposeRequest::class.java) | ||
| LOG.info("Request: {}", connectorRequest) | ||
| return executeConnector(connectorRequest) | ||
| } | ||
|
|
||
| private fun executeConnector(request: ComposeRequest): ComposeResult { | ||
| val constitutionalPrinciple = when (request.constitutionalPrinciple) { | ||
| null, "none" -> null | ||
| "custom" -> request.customPrinciple | ||
| else -> request.constitutionalPrinciple | ||
| override fun execute(context: OutboundConnectorContext): Any { | ||
| logger.info("Executing ComposeFunction") | ||
| val unescapedVariables = StringEscapeUtils.unescapeJson(context.variables) // TODO remove when Camunda fixes this in zeebe :P zeebe/issues/9859 | ||
| val connectorRequest = unescapedVariables.readFromJson<ComposeRequest>() | ||
| logger.info("ComposeFunction request: $connectorRequest") | ||
| return executeRequest(ComposeTask.fromRequest(connectorRequest)) | ||
| } | ||
|
|
||
| val result = LLMServiceClient.run("compose", | ||
| ComposeTask( | ||
| request.model.modelId, | ||
| request.inputJson, | ||
| request.description, | ||
| request.type, | ||
| request.style, | ||
| request.tone, | ||
| request.length, | ||
| request.language, | ||
| request.temperature, | ||
| request.sender, | ||
| constitutionalPrinciple | ||
| ) | ||
| ) | ||
|
|
||
| LOG.info("ComposeFunction result: $result") | ||
|
|
||
| return ComposeResult(result) | ||
| } | ||
|
|
||
| data class ComposeTask( | ||
| val model: String, | ||
| val context: JsonNode, | ||
| val instructions: String, | ||
| val type: String, | ||
| val style: String, | ||
| val tone: String, | ||
| val length: String, | ||
| val language: String, | ||
| val temperature: Double, | ||
| val sender: String?, | ||
| val constitutional_principle: String?, | ||
| ) | ||
| private fun executeRequest(composeTask: ComposeTask): ComposeResult { | ||
| val result = LLMServiceClient.run("compose", composeTask) | ||
| logger.info("ComposeFunction result: $result") | ||
| return ComposeResult(result) | ||
| } | ||
|
|
||
| companion object { | ||
| private val LOG = LoggerFactory.getLogger(ComposeFunction::class.java) | ||
| } | ||
| companion object : KLogging() | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
38 changes: 38 additions & 0 deletions
38
core/src/main/kotlin/io/holunda/connector/compose/ComposeTask.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,38 @@ | ||
| package io.holunda.connector.compose | ||
|
|
||
| import com.fasterxml.jackson.databind.* | ||
|
|
||
| data class ComposeTask( | ||
| val model: String, | ||
| val context: JsonNode, | ||
| val instructions: String, | ||
| val type: String, | ||
| val style: String, | ||
| val tone: String, | ||
| val length: String, | ||
| val language: String, | ||
| val temperature: Double, | ||
| val sender: String?, | ||
| val constitutional_principle: String?, | ||
| ) { | ||
| companion object { | ||
| fun fromRequest(request: ComposeRequest) = | ||
| ComposeTask( | ||
| request.model.modelId, | ||
| request.inputJson, | ||
| request.description, | ||
| request.type, | ||
| request.style, | ||
| request.tone, | ||
| request.length, | ||
| request.language, | ||
| request.temperature, | ||
| request.sender, | ||
| when (request.constitutionalPrinciple) { | ||
| null, "none" -> null | ||
| "custom" -> request.customPrinciple | ||
| else -> request.constitutionalPrinciple | ||
| } | ||
| ) | ||
| } | ||
| } |
Oops, something went wrong.