feat: njord adhoc (#2703)

Author: capJavert

.env

@@ -40,7 +40,7 @@ MAGNI_ORIGIN=http://localhost:9000
 MEILI_ORIGIN=http://localhost:7700/
 SUBMIT_ARTICLE_THRESHOLD=250
 ANALYTICS_URL=http://localhost:5000
-NJORD_ORIGIN=http://localhost:50051
+NJORD_ORIGIN=http://njord-transactions-server
 
 MEILI_INDEX=dev
 MEILI_TOKEN=dev

bin/import.ts

@@ -64,6 +64,7 @@ const start = async (): Promise<void> => {
   await importEntity(con, 'UserTopReader');
   await importEntity(con, 'MarketingCta');
   await importEntity(con, 'SourceMember');
+  await importEntity(con, 'Product');
   // Manually have to reset these as insert has a issue with `type` columns
   await con.query(`update post set type = 'article' where type = 'Post'`);
   await con.query(`update source set type = 'machine' where type = 'Source'`);

seeds/Product.json

@@ -0,0 +1,42 @@
+[
+	{
+		"id": "a39d7368-22d9-4e01-b961-077179ff992d",
+		"type": "award",
+		"image": "https:\/\/daily-now-res.cloudinary.com\/image\/upload\/s--t9sWnia4--\/f_auto,q_auto\/v1740123247\/awards\/Unicorn",
+		"name": "Test",
+		"createdAt": "2025-03-05T14:13:01.035Z",
+		"updatedAt": "2025-03-05T14:13:01.035Z",
+		"value": 10,
+		"flags": "{}"
+	},
+	{
+		"id": "ef2e2633-c9b9-401a-a372-0edce9fa6329",
+		"type": "award",
+		"image": "https:\/\/daily-now-res.cloudinary.com\/image\/upload\/s--t9sWnia4--\/f_auto,q_auto\/v1740123247\/awards\/Unicorn",
+		"name": "Test 2",
+		"createdAt": "2025-03-05T14:13:01.035Z",
+		"updatedAt": "2025-03-05T14:13:01.035Z",
+		"value": 25,
+		"flags": "{}"
+	},
+	{
+		"id": "8aeb45ce-2e96-4dbf-826d-433c98047642",
+		"type": "award",
+		"image": "https:\/\/daily-now-res.cloudinary.com\/image\/upload\/s--t9sWnia4--\/f_auto,q_auto\/v1740123247\/awards\/Unicorn",
+		"name": "Test 3",
+		"createdAt": "2025-03-05T14:13:01.035Z",
+		"updatedAt": "2025-03-05T14:13:01.035Z",
+		"value": 50,
+		"flags": "{}"
+	},
+	{
+		"id": "1b536ed1-3ab0-4780-a179-d0387d4c6d72",
+		"type": "award",
+		"image": "https:\/\/daily-now-res.cloudinary.com\/image\/upload\/s--t9sWnia4--\/f_auto,q_auto\/v1740123247\/awards\/Unicorn",
+		"name": "Test free",
+		"createdAt": "2025-03-05T14:13:01.035Z",
+		"updatedAt": "2025-03-05T14:13:01.035Z",
+		"value": 0,
+		"flags": "{}"
+	}
+]

src/workers/transactionBalanceLog.ts

@@ -10,9 +10,6 @@ export const transactionBalanceLogWorker: TypedWorker<'njord.v1.balance-log'> =
       logger.info({ data }, 'transaction log');
     },
     parseMessage: (message) => {
-      return {
-        ...message,
-        data: TransferResponse.fromBinary(message.data),
-      };
+      return TransferResponse.fromBinary(message.data);
     },
   };

src/workers/worker.ts

@@ -53,7 +53,7 @@ export interface BaseTypedWorker<
   subscription: string;
   handler: Worker;
   maxMessages?: number;
-  parseMessage?: (message: Message) => TypedMessage<T>;
+  parseMessage?: (message: Message) => T;
 }
 
 export interface TypedWorker<T extends keyof PubSubSchema>