File size: 1,833 Bytes
bc20498 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
'use strict';
const { dedent } = require('../utils.js');
const { io } = require('./_io.js');
const loader = new WeakMap();
exports.loader = loader;
// REQUIRES INTEGRATION TEST
/* c8 ignore start */
const registerJSModule = (interpreter, name, value) => {
if (name === 'polyscript') {
value.lazy_py_modules = async (...packages) => {
await loader.get(interpreter)(packages);
return packages.map(name => interpreter.pyimport(name));
};
}
interpreter.registerJsModule(name, value);
};
exports.registerJSModule = registerJSModule;
const getFormat = (path, url) => {
if (path.endsWith('/*')) {
if (/\.(zip|tar(?:\.gz)?)$/.test(url))
return RegExp.$1;
throw new Error(`Unsupported archive ${url}`);
}
return '';
};
exports.getFormat = getFormat;
const run = (interpreter, code, ...args) => {
try {
return interpreter.runPython(dedent(code), ...args);
}
catch (error) {
io.get(interpreter).stderr(error);
}
};
exports.run = run;
const runAsync = async (interpreter, code, ...args) => {
try {
return await interpreter.runPythonAsync(dedent(code), ...args);
}
catch (error) {
io.get(interpreter).stderr(error);
}
};
exports.runAsync = runAsync;
const runEvent = async (interpreter, code, event) => {
// allows method(event) as well as namespace.method(event)
// it does not allow fancy brackets names for now
const [name, ...keys] = code.split('.');
let target = interpreter.globals.get(name);
let context;
for (const key of keys) [context, target] = [target, target[key]];
try {
await target.call(context, event);
}
catch (error) {
io.get(interpreter).stderr(error);
}
};
exports.runEvent = runEvent;
/* c8 ignore stop */
|