@devbookhq/sdk - npm Package Compare versions

Comparing version 1.0.10 to 1.0.11

lib/cjs/core/constants/runner.d.ts

 export declare const REMOTE_RUNNER_HOSTNAME = "orchestrator.usedevbook.com";
 export declare const STORAGE_SESSION_ID_KEY = "dbk_sdk_session_id";
 export declare const SESSION_PING_PERIOD = 5000;
-export declare const SESSION_RESTART_PERIOD = 3000;
-export declare const WSCONN_RESTART_PERIOD = 3000;
+export declare const SESSION_RESTART_PERIOD = 2500;
+export declare const WSCONN_RESTART_PERIOD = 2500;

lib/cjs/core/devbook.d.ts

@@ -139,2 +139,6 @@ import { Filesystem } from './runningEnvironment/filesystem';
     destroy(): void;
+    /** @internal */
+    __internal__start(): void;
+    /** @internal */
+    __internal__stop(): void;
     private listDir;
@@ -141,0 +145,0 @@ private createDir;

lib/cjs/core/runner.d.ts

@@ -15,4 +15,8 @@ import EvaluationContext, { EvaluationContextOpts } from './evaluationContext';
     createContext(opts: Omit<EvaluationContextOpts, 'conn'>): EvaluationContext;
+    /** @internal */
+    __internal__start(): void;
+    /** @internal */
+    __internal__stop(): void;
     __debug__loadNewSession(): void;
 }
 export default Runner;

lib/cjs/core/session/sessionManager.d.ts

@@ -12,2 +12,4 @@ import { WebSocketConnection } from '../webSocketConnection';
     private readonly url;
+    private userActivity;
+    private startActivity?;
     private isGettingSessionActive;
@@ -19,2 +21,4 @@ private get cachedSessionID();
     constructor(conn: WebSocketConnection);
+    stop(): void;
+    start(): void;
     reset(): void;
@@ -21,0 +25,0 @@ /**

lib/cjs/index.js

@@ -15,3 +15,3 @@ "use strict";Object.defineProperty(exports,"__esModule",{value:!0});var t=require("react");class e{constructor(t,e=!1){this.logID=t,this.isEnabled=e}id(){return"function"==typeof this.logID?this.logID():this.logID}log(...t){this.isEnabled&&console.log(`[${this.id()}]`,...t)}warn(...t){this.isEnabled&&console.warn(`[${this.id()}]`,...t)}error(...t){console.error(`[${this.id()} ERROR]`,...t)}}
 PERFORMANCE OF THIS SOFTWARE.
-***************************************************************************** */function n(t,e,n,s){return new(n||(n=Promise))((function(i,o){function r(t){try{h(s.next(t))}catch(t){o(t)}}function a(t){try{h(s.throw(t))}catch(t){o(t)}}function h(t){var e;t.done?i(t.value):(e=t.value,e instanceof n?e:new n((function(t){t(e)}))).then(r,a)}h((s=s.apply(t,e||[])).next())}))}function s(t){return new Promise((e=>setTimeout(e,t)))}var i,o,r;!function(t){t.Error="Runner.Error"}(i||(i={})),function(t){t.Start="RunningEnvironment.Start",t.StartAck="RunningEnvironment.StartAck",t.Eval="RunningEnvironment.Eval",t.FSEventCreate="RunningEnvironment.FSEventCreate",t.FSEventRemove="RunningEnvironment.FSEventRemove",t.FSEventWrite="RunningEnvironment.FSEventWrite",t.CreateDir="RunningEnvironment.CreateDir",t.ListDir="RunningEnvironment.ListDir",t.WriteFile="RunningEnvironment.WriteFile",t.GetFile="RunningEnvironment.GetFile",t.RemoveFile="RunningEnvironment.RemoveFile",t.DirContent="RunningEnvironment.DirContent",t.FileContent="RunningEnvironment.FileContent",t.Stdout="RunningEnvironment.Stdout",t.Stderr="RunningEnvironment.Stderr",t.ExecCmd="RunningEnvironment.ExecCmd",t.KillCmd="RunningEnvironment.KillCmd",t.ListRunningCmds="RunningEnvironment.ListRunningCmds",t.CmdOut="RunningEnvironment.CmdOut",t.CmdExit="RunningEnvironment.CmdExit",t.RunningCmds="RunningEnvironment.RunningCmds",t.RunCode="RunningEnvironment.Run"}(o||(o={})),function(t){t.Error="CodeCell.Error"}(r||(r={}));const a={Runner:i,RunningEnvironment:o,CodeCell:r};class h{constructor(){this.url="wss://orchestrator.usedevbook.com",this.logger=new e("WebSocketConnection"),this.handlers=[]}get state(){var t;return null===(t=this.client)||void 0===t?void 0:t.readyState}get isClosed(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSED}get isClosing(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSING}get isOpen(){if(void 0!==this.client)return this.client.readyState===this.client.OPEN}get isConnecting(){if(void 0!==this.client)return this.client.readyState===this.client.CONNECTING}subscribeHandler(t){return this.handlers.push(t),()=>{this.handlers=this.handlers.filter((e=>e!==t))}}connect(t){(!this.client||this.client.readyState!==this.client.CONNECTING&&this.client.readyState!==this.client.OPEN)&&(t||this.sessionID?(t?(this.logger.log(`Will try to connect to session "${t}"`),this.sessionID=t):!t&&this.sessionID&&this.logger.log(`Will try to connect to previous session "${this.sessionID}"`),this.client=new WebSocket(`${this.url}/session/ws/${this.sessionID}`),this.client.onopen=()=>this.handleOpen(this.sessionID),this.client.onmessage=t=>{this.logger.log("Received (raw)",{msg:t}),this.handleMessage(t)},this.client.onerror=t=>this.handleError(t),this.client.onclose=t=>this.handleClose(t)):this.logger.error("Cannot connect, no session ID passed to the function and no session ID saved from the previous session"))}send(t){this.client&&this.client.readyState===this.client.OPEN?(this.logger.log("Send",t),this._send(t)):this.logger.warn("Trying to send a message while not being in the `OPEN` state or without established connection, message will be discarded",t)}close(){var t;this.logger.log("Closing connection"),null===(t=this.client)||void 0===t||t.close(1e3)}handleOpen(t){var e;this.logger.log("Connection opened",{readyState:null===(e=this.client)||void 0===e?void 0:e.readyState}),this.handlers.forEach((e=>e.onOpen(t)))}_send(t){var e,n;null===(e=this.client)||void 0===e||e.send((n=t,JSON.stringify(n,(()=>{const t=new WeakSet;return(e,n)=>{if("object"==typeof n&&null!==n){if(t.has(n))return;t.add(n)}return n}})(),2)))}handleClose(t){return n(this,void 0,void 0,(function*(){this.logger.log("Connection closed",t),this.handlers.forEach((t=>t.onClose())),this.logger.log("Will try to reconnect in 3s"),yield s(3e3),this.connect()}))}handleError(t){var e;this.logger.error("Connection error",t),null===(e=this.client)||void 0===e||e.close()}handleMessage(t){if(!t.data)return void this.logger.error("Message has empty data field",t);const e=JSON.parse(t.data);if(!e.type)return void this.logger.error("Message has no type",e);const n=e;Object.values(a.RunningEnvironment).includes(n.type)||Object.values(a.Runner).includes(n.type)||Object.values(a.CodeCell).includes(n.type)?n.type!==a.Runner.Error?(this.logger.log("Received (parsed)",n),this.handlers.forEach((t=>t.onMessage(n)))):this.logger.error("Runner error",n):this.logger.error('Message "type" field has unexpected value',n)}}var l,d;!function(t){t.Ok="Ok",t.Terminated="Terminated"}(l||(l={}));class c{constructor(t,n=new Date){this.id=t,this.lastPing=n,this.logger=new e("RunnerSession"),this.url="https://orchestrator.usedevbook.com"}ping(){return n(this,void 0,void 0,(function*(){this.logger.log(`Pinging session "${this.id}"`);const t=JSON.stringify({sessionID:this.id});try{const e=yield fetch(`${this.url}/session/ping`,{method:"POST",headers:{"Content-Type":"application/json"},body:t}),n=yield e.json();if(!e.ok)throw this.logger.error(e.headers,n),new Error("Non-OK response when trying to ping active Runner session");if(n.status===l.Terminated)throw new Error(`[keepAlive]: Session '${this.id}' is terminated`);this.lastPing=new Date}catch(t){throw this.logger.error(t),new Error("Failed to ping active Runner session")}}))}}!function(t){t.Connected="Connected",t.Connecting="Connecting",t.Disconnected="Disconnected"}(d||(d={}));class u{constructor(t){this.conn=t,this.logger=new e("SessionManager"),this.url="https://orchestrator.usedevbook.com",this.isGettingSessionActive=!1,this.status=d.Disconnected,this.logger.log("Initialize"),this.getSession()}get cachedSessionID(){return sessionStorage.getItem("dbk_sdk_session_id")}set cachedSessionID(t){null===t?(this.logger.log("Cleared last sessionID"),sessionStorage.removeItem("dbk_sdk_session_id")):(this.logger.log(`Saved sessionID "${t}" as last sessionID`),sessionStorage.setItem("dbk_sdk_session_id",t))}reset(){this.logger.log("Reset"),this.status=d.Disconnected,this.cachedSessionID=null,this.conn.close(),this.session=void 0}getSession(){var t;return n(this,void 0,void 0,(function*(){if(!this.isGettingSessionActive)for(this.isGettingSessionActive=!0;;){this.status=d.Connecting;try{const e=this.cachedSessionID?`${this.url}/session/${this.cachedSessionID}`:`${this.url}/session`;this.cachedSessionID?this.logger.log(`Restoring old Runner session "${this.cachedSessionID}"`):this.logger.log("Acquiring new Runner session");const n=yield fetch(e),i=yield n.json();if(!n.ok){this.logger.error("Non-OK response when trying to ping active Runner session. Will try again in 3s",n.headers,i),yield s(3e3);continue}for(this.session=new c(i.sessionID),this.logger.log(`Acquired session "${this.session.id}"`),this.cachedSessionID=this.session.id,this.status=d.Connected,this.conn.connect(this.session.id),this.logger.log(`Started pinging session "${this.session.id}"`);this.session;)try{yield this.session.ping(),yield s(5e3)}catch(t){this.logger.error(`Failed to ping session "${this.session.id}"`,t);break}this.logger.log(`Stopped pinging session "${null===(t=this.session)||void 0===t?void 0:t.id}"`),this.session=void 0,this.status=d.Disconnected,this.conn.close()}catch(t){this.logger.error("Failed to acquire Runner session. Will try again in 3s",t),yield s(3e3)}}}))}}function g(t,e){for(var n=0,s=t.length-1;s>=0;s--){var i=t[s];"."===i?t.splice(s,1):".."===i?(t.splice(s,1),n++):n&&(t.splice(s,1),n--)}if(e)for(;n--;n)t.unshift("..");return t}var m=/^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/,p=function(t){return m.exec(t).slice(1)};function v(){for(var t="",e=!1,n=arguments.length-1;n>=-1&&!e;n--){var s=n>=0?arguments[n]:"/";if("string"!=typeof s)throw new TypeError("Arguments to path.resolve must be strings");s&&(t=s+"/"+t,e="/"===s.charAt(0))}return(e?"/":"")+(t=g(C(t.split("/"),(function(t){return!!t})),!e).join("/"))||"."}function f(t){var e=D(t),n="/"===b(t,-1);return(t=g(C(t.split("/"),(function(t){return!!t})),!e).join("/"))||e||(t="."),t&&n&&(t+="/"),(e?"/":"")+t}function D(t){return"/"===t.charAt(0)}var y={extname:function(t){return p(t)[3]},basename:function(t,e){var n=p(t)[2];return e&&n.substr(-1*e.length)===e&&(n=n.substr(0,n.length-e.length)),n},dirname:function(t){var e=p(t),n=e[0],s=e[1];return n||s?(s&&(s=s.substr(0,s.length-1)),n+s):"."},sep:"/",delimiter:":",relative:function(t,e){function n(t){for(var e=0;e<t.length&&""===t[e];e++);for(var n=t.length-1;n>=0&&""===t[n];n--);return e>n?[]:t.slice(e,n-e+1)}t=v(t).substr(1),e=v(e).substr(1);for(var s=n(t.split("/")),i=n(e.split("/")),o=Math.min(s.length,i.length),r=o,a=0;a<o;a++)if(s[a]!==i[a]){r=a;break}var h=[];for(a=r;a<s.length;a++)h.push("..");return(h=h.concat(i.slice(r))).join("/")},join:function(){var t=Array.prototype.slice.call(arguments,0);return f(C(t,(function(t,e){if("string"!=typeof t)throw new TypeError("Arguments to path.join must be strings");return t})).join("/"))},isAbsolute:D,normalize:f,resolve:v};function C(t,e){if(t.filter)return t.filter(e);for(var n=[],s=0;s<t.length;s++)e(t[s],s,t)&&n.push(t[s]);return n}var S,b="b"==="ab".substr(-1)?function(t,e,n){return t.substr(e,n)}:function(t,e,n){return e<0&&(e=t.length+e),t.substr(e,n)};class w{get level(){return y.normalize(this.path).split(y.sep).length-1}}function E(t){return t.sort(((t,e)=>"Prompt"===t.type?-2:t.type!==e.type?"Dir"===t.type?-1:"Dir"===e.type?1:0:t.key.localeCompare(e.key))),t}class I extends w{constructor({name:t,parent:e,onAddItem:n}){super(),this.children=[],this.name=t,this.parent=e,this.addItemHandler=n,this.path=y.join(this.parent.path,this.name)}removeChildNode(t){this.children=this.children.filter((e=>e!==t))}serialize(t,e,n){const s=this.children.map((s=>s.serialize(t,e,n)));return{type:"Dir",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:E(s)}}}class R extends w{constructor({name:t,parent:e}){super(),this.name=t,this.parent=e,this.path=y.join(this.parent.path,this.name)}serialize(){return{type:"File",key:this.path,title:this.name,isLeaf:!0}}}class k extends w{constructor({parent:t,forNode:e,onConfirm:n,onBlur:s}){super(),this.name="name-prompt",this.parent=t,this.forNode=e,this.path=y.join(t.path,this.name),this.onConfirm=n,this.onBlur=s}serialize(t,e,n){return{type:"Prompt",key:this.path,title:e({onConfirm:t=>{var e;return null===(e=this.onConfirm)||void 0===e?void 0:e.call(this,this,t)},onBlur:()=>{var t;return null===(t=this.onBlur)||void 0===t?void 0:t.call(this,this)}}),isLeaf:!0,selectable:!1,icon:n({type:this.forNode})}}}class F extends w{constructor({onAddItem:t}){super(),this.name="/",this.path="/",this.parent=void 0,this.children=[],this.addItemHandler=t}serialize(t,e,n){const s=this.children.map((s=>s.serialize(t,e,n)));return{type:"Root",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:E(s)}}}class x extends w{constructor({parent:t}){super(),this.name="empty-node",this.parent=t,this.path=y.join(this.parent.path,this.name)}serialize(){return{type:"Empty",key:this.path,title:"Empty Directory",isLeaf:!0,disabled:!0}}}class P{constructor(){this.logger=new e("Filesystem"),this.root=new F({onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}),this.startingPrintIndent=0,this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}removeAllListeners(){this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}addListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs.push(e);break;case"onDirsChange":this.onDirsChangeLs.push(e);break;case"onFileContent":this.onFileContentLs.push(e);break;case"onShowPrompt":this.onShowPromptLs.push(e);break;default:throw new Error(`Unknown event type: ${t}`)}}removeListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs=this.onNewItemConfirmLs.filter((t=>t!==e));break;case"onDirsChange":this.onDirsChangeLs=this.onDirsChangeLs.filter((t=>t!==e));break;case"onFileContent":this.onFileContentLs=this.onFileContentLs.filter((t=>t!==e));break;case"onShowPrompt":this.onShowPromptLs=this.onShowPromptLs.filter((t=>t!==e));break;default:throw new Error(`Unknown event type: ${t}`)}}addNodeToDir(t,e){this.logger.log("Adding node to dir",{dirPath:t,node:e});let n=this.find(t);if(n||(this.logger.log("Dir not found, will make all",{dirPath:t}),n=this.mkAll(t)),!n)throw new Error("dirNode is undefined");if(!(n instanceof F||n instanceof I))throw new Error(`Node at '${t}' is not a directory or a root node`);if(n.children.some((t=>t.name===e.name)))return;let s;s="Dir"===e.type?new I({name:e.name,parent:n,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new R({name:e.name,parent:n}),1===n.children.length&&n.children[0]instanceof x?n.children=[s]:n.children.push(s),this.notifyOnDirsChangeLs({dirPaths:[t]})}removeNodeFromDir(t,e){this.logger.log("Remove node from dir",{dirPath:t,nodeName:e.name});const n=this.find(t);if(!n)throw new Error(`No node with path '${t}'`);if(!(n instanceof F||n instanceof I))throw new Error(`Node at '${t}' is not a directory or root node`);const s=n.children.length;n.children=n.children.filter((t=>t.name!==e.name));s!==n.children.length?(0===n.children.length&&(n.children=[new x({parent:n})]),this.notifyOnDirsChangeLs({dirPaths:[t]})):this.logger.warn("Node not found in dir",{dirPath:t,nodeName:e.name})}setFileContent(t){this.logger.log("Update file content",t),this.onFileContentLs.forEach((e=>e(t)))}setDirsContent(t){this.logger.log("Set dirs content",t);for(const e of t){let t=this.find(e.dirPath);if(t||(this.logger.log("Dir not found, will make all",{dirPath:e.dirPath}),t=this.mkAll(e.dirPath)),!t)throw new Error("dirNode is undefined");if(!(t instanceof F||t instanceof I))throw new Error(`Node at '${e.dirPath}' is not a directory or a root node`);const n=t.children.find((t=>t instanceof k));if(e.content.length){const n=[];for(const s of e.content){let e;e="Dir"===s.type?new I({name:s.name,parent:t,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new R({name:s.name,parent:t}),n.push(e)}t.children=n}else t.children=[new x({parent:t})];n&&t.children.push(n)}this.notifyOnDirsChangeLs({dirPaths:t.map((t=>t.dirPath))})}showPrompt(t){const{event:e,parent:n,type:s}=t;if(this.logger.log("Show prompt",{parent:n,type:s}),n.children.some((t=>t instanceof k)))return;e.preventDefault();const i=new k({parent:n,forNode:s,onConfirm:((t,e)=>{if(this.logger.log("Prompt confirm",{prompt:t,name:e}),!e)return;const n=t.parent.path,i=y.join(t.parent.path,e);this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[n]}),this.notifyOnNewItemConfirmLs({fullPath:i,name:e,type:s})}).bind(this),onBlur:(t=>{this.logger.log("Prompt blur",{prompt:t});const e=t.parent.path;this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[e]})}).bind(this)});n.children.push(i),this.notifyOnDirsChangeLs({dirPaths:[i.parent.path]}),this.notifyOnShowPromptLs({dirPath:i.parent.path})}serialize(t,e,n){return this.logger.log("Serialize"),[this.root.serialize(t,e,n)]}print(t=this.root,e=this.startingPrintIndent){const n="  ".repeat(e);console.log(n+t.path,`(${t.name})`);for(const s of t.children)s instanceof I?this.print(s,e+1):console.log(n+"  "+s.path,`(${s.name})`)}find(t,e=this.root){if(this.logger.log("Find (recursion)",{currentPath:e.path,targetPath:t}),t=y.normalize(t),e.path===t)return e;const n=t.split(y.sep).length-1;if(!(e.level>n)&&(e instanceof F||e instanceof I))for(const n of e.children){const e=this.find(t,n);if(e)return e}}mkDir(t){this.logger.log("Make dir",t);const e=this.find(t.parentPath);if(!e)throw new Error(`Parent dir '${t.parentPath}' not found`);if(!(e instanceof F||e instanceof I))throw new Error("Parent is not a dir or root");const n=new I({parent:e,name:t.name,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})});return e.children.push(n),n}mkAll(t){this.logger.log("Make all",t);const e=t.split(y.sep);let n,s="/";for(const t of e)if(s=y.join(s,t),!this.find(s)){const e=y.dirname(s);n=this.mkDir({parentPath:e,name:t})}return n}removeFromParent(t){const{parent:e}=t;(e instanceof F||e instanceof I)&&(e.children=e.children.filter((e=>e!==t))),t.parent=void 0}notifyOnShowPromptLs(t){this.logger.log("Notify on show prompt",t),this.onShowPromptLs.forEach((e=>e(t)))}notifyOnNewItemConfirmLs(t){this.logger.log("Notify on new item confirm",t),this.onNewItemConfirmLs.forEach((e=>e(t)))}notifyOnDirsChangeLs(t){this.logger.log("Notify on dirs change",t),this.onDirsChangeLs.forEach((e=>e(t)))}}function L(t){return function(t){const e=Array.from(t).reduce(((t,e)=>0|31*t+e.charCodeAt(0)),0);return("0000000"+(e>>>0).toString(16)).slice(-8)}(t)}!function(t){t[t.Stdout=0]="Stdout",t[t.Stderr=1]="Stderr"}(S||(S={}));class _{constructor(t,e){this.contextID=t,this.templateID=e,this.output=[],this.filesystem=new P,this.isReady=!1,this.id=`${t}_${L(e)}`}restart(){this.output=[],this.isReady=!1,this.filesystem.setDirsContent([{dirPath:"/",content:[]}])}logOutput(t,e){this.output=[...this.output,{message:t,source:e}]}}function O(t,{environmentID:e,templateID:n}){const s={type:a.RunningEnvironment.Start,payload:{environmentID:e,templateID:n}};t.send(s)}class N{constructor(t){var n,s;this.opts=t,this.fsWriteSubscribers=[],this.fileContentSubscribers=[],this.logger=new e(`EvaluationContext [${t.templateID}]`,t.debug),this.env=new _(this.contextID,t.templateID);this.unsubscribeConnHandler=this.opts.conn.subscribeHandler({onOpen:t=>this.handleConnectionOpen(t),onMessage:t=>this.handleConnectionMessage(t),onClose:()=>this.handleConnectionClose()}),this.opts.conn.isOpen&&this.opts.conn.sessionID&&this.handleConnectionOpen(this.opts.conn.sessionID),this.opts.conn.isClosed&&this.handleConnectionClose(),O(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID}),null===(s=(n=this.opts).onEnvChange)||void 0===s||s.call(n,this.env)}get contextID(){return this.opts.contextID}restart(){this.logger.log("Restart",this.opts.conn.sessionID),this.env.restart(),O(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID})}destroy(){this.logger.log("Destroy"),this.unsubscribeConnHandler(),this.fsWriteSubscribers=[],this.fileContentSubscribers=[]}getFile({path:t}){return n(this,void 0,void 0,(function*(){let e;this.logger.log("Get file",{filepath:t});const n=new Promise(((t,n)=>{e=t,setTimeout((()=>{n("Timeout")}),1e4)})),s=n=>{n.path.endsWith(t)&&e(n.content)};this.subscribeFileContent(s),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.GetFile,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t});try{return yield n}catch(e){throw new Error(`Error retrieving file ${t}: ${e}`)}finally{this.unsubscribeFileContent(s)}}))}deleteFile({path:t}){this.logger.log("Delete file",{filepath:t}),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.RemoveFile,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t})}updateFile({path:t,content:e}){return n(this,void 0,void 0,(function*(){let n;this.logger.log("Update file",{filepath:t});const s=new Promise(((t,e)=>{n=t,setTimeout((()=>{e("Timeout")}),1e4)})),i=e=>{e.path.endsWith(t)&&n()};this.subscribeFSWrite(i),function(t,{environmentID:e,path:n,content:s}){const i={type:a.RunningEnvironment.WriteFile,payload:{environmentID:e,path:n,content:s}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t,content:e});try{yield s}catch(e){throw new Error(`File ${t} not written to VM: ${e}`)}finally{this.unsubscribeFSWrite(i)}}))}createDir({path:t}){this.logger.log("Create dir",{filepath:t}),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.CreateDir,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t})}listDir({path:t}){this.logger.log("List dir",{filepath:t}),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.ListDir,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t})}executeCommand({executionID:t,command:e}){this.logger.log("Execute shell command",{executionID:t,command:e}),function(t,{environmentID:e,executionID:n,command:s}){const i={type:a.RunningEnvironment.ExecCmd,payload:{environmentID:e,executionID:n,command:s}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,executionID:t,command:e})}subscribeFileContent(t){this.fileContentSubscribers.push(t)}unsubscribeFileContent(t){const e=this.fileContentSubscribers.indexOf(t);e>-1&&this.fileContentSubscribers.splice(e,1)}subscribeFSWrite(t){this.fsWriteSubscribers.push(t)}unsubscribeFSWrite(t){const e=this.fsWriteSubscribers.indexOf(t);e>-1&&this.fsWriteSubscribers.splice(e,1)}handleConnectionOpen(t){var e,n;this.restart(),null===(n=(e=this.opts).onSessionChange)||void 0===n||n.call(e,{status:d.Connected,sessionID:t})}handleConnectionClose(){var t,e;null===(e=(t=this.opts).onSessionChange)||void 0===e||e.call(t,{status:d.Connecting})}handleConnectionMessage(t){switch(this.logger.log("Handling message from remote Runner",{message:t}),t.type){case a.RunningEnvironment.StartAck:{const e=t;this.vmenv_handleStartAck(e.payload);break}case a.RunningEnvironment.CmdOut:{const e=t;this.vmenv_handleCmdOut(e.payload);break}case a.RunningEnvironment.CmdExit:{const e=t;this.vmenv_handleCmdExit(e.payload);break}case a.RunningEnvironment.FSEventWrite:{const e=t;this.vmenv_handleFSEventWrite(e.payload);break}case a.RunningEnvironment.FileContent:{const e=t;this.vmenv_handleFileContent(e.payload);break}case a.RunningEnvironment.FSEventCreate:{const e=t;this.vmenv_handleFSEventCreate(e.payload);break}case a.RunningEnvironment.FSEventRemove:{const e=t;this.vmenv_handleFSEventRemove(e.payload);break}case a.RunningEnvironment.DirContent:{const e=t;this.vmenv_handleDirContent(e.payload);break}case a.RunningEnvironment.Stderr:{const e=t;this.vmenv_handleStderr(e.payload);break}case a.RunningEnvironment.Stdout:{const e=t;this.vmenv_handleStdout(e.payload);break}default:this.logger.warn("Unknown message type",{message:t})}}vmenv_handleFSEventCreate(t){this.logger.log('[vmenv] Handling "FSEventCreate"',t);const e=y.basename(t.path),n=y.dirname(t.path),s="Directory"===t.type?"Dir":"File";this.env.filesystem.addNodeToDir(n,{name:e,type:s})}vmenv_handleFSEventRemove(t){this.logger.log('[vmenv] Handling "FSEventRemove"',{payload:t});const e=y.basename(t.path),n=y.dirname(t.path);this.env.filesystem.removeNodeFromDir(n,{name:e})}vmenv_handleDirContent(t){this.logger.log('[vmenv] Handling "DirContent"',t);const e=[];for(const n of t.content){const t=y.basename(n.path),s="Directory"===n.type?"Dir":"File";e.push({name:t,type:s})}this.env.filesystem.setDirsContent([{dirPath:t.dirPath,content:e}])}vmenv_handleCmdExit(t){var e,n;this.logger.log('[vmenv] Handling "CmdExit"',t),void 0!==t.error&&(null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,{environmentID:t.environmentID,executionID:t.executionID,stderr:t.error}))}vmenv_handleFSEventWrite(t){this.logger.log('[vmenv] Handling "FSEventWrite"',t),this.fsWriteSubscribers.forEach((e=>e(t)))}vmenv_handleFileContent(t){this.logger.log('[vmenv] Handling "FileContent"',{environmentID:t.environmentID,path:t.path}),this.fileContentSubscribers.forEach((e=>e(t)))}vmenv_handleStartAck(t){var e,n;this.logger.log('[vmenv] Handling "StartAck"',{payload:t}),this.env.isReady=!0,null===(n=(e=this.opts).onEnvChange)||void 0===n||n.call(e,this.env)}vmenv_handleCmdOut(t){var e,n;this.logger.log('[vmenv] Handling "CmdOut"',t),null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,t)}vmenv_handleStderr(t){this.logger.log('[vmenv] Handling "Stderr"',t),this.env.logOutput(t.message,S.Stderr)}vmenv_handleStdout(t){this.logger.log('[vmenv] Handling "Stdout"',t),this.env.logOutput(t.message,S.Stdout)}}class ${constructor(){this.logger=new e("Runner"),this.conn=new h,this.sessManager=new u(this.conn)}static get obj(){return $._obj||($._obj=new $)}get session(){return this.sessManager.session}get status(){return this.sessManager.status}reset(){this.logger.log("Reset"),this.sessManager.reset()}createContext(t){return new N(Object.assign(Object.assign({},t),{conn:this.conn}))}__debug__loadNewSession(){this.logger.log("__debug__loadNewSession"),this.sessManager.reset()}}const A=(M="1234567890abcdefghijklmnopqrstuvwxyz",W=6,()=>{let t="",e=W;for(;e--;)t+=M[Math.random()*M.length|0];return t});var M,W,j;exports.DevbookStatus=void 0,(j=exports.DevbookStatus||(exports.DevbookStatus={})).Disconnected="Disconnected",j.Connecting="Connecting",j.Connected="Connected";class H{constructor(t){this.opts=t,this.contextID="default",this.executionID=A(),this._isDestroyed=!1,this._isEnvReady=!1,this._sessionStatus=d.Disconnected,this._status=exports.DevbookStatus.Disconnected;const e=this.getURL.bind(this),n=()=>this.opts.env,s=()=>this.executionID,i=t=>this.isEnvReady=t,o=t=>this.sessionStatus=t,r=t=>this.sessionID=t;this.context=$.obj.createContext({debug:t.debug,templateID:t.env,contextID:this.contextID,onEnvChange(s){var o;s.templateID===n()&&(i(s.isReady),null===(o=t.onURLChange)||void 0===o||o.call(t,e))},onSessionChange({status:n,sessionID:s}){var i;r(s),o(n),null===(i=t.onURLChange)||void 0===i||i.call(t,e)},onCmdOut(e){var n,i;e.executionID===s()&&(void 0!==e.stdout&&(null===(n=t.onStdout)||void 0===n||n.call(t,e.stdout)),void 0!==e.stderr&&(null===(i=t.onStderr)||void 0===i||i.call(t,e.stderr)))}})}get sessionID(){return this._sessionID}set sessionID(t){this._sessionID=t}get isDestroyed(){return this._isDestroyed}set isDestroyed(t){this._isDestroyed=t,this.updateStatus()}get isEnvReady(){return this._isEnvReady}set isEnvReady(t){this._isEnvReady=t,this.updateStatus()}get sessionStatus(){return this._sessionStatus}set sessionStatus(t){this._sessionStatus=t,this.updateStatus()}get status(){return this._status}set status(t){var e,n;this._status=t,null===(n=(e=this.opts).onStatusChange)||void 0===n||n.call(e,t)}get env(){return this.context.env}get fs(){const t=this.env.filesystem;return{delete:this.deleteFile.bind(this),listDir:this.listDir.bind(this),createDir:this.createDir.bind(this),get:this.getFile.bind(this),write:this.writeFile.bind(this),addListener:t.addListener.bind(t),removeListener:t.removeListener.bind(t),serialize:t.serialize.bind(t)}}getURL(t){if(this.status===exports.DevbookStatus.Connected&&this.sessionID&&this.env.isReady)return`https://${t}-${this.env.id}-${this.sessionID}.o.usedevbook.com`}runCmd(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");this.executionID=A(),this.context.executeCommand({executionID:this.executionID,command:t})}destroy(){this.context.destroy(),this.isDestroyed=!0}listDir(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.listDir({path:t})}createDir(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.createDir({path:t})}deleteFile(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.deleteFile({path:t})}getFile(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.getFile({path:t})}writeFile(t,e){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.updateFile({path:t,content:e})}updateStatus(){if(this.isDestroyed)return void(this.status!==exports.DevbookStatus.Disconnected&&(this.status=exports.DevbookStatus.Disconnected));let t;switch(this.sessionStatus){case d.Disconnected:t=exports.DevbookStatus.Disconnected;break;case d.Connecting:t=exports.DevbookStatus.Connecting;break;case d.Connected:if(!this.isEnvReady){t=exports.DevbookStatus.Connecting;break}t=exports.DevbookStatus.Connected}this.status=t}}exports.Devbook=H,exports.useDevbook=function({env:e,debug:n,port:s}){const[i,o]=t.useState(),[r,a]=t.useState(exports.DevbookStatus.Disconnected),[h,l]=t.useState([]),[d,c]=t.useState([]),[u,g]=t.useState(),m=t.useCallback((t=>{i&&(c([]),l([]),i.runCmd(t))}),[i]);return t.useEffect((function(){const t=new H({debug:n,env:e,onStatusChange(t){a(t)},onStderr(t){l((e=>[...e,t]))},onStdout(t){c((e=>[...e,t]))},onURLChange(t){s&&g(t(s))}});return c([]),l([]),g(void 0),o(t),()=>{t.destroy()}}),[e,n,s]),{stderr:h,stdout:d,runCmd:m,status:r,fs:null==i?void 0:i.fs,url:u}};
+***************************************************************************** */function n(t,e,n,s){return new(n||(n=Promise))((function(i,o){function r(t){try{h(s.next(t))}catch(t){o(t)}}function a(t){try{h(s.throw(t))}catch(t){o(t)}}function h(t){var e;t.done?i(t.value):(e=t.value,e instanceof n?e:new n((function(t){t(e)}))).then(r,a)}h((s=s.apply(t,e||[])).next())}))}function s(t){return new Promise((e=>setTimeout(e,t)))}var i,o,r;!function(t){t.Error="Runner.Error"}(i||(i={})),function(t){t.Start="RunningEnvironment.Start",t.StartAck="RunningEnvironment.StartAck",t.Eval="RunningEnvironment.Eval",t.FSEventCreate="RunningEnvironment.FSEventCreate",t.FSEventRemove="RunningEnvironment.FSEventRemove",t.FSEventWrite="RunningEnvironment.FSEventWrite",t.CreateDir="RunningEnvironment.CreateDir",t.ListDir="RunningEnvironment.ListDir",t.WriteFile="RunningEnvironment.WriteFile",t.GetFile="RunningEnvironment.GetFile",t.RemoveFile="RunningEnvironment.RemoveFile",t.DirContent="RunningEnvironment.DirContent",t.FileContent="RunningEnvironment.FileContent",t.Stdout="RunningEnvironment.Stdout",t.Stderr="RunningEnvironment.Stderr",t.ExecCmd="RunningEnvironment.ExecCmd",t.KillCmd="RunningEnvironment.KillCmd",t.ListRunningCmds="RunningEnvironment.ListRunningCmds",t.CmdOut="RunningEnvironment.CmdOut",t.CmdExit="RunningEnvironment.CmdExit",t.RunningCmds="RunningEnvironment.RunningCmds",t.RunCode="RunningEnvironment.Run"}(o||(o={})),function(t){t.Error="CodeCell.Error"}(r||(r={}));const a={Runner:i,RunningEnvironment:o,CodeCell:r};class h{constructor(){this.url="wss://orchestrator.usedevbook.com",this.logger=new e("WebSocketConnection"),this.handlers=[]}get state(){var t;return null===(t=this.client)||void 0===t?void 0:t.readyState}get isClosed(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSED}get isClosing(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSING}get isOpen(){if(void 0!==this.client)return this.client.readyState===this.client.OPEN}get isConnecting(){if(void 0!==this.client)return this.client.readyState===this.client.CONNECTING}subscribeHandler(t){return this.handlers.push(t),()=>{this.handlers=this.handlers.filter((e=>e!==t))}}connect(t){(!this.client||this.client.readyState!==this.client.CONNECTING&&this.client.readyState!==this.client.OPEN)&&(t||this.sessionID?(t?(this.logger.log(`Will try to connect to session "${t}"`),this.sessionID=t):!t&&this.sessionID&&this.logger.log(`Will try to connect to previous session "${this.sessionID}"`),this.client=new WebSocket(`${this.url}/session/ws/${this.sessionID}`),this.client.onopen=()=>this.handleOpen(this.sessionID),this.client.onmessage=t=>{this.logger.log("Received (raw)",{msg:t}),this.handleMessage(t)},this.client.onerror=t=>this.handleError(t),this.client.onclose=t=>this.handleClose(t)):this.logger.error("Cannot connect, no session ID passed to the function and no session ID saved from the previous session"))}send(t){this.client&&this.client.readyState===this.client.OPEN?(this.logger.log("Send",t),this._send(t)):this.logger.warn("Trying to send a message while not being in the `OPEN` state or without established connection, message will be discarded",t)}close(){var t;this.logger.log("Closing connection"),null===(t=this.client)||void 0===t||t.close(1e3)}handleOpen(t){var e;this.logger.log("Connection opened",{readyState:null===(e=this.client)||void 0===e?void 0:e.readyState}),this.handlers.forEach((e=>e.onOpen(t)))}_send(t){var e,n;null===(e=this.client)||void 0===e||e.send((n=t,JSON.stringify(n,(()=>{const t=new WeakSet;return(e,n)=>{if("object"==typeof n&&null!==n){if(t.has(n))return;t.add(n)}return n}})(),2)))}handleClose(t){return n(this,void 0,void 0,(function*(){this.logger.log("Connection closed",t),this.handlers.forEach((t=>t.onClose())),this.logger.log("Will try to reconnect in 2.5s"),yield s(2500),this.connect()}))}handleError(t){var e;this.logger.error("Connection error",t),null===(e=this.client)||void 0===e||e.close()}handleMessage(t){if(!t.data)return void this.logger.error("Message has empty data field",t);const e=JSON.parse(t.data);if(!e.type)return void this.logger.error("Message has no type",e);const n=e;Object.values(a.RunningEnvironment).includes(n.type)||Object.values(a.Runner).includes(n.type)||Object.values(a.CodeCell).includes(n.type)?n.type!==a.Runner.Error?(this.logger.log("Received (parsed)",n),this.handlers.forEach((t=>t.onMessage(n)))):this.logger.error("Runner error",n):this.logger.error('Message "type" field has unexpected value',n)}}var l,c;!function(t){t.Ok="Ok",t.Terminated="Terminated"}(l||(l={}));class d{constructor(t,n=new Date){this.id=t,this.lastPing=n,this.logger=new e("RunnerSession"),this.url="https://orchestrator.usedevbook.com"}ping(){return n(this,void 0,void 0,(function*(){this.logger.log(`Pinging session "${this.id}"`);const t=JSON.stringify({sessionID:this.id});try{const e=yield fetch(`${this.url}/session/ping`,{method:"POST",headers:{"Content-Type":"application/json"},body:t}),n=yield e.json();if(!e.ok)throw this.logger.error(e.headers,n),new Error("Non-OK response when trying to ping active Runner session");if(n.status===l.Terminated)throw new Error(`[keepAlive]: Session '${this.id}' is terminated`);this.lastPing=new Date}catch(t){throw this.logger.error(t),new Error("Failed to ping active Runner session")}}))}}!function(t){t.Connected="Connected",t.Connecting="Connecting",t.Disconnected="Disconnected"}(c||(c={}));class u{constructor(t){this.conn=t,this.logger=new e("SessionManager"),this.url="https://orchestrator.usedevbook.com",this.userActivity=Promise.resolve(),this.isGettingSessionActive=!1,this.status=c.Disconnected,this.logger.log("Initialize"),this.getSession()}get cachedSessionID(){return sessionStorage.getItem("dbk_sdk_session_id")}set cachedSessionID(t){null===t?(this.logger.log("Cleared last sessionID"),sessionStorage.removeItem("dbk_sdk_session_id")):(this.logger.log(`Saved sessionID "${t}" as last sessionID`),sessionStorage.setItem("dbk_sdk_session_id",t))}stop(){var t;console.log("stopping session"),null===(t=this.startActivity)||void 0===t||t.call(this),this.userActivity=new Promise((t=>{this.startActivity=t})),this.reset()}start(){var t;console.log("starting session"),null===(t=this.startActivity)||void 0===t||t.call(this)}reset(){this.logger.log("Reset"),this.status=c.Disconnected,this.cachedSessionID=null,this.conn.close(),this.session=void 0}getSession(){var t;return n(this,void 0,void 0,(function*(){if(!this.isGettingSessionActive)for(this.isGettingSessionActive=!0;;){this.status=c.Connecting;try{const e=this.cachedSessionID?`${this.url}/session/${this.cachedSessionID}`:`${this.url}/session`;this.cachedSessionID?this.logger.log(`Restoring old Runner session "${this.cachedSessionID}"`):this.logger.log("Acquiring new Runner session");const n=yield fetch(e),i=yield n.json();if(!n.ok){this.logger.error("Non-OK response when trying to ping active Runner session. Will try again in 2.5s",n.headers,i),yield s(2500);continue}for(this.session=new d(i.sessionID),this.logger.log(`Acquired session "${this.session.id}"`),this.cachedSessionID=this.session.id,this.status=c.Connected,this.conn.connect(this.session.id),this.logger.log(`Started pinging session "${this.session.id}"`);this.session;)try{yield this.userActivity,yield this.session.ping(),yield s(5e3)}catch(t){this.logger.error(`Failed to ping session "${this.session.id}"`,t);break}this.logger.log(`Stopped pinging session "${null===(t=this.session)||void 0===t?void 0:t.id}"`),this.session=void 0,this.status=c.Disconnected,this.conn.close()}catch(t){this.logger.error("Failed to acquire Runner session. Will try again in 2.5s",t),yield s(2500)}}}))}}function g(t,e){for(var n=0,s=t.length-1;s>=0;s--){var i=t[s];"."===i?t.splice(s,1):".."===i?(t.splice(s,1),n++):n&&(t.splice(s,1),n--)}if(e)for(;n--;n)t.unshift("..");return t}var p=/^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/,v=function(t){return p.exec(t).slice(1)};function m(){for(var t="",e=!1,n=arguments.length-1;n>=-1&&!e;n--){var s=n>=0?arguments[n]:"/";if("string"!=typeof s)throw new TypeError("Arguments to path.resolve must be strings");s&&(t=s+"/"+t,e="/"===s.charAt(0))}return(e?"/":"")+(t=g(C(t.split("/"),(function(t){return!!t})),!e).join("/"))||"."}function f(t){var e=D(t),n="/"===b(t,-1);return(t=g(C(t.split("/"),(function(t){return!!t})),!e).join("/"))||e||(t="."),t&&n&&(t+="/"),(e?"/":"")+t}function D(t){return"/"===t.charAt(0)}var y={extname:function(t){return v(t)[3]},basename:function(t,e){var n=v(t)[2];return e&&n.substr(-1*e.length)===e&&(n=n.substr(0,n.length-e.length)),n},dirname:function(t){var e=v(t),n=e[0],s=e[1];return n||s?(s&&(s=s.substr(0,s.length-1)),n+s):"."},sep:"/",delimiter:":",relative:function(t,e){function n(t){for(var e=0;e<t.length&&""===t[e];e++);for(var n=t.length-1;n>=0&&""===t[n];n--);return e>n?[]:t.slice(e,n-e+1)}t=m(t).substr(1),e=m(e).substr(1);for(var s=n(t.split("/")),i=n(e.split("/")),o=Math.min(s.length,i.length),r=o,a=0;a<o;a++)if(s[a]!==i[a]){r=a;break}var h=[];for(a=r;a<s.length;a++)h.push("..");return(h=h.concat(i.slice(r))).join("/")},join:function(){var t=Array.prototype.slice.call(arguments,0);return f(C(t,(function(t,e){if("string"!=typeof t)throw new TypeError("Arguments to path.join must be strings");return t})).join("/"))},isAbsolute:D,normalize:f,resolve:m};function C(t,e){if(t.filter)return t.filter(e);for(var n=[],s=0;s<t.length;s++)e(t[s],s,t)&&n.push(t[s]);return n}var S,b="b"==="ab".substr(-1)?function(t,e,n){return t.substr(e,n)}:function(t,e,n){return e<0&&(e=t.length+e),t.substr(e,n)};class w{get level(){return y.normalize(this.path).split(y.sep).length-1}}function E(t){return t.sort(((t,e)=>"Prompt"===t.type?-2:t.type!==e.type?"Dir"===t.type?-1:"Dir"===e.type?1:0:t.key.localeCompare(e.key))),t}class I extends w{constructor({name:t,parent:e,onAddItem:n}){super(),this.children=[],this.name=t,this.parent=e,this.addItemHandler=n,this.path=y.join(this.parent.path,this.name)}removeChildNode(t){this.children=this.children.filter((e=>e!==t))}serialize(t,e,n){const s=this.children.map((s=>s.serialize(t,e,n)));return{type:"Dir",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:E(s)}}}class R extends w{constructor({name:t,parent:e}){super(),this.name=t,this.parent=e,this.path=y.join(this.parent.path,this.name)}serialize(){return{type:"File",key:this.path,title:this.name,isLeaf:!0}}}class k extends w{constructor({parent:t,forNode:e,onConfirm:n,onBlur:s}){super(),this.name="name-prompt",this.parent=t,this.forNode=e,this.path=y.join(t.path,this.name),this.onConfirm=n,this.onBlur=s}serialize(t,e,n){return{type:"Prompt",key:this.path,title:e({onConfirm:t=>{var e;return null===(e=this.onConfirm)||void 0===e?void 0:e.call(this,this,t)},onBlur:()=>{var t;return null===(t=this.onBlur)||void 0===t?void 0:t.call(this,this)}}),isLeaf:!0,selectable:!1,icon:n({type:this.forNode})}}}class _ extends w{constructor({onAddItem:t}){super(),this.name="/",this.path="/",this.parent=void 0,this.children=[],this.addItemHandler=t}serialize(t,e,n){const s=this.children.map((s=>s.serialize(t,e,n)));return{type:"Root",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:E(s)}}}class F extends w{constructor({parent:t}){super(),this.name="empty-node",this.parent=t,this.path=y.join(this.parent.path,this.name)}serialize(){return{type:"Empty",key:this.path,title:"Empty Directory",isLeaf:!0,disabled:!0}}}class x{constructor(){this.logger=new e("Filesystem"),this.root=new _({onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}),this.startingPrintIndent=0,this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}removeAllListeners(){this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}addListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs.push(e);break;case"onDirsChange":this.onDirsChangeLs.push(e);break;case"onFileContent":this.onFileContentLs.push(e);break;case"onShowPrompt":this.onShowPromptLs.push(e);break;default:throw new Error(`Unknown event type: ${t}`)}}removeListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs=this.onNewItemConfirmLs.filter((t=>t!==e));break;case"onDirsChange":this.onDirsChangeLs=this.onDirsChangeLs.filter((t=>t!==e));break;case"onFileContent":this.onFileContentLs=this.onFileContentLs.filter((t=>t!==e));break;case"onShowPrompt":this.onShowPromptLs=this.onShowPromptLs.filter((t=>t!==e));break;default:throw new Error(`Unknown event type: ${t}`)}}addNodeToDir(t,e){this.logger.log("Adding node to dir",{dirPath:t,node:e});let n=this.find(t);if(n||(this.logger.log("Dir not found, will make all",{dirPath:t}),n=this.mkAll(t)),!n)throw new Error("dirNode is undefined");if(!(n instanceof _||n instanceof I))throw new Error(`Node at '${t}' is not a directory or a root node`);if(n.children.some((t=>t.name===e.name)))return;let s;s="Dir"===e.type?new I({name:e.name,parent:n,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new R({name:e.name,parent:n}),1===n.children.length&&n.children[0]instanceof F?n.children=[s]:n.children.push(s),this.notifyOnDirsChangeLs({dirPaths:[t]})}removeNodeFromDir(t,e){this.logger.log("Remove node from dir",{dirPath:t,nodeName:e.name});const n=this.find(t);if(!n)throw new Error(`No node with path '${t}'`);if(!(n instanceof _||n instanceof I))throw new Error(`Node at '${t}' is not a directory or root node`);const s=n.children.length;n.children=n.children.filter((t=>t.name!==e.name));s!==n.children.length?(0===n.children.length&&(n.children=[new F({parent:n})]),this.notifyOnDirsChangeLs({dirPaths:[t]})):this.logger.warn("Node not found in dir",{dirPath:t,nodeName:e.name})}setFileContent(t){this.logger.log("Update file content",t),this.onFileContentLs.forEach((e=>e(t)))}setDirsContent(t){this.logger.log("Set dirs content",t);for(const e of t){let t=this.find(e.dirPath);if(t||(this.logger.log("Dir not found, will make all",{dirPath:e.dirPath}),t=this.mkAll(e.dirPath)),!t)throw new Error("dirNode is undefined");if(!(t instanceof _||t instanceof I))throw new Error(`Node at '${e.dirPath}' is not a directory or a root node`);const n=t.children.find((t=>t instanceof k));if(e.content.length){const n=[];for(const s of e.content){let e;e="Dir"===s.type?new I({name:s.name,parent:t,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new R({name:s.name,parent:t}),n.push(e)}t.children=n}else t.children=[new F({parent:t})];n&&t.children.push(n)}this.notifyOnDirsChangeLs({dirPaths:t.map((t=>t.dirPath))})}showPrompt(t){const{event:e,parent:n,type:s}=t;if(this.logger.log("Show prompt",{parent:n,type:s}),n.children.some((t=>t instanceof k)))return;e.preventDefault();const i=new k({parent:n,forNode:s,onConfirm:((t,e)=>{if(this.logger.log("Prompt confirm",{prompt:t,name:e}),!e)return;const n=t.parent.path,i=y.join(t.parent.path,e);this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[n]}),this.notifyOnNewItemConfirmLs({fullPath:i,name:e,type:s})}).bind(this),onBlur:(t=>{this.logger.log("Prompt blur",{prompt:t});const e=t.parent.path;this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[e]})}).bind(this)});n.children.push(i),this.notifyOnDirsChangeLs({dirPaths:[i.parent.path]}),this.notifyOnShowPromptLs({dirPath:i.parent.path})}serialize(t,e,n){return this.logger.log("Serialize"),[this.root.serialize(t,e,n)]}print(t=this.root,e=this.startingPrintIndent){const n="  ".repeat(e);console.log(n+t.path,`(${t.name})`);for(const s of t.children)s instanceof I?this.print(s,e+1):console.log(n+"  "+s.path,`(${s.name})`)}find(t,e=this.root){if(this.logger.log("Find (recursion)",{currentPath:e.path,targetPath:t}),t=y.normalize(t),e.path===t)return e;const n=t.split(y.sep).length-1;if(!(e.level>n)&&(e instanceof _||e instanceof I))for(const n of e.children){const e=this.find(t,n);if(e)return e}}mkDir(t){this.logger.log("Make dir",t);const e=this.find(t.parentPath);if(!e)throw new Error(`Parent dir '${t.parentPath}' not found`);if(!(e instanceof _||e instanceof I))throw new Error("Parent is not a dir or root");const n=new I({parent:e,name:t.name,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})});return e.children.push(n),n}mkAll(t){this.logger.log("Make all",t);const e=t.split(y.sep);let n,s="/";for(const t of e)if(s=y.join(s,t),!this.find(s)){const e=y.dirname(s);n=this.mkDir({parentPath:e,name:t})}return n}removeFromParent(t){const{parent:e}=t;(e instanceof _||e instanceof I)&&(e.children=e.children.filter((e=>e!==t))),t.parent=void 0}notifyOnShowPromptLs(t){this.logger.log("Notify on show prompt",t),this.onShowPromptLs.forEach((e=>e(t)))}notifyOnNewItemConfirmLs(t){this.logger.log("Notify on new item confirm",t),this.onNewItemConfirmLs.forEach((e=>e(t)))}notifyOnDirsChangeLs(t){this.logger.log("Notify on dirs change",t),this.onDirsChangeLs.forEach((e=>e(t)))}}function P(t){return function(t){const e=Array.from(t).reduce(((t,e)=>0|31*t+e.charCodeAt(0)),0);return("0000000"+(e>>>0).toString(16)).slice(-8)}(t)}!function(t){t[t.Stdout=0]="Stdout",t[t.Stderr=1]="Stderr"}(S||(S={}));class L{constructor(t,e){this.contextID=t,this.templateID=e,this.output=[],this.filesystem=new x,this.isReady=!1,this.id=`${t}_${P(e)}`}restart(){this.output=[],this.isReady=!1,this.filesystem.setDirsContent([{dirPath:"/",content:[]}])}logOutput(t,e){this.output=[...this.output,{message:t,source:e}]}}function O(t,{environmentID:e,templateID:n}){const s={type:a.RunningEnvironment.Start,payload:{environmentID:e,templateID:n}};t.send(s)}class N{constructor(t){var n,s;this.opts=t,this.fsWriteSubscribers=[],this.fileContentSubscribers=[],this.logger=new e(`EvaluationContext [${t.templateID}]`,t.debug),this.env=new L(this.contextID,t.templateID);this.unsubscribeConnHandler=this.opts.conn.subscribeHandler({onOpen:t=>this.handleConnectionOpen(t),onMessage:t=>this.handleConnectionMessage(t),onClose:()=>this.handleConnectionClose()}),this.opts.conn.isOpen&&this.opts.conn.sessionID&&this.handleConnectionOpen(this.opts.conn.sessionID),this.opts.conn.isClosed&&this.handleConnectionClose(),O(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID}),null===(s=(n=this.opts).onEnvChange)||void 0===s||s.call(n,this.env)}get contextID(){return this.opts.contextID}restart(){this.logger.log("Restart",this.opts.conn.sessionID),this.env.restart(),O(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID})}destroy(){this.logger.log("Destroy"),this.unsubscribeConnHandler(),this.fsWriteSubscribers=[],this.fileContentSubscribers=[]}getFile({path:t}){return n(this,void 0,void 0,(function*(){let e;this.logger.log("Get file",{filepath:t});const n=new Promise(((t,n)=>{e=t,setTimeout((()=>{n("Timeout")}),1e4)})),s=n=>{n.path.endsWith(t)&&e(n.content)};this.subscribeFileContent(s),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.GetFile,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t});try{return yield n}catch(e){throw new Error(`Error retrieving file ${t}: ${e}`)}finally{this.unsubscribeFileContent(s)}}))}deleteFile({path:t}){this.logger.log("Delete file",{filepath:t}),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.RemoveFile,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t})}updateFile({path:t,content:e}){return n(this,void 0,void 0,(function*(){let n;this.logger.log("Update file",{filepath:t});const s=new Promise(((t,e)=>{n=t,setTimeout((()=>{e("Timeout")}),1e4)})),i=e=>{e.path.endsWith(t)&&n()};this.subscribeFSWrite(i),function(t,{environmentID:e,path:n,content:s}){const i={type:a.RunningEnvironment.WriteFile,payload:{environmentID:e,path:n,content:s}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t,content:e});try{yield s}catch(e){throw new Error(`File ${t} not written to VM: ${e}`)}finally{this.unsubscribeFSWrite(i)}}))}createDir({path:t}){this.logger.log("Create dir",{filepath:t}),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.CreateDir,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t})}listDir({path:t}){this.logger.log("List dir",{filepath:t}),function(t,{environmentID:e,path:n}){const s={type:a.RunningEnvironment.ListDir,payload:{environmentID:e,path:n}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t})}executeCommand({executionID:t,command:e}){this.logger.log("Execute shell command",{executionID:t,command:e}),function(t,{environmentID:e,executionID:n,command:s}){const i={type:a.RunningEnvironment.ExecCmd,payload:{environmentID:e,executionID:n,command:s}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,executionID:t,command:e})}subscribeFileContent(t){this.fileContentSubscribers.push(t)}unsubscribeFileContent(t){const e=this.fileContentSubscribers.indexOf(t);e>-1&&this.fileContentSubscribers.splice(e,1)}subscribeFSWrite(t){this.fsWriteSubscribers.push(t)}unsubscribeFSWrite(t){const e=this.fsWriteSubscribers.indexOf(t);e>-1&&this.fsWriteSubscribers.splice(e,1)}handleConnectionOpen(t){var e,n;this.restart(),null===(n=(e=this.opts).onSessionChange)||void 0===n||n.call(e,{status:c.Connecting})}handleConnectionClose(){var t,e;null===(e=(t=this.opts).onSessionChange)||void 0===e||e.call(t,{status:c.Connecting})}handleConnectionMessage(t){switch(this.logger.log("Handling message from remote Runner",{message:t}),t.type){case a.RunningEnvironment.StartAck:{const e=t;this.vmenv_handleStartAck(e.payload);break}case a.RunningEnvironment.CmdOut:{const e=t;this.vmenv_handleCmdOut(e.payload);break}case a.RunningEnvironment.CmdExit:{const e=t;this.vmenv_handleCmdExit(e.payload);break}case a.RunningEnvironment.FSEventWrite:{const e=t;this.vmenv_handleFSEventWrite(e.payload);break}case a.RunningEnvironment.FileContent:{const e=t;this.vmenv_handleFileContent(e.payload);break}case a.RunningEnvironment.FSEventCreate:{const e=t;this.vmenv_handleFSEventCreate(e.payload);break}case a.RunningEnvironment.FSEventRemove:{const e=t;this.vmenv_handleFSEventRemove(e.payload);break}case a.RunningEnvironment.DirContent:{const e=t;this.vmenv_handleDirContent(e.payload);break}case a.RunningEnvironment.Stderr:{const e=t;this.vmenv_handleStderr(e.payload);break}case a.RunningEnvironment.Stdout:{const e=t;this.vmenv_handleStdout(e.payload);break}default:this.logger.warn("Unknown message type",{message:t})}}vmenv_handleFSEventCreate(t){this.logger.log('[vmenv] Handling "FSEventCreate"',t);const e=y.basename(t.path),n=y.dirname(t.path),s="Directory"===t.type?"Dir":"File";this.env.filesystem.addNodeToDir(n,{name:e,type:s})}vmenv_handleFSEventRemove(t){this.logger.log('[vmenv] Handling "FSEventRemove"',{payload:t});const e=y.basename(t.path),n=y.dirname(t.path);this.env.filesystem.removeNodeFromDir(n,{name:e})}vmenv_handleDirContent(t){this.logger.log('[vmenv] Handling "DirContent"',t);const e=[];for(const n of t.content){const t=y.basename(n.path),s="Directory"===n.type?"Dir":"File";e.push({name:t,type:s})}this.env.filesystem.setDirsContent([{dirPath:t.dirPath,content:e}])}vmenv_handleCmdExit(t){var e,n;this.logger.log('[vmenv] Handling "CmdExit"',t),void 0!==t.error&&(null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,{environmentID:t.environmentID,executionID:t.executionID,stderr:t.error}))}vmenv_handleFSEventWrite(t){this.logger.log('[vmenv] Handling "FSEventWrite"',t),this.fsWriteSubscribers.forEach((e=>e(t)))}vmenv_handleFileContent(t){this.logger.log('[vmenv] Handling "FileContent"',{environmentID:t.environmentID,path:t.path}),this.fileContentSubscribers.forEach((e=>e(t)))}vmenv_handleStartAck(t){var e,n,s,i;this.logger.log('[vmenv] Handling "StartAck"',{payload:t}),this.env.isReady=!0,null===(n=(e=this.opts).onEnvChange)||void 0===n||n.call(e,this.env),null===(i=(s=this.opts).onSessionChange)||void 0===i||i.call(s,{status:c.Connected,sessionID:this.opts.conn.sessionID})}vmenv_handleCmdOut(t){var e,n;this.logger.log('[vmenv] Handling "CmdOut"',t),null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,t)}vmenv_handleStderr(t){this.logger.log('[vmenv] Handling "Stderr"',t),this.env.logOutput(t.message,S.Stderr)}vmenv_handleStdout(t){this.logger.log('[vmenv] Handling "Stdout"',t),this.env.logOutput(t.message,S.Stdout)}}class A{constructor(){this.logger=new e("Runner"),this.conn=new h,this.sessManager=new u(this.conn)}static get obj(){return A._obj||(A._obj=new A)}get session(){return this.sessManager.session}get status(){return this.sessManager.status}reset(){this.logger.log("Reset"),this.sessManager.reset()}createContext(t){return new N(Object.assign(Object.assign({},t),{conn:this.conn}))}__internal__start(){this.sessManager.start()}__internal__stop(){this.sessManager.stop()}__debug__loadNewSession(){this.logger.log("__debug__loadNewSession"),this.sessManager.reset()}}const $=(M="1234567890abcdefghijklmnopqrstuvwxyz",j=6,()=>{let t="",e=j;for(;e--;)t+=M[Math.random()*M.length|0];return t});var M,j,W;exports.DevbookStatus=void 0,(W=exports.DevbookStatus||(exports.DevbookStatus={})).Disconnected="Disconnected",W.Connecting="Connecting",W.Connected="Connected";class H{constructor(t){this.opts=t,this.contextID="default",this.executionID=$(),this._isDestroyed=!1,this._isEnvReady=!1,this._sessionStatus=c.Disconnected,this._status=exports.DevbookStatus.Disconnected;const e=this.getURL.bind(this),n=()=>this.opts.env,s=()=>this.executionID,i=t=>this.isEnvReady=t,o=t=>this.sessionStatus=t,r=t=>this.sessionID=t;this.context=A.obj.createContext({debug:t.debug,templateID:t.env,contextID:this.contextID,onEnvChange(s){var o;s.templateID===n()&&(i(s.isReady),null===(o=t.onURLChange)||void 0===o||o.call(t,e))},onSessionChange({status:n,sessionID:s}){var i;r(s),o(n),null===(i=t.onURLChange)||void 0===i||i.call(t,e)},onCmdOut(e){var n,i;e.executionID===s()&&(void 0!==e.stdout&&(null===(n=t.onStdout)||void 0===n||n.call(t,e.stdout)),void 0!==e.stderr&&(null===(i=t.onStderr)||void 0===i||i.call(t,e.stderr)))}})}get sessionID(){return this._sessionID}set sessionID(t){this._sessionID=t}get isDestroyed(){return this._isDestroyed}set isDestroyed(t){this._isDestroyed=t,this.updateStatus()}get isEnvReady(){return this._isEnvReady}set isEnvReady(t){this._isEnvReady=t,this.updateStatus()}get sessionStatus(){return this._sessionStatus}set sessionStatus(t){this._sessionStatus=t,this.updateStatus()}get status(){return this._status}set status(t){var e,n;this._status=t,null===(n=(e=this.opts).onStatusChange)||void 0===n||n.call(e,t)}get env(){return this.context.env}get fs(){const t=this.env.filesystem;return{delete:this.deleteFile.bind(this),listDir:this.listDir.bind(this),createDir:this.createDir.bind(this),get:this.getFile.bind(this),write:this.writeFile.bind(this),addListener:t.addListener.bind(t),removeListener:t.removeListener.bind(t),serialize:t.serialize.bind(t)}}getURL(t){if(this.status===exports.DevbookStatus.Connected&&this.sessionID&&this.env.isReady)return`https://${t}-${this.env.id}-${this.sessionID}.o.usedevbook.com`}runCmd(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");this.executionID=$(),this.context.executeCommand({executionID:this.executionID,command:t})}destroy(){this.context.destroy(),this.isDestroyed=!0}__internal__start(){A.obj.__internal__start()}__internal__stop(){A.obj.__internal__stop()}listDir(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.listDir({path:t})}createDir(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.createDir({path:t})}deleteFile(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.deleteFile({path:t})}getFile(t){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.getFile({path:t})}writeFile(t,e){if(this.status!==exports.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.updateFile({path:t,content:e})}updateStatus(){if(this.isDestroyed)return void(this.status!==exports.DevbookStatus.Disconnected&&(this.status=exports.DevbookStatus.Disconnected));let t;switch(this.sessionStatus){case c.Disconnected:t=exports.DevbookStatus.Disconnected;break;case c.Connecting:t=exports.DevbookStatus.Connecting;break;case c.Connected:if(!this.isEnvReady){t=exports.DevbookStatus.Connecting;break}t=exports.DevbookStatus.Connected}this.status=t}}exports.Devbook=H,exports.useDevbook=function({env:e,debug:n,port:s}){const[i,o]=t.useState(),[r,a]=t.useState(exports.DevbookStatus.Disconnected),[h,l]=t.useState([]),[c,d]=t.useState([]),[u,g]=t.useState(),p=t.useCallback((t=>{i&&(d([]),l([]),i.runCmd(t))}),[i]);return t.useEffect((function(){const t=new H({debug:n,env:e,onStatusChange(t){a(t)},onStderr(t){l((e=>[...e,t]))},onStdout(t){d((e=>[...e,t]))},onURLChange(t){s&&g(t(s))}});return d([]),l([]),g(void 0),o(t),()=>{t.destroy()}}),[e,n,s]),{stderr:h,stdout:c,runCmd:p,status:r,fs:null==i?void 0:i.fs,url:u}};
 //# sourceMappingURL=index.js.map

lib/esm/core/constants/runner.d.ts

 export declare const REMOTE_RUNNER_HOSTNAME = "orchestrator.usedevbook.com";
 export declare const STORAGE_SESSION_ID_KEY = "dbk_sdk_session_id";
 export declare const SESSION_PING_PERIOD = 5000;
-export declare const SESSION_RESTART_PERIOD = 3000;
-export declare const WSCONN_RESTART_PERIOD = 3000;
+export declare const SESSION_RESTART_PERIOD = 2500;
+export declare const WSCONN_RESTART_PERIOD = 2500;

lib/esm/core/devbook.d.ts

@@ -139,2 +139,6 @@ import { Filesystem } from './runningEnvironment/filesystem';
     destroy(): void;
+    /** @internal */
+    __internal__start(): void;
+    /** @internal */
+    __internal__stop(): void;
     private listDir;
@@ -141,0 +145,0 @@ private createDir;

lib/esm/core/runner.d.ts

@@ -15,4 +15,8 @@ import EvaluationContext, { EvaluationContextOpts } from './evaluationContext';
     createContext(opts: Omit<EvaluationContextOpts, 'conn'>): EvaluationContext;
+    /** @internal */
+    __internal__start(): void;
+    /** @internal */
+    __internal__stop(): void;
     __debug__loadNewSession(): void;
 }
 export default Runner;

lib/esm/core/session/sessionManager.d.ts

@@ -12,2 +12,4 @@ import { WebSocketConnection } from '../webSocketConnection';
     private readonly url;
+    private userActivity;
+    private startActivity?;
     private isGettingSessionActive;
@@ -19,2 +21,4 @@ private get cachedSessionID();
     constructor(conn: WebSocketConnection);
+    stop(): void;
+    start(): void;
     reset(): void;
@@ -21,0 +25,0 @@ /**

lib/esm/index.js

@@ -1,2 +0,2 @@
-import{useState as e,useCallback as t,useEffect as n}from"react";class i{constructor(e,t=!1){this.logID=e,this.isEnabled=t}id(){return"function"==typeof this.logID?this.logID():this.logID}log(...e){this.isEnabled&&console.log(`[${this.id()}]`,...e)}warn(...e){this.isEnabled&&console.warn(`[${this.id()}]`,...e)}error(...e){console.error(`[${this.id()} ERROR]`,...e)}}
+import{useState as t,useCallback as e,useEffect as n}from"react";class i{constructor(t,e=!1){this.logID=t,this.isEnabled=e}id(){return"function"==typeof this.logID?this.logID():this.logID}log(...t){this.isEnabled&&console.log(`[${this.id()}]`,...t)}warn(...t){this.isEnabled&&console.warn(`[${this.id()}]`,...t)}error(...t){console.error(`[${this.id()} ERROR]`,...t)}}
 /*! *****************************************************************************
@@ -15,3 +15,3 @@ Copyright (c) Microsoft Corporation.
 PERFORMANCE OF THIS SOFTWARE.
-***************************************************************************** */function s(e,t,n,i){return new(n||(n=Promise))((function(s,o){function r(e){try{a(i.next(e))}catch(e){o(e)}}function h(e){try{a(i.throw(e))}catch(e){o(e)}}function a(e){var t;e.done?s(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(r,h)}a((i=i.apply(e,t||[])).next())}))}function o(e){return new Promise((t=>setTimeout(t,e)))}var r,h,a;!function(e){e.Error="Runner.Error"}(r||(r={})),function(e){e.Start="RunningEnvironment.Start",e.StartAck="RunningEnvironment.StartAck",e.Eval="RunningEnvironment.Eval",e.FSEventCreate="RunningEnvironment.FSEventCreate",e.FSEventRemove="RunningEnvironment.FSEventRemove",e.FSEventWrite="RunningEnvironment.FSEventWrite",e.CreateDir="RunningEnvironment.CreateDir",e.ListDir="RunningEnvironment.ListDir",e.WriteFile="RunningEnvironment.WriteFile",e.GetFile="RunningEnvironment.GetFile",e.RemoveFile="RunningEnvironment.RemoveFile",e.DirContent="RunningEnvironment.DirContent",e.FileContent="RunningEnvironment.FileContent",e.Stdout="RunningEnvironment.Stdout",e.Stderr="RunningEnvironment.Stderr",e.ExecCmd="RunningEnvironment.ExecCmd",e.KillCmd="RunningEnvironment.KillCmd",e.ListRunningCmds="RunningEnvironment.ListRunningCmds",e.CmdOut="RunningEnvironment.CmdOut",e.CmdExit="RunningEnvironment.CmdExit",e.RunningCmds="RunningEnvironment.RunningCmds",e.RunCode="RunningEnvironment.Run"}(h||(h={})),function(e){e.Error="CodeCell.Error"}(a||(a={}));const l={Runner:r,RunningEnvironment:h,CodeCell:a};class d{constructor(){this.url="wss://orchestrator.usedevbook.com",this.logger=new i("WebSocketConnection"),this.handlers=[]}get state(){var e;return null===(e=this.client)||void 0===e?void 0:e.readyState}get isClosed(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSED}get isClosing(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSING}get isOpen(){if(void 0!==this.client)return this.client.readyState===this.client.OPEN}get isConnecting(){if(void 0!==this.client)return this.client.readyState===this.client.CONNECTING}subscribeHandler(e){return this.handlers.push(e),()=>{this.handlers=this.handlers.filter((t=>t!==e))}}connect(e){(!this.client||this.client.readyState!==this.client.CONNECTING&&this.client.readyState!==this.client.OPEN)&&(e||this.sessionID?(e?(this.logger.log(`Will try to connect to session "${e}"`),this.sessionID=e):!e&&this.sessionID&&this.logger.log(`Will try to connect to previous session "${this.sessionID}"`),this.client=new WebSocket(`${this.url}/session/ws/${this.sessionID}`),this.client.onopen=()=>this.handleOpen(this.sessionID),this.client.onmessage=e=>{this.logger.log("Received (raw)",{msg:e}),this.handleMessage(e)},this.client.onerror=e=>this.handleError(e),this.client.onclose=e=>this.handleClose(e)):this.logger.error("Cannot connect, no session ID passed to the function and no session ID saved from the previous session"))}send(e){this.client&&this.client.readyState===this.client.OPEN?(this.logger.log("Send",e),this._send(e)):this.logger.warn("Trying to send a message while not being in the `OPEN` state or without established connection, message will be discarded",e)}close(){var e;this.logger.log("Closing connection"),null===(e=this.client)||void 0===e||e.close(1e3)}handleOpen(e){var t;this.logger.log("Connection opened",{readyState:null===(t=this.client)||void 0===t?void 0:t.readyState}),this.handlers.forEach((t=>t.onOpen(e)))}_send(e){var t,n;null===(t=this.client)||void 0===t||t.send((n=e,JSON.stringify(n,(()=>{const e=new WeakSet;return(t,n)=>{if("object"==typeof n&&null!==n){if(e.has(n))return;e.add(n)}return n}})(),2)))}handleClose(e){return s(this,void 0,void 0,(function*(){this.logger.log("Connection closed",e),this.handlers.forEach((e=>e.onClose())),this.logger.log("Will try to reconnect in 3s"),yield o(3e3),this.connect()}))}handleError(e){var t;this.logger.error("Connection error",e),null===(t=this.client)||void 0===t||t.close()}handleMessage(e){if(!e.data)return void this.logger.error("Message has empty data field",e);const t=JSON.parse(e.data);if(!t.type)return void this.logger.error("Message has no type",t);const n=t;Object.values(l.RunningEnvironment).includes(n.type)||Object.values(l.Runner).includes(n.type)||Object.values(l.CodeCell).includes(n.type)?n.type!==l.Runner.Error?(this.logger.log("Received (parsed)",n),this.handlers.forEach((e=>e.onMessage(n)))):this.logger.error("Runner error",n):this.logger.error('Message "type" field has unexpected value',n)}}var c,u;!function(e){e.Ok="Ok",e.Terminated="Terminated"}(c||(c={}));class g{constructor(e,t=new Date){this.id=e,this.lastPing=t,this.logger=new i("RunnerSession"),this.url="https://orchestrator.usedevbook.com"}ping(){return s(this,void 0,void 0,(function*(){this.logger.log(`Pinging session "${this.id}"`);const e=JSON.stringify({sessionID:this.id});try{const t=yield fetch(`${this.url}/session/ping`,{method:"POST",headers:{"Content-Type":"application/json"},body:e}),n=yield t.json();if(!t.ok)throw this.logger.error(t.headers,n),new Error("Non-OK response when trying to ping active Runner session");if(n.status===c.Terminated)throw new Error(`[keepAlive]: Session '${this.id}' is terminated`);this.lastPing=new Date}catch(e){throw this.logger.error(e),new Error("Failed to ping active Runner session")}}))}}!function(e){e.Connected="Connected",e.Connecting="Connecting",e.Disconnected="Disconnected"}(u||(u={}));class m{constructor(e){this.conn=e,this.logger=new i("SessionManager"),this.url="https://orchestrator.usedevbook.com",this.isGettingSessionActive=!1,this.status=u.Disconnected,this.logger.log("Initialize"),this.getSession()}get cachedSessionID(){return sessionStorage.getItem("dbk_sdk_session_id")}set cachedSessionID(e){null===e?(this.logger.log("Cleared last sessionID"),sessionStorage.removeItem("dbk_sdk_session_id")):(this.logger.log(`Saved sessionID "${e}" as last sessionID`),sessionStorage.setItem("dbk_sdk_session_id",e))}reset(){this.logger.log("Reset"),this.status=u.Disconnected,this.cachedSessionID=null,this.conn.close(),this.session=void 0}getSession(){var e;return s(this,void 0,void 0,(function*(){if(!this.isGettingSessionActive)for(this.isGettingSessionActive=!0;;){this.status=u.Connecting;try{const t=this.cachedSessionID?`${this.url}/session/${this.cachedSessionID}`:`${this.url}/session`;this.cachedSessionID?this.logger.log(`Restoring old Runner session "${this.cachedSessionID}"`):this.logger.log("Acquiring new Runner session");const n=yield fetch(t),i=yield n.json();if(!n.ok){this.logger.error("Non-OK response when trying to ping active Runner session. Will try again in 3s",n.headers,i),yield o(3e3);continue}for(this.session=new g(i.sessionID),this.logger.log(`Acquired session "${this.session.id}"`),this.cachedSessionID=this.session.id,this.status=u.Connected,this.conn.connect(this.session.id),this.logger.log(`Started pinging session "${this.session.id}"`);this.session;)try{yield this.session.ping(),yield o(5e3)}catch(e){this.logger.error(`Failed to ping session "${this.session.id}"`,e);break}this.logger.log(`Stopped pinging session "${null===(e=this.session)||void 0===e?void 0:e.id}"`),this.session=void 0,this.status=u.Disconnected,this.conn.close()}catch(e){this.logger.error("Failed to acquire Runner session. Will try again in 3s",e),yield o(3e3)}}}))}}function p(e,t){for(var n=0,i=e.length-1;i>=0;i--){var s=e[i];"."===s?e.splice(i,1):".."===s?(e.splice(i,1),n++):n&&(e.splice(i,1),n--)}if(t)for(;n--;n)e.unshift("..");return e}var v=/^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/,f=function(e){return v.exec(e).slice(1)};function y(){for(var e="",t=!1,n=arguments.length-1;n>=-1&&!t;n--){var i=n>=0?arguments[n]:"/";if("string"!=typeof i)throw new TypeError("Arguments to path.resolve must be strings");i&&(e=i+"/"+e,t="/"===i.charAt(0))}return(t?"/":"")+(e=p(S(e.split("/"),(function(e){return!!e})),!t).join("/"))||"."}function D(e){var t=C(e),n="/"===E(e,-1);return(e=p(S(e.split("/"),(function(e){return!!e})),!t).join("/"))||t||(e="."),e&&n&&(e+="/"),(t?"/":"")+e}function C(e){return"/"===e.charAt(0)}var w={extname:function(e){return f(e)[3]},basename:function(e,t){var n=f(e)[2];return t&&n.substr(-1*t.length)===t&&(n=n.substr(0,n.length-t.length)),n},dirname:function(e){var t=f(e),n=t[0],i=t[1];return n||i?(i&&(i=i.substr(0,i.length-1)),n+i):"."},sep:"/",delimiter:":",relative:function(e,t){function n(e){for(var t=0;t<e.length&&""===e[t];t++);for(var n=e.length-1;n>=0&&""===e[n];n--);return t>n?[]:e.slice(t,n-t+1)}e=y(e).substr(1),t=y(t).substr(1);for(var i=n(e.split("/")),s=n(t.split("/")),o=Math.min(i.length,s.length),r=o,h=0;h<o;h++)if(i[h]!==s[h]){r=h;break}var a=[];for(h=r;h<i.length;h++)a.push("..");return(a=a.concat(s.slice(r))).join("/")},join:function(){var e=Array.prototype.slice.call(arguments,0);return D(S(e,(function(e,t){if("string"!=typeof e)throw new TypeError("Arguments to path.join must be strings");return e})).join("/"))},isAbsolute:C,normalize:D,resolve:y};function S(e,t){if(e.filter)return e.filter(t);for(var n=[],i=0;i<e.length;i++)t(e[i],i,e)&&n.push(e[i]);return n}var b,E="b"==="ab".substr(-1)?function(e,t,n){return e.substr(t,n)}:function(e,t,n){return t<0&&(t=e.length+t),e.substr(t,n)};class I{get level(){return w.normalize(this.path).split(w.sep).length-1}}function R(e){return e.sort(((e,t)=>"Prompt"===e.type?-2:e.type!==t.type?"Dir"===e.type?-1:"Dir"===t.type?1:0:e.key.localeCompare(t.key))),e}class F extends I{constructor({name:e,parent:t,onAddItem:n}){super(),this.children=[],this.name=e,this.parent=t,this.addItemHandler=n,this.path=w.join(this.parent.path,this.name)}removeChildNode(e){this.children=this.children.filter((t=>t!==e))}serialize(e,t,n){const i=this.children.map((i=>i.serialize(e,t,n)));return{type:"Dir",key:this.path,title:e({name:this.name,onAddFileMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"File"})},onAddDirMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"Dir"})}}),children:R(i)}}}class k extends I{constructor({name:e,parent:t}){super(),this.name=e,this.parent=t,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"File",key:this.path,title:this.name,isLeaf:!0}}}class P extends I{constructor({parent:e,forNode:t,onConfirm:n,onBlur:i}){super(),this.name="name-prompt",this.parent=e,this.forNode=t,this.path=w.join(e.path,this.name),this.onConfirm=n,this.onBlur=i}serialize(e,t,n){return{type:"Prompt",key:this.path,title:t({onConfirm:e=>{var t;return null===(t=this.onConfirm)||void 0===t?void 0:t.call(this,this,e)},onBlur:()=>{var e;return null===(e=this.onBlur)||void 0===e?void 0:e.call(this,this)}}),isLeaf:!0,selectable:!1,icon:n({type:this.forNode})}}}class x extends I{constructor({onAddItem:e}){super(),this.name="/",this.path="/",this.parent=void 0,this.children=[],this.addItemHandler=e}serialize(e,t,n){const i=this.children.map((i=>i.serialize(e,t,n)));return{type:"Root",key:this.path,title:e({name:this.name,onAddFileMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"File"})},onAddDirMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"Dir"})}}),children:R(i)}}}class L extends I{constructor({parent:e}){super(),this.name="empty-node",this.parent=e,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"Empty",key:this.path,title:"Empty Directory",isLeaf:!0,disabled:!0}}}class O{constructor(){this.logger=new i("Filesystem"),this.root=new x({onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})}),this.startingPrintIndent=0,this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}removeAllListeners(){this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}addListener(e,t){switch(e){case"onNewItemConfirm":this.onNewItemConfirmLs.push(t);break;case"onDirsChange":this.onDirsChangeLs.push(t);break;case"onFileContent":this.onFileContentLs.push(t);break;case"onShowPrompt":this.onShowPromptLs.push(t);break;default:throw new Error(`Unknown event type: ${e}`)}}removeListener(e,t){switch(e){case"onNewItemConfirm":this.onNewItemConfirmLs=this.onNewItemConfirmLs.filter((e=>e!==t));break;case"onDirsChange":this.onDirsChangeLs=this.onDirsChangeLs.filter((e=>e!==t));break;case"onFileContent":this.onFileContentLs=this.onFileContentLs.filter((e=>e!==t));break;case"onShowPrompt":this.onShowPromptLs=this.onShowPromptLs.filter((e=>e!==t));break;default:throw new Error(`Unknown event type: ${e}`)}}addNodeToDir(e,t){this.logger.log("Adding node to dir",{dirPath:e,node:t});let n=this.find(e);if(n||(this.logger.log("Dir not found, will make all",{dirPath:e}),n=this.mkAll(e)),!n)throw new Error("dirNode is undefined");if(!(n instanceof x||n instanceof F))throw new Error(`Node at '${e}' is not a directory or a root node`);if(n.children.some((e=>e.name===t.name)))return;let i;i="Dir"===t.type?new F({name:t.name,parent:n,onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})}):new k({name:t.name,parent:n}),1===n.children.length&&n.children[0]instanceof L?n.children=[i]:n.children.push(i),this.notifyOnDirsChangeLs({dirPaths:[e]})}removeNodeFromDir(e,t){this.logger.log("Remove node from dir",{dirPath:e,nodeName:t.name});const n=this.find(e);if(!n)throw new Error(`No node with path '${e}'`);if(!(n instanceof x||n instanceof F))throw new Error(`Node at '${e}' is not a directory or root node`);const i=n.children.length;n.children=n.children.filter((e=>e.name!==t.name));i!==n.children.length?(0===n.children.length&&(n.children=[new L({parent:n})]),this.notifyOnDirsChangeLs({dirPaths:[e]})):this.logger.warn("Node not found in dir",{dirPath:e,nodeName:t.name})}setFileContent(e){this.logger.log("Update file content",e),this.onFileContentLs.forEach((t=>t(e)))}setDirsContent(e){this.logger.log("Set dirs content",e);for(const t of e){let e=this.find(t.dirPath);if(e||(this.logger.log("Dir not found, will make all",{dirPath:t.dirPath}),e=this.mkAll(t.dirPath)),!e)throw new Error("dirNode is undefined");if(!(e instanceof x||e instanceof F))throw new Error(`Node at '${t.dirPath}' is not a directory or a root node`);const n=e.children.find((e=>e instanceof P));if(t.content.length){const n=[];for(const i of t.content){let t;t="Dir"===i.type?new F({name:i.name,parent:e,onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})}):new k({name:i.name,parent:e}),n.push(t)}e.children=n}else e.children=[new L({parent:e})];n&&e.children.push(n)}this.notifyOnDirsChangeLs({dirPaths:e.map((e=>e.dirPath))})}showPrompt(e){const{event:t,parent:n,type:i}=e;if(this.logger.log("Show prompt",{parent:n,type:i}),n.children.some((e=>e instanceof P)))return;t.preventDefault();const s=new P({parent:n,forNode:i,onConfirm:((e,t)=>{if(this.logger.log("Prompt confirm",{prompt:e,name:t}),!t)return;const n=e.parent.path,s=w.join(e.parent.path,t);this.removeFromParent(e),this.notifyOnDirsChangeLs({dirPaths:[n]}),this.notifyOnNewItemConfirmLs({fullPath:s,name:t,type:i})}).bind(this),onBlur:(e=>{this.logger.log("Prompt blur",{prompt:e});const t=e.parent.path;this.removeFromParent(e),this.notifyOnDirsChangeLs({dirPaths:[t]})}).bind(this)});n.children.push(s),this.notifyOnDirsChangeLs({dirPaths:[s.parent.path]}),this.notifyOnShowPromptLs({dirPath:s.parent.path})}serialize(e,t,n){return this.logger.log("Serialize"),[this.root.serialize(e,t,n)]}print(e=this.root,t=this.startingPrintIndent){const n="  ".repeat(t);console.log(n+e.path,`(${e.name})`);for(const i of e.children)i instanceof F?this.print(i,t+1):console.log(n+"  "+i.path,`(${i.name})`)}find(e,t=this.root){if(this.logger.log("Find (recursion)",{currentPath:t.path,targetPath:e}),e=w.normalize(e),t.path===e)return t;const n=e.split(w.sep).length-1;if(!(t.level>n)&&(t instanceof x||t instanceof F))for(const n of t.children){const t=this.find(e,n);if(t)return t}}mkDir(e){this.logger.log("Make dir",e);const t=this.find(e.parentPath);if(!t)throw new Error(`Parent dir '${e.parentPath}' not found`);if(!(t instanceof x||t instanceof F))throw new Error("Parent is not a dir or root");const n=new F({parent:t,name:e.name,onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})});return t.children.push(n),n}mkAll(e){this.logger.log("Make all",e);const t=e.split(w.sep);let n,i="/";for(const e of t)if(i=w.join(i,e),!this.find(i)){const t=w.dirname(i);n=this.mkDir({parentPath:t,name:e})}return n}removeFromParent(e){const{parent:t}=e;(t instanceof x||t instanceof F)&&(t.children=t.children.filter((t=>t!==e))),e.parent=void 0}notifyOnShowPromptLs(e){this.logger.log("Notify on show prompt",e),this.onShowPromptLs.forEach((t=>t(e)))}notifyOnNewItemConfirmLs(e){this.logger.log("Notify on new item confirm",e),this.onNewItemConfirmLs.forEach((t=>t(e)))}notifyOnDirsChangeLs(e){this.logger.log("Notify on dirs change",e),this.onDirsChangeLs.forEach((t=>t(e)))}}function _(e){return function(e){const t=Array.from(e).reduce(((e,t)=>0|31*e+t.charCodeAt(0)),0);return("0000000"+(t>>>0).toString(16)).slice(-8)}(e)}!function(e){e[e.Stdout=0]="Stdout",e[e.Stderr=1]="Stderr"}(b||(b={}));class N{constructor(e,t){this.contextID=e,this.templateID=t,this.output=[],this.filesystem=new O,this.isReady=!1,this.id=`${e}_${_(t)}`}restart(){this.output=[],this.isReady=!1,this.filesystem.setDirsContent([{dirPath:"/",content:[]}])}logOutput(e,t){this.output=[...this.output,{message:e,source:t}]}}function $(e,{environmentID:t,templateID:n}){const i={type:l.RunningEnvironment.Start,payload:{environmentID:t,templateID:n}};e.send(i)}class A{constructor(e){var t,n;this.opts=e,this.fsWriteSubscribers=[],this.fileContentSubscribers=[],this.logger=new i(`EvaluationContext [${e.templateID}]`,e.debug),this.env=new N(this.contextID,e.templateID);this.unsubscribeConnHandler=this.opts.conn.subscribeHandler({onOpen:e=>this.handleConnectionOpen(e),onMessage:e=>this.handleConnectionMessage(e),onClose:()=>this.handleConnectionClose()}),this.opts.conn.isOpen&&this.opts.conn.sessionID&&this.handleConnectionOpen(this.opts.conn.sessionID),this.opts.conn.isClosed&&this.handleConnectionClose(),$(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID}),null===(n=(t=this.opts).onEnvChange)||void 0===n||n.call(t,this.env)}get contextID(){return this.opts.contextID}restart(){this.logger.log("Restart",this.opts.conn.sessionID),this.env.restart(),$(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID})}destroy(){this.logger.log("Destroy"),this.unsubscribeConnHandler(),this.fsWriteSubscribers=[],this.fileContentSubscribers=[]}getFile({path:e}){return s(this,void 0,void 0,(function*(){let t;this.logger.log("Get file",{filepath:e});const n=new Promise(((e,n)=>{t=e,setTimeout((()=>{n("Timeout")}),1e4)})),i=n=>{n.path.endsWith(e)&&t(n.content)};this.subscribeFileContent(i),function(e,{environmentID:t,path:n}){const i={type:l.RunningEnvironment.GetFile,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e});try{return yield n}catch(t){throw new Error(`Error retrieving file ${e}: ${t}`)}finally{this.unsubscribeFileContent(i)}}))}deleteFile({path:e}){this.logger.log("Delete file",{filepath:e}),function(e,{environmentID:t,path:n}){const i={type:l.RunningEnvironment.RemoveFile,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e})}updateFile({path:e,content:t}){return s(this,void 0,void 0,(function*(){let n;this.logger.log("Update file",{filepath:e});const i=new Promise(((e,t)=>{n=e,setTimeout((()=>{t("Timeout")}),1e4)})),s=t=>{t.path.endsWith(e)&&n()};this.subscribeFSWrite(s),function(e,{environmentID:t,path:n,content:i}){const s={type:l.RunningEnvironment.WriteFile,payload:{environmentID:t,path:n,content:i}};e.send(s)}(this.opts.conn,{environmentID:this.env.id,path:e,content:t});try{yield i}catch(t){throw new Error(`File ${e} not written to VM: ${t}`)}finally{this.unsubscribeFSWrite(s)}}))}createDir({path:e}){this.logger.log("Create dir",{filepath:e}),function(e,{environmentID:t,path:n}){const i={type:l.RunningEnvironment.CreateDir,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e})}listDir({path:e}){this.logger.log("List dir",{filepath:e}),function(e,{environmentID:t,path:n}){const i={type:l.RunningEnvironment.ListDir,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e})}executeCommand({executionID:e,command:t}){this.logger.log("Execute shell command",{executionID:e,command:t}),function(e,{environmentID:t,executionID:n,command:i}){const s={type:l.RunningEnvironment.ExecCmd,payload:{environmentID:t,executionID:n,command:i}};e.send(s)}(this.opts.conn,{environmentID:this.env.id,executionID:e,command:t})}subscribeFileContent(e){this.fileContentSubscribers.push(e)}unsubscribeFileContent(e){const t=this.fileContentSubscribers.indexOf(e);t>-1&&this.fileContentSubscribers.splice(t,1)}subscribeFSWrite(e){this.fsWriteSubscribers.push(e)}unsubscribeFSWrite(e){const t=this.fsWriteSubscribers.indexOf(e);t>-1&&this.fsWriteSubscribers.splice(t,1)}handleConnectionOpen(e){var t,n;this.restart(),null===(n=(t=this.opts).onSessionChange)||void 0===n||n.call(t,{status:u.Connected,sessionID:e})}handleConnectionClose(){var e,t;null===(t=(e=this.opts).onSessionChange)||void 0===t||t.call(e,{status:u.Connecting})}handleConnectionMessage(e){switch(this.logger.log("Handling message from remote Runner",{message:e}),e.type){case l.RunningEnvironment.StartAck:{const t=e;this.vmenv_handleStartAck(t.payload);break}case l.RunningEnvironment.CmdOut:{const t=e;this.vmenv_handleCmdOut(t.payload);break}case l.RunningEnvironment.CmdExit:{const t=e;this.vmenv_handleCmdExit(t.payload);break}case l.RunningEnvironment.FSEventWrite:{const t=e;this.vmenv_handleFSEventWrite(t.payload);break}case l.RunningEnvironment.FileContent:{const t=e;this.vmenv_handleFileContent(t.payload);break}case l.RunningEnvironment.FSEventCreate:{const t=e;this.vmenv_handleFSEventCreate(t.payload);break}case l.RunningEnvironment.FSEventRemove:{const t=e;this.vmenv_handleFSEventRemove(t.payload);break}case l.RunningEnvironment.DirContent:{const t=e;this.vmenv_handleDirContent(t.payload);break}case l.RunningEnvironment.Stderr:{const t=e;this.vmenv_handleStderr(t.payload);break}case l.RunningEnvironment.Stdout:{const t=e;this.vmenv_handleStdout(t.payload);break}default:this.logger.warn("Unknown message type",{message:e})}}vmenv_handleFSEventCreate(e){this.logger.log('[vmenv] Handling "FSEventCreate"',e);const t=w.basename(e.path),n=w.dirname(e.path),i="Directory"===e.type?"Dir":"File";this.env.filesystem.addNodeToDir(n,{name:t,type:i})}vmenv_handleFSEventRemove(e){this.logger.log('[vmenv] Handling "FSEventRemove"',{payload:e});const t=w.basename(e.path),n=w.dirname(e.path);this.env.filesystem.removeNodeFromDir(n,{name:t})}vmenv_handleDirContent(e){this.logger.log('[vmenv] Handling "DirContent"',e);const t=[];for(const n of e.content){const e=w.basename(n.path),i="Directory"===n.type?"Dir":"File";t.push({name:e,type:i})}this.env.filesystem.setDirsContent([{dirPath:e.dirPath,content:t}])}vmenv_handleCmdExit(e){var t,n;this.logger.log('[vmenv] Handling "CmdExit"',e),void 0!==e.error&&(null===(n=(t=this.opts).onCmdOut)||void 0===n||n.call(t,{environmentID:e.environmentID,executionID:e.executionID,stderr:e.error}))}vmenv_handleFSEventWrite(e){this.logger.log('[vmenv] Handling "FSEventWrite"',e),this.fsWriteSubscribers.forEach((t=>t(e)))}vmenv_handleFileContent(e){this.logger.log('[vmenv] Handling "FileContent"',{environmentID:e.environmentID,path:e.path}),this.fileContentSubscribers.forEach((t=>t(e)))}vmenv_handleStartAck(e){var t,n;this.logger.log('[vmenv] Handling "StartAck"',{payload:e}),this.env.isReady=!0,null===(n=(t=this.opts).onEnvChange)||void 0===n||n.call(t,this.env)}vmenv_handleCmdOut(e){var t,n;this.logger.log('[vmenv] Handling "CmdOut"',e),null===(n=(t=this.opts).onCmdOut)||void 0===n||n.call(t,e)}vmenv_handleStderr(e){this.logger.log('[vmenv] Handling "Stderr"',e),this.env.logOutput(e.message,b.Stderr)}vmenv_handleStdout(e){this.logger.log('[vmenv] Handling "Stdout"',e),this.env.logOutput(e.message,b.Stdout)}}class M{constructor(){this.logger=new i("Runner"),this.conn=new d,this.sessManager=new m(this.conn)}static get obj(){return M._obj||(M._obj=new M)}get session(){return this.sessManager.session}get status(){return this.sessManager.status}reset(){this.logger.log("Reset"),this.sessManager.reset()}createContext(e){return new A(Object.assign(Object.assign({},e),{conn:this.conn}))}__debug__loadNewSession(){this.logger.log("__debug__loadNewSession"),this.sessManager.reset()}}const W=(j="1234567890abcdefghijklmnopqrstuvwxyz",H=6,()=>{let e="",t=H;for(;t--;)e+=j[Math.random()*j.length|0];return e});var j,H,z;!function(e){e.Disconnected="Disconnected",e.Connecting="Connecting",e.Connected="Connected"}(z||(z={}));class T{constructor(e){this.opts=e,this.contextID="default",this.executionID=W(),this._isDestroyed=!1,this._isEnvReady=!1,this._sessionStatus=u.Disconnected,this._status=z.Disconnected;const t=this.getURL.bind(this),n=()=>this.opts.env,i=()=>this.executionID,s=e=>this.isEnvReady=e,o=e=>this.sessionStatus=e,r=e=>this.sessionID=e;this.context=M.obj.createContext({debug:e.debug,templateID:e.env,contextID:this.contextID,onEnvChange(i){var o;i.templateID===n()&&(s(i.isReady),null===(o=e.onURLChange)||void 0===o||o.call(e,t))},onSessionChange({status:n,sessionID:i}){var s;r(i),o(n),null===(s=e.onURLChange)||void 0===s||s.call(e,t)},onCmdOut(t){var n,s;t.executionID===i()&&(void 0!==t.stdout&&(null===(n=e.onStdout)||void 0===n||n.call(e,t.stdout)),void 0!==t.stderr&&(null===(s=e.onStderr)||void 0===s||s.call(e,t.stderr)))}})}get sessionID(){return this._sessionID}set sessionID(e){this._sessionID=e}get isDestroyed(){return this._isDestroyed}set isDestroyed(e){this._isDestroyed=e,this.updateStatus()}get isEnvReady(){return this._isEnvReady}set isEnvReady(e){this._isEnvReady=e,this.updateStatus()}get sessionStatus(){return this._sessionStatus}set sessionStatus(e){this._sessionStatus=e,this.updateStatus()}get status(){return this._status}set status(e){var t,n;this._status=e,null===(n=(t=this.opts).onStatusChange)||void 0===n||n.call(t,e)}get env(){return this.context.env}get fs(){const e=this.env.filesystem;return{delete:this.deleteFile.bind(this),listDir:this.listDir.bind(this),createDir:this.createDir.bind(this),get:this.getFile.bind(this),write:this.writeFile.bind(this),addListener:e.addListener.bind(e),removeListener:e.removeListener.bind(e),serialize:e.serialize.bind(e)}}getURL(e){if(this.status===z.Connected&&this.sessionID&&this.env.isReady)return`https://${e}-${this.env.id}-${this.sessionID}.o.usedevbook.com`}runCmd(e){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");this.executionID=W(),this.context.executeCommand({executionID:this.executionID,command:e})}destroy(){this.context.destroy(),this.isDestroyed=!0}listDir(e){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.listDir({path:e})}createDir(e){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.createDir({path:e})}deleteFile(e){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.deleteFile({path:e})}getFile(e){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.getFile({path:e})}writeFile(e,t){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.updateFile({path:e,content:t})}updateStatus(){if(this.isDestroyed)return void(this.status!==z.Disconnected&&(this.status=z.Disconnected));let e;switch(this.sessionStatus){case u.Disconnected:e=z.Disconnected;break;case u.Connecting:e=z.Connecting;break;case u.Connected:if(!this.isEnvReady){e=z.Connecting;break}e=z.Connected}this.status=e}}function G({env:i,debug:s,port:o}){const[r,h]=e(),[a,l]=e(z.Disconnected),[d,c]=e([]),[u,g]=e([]),[m,p]=e(),v=t((e=>{r&&(g([]),c([]),r.runCmd(e))}),[r]);return n((function(){const e=new T({debug:s,env:i,onStatusChange(e){l(e)},onStderr(e){c((t=>[...t,e]))},onStdout(e){g((t=>[...t,e]))},onURLChange(e){o&&p(e(o))}});return g([]),c([]),p(void 0),h(e),()=>{e.destroy()}}),[i,s,o]),{stderr:d,stdout:u,runCmd:v,status:a,fs:null==r?void 0:r.fs,url:m}}export{T as Devbook,z as DevbookStatus,G as useDevbook};
+***************************************************************************** */function s(t,e,n,i){return new(n||(n=Promise))((function(s,o){function r(t){try{h(i.next(t))}catch(t){o(t)}}function a(t){try{h(i.throw(t))}catch(t){o(t)}}function h(t){var e;t.done?s(t.value):(e=t.value,e instanceof n?e:new n((function(t){t(e)}))).then(r,a)}h((i=i.apply(t,e||[])).next())}))}function o(t){return new Promise((e=>setTimeout(e,t)))}var r,a,h;!function(t){t.Error="Runner.Error"}(r||(r={})),function(t){t.Start="RunningEnvironment.Start",t.StartAck="RunningEnvironment.StartAck",t.Eval="RunningEnvironment.Eval",t.FSEventCreate="RunningEnvironment.FSEventCreate",t.FSEventRemove="RunningEnvironment.FSEventRemove",t.FSEventWrite="RunningEnvironment.FSEventWrite",t.CreateDir="RunningEnvironment.CreateDir",t.ListDir="RunningEnvironment.ListDir",t.WriteFile="RunningEnvironment.WriteFile",t.GetFile="RunningEnvironment.GetFile",t.RemoveFile="RunningEnvironment.RemoveFile",t.DirContent="RunningEnvironment.DirContent",t.FileContent="RunningEnvironment.FileContent",t.Stdout="RunningEnvironment.Stdout",t.Stderr="RunningEnvironment.Stderr",t.ExecCmd="RunningEnvironment.ExecCmd",t.KillCmd="RunningEnvironment.KillCmd",t.ListRunningCmds="RunningEnvironment.ListRunningCmds",t.CmdOut="RunningEnvironment.CmdOut",t.CmdExit="RunningEnvironment.CmdExit",t.RunningCmds="RunningEnvironment.RunningCmds",t.RunCode="RunningEnvironment.Run"}(a||(a={})),function(t){t.Error="CodeCell.Error"}(h||(h={}));const l={Runner:r,RunningEnvironment:a,CodeCell:h};class c{constructor(){this.url="wss://orchestrator.usedevbook.com",this.logger=new i("WebSocketConnection"),this.handlers=[]}get state(){var t;return null===(t=this.client)||void 0===t?void 0:t.readyState}get isClosed(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSED}get isClosing(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSING}get isOpen(){if(void 0!==this.client)return this.client.readyState===this.client.OPEN}get isConnecting(){if(void 0!==this.client)return this.client.readyState===this.client.CONNECTING}subscribeHandler(t){return this.handlers.push(t),()=>{this.handlers=this.handlers.filter((e=>e!==t))}}connect(t){(!this.client||this.client.readyState!==this.client.CONNECTING&&this.client.readyState!==this.client.OPEN)&&(t||this.sessionID?(t?(this.logger.log(`Will try to connect to session "${t}"`),this.sessionID=t):!t&&this.sessionID&&this.logger.log(`Will try to connect to previous session "${this.sessionID}"`),this.client=new WebSocket(`${this.url}/session/ws/${this.sessionID}`),this.client.onopen=()=>this.handleOpen(this.sessionID),this.client.onmessage=t=>{this.logger.log("Received (raw)",{msg:t}),this.handleMessage(t)},this.client.onerror=t=>this.handleError(t),this.client.onclose=t=>this.handleClose(t)):this.logger.error("Cannot connect, no session ID passed to the function and no session ID saved from the previous session"))}send(t){this.client&&this.client.readyState===this.client.OPEN?(this.logger.log("Send",t),this._send(t)):this.logger.warn("Trying to send a message while not being in the `OPEN` state or without established connection, message will be discarded",t)}close(){var t;this.logger.log("Closing connection"),null===(t=this.client)||void 0===t||t.close(1e3)}handleOpen(t){var e;this.logger.log("Connection opened",{readyState:null===(e=this.client)||void 0===e?void 0:e.readyState}),this.handlers.forEach((e=>e.onOpen(t)))}_send(t){var e,n;null===(e=this.client)||void 0===e||e.send((n=t,JSON.stringify(n,(()=>{const t=new WeakSet;return(e,n)=>{if("object"==typeof n&&null!==n){if(t.has(n))return;t.add(n)}return n}})(),2)))}handleClose(t){return s(this,void 0,void 0,(function*(){this.logger.log("Connection closed",t),this.handlers.forEach((t=>t.onClose())),this.logger.log("Will try to reconnect in 2.5s"),yield o(2500),this.connect()}))}handleError(t){var e;this.logger.error("Connection error",t),null===(e=this.client)||void 0===e||e.close()}handleMessage(t){if(!t.data)return void this.logger.error("Message has empty data field",t);const e=JSON.parse(t.data);if(!e.type)return void this.logger.error("Message has no type",e);const n=e;Object.values(l.RunningEnvironment).includes(n.type)||Object.values(l.Runner).includes(n.type)||Object.values(l.CodeCell).includes(n.type)?n.type!==l.Runner.Error?(this.logger.log("Received (parsed)",n),this.handlers.forEach((t=>t.onMessage(n)))):this.logger.error("Runner error",n):this.logger.error('Message "type" field has unexpected value',n)}}var d,u;!function(t){t.Ok="Ok",t.Terminated="Terminated"}(d||(d={}));class g{constructor(t,e=new Date){this.id=t,this.lastPing=e,this.logger=new i("RunnerSession"),this.url="https://orchestrator.usedevbook.com"}ping(){return s(this,void 0,void 0,(function*(){this.logger.log(`Pinging session "${this.id}"`);const t=JSON.stringify({sessionID:this.id});try{const e=yield fetch(`${this.url}/session/ping`,{method:"POST",headers:{"Content-Type":"application/json"},body:t}),n=yield e.json();if(!e.ok)throw this.logger.error(e.headers,n),new Error("Non-OK response when trying to ping active Runner session");if(n.status===d.Terminated)throw new Error(`[keepAlive]: Session '${this.id}' is terminated`);this.lastPing=new Date}catch(t){throw this.logger.error(t),new Error("Failed to ping active Runner session")}}))}}!function(t){t.Connected="Connected",t.Connecting="Connecting",t.Disconnected="Disconnected"}(u||(u={}));class m{constructor(t){this.conn=t,this.logger=new i("SessionManager"),this.url="https://orchestrator.usedevbook.com",this.userActivity=Promise.resolve(),this.isGettingSessionActive=!1,this.status=u.Disconnected,this.logger.log("Initialize"),this.getSession()}get cachedSessionID(){return sessionStorage.getItem("dbk_sdk_session_id")}set cachedSessionID(t){null===t?(this.logger.log("Cleared last sessionID"),sessionStorage.removeItem("dbk_sdk_session_id")):(this.logger.log(`Saved sessionID "${t}" as last sessionID`),sessionStorage.setItem("dbk_sdk_session_id",t))}stop(){var t;console.log("stopping session"),null===(t=this.startActivity)||void 0===t||t.call(this),this.userActivity=new Promise((t=>{this.startActivity=t})),this.reset()}start(){var t;console.log("starting session"),null===(t=this.startActivity)||void 0===t||t.call(this)}reset(){this.logger.log("Reset"),this.status=u.Disconnected,this.cachedSessionID=null,this.conn.close(),this.session=void 0}getSession(){var t;return s(this,void 0,void 0,(function*(){if(!this.isGettingSessionActive)for(this.isGettingSessionActive=!0;;){this.status=u.Connecting;try{const e=this.cachedSessionID?`${this.url}/session/${this.cachedSessionID}`:`${this.url}/session`;this.cachedSessionID?this.logger.log(`Restoring old Runner session "${this.cachedSessionID}"`):this.logger.log("Acquiring new Runner session");const n=yield fetch(e),i=yield n.json();if(!n.ok){this.logger.error("Non-OK response when trying to ping active Runner session. Will try again in 2.5s",n.headers,i),yield o(2500);continue}for(this.session=new g(i.sessionID),this.logger.log(`Acquired session "${this.session.id}"`),this.cachedSessionID=this.session.id,this.status=u.Connected,this.conn.connect(this.session.id),this.logger.log(`Started pinging session "${this.session.id}"`);this.session;)try{yield this.userActivity,yield this.session.ping(),yield o(5e3)}catch(t){this.logger.error(`Failed to ping session "${this.session.id}"`,t);break}this.logger.log(`Stopped pinging session "${null===(t=this.session)||void 0===t?void 0:t.id}"`),this.session=void 0,this.status=u.Disconnected,this.conn.close()}catch(t){this.logger.error("Failed to acquire Runner session. Will try again in 2.5s",t),yield o(2500)}}}))}}function p(t,e){for(var n=0,i=t.length-1;i>=0;i--){var s=t[i];"."===s?t.splice(i,1):".."===s?(t.splice(i,1),n++):n&&(t.splice(i,1),n--)}if(e)for(;n--;n)t.unshift("..");return t}var v=/^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/,f=function(t){return v.exec(t).slice(1)};function y(){for(var t="",e=!1,n=arguments.length-1;n>=-1&&!e;n--){var i=n>=0?arguments[n]:"/";if("string"!=typeof i)throw new TypeError("Arguments to path.resolve must be strings");i&&(t=i+"/"+t,e="/"===i.charAt(0))}return(e?"/":"")+(t=p(S(t.split("/"),(function(t){return!!t})),!e).join("/"))||"."}function C(t){var e=D(t),n="/"===E(t,-1);return(t=p(S(t.split("/"),(function(t){return!!t})),!e).join("/"))||e||(t="."),t&&n&&(t+="/"),(e?"/":"")+t}function D(t){return"/"===t.charAt(0)}var w={extname:function(t){return f(t)[3]},basename:function(t,e){var n=f(t)[2];return e&&n.substr(-1*e.length)===e&&(n=n.substr(0,n.length-e.length)),n},dirname:function(t){var e=f(t),n=e[0],i=e[1];return n||i?(i&&(i=i.substr(0,i.length-1)),n+i):"."},sep:"/",delimiter:":",relative:function(t,e){function n(t){for(var e=0;e<t.length&&""===t[e];e++);for(var n=t.length-1;n>=0&&""===t[n];n--);return e>n?[]:t.slice(e,n-e+1)}t=y(t).substr(1),e=y(e).substr(1);for(var i=n(t.split("/")),s=n(e.split("/")),o=Math.min(i.length,s.length),r=o,a=0;a<o;a++)if(i[a]!==s[a]){r=a;break}var h=[];for(a=r;a<i.length;a++)h.push("..");return(h=h.concat(s.slice(r))).join("/")},join:function(){var t=Array.prototype.slice.call(arguments,0);return C(S(t,(function(t,e){if("string"!=typeof t)throw new TypeError("Arguments to path.join must be strings");return t})).join("/"))},isAbsolute:D,normalize:C,resolve:y};function S(t,e){if(t.filter)return t.filter(e);for(var n=[],i=0;i<t.length;i++)e(t[i],i,t)&&n.push(t[i]);return n}var b,E="b"==="ab".substr(-1)?function(t,e,n){return t.substr(e,n)}:function(t,e,n){return e<0&&(e=t.length+e),t.substr(e,n)};class I{get level(){return w.normalize(this.path).split(w.sep).length-1}}function R(t){return t.sort(((t,e)=>"Prompt"===t.type?-2:t.type!==e.type?"Dir"===t.type?-1:"Dir"===e.type?1:0:t.key.localeCompare(e.key))),t}class F extends I{constructor({name:t,parent:e,onAddItem:n}){super(),this.children=[],this.name=t,this.parent=e,this.addItemHandler=n,this.path=w.join(this.parent.path,this.name)}removeChildNode(t){this.children=this.children.filter((e=>e!==t))}serialize(t,e,n){const i=this.children.map((i=>i.serialize(t,e,n)));return{type:"Dir",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:R(i)}}}class _ extends I{constructor({name:t,parent:e}){super(),this.name=t,this.parent=e,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"File",key:this.path,title:this.name,isLeaf:!0}}}class k extends I{constructor({parent:t,forNode:e,onConfirm:n,onBlur:i}){super(),this.name="name-prompt",this.parent=t,this.forNode=e,this.path=w.join(t.path,this.name),this.onConfirm=n,this.onBlur=i}serialize(t,e,n){return{type:"Prompt",key:this.path,title:e({onConfirm:t=>{var e;return null===(e=this.onConfirm)||void 0===e?void 0:e.call(this,this,t)},onBlur:()=>{var t;return null===(t=this.onBlur)||void 0===t?void 0:t.call(this,this)}}),isLeaf:!0,selectable:!1,icon:n({type:this.forNode})}}}class P extends I{constructor({onAddItem:t}){super(),this.name="/",this.path="/",this.parent=void 0,this.children=[],this.addItemHandler=t}serialize(t,e,n){const i=this.children.map((i=>i.serialize(t,e,n)));return{type:"Root",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:R(i)}}}class x extends I{constructor({parent:t}){super(),this.name="empty-node",this.parent=t,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"Empty",key:this.path,title:"Empty Directory",isLeaf:!0,disabled:!0}}}class L{constructor(){this.logger=new i("Filesystem"),this.root=new P({onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}),this.startingPrintIndent=0,this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}removeAllListeners(){this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}addListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs.push(e);break;case"onDirsChange":this.onDirsChangeLs.push(e);break;case"onFileContent":this.onFileContentLs.push(e);break;case"onShowPrompt":this.onShowPromptLs.push(e);break;default:throw new Error(`Unknown event type: ${t}`)}}removeListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs=this.onNewItemConfirmLs.filter((t=>t!==e));break;case"onDirsChange":this.onDirsChangeLs=this.onDirsChangeLs.filter((t=>t!==e));break;case"onFileContent":this.onFileContentLs=this.onFileContentLs.filter((t=>t!==e));break;case"onShowPrompt":this.onShowPromptLs=this.onShowPromptLs.filter((t=>t!==e));break;default:throw new Error(`Unknown event type: ${t}`)}}addNodeToDir(t,e){this.logger.log("Adding node to dir",{dirPath:t,node:e});let n=this.find(t);if(n||(this.logger.log("Dir not found, will make all",{dirPath:t}),n=this.mkAll(t)),!n)throw new Error("dirNode is undefined");if(!(n instanceof P||n instanceof F))throw new Error(`Node at '${t}' is not a directory or a root node`);if(n.children.some((t=>t.name===e.name)))return;let i;i="Dir"===e.type?new F({name:e.name,parent:n,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new _({name:e.name,parent:n}),1===n.children.length&&n.children[0]instanceof x?n.children=[i]:n.children.push(i),this.notifyOnDirsChangeLs({dirPaths:[t]})}removeNodeFromDir(t,e){this.logger.log("Remove node from dir",{dirPath:t,nodeName:e.name});const n=this.find(t);if(!n)throw new Error(`No node with path '${t}'`);if(!(n instanceof P||n instanceof F))throw new Error(`Node at '${t}' is not a directory or root node`);const i=n.children.length;n.children=n.children.filter((t=>t.name!==e.name));i!==n.children.length?(0===n.children.length&&(n.children=[new x({parent:n})]),this.notifyOnDirsChangeLs({dirPaths:[t]})):this.logger.warn("Node not found in dir",{dirPath:t,nodeName:e.name})}setFileContent(t){this.logger.log("Update file content",t),this.onFileContentLs.forEach((e=>e(t)))}setDirsContent(t){this.logger.log("Set dirs content",t);for(const e of t){let t=this.find(e.dirPath);if(t||(this.logger.log("Dir not found, will make all",{dirPath:e.dirPath}),t=this.mkAll(e.dirPath)),!t)throw new Error("dirNode is undefined");if(!(t instanceof P||t instanceof F))throw new Error(`Node at '${e.dirPath}' is not a directory or a root node`);const n=t.children.find((t=>t instanceof k));if(e.content.length){const n=[];for(const i of e.content){let e;e="Dir"===i.type?new F({name:i.name,parent:t,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new _({name:i.name,parent:t}),n.push(e)}t.children=n}else t.children=[new x({parent:t})];n&&t.children.push(n)}this.notifyOnDirsChangeLs({dirPaths:t.map((t=>t.dirPath))})}showPrompt(t){const{event:e,parent:n,type:i}=t;if(this.logger.log("Show prompt",{parent:n,type:i}),n.children.some((t=>t instanceof k)))return;e.preventDefault();const s=new k({parent:n,forNode:i,onConfirm:((t,e)=>{if(this.logger.log("Prompt confirm",{prompt:t,name:e}),!e)return;const n=t.parent.path,s=w.join(t.parent.path,e);this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[n]}),this.notifyOnNewItemConfirmLs({fullPath:s,name:e,type:i})}).bind(this),onBlur:(t=>{this.logger.log("Prompt blur",{prompt:t});const e=t.parent.path;this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[e]})}).bind(this)});n.children.push(s),this.notifyOnDirsChangeLs({dirPaths:[s.parent.path]}),this.notifyOnShowPromptLs({dirPath:s.parent.path})}serialize(t,e,n){return this.logger.log("Serialize"),[this.root.serialize(t,e,n)]}print(t=this.root,e=this.startingPrintIndent){const n="  ".repeat(e);console.log(n+t.path,`(${t.name})`);for(const i of t.children)i instanceof F?this.print(i,e+1):console.log(n+"  "+i.path,`(${i.name})`)}find(t,e=this.root){if(this.logger.log("Find (recursion)",{currentPath:e.path,targetPath:t}),t=w.normalize(t),e.path===t)return e;const n=t.split(w.sep).length-1;if(!(e.level>n)&&(e instanceof P||e instanceof F))for(const n of e.children){const e=this.find(t,n);if(e)return e}}mkDir(t){this.logger.log("Make dir",t);const e=this.find(t.parentPath);if(!e)throw new Error(`Parent dir '${t.parentPath}' not found`);if(!(e instanceof P||e instanceof F))throw new Error("Parent is not a dir or root");const n=new F({parent:e,name:t.name,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})});return e.children.push(n),n}mkAll(t){this.logger.log("Make all",t);const e=t.split(w.sep);let n,i="/";for(const t of e)if(i=w.join(i,t),!this.find(i)){const e=w.dirname(i);n=this.mkDir({parentPath:e,name:t})}return n}removeFromParent(t){const{parent:e}=t;(e instanceof P||e instanceof F)&&(e.children=e.children.filter((e=>e!==t))),t.parent=void 0}notifyOnShowPromptLs(t){this.logger.log("Notify on show prompt",t),this.onShowPromptLs.forEach((e=>e(t)))}notifyOnNewItemConfirmLs(t){this.logger.log("Notify on new item confirm",t),this.onNewItemConfirmLs.forEach((e=>e(t)))}notifyOnDirsChangeLs(t){this.logger.log("Notify on dirs change",t),this.onDirsChangeLs.forEach((e=>e(t)))}}function O(t){return function(t){const e=Array.from(t).reduce(((t,e)=>0|31*t+e.charCodeAt(0)),0);return("0000000"+(e>>>0).toString(16)).slice(-8)}(t)}!function(t){t[t.Stdout=0]="Stdout",t[t.Stderr=1]="Stderr"}(b||(b={}));class N{constructor(t,e){this.contextID=t,this.templateID=e,this.output=[],this.filesystem=new L,this.isReady=!1,this.id=`${t}_${O(e)}`}restart(){this.output=[],this.isReady=!1,this.filesystem.setDirsContent([{dirPath:"/",content:[]}])}logOutput(t,e){this.output=[...this.output,{message:t,source:e}]}}function A(t,{environmentID:e,templateID:n}){const i={type:l.RunningEnvironment.Start,payload:{environmentID:e,templateID:n}};t.send(i)}class ${constructor(t){var e,n;this.opts=t,this.fsWriteSubscribers=[],this.fileContentSubscribers=[],this.logger=new i(`EvaluationContext [${t.templateID}]`,t.debug),this.env=new N(this.contextID,t.templateID);this.unsubscribeConnHandler=this.opts.conn.subscribeHandler({onOpen:t=>this.handleConnectionOpen(t),onMessage:t=>this.handleConnectionMessage(t),onClose:()=>this.handleConnectionClose()}),this.opts.conn.isOpen&&this.opts.conn.sessionID&&this.handleConnectionOpen(this.opts.conn.sessionID),this.opts.conn.isClosed&&this.handleConnectionClose(),A(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID}),null===(n=(e=this.opts).onEnvChange)||void 0===n||n.call(e,this.env)}get contextID(){return this.opts.contextID}restart(){this.logger.log("Restart",this.opts.conn.sessionID),this.env.restart(),A(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID})}destroy(){this.logger.log("Destroy"),this.unsubscribeConnHandler(),this.fsWriteSubscribers=[],this.fileContentSubscribers=[]}getFile({path:t}){return s(this,void 0,void 0,(function*(){let e;this.logger.log("Get file",{filepath:t});const n=new Promise(((t,n)=>{e=t,setTimeout((()=>{n("Timeout")}),1e4)})),i=n=>{n.path.endsWith(t)&&e(n.content)};this.subscribeFileContent(i),function(t,{environmentID:e,path:n}){const i={type:l.RunningEnvironment.GetFile,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t});try{return yield n}catch(e){throw new Error(`Error retrieving file ${t}: ${e}`)}finally{this.unsubscribeFileContent(i)}}))}deleteFile({path:t}){this.logger.log("Delete file",{filepath:t}),function(t,{environmentID:e,path:n}){const i={type:l.RunningEnvironment.RemoveFile,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t})}updateFile({path:t,content:e}){return s(this,void 0,void 0,(function*(){let n;this.logger.log("Update file",{filepath:t});const i=new Promise(((t,e)=>{n=t,setTimeout((()=>{e("Timeout")}),1e4)})),s=e=>{e.path.endsWith(t)&&n()};this.subscribeFSWrite(s),function(t,{environmentID:e,path:n,content:i}){const s={type:l.RunningEnvironment.WriteFile,payload:{environmentID:e,path:n,content:i}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t,content:e});try{yield i}catch(e){throw new Error(`File ${t} not written to VM: ${e}`)}finally{this.unsubscribeFSWrite(s)}}))}createDir({path:t}){this.logger.log("Create dir",{filepath:t}),function(t,{environmentID:e,path:n}){const i={type:l.RunningEnvironment.CreateDir,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t})}listDir({path:t}){this.logger.log("List dir",{filepath:t}),function(t,{environmentID:e,path:n}){const i={type:l.RunningEnvironment.ListDir,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t})}executeCommand({executionID:t,command:e}){this.logger.log("Execute shell command",{executionID:t,command:e}),function(t,{environmentID:e,executionID:n,command:i}){const s={type:l.RunningEnvironment.ExecCmd,payload:{environmentID:e,executionID:n,command:i}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,executionID:t,command:e})}subscribeFileContent(t){this.fileContentSubscribers.push(t)}unsubscribeFileContent(t){const e=this.fileContentSubscribers.indexOf(t);e>-1&&this.fileContentSubscribers.splice(e,1)}subscribeFSWrite(t){this.fsWriteSubscribers.push(t)}unsubscribeFSWrite(t){const e=this.fsWriteSubscribers.indexOf(t);e>-1&&this.fsWriteSubscribers.splice(e,1)}handleConnectionOpen(t){var e,n;this.restart(),null===(n=(e=this.opts).onSessionChange)||void 0===n||n.call(e,{status:u.Connecting})}handleConnectionClose(){var t,e;null===(e=(t=this.opts).onSessionChange)||void 0===e||e.call(t,{status:u.Connecting})}handleConnectionMessage(t){switch(this.logger.log("Handling message from remote Runner",{message:t}),t.type){case l.RunningEnvironment.StartAck:{const e=t;this.vmenv_handleStartAck(e.payload);break}case l.RunningEnvironment.CmdOut:{const e=t;this.vmenv_handleCmdOut(e.payload);break}case l.RunningEnvironment.CmdExit:{const e=t;this.vmenv_handleCmdExit(e.payload);break}case l.RunningEnvironment.FSEventWrite:{const e=t;this.vmenv_handleFSEventWrite(e.payload);break}case l.RunningEnvironment.FileContent:{const e=t;this.vmenv_handleFileContent(e.payload);break}case l.RunningEnvironment.FSEventCreate:{const e=t;this.vmenv_handleFSEventCreate(e.payload);break}case l.RunningEnvironment.FSEventRemove:{const e=t;this.vmenv_handleFSEventRemove(e.payload);break}case l.RunningEnvironment.DirContent:{const e=t;this.vmenv_handleDirContent(e.payload);break}case l.RunningEnvironment.Stderr:{const e=t;this.vmenv_handleStderr(e.payload);break}case l.RunningEnvironment.Stdout:{const e=t;this.vmenv_handleStdout(e.payload);break}default:this.logger.warn("Unknown message type",{message:t})}}vmenv_handleFSEventCreate(t){this.logger.log('[vmenv] Handling "FSEventCreate"',t);const e=w.basename(t.path),n=w.dirname(t.path),i="Directory"===t.type?"Dir":"File";this.env.filesystem.addNodeToDir(n,{name:e,type:i})}vmenv_handleFSEventRemove(t){this.logger.log('[vmenv] Handling "FSEventRemove"',{payload:t});const e=w.basename(t.path),n=w.dirname(t.path);this.env.filesystem.removeNodeFromDir(n,{name:e})}vmenv_handleDirContent(t){this.logger.log('[vmenv] Handling "DirContent"',t);const e=[];for(const n of t.content){const t=w.basename(n.path),i="Directory"===n.type?"Dir":"File";e.push({name:t,type:i})}this.env.filesystem.setDirsContent([{dirPath:t.dirPath,content:e}])}vmenv_handleCmdExit(t){var e,n;this.logger.log('[vmenv] Handling "CmdExit"',t),void 0!==t.error&&(null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,{environmentID:t.environmentID,executionID:t.executionID,stderr:t.error}))}vmenv_handleFSEventWrite(t){this.logger.log('[vmenv] Handling "FSEventWrite"',t),this.fsWriteSubscribers.forEach((e=>e(t)))}vmenv_handleFileContent(t){this.logger.log('[vmenv] Handling "FileContent"',{environmentID:t.environmentID,path:t.path}),this.fileContentSubscribers.forEach((e=>e(t)))}vmenv_handleStartAck(t){var e,n,i,s;this.logger.log('[vmenv] Handling "StartAck"',{payload:t}),this.env.isReady=!0,null===(n=(e=this.opts).onEnvChange)||void 0===n||n.call(e,this.env),null===(s=(i=this.opts).onSessionChange)||void 0===s||s.call(i,{status:u.Connected,sessionID:this.opts.conn.sessionID})}vmenv_handleCmdOut(t){var e,n;this.logger.log('[vmenv] Handling "CmdOut"',t),null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,t)}vmenv_handleStderr(t){this.logger.log('[vmenv] Handling "Stderr"',t),this.env.logOutput(t.message,b.Stderr)}vmenv_handleStdout(t){this.logger.log('[vmenv] Handling "Stdout"',t),this.env.logOutput(t.message,b.Stdout)}}class M{constructor(){this.logger=new i("Runner"),this.conn=new c,this.sessManager=new m(this.conn)}static get obj(){return M._obj||(M._obj=new M)}get session(){return this.sessManager.session}get status(){return this.sessManager.status}reset(){this.logger.log("Reset"),this.sessManager.reset()}createContext(t){return new $(Object.assign(Object.assign({},t),{conn:this.conn}))}__internal__start(){this.sessManager.start()}__internal__stop(){this.sessManager.stop()}__debug__loadNewSession(){this.logger.log("__debug__loadNewSession"),this.sessManager.reset()}}const W=(j="1234567890abcdefghijklmnopqrstuvwxyz",H=6,()=>{let t="",e=H;for(;e--;)t+=j[Math.random()*j.length|0];return t});var j,H,z;!function(t){t.Disconnected="Disconnected",t.Connecting="Connecting",t.Connected="Connected"}(z||(z={}));class T{constructor(t){this.opts=t,this.contextID="default",this.executionID=W(),this._isDestroyed=!1,this._isEnvReady=!1,this._sessionStatus=u.Disconnected,this._status=z.Disconnected;const e=this.getURL.bind(this),n=()=>this.opts.env,i=()=>this.executionID,s=t=>this.isEnvReady=t,o=t=>this.sessionStatus=t,r=t=>this.sessionID=t;this.context=M.obj.createContext({debug:t.debug,templateID:t.env,contextID:this.contextID,onEnvChange(i){var o;i.templateID===n()&&(s(i.isReady),null===(o=t.onURLChange)||void 0===o||o.call(t,e))},onSessionChange({status:n,sessionID:i}){var s;r(i),o(n),null===(s=t.onURLChange)||void 0===s||s.call(t,e)},onCmdOut(e){var n,s;e.executionID===i()&&(void 0!==e.stdout&&(null===(n=t.onStdout)||void 0===n||n.call(t,e.stdout)),void 0!==e.stderr&&(null===(s=t.onStderr)||void 0===s||s.call(t,e.stderr)))}})}get sessionID(){return this._sessionID}set sessionID(t){this._sessionID=t}get isDestroyed(){return this._isDestroyed}set isDestroyed(t){this._isDestroyed=t,this.updateStatus()}get isEnvReady(){return this._isEnvReady}set isEnvReady(t){this._isEnvReady=t,this.updateStatus()}get sessionStatus(){return this._sessionStatus}set sessionStatus(t){this._sessionStatus=t,this.updateStatus()}get status(){return this._status}set status(t){var e,n;this._status=t,null===(n=(e=this.opts).onStatusChange)||void 0===n||n.call(e,t)}get env(){return this.context.env}get fs(){const t=this.env.filesystem;return{delete:this.deleteFile.bind(this),listDir:this.listDir.bind(this),createDir:this.createDir.bind(this),get:this.getFile.bind(this),write:this.writeFile.bind(this),addListener:t.addListener.bind(t),removeListener:t.removeListener.bind(t),serialize:t.serialize.bind(t)}}getURL(t){if(this.status===z.Connected&&this.sessionID&&this.env.isReady)return`https://${t}-${this.env.id}-${this.sessionID}.o.usedevbook.com`}runCmd(t){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");this.executionID=W(),this.context.executeCommand({executionID:this.executionID,command:t})}destroy(){this.context.destroy(),this.isDestroyed=!0}__internal__start(){M.obj.__internal__start()}__internal__stop(){M.obj.__internal__stop()}listDir(t){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.listDir({path:t})}createDir(t){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.createDir({path:t})}deleteFile(t){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.deleteFile({path:t})}getFile(t){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.getFile({path:t})}writeFile(t,e){if(this.status!==z.Connected)throw new Error("Not connected to the VM yet.");return this.context.updateFile({path:t,content:e})}updateStatus(){if(this.isDestroyed)return void(this.status!==z.Disconnected&&(this.status=z.Disconnected));let t;switch(this.sessionStatus){case u.Disconnected:t=z.Disconnected;break;case u.Connecting:t=z.Connecting;break;case u.Connected:if(!this.isEnvReady){t=z.Connecting;break}t=z.Connected}this.status=t}}function G({env:i,debug:s,port:o}){const[r,a]=t(),[h,l]=t(z.Disconnected),[c,d]=t([]),[u,g]=t([]),[m,p]=t(),v=e((t=>{r&&(g([]),d([]),r.runCmd(t))}),[r]);return n((function(){const t=new T({debug:s,env:i,onStatusChange(t){l(t)},onStderr(t){d((e=>[...e,t]))},onStdout(t){g((e=>[...e,t]))},onURLChange(t){o&&p(t(o))}});return g([]),d([]),p(void 0),a(t),()=>{t.destroy()}}),[i,s,o]),{stderr:c,stdout:u,runCmd:v,status:h,fs:null==r?void 0:r.fs,url:m}}export{T as Devbook,z as DevbookStatus,G as useDevbook};
 //# sourceMappingURL=index.js.map

lib/umd/core/constants/runner.d.ts

 export declare const REMOTE_RUNNER_HOSTNAME = "orchestrator.usedevbook.com";
 export declare const STORAGE_SESSION_ID_KEY = "dbk_sdk_session_id";
 export declare const SESSION_PING_PERIOD = 5000;
-export declare const SESSION_RESTART_PERIOD = 3000;
-export declare const WSCONN_RESTART_PERIOD = 3000;
+export declare const SESSION_RESTART_PERIOD = 2500;
+export declare const WSCONN_RESTART_PERIOD = 2500;

lib/umd/core/devbook.d.ts

@@ -139,2 +139,6 @@ import { Filesystem } from './runningEnvironment/filesystem';
     destroy(): void;
+    /** @internal */
+    __internal__start(): void;
+    /** @internal */
+    __internal__stop(): void;
     private listDir;
@@ -141,0 +145,0 @@ private createDir;

lib/umd/core/runner.d.ts

@@ -15,4 +15,8 @@ import EvaluationContext, { EvaluationContextOpts } from './evaluationContext';
     createContext(opts: Omit<EvaluationContextOpts, 'conn'>): EvaluationContext;
+    /** @internal */
+    __internal__start(): void;
+    /** @internal */
+    __internal__stop(): void;
     __debug__loadNewSession(): void;
 }
 export default Runner;

lib/umd/core/session/sessionManager.d.ts

@@ -12,2 +12,4 @@ import { WebSocketConnection } from '../webSocketConnection';
     private readonly url;
+    private userActivity;
+    private startActivity?;
     private isGettingSessionActive;
@@ -19,2 +21,4 @@ private get cachedSessionID();
     constructor(conn: WebSocketConnection);
+    stop(): void;
+    start(): void;
     reset(): void;
@@ -21,0 +25,0 @@ /**

lib/umd/index.js

@@ -1,2 +0,2 @@
-!function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("react")):"function"==typeof define&&define.amd?define(["exports","react"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self)["@devbookhq/sdk"]={},e.react)}(this,(function(e,t){"use strict";class n{constructor(e,t=!1){this.logID=e,this.isEnabled=t}id(){return"function"==typeof this.logID?this.logID():this.logID}log(...e){this.isEnabled&&console.log(`[${this.id()}]`,...e)}warn(...e){this.isEnabled&&console.warn(`[${this.id()}]`,...e)}error(...e){console.error(`[${this.id()} ERROR]`,...e)}}
+!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports,require("react")):"function"==typeof define&&define.amd?define(["exports","react"],e):e((t="undefined"!=typeof globalThis?globalThis:t||self)["@devbookhq/sdk"]={},t.react)}(this,(function(t,e){"use strict";class n{constructor(t,e=!1){this.logID=t,this.isEnabled=e}id(){return"function"==typeof this.logID?this.logID():this.logID}log(...t){this.isEnabled&&console.log(`[${this.id()}]`,...t)}warn(...t){this.isEnabled&&console.warn(`[${this.id()}]`,...t)}error(...t){console.error(`[${this.id()} ERROR]`,...t)}}
 /*! *****************************************************************************
@@ -15,3 +15,3 @@ Copyright (c) Microsoft Corporation.
   PERFORMANCE OF THIS SOFTWARE.
-  ***************************************************************************** */function i(e,t,n,i){return new(n||(n=Promise))((function(s,o){function r(e){try{h(i.next(e))}catch(e){o(e)}}function a(e){try{h(i.throw(e))}catch(e){o(e)}}function h(e){var t;e.done?s(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(r,a)}h((i=i.apply(e,t||[])).next())}))}function s(e){return new Promise((t=>setTimeout(t,e)))}var o,r,a;!function(e){e.Error="Runner.Error"}(o||(o={})),function(e){e.Start="RunningEnvironment.Start",e.StartAck="RunningEnvironment.StartAck",e.Eval="RunningEnvironment.Eval",e.FSEventCreate="RunningEnvironment.FSEventCreate",e.FSEventRemove="RunningEnvironment.FSEventRemove",e.FSEventWrite="RunningEnvironment.FSEventWrite",e.CreateDir="RunningEnvironment.CreateDir",e.ListDir="RunningEnvironment.ListDir",e.WriteFile="RunningEnvironment.WriteFile",e.GetFile="RunningEnvironment.GetFile",e.RemoveFile="RunningEnvironment.RemoveFile",e.DirContent="RunningEnvironment.DirContent",e.FileContent="RunningEnvironment.FileContent",e.Stdout="RunningEnvironment.Stdout",e.Stderr="RunningEnvironment.Stderr",e.ExecCmd="RunningEnvironment.ExecCmd",e.KillCmd="RunningEnvironment.KillCmd",e.ListRunningCmds="RunningEnvironment.ListRunningCmds",e.CmdOut="RunningEnvironment.CmdOut",e.CmdExit="RunningEnvironment.CmdExit",e.RunningCmds="RunningEnvironment.RunningCmds",e.RunCode="RunningEnvironment.Run"}(r||(r={})),function(e){e.Error="CodeCell.Error"}(a||(a={}));const h={Runner:o,RunningEnvironment:r,CodeCell:a},l="orchestrator.usedevbook.com",d="dbk_sdk_session_id",c=3e3;class u{constructor(){this.url=`wss://${l}`,this.logger=new n("WebSocketConnection"),this.handlers=[]}get state(){var e;return null===(e=this.client)||void 0===e?void 0:e.readyState}get isClosed(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSED}get isClosing(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSING}get isOpen(){if(void 0!==this.client)return this.client.readyState===this.client.OPEN}get isConnecting(){if(void 0!==this.client)return this.client.readyState===this.client.CONNECTING}subscribeHandler(e){return this.handlers.push(e),()=>{this.handlers=this.handlers.filter((t=>t!==e))}}connect(e){(!this.client||this.client.readyState!==this.client.CONNECTING&&this.client.readyState!==this.client.OPEN)&&(e||this.sessionID?(e?(this.logger.log(`Will try to connect to session "${e}"`),this.sessionID=e):!e&&this.sessionID&&this.logger.log(`Will try to connect to previous session "${this.sessionID}"`),this.client=new WebSocket(`${this.url}/session/ws/${this.sessionID}`),this.client.onopen=()=>this.handleOpen(this.sessionID),this.client.onmessage=e=>{this.logger.log("Received (raw)",{msg:e}),this.handleMessage(e)},this.client.onerror=e=>this.handleError(e),this.client.onclose=e=>this.handleClose(e)):this.logger.error("Cannot connect, no session ID passed to the function and no session ID saved from the previous session"))}send(e){this.client&&this.client.readyState===this.client.OPEN?(this.logger.log("Send",e),this._send(e)):this.logger.warn("Trying to send a message while not being in the `OPEN` state or without established connection, message will be discarded",e)}close(){var e;this.logger.log("Closing connection"),null===(e=this.client)||void 0===e||e.close(1e3)}handleOpen(e){var t;this.logger.log("Connection opened",{readyState:null===(t=this.client)||void 0===t?void 0:t.readyState}),this.handlers.forEach((t=>t.onOpen(e)))}_send(e){var t,n;null===(t=this.client)||void 0===t||t.send((n=e,JSON.stringify(n,(()=>{const e=new WeakSet;return(t,n)=>{if("object"==typeof n&&null!==n){if(e.has(n))return;e.add(n)}return n}})(),2)))}handleClose(e){return i(this,void 0,void 0,(function*(){this.logger.log("Connection closed",e),this.handlers.forEach((e=>e.onClose())),this.logger.log("Will try to reconnect in 3s"),yield s(3e3),this.connect()}))}handleError(e){var t;this.logger.error("Connection error",e),null===(t=this.client)||void 0===t||t.close()}handleMessage(e){if(!e.data)return void this.logger.error("Message has empty data field",e);const t=JSON.parse(e.data);if(!t.type)return void this.logger.error("Message has no type",t);const n=t;Object.values(h.RunningEnvironment).includes(n.type)||Object.values(h.Runner).includes(n.type)||Object.values(h.CodeCell).includes(n.type)?n.type!==h.Runner.Error?(this.logger.log("Received (parsed)",n),this.handlers.forEach((e=>e.onMessage(n)))):this.logger.error("Runner error",n):this.logger.error('Message "type" field has unexpected value',n)}}var g,m;!function(e){e.Ok="Ok",e.Terminated="Terminated"}(g||(g={}));class v{constructor(e,t=new Date){this.id=e,this.lastPing=t,this.logger=new n("RunnerSession"),this.url=`https://${l}`}ping(){return i(this,void 0,void 0,(function*(){this.logger.log(`Pinging session "${this.id}"`);const e=JSON.stringify({sessionID:this.id});try{const t=yield fetch(`${this.url}/session/ping`,{method:"POST",headers:{"Content-Type":"application/json"},body:e}),n=yield t.json();if(!t.ok)throw this.logger.error(t.headers,n),new Error("Non-OK response when trying to ping active Runner session");if(n.status===g.Terminated)throw new Error(`[keepAlive]: Session '${this.id}' is terminated`);this.lastPing=new Date}catch(e){throw this.logger.error(e),new Error("Failed to ping active Runner session")}}))}}!function(e){e.Connected="Connected",e.Connecting="Connecting",e.Disconnected="Disconnected"}(m||(m={}));class p{constructor(e){this.conn=e,this.logger=new n("SessionManager"),this.url=`https://${l}`,this.isGettingSessionActive=!1,this.status=m.Disconnected,this.logger.log("Initialize"),this.getSession()}get cachedSessionID(){return sessionStorage.getItem(d)}set cachedSessionID(e){null===e?(this.logger.log("Cleared last sessionID"),sessionStorage.removeItem(d)):(this.logger.log(`Saved sessionID "${e}" as last sessionID`),sessionStorage.setItem(d,e))}reset(){this.logger.log("Reset"),this.status=m.Disconnected,this.cachedSessionID=null,this.conn.close(),this.session=void 0}getSession(){var e;return i(this,void 0,void 0,(function*(){if(!this.isGettingSessionActive)for(this.isGettingSessionActive=!0;;){this.status=m.Connecting;try{const t=this.cachedSessionID?`${this.url}/session/${this.cachedSessionID}`:`${this.url}/session`;this.cachedSessionID?this.logger.log(`Restoring old Runner session "${this.cachedSessionID}"`):this.logger.log("Acquiring new Runner session");const n=yield fetch(t),i=yield n.json();if(!n.ok){this.logger.error("Non-OK response when trying to ping active Runner session. Will try again in 3s",n.headers,i),yield s(c);continue}for(this.session=new v(i.sessionID),this.logger.log(`Acquired session "${this.session.id}"`),this.cachedSessionID=this.session.id,this.status=m.Connected,this.conn.connect(this.session.id),this.logger.log(`Started pinging session "${this.session.id}"`);this.session;)try{yield this.session.ping(),yield s(5e3)}catch(e){this.logger.error(`Failed to ping session "${this.session.id}"`,e);break}this.logger.log(`Stopped pinging session "${null===(e=this.session)||void 0===e?void 0:e.id}"`),this.session=void 0,this.status=m.Disconnected,this.conn.close()}catch(e){this.logger.error("Failed to acquire Runner session. Will try again in 3s",e),yield s(c)}}}))}}function f(e,t){for(var n=0,i=e.length-1;i>=0;i--){var s=e[i];"."===s?e.splice(i,1):".."===s?(e.splice(i,1),n++):n&&(e.splice(i,1),n--)}if(t)for(;n--;n)e.unshift("..");return e}var D=/^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/,y=function(e){return D.exec(e).slice(1)};function C(){for(var e="",t=!1,n=arguments.length-1;n>=-1&&!t;n--){var i=n>=0?arguments[n]:"/";if("string"!=typeof i)throw new TypeError("Arguments to path.resolve must be strings");i&&(e=i+"/"+e,t="/"===i.charAt(0))}return(t?"/":"")+(e=f(E(e.split("/"),(function(e){return!!e})),!t).join("/"))||"."}function S(e){var t=b(e),n="/"===R(e,-1);return(e=f(E(e.split("/"),(function(e){return!!e})),!t).join("/"))||t||(e="."),e&&n&&(e+="/"),(t?"/":"")+e}function b(e){return"/"===e.charAt(0)}var w={extname:function(e){return y(e)[3]},basename:function(e,t){var n=y(e)[2];return t&&n.substr(-1*t.length)===t&&(n=n.substr(0,n.length-t.length)),n},dirname:function(e){var t=y(e),n=t[0],i=t[1];return n||i?(i&&(i=i.substr(0,i.length-1)),n+i):"."},sep:"/",delimiter:":",relative:function(e,t){function n(e){for(var t=0;t<e.length&&""===e[t];t++);for(var n=e.length-1;n>=0&&""===e[n];n--);return t>n?[]:e.slice(t,n-t+1)}e=C(e).substr(1),t=C(t).substr(1);for(var i=n(e.split("/")),s=n(t.split("/")),o=Math.min(i.length,s.length),r=o,a=0;a<o;a++)if(i[a]!==s[a]){r=a;break}var h=[];for(a=r;a<i.length;a++)h.push("..");return(h=h.concat(s.slice(r))).join("/")},join:function(){var e=Array.prototype.slice.call(arguments,0);return S(E(e,(function(e,t){if("string"!=typeof e)throw new TypeError("Arguments to path.join must be strings");return e})).join("/"))},isAbsolute:b,normalize:S,resolve:C};function E(e,t){if(e.filter)return e.filter(t);for(var n=[],i=0;i<e.length;i++)t(e[i],i,e)&&n.push(e[i]);return n}var I,R="b"==="ab".substr(-1)?function(e,t,n){return e.substr(t,n)}:function(e,t,n){return t<0&&(t=e.length+t),e.substr(t,n)};class k{get level(){return w.normalize(this.path).split(w.sep).length-1}}function F(e){return e.sort(((e,t)=>"Prompt"===e.type?-2:e.type!==t.type?"Dir"===e.type?-1:"Dir"===t.type?1:0:e.key.localeCompare(t.key))),e}class P extends k{constructor({name:e,parent:t,onAddItem:n}){super(),this.children=[],this.name=e,this.parent=t,this.addItemHandler=n,this.path=w.join(this.parent.path,this.name)}removeChildNode(e){this.children=this.children.filter((t=>t!==e))}serialize(e,t,n){const i=this.children.map((i=>i.serialize(e,t,n)));return{type:"Dir",key:this.path,title:e({name:this.name,onAddFileMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"File"})},onAddDirMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"Dir"})}}),children:F(i)}}}class x extends k{constructor({name:e,parent:t}){super(),this.name=e,this.parent=t,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"File",key:this.path,title:this.name,isLeaf:!0}}}class L extends k{constructor({parent:e,forNode:t,onConfirm:n,onBlur:i}){super(),this.name="name-prompt",this.parent=e,this.forNode=t,this.path=w.join(e.path,this.name),this.onConfirm=n,this.onBlur=i}serialize(e,t,n){return{type:"Prompt",key:this.path,title:t({onConfirm:e=>{var t;return null===(t=this.onConfirm)||void 0===t?void 0:t.call(this,this,e)},onBlur:()=>{var e;return null===(e=this.onBlur)||void 0===e?void 0:e.call(this,this)}}),isLeaf:!0,selectable:!1,icon:n({type:this.forNode})}}}class O extends k{constructor({onAddItem:e}){super(),this.name="/",this.path="/",this.parent=void 0,this.children=[],this.addItemHandler=e}serialize(e,t,n){const i=this.children.map((i=>i.serialize(e,t,n)));return{type:"Root",key:this.path,title:e({name:this.name,onAddFileMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"File"})},onAddDirMouseDown:e=>{this.addItemHandler({event:e,dir:this,type:"Dir"})}}),children:F(i)}}}class N extends k{constructor({parent:e}){super(),this.name="empty-node",this.parent=e,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"Empty",key:this.path,title:"Empty Directory",isLeaf:!0,disabled:!0}}}class _{constructor(){this.logger=new n("Filesystem"),this.root=new O({onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})}),this.startingPrintIndent=0,this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}removeAllListeners(){this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}addListener(e,t){switch(e){case"onNewItemConfirm":this.onNewItemConfirmLs.push(t);break;case"onDirsChange":this.onDirsChangeLs.push(t);break;case"onFileContent":this.onFileContentLs.push(t);break;case"onShowPrompt":this.onShowPromptLs.push(t);break;default:throw new Error(`Unknown event type: ${e}`)}}removeListener(e,t){switch(e){case"onNewItemConfirm":this.onNewItemConfirmLs=this.onNewItemConfirmLs.filter((e=>e!==t));break;case"onDirsChange":this.onDirsChangeLs=this.onDirsChangeLs.filter((e=>e!==t));break;case"onFileContent":this.onFileContentLs=this.onFileContentLs.filter((e=>e!==t));break;case"onShowPrompt":this.onShowPromptLs=this.onShowPromptLs.filter((e=>e!==t));break;default:throw new Error(`Unknown event type: ${e}`)}}addNodeToDir(e,t){this.logger.log("Adding node to dir",{dirPath:e,node:t});let n=this.find(e);if(n||(this.logger.log("Dir not found, will make all",{dirPath:e}),n=this.mkAll(e)),!n)throw new Error("dirNode is undefined");if(!(n instanceof O||n instanceof P))throw new Error(`Node at '${e}' is not a directory or a root node`);if(n.children.some((e=>e.name===t.name)))return;let i;i="Dir"===t.type?new P({name:t.name,parent:n,onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})}):new x({name:t.name,parent:n}),1===n.children.length&&n.children[0]instanceof N?n.children=[i]:n.children.push(i),this.notifyOnDirsChangeLs({dirPaths:[e]})}removeNodeFromDir(e,t){this.logger.log("Remove node from dir",{dirPath:e,nodeName:t.name});const n=this.find(e);if(!n)throw new Error(`No node with path '${e}'`);if(!(n instanceof O||n instanceof P))throw new Error(`Node at '${e}' is not a directory or root node`);const i=n.children.length;n.children=n.children.filter((e=>e.name!==t.name));i!==n.children.length?(0===n.children.length&&(n.children=[new N({parent:n})]),this.notifyOnDirsChangeLs({dirPaths:[e]})):this.logger.warn("Node not found in dir",{dirPath:e,nodeName:t.name})}setFileContent(e){this.logger.log("Update file content",e),this.onFileContentLs.forEach((t=>t(e)))}setDirsContent(e){this.logger.log("Set dirs content",e);for(const t of e){let e=this.find(t.dirPath);if(e||(this.logger.log("Dir not found, will make all",{dirPath:t.dirPath}),e=this.mkAll(t.dirPath)),!e)throw new Error("dirNode is undefined");if(!(e instanceof O||e instanceof P))throw new Error(`Node at '${t.dirPath}' is not a directory or a root node`);const n=e.children.find((e=>e instanceof L));if(t.content.length){const n=[];for(const i of t.content){let t;t="Dir"===i.type?new P({name:i.name,parent:e,onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})}):new x({name:i.name,parent:e}),n.push(t)}e.children=n}else e.children=[new N({parent:e})];n&&e.children.push(n)}this.notifyOnDirsChangeLs({dirPaths:e.map((e=>e.dirPath))})}showPrompt(e){const{event:t,parent:n,type:i}=e;if(this.logger.log("Show prompt",{parent:n,type:i}),n.children.some((e=>e instanceof L)))return;t.preventDefault();const s=new L({parent:n,forNode:i,onConfirm:((e,t)=>{if(this.logger.log("Prompt confirm",{prompt:e,name:t}),!t)return;const n=e.parent.path,s=w.join(e.parent.path,t);this.removeFromParent(e),this.notifyOnDirsChangeLs({dirPaths:[n]}),this.notifyOnNewItemConfirmLs({fullPath:s,name:t,type:i})}).bind(this),onBlur:(e=>{this.logger.log("Prompt blur",{prompt:e});const t=e.parent.path;this.removeFromParent(e),this.notifyOnDirsChangeLs({dirPaths:[t]})}).bind(this)});n.children.push(s),this.notifyOnDirsChangeLs({dirPaths:[s.parent.path]}),this.notifyOnShowPromptLs({dirPath:s.parent.path})}serialize(e,t,n){return this.logger.log("Serialize"),[this.root.serialize(e,t,n)]}print(e=this.root,t=this.startingPrintIndent){const n="  ".repeat(t);console.log(n+e.path,`(${e.name})`);for(const i of e.children)i instanceof P?this.print(i,t+1):console.log(n+"  "+i.path,`(${i.name})`)}find(e,t=this.root){if(this.logger.log("Find (recursion)",{currentPath:t.path,targetPath:e}),e=w.normalize(e),t.path===e)return t;const n=e.split(w.sep).length-1;if(!(t.level>n)&&(t instanceof O||t instanceof P))for(const n of t.children){const t=this.find(e,n);if(t)return t}}mkDir(e){this.logger.log("Make dir",e);const t=this.find(e.parentPath);if(!t)throw new Error(`Parent dir '${e.parentPath}' not found`);if(!(t instanceof O||t instanceof P))throw new Error("Parent is not a dir or root");const n=new P({parent:t,name:e.name,onAddItem:({event:e,dir:t,type:n})=>this.showPrompt({event:e,parent:t,type:n})});return t.children.push(n),n}mkAll(e){this.logger.log("Make all",e);const t=e.split(w.sep);let n,i="/";for(const e of t)if(i=w.join(i,e),!this.find(i)){const t=w.dirname(i);n=this.mkDir({parentPath:t,name:e})}return n}removeFromParent(e){const{parent:t}=e;(t instanceof O||t instanceof P)&&(t.children=t.children.filter((t=>t!==e))),e.parent=void 0}notifyOnShowPromptLs(e){this.logger.log("Notify on show prompt",e),this.onShowPromptLs.forEach((t=>t(e)))}notifyOnNewItemConfirmLs(e){this.logger.log("Notify on new item confirm",e),this.onNewItemConfirmLs.forEach((t=>t(e)))}notifyOnDirsChangeLs(e){this.logger.log("Notify on dirs change",e),this.onDirsChangeLs.forEach((t=>t(e)))}}function $(e){return function(e){const t=Array.from(e).reduce(((e,t)=>0|31*e+t.charCodeAt(0)),0);return("0000000"+(t>>>0).toString(16)).slice(-8)}(e)}!function(e){e[e.Stdout=0]="Stdout",e[e.Stderr=1]="Stderr"}(I||(I={}));class A{constructor(e,t){this.contextID=e,this.templateID=t,this.output=[],this.filesystem=new _,this.isReady=!1,this.id=`${e}_${$(t)}`}restart(){this.output=[],this.isReady=!1,this.filesystem.setDirsContent([{dirPath:"/",content:[]}])}logOutput(e,t){this.output=[...this.output,{message:e,source:t}]}}function M(e,{environmentID:t,templateID:n}){const i={type:h.RunningEnvironment.Start,payload:{environmentID:t,templateID:n}};e.send(i)}class W{constructor(e){var t,i;this.opts=e,this.fsWriteSubscribers=[],this.fileContentSubscribers=[],this.logger=new n(`EvaluationContext [${e.templateID}]`,e.debug),this.env=new A(this.contextID,e.templateID);this.unsubscribeConnHandler=this.opts.conn.subscribeHandler({onOpen:e=>this.handleConnectionOpen(e),onMessage:e=>this.handleConnectionMessage(e),onClose:()=>this.handleConnectionClose()}),this.opts.conn.isOpen&&this.opts.conn.sessionID&&this.handleConnectionOpen(this.opts.conn.sessionID),this.opts.conn.isClosed&&this.handleConnectionClose(),M(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID}),null===(i=(t=this.opts).onEnvChange)||void 0===i||i.call(t,this.env)}get contextID(){return this.opts.contextID}restart(){this.logger.log("Restart",this.opts.conn.sessionID),this.env.restart(),M(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID})}destroy(){this.logger.log("Destroy"),this.unsubscribeConnHandler(),this.fsWriteSubscribers=[],this.fileContentSubscribers=[]}getFile({path:e}){return i(this,void 0,void 0,(function*(){let t;this.logger.log("Get file",{filepath:e});const n=new Promise(((e,n)=>{t=e,setTimeout((()=>{n("Timeout")}),1e4)})),i=n=>{n.path.endsWith(e)&&t(n.content)};this.subscribeFileContent(i),function(e,{environmentID:t,path:n}){const i={type:h.RunningEnvironment.GetFile,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e});try{return yield n}catch(t){throw new Error(`Error retrieving file ${e}: ${t}`)}finally{this.unsubscribeFileContent(i)}}))}deleteFile({path:e}){this.logger.log("Delete file",{filepath:e}),function(e,{environmentID:t,path:n}){const i={type:h.RunningEnvironment.RemoveFile,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e})}updateFile({path:e,content:t}){return i(this,void 0,void 0,(function*(){let n;this.logger.log("Update file",{filepath:e});const i=new Promise(((e,t)=>{n=e,setTimeout((()=>{t("Timeout")}),1e4)})),s=t=>{t.path.endsWith(e)&&n()};this.subscribeFSWrite(s),function(e,{environmentID:t,path:n,content:i}){const s={type:h.RunningEnvironment.WriteFile,payload:{environmentID:t,path:n,content:i}};e.send(s)}(this.opts.conn,{environmentID:this.env.id,path:e,content:t});try{yield i}catch(t){throw new Error(`File ${e} not written to VM: ${t}`)}finally{this.unsubscribeFSWrite(s)}}))}createDir({path:e}){this.logger.log("Create dir",{filepath:e}),function(e,{environmentID:t,path:n}){const i={type:h.RunningEnvironment.CreateDir,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e})}listDir({path:e}){this.logger.log("List dir",{filepath:e}),function(e,{environmentID:t,path:n}){const i={type:h.RunningEnvironment.ListDir,payload:{environmentID:t,path:n}};e.send(i)}(this.opts.conn,{environmentID:this.env.id,path:e})}executeCommand({executionID:e,command:t}){this.logger.log("Execute shell command",{executionID:e,command:t}),function(e,{environmentID:t,executionID:n,command:i}){const s={type:h.RunningEnvironment.ExecCmd,payload:{environmentID:t,executionID:n,command:i}};e.send(s)}(this.opts.conn,{environmentID:this.env.id,executionID:e,command:t})}subscribeFileContent(e){this.fileContentSubscribers.push(e)}unsubscribeFileContent(e){const t=this.fileContentSubscribers.indexOf(e);t>-1&&this.fileContentSubscribers.splice(t,1)}subscribeFSWrite(e){this.fsWriteSubscribers.push(e)}unsubscribeFSWrite(e){const t=this.fsWriteSubscribers.indexOf(e);t>-1&&this.fsWriteSubscribers.splice(t,1)}handleConnectionOpen(e){var t,n;this.restart(),null===(n=(t=this.opts).onSessionChange)||void 0===n||n.call(t,{status:m.Connected,sessionID:e})}handleConnectionClose(){var e,t;null===(t=(e=this.opts).onSessionChange)||void 0===t||t.call(e,{status:m.Connecting})}handleConnectionMessage(e){switch(this.logger.log("Handling message from remote Runner",{message:e}),e.type){case h.RunningEnvironment.StartAck:{const t=e;this.vmenv_handleStartAck(t.payload);break}case h.RunningEnvironment.CmdOut:{const t=e;this.vmenv_handleCmdOut(t.payload);break}case h.RunningEnvironment.CmdExit:{const t=e;this.vmenv_handleCmdExit(t.payload);break}case h.RunningEnvironment.FSEventWrite:{const t=e;this.vmenv_handleFSEventWrite(t.payload);break}case h.RunningEnvironment.FileContent:{const t=e;this.vmenv_handleFileContent(t.payload);break}case h.RunningEnvironment.FSEventCreate:{const t=e;this.vmenv_handleFSEventCreate(t.payload);break}case h.RunningEnvironment.FSEventRemove:{const t=e;this.vmenv_handleFSEventRemove(t.payload);break}case h.RunningEnvironment.DirContent:{const t=e;this.vmenv_handleDirContent(t.payload);break}case h.RunningEnvironment.Stderr:{const t=e;this.vmenv_handleStderr(t.payload);break}case h.RunningEnvironment.Stdout:{const t=e;this.vmenv_handleStdout(t.payload);break}default:this.logger.warn("Unknown message type",{message:e})}}vmenv_handleFSEventCreate(e){this.logger.log('[vmenv] Handling "FSEventCreate"',e);const t=w.basename(e.path),n=w.dirname(e.path),i="Directory"===e.type?"Dir":"File";this.env.filesystem.addNodeToDir(n,{name:t,type:i})}vmenv_handleFSEventRemove(e){this.logger.log('[vmenv] Handling "FSEventRemove"',{payload:e});const t=w.basename(e.path),n=w.dirname(e.path);this.env.filesystem.removeNodeFromDir(n,{name:t})}vmenv_handleDirContent(e){this.logger.log('[vmenv] Handling "DirContent"',e);const t=[];for(const n of e.content){const e=w.basename(n.path),i="Directory"===n.type?"Dir":"File";t.push({name:e,type:i})}this.env.filesystem.setDirsContent([{dirPath:e.dirPath,content:t}])}vmenv_handleCmdExit(e){var t,n;this.logger.log('[vmenv] Handling "CmdExit"',e),void 0!==e.error&&(null===(n=(t=this.opts).onCmdOut)||void 0===n||n.call(t,{environmentID:e.environmentID,executionID:e.executionID,stderr:e.error}))}vmenv_handleFSEventWrite(e){this.logger.log('[vmenv] Handling "FSEventWrite"',e),this.fsWriteSubscribers.forEach((t=>t(e)))}vmenv_handleFileContent(e){this.logger.log('[vmenv] Handling "FileContent"',{environmentID:e.environmentID,path:e.path}),this.fileContentSubscribers.forEach((t=>t(e)))}vmenv_handleStartAck(e){var t,n;this.logger.log('[vmenv] Handling "StartAck"',{payload:e}),this.env.isReady=!0,null===(n=(t=this.opts).onEnvChange)||void 0===n||n.call(t,this.env)}vmenv_handleCmdOut(e){var t,n;this.logger.log('[vmenv] Handling "CmdOut"',e),null===(n=(t=this.opts).onCmdOut)||void 0===n||n.call(t,e)}vmenv_handleStderr(e){this.logger.log('[vmenv] Handling "Stderr"',e),this.env.logOutput(e.message,I.Stderr)}vmenv_handleStdout(e){this.logger.log('[vmenv] Handling "Stdout"',e),this.env.logOutput(e.message,I.Stdout)}}class j{constructor(){this.logger=new n("Runner"),this.conn=new u,this.sessManager=new p(this.conn)}static get obj(){return j._obj||(j._obj=new j)}get session(){return this.sessManager.session}get status(){return this.sessManager.status}reset(){this.logger.log("Reset"),this.sessManager.reset()}createContext(e){return new W(Object.assign(Object.assign({},e),{conn:this.conn}))}__debug__loadNewSession(){this.logger.log("__debug__loadNewSession"),this.sessManager.reset()}}const H=(T="1234567890abcdefghijklmnopqrstuvwxyz",z=6,()=>{let e="",t=z;for(;t--;)e+=T[Math.random()*T.length|0];return e});var T,z,G;e.DevbookStatus=void 0,(G=e.DevbookStatus||(e.DevbookStatus={})).Disconnected="Disconnected",G.Connecting="Connecting",G.Connected="Connected";class U{constructor(t){this.opts=t,this.contextID="default",this.executionID=H(),this._isDestroyed=!1,this._isEnvReady=!1,this._sessionStatus=m.Disconnected,this._status=e.DevbookStatus.Disconnected;const n=this.getURL.bind(this),i=()=>this.opts.env,s=()=>this.executionID,o=e=>this.isEnvReady=e,r=e=>this.sessionStatus=e,a=e=>this.sessionID=e;this.context=j.obj.createContext({debug:t.debug,templateID:t.env,contextID:this.contextID,onEnvChange(e){var s;e.templateID===i()&&(o(e.isReady),null===(s=t.onURLChange)||void 0===s||s.call(t,n))},onSessionChange({status:e,sessionID:i}){var s;a(i),r(e),null===(s=t.onURLChange)||void 0===s||s.call(t,n)},onCmdOut(e){var n,i;e.executionID===s()&&(void 0!==e.stdout&&(null===(n=t.onStdout)||void 0===n||n.call(t,e.stdout)),void 0!==e.stderr&&(null===(i=t.onStderr)||void 0===i||i.call(t,e.stderr)))}})}get sessionID(){return this._sessionID}set sessionID(e){this._sessionID=e}get isDestroyed(){return this._isDestroyed}set isDestroyed(e){this._isDestroyed=e,this.updateStatus()}get isEnvReady(){return this._isEnvReady}set isEnvReady(e){this._isEnvReady=e,this.updateStatus()}get sessionStatus(){return this._sessionStatus}set sessionStatus(e){this._sessionStatus=e,this.updateStatus()}get status(){return this._status}set status(e){var t,n;this._status=e,null===(n=(t=this.opts).onStatusChange)||void 0===n||n.call(t,e)}get env(){return this.context.env}get fs(){const e=this.env.filesystem;return{delete:this.deleteFile.bind(this),listDir:this.listDir.bind(this),createDir:this.createDir.bind(this),get:this.getFile.bind(this),write:this.writeFile.bind(this),addListener:e.addListener.bind(e),removeListener:e.removeListener.bind(e),serialize:e.serialize.bind(e)}}getURL(t){if(this.status===e.DevbookStatus.Connected&&this.sessionID&&this.env.isReady)return`https://${t}-${this.env.id}-${this.sessionID}.o.usedevbook.com`}runCmd(t){if(this.status!==e.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");this.executionID=H(),this.context.executeCommand({executionID:this.executionID,command:t})}destroy(){this.context.destroy(),this.isDestroyed=!0}listDir(t){if(this.status!==e.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.listDir({path:t})}createDir(t){if(this.status!==e.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.createDir({path:t})}deleteFile(t){if(this.status!==e.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.deleteFile({path:t})}getFile(t){if(this.status!==e.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.getFile({path:t})}writeFile(t,n){if(this.status!==e.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.updateFile({path:t,content:n})}updateStatus(){if(this.isDestroyed)return void(this.status!==e.DevbookStatus.Disconnected&&(this.status=e.DevbookStatus.Disconnected));let t;switch(this.sessionStatus){case m.Disconnected:t=e.DevbookStatus.Disconnected;break;case m.Connecting:t=e.DevbookStatus.Connecting;break;case m.Connected:if(!this.isEnvReady){t=e.DevbookStatus.Connecting;break}t=e.DevbookStatus.Connected}this.status=t}}e.Devbook=U,e.useDevbook=function({env:n,debug:i,port:s}){const[o,r]=t.useState(),[a,h]=t.useState(e.DevbookStatus.Disconnected),[l,d]=t.useState([]),[c,u]=t.useState([]),[g,m]=t.useState(),v=t.useCallback((e=>{o&&(u([]),d([]),o.runCmd(e))}),[o]);return t.useEffect((function(){const e=new U({debug:i,env:n,onStatusChange(e){h(e)},onStderr(e){d((t=>[...t,e]))},onStdout(e){u((t=>[...t,e]))},onURLChange(e){s&&m(e(s))}});return u([]),d([]),m(void 0),r(e),()=>{e.destroy()}}),[n,i,s]),{stderr:l,stdout:c,runCmd:v,status:a,fs:null==o?void 0:o.fs,url:g}},Object.defineProperty(e,"__esModule",{value:!0})}));
+  ***************************************************************************** */function i(t,e,n,i){return new(n||(n=Promise))((function(s,o){function r(t){try{h(i.next(t))}catch(t){o(t)}}function a(t){try{h(i.throw(t))}catch(t){o(t)}}function h(t){var e;t.done?s(t.value):(e=t.value,e instanceof n?e:new n((function(t){t(e)}))).then(r,a)}h((i=i.apply(t,e||[])).next())}))}function s(t){return new Promise((e=>setTimeout(e,t)))}var o,r,a;!function(t){t.Error="Runner.Error"}(o||(o={})),function(t){t.Start="RunningEnvironment.Start",t.StartAck="RunningEnvironment.StartAck",t.Eval="RunningEnvironment.Eval",t.FSEventCreate="RunningEnvironment.FSEventCreate",t.FSEventRemove="RunningEnvironment.FSEventRemove",t.FSEventWrite="RunningEnvironment.FSEventWrite",t.CreateDir="RunningEnvironment.CreateDir",t.ListDir="RunningEnvironment.ListDir",t.WriteFile="RunningEnvironment.WriteFile",t.GetFile="RunningEnvironment.GetFile",t.RemoveFile="RunningEnvironment.RemoveFile",t.DirContent="RunningEnvironment.DirContent",t.FileContent="RunningEnvironment.FileContent",t.Stdout="RunningEnvironment.Stdout",t.Stderr="RunningEnvironment.Stderr",t.ExecCmd="RunningEnvironment.ExecCmd",t.KillCmd="RunningEnvironment.KillCmd",t.ListRunningCmds="RunningEnvironment.ListRunningCmds",t.CmdOut="RunningEnvironment.CmdOut",t.CmdExit="RunningEnvironment.CmdExit",t.RunningCmds="RunningEnvironment.RunningCmds",t.RunCode="RunningEnvironment.Run"}(r||(r={})),function(t){t.Error="CodeCell.Error"}(a||(a={}));const h={Runner:o,RunningEnvironment:r,CodeCell:a},l="orchestrator.usedevbook.com",c="dbk_sdk_session_id",d=2500;class u{constructor(){this.url=`wss://${l}`,this.logger=new n("WebSocketConnection"),this.handlers=[]}get state(){var t;return null===(t=this.client)||void 0===t?void 0:t.readyState}get isClosed(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSED}get isClosing(){if(void 0!==this.client)return this.client.readyState===this.client.CLOSING}get isOpen(){if(void 0!==this.client)return this.client.readyState===this.client.OPEN}get isConnecting(){if(void 0!==this.client)return this.client.readyState===this.client.CONNECTING}subscribeHandler(t){return this.handlers.push(t),()=>{this.handlers=this.handlers.filter((e=>e!==t))}}connect(t){(!this.client||this.client.readyState!==this.client.CONNECTING&&this.client.readyState!==this.client.OPEN)&&(t||this.sessionID?(t?(this.logger.log(`Will try to connect to session "${t}"`),this.sessionID=t):!t&&this.sessionID&&this.logger.log(`Will try to connect to previous session "${this.sessionID}"`),this.client=new WebSocket(`${this.url}/session/ws/${this.sessionID}`),this.client.onopen=()=>this.handleOpen(this.sessionID),this.client.onmessage=t=>{this.logger.log("Received (raw)",{msg:t}),this.handleMessage(t)},this.client.onerror=t=>this.handleError(t),this.client.onclose=t=>this.handleClose(t)):this.logger.error("Cannot connect, no session ID passed to the function and no session ID saved from the previous session"))}send(t){this.client&&this.client.readyState===this.client.OPEN?(this.logger.log("Send",t),this._send(t)):this.logger.warn("Trying to send a message while not being in the `OPEN` state or without established connection, message will be discarded",t)}close(){var t;this.logger.log("Closing connection"),null===(t=this.client)||void 0===t||t.close(1e3)}handleOpen(t){var e;this.logger.log("Connection opened",{readyState:null===(e=this.client)||void 0===e?void 0:e.readyState}),this.handlers.forEach((e=>e.onOpen(t)))}_send(t){var e,n;null===(e=this.client)||void 0===e||e.send((n=t,JSON.stringify(n,(()=>{const t=new WeakSet;return(e,n)=>{if("object"==typeof n&&null!==n){if(t.has(n))return;t.add(n)}return n}})(),2)))}handleClose(t){return i(this,void 0,void 0,(function*(){this.logger.log("Connection closed",t),this.handlers.forEach((t=>t.onClose())),this.logger.log("Will try to reconnect in 2.5s"),yield s(2500),this.connect()}))}handleError(t){var e;this.logger.error("Connection error",t),null===(e=this.client)||void 0===e||e.close()}handleMessage(t){if(!t.data)return void this.logger.error("Message has empty data field",t);const e=JSON.parse(t.data);if(!e.type)return void this.logger.error("Message has no type",e);const n=e;Object.values(h.RunningEnvironment).includes(n.type)||Object.values(h.Runner).includes(n.type)||Object.values(h.CodeCell).includes(n.type)?n.type!==h.Runner.Error?(this.logger.log("Received (parsed)",n),this.handlers.forEach((t=>t.onMessage(n)))):this.logger.error("Runner error",n):this.logger.error('Message "type" field has unexpected value',n)}}var g,m;!function(t){t.Ok="Ok",t.Terminated="Terminated"}(g||(g={}));class v{constructor(t,e=new Date){this.id=t,this.lastPing=e,this.logger=new n("RunnerSession"),this.url=`https://${l}`}ping(){return i(this,void 0,void 0,(function*(){this.logger.log(`Pinging session "${this.id}"`);const t=JSON.stringify({sessionID:this.id});try{const e=yield fetch(`${this.url}/session/ping`,{method:"POST",headers:{"Content-Type":"application/json"},body:t}),n=yield e.json();if(!e.ok)throw this.logger.error(e.headers,n),new Error("Non-OK response when trying to ping active Runner session");if(n.status===g.Terminated)throw new Error(`[keepAlive]: Session '${this.id}' is terminated`);this.lastPing=new Date}catch(t){throw this.logger.error(t),new Error("Failed to ping active Runner session")}}))}}!function(t){t.Connected="Connected",t.Connecting="Connecting",t.Disconnected="Disconnected"}(m||(m={}));class p{constructor(t){this.conn=t,this.logger=new n("SessionManager"),this.url=`https://${l}`,this.userActivity=Promise.resolve(),this.isGettingSessionActive=!1,this.status=m.Disconnected,this.logger.log("Initialize"),this.getSession()}get cachedSessionID(){return sessionStorage.getItem(c)}set cachedSessionID(t){null===t?(this.logger.log("Cleared last sessionID"),sessionStorage.removeItem(c)):(this.logger.log(`Saved sessionID "${t}" as last sessionID`),sessionStorage.setItem(c,t))}stop(){var t;console.log("stopping session"),null===(t=this.startActivity)||void 0===t||t.call(this),this.userActivity=new Promise((t=>{this.startActivity=t})),this.reset()}start(){var t;console.log("starting session"),null===(t=this.startActivity)||void 0===t||t.call(this)}reset(){this.logger.log("Reset"),this.status=m.Disconnected,this.cachedSessionID=null,this.conn.close(),this.session=void 0}getSession(){var t;return i(this,void 0,void 0,(function*(){if(!this.isGettingSessionActive)for(this.isGettingSessionActive=!0;;){this.status=m.Connecting;try{const e=this.cachedSessionID?`${this.url}/session/${this.cachedSessionID}`:`${this.url}/session`;this.cachedSessionID?this.logger.log(`Restoring old Runner session "${this.cachedSessionID}"`):this.logger.log("Acquiring new Runner session");const n=yield fetch(e),i=yield n.json();if(!n.ok){this.logger.error("Non-OK response when trying to ping active Runner session. Will try again in 2.5s",n.headers,i),yield s(d);continue}for(this.session=new v(i.sessionID),this.logger.log(`Acquired session "${this.session.id}"`),this.cachedSessionID=this.session.id,this.status=m.Connected,this.conn.connect(this.session.id),this.logger.log(`Started pinging session "${this.session.id}"`);this.session;)try{yield this.userActivity,yield this.session.ping(),yield s(5e3)}catch(t){this.logger.error(`Failed to ping session "${this.session.id}"`,t);break}this.logger.log(`Stopped pinging session "${null===(t=this.session)||void 0===t?void 0:t.id}"`),this.session=void 0,this.status=m.Disconnected,this.conn.close()}catch(t){this.logger.error("Failed to acquire Runner session. Will try again in 2.5s",t),yield s(d)}}}))}}function f(t,e){for(var n=0,i=t.length-1;i>=0;i--){var s=t[i];"."===s?t.splice(i,1):".."===s?(t.splice(i,1),n++):n&&(t.splice(i,1),n--)}if(e)for(;n--;n)t.unshift("..");return t}var D=/^(\/?|)([\s\S]*?)((?:\.{1,2}|[^\/]+?|)(\.[^.\/]*|))(?:[\/]*)$/,y=function(t){return D.exec(t).slice(1)};function C(){for(var t="",e=!1,n=arguments.length-1;n>=-1&&!e;n--){var i=n>=0?arguments[n]:"/";if("string"!=typeof i)throw new TypeError("Arguments to path.resolve must be strings");i&&(t=i+"/"+t,e="/"===i.charAt(0))}return(e?"/":"")+(t=f(E(t.split("/"),(function(t){return!!t})),!e).join("/"))||"."}function S(t){var e=b(t),n="/"===R(t,-1);return(t=f(E(t.split("/"),(function(t){return!!t})),!e).join("/"))||e||(t="."),t&&n&&(t+="/"),(e?"/":"")+t}function b(t){return"/"===t.charAt(0)}var w={extname:function(t){return y(t)[3]},basename:function(t,e){var n=y(t)[2];return e&&n.substr(-1*e.length)===e&&(n=n.substr(0,n.length-e.length)),n},dirname:function(t){var e=y(t),n=e[0],i=e[1];return n||i?(i&&(i=i.substr(0,i.length-1)),n+i):"."},sep:"/",delimiter:":",relative:function(t,e){function n(t){for(var e=0;e<t.length&&""===t[e];e++);for(var n=t.length-1;n>=0&&""===t[n];n--);return e>n?[]:t.slice(e,n-e+1)}t=C(t).substr(1),e=C(e).substr(1);for(var i=n(t.split("/")),s=n(e.split("/")),o=Math.min(i.length,s.length),r=o,a=0;a<o;a++)if(i[a]!==s[a]){r=a;break}var h=[];for(a=r;a<i.length;a++)h.push("..");return(h=h.concat(s.slice(r))).join("/")},join:function(){var t=Array.prototype.slice.call(arguments,0);return S(E(t,(function(t,e){if("string"!=typeof t)throw new TypeError("Arguments to path.join must be strings");return t})).join("/"))},isAbsolute:b,normalize:S,resolve:C};function E(t,e){if(t.filter)return t.filter(e);for(var n=[],i=0;i<t.length;i++)e(t[i],i,t)&&n.push(t[i]);return n}var I,R="b"==="ab".substr(-1)?function(t,e,n){return t.substr(e,n)}:function(t,e,n){return e<0&&(e=t.length+e),t.substr(e,n)};class k{get level(){return w.normalize(this.path).split(w.sep).length-1}}function F(t){return t.sort(((t,e)=>"Prompt"===t.type?-2:t.type!==e.type?"Dir"===t.type?-1:"Dir"===e.type?1:0:t.key.localeCompare(e.key))),t}class _ extends k{constructor({name:t,parent:e,onAddItem:n}){super(),this.children=[],this.name=t,this.parent=e,this.addItemHandler=n,this.path=w.join(this.parent.path,this.name)}removeChildNode(t){this.children=this.children.filter((e=>e!==t))}serialize(t,e,n){const i=this.children.map((i=>i.serialize(t,e,n)));return{type:"Dir",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:F(i)}}}class P extends k{constructor({name:t,parent:e}){super(),this.name=t,this.parent=e,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"File",key:this.path,title:this.name,isLeaf:!0}}}class x extends k{constructor({parent:t,forNode:e,onConfirm:n,onBlur:i}){super(),this.name="name-prompt",this.parent=t,this.forNode=e,this.path=w.join(t.path,this.name),this.onConfirm=n,this.onBlur=i}serialize(t,e,n){return{type:"Prompt",key:this.path,title:e({onConfirm:t=>{var e;return null===(e=this.onConfirm)||void 0===e?void 0:e.call(this,this,t)},onBlur:()=>{var t;return null===(t=this.onBlur)||void 0===t?void 0:t.call(this,this)}}),isLeaf:!0,selectable:!1,icon:n({type:this.forNode})}}}class L extends k{constructor({onAddItem:t}){super(),this.name="/",this.path="/",this.parent=void 0,this.children=[],this.addItemHandler=t}serialize(t,e,n){const i=this.children.map((i=>i.serialize(t,e,n)));return{type:"Root",key:this.path,title:t({name:this.name,onAddFileMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"File"})},onAddDirMouseDown:t=>{this.addItemHandler({event:t,dir:this,type:"Dir"})}}),children:F(i)}}}class O extends k{constructor({parent:t}){super(),this.name="empty-node",this.parent=t,this.path=w.join(this.parent.path,this.name)}serialize(){return{type:"Empty",key:this.path,title:"Empty Directory",isLeaf:!0,disabled:!0}}}class N{constructor(){this.logger=new n("Filesystem"),this.root=new L({onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}),this.startingPrintIndent=0,this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}removeAllListeners(){this.onNewItemConfirmLs=[],this.onDirsChangeLs=[],this.onFileContentLs=[],this.onShowPromptLs=[]}addListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs.push(e);break;case"onDirsChange":this.onDirsChangeLs.push(e);break;case"onFileContent":this.onFileContentLs.push(e);break;case"onShowPrompt":this.onShowPromptLs.push(e);break;default:throw new Error(`Unknown event type: ${t}`)}}removeListener(t,e){switch(t){case"onNewItemConfirm":this.onNewItemConfirmLs=this.onNewItemConfirmLs.filter((t=>t!==e));break;case"onDirsChange":this.onDirsChangeLs=this.onDirsChangeLs.filter((t=>t!==e));break;case"onFileContent":this.onFileContentLs=this.onFileContentLs.filter((t=>t!==e));break;case"onShowPrompt":this.onShowPromptLs=this.onShowPromptLs.filter((t=>t!==e));break;default:throw new Error(`Unknown event type: ${t}`)}}addNodeToDir(t,e){this.logger.log("Adding node to dir",{dirPath:t,node:e});let n=this.find(t);if(n||(this.logger.log("Dir not found, will make all",{dirPath:t}),n=this.mkAll(t)),!n)throw new Error("dirNode is undefined");if(!(n instanceof L||n instanceof _))throw new Error(`Node at '${t}' is not a directory or a root node`);if(n.children.some((t=>t.name===e.name)))return;let i;i="Dir"===e.type?new _({name:e.name,parent:n,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new P({name:e.name,parent:n}),1===n.children.length&&n.children[0]instanceof O?n.children=[i]:n.children.push(i),this.notifyOnDirsChangeLs({dirPaths:[t]})}removeNodeFromDir(t,e){this.logger.log("Remove node from dir",{dirPath:t,nodeName:e.name});const n=this.find(t);if(!n)throw new Error(`No node with path '${t}'`);if(!(n instanceof L||n instanceof _))throw new Error(`Node at '${t}' is not a directory or root node`);const i=n.children.length;n.children=n.children.filter((t=>t.name!==e.name));i!==n.children.length?(0===n.children.length&&(n.children=[new O({parent:n})]),this.notifyOnDirsChangeLs({dirPaths:[t]})):this.logger.warn("Node not found in dir",{dirPath:t,nodeName:e.name})}setFileContent(t){this.logger.log("Update file content",t),this.onFileContentLs.forEach((e=>e(t)))}setDirsContent(t){this.logger.log("Set dirs content",t);for(const e of t){let t=this.find(e.dirPath);if(t||(this.logger.log("Dir not found, will make all",{dirPath:e.dirPath}),t=this.mkAll(e.dirPath)),!t)throw new Error("dirNode is undefined");if(!(t instanceof L||t instanceof _))throw new Error(`Node at '${e.dirPath}' is not a directory or a root node`);const n=t.children.find((t=>t instanceof x));if(e.content.length){const n=[];for(const i of e.content){let e;e="Dir"===i.type?new _({name:i.name,parent:t,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})}):new P({name:i.name,parent:t}),n.push(e)}t.children=n}else t.children=[new O({parent:t})];n&&t.children.push(n)}this.notifyOnDirsChangeLs({dirPaths:t.map((t=>t.dirPath))})}showPrompt(t){const{event:e,parent:n,type:i}=t;if(this.logger.log("Show prompt",{parent:n,type:i}),n.children.some((t=>t instanceof x)))return;e.preventDefault();const s=new x({parent:n,forNode:i,onConfirm:((t,e)=>{if(this.logger.log("Prompt confirm",{prompt:t,name:e}),!e)return;const n=t.parent.path,s=w.join(t.parent.path,e);this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[n]}),this.notifyOnNewItemConfirmLs({fullPath:s,name:e,type:i})}).bind(this),onBlur:(t=>{this.logger.log("Prompt blur",{prompt:t});const e=t.parent.path;this.removeFromParent(t),this.notifyOnDirsChangeLs({dirPaths:[e]})}).bind(this)});n.children.push(s),this.notifyOnDirsChangeLs({dirPaths:[s.parent.path]}),this.notifyOnShowPromptLs({dirPath:s.parent.path})}serialize(t,e,n){return this.logger.log("Serialize"),[this.root.serialize(t,e,n)]}print(t=this.root,e=this.startingPrintIndent){const n="  ".repeat(e);console.log(n+t.path,`(${t.name})`);for(const i of t.children)i instanceof _?this.print(i,e+1):console.log(n+"  "+i.path,`(${i.name})`)}find(t,e=this.root){if(this.logger.log("Find (recursion)",{currentPath:e.path,targetPath:t}),t=w.normalize(t),e.path===t)return e;const n=t.split(w.sep).length-1;if(!(e.level>n)&&(e instanceof L||e instanceof _))for(const n of e.children){const e=this.find(t,n);if(e)return e}}mkDir(t){this.logger.log("Make dir",t);const e=this.find(t.parentPath);if(!e)throw new Error(`Parent dir '${t.parentPath}' not found`);if(!(e instanceof L||e instanceof _))throw new Error("Parent is not a dir or root");const n=new _({parent:e,name:t.name,onAddItem:({event:t,dir:e,type:n})=>this.showPrompt({event:t,parent:e,type:n})});return e.children.push(n),n}mkAll(t){this.logger.log("Make all",t);const e=t.split(w.sep);let n,i="/";for(const t of e)if(i=w.join(i,t),!this.find(i)){const e=w.dirname(i);n=this.mkDir({parentPath:e,name:t})}return n}removeFromParent(t){const{parent:e}=t;(e instanceof L||e instanceof _)&&(e.children=e.children.filter((e=>e!==t))),t.parent=void 0}notifyOnShowPromptLs(t){this.logger.log("Notify on show prompt",t),this.onShowPromptLs.forEach((e=>e(t)))}notifyOnNewItemConfirmLs(t){this.logger.log("Notify on new item confirm",t),this.onNewItemConfirmLs.forEach((e=>e(t)))}notifyOnDirsChangeLs(t){this.logger.log("Notify on dirs change",t),this.onDirsChangeLs.forEach((e=>e(t)))}}function $(t){return function(t){const e=Array.from(t).reduce(((t,e)=>0|31*t+e.charCodeAt(0)),0);return("0000000"+(e>>>0).toString(16)).slice(-8)}(t)}!function(t){t[t.Stdout=0]="Stdout",t[t.Stderr=1]="Stderr"}(I||(I={}));class A{constructor(t,e){this.contextID=t,this.templateID=e,this.output=[],this.filesystem=new N,this.isReady=!1,this.id=`${t}_${$(e)}`}restart(){this.output=[],this.isReady=!1,this.filesystem.setDirsContent([{dirPath:"/",content:[]}])}logOutput(t,e){this.output=[...this.output,{message:t,source:e}]}}function M(t,{environmentID:e,templateID:n}){const i={type:h.RunningEnvironment.Start,payload:{environmentID:e,templateID:n}};t.send(i)}class j{constructor(t){var e,i;this.opts=t,this.fsWriteSubscribers=[],this.fileContentSubscribers=[],this.logger=new n(`EvaluationContext [${t.templateID}]`,t.debug),this.env=new A(this.contextID,t.templateID);this.unsubscribeConnHandler=this.opts.conn.subscribeHandler({onOpen:t=>this.handleConnectionOpen(t),onMessage:t=>this.handleConnectionMessage(t),onClose:()=>this.handleConnectionClose()}),this.opts.conn.isOpen&&this.opts.conn.sessionID&&this.handleConnectionOpen(this.opts.conn.sessionID),this.opts.conn.isClosed&&this.handleConnectionClose(),M(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID}),null===(i=(e=this.opts).onEnvChange)||void 0===i||i.call(e,this.env)}get contextID(){return this.opts.contextID}restart(){this.logger.log("Restart",this.opts.conn.sessionID),this.env.restart(),M(this.opts.conn,{environmentID:this.env.id,templateID:this.env.templateID})}destroy(){this.logger.log("Destroy"),this.unsubscribeConnHandler(),this.fsWriteSubscribers=[],this.fileContentSubscribers=[]}getFile({path:t}){return i(this,void 0,void 0,(function*(){let e;this.logger.log("Get file",{filepath:t});const n=new Promise(((t,n)=>{e=t,setTimeout((()=>{n("Timeout")}),1e4)})),i=n=>{n.path.endsWith(t)&&e(n.content)};this.subscribeFileContent(i),function(t,{environmentID:e,path:n}){const i={type:h.RunningEnvironment.GetFile,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t});try{return yield n}catch(e){throw new Error(`Error retrieving file ${t}: ${e}`)}finally{this.unsubscribeFileContent(i)}}))}deleteFile({path:t}){this.logger.log("Delete file",{filepath:t}),function(t,{environmentID:e,path:n}){const i={type:h.RunningEnvironment.RemoveFile,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t})}updateFile({path:t,content:e}){return i(this,void 0,void 0,(function*(){let n;this.logger.log("Update file",{filepath:t});const i=new Promise(((t,e)=>{n=t,setTimeout((()=>{e("Timeout")}),1e4)})),s=e=>{e.path.endsWith(t)&&n()};this.subscribeFSWrite(s),function(t,{environmentID:e,path:n,content:i}){const s={type:h.RunningEnvironment.WriteFile,payload:{environmentID:e,path:n,content:i}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,path:t,content:e});try{yield i}catch(e){throw new Error(`File ${t} not written to VM: ${e}`)}finally{this.unsubscribeFSWrite(s)}}))}createDir({path:t}){this.logger.log("Create dir",{filepath:t}),function(t,{environmentID:e,path:n}){const i={type:h.RunningEnvironment.CreateDir,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t})}listDir({path:t}){this.logger.log("List dir",{filepath:t}),function(t,{environmentID:e,path:n}){const i={type:h.RunningEnvironment.ListDir,payload:{environmentID:e,path:n}};t.send(i)}(this.opts.conn,{environmentID:this.env.id,path:t})}executeCommand({executionID:t,command:e}){this.logger.log("Execute shell command",{executionID:t,command:e}),function(t,{environmentID:e,executionID:n,command:i}){const s={type:h.RunningEnvironment.ExecCmd,payload:{environmentID:e,executionID:n,command:i}};t.send(s)}(this.opts.conn,{environmentID:this.env.id,executionID:t,command:e})}subscribeFileContent(t){this.fileContentSubscribers.push(t)}unsubscribeFileContent(t){const e=this.fileContentSubscribers.indexOf(t);e>-1&&this.fileContentSubscribers.splice(e,1)}subscribeFSWrite(t){this.fsWriteSubscribers.push(t)}unsubscribeFSWrite(t){const e=this.fsWriteSubscribers.indexOf(t);e>-1&&this.fsWriteSubscribers.splice(e,1)}handleConnectionOpen(t){var e,n;this.restart(),null===(n=(e=this.opts).onSessionChange)||void 0===n||n.call(e,{status:m.Connecting})}handleConnectionClose(){var t,e;null===(e=(t=this.opts).onSessionChange)||void 0===e||e.call(t,{status:m.Connecting})}handleConnectionMessage(t){switch(this.logger.log("Handling message from remote Runner",{message:t}),t.type){case h.RunningEnvironment.StartAck:{const e=t;this.vmenv_handleStartAck(e.payload);break}case h.RunningEnvironment.CmdOut:{const e=t;this.vmenv_handleCmdOut(e.payload);break}case h.RunningEnvironment.CmdExit:{const e=t;this.vmenv_handleCmdExit(e.payload);break}case h.RunningEnvironment.FSEventWrite:{const e=t;this.vmenv_handleFSEventWrite(e.payload);break}case h.RunningEnvironment.FileContent:{const e=t;this.vmenv_handleFileContent(e.payload);break}case h.RunningEnvironment.FSEventCreate:{const e=t;this.vmenv_handleFSEventCreate(e.payload);break}case h.RunningEnvironment.FSEventRemove:{const e=t;this.vmenv_handleFSEventRemove(e.payload);break}case h.RunningEnvironment.DirContent:{const e=t;this.vmenv_handleDirContent(e.payload);break}case h.RunningEnvironment.Stderr:{const e=t;this.vmenv_handleStderr(e.payload);break}case h.RunningEnvironment.Stdout:{const e=t;this.vmenv_handleStdout(e.payload);break}default:this.logger.warn("Unknown message type",{message:t})}}vmenv_handleFSEventCreate(t){this.logger.log('[vmenv] Handling "FSEventCreate"',t);const e=w.basename(t.path),n=w.dirname(t.path),i="Directory"===t.type?"Dir":"File";this.env.filesystem.addNodeToDir(n,{name:e,type:i})}vmenv_handleFSEventRemove(t){this.logger.log('[vmenv] Handling "FSEventRemove"',{payload:t});const e=w.basename(t.path),n=w.dirname(t.path);this.env.filesystem.removeNodeFromDir(n,{name:e})}vmenv_handleDirContent(t){this.logger.log('[vmenv] Handling "DirContent"',t);const e=[];for(const n of t.content){const t=w.basename(n.path),i="Directory"===n.type?"Dir":"File";e.push({name:t,type:i})}this.env.filesystem.setDirsContent([{dirPath:t.dirPath,content:e}])}vmenv_handleCmdExit(t){var e,n;this.logger.log('[vmenv] Handling "CmdExit"',t),void 0!==t.error&&(null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,{environmentID:t.environmentID,executionID:t.executionID,stderr:t.error}))}vmenv_handleFSEventWrite(t){this.logger.log('[vmenv] Handling "FSEventWrite"',t),this.fsWriteSubscribers.forEach((e=>e(t)))}vmenv_handleFileContent(t){this.logger.log('[vmenv] Handling "FileContent"',{environmentID:t.environmentID,path:t.path}),this.fileContentSubscribers.forEach((e=>e(t)))}vmenv_handleStartAck(t){var e,n,i,s;this.logger.log('[vmenv] Handling "StartAck"',{payload:t}),this.env.isReady=!0,null===(n=(e=this.opts).onEnvChange)||void 0===n||n.call(e,this.env),null===(s=(i=this.opts).onSessionChange)||void 0===s||s.call(i,{status:m.Connected,sessionID:this.opts.conn.sessionID})}vmenv_handleCmdOut(t){var e,n;this.logger.log('[vmenv] Handling "CmdOut"',t),null===(n=(e=this.opts).onCmdOut)||void 0===n||n.call(e,t)}vmenv_handleStderr(t){this.logger.log('[vmenv] Handling "Stderr"',t),this.env.logOutput(t.message,I.Stderr)}vmenv_handleStdout(t){this.logger.log('[vmenv] Handling "Stdout"',t),this.env.logOutput(t.message,I.Stdout)}}class W{constructor(){this.logger=new n("Runner"),this.conn=new u,this.sessManager=new p(this.conn)}static get obj(){return W._obj||(W._obj=new W)}get session(){return this.sessManager.session}get status(){return this.sessManager.status}reset(){this.logger.log("Reset"),this.sessManager.reset()}createContext(t){return new j(Object.assign(Object.assign({},t),{conn:this.conn}))}__internal__start(){this.sessManager.start()}__internal__stop(){this.sessManager.stop()}__debug__loadNewSession(){this.logger.log("__debug__loadNewSession"),this.sessManager.reset()}}const H=(T="1234567890abcdefghijklmnopqrstuvwxyz",z=6,()=>{let t="",e=z;for(;e--;)t+=T[Math.random()*T.length|0];return t});var T,z,G;t.DevbookStatus=void 0,(G=t.DevbookStatus||(t.DevbookStatus={})).Disconnected="Disconnected",G.Connecting="Connecting",G.Connected="Connected";class U{constructor(e){this.opts=e,this.contextID="default",this.executionID=H(),this._isDestroyed=!1,this._isEnvReady=!1,this._sessionStatus=m.Disconnected,this._status=t.DevbookStatus.Disconnected;const n=this.getURL.bind(this),i=()=>this.opts.env,s=()=>this.executionID,o=t=>this.isEnvReady=t,r=t=>this.sessionStatus=t,a=t=>this.sessionID=t;this.context=W.obj.createContext({debug:e.debug,templateID:e.env,contextID:this.contextID,onEnvChange(t){var s;t.templateID===i()&&(o(t.isReady),null===(s=e.onURLChange)||void 0===s||s.call(e,n))},onSessionChange({status:t,sessionID:i}){var s;a(i),r(t),null===(s=e.onURLChange)||void 0===s||s.call(e,n)},onCmdOut(t){var n,i;t.executionID===s()&&(void 0!==t.stdout&&(null===(n=e.onStdout)||void 0===n||n.call(e,t.stdout)),void 0!==t.stderr&&(null===(i=e.onStderr)||void 0===i||i.call(e,t.stderr)))}})}get sessionID(){return this._sessionID}set sessionID(t){this._sessionID=t}get isDestroyed(){return this._isDestroyed}set isDestroyed(t){this._isDestroyed=t,this.updateStatus()}get isEnvReady(){return this._isEnvReady}set isEnvReady(t){this._isEnvReady=t,this.updateStatus()}get sessionStatus(){return this._sessionStatus}set sessionStatus(t){this._sessionStatus=t,this.updateStatus()}get status(){return this._status}set status(t){var e,n;this._status=t,null===(n=(e=this.opts).onStatusChange)||void 0===n||n.call(e,t)}get env(){return this.context.env}get fs(){const t=this.env.filesystem;return{delete:this.deleteFile.bind(this),listDir:this.listDir.bind(this),createDir:this.createDir.bind(this),get:this.getFile.bind(this),write:this.writeFile.bind(this),addListener:t.addListener.bind(t),removeListener:t.removeListener.bind(t),serialize:t.serialize.bind(t)}}getURL(e){if(this.status===t.DevbookStatus.Connected&&this.sessionID&&this.env.isReady)return`https://${e}-${this.env.id}-${this.sessionID}.o.usedevbook.com`}runCmd(e){if(this.status!==t.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");this.executionID=H(),this.context.executeCommand({executionID:this.executionID,command:e})}destroy(){this.context.destroy(),this.isDestroyed=!0}__internal__start(){W.obj.__internal__start()}__internal__stop(){W.obj.__internal__stop()}listDir(e){if(this.status!==t.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.listDir({path:e})}createDir(e){if(this.status!==t.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.createDir({path:e})}deleteFile(e){if(this.status!==t.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.deleteFile({path:e})}getFile(e){if(this.status!==t.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.getFile({path:e})}writeFile(e,n){if(this.status!==t.DevbookStatus.Connected)throw new Error("Not connected to the VM yet.");return this.context.updateFile({path:e,content:n})}updateStatus(){if(this.isDestroyed)return void(this.status!==t.DevbookStatus.Disconnected&&(this.status=t.DevbookStatus.Disconnected));let e;switch(this.sessionStatus){case m.Disconnected:e=t.DevbookStatus.Disconnected;break;case m.Connecting:e=t.DevbookStatus.Connecting;break;case m.Connected:if(!this.isEnvReady){e=t.DevbookStatus.Connecting;break}e=t.DevbookStatus.Connected}this.status=e}}t.Devbook=U,t.useDevbook=function({env:n,debug:i,port:s}){const[o,r]=e.useState(),[a,h]=e.useState(t.DevbookStatus.Disconnected),[l,c]=e.useState([]),[d,u]=e.useState([]),[g,m]=e.useState(),v=e.useCallback((t=>{o&&(u([]),c([]),o.runCmd(t))}),[o]);return e.useEffect((function(){const t=new U({debug:i,env:n,onStatusChange(t){h(t)},onStderr(t){c((e=>[...e,t]))},onStdout(t){u((e=>[...e,t]))},onURLChange(t){s&&m(t(s))}});return u([]),c([]),m(void 0),r(t),()=>{t.destroy()}}),[n,i,s]),{stderr:l,stdout:d,runCmd:v,status:a,fs:null==o?void 0:o.fs,url:g}},Object.defineProperty(t,"__esModule",{value:!0})}));
 //# sourceMappingURL=index.js.map

package.json

 {
   "name": "@devbookhq/sdk",
-  "version": "1.0.10",
+  "version": "1.0.11",
   "description": "Devbook allows visitors of your docs to interact with and execute any code snippet or shell command in a private VM",
@@ -5,0 +5,0 @@ "homepage": "https://usedevbook.com",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

539601

increased by1.27%

Lines of code

4081

increased by1.09%

No dependency changes