/** * * This file is generated using: * @fluencelabs/aqua-api version: 0.12.0 * @fluencelabs/aqua-to-js version: 0.1.0 * If you find any bugs in generated AIR, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues * If you find any bugs in generated JS/TS, please write an issue on GitHub: https://github.com/fluencelabs/js-client/issues * */ import type { IFluenceClient as IFluenceClient$$ } from '@fluencelabs/js-client'; export declare const upload_workers_script = "\n(xor\n (seq\n (seq\n (seq\n (seq\n (call %init_peer_id% (\"getDataSrv\" \"-relay-\") [] -relay-)\n (call %init_peer_id% (\"getDataSrv\" \"config\") [] -config-arg-)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_workers\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (new $deploy_defs\n (seq\n (fold -config-arg-.$.workers w-0\n (seq\n (new $ipfs_multiaddrs\n (new $definition_cid\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Array.dedup\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"array\" \"dedup\") [w-0.$.hosts] ret)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Array.dedup\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Array.dedup\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (fold ret h-0\n (seq\n (xor\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (par\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Ipfs.get_external_api_multiaddr\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call h-0 (\"aqua-ipfs\" \"get_external_api_multiaddr\") [] ret-0)\n (par\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Ipfs.get_external_api_multiaddr\" \"exit\"])\n )\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Ipfs.get_external_api_multiaddr\" -return-error-msg-])\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon h-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (ap ret-0.$.multiaddr $ipfs_multiaddrs)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon %init_peer_id% $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n (next h-0)\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Array.dedup\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (seq\n (canon %init_peer_id% $ipfs_multiaddrs #ipfs_multiaddrs_canon)\n (call %init_peer_id% (\"array\" \"dedup\") [#ipfs_multiaddrs_canon] ret-1)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Array.dedup\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Array.dedup\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (fold ret-1 maddr-0\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (new $spells\n (new $services\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (fold w-0.$.config.services s-0\n (seq\n (new $modules\n (seq\n (seq\n (fold s-0.$.modules m-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload\") [maddr-0 m-0.$.wasm] ret-2)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [maddr-0 m-0.$.config] ret-3)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %Module_obj_map\n (seq\n (seq\n (ap (\"config\" ret-3) %Module_obj_map)\n (ap (\"wasm\" ret-2) %Module_obj_map)\n )\n (canon %init_peer_id% %Module_obj_map Module_obj)\n )\n )\n )\n (ap Module_obj $modules)\n )\n (next m-0)\n )\n )\n (new %Service_obj_map\n (seq\n (seq\n (seq\n (canon %init_peer_id% $modules #modules_canon)\n (ap (\"modules\" #modules_canon) %Service_obj_map)\n )\n (ap (\"name\" s-0.$.name) %Service_obj_map)\n )\n (canon %init_peer_id% %Service_obj_map Service_obj)\n )\n )\n )\n (ap Service_obj $services)\n )\n )\n (next s-0)\n )\n )\n (fold w-0.$.config.spells sp-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [maddr-0 sp-0.$.script] ret-4)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [sp-0.$.config] ret-5)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [maddr-0 ret-5] ret-6)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [sp-0.$.init_args] ret-7)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [maddr-0 ret-7] ret-8)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %SpellDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (ap (\"config\" ret-6) %SpellDefinition_obj_map)\n (ap (\"init_args\" ret-8) %SpellDefinition_obj_map)\n )\n (ap (\"name\" sp-0.$.name) %SpellDefinition_obj_map)\n )\n (ap (\"script\" ret-4) %SpellDefinition_obj_map)\n )\n (canon %init_peer_id% %SpellDefinition_obj_map SpellDefinition_obj)\n )\n )\n )\n (ap SpellDefinition_obj $spells)\n )\n (next sp-0)\n )\n )\n )\n (new %WorkerDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (canon %init_peer_id% $services #services_canon)\n (canon %init_peer_id% $spells #spells_canon)\n )\n (ap (\"services\" #services_canon) %WorkerDefinition_obj_map)\n )\n (ap (\"spells\" #spells_canon) %WorkerDefinition_obj_map)\n )\n (canon %init_peer_id% %WorkerDefinition_obj_map WorkerDefinition_obj)\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [WorkerDefinition_obj] ret-9)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [maddr-0 ret-9] ret-10)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n )\n )\n (ap ret-10 $definition_cid)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (next maddr-0)\n )\n )\n )\n (new $definition_cid_test\n (seq\n (seq\n (fold $definition_cid definition_cid_fold_var\n (seq\n (seq\n (ap definition_cid_fold_var $definition_cid_test)\n (canon %init_peer_id% $definition_cid_test #definition_cid_iter_canon)\n )\n (xor\n (match #definition_cid_iter_canon.length 1\n (null)\n )\n (next definition_cid_fold_var)\n )\n )\n (never)\n )\n (canon %init_peer_id% $definition_cid_test #definition_cid_result_canon)\n )\n (ap #definition_cid_result_canon definition_cid_gate)\n )\n )\n )\n (new %WorkerDeployDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (ap (\"definition\" definition_cid_gate.$.[0]) %WorkerDeployDefinition_obj_map)\n (ap (\"dummy_deal_id\" w-0.$.dummy_deal_id) %WorkerDeployDefinition_obj_map)\n )\n (ap (\"hosts\" w-0.$.hosts) %WorkerDeployDefinition_obj_map)\n )\n (ap (\"name\" w-0.$.name) %WorkerDeployDefinition_obj_map)\n )\n (canon %init_peer_id% %WorkerDeployDefinition_obj_map WorkerDeployDefinition_obj)\n )\n )\n )\n (ap WorkerDeployDefinition_obj $deploy_defs)\n )\n )\n )\n (next w-0)\n )\n )\n (new %AppDeployDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (canon %init_peer_id% $deploy_defs #deploy_defs_canon)\n (ap (\"installation_script\" -config-arg-.$.installation_script) %AppDeployDefinition_obj_map)\n )\n (ap (\"installation_trigger\" -config-arg-.$.installation_trigger) %AppDeployDefinition_obj_map)\n )\n (ap (\"workers\" #deploy_defs_canon) %AppDeployDefinition_obj_map)\n )\n (canon %init_peer_id% %AppDeployDefinition_obj_map AppDeployDefinition_obj)\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_workers\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_workers\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (call %init_peer_id% (\"callbackSrv\" \"response\") [AppDeployDefinition_obj])\n )\n (call %init_peer_id% (\"errorHandlingSrv\" \"error\") [:error: 0])\n)\n"; export type Upload_workersArgConfig = { installation_script: string; installation_trigger: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; workers: { config: { services: { modules: { config: string; wasm: string; }[]; name: string; }[]; spells: { config: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; init_args: unknown; name: string; script: string; }[]; }; dummy_deal_id: string; hosts: string[]; name: string; }[]; }; export type Upload_workersResult = { installation_script: string; installation_trigger: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; workers: { definition: string; dummy_deal_id: string; hosts: string[]; name: string; }[]; }; export declare function upload_workers(config: Upload_workersArgConfig, config?: { ttl?: number; }): Promise; export declare function upload_workers(peer: IFluenceClient$$, config: Upload_workersArgConfig, config?: { ttl?: number; }): Promise; export declare const upload_worker_config_script = "\n(xor\n (seq\n (seq\n (seq\n (seq\n (seq\n (call %init_peer_id% (\"getDataSrv\" \"-relay-\") [] -relay-)\n (call %init_peer_id% (\"getDataSrv\" \"ipfs\") [] -ipfs-arg-)\n )\n (call %init_peer_id% (\"getDataSrv\" \"config\") [] -config-arg-)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (new $spells\n (new $services\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (fold -config-arg-.$.services s-0\n (seq\n (new $modules\n (seq\n (seq\n (fold s-0.$.modules m-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload\") [-ipfs-arg- m-0.$.wasm] ret)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- m-0.$.config] ret-0)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %Module_obj_map\n (seq\n (seq\n (ap (\"config\" ret-0) %Module_obj_map)\n (ap (\"wasm\" ret) %Module_obj_map)\n )\n (canon %init_peer_id% %Module_obj_map Module_obj)\n )\n )\n )\n (ap Module_obj $modules)\n )\n (next m-0)\n )\n )\n (new %Service_obj_map\n (seq\n (seq\n (seq\n (canon %init_peer_id% $modules #modules_canon)\n (ap (\"modules\" #modules_canon) %Service_obj_map)\n )\n (ap (\"name\" s-0.$.name) %Service_obj_map)\n )\n (canon %init_peer_id% %Service_obj_map Service_obj)\n )\n )\n )\n (ap Service_obj $services)\n )\n )\n (next s-0)\n )\n )\n (fold -config-arg-.$.spells sp-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- sp-0.$.script] ret-1)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [sp-0.$.config] ret-2)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- ret-2] ret-3)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [sp-0.$.init_args] ret-4)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- ret-4] ret-5)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %SpellDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (ap (\"config\" ret-3) %SpellDefinition_obj_map)\n (ap (\"init_args\" ret-5) %SpellDefinition_obj_map)\n )\n (ap (\"name\" sp-0.$.name) %SpellDefinition_obj_map)\n )\n (ap (\"script\" ret-1) %SpellDefinition_obj_map)\n )\n (canon %init_peer_id% %SpellDefinition_obj_map SpellDefinition_obj)\n )\n )\n )\n (ap SpellDefinition_obj $spells)\n )\n (next sp-0)\n )\n )\n )\n (new %WorkerDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (canon %init_peer_id% $services #services_canon)\n (canon %init_peer_id% $spells #spells_canon)\n )\n (ap (\"services\" #services_canon) %WorkerDefinition_obj_map)\n )\n (ap (\"spells\" #spells_canon) %WorkerDefinition_obj_map)\n )\n (canon %init_peer_id% %WorkerDefinition_obj_map WorkerDefinition_obj)\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [WorkerDefinition_obj] ret-6)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- ret-6] ret-7)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (call %init_peer_id% (\"callbackSrv\" \"response\") [ret-7])\n )\n (call %init_peer_id% (\"errorHandlingSrv\" \"error\") [:error: 0])\n)\n"; export type Upload_worker_configArgConfig = { services: { modules: { config: string; wasm: string; }[]; name: string; }[]; spells: { config: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; init_args: unknown; name: string; script: string; }[]; }; export declare function upload_worker_config(ipfs: string, config: Upload_worker_configArgConfig, config?: { ttl?: number; }): Promise; export declare function upload_worker_config(peer: IFluenceClient$$, ipfs: string, config: Upload_worker_configArgConfig, config?: { ttl?: number; }): Promise; export declare const upload_deal_script = "\n(xor\n (seq\n (seq\n (seq\n (seq\n (seq\n (call %init_peer_id% (\"getDataSrv\" \"-relay-\") [] -relay-)\n (call %init_peer_id% (\"getDataSrv\" \"config\") [] -config-arg-)\n )\n (call %init_peer_id% (\"getDataSrv\" \"ipfs\") [] -ipfs-arg-)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_deal\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (new $deploy_defs\n (seq\n (fold -config-arg-.$.workers w-0\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (new $spells\n (new $services\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (fold w-0.$.config.services s-0\n (seq\n (new $modules\n (seq\n (seq\n (fold s-0.$.modules m-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload\") [-ipfs-arg- m-0.$.wasm] ret)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- m-0.$.config] ret-0)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %Module_obj_map\n (seq\n (seq\n (ap (\"config\" ret-0) %Module_obj_map)\n (ap (\"wasm\" ret) %Module_obj_map)\n )\n (canon %init_peer_id% %Module_obj_map Module_obj)\n )\n )\n )\n (ap Module_obj $modules)\n )\n (next m-0)\n )\n )\n (new %Service_obj_map\n (seq\n (seq\n (seq\n (canon %init_peer_id% $modules #modules_canon)\n (ap (\"modules\" #modules_canon) %Service_obj_map)\n )\n (ap (\"name\" s-0.$.name) %Service_obj_map)\n )\n (canon %init_peer_id% %Service_obj_map Service_obj)\n )\n )\n )\n (ap Service_obj $services)\n )\n )\n (next s-0)\n )\n )\n (fold w-0.$.config.spells sp-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- sp-0.$.script] ret-1)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [sp-0.$.config] ret-2)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"TriggerConfigJson.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- ret-2] ret-3)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [sp-0.$.init_args] ret-4)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Json.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- ret-4] ret-5)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %SpellDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (ap (\"config\" ret-3) %SpellDefinition_obj_map)\n (ap (\"init_args\" ret-5) %SpellDefinition_obj_map)\n )\n (ap (\"name\" sp-0.$.name) %SpellDefinition_obj_map)\n )\n (ap (\"script\" ret-1) %SpellDefinition_obj_map)\n )\n (canon %init_peer_id% %SpellDefinition_obj_map SpellDefinition_obj)\n )\n )\n )\n (ap SpellDefinition_obj $spells)\n )\n (next sp-0)\n )\n )\n )\n (new %WorkerDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (canon %init_peer_id% $services #services_canon)\n (canon %init_peer_id% $spells #spells_canon)\n )\n (ap (\"services\" #services_canon) %WorkerDefinition_obj_map)\n )\n (ap (\"spells\" #spells_canon) %WorkerDefinition_obj_map)\n )\n (canon %init_peer_id% %WorkerDefinition_obj_map WorkerDefinition_obj)\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"json\" \"stringify\") [WorkerDefinition_obj] ret-6)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"WDJson.stringify\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call %init_peer_id% (\"ipfs_client\" \"upload_string\") [-ipfs-arg- ret-6] ret-7)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" \"exit\"])\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"IpfsClient.upload_string\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_worker_config\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new %WorkerDeployDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (ap (\"definition\" ret-7) %WorkerDeployDefinition_obj_map)\n (ap (\"dummy_deal_id\" w-0.$.dummy_deal_id) %WorkerDeployDefinition_obj_map)\n )\n (ap (\"hosts\" w-0.$.hosts) %WorkerDeployDefinition_obj_map)\n )\n (ap (\"name\" w-0.$.name) %WorkerDeployDefinition_obj_map)\n )\n (canon %init_peer_id% %WorkerDeployDefinition_obj_map WorkerDeployDefinition_obj)\n )\n )\n )\n (ap WorkerDeployDefinition_obj $deploy_defs)\n )\n (next w-0)\n )\n )\n (new %AppDeployDefinition_obj_map\n (seq\n (seq\n (seq\n (seq\n (canon %init_peer_id% $deploy_defs #deploy_defs_canon)\n (ap (\"installation_script\" -config-arg-.$.installation_script) %AppDeployDefinition_obj_map)\n )\n (ap (\"installation_trigger\" -config-arg-.$.installation_trigger) %AppDeployDefinition_obj_map)\n )\n (ap (\"workers\" #deploy_defs_canon) %AppDeployDefinition_obj_map)\n )\n (canon %init_peer_id% %AppDeployDefinition_obj_map AppDeployDefinition_obj)\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_deal\" \"exit\"])\n (null)\n )\n )\n (seq\n (new -return-error-msg-\n (seq\n (call %init_peer_id% (\"op\" \"concat_strings\") [\"exit with error: \" :error:.$.message] -return-error-msg-)\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_deal\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (call %init_peer_id% (\"callbackSrv\" \"response\") [AppDeployDefinition_obj])\n )\n (call %init_peer_id% (\"errorHandlingSrv\" \"error\") [:error: 0])\n)\n"; export type Upload_dealArgConfig = { installation_script: string; installation_trigger: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; workers: { config: { services: { modules: { config: string; wasm: string; }[]; name: string; }[]; spells: { config: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; init_args: unknown; name: string; script: string; }[]; }; dummy_deal_id: string; hosts: string[]; name: string; }[]; }; export type Upload_dealResult = { installation_script: string; installation_trigger: { blockchain: { end_block: number; start_block: number; }; clock: { end_sec: number; period_sec: number; start_sec: number; }; connections: { connect: boolean; disconnect: boolean; }; }; workers: { definition: string; dummy_deal_id: string; hosts: string[]; name: string; }[]; }; export declare function upload_deal(config: Upload_dealArgConfig, ipfs: string, config?: { ttl?: number; }): Promise; export declare function upload_deal(peer: IFluenceClient$$, config: Upload_dealArgConfig, ipfs: string, config?: { ttl?: number; }): Promise;