Introduce lambda worker sample (#455)

Author: Sushisource

.gitignore

@@ -111,3 +111,7 @@ package-lock.json
 */**/pnpm-lock.yaml
 
 .idea/
+
+**/client.key
+**/client.pem
+worker-versioning/.claude/settings.local.json

.scripts/copy-shared-files.mjs

@@ -25,6 +25,7 @@ const TSCONFIG_EXCLUDE = [
   'production',
   'hello-world-js',
   'food-delivery',
+  'lambda-worker',
   'nestjs-exchange-rates',
   'empty',
   'hello-world',
@@ -37,6 +38,7 @@ const GITIGNORE_EXCLUDE = [
   'hello-world-js',
   'protobufs',
   'food-delivery',
+  'lambda-worker',
   'nestjs-exchange-rates',
 ];
 const ESLINTRC_EXCLUDE = [
@@ -71,6 +73,7 @@ const POST_CREATE_EXCLUDE = [
   'patching-api',
   'signals-queries',
   'activities-cancellation-heartbeating',
+  'lambda-worker',
   'nestjs-exchange-rates',
   'food-delivery',
   'search-attributes',

.scripts/list-of-samples.json

@@ -24,6 +24,7 @@
     "hello-world-js",
     "hello-world-mtls",
     "interceptors-opentelemetry",
+    "lambda-worker",
     "monorepo-folders",
     "mutex",
     "nestjs-exchange-rates",

cron-workflows/src/activities.ts

@@ -2,5 +2,5 @@ import { log, activityInfo } from '@temporalio/activity';
 
 export async function logTime(name: string, wfTime: string): Promise<void> {
   const { workflowExecution } = activityInfo();
-  log.info(`Hello from ${workflowExecution.workflowId}, ${name}!`, { workflowTime: wfTime, activityTime: Date.now() });
+  log.info(`Hello from ${workflowExecution?.workflowId}, ${name}!`, { workflowTime: wfTime, activityTime: Date.now() });
 }

food-delivery/packages/activities/services.ts

@@ -13,7 +13,7 @@ export const notificationService = {
 export const paymentService = {
   charge(cents: number) {
     // In a real app, we would pass an idempotency token to the downstream service
-    const _idempotencyToken = `${activityInfo().workflowExecution.workflowId}-charge`
+    const _idempotencyToken = `${activityInfo().workflowExecution!.workflowId}-charge`
     if (cents >= 3500) {
       throw ApplicationFailure.create({ nonRetryable: true, message: 'Card declined: insufficient funds' })
     }
@@ -25,7 +25,7 @@ export const paymentService = {
 
   refund(cents: number) {
     // In a real app, we would pass an idempotency token to the downstream service
-    const _idempotencyToken = `${activityInfo().workflowExecution.workflowId}-refund`
+    const _idempotencyToken = `${activityInfo().workflowExecution!.workflowId}-refund`
     if (Math.random() < 0.7) {
       throw new Error('Failed to refund. Unable to reach payment service.')
     }

lambda-worker/.eslintignore

@@ -0,0 +1,3 @@
+node_modules
+lib
+.eslintrc.js

lambda-worker/.eslintrc.js

@@ -0,0 +1,48 @@
+const { builtinModules } = require('module');
+
+const ALLOWED_NODE_BUILTINS = new Set(['assert']);
+
+module.exports = {
+  root: true,
+  parser: '@typescript-eslint/parser',
+  parserOptions: {
+    project: './tsconfig.json',
+    tsconfigRootDir: __dirname,
+  },
+  plugins: ['@typescript-eslint', 'deprecation'],
+  extends: [
+    'eslint:recommended',
+    'plugin:@typescript-eslint/eslint-recommended',
+    'plugin:@typescript-eslint/recommended',
+    'prettier',
+  ],
+  rules: {
+    // recommended for safety
+    '@typescript-eslint/no-floating-promises': 'error', // forgetting to await Activities and Workflow APIs is bad
+    'deprecation/deprecation': 'warn',
+
+    // code style preference
+    'object-shorthand': ['error', 'always'],
+
+    // relaxed rules, for convenience
+    '@typescript-eslint/no-unused-vars': [
+      'warn',
+      {
+        argsIgnorePattern: '^_',
+        varsIgnorePattern: '^_',
+      },
+    ],
+    '@typescript-eslint/no-explicit-any': 'off',
+  },
+  overrides: [
+    {
+      files: ['src/workflows.ts', 'src/workflows-*.ts', 'src/workflows/*.ts'],
+      rules: {
+        'no-restricted-imports': [
+          'error',
+          ...builtinModules.filter((m) => !ALLOWED_NODE_BUILTINS.has(m)).flatMap((m) => [m, `node:${m}`]),
+        ],
+      },
+    },
+  ],
+};

lambda-worker/.gitignore

@@ -0,0 +1,5 @@
+lib
+node_modules
+workflow-bundle.js
+function.zip
+package/

lambda-worker/.npmrc

@@ -0,0 +1 @@
+package-lock=false

lambda-worker/.nvmrc

@@ -0,0 +1 @@
+22