fix: added guide on how you build the trigger.dev apps

Author: NERLOE

BUILD.md

@@ -0,0 +1,26 @@
+# Webapp
+
+```shell
+docker buildx build \
+  --platform linux/amd64 \
+  -f docker/Dockerfile \
+  --build-arg BUILD_APP_VERSION=spaak-version \
+  --build-arg BUILD_GIT_SHA=e2010087d6448c51633e22902dc7cc41489a7682 \
+  --build-arg BUILD_GIT_REF_NAME=spaak-version \
+  --build-arg BUILD_TIMESTAMP_SECONDS=$(date +%s) \
+  -t ghcr.io/spaak-technologies/trigger-webapp:latest \
+  --push \
+  .
+```
+
+
+# Supervisor
+
+```shell
+docker buildx build \
+  --platform linux/amd64 \
+  -f apps/supervisor/Containerfile \
+  -t ghcr.io/spaak-technologies/trigger-supervisor:latest \
+  --push \
+  .
+```

apps/webapp/app/services/runsReplicationService.server.ts

@@ -57,7 +57,6 @@ export type RunsReplicationServiceOptions = {
   leaderLockExtendIntervalMs?: number;
   leaderLockAcquireAdditionalTimeMs?: number;
   leaderLockRetryIntervalMs?: number;
-  leaderElectionRetryIntervalMs?: number;
   ackIntervalSeconds?: number;
   acknowledgeTimeoutMs?: number;
   logger?: Logger;
@@ -86,7 +85,6 @@ export type RunsReplicationServiceEvents = {
   batchFlushed: [
     { flushId: string; taskRunInserts: TaskRunInsertArray[]; payloadInserts: PayloadInsertArray[] }
   ];
-  leaderElection: [boolean];
 };
 
 export class RunsReplicationService {
@@ -235,27 +233,21 @@ export class RunsReplicationService {
       tracer: options.tracer,
     });
 
-    this._replicationClient.events.on(
-      "data",
-      async ({ lsn, log, parseDuration }: { lsn: string; log: PgoutputMessage; parseDuration: bigint }) => {
-        this.#handleData(lsn, log, parseDuration);
-      }
-    );
+    this._replicationClient.events.on("data", async ({ lsn, log, parseDuration }) => {
+      this.#handleData(lsn, log, parseDuration);
+    });
 
-    this._replicationClient.events.on(
-      "heartbeat",
-      async ({ lsn, shouldRespond }: { lsn: string; shouldRespond: boolean }) => {
-        if (this._isShuttingDown) return;
-        if (this._isShutDownComplete) return;
+    this._replicationClient.events.on("heartbeat", async ({ lsn, shouldRespond }) => {
+      if (this._isShuttingDown) return;
+      if (this._isShutDownComplete) return;
 
-        if (shouldRespond) {
-          this._lastAcknowledgedLsn = lsn;
-          await this._replicationClient.acknowledge(lsn);
-        }
+      if (shouldRespond) {
+        this._lastAcknowledgedLsn = lsn;
+        await this._replicationClient.acknowledge(lsn);
       }
-    );
+    });
 
-    this._replicationClient.events.on("error", (error: Error) => {
+    this._replicationClient.events.on("error", (error) => {
       this.logger.error("Replication client error", {
         error,
       });
@@ -271,17 +263,14 @@ export class RunsReplicationService {
       this._isSubscribed = true;
     });
 
-    this._replicationClient.events.on("acknowledge", ({ lsn }: { lsn: string }) => {
+    this._replicationClient.events.on("acknowledge", ({ lsn }) => {
       this.logger.debug("Acknowledged", { lsn });
     });
 
-    this._replicationClient.events.on("leaderElection", (isLeader: boolean) => {
+    this._replicationClient.events.on("leaderElection", (isLeader) => {
       this.logger.info("Leader election", { isLeader });
       this._isSubscribed = isLeader;
 
-      // Forward the event to external listeners
-      this.events.emit("leaderElection", isLeader);
-
       if (!isLeader && !this._isShuttingDown) {
         this.#scheduleLeaderElectionRetry();
       }