feat: add npm hello workflow and activity

Signed-off-by: anilb <epipav@gmail.com>

Author: epipav

docs/adr/README.md

@@ -10,6 +10,7 @@ Use the `/adr` skill in Claude Code to record new ADRs or query past decisions.
 | --- | ----- | ------ | ---- |
 | [ADR-0001](./0001-packages-database.md) | Separate physical database for the packages domain | accepted | 2026-05-26 |
 | [ADR-0002](./0002-packages-worker-architecture.md) | Single-service, multi-entry-point architecture for packages_worker | accepted | 2026-05-25 |
+| [ADR-0003](./0003-packages-worker-temporal-parent.md) | Temporal ServiceWorker as the host for packages_worker scheduled workflows | accepted | 2026-05-26 |
 
 ## Why ADRs?
 

pnpm-lock.yaml

@@ -4,6 +4,7 @@ x-env-args: &env-args
   DOCKER_BUILDKIT: 1
   NODE_ENV: docker
   SERVICE: packages-worker
+  CROWD_TEMPORAL_TASKQUEUE: packages-worker
   SHELL: /bin/sh
   SUPPRESS_NO_CONFIG_WARNING: 'true'
 

scripts/services/packages-worker.yaml

@@ -2,22 +2,26 @@
   "name": "@crowd/packages-worker",
   "private": true,
   "scripts": {
-    "start:packages-worker": "SERVICE=packages-worker tsx src/bin/packages-worker.ts",
+    "start:packages-worker": "CROWD_TEMPORAL_TASKQUEUE=packages-worker SERVICE=packages-worker tsx src/bin/packages-worker.ts",
     "start:github-repos-enricher": "SERVICE=github-repos-enricher tsx src/bin/github-repos-enricher.ts",
-    "dev:packages-worker": "SERVICE=packages-worker LOG_LEVEL=trace nodemon --watch src --watch ../../libs --ext ts --exec tsx --inspect=0.0.0.0:9233 src/bin/packages-worker.ts",
+    "dev:packages-worker": "CROWD_TEMPORAL_TASKQUEUE=packages-worker SERVICE=packages-worker LOG_LEVEL=trace nodemon --watch src --watch ../../libs --ext ts --exec tsx --inspect=0.0.0.0:9233 src/bin/packages-worker.ts",
     "dev:github-repos-enricher": "SERVICE=github-repos-enricher LOG_LEVEL=trace nodemon --watch src --watch ../../libs --ext ts --exec tsx --inspect=0.0.0.0:9234 src/bin/github-repos-enricher.ts",
-    "dev:packages-worker:local": "set -a && . ../../../backend/.env.dist.local && . ../../../backend/.env.override.local && set +a && SERVICE=packages-worker LOG_LEVEL=trace nodemon --watch src --watch ../../libs --ext ts --exec tsx --inspect=0.0.0.0:9233 src/bin/packages-worker.ts",
+    "dev:packages-worker:local": "set -a && . ../../../backend/.env.dist.local && . ../../../backend/.env.override.local && set +a && CROWD_TEMPORAL_TASKQUEUE=packages-worker SERVICE=packages-worker LOG_LEVEL=trace nodemon --watch src --watch ../../libs --ext ts --exec tsx --inspect=0.0.0.0:9233 src/bin/packages-worker.ts",
     "dev:github-repos-enricher:local": "set -a && . ../../../backend/.env.dist.local && . ../../../backend/.env.override.local && set +a && SERVICE=github-repos-enricher LOG_LEVEL=trace nodemon --watch src --watch ../../libs --ext ts --exec tsx --inspect=0.0.0.0:9234 src/bin/github-repos-enricher.ts",
     "lint": "npx eslint --ext .ts src --max-warnings=0",
     "format": "npx prettier --write \"src/**/*.ts\"",
     "format-check": "npx prettier --check .",
     "tsc-check": "tsc --noEmit"
   },
   "dependencies": {
+    "@crowd/archetype-standard": "workspace:*",
+    "@crowd/archetype-worker": "workspace:*",
     "@crowd/common": "workspace:*",
     "@crowd/data-access-layer": "workspace:*",
     "@crowd/database": "workspace:*",
     "@crowd/logging": "workspace:*",
+    "@temporalio/client": "~1.11.8",
+    "@temporalio/workflow": "~1.11.8",
     "tsx": "^4.7.1",
     "typescript": "^5.6.3"
   },

services/apps/packages_worker/package.json

@@ -0,0 +1 @@
+export { sayHiNpm } from './npm/activities'

services/apps/packages_worker/src/activities.ts

@@ -1,53 +1,6 @@
-import fs from 'fs'
-import path from 'path'
+import { svc } from '../service'
 
-import { getServiceLogger } from '@crowd/logging'
-
-import { getPackagesDb } from '../db'
-
-const log = getServiceLogger()
-
-const liveFilePath = path.join(__dirname, '../tmp/packages-worker-live.tmp')
-const readyFilePath = path.join(__dirname, '../tmp/packages-worker-ready.tmp')
-
-let shuttingDown = false
-
-const shutdown = async () => {
-  if (shuttingDown) return
-  shuttingDown = true
-  log.info('Shutting down packages-worker...')
-  process.exit(0)
-}
-
-process.on('SIGINT', shutdown)
-process.on('SIGTERM', shutdown)
-
-const main = async () => {
-  log.info('packages-worker starting...')
-
-  const qx = await getPackagesDb()
-  await qx.selectOne('SELECT 1')
-  log.info('Connected to packages-db.')
-
-  // Create tmp directory for health probe files
-  fs.mkdirSync(path.dirname(liveFilePath), { recursive: true })
-
-  setInterval(async () => {
-    if (shuttingDown) return
-    try {
-      await Promise.all([
-        fs.promises.open(liveFilePath, 'a').then((f) => f.close()),
-        fs.promises.open(readyFilePath, 'a').then((f) => f.close()),
-      ])
-    } catch (err) {
-      log.warn({ err }, 'Failed to write health probe files')
-    }
-  }, 5000)
-
-  log.info('packages-worker started, idle.')
-}
-
-main().catch((err) => {
-  log.error({ err }, 'packages-worker fatal error')
-  process.exit(1)
+setImmediate(async () => {
+  await svc.init()
+  await svc.start()
 })

services/apps/packages_worker/src/bin/packages-worker.ts

@@ -0,0 +1,8 @@
+import { getServiceChildLogger } from '@crowd/logging'
+
+const log = getServiceChildLogger('npm')
+
+export async function sayHiNpm(): Promise<string> {
+  log.info('👋 hi from npm activity')
+  return 'hi from npm'
+}

services/apps/packages_worker/src/npm/activities.ts

@@ -0,0 +1,11 @@
+import { proxyActivities } from '@temporalio/workflow'
+
+import type * as activities from './activities'
+
+const { sayHiNpm } = proxyActivities<typeof activities>({
+  startToCloseTimeout: '1 minute',
+})
+
+export async function npmHello(): Promise<void> {
+  await sayHiNpm()
+}

services/apps/packages_worker/src/npm/workflows.ts

@@ -0,0 +1,15 @@
+import { Config } from '@crowd/archetype-standard'
+import { Options, ServiceWorker } from '@crowd/archetype-worker'
+
+const config: Config = {
+  envvars: [],
+  producer: { enabled: false },
+  temporal: { enabled: true },
+  redis: { enabled: false },
+}
+
+const options: Options = {
+  postgres: { enabled: false }, // packages-db is managed via getPackagesDb()
+}
+
+export const svc = new ServiceWorker(config, options)

services/apps/packages_worker/src/service.ts

@@ -0,0 +1 @@
+export { npmHello } from './npm/workflows'