Make --dry-run a synchronize-specific option

src/commands/base.ts

@@ -11,10 +11,6 @@ export abstract class BaseCommand extends Command<Context> {
     required: false,
   });
 
-  dryRun = Option.Boolean("--dry-run", false, {
-    description: "Print statements without executing",
-  });
-
   protected getDatabaseUrl(): string {
     const url = this.url ?? process.env.PGSLICE_URL;
     if (!url) {
@@ -27,9 +23,6 @@ export abstract class BaseCommand extends Command<Context> {
     try {
       this.context.pgslice ??= await Pgslice.connect(
         new URL(this.getDatabaseUrl()),
-        {
-          dryRun: this.dryRun,
-        },
       );
 
       await this.perform(this.context.pgslice);

src/commands/synchronize.ts

@@ -39,6 +39,10 @@ export class SynchronizeCommand extends BaseCommand {
     ],
   });
 
+  dryRun = Option.Boolean("--dry-run", false, {
+    description: "Print statements without executing",
+  });
+
   table = Option.String({ required: true, name: "table" });
 
   start = Option.String("--start", {

src/pgslice.ts

@@ -35,8 +35,6 @@ import { Swapper } from "./swapper.js";
 import { AdvisoryLock } from "./advisory-lock.js";
 
 interface PgsliceOptions {
-  dryRun?: boolean;
-
   /**
    * Whether to use Postgres advisory locks to prevent concurrent operations
    * on the same table for the same operation. Defaults to true.
@@ -46,11 +44,9 @@ interface PgsliceOptions {
 
 export class Pgslice {
   #pool: DatabasePool | null = null;
-  #dryRun: boolean;
   #advisoryLocks: boolean;
 
   constructor(pool: DatabasePool, options: PgsliceOptions) {
-    this.#dryRun = options.dryRun ?? false;
     this.#advisoryLocks = options.advisoryLocks ?? true;
     this.#pool = pool;
   }
@@ -88,10 +84,6 @@ export class Pgslice {
   async start<T>(
     handler: (transaction: DatabasePoolConnection) => Promise<T>,
   ): Promise<T> {
-    if (this.#dryRun) {
-      throw new Error("Dry run not yet supported.");
-    }
-
     return this.pool.connect(handler);
   }