Continuous publishing

.changeset/real-kiwis-impress.md

@@ -0,0 +1,5 @@
+---
+'pg-task': patch
+---
+
+Auto publishing

.github/workflows/cicd.yml

@@ -49,7 +49,12 @@ jobs:
       - name: Install dependencies
         run: pnpm install --frozen-lockfile
 
-      - name: Create Release Pull Request
+      - name: Create Release Pull Request or Publish to npm
+        id: changesets
         uses: changesets/action@v1
+        with:
+          # This expects you to have a script called release which does a build for your packages and calls changeset publish
+          publish: pnpm run ci:publish
         env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}

README.md

@@ -21,7 +21,7 @@ const manager = createManager({
 await manager.start();
 
 // Register a worker for `worker-queue` task queue
-const workerId = await manager.work<MyTask>({
+const workerId = await manager.register<MyTask>({
   queue: 'worker-queue',
   async handler(data) {
     await Promise.resolve();

jest.config.ts

@@ -6,7 +6,7 @@ const config: Config = {
   preset: 'ts-jest/presets/js-with-ts',
   testEnvironment: 'node',
   collectCoverage: true,
-  coveragePathIgnorePatterns: ['/node_modules/', '<rootDir>/__tests__/'],
+  coveragePathIgnorePatterns: ['/node_modules/', '<rootDir>/__utils__/'],
   testMatch: ['**/?(*.)+(spec|test).[jt]s?(x)'],
   prettierPath: null,
   transformIgnorePatterns: [`node_modules/(?!(?:.pnpm/)?(${esmModules.join('|')}))`],

src/manager.spec.ts

@@ -1,6 +1,6 @@
 import { PostgreSqlContainer, StartedPostgreSqlContainer } from '@testcontainers/postgresql';
 import { Pool } from 'pg';
-import { cleanupSchema, createRandomSchema } from '../__tests__/db';
+import { cleanupSchema, createRandomSchema } from '../__utils__/db';
 import { createManager } from './manager';
 import EventEmitter, { once } from 'node:events';
 import { executeQuery } from './utils/sql';
@@ -58,7 +58,7 @@ describe('pg worker', () => {
     const ee = new EventEmitter();
     const promise = once(ee, 'received');
 
-    const workerId = await manager.work({
+    const workerId = await manager.register({
       queue: queue,
       options: {
         poolInternvalInMs: 20,

src/manager.ts

@@ -9,13 +9,13 @@ import type { Pool } from './utils/sql';
 const brandSymbol = Symbol('brand');
 type WorkerId = number & { [brandSymbol]: 'WorkerId' };
 
-export type WorkerManager = {
+export interface WorkerManager {
   start(): Promise<void>;
-  work<TData>(props: QueueWorkerConfig<TData>): Promise<WorkerId>;
+  register<TData>(props: QueueWorkerConfig<TData>): Promise<WorkerId>;
   notifyWorker(workerId: WorkerId): void;
   stopWorker(workerId: WorkerId): Promise<void>;
   stop(): Promise<void>;
-};
+}
 
 export type WorkerManagerProperties = {
   pgClient: Pool;
@@ -84,7 +84,7 @@ export const createManager = (properties: WorkerManagerProperties): WorkerManage
     return workerId;
   }
 
-  async function work<TData>(config: QueueWorkerConfig<TData>): Promise<WorkerId> {
+  async function register<TData>(config: QueueWorkerConfig<TData>): Promise<WorkerId> {
     await ensureStarted();
     return startWorker(config);
   }
@@ -93,7 +93,7 @@ export const createManager = (properties: WorkerManagerProperties): WorkerManage
     start() {
       return ensureStarted();
     },
-    work,
+    register,
     notifyWorker(workerId) {
       workers.get(workerId)?.notify();
     },

src/plans.spec.ts

@@ -2,7 +2,7 @@ import { Pool } from 'pg';
 import { createPlans } from './plans';
 import { ConfiguredTask, TaskResultStates, Task, SelectedTask, TaskResult } from './task';
 import { PostgreSqlContainer, StartedPostgreSqlContainer } from '@testcontainers/postgresql';
-import { cleanupSchema, createRandomSchema } from '../__tests__/db';
+import { cleanupSchema, createRandomSchema } from '../__utils__/db';
 import { executeQuery } from './utils/sql';
 import { migrate } from './utils/migrate';
 import { createMigrations } from './migrations';