wip

Author: matuscongrady

_test-stacks/all-workloads/bun.lock

@@ -3,11 +3,14 @@
   "workspaces": {
     "": {
       "dependencies": {
+        "@hono/node-server": "^1.19.6",
         "hono": "^4.10.7",
       },
     },
   },
   "packages": {
+    "@hono/node-server": ["@hono/[email protected]", "", { "peerDependencies": { "hono": "^4" } }, "sha512-Shz/KjlIeAhfiuE93NDKVdZ7HdBVLQAfdbaXEaoAVO3ic9ibRSLGIQGkcBbFyuLr+7/1D5ZCINM8B+6IvXeMtw=="],
+
     "hono": ["[email protected]", "", {}, "sha512-icXIITfw/07Q88nLSkB9aiUrd8rYzSweK681Kjo/TSggaGbOX4RRyxxm71v+3PC8C/j+4rlxGeoTRxQDkaJkUw=="],
   }
 }

_test-stacks/all-workloads/package.json

@@ -1,5 +1,6 @@
 {
   "dependencies": {
+    "@hono/node-server": "^1.19.6",
     "hono": "^4.10.7"
   }
 }

_test-stacks/all-workloads/src/batch-job.ts

@@ -1,8 +1,3 @@
-/* eslint-disable antfu/no-top-level-await */
 const triggerEvent = JSON.parse(process.env.STP_TRIGGER_EVENT_DATA!);
 
-await new Promise((resolve) => setTimeout(resolve, 5000));
-
 console.log(triggerEvent);
-
-throw new Error('Test error');

_test-stacks/all-workloads/src/container.ts

@@ -1,6 +1,12 @@
+import { serve } from '@hono/node-server';
 import { Hono } from 'hono';
 
 const app = new Hono();
-app.get('/', (c) => c.text('Hello Bun!'));
 
-export default app;
+app.get('/', (c) => c.text('Hello Node.js!'));
+
+const port = Number(process.env.PORT) || 3000;
+
+serve({ fetch: app.fetch, port });
+
+console.info(`Container started successfully. Listening on port ${port}.`);

_test-stacks/all-workloads/src/lambda.ts

@@ -2,7 +2,6 @@ import type { Handler } from 'aws-lambda';
 
 const handler: Handler = async (event, context) => {
   console.log(event, context);
-  throw new Error('Test error');
   return {
     statusCode: 200,
     body: JSON.stringify({

docs/code-snippets/web-services/basic-usage.ts

@@ -6,7 +6,6 @@ app.get('/', async (req, res) => {
   res.send({ message: 'Hello' });
 });
 
-// for your use port number stored in PORT environment variable for your application
 // this environment variable is automatically injected by Stacktape
 app.listen(process.env.PORT, () => {
   console.info(`Server running on port ${process.env.PORT}`);

src/domain/packaging-manager/index.ts

@@ -340,12 +340,10 @@ export class PackagingManager {
   }) => {
     const shouldUseCache = this.#shouldWorkloadUseCache({ workloadName, commandCanUseCache });
 
-    // console.log(workloadName, shouldUseCache, deploymentArtifactManager.getExistingDigestsForJob(jobName));
     const existingDigests = shouldUseCache ? deploymentArtifactManager.getExistingDigestsForJob(jobName) : [];
     const packagingType = packaging.type;
     const progressLogger = eventManager.getNamespacedInstance({ eventType: parentEventType, identifier: jobName });
 
-    // Docker remote cache refs (enabled by default, can be disabled with --disable-docker-remote-cache)
     const useRemoteCache = !globalStateManager.args.disableDockerRemoteCache;
     const cacheRef = useRemoteCache ? getCacheRef(jobName) : undefined;
 
@@ -441,6 +439,7 @@ export class PackagingManager {
               }),
               additionalDigestInput
             });
+            console.dir({ sharedProps, result }, { depth: 5 });
             this.#packagedJobs.push({ ...result, skipped: result.outcome === 'skipped' });
             return result;
           }