update jobs for the simple function

Author: Anmol1696

functions/simple-email/package.json

@@ -14,6 +14,7 @@
     "build:watch": "tsc -p tsconfig.json -w"
   },
   "dependencies": {
-    "@launchql/knative-job-fn": "workspace:^"
+    "@launchql/knative-job-fn": "workspace:^",
+    "@launchql/postmaster": "0.1.4"
   }
 }

functions/simple-email/src/index.ts

@@ -1,4 +1,5 @@
 import app from '@launchql/knative-job-fn';
+import { send as sendEmail } from '@launchql/postmaster';
 
 type SimpleEmailPayload = {
   to: string;
@@ -37,14 +38,29 @@ app.post('*', async (req: any, res: any, next: any) => {
       throw new Error("Either 'html' or 'text' must be provided");
     }
 
-    const from = isNonEmptyString(payload.from) ? payload.from : undefined;
+    const fromEnv = process.env.MAILGUN_FROM;
+    const from = isNonEmptyString(payload.from)
+      ? payload.from
+      : isNonEmptyString(fromEnv)
+        ? fromEnv
+        : undefined;
+
     const replyTo = isNonEmptyString(payload.replyTo)
       ? payload.replyTo
       : undefined;
 
-    // Log the email (dry-run mode, no actual send)
+    // Send via @launchql/postmaster (Mailgun or configured provider)
+    await sendEmail({
+      to,
+      subject,
+      ...(html && { html }),
+      ...(text && { text }),
+      ...(from && { from }),
+      ...(replyTo && { replyTo })
+    });
+
     // eslint-disable-next-line no-console
-    console.log('[simple-email] DRY RUN email', {
+    console.log('[simple-email] Sent email', {
       to,
       subject,
       from,
@@ -53,10 +69,6 @@ app.post('*', async (req: any, res: any, next: any) => {
       hasText: Boolean(text)
     });
 
-    // Optionally also log the full payload (for debugging)
-    // eslint-disable-next-line no-console
-    console.log('[simple-email] DRY RUN payload', payload);
-
     res.status(200).json({ complete: true });
   } catch (err) {
     next(err);

jobs/knative-job-worker/src/env.ts

@@ -21,8 +21,7 @@ const baseEnv = cleanEnv(
   { dotEnvPath: null }
 );
 
-const KNATIVE_SERVICE_URL =
-  process.env.KNATIVE_SERVICE_URL || process.env.INTERNAL_GATEWAY_URL;
+const KNATIVE_SERVICE_URL = process.env.KNATIVE_SERVICE_URL;
 
 if (!KNATIVE_SERVICE_URL) {
   throw new Error(

jobs/knative-job-worker/src/req.ts

@@ -18,7 +18,7 @@ const getFunctionUrl = (fn: string): string => {
   if (hasDevMap) {
     return DEV_MAP[fn] || completeUrl;
   }
-  return `${env.KNATIVE_SERVICE_URL}/${fn}`;
+  return `http://${fn}.${env.KNATIVE_SERVICE_URL}`;
 };
 
 interface RequestOptions {