fix issue

Author: fayedraza

.github/workflows/dagger-fraud-sim.yml

@@ -24,5 +24,5 @@ jobs:
 
           dagger run --cloud authentication-service/auth-service:fraud-v1 \
             call run-fraud-sim \
-            --gemini-api-key secret:GEMINI_API_KEY \
-            --groq-api-key secret:GROQ_API_KEY
+            --gemini-api-key env:GEMINI_API_KEY \
+            --groq-api-key env:GROQ_API_KEY

.secrets.baseline

@@ -90,6 +90,10 @@
     {
       "path": "detect_secrets.filters.allowlist.is_line_allowlisted"
     },
+    {
+      "path": "detect_secrets.filters.common.is_baseline_file",
+      "filename": ".secrets.baseline"
+    },
     {
       "path": "detect_secrets.filters.common.is_ignored_due_to_verification_policies",
       "min_level": 2
@@ -123,15 +127,6 @@
     }
   ],
   "results": {
-    ".github/workflows/dagger-fraud-sim.yml": [
-      {
-        "type": "Secret Keyword",
-        "filename": ".github/workflows/dagger-fraud-sim.yml",
-        "hashed_secret": "86ac1a7088a5e5b345ffbff04ea68577f644efff",
-        "is_verified": false,
-        "line_number": 19
-      }
-    ],
     "COMPLETE_TESTING_GUIDE.md": [
       {
         "type": "Secret Keyword",
@@ -362,5 +357,5 @@
       }
     ]
   },
-  "generated_at": "2026-01-03T05:38:20Z"
+  "generated_at": "2026-01-03T06:46:05Z"
 }

dagger/src/fraud_simulation/__init__.py

@@ -1,16 +0,0 @@
-"""A generated module for FraudSimulation functions
-
-This module has been generated via dagger init and serves as a reference to
-basic module structure as you get started with Dagger.
-
-Two functions have been pre-created. You can modify, delete, or add to them,
-as needed. They demonstrate usage of arguments and return types using simple
-echo and grep commands. The functions can be called from the dagger CLI or
-from one of the SDKs.
-
-The first line in this comment block is a short description line and the
-rest is a long description with more detail on the module's purpose or usage,
-if appropriate. All modules should have a short description.
-"""
-
-from .main import FraudSimulation as FraudSimulation

dagger/src/fraud_simulation/main.py

@@ -1,58 +1,41 @@
-"""Dagger module for fraud simulation."""
+# dagger/module.py
 import dagger
-from dagger import dag, function, object_type, Doc
-from typing import Annotated
-
-@object_type
-class FraudSimulation:
-    """A Dagger module to run fraud simulation pipelines."""
-    @function
-    async def run_fraud_sim(
-        self,
-        gemini_api_key: Annotated[dagger.Secret, Doc("Gemini API token")],
-        groq_api_key: Annotated[dagger.Secret, Doc("Groq API token")],
-    ) -> str:
-        """
-        Runs the fraud simulation pipeline with the provided AI API keys.
-        """
-        # Get the host directory (where dagger call is executed)
-        # In Dagger Cloud, this will be the workspace directory.
-        host_dir = dag.host().directory(".")
-
-        # Define the base container with Python
-        base = (
-            dag.container()
-            .from_("python:3.11-slim")
-            .with_directory("/app", host_dir)
-            .with_workdir("/app")
-            .with_exec(["pip", "install", "pydantic"])
-        )
-
-        print("\n" + "="*50)
-        print("🚀 STARTING DAGGER FRAUD SIMULATION (CLOUD/MODULE)")
-        print("="*50 + "\n")
-
-        # Step 1: Generate Accounts
-        print("👉 Step 1: Generating Accounts...")
-        step1 = base.with_exec(["python3", "fraud_simulation/generate_accounts.py"])
-
-        # Step 2: Generate Logs
-        print("👉 Step 2: Generating Logs...")
-        step2 = step1.with_exec(["python3", "fraud_simulation/generate_logs.py"])
-
-        # Step 3: Process Logs with Secrets
-        print("👉 Step 3: Running Fraud Analysis Agent (Comparing Gemini & Groq)...")
-        step3 = (
-            step2
-            .with_secret_variable("GEMINI_API_KEY", gemini_api_key)
-            .with_secret_variable("GROQ_API_KEY", groq_api_key)
-            .with_exec(["python3", "fraud_simulation/process_logs.py"])
-        )
-
-        # Step 4: Expose Output
-        # This makes the results available via the Dagger API/UI
-
-        # To make it "complete" the simulation and show status
-        await step3.stdout()
-
-        return "✅ Simulation complete! Results available in fraud_simulation_reports/summary.json"
+from dagger import function
+
+@function
+async def run_fraud_sim(
+    gemini_api_key: dagger.Secret,
+    groq_api_key: dagger.Secret,
+) -> str:
+    """
+    Runs the fraud simulation using the global Dagger context.
+    """
+
+    # Use global `dagger` / `dag`, not self
+    host_dir = dagger.host().directory(".")
+
+    base = (
+        dagger.container()
+        .from_("python:3.11-slim")
+        .with_directory("/app", host_dir)
+        .with_workdir("/app")
+        .with_exec(["pip", "install", "pydantic"])
+    )
+
+    print("\n" + "=" * 50)
+    print("🚀 STARTING DAGGER FRAUD SIMULATION")
+    print("=" * 50 + "\n")
+
+    step1 = base.with_exec(["python3", "fraud_simulation/generate_accounts.py"])
+    step2 = step1.with_exec(["python3", "fraud_simulation/generate_logs.py"])
+    step3 = (
+        step2
+        .with_secret_variable("GEMINI_API_KEY", gemini_api_key)
+        .with_secret_variable("GROQ_API_KEY", groq_api_key)
+        .with_exec(["python3", "fraud_simulation/process_logs.py"])
+    )
+
+    # Force streaming stdout to trigger execution
+    await step3.stdout()
+
+    return "✅ Simulation complete! Results available in fraud_simulation_reports/summary.json"