github_mirrors/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2025-02-02 14:18:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

dev: async await for puter-exec

Browse Source
This commit is contained in:
KernelDeimos 2025-01-30 13:37:15 -05:00
parent d0eca6dafb
commit af3d732fc4
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/puter-js/src/modules/Exec.js
View File

@ -1,3 +1,4 @@
import putility from '@heyputer/putility';
import * as utils from '../lib/utils.js'; import * as utils from '../lib/utils.js';
export default class Exec { export default class Exec {
@ -11,7 +12,18 @@ export default class Exec {
// Exec Interface // Exec Interface
async exec (...args) { async exec (...args) {
return await utils.make_driver_method([ const socket = puter.fs.socket;
const tokenPromise = new putility.libs.promise.TeePromise();
const resultPromise = new putility.libs.promise.TeePromise();
const listener = async result => {
const token = await tokenPromise;
if ( result.id !== token ) return;
resultPromise.resolve(result);
socket.off('submission.done', listener);
};
socket.on('submission.done', listener);
const { token } = await utils.make_driver_method([
'runtime', 'code', 'stdin', 'runtime', 'code', 'stdin',
], 'puter-exec', undefined, 'exec', { ], 'puter-exec', undefined, 'exec', {
transform: async (result) => { transform: async (result) => {
@ -26,6 +38,8 @@ export default class Exec {
return result; return result;
} }
}).call(this, ...args); }).call(this, ...args);
tokenPromise.resolve(token);
return await resultPromise;
} }
// Internal // Internal