Merge pull request #266 from vitalygashkov/next

Improved storage for extensions, added `common.getRandomElements` in extension API, improved `eval` error handling

packages/api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamyx/api",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "description": "Type definitions for the latest Streamyx API",
   "main": "streamyx.js",
   "types": "streamyx.d.ts",

packages/api/types/common.d.ts

@@ -21,4 +21,6 @@ export type Common = {
     seasonsCount: number;
     episodesCount: number;
   };
+
+  getRandomElements: (array: unknown, count?: number) => unknown[];
 };

packages/core/lib/store.ts

@@ -21,32 +21,40 @@ const createStorePath = (name: string) => {
   return oldStorePath;
 };
 
+const exitQueue: (() => void)[] = [];
+
+const onExit = () => {
+  for (const fn of exitQueue) fn();
+  exitQueue.length = 0;
+};
+
+process.on('SIGINT', () => {
+  onExit();
+  process.exit(0); // Ensure the app exits
+});
+
+process.on('SIGTERM', () => {
+  onExit();
+  process.exit(0);
+});
+
+// Catch uncaught exceptions
+process.on('uncaughtException', () => {
+  onExit;
+  process.exit(1);
+});
+
+// Optional: Catch exit event (not ideal for async operations)
+process.on('exit', () => onExit());
+
 class LocalStorage implements Storage {
   items: Map<string, any>;
   filePath: string;
 
   constructor(filePath: string) {
     this.items = new Map();
     this.filePath = filePath;
-
-    process.on('SIGINT', () => {
-      this.save();
-      process.exit(0); // Ensure the app exits
-    });
-
-    process.on('SIGTERM', () => {
-      this.save();
-      process.exit(0);
-    });
-
-    // Catch uncaught exceptions
-    process.on('uncaughtException', () => {
-      this.save();
-      process.exit(1);
-    });
-
-    // Optional: Catch exit event (not ideal for async operations)
-    process.on('exit', () => this.save());
+    exitQueue.push(() => this.save());
   }
 
   async load() {

packages/loader/index.js

@@ -50,8 +50,13 @@ const load = async (scriptPath, options = {}) => {
 };
 
 const create = (src, name = 'Eval') => {
-  const script = metavm.createScript(name, src);
-  return script;
+  try {
+    const script = metavm.createScript(name, src);
+    return script;
+  } catch (e) {
+    console.error(`Syntax Error: ${e.message}`);
+    return null;
+  }
 };
 
 module.exports = { load, create };