/** * * 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 get_logs_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\" \"app_workers\") [] -app_workers-arg-)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"get_logs\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (new $logs\n (seq\n (seq\n (fold -app_workers-arg-.$.workers w-0\n (seq\n (fold w-0.$.installation_spells i-0\n (seq\n (new $error\n (xor\n (seq\n (seq\n (seq\n (seq\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 $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Spell-0-get_logs\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call i-0.$.worker_id (i-0.$.spell_id \"get_logs\") [] ret)\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Spell-0-get_logs\" \"exit\"])\n )\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\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\") [\"Spell-0-get_logs\" -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 i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.worker_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (xor\n (seq\n (match ret.$.success true\n (ap false not)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (ap true not)\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (new -if-error-\n (xor\n (match not true\n (seq\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Op.concat_strings\" \"enter\"])\n )\n (null)\n )\n (xor\n (seq\n (seq\n (call i-0.$.worker_id (\"op\" \"concat_strings\") [\"Failed to get logs: \" ret.$.error] ret-0)\n (ap ret-0 $error)\n )\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Op.concat_strings\" \"exit\"])\n )\n (null)\n )\n )\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\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\") [\"Op.concat_strings\" -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 i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.worker_id $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n )\n (seq\n (ap :error: -if-error-)\n (xor\n (match :error:.$.error_code 10001\n (null)\n )\n (fail -if-error-)\n )\n )\n )\n )\n )\n (new %LogsDirectResult_obj_map\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (canon i-0.$.worker_id $error #error_canon)\n (ap (\"error\" #error_canon) %LogsDirectResult_obj_map)\n )\n (ap (\"host_id\" i-0.$.host_id) %LogsDirectResult_obj_map)\n )\n (ap (\"logs\" ret.$.logs) %LogsDirectResult_obj_map)\n )\n (ap (\"spell_id\" i-0.$.spell_id) %LogsDirectResult_obj_map)\n )\n (ap (\"worker_id\" i-0.$.worker_id) %LogsDirectResult_obj_map)\n )\n (ap (\"worker_name\" w-0.$.name) %LogsDirectResult_obj_map)\n )\n (canon i-0.$.worker_id %LogsDirectResult_obj_map LogsDirectResult_obj)\n )\n )\n )\n (ap LogsDirectResult_obj $logs)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\n )\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 (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon i-0.$.host_id $-ephemeral-stream- #-ephemeral-canon-)\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 %init_peer_id% $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n (next i-0)\n )\n )\n (next w-0)\n )\n )\n (canon %init_peer_id% $logs #-logs-fix-0)\n )\n (ap #-logs-fix-0 -logs-flat-0)\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"get_logs\" \"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\") [\"get_logs\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (call %init_peer_id% (\"callbackSrv\" \"response\") [-logs-flat-0])\n )\n (call %init_peer_id% (\"errorHandlingSrv\" \"error\") [:error: 0])\n)\n"; export type Get_logsArgApp_workers = { workers: { definition: string; dummy_deal_id: string; installation_spells: { host_id: string; spell_id: string; worker_id: string; }[]; name: string; }[]; }; export declare function get_logs(app_workers: Get_logsArgApp_workers, config?: { ttl?: number; }): Promise<{ worker_id: string; worker_name: string; logs: { message: string; timestamp: number; }[]; spell_id: string; host_id: string; error: string | null; }[]>; export declare function get_logs(peer: IFluenceClient$$, app_workers: Get_logsArgApp_workers, config?: { ttl?: number; }): Promise<{ worker_id: string; worker_name: string; logs: { message: string; timestamp: number; }[]; spell_id: string; host_id: string; error: string | null; }[]>; export declare const upload_deploy_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_deploy\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"upload_workers\" \"enter\"])\n (null)\n )\n (xor\n (seq\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 (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\") [\"upload_workers\" -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\") [\"deploy\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (seq\n (new $workers\n (seq\n (fold AppDeployDefinition_obj.$.workers w-1-0\n (seq\n (new $spells-0\n (seq\n (seq\n (seq\n (fold w-1-0.$.hosts h-1-0\n (seq\n (xor\n (seq\n (seq\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 (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_local_api_multiaddr\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call h-1-0 (\"aqua-ipfs\" \"get_local_api_multiaddr\") [] ret-11)\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_local_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_local_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-1-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 (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\") [\"deploy_single_worker\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (new $spell_id-0\n (new $worker_id-0\n (seq\n (seq\n (seq\n (seq\n (seq\n (new %WorkerSpellArgs_obj_map\n (seq\n (seq\n (seq\n (ap (\"deal_id\" w-1-0.$.dummy_deal_id) %WorkerSpellArgs_obj_map)\n (ap (\"ipfs\" ret-11.$.multiaddr) %WorkerSpellArgs_obj_map)\n )\n (ap (\"worker_def_cid\" w-1-0.$.definition) %WorkerSpellArgs_obj_map)\n )\n (canon h-1-0 %WorkerSpellArgs_obj_map WorkerSpellArgs_obj)\n )\n )\n (xor\n (seq\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\") [\"Worker.create\" \"enter\"])\n )\n (null)\n )\n (xor\n (seq\n (seq\n (seq\n (new $option-inline\n (seq\n (xor\n (ap w-1-0.$.dummy_deal_id $option-inline)\n (null)\n )\n (canon h-1-0 $option-inline #option-inline-0)\n )\n )\n (call h-1-0 (\"worker\" \"create\") [#option-inline-0] ret-12)\n )\n (ap ret-12 $worker_id-0)\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\") [\"Worker.create\" \"exit\"])\n )\n (null)\n )\n )\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\") [\"Worker.create\" -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-1-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n (seq\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\") [\"Worker.get_peer_id\" \"enter\"])\n )\n (null)\n )\n (xor\n (seq\n (seq\n (seq\n (new $option-inline-1\n (seq\n (xor\n (ap w-1-0.$.dummy_deal_id $option-inline-1)\n (null)\n )\n (canon h-1-0 $option-inline-1 #option-inline-1-0)\n )\n )\n (call h-1-0 (\"worker\" \"get_peer_id\") [#option-inline-1-0] ret-13)\n )\n (ap ret-13 $worker_id-0)\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\") [\"Worker.get_peer_id\" \"exit\"])\n )\n (null)\n )\n )\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\") [\"Worker.get_peer_id\" -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-1-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n )\n )\n (new $worker_id-0_test\n (seq\n (seq\n (fold $worker_id-0 worker_id-0_fold_var\n (seq\n (seq\n (ap worker_id-0_fold_var $worker_id-0_test)\n (canon h-1-0 $worker_id-0_test #worker_id-0_iter_canon)\n )\n (xor\n (match #worker_id-0_iter_canon.length 1\n (null)\n )\n (next worker_id-0_fold_var)\n )\n )\n (never)\n )\n (canon h-1-0 $worker_id-0_test #worker_id-0_result_canon)\n )\n (ap #worker_id-0_result_canon worker_id-0_gate)\n )\n )\n )\n (xor\n (xor\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\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\") [\"Srv.resolve_alias\" \"enter\"])\n )\n (null)\n )\n (xor\n (seq\n (seq\n (call worker_id-0_gate.$.[0] (\"srv\" \"resolve_alias\") [\"worker-spell\"] ret-14)\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\") [\"Srv.resolve_alias\" \"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\") [\"Srv.resolve_alias\" -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 worker_id-0_gate.$.[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 (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\") [\"Json.stringify\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call worker_id-0_gate.$.[0] (\"json\" \"stringify\") [w-1-0.$.definition] ret-15)\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\") [\"Json.stringify\" \"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\") [\"Json.stringify\" -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 worker_id-0_gate.$.[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 (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\") [\"Spell-0-set_string\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call worker_id-0_gate.$.[0] (ret-14 \"set_string\") [\"worker_def_cid\" ret-15] ret-16)\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\") [\"Spell-0-set_string\" \"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\") [\"Spell-0-set_string\" -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 worker_id-0_gate.$.[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-14 $spell_id-0)\n )\n (seq\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\") [\"PeerSpell.install\" \"enter\"])\n )\n (null)\n )\n (xor\n (seq\n (seq\n (call worker_id-0_gate.$.[0] (\"spell\" \"install\") [AppDeployDefinition_obj.$.installation_script WorkerSpellArgs_obj AppDeployDefinition_obj.$.installation_trigger \"worker-spell\"] ret-17)\n (ap ret-17 $spell_id-0)\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\") [\"PeerSpell.install\" \"exit\"])\n )\n (null)\n )\n )\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\") [\"PeerSpell.install\" -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 worker_id-0_gate.$.[0] $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n )\n (fail :error:)\n )\n )\n (new $spell_id-0_test\n (seq\n (seq\n (fold $spell_id-0 spell_id-0_fold_var\n (seq\n (seq\n (ap spell_id-0_fold_var $spell_id-0_test)\n (canon h-1-0 $spell_id-0_test #spell_id-0_iter_canon)\n )\n (xor\n (match #spell_id-0_iter_canon.length 1\n (null)\n )\n (next spell_id-0_fold_var)\n )\n )\n (never)\n )\n (canon h-1-0 $spell_id-0_test #spell_id-0_result_canon)\n )\n (ap #spell_id-0_result_canon spell_id-0_gate)\n )\n )\n )\n (new $worker_id-0_test-0\n (seq\n (seq\n (fold $worker_id-0 worker_id-0_fold_var-0\n (seq\n (seq\n (ap worker_id-0_fold_var-0 $worker_id-0_test-0)\n (canon h-1-0 $worker_id-0_test-0 #worker_id-0_iter_canon-0)\n )\n (xor\n (match #worker_id-0_iter_canon-0.length 1\n (null)\n )\n (next worker_id-0_fold_var-0)\n )\n )\n (never)\n )\n (canon h-1-0 $worker_id-0_test-0 #worker_id-0_result_canon-0)\n )\n (ap #worker_id-0_result_canon-0 worker_id-0_gate-0)\n )\n )\n )\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\") [\"deploy_single_worker\" \"exit\"])\n )\n (null)\n )\n )\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\") [\"deploy_single_worker\" -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-1-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n (new %DeployedSpell_obj_map\n (seq\n (seq\n (seq\n (ap (\"host_id\" h-1-0) %DeployedSpell_obj_map)\n (ap (\"spell_id\" spell_id-0_gate.$.[0]) %DeployedSpell_obj_map)\n )\n (ap (\"worker_id\" worker_id-0_gate-0.$.[0]) %DeployedSpell_obj_map)\n )\n (canon h-1-0 %DeployedSpell_obj_map DeployedSpell_obj)\n )\n )\n )\n (ap DeployedSpell_obj $spells-0)\n )\n (xor\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (par\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Console.print\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (new $array-inline\n (seq\n (seq\n (seq\n (seq\n (seq\n (ap \"deployed spell\" $array-inline)\n (ap spell_id-0_gate.$.[0] $array-inline)\n )\n (ap worker_id-0_gate-0.$.[0] $array-inline)\n )\n (ap \"to\" $array-inline)\n )\n (ap h-1-0 $array-inline)\n )\n (canon %init_peer_id% $array-inline #array-inline-0)\n )\n )\n (call %init_peer_id% (\"run-console\" \"print\") [#array-inline-0])\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Console.print\" \"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\") [\"Console.print\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (null)\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 h-1-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\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-1-0)\n )\n )\n (new %DeployedWorkers_obj_map\n (seq\n (seq\n (seq\n (seq\n (seq\n (canon %init_peer_id% $spells-0 #spells-0_canon)\n (ap (\"definition\" w-1-0.$.definition) %DeployedWorkers_obj_map)\n )\n (ap (\"dummy_deal_id\" w-1-0.$.dummy_deal_id) %DeployedWorkers_obj_map)\n )\n (ap (\"installation_spells\" #spells-0_canon) %DeployedWorkers_obj_map)\n )\n (ap (\"name\" w-1-0.$.name) %DeployedWorkers_obj_map)\n )\n (canon %init_peer_id% %DeployedWorkers_obj_map DeployedWorkers_obj)\n )\n )\n )\n (ap DeployedWorkers_obj $workers)\n )\n (xor\n (par\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Console.print\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (new $array-inline-1\n (seq\n (seq\n (seq\n (ap \"deployed workers\" $array-inline-1)\n (canon %init_peer_id% $workers #push-to-stream-605)\n )\n (ap #push-to-stream-605 $array-inline-1)\n )\n (canon %init_peer_id% $array-inline-1 #array-inline-1-0)\n )\n )\n (call %init_peer_id% (\"run-console\" \"print\") [#array-inline-1-0])\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Console.print\" \"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\") [\"Console.print\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (null)\n )\n (fail :error:)\n )\n )\n )\n (next w-1-0)\n )\n )\n (new %DeployedAppWorkers_obj_map\n (seq\n (seq\n (canon %init_peer_id% $workers #workers_canon)\n (ap (\"workers\" #workers_canon) %DeployedAppWorkers_obj_map)\n )\n (canon %init_peer_id% %DeployedAppWorkers_obj_map DeployedAppWorkers_obj)\n )\n )\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"deploy\" \"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\") [\"deploy\" -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\") [\"upload_deploy\" \"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_deploy\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (call %init_peer_id% (\"callbackSrv\" \"response\") [DeployedAppWorkers_obj])\n )\n (call %init_peer_id% (\"errorHandlingSrv\" \"error\") [:error: 0])\n)\n"; export type Upload_deployArgConfig = { 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_deployResult = { workers: { definition: string; dummy_deal_id: string; installation_spells: { host_id: string; spell_id: string; worker_id: string; }[]; name: string; }[]; }; export declare function upload_deploy(config: Upload_deployArgConfig, config?: { ttl?: number; }): Promise; export declare function upload_deploy(peer: IFluenceClient$$, config: Upload_deployArgConfig, config?: { ttl?: number; }): Promise; export declare const get_logs_deal_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\" \"deals\") [] -deals-arg-)\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"get_logs_deal\" \"enter\"])\n (null)\n )\n )\n (xor\n (seq\n (new $result\n (seq\n (seq\n (xor\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (fold -deals-arg- deal_id-0\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Subnet.resolve\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (seq\n (call -relay- (\"subnet\" \"resolve\") [deal_id-0] ret)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Subnet.resolve\" \"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\") [\"Subnet.resolve\" -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 (xor\n (seq\n (match ret.$.success true\n (ap false not)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (ap true not)\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (new -if-else-error-\n (new -else-error-\n (new -if-error-\n (xor\n (seq\n (match not true\n (seq\n (seq\n (seq\n (seq\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Op.concat_strings\" \"enter\"])\n (null)\n )\n (xor\n (seq\n (call -relay- (\"op\" \"concat_strings\") [\"Failed to resolve subnet: \" ret.$.error.[0]] ret-0)\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Op.concat_strings\" \"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\") [\"Op.concat_strings\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (new $option-inline\n (seq\n (xor\n (ap ret-0 $option-inline)\n (null)\n )\n (canon -relay- $option-inline #option-inline-0)\n )\n )\n )\n (new %LogsDealResult_obj_map\n (seq\n (seq\n (seq\n (seq\n (ap (\"deal_id\" deal_id-0) %LogsDealResult_obj_map)\n (ap (\"error\" #option-inline-0) %LogsDealResult_obj_map)\n )\n (ap (\"logs\" []) %LogsDealResult_obj_map)\n )\n (ap (\"success\" false) %LogsDealResult_obj_map)\n )\n (canon -relay- %LogsDealResult_obj_map LogsDealResult_obj)\n )\n )\n )\n (ap LogsDealResult_obj $result)\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 (ap :error: -if-error-)\n (xor\n (seq\n (match :error:.$.error_code 10001\n (new $logs\n (seq\n (seq\n (fold ret.$.workers w-0\n (seq\n (seq\n (seq\n (ap w-0.$.worker_id w-0_flat)\n (ap w-0.$.host_id w-0_flat-0)\n )\n (new -if-else-error-\n (new -else-error-\n (new -if-error-\n (xor\n (match w-0.$.worker_id []\n (seq\n (seq\n (new $option-inline-1\n (seq\n (xor\n (ap \"Worker is not installed yet\" $option-inline-1)\n (null)\n )\n (canon -relay- $option-inline-1 #option-inline-1-0)\n )\n )\n (new %LogsDeal_obj_map\n (seq\n (seq\n (seq\n (seq\n (seq\n (ap (\"error\" #option-inline-1-0) %LogsDeal_obj_map)\n (ap (\"host_id\" w-0_flat-0) %LogsDeal_obj_map)\n )\n (ap (\"logs\" []) %LogsDeal_obj_map)\n )\n (ap (\"spell_id\" []) %LogsDeal_obj_map)\n )\n (ap (\"worker_id\" []) %LogsDeal_obj_map)\n )\n (canon -relay- %LogsDeal_obj_map LogsDeal_obj)\n )\n )\n )\n (ap LogsDeal_obj $logs)\n )\n )\n (seq\n (ap :error: -if-error-)\n (xor\n (match :error:.$.error_code 10001\n (new $error\n (xor\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Srv.resolve_alias\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call w-0_flat.$.[0] (\"srv\" \"resolve_alias\") [\"worker-spell\"] ret-1)\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Srv.resolve_alias\" \"exit\"])\n )\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\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\") [\"Srv.resolve_alias\" -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 w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat.$.[0] $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Spell-1-get_logs\" \"enter\"])\n )\n (null)\n )\n )\n (xor\n (seq\n (seq\n (call w-0_flat.$.[0] (ret-1 \"get_logs\") [] ret-2)\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Spell-1-get_logs\" \"exit\"])\n )\n (null)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\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\") [\"Spell-1-get_logs\" -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 w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat.$.[0] $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (xor\n (seq\n (match ret-2.$.success true\n (ap false not-0)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (ap true not-0)\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (new -if-error-\n (xor\n (match not-0 true\n (seq\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Op.concat_strings\" \"enter\"])\n )\n (null)\n )\n (xor\n (seq\n (seq\n (call w-0_flat.$.[0] (\"op\" \"concat_strings\") [\"Failed to get logs: \" ret-2.$.error] ret-3)\n (ap ret-3 $error)\n )\n (par\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"Op.concat_strings\" \"exit\"])\n )\n (null)\n )\n )\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\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\") [\"Op.concat_strings\" -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 w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat.$.[0] $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n )\n (seq\n (ap :error: -if-error-)\n (xor\n (match :error:.$.error_code 10001\n (null)\n )\n (fail -if-error-)\n )\n )\n )\n )\n )\n (new $option-inline-2\n (seq\n (xor\n (ap ret-1 $option-inline-2)\n (null)\n )\n (canon w-0_flat.$.[0] $option-inline-2 #option-inline-2-0)\n )\n )\n )\n (new %LogsDeal_obj-0_map\n (seq\n (seq\n (seq\n (seq\n (seq\n (seq\n (canon w-0_flat.$.[0] $error #error_canon)\n (ap (\"error\" #error_canon) %LogsDeal_obj-0_map)\n )\n (ap (\"host_id\" w-0_flat-0) %LogsDeal_obj-0_map)\n )\n (ap (\"logs\" ret-2.$.logs) %LogsDeal_obj-0_map)\n )\n (ap (\"spell_id\" #option-inline-2-0) %LogsDeal_obj-0_map)\n )\n (ap (\"worker_id\" w-0_flat) %LogsDeal_obj-0_map)\n )\n (canon w-0_flat.$.[0] %LogsDeal_obj-0_map LogsDeal_obj-0)\n )\n )\n )\n (ap LogsDeal_obj-0 $logs)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (seq\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon w-0_flat-0 $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (fail :error:)\n )\n )\n )\n )\n (seq\n (seq\n (ap :error: -else-error-)\n (xor\n (match :error:.$.error_code 10001\n (ap -if-error- -if-else-error-)\n )\n (ap -else-error- -if-else-error-)\n )\n )\n (fail -if-else-error-)\n )\n )\n )\n )\n )\n )\n )\n )\n (next w-0)\n )\n )\n (new %LogsDealResult_obj-0_map\n (seq\n (seq\n (seq\n (seq\n (seq\n (canon -relay- $logs #logs_canon)\n (ap (\"deal_id\" deal_id-0) %LogsDealResult_obj-0_map)\n )\n (ap (\"error\" []) %LogsDealResult_obj-0_map)\n )\n (ap (\"logs\" #logs_canon) %LogsDealResult_obj-0_map)\n )\n (ap (\"success\" true) %LogsDealResult_obj-0_map)\n )\n (canon -relay- %LogsDealResult_obj-0_map LogsDealResult_obj-0)\n )\n )\n )\n (ap LogsDealResult_obj-0 $result)\n )\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 (ap :error: -else-error-)\n (xor\n (seq\n (match :error:.$.error_code 10001\n (ap -if-error- -if-else-error-)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n (seq\n (ap -else-error- -if-else-error-)\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (fail -if-else-error-)\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n (new $-ephemeral-stream-\n (new #-ephemeral-canon-\n (canon -relay- $-ephemeral-stream- #-ephemeral-canon-)\n )\n )\n )\n )\n )\n )\n )\n )\n (next deal_id-0)\n )\n )\n )\n (fail :error:)\n )\n (canon %init_peer_id% $result #-result-fix-0)\n )\n (ap #-result-fix-0 -result-flat-0)\n )\n )\n (par\n (call %init_peer_id% (\"tracingSrv\" \"tracingEvent\") [\"get_logs_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\") [\"get_logs_deal\" -return-error-msg-])\n )\n )\n (fail :error:)\n )\n )\n )\n (call %init_peer_id% (\"callbackSrv\" \"response\") [-result-flat-0])\n )\n (call %init_peer_id% (\"errorHandlingSrv\" \"error\") [:error: 0])\n)\n"; export declare function get_logs_deal(deals: string[], config?: { ttl?: number; }): Promise<{ deal_id: string; error: string | null; logs: { worker_id: string | null; logs: { message: string; timestamp: number; }[]; spell_id: string | null; host_id: string; error: string | null; }[]; }[]>; export declare function get_logs_deal(peer: IFluenceClient$$, deals: string[], config?: { ttl?: number; }): Promise<{ deal_id: string; error: string | null; logs: { worker_id: string | null; logs: { message: string; timestamp: number; }[]; spell_id: string | null; host_id: string; error: string | null; }[]; }[]>;