added changes

frontend/app/config.ts

@@ -1,2 +1,2 @@
 export const BACKEND_URL="http://localhost:3000"
-export const HOOKS_URL="https://localhost:3002"
+export const HOOKS_URL="http://localhost:3002"

frontend/app/login/page.tsx

@@ -12,11 +12,6 @@ export default function Page() {
   const [email,setEmail]=useState("");
   const [password,setPassword]=useState("");
   const router=useRouter();
-  useEffect(()=>{
-    if(localStorage.getItem("token")){
-      router.push("/dashboard")
-    }
-  },[])
   return (
     <div>
       <Appbar />

hooks/package.json

@@ -3,7 +3,7 @@
   "version": "1.0.0",
   "main": "index.js",
   "scripts": {
-    "start": "tsc -b && node dist/index.js"
+    "dev": "tsc -b && node dist/index.js"
   },
   "keywords": [],
   "author": "",

primaryBackend/package.json

@@ -3,7 +3,7 @@
   "version": "1.0.0",
   "main": "index.js",
   "scripts": {
-    "start": "tsc -b && node dist/index.js"
+    "dev": "tsc -b && node dist/index.js"
   },
   "keywords": [],
   "author": "",

processor/dist/index.js

@@ -31,7 +31,7 @@ function main() {
                 topic: TOPIC_NAME,
                 messages: pendingRows.map(r => {
                     return {
-                        value: r.zapRunId
+                        value: JSON.stringify({ zapRunId: r.zapRunId, stage: 0 })
                     };
                 })
             });

processor/package.json

@@ -3,7 +3,7 @@
   "version": "1.0.0",
   "main": "index.js",
   "scripts": {
-    "start": "tsc -b && node dist/index.js"
+    "dev": "tsc -b && node dist/index.js"
   },
   "keywords": [],
   "author": "",

worker/.gitignore

@@ -0,0 +1,3 @@
+node_modules
+# Keep environment variables out of version control
+.env

worker/dist/index.js

@@ -10,6 +10,8 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 const kafkajs_1 = require("kafkajs");
+const client_1 = require("@prisma/client");
+const prismaClient = new client_1.PrismaClient();
 const TOPIC_NAME = "zap-events";
 const kafka = new kafkajs_1.Kafka({
     clientId: "outbox-processor",
@@ -21,18 +23,68 @@ function main() {
             groupId: "main-worker",
         });
         yield consumer.connect();
+        const producer = kafka.producer();
+        yield producer.connect();
         yield consumer.subscribe({ topic: TOPIC_NAME, fromBeginning: true });
         yield consumer.run({
             autoCommit: false,
             eachMessage: (_a) => __awaiter(this, [_a], void 0, function* ({ topic, partition, message }) {
-                var _b;
+                var _b, _c, _d, _e, _f;
                 console.log({
                     partition,
                     offset: message.offset,
                     value: (_b = message.value) === null || _b === void 0 ? void 0 : _b.toString(),
                 });
-                //
+                if (!((_c = message.value) === null || _c === void 0 ? void 0 : _c.toString())) {
+                    return;
+                }
+                const parsedValue = JSON.parse((_d = message.value) === null || _d === void 0 ? void 0 : _d.toString());
+                const zapRunId = parsedValue.zapRunId;
+                const stage = parsedValue.stage;
+                const zapRunDetails = yield prismaClient.zapRun.findFirst({
+                    where: {
+                        id: zapRunId
+                    },
+                    include: {
+                        zap: {
+                            include: {
+                                actions: {
+                                    include: {
+                                        type: true
+                                    }
+                                }
+                            }
+                        }
+                    }
+                });
+                const currentAction = zapRunDetails === null || zapRunDetails === void 0 ? void 0 : zapRunDetails.zap.actions.find(x => x.sortingOrder === stage);
+                if (!currentAction) {
+                    console.log('Current action not found');
+                    return;
+                }
+                console.log(currentAction);
+                if (currentAction.type.id === 'email') {
+                    console.log('Sending out an email');
+                    //parse out the email to send
+                }
+                if (currentAction.type.id === 'send-sol') {
+                    console.log('Sending out solana');
+                    //parse out the address and the amount to send
+                }
                 yield new Promise((r) => setTimeout(r, 500));
+                const zapId = (_e = message === null || message === void 0 ? void 0 : message.value) === null || _e === void 0 ? void 0 : _e.toString();
+                const lastStage = (((_f = zapRunDetails === null || zapRunDetails === void 0 ? void 0 : zapRunDetails.zap.actions) === null || _f === void 0 ? void 0 : _f.length) || 1) - 1;
+                if (lastStage !== stage) {
+                    yield producer.send({
+                        topic: TOPIC_NAME,
+                        messages: [{
+                                value: JSON.stringify({
+                                    stage: stage + 1,
+                                    zapRunId
+                                })
+                            }]
+                    });
+                }
                 console.log('processing done');
                 //you can do your action operation here!
                 //

worker/package.json

@@ -3,13 +3,17 @@
   "version": "1.0.0",
   "main": "index.js",
   "scripts": {
-    "start": "tsc -b && node dist/index.js"
+    "dev": "tsc -b && node dist/index.js"
   },
   "keywords": [],
   "author": "",
   "license": "ISC",
   "description": "",
   "dependencies": {
+    "@prisma/client": "^5.20.0",
     "kafkajs": "^2.2.4"
+  },
+  "devDependencies": {
+    "prisma": "^5.20.0"
   }
 }