Revert "revert: revert devex changes (#1728)" (#1729)

This reverts commit fc725d0.

Author: Salazareo

extensions/example-kv.js

@@ -25,6 +25,6 @@ extension.on('init', async () => {
         // and just a little bit longer
         // await sleep(100);
 
-        console.log('kv key should no longer have the value', kv.get('example-kv-key'));
+        console.log('kv key should no longer have the value', await kv.get('example-kv-key'));
     })();
 });

package-lock.json

@@ -57,6 +57,7 @@
   },
   "dependencies": {
     "@aws-sdk/client-secrets-manager": "^3.879.0",
+    "@aws-sdk/client-sns": "^3.907.0",
     "@google/genai": "^1.19.0",
     "@heyputer/putility": "^1.0.2",
     "@paralleldrive/cuid2": "^2.2.2",
@@ -74,11 +75,11 @@
     "uuid": "^9.0.1"
   },
   "optionalDependencies": {
-    "sharp": "^0.34.3",
+    "sharp": "^0.34.4",
     "sharp-bmp": "^0.1.5",
     "sharp-ico": "^0.1.5"
   },
   "engines": {
     "node": ">=20.19.5"
   }
-}
+}

package.json

@@ -63,7 +63,7 @@ module.exports = {
         HostOSModule,
         CoreModule,
         WebModule,
-        TemplateModule,
+        // TemplateModule,
         AppsModule,
         CaptchaModule,
         EntityStoreModule,

src/backend/exports.js

@@ -24,7 +24,6 @@
     "@pagerduty/pdjs": "^2.2.4",
     "@smithy/node-http-handler": "^2.2.2",
     "args": "^5.0.3",
-    "aws-sdk": "^2.1383.0",
     "axios": "^1.8.2",
     "bcrypt": "^5.1.0",
     "better-sqlite3": "^11.9.0",

src/backend/package.json

@@ -36,13 +36,30 @@ class Extension extends AdvancedBase {
             ]
         }),
     ];
+    
+    randomBrightColor() {
+        // Bright colors in ANSI (foreground codes 90–97)
+        const brightColors = [
+            // 91, // Bright Red
+            92, // Bright Green
+            // 93, // Bright Yellow
+            94, // Bright Blue
+            95, // Bright Magenta
+            // 96, // Bright Cyan
+        ];
+
+        return brightColors[Math.floor(Math.random() * brightColors.length)];
+    }
 
     constructor (...a) {
         super(...a);
         this.service = null;
         this.log = null;
         this.ensure_service_();
 
+        // this.terminal_color = this.randomBrightColor();
+        this.terminal_color = 94;
+        
         this.log = (...a) => {
             this.log_context.info(a.join(' '));
         };
@@ -260,6 +277,14 @@ class Extension extends AdvancedBase {
         }
         this.only_one_init_fn = callback;
     }
+    
+    get console () {
+        const extensionConsole = Object.create(console);
+        extensionConsole.log = (...a) => {
+            console.log(`\x1B[${this.terminal_color};1m(extension/${this.name})\x1B[0m`, ...a);
+        };
+        return extensionConsole;
+    }
 
     /**
      * This method will create the "default service" for an extension.

src/backend/src/Extension.js

@@ -218,8 +218,6 @@ class Kernel extends AdvancedBase {
             await services.ready;
             globalThis.services = services;
             const log = services.get('log-service').create('init');
-            log.info('services ready');
-
             log.system('server ready', {
                 deployment_type: globalThis.deployment_type,
             });
@@ -411,6 +409,7 @@ class Kernel extends AdvancedBase {
             `const { use: puter } = globalThis.__puter_extension_globals__.useapi;`,
             `const extension = globalThis.__puter_extension_globals__` +
                 `.extensionObjectRegistry[${JSON.stringify(extension_id)}];`,
+            `const console = extension.console;`,
             `const runtime = extension.runtime;`,
             `const config = extension.config;`,
             `const registry = extension.registry;`,
@@ -465,6 +464,8 @@ class Kernel extends AdvancedBase {
             },
         });
 
+        mod.extension.name = packageJSON.name;
+        
         const maybe_promise = (typ => typ.trim().toLowerCase())(packageJSON.type ?? '') === 'module'
             ? await import(path_.join(require_dir, packageJSON.main ?? 'index.js'))
             : require(require_dir);
@@ -577,18 +578,34 @@ class Kernel extends AdvancedBase {
 
     async run_npm_install (path) {
         const npmCmd = process.platform === "win32" ? "npm.cmd" : "npm";
-        const proc = spawn(npmCmd, ["install"], { cwd: path, shell: true, stdio: "inherit" });
+        const proc = spawn(npmCmd, ["install"], { cwd: path, stdio: "pipe" });
+
+        let buffer = '';
+
+        proc.stdout.on('data', (data) => {
+            buffer += data.toString();
+        });
+
+        proc.stderr.on('data', (data) => {
+            buffer += data.toString();
+        });
+
         return new Promise((rslv, rjct) => {
             proc.on('close', code => {
                 if ( code !== 0 ) {
-                    throw new Error(`exit code: ${code}`);
+                    // Print buffered output on error
+                    if ( buffer ) process.stdout.write(buffer);
+                    rjct(new Error(`exit code: ${code}`));
+                    return;
                 }
                 rslv();
             });
             proc.on('error', err => {
+                // Print buffered output on error
+                if ( buffer ) process.stdout.write(buffer);
                 rjct(err);
-            })
-        })
+            });
+        });
     }
 }
 

src/backend/src/Kernel.js

@@ -17,11 +17,6 @@
  * along with this program.  If not, see <https://www.gnu.org/licenses/>.
  */
 class BootLogger {
-    constructor () {
-        console.log(
-            `\x1B[36;1mBoot logger started :)\x1B[0m`,
-        );
-    }
     info (...args) {
         console.log(
             '\x1B[36;1m[BOOT/INFO]\x1B[0m',

src/backend/src/boot/BootLogger.js

@@ -381,7 +381,7 @@ class RuntimeEnvironment extends AdvancedBase {
             if ( ! checks_pass ) continue;
 
             this.logger.info(
-                `${hl('USING')} ${quot(entry.path)} for ${meta.pathFor}.`
+                `${hl(meta.pathFor)} ${quot(entry.path)}`
             )
 
             return entry;

src/backend/src/boot/RuntimeEnvironment.js

@@ -246,7 +246,8 @@ const config_pointer = {};
     config_to_export = new Proxy(config_to_export, {
         set: (target, prop, value, receiver) => {
             const logger = Context.get('logger', { allow_fallback: true });
-            logger.debug(
+            // If no logger, just give up
+            if ( logger ) logger.debug(
                 '\x1B[36;1mCONFIGURATION MUTATED AT RUNTIME\x1B[0m',
                 { prop, value },
             );