Add CampaignUpdated event message

Author: 1v4n4

src/eventMessage.ts

@@ -0,0 +1,43 @@
+import {ContactV2, PrivacyV2, Campaign as CampaignFragment, ActionV2, ActionPage, Tracking} from './actionMessage'
+
+export type EmailStatusEvent = {
+  eventType: 'email_status';
+  action?: ActionV2;
+  actionPage?: ActionPage;
+  campaign?: CampaignFragment;
+  supporter: {
+    contact: ContactV2;
+    privacy: PrivacyV2;
+  },
+  tracking?: Tracking;
+}
+
+export type EventMessageV2 = {
+  schema: 'proca:event:2',
+  timestamp: string,
+} & EmailStatusEvent
+
+
+type Json = Record<string, any>;
+
+type Campaign = {
+  config: Json; // JSON object with arbitrary structure
+  contactSchema: string; // e.g., "basic"
+  externalId: number;
+  id: number;
+  name: string;
+  org: {
+    name: string;
+    title: string;
+  };
+  title: string;
+};
+
+export type CampaignUpdateEvent = {
+  campaign: Campaign;
+  campaignId: number;
+  eventType: string; // e.g., "campaign_updated"
+  orgId: number;
+  schema: string; // e.g., "proca:event:2"
+  timestamp: string; // ISO8601 format
+};

src/events.ts

@@ -1,6 +1,6 @@
 import { KeyStore } from "@proca/crypto";
 import { ActionMessage } from "./actionMessage";
-import { EventMessageV2 } from "./eventMessage";
+import { EventMessageV2, CampaignUpdated } from "./events";
 
 export type DecryptOpts = {
   decrypt?: boolean;
@@ -18,7 +18,7 @@ export type SyncResult = {
   processed: boolean;
 }
 
-export type SyncCallback = (action: ActionMessage | EventMessageV2) => Promise<SyncResult | boolean>;
+export type SyncCallback = (action: ActionMessage | EventMessageV2 | CampaignUpdated) => Promise<SyncResult | boolean>;
 
 export type Counters = {
   ack: number;