Feature/auth

auth-service/src/main/java/com/flowforge/auth_service/dto/ApiResponse.java

@@ -23,7 +23,7 @@ public static <T> ApiResponse<T> success(T data, String message) {
     }
 
     public static <T> ApiResponse<T> success(T data) {
-        return success(data, "Request processed successfully");
+        return success(data, "Request  .processed successfully");
     }
 
     public static <T> ApiResponse<T> error(String message, Object errors) {

auth-service/src/main/resources/application.yaml

@@ -25,6 +25,9 @@ spring:
     enabled: true
     baseline-on-migrate: true
     locations: filesystem:/app/database/migrations
+    schemas: auth
+    default-schema: auth
+    create-schemas: true
 
   mail:
     host: flowforge-mailpit

auth-service/target/classes/application.yaml

@@ -25,6 +25,9 @@ spring:
     enabled: true
     baseline-on-migrate: true
     locations: filesystem:/app/database/migrations
+    schemas: auth
+    default-schema: auth
+    create-schemas: true
 
   mail:
     host: flowforge-mailpit

database/migrations/V1__create_worker_tasks.sql

@@ -0,0 +1,10 @@
+CREATE TABLE worker_tasks (
+    id          VARCHAR(36)  PRIMARY KEY,
+    type        VARCHAR(50)  NOT NULL,
+    payload     TEXT         NOT NULL,
+    status      VARCHAR(20)  NOT NULL DEFAULT 'PENDING',
+    result      TEXT,
+    error       TEXT,
+    created_at  TIMESTAMP    NOT NULL DEFAULT NOW(),
+    updated_at  TIMESTAMP    NOT NULL DEFAULT NOW()
+);

database/migrations/V2__add_worker_task_execution_columns.sql

@@ -0,0 +1,6 @@
+ALTER TABLE worker_tasks
+    ADD COLUMN IF NOT EXISTS workflow_execution_id VARCHAR(36),
+    ADD COLUMN IF NOT EXISTS node_id VARCHAR(36);
+
+ALTER TABLE worker_tasks
+    ALTER COLUMN payload DROP NOT NULL;

docker-compose.yml

@@ -27,6 +27,8 @@ services:
       - discovery-service
     ports:
       - "8083:8082"
+    volumes:
+      - ./database/auth:/app/database/migrations
 
   db:
     image: postgres:16-alpine