Make 0.0.66 work

Author: Knerio

ts/examples/simple-example-ts/index.ts

@@ -7,13 +7,12 @@ import {
 
 const sdk = createSdk({
     authToken: "token",
-    aquilaUrl: "127.0.0.1:50051",
-    actionId: "service",
+    aquilaUrl: "127.0.0.1:8081",
+    actionId: "example",
     version: "0.0.0",
 }, [
     {
-        type: "LIST<STRING>",
-        linkedDataTypes: ["STRING", "LIST"],
+        type: "string[]",
         identifier: "config_discord_bot_token",
     }
 ])
@@ -25,38 +24,35 @@ sdk.registerDataTypes({
 
 sdk.registerRuntimeFunctionDefinitionsAndFunctionDefinitions({
         definition: {
-            signature: "(n: NUMBER) => NUMBER",
-            linkedDataTypes: ["NUMBER"],
+            signature: "(number: number) => number",
             parameters: [
                 {
-                    runtimeName: "n",
+                    runtimeName: "number",
                     defaultValue: 20,
                 }
             ],
             runtimeName: "fib",
         },
                 //This param is optional and can be omitted
-        handler: (context: HerculesFunctionContext, n: number): number => {
+        handler: (context: HerculesFunctionContext, number: bigint): bigint => {
                 console.log(context)
                 console.log("Project id:", context.projectId);
                 console.log("Execution id:", context.executionId);
                 console.log("Matched configs:", context.matchedConfig); // matched configs for the current execution
 
-                function fibonacci(num: number): number {
+                function fibonacci(num: bigint): bigint {
                     if (num <= 1) return num;
-                    return fibonacci(num - 1) + fibonacci(num - 2);
+                    return fibonacci(num - 1n) + fibonacci(num - 2n);
                 }
 
-                throw new RuntimeErrorException("ERROR_CALCULATING_FIB", "An error occurred while calculating the Fibonacci number.");
-
+                return fibonacci(number)
             }
     }
 )
 
 sdk.registerFlowTypes(
     {
-        signature: "(): TEXT",
-        linkedDataTypes: ["TEXT"],
+        signature: "(): string",
         editable: false,
         identifier: "test_flow",
     }
@@ -71,8 +67,8 @@ function connectToSdk() {
         sdk.dispatchEvent("test_flow", configs[0].projectId, "Hello, World! Configs loaded: " + configs.length).then(() => {
             console.log("Event dispatched successfully");
         })
-    }).catch((_error) => {
-        console.error("Error connecting SDK:");
+    }).catch((error) => {
+        console.error("Error connecting SDK:", error);
     })
 
     sdk.onError((error) => {

ts/examples/simple-example-ts/package-lock.json

@@ -11,7 +11,6 @@
     "dev": "cd ../.. && npm install && npm run build && npm pack && cd examples/simple-example-ts && npm install ../../code0-tech-hercules-0.0.0.tgz && npx tsx index.ts"
   },
   "dependencies": {
-    "@code0-tech/hercules": "file:../../code0-tech-hercules-0.0.0.tgz",
-    "@code0-tech/tucana": "^0.0.62"
+    "@code0-tech/hercules": "file:../../code0-tech-hercules-0.0.0.tgz"
   }
 }

ts/examples/simple-example-ts/package.json

@@ -30,7 +30,7 @@
   "license": "ISC",
   "type": "module",
   "dependencies": {
-    "@code0-tech/tucana": "^0.0.67",
+    "@code0-tech/tucana": "0.0.66",
     "@grpc/grpc-js": "^1.14.3",
     "@protobuf-ts/grpc-backend": "^2.11.1",
     "@protobuf-ts/grpc-transport": "^2.11.1",

ts/package-lock.json

@@ -77,11 +77,11 @@ const createSdk = (config: ActionSdk["config"], configDefinitions?: HerculesActi
                         defaultValue: constructValue(param.defaultValue || null),
                         hidden: param.hidden || false,
                         optional: param.hidden || false,
-                        runtimeDefinitionName: param.runtimeDefinitionName || param.runtimeName
+                        // runtimeDefinitionName: param.runtimeDefinitionName || param.runtimeName
                     })),
                     signature: functionDefinition.signature,
                     throwsError: functionDefinition.throwsError || false,
-                    runtimeDefinitionName: functionDefinition.runtimeDefinitionName
+                    // runtimeDefinitionName: functionDefinition.runtimeDefinitionName
                 }
             });
         }
@@ -315,22 +315,22 @@ async function connect(state: SdkState, config: ActionSdk["config"], options?: R
         }
     })
 
-    const FunctionDefinitionClient = new FunctionDefinitionServiceClient(state.transport)
-    await FunctionDefinitionClient.update(
-        FunctionDefinitionUpdateRequest.create(
-            {
-                functions: [
-                    ...state.functions.map(func => ({
-                        ...func.definition,
-                    }))
-                ]
-            }
-        ), builtOptions
-    ).then(value => {
-        if (!value.response.success) {
-            return Promise.reject(value.response);
-        }
-    })
+    // const FunctionDefinitionClient = new FunctionDefinitionServiceClient(state.transport)
+    // await FunctionDefinitionClient.update(
+    //     FunctionDefinitionUpdateRequest.create(
+    //         {
+    //             functions: [
+    //                 ...state.functions.map(func => ({
+    //                     ...func.definition,
+    //                 }))
+    //             ]
+    //         }
+    //     ), builtOptions
+    // ).then(value => {
+    //     if (!value.response.success) {
+    //         return Promise.reject(value.response);
+    //     }
+    // })
 
     const flowTypeClient = new FlowTypeServiceClient(state.transport)
     await flowTypeClient.update(FlowTypeUpdateRequest.create({
@@ -388,19 +388,23 @@ function handleExecutionRequest(state: SdkState, message: TransferResponse) {
     }
     const execution = message.data.execution as ExecutionRequest;
     const func = state.runtimeFunctions.find(value => value.identifier == execution.functionIdentifier);
+    
     if (func) {
         const params = Object.entries(execution.parameters!.fields!).map(([key, value]) => {
             const param = func.definition.runtimeParameterDefinitions
                 .find(p => p.runtimeName === key);
 
             return param ? toAllowedValue(value) : undefined;
         });
-        const conf = state.projectConfigurations.find(config => {
+        let conf = state.projectConfigurations.find(config => {
             return true
         })
         if (!conf) {
             console.error(`No configuration found for project ${execution.projectId}`)
-            return;
+            conf = {
+                projectId: 0n,
+                actionConfigurations: []
+            }
         }
 
         const context: HerculesFunctionContext = {
@@ -437,6 +441,7 @@ function handleExecutionRequest(state: SdkState, message: TransferResponse) {
             }
         })
         result.then((value: any) => {
+            console.log(constructValue(value))
             state.stream!.requests.send(
                 TransferRequest.create({
                     data: {