Cleanup sdk

README.md

@@ -19,6 +19,8 @@ sequenceDiagram
 
     Hercules->>Aquila: Register datatypes
     Aquila-->>Hercules: Validation result
+
+    Hercules->>Stream: ActionConfiguration Request<br>with (registered) datatypes
 
     Hercules->>Aquila: Register function definitions
     Aquila-->>Hercules: Validation result

bin/Gemfile

@@ -1,7 +1,8 @@
+# frozen_string_literal: true
+
 source 'https://rubygems.org'
 
 ruby '3.4.7'
 
-
-gem 'tucana', '0.0.56'
 gem 'grpc', '~> 1.67'
+gem 'tucana', '0.0.56'

bin/Gemfile.lock

@@ -1,3 +1,9 @@
+PATH
+  remote: ../../tucana/build/ruby
+  specs:
+    tucana (0.0.0)
+      grpc (~> 1.64)
+
 GEM
   remote: https://rubygems.org/
   specs:
@@ -17,16 +23,14 @@ GEM
       google-protobuf (>= 3.25, < 5.0)
       googleapis-common-protos-types (~> 1.0)
     rake (13.3.1)
-    tucana (0.0.56)
-      grpc (~> 1.64)
 
 PLATFORMS
   ruby
   x86_64-linux
 
 DEPENDENCIES
   grpc (~> 1.67)
-  tucana (= 0.0.56)
+  tucana (= 0.0.0)!
 
 RUBY VERSION
    ruby 3.4.7p58

bin/test_server.rb

@@ -31,6 +31,16 @@ def add_runtime_functions(functions)
   def add_action_config_definition(config)
     @action_config_definitions << config
   end
+
+  def register_config_definitions(token, config_definitions)
+    @action_config_definitions.each do |config|
+      next unless config[:auth_token] == token
+
+      config[:config_definitions] = config_definitions
+      puts "Registered config definitions for action: #{config[:action_identifier]} (v#{config[:version]})"
+      break
+    end
+  end
 end
 
 class FlowTypeTransferService < Tucana::Aquila::FlowTypeService::Service
@@ -93,7 +103,8 @@ def construct_parameters(func)
   end
 
   def transfer(requests, call)
-    puts "Got Auth token: #{call.metadata['authorization']}"
+    token = call.metadata['authorization']
+    puts "Got Auth token: #{token}"
     Enumerator.new do |yielder|
       Thread.new do
         loop do
@@ -144,6 +155,7 @@ def transfer(requests, call)
       end
 
       requests.each do |req|
+        p req
         unless req.result.nil?
           puts "Received execution result for: #{req.result.execution_identifier}"
           puts "Result value: #{req.result.result}"
@@ -157,14 +169,20 @@ def transfer(requests, call)
           next
         end
 
+        unless req.action_configuration.nil?
+          @state.register_config_definitions(token,
+                                             req.action_configuration.action_configurations)
+        end
+
         next if req.logon.nil?
 
         logon = req.logon
 
         @state.add_action_config_definition({
+                                              auth_token: token,
                                               action_identifier: logon.action_identifier,
                                               version: logon.version,
-                                              config_definitions: logon.action_configurations,
+                                              config_definitions: [],
                                             })
 
         puts "Action logon received: #{logon.action_identifier} (v#{logon.version})"

ts/examples/simple_example.ts

@@ -1,50 +1,29 @@
 import { createSdk } from "../src/action_sdk.js";
-import { Struct, Value } from "@code0-tech/tucana/pb/shared.struct_pb.js";
 import { constructValue } from "@code0-tech/tucana/helpers/shared.struct_helper.js";
 import { ActionProjectConfiguration } from "@code0-tech/tucana/pb/shared.action_configuration_pb.js";
+import {randomUUID} from "node:crypto";
 
 const sdk = createSdk({
-    token: "your_token_here",
+    token: randomUUID(),
     actionUrl: "127.0.0.1:50051",
     actionId: "action_123",
     version: "0.0.0",
 })
 
 sdk.registerConfigDefinitions({
-    type: {
-        signature: "string",
-        identifier: "STRING",
-        version: "0.0.0",
-        rules: [],
-        name: [],
-        genericKeys: [],
-        alias: [],
-        displayMessage: [],
-        linkedDataTypeIdentifiers: [],
-        definitionSource: ""
-    },
-    name: [],
-    description: [],
+    type: "LIST<STRING>",
+    linkedDataTypeIdentifiers: ["STRING", "LIST"],
     identifier: "config_discord_bot_token",
 })
 
 sdk.registerDataType({
     identifier: "SOME_DATATYPE",
     signature: "any",
-    name: [],
-    alias: [],
-    rules: [],
-    genericKeys: [],
-    displayMessage: [],
-    definitionSource: "",
-    linkedDataTypeIdentifiers: [],
-    version: "0.0.0",
 })
 
 sdk.registerFunctionDefinition(
     {
         signature: "(n: NUMBER) => NUMBER",
-        definitionSource: "",
         linkedDataTypeIdentifiers: ["NUMBER"],
         runtimeParameterDefinitions: [
             {
@@ -55,46 +34,23 @@ sdk.registerFunctionDefinition(
                 defaultValue: constructValue(20),
             }
         ],
-        alias: [],
-        deprecationMessage: [],
-        description: [],
-        displayIcon: "",
-        displayMessage: [],
-        documentation: [],
-        name: [],
-        throwsError: false,
         version: "0.0.0",
         runtimeName: "fib",
     },
-    async (params: Struct): Promise<Value> => {
-        console.log("Received parameters:", params);
-        let n = params.fields["n"];
-
+    (n: number): number => {
         function fibonacci(num: number): number {
             if (num <= 1) return num;
             return fibonacci(num - 1) + fibonacci(num - 2);
         }
-
-        if (n && n.kind.oneofKind === "numberValue") {
-            return constructValue(fibonacci(n.kind.numberValue));
-        }
-
-        return constructValue(fibonacci(1));
+        return fibonacci(n)
     }
 )
 
 sdk.registerFlowType(
     {
-        documentation: [],
-        description: [],
-        displayIcon: "",
-        displayMessage: [],
         editable: false,
         inputTypeIdentifier: "STRING",
-        name: [],
-        alias: [],
         identifier: "test_flow",
-        settings: [],
         version: "0.0.0",
     }
 )
@@ -119,4 +75,4 @@ function connectToSdk() {
             connectToSdk();
         }, 5000)
     })
-}
+}