Email updates from an objective

import express from 'express';
import nodemailer from 'nodemailer';
import Cadenya, { type Cadenya as CadenyaTypes } from '@cadenya/cadenya';

const cadenya = new Cadenya(); // reads CADENYA_API_KEY and CADENYA_WEBHOOK_KEY
const mailer = nodemailer.createTransport({
  host: process.env.SMTP_HOST,
  port: 587,
  auth: { user: process.env.SMTP_USER, pass: process.env.SMTP_PASS },
});
const app = express();

app.post('/webhooks/cadenya', express.raw({ type: 'application/json' }), (req, res) => {
  let event;
  try {
    event = cadenya.webhooks.unwrap(req.body.toString(), { headers: req.headers });
  } catch {
    res.status(401).send('bad signature');
    return;
  }
  res.status(200).end(); // ack first
  notify(event).catch((err) => console.error({ err }, 'email failed'));
});

app.listen(3000);

package main

import (
	"io"
	"net/http"
	"net/smtp"
	"os"

	"go.cadenya.com/cadenya-go"
	"go.cadenya.com/cadenya-go/option"
)

var client = cadenya.NewClient(
	option.WithAPIKey(os.Getenv("CADENYA_API_KEY")),
	option.WithWebhookKey(os.Getenv("CADENYA_WEBHOOK_KEY")),
)

func webhookHandler(w http.ResponseWriter, r *http.Request) {
	body, _ := io.ReadAll(r.Body)
	event, err := client.Webhooks.Unwrap(body, r.Header)
	if err != nil {
		http.Error(w, "bad signature", http.StatusUnauthorized)
		return
	}
	w.WriteHeader(http.StatusOK) // ack first
	go notify(event)
}

func main() {
	http.HandleFunc("/webhooks/cadenya", webhookHandler)
	http.ListenAndServe(":3000", nil)
}

async function notify(event: CadenyaTypes.UnwrapWebhookEvent) {
  const objective = event.data.objective;
  const to = objective.labels?.notify_email;
  if (!to) return; // this run did not ask for email

  const ref = objective.externalId ?? objective.id;
  const data = event.data.objectiveEvent.data;

  switch (data.type) {
    case 'finalized': {
      const output = data.finalized.output;
      await send(
        to,
        `Objective ${ref} finished`,
        output
          ? JSON.stringify(output, null, 2)
          : 'The agent finished with no structured output.',
      );
      break;
    }
    case 'error':
      await send(
        to,
        `Objective ${ref} failed`,
        data.error.message ?? 'Unknown error',
      );
      break;
  }
}

async function send(to: string, subject: string, body: string) {
  await mailer.sendMail({ from: 'agents@acme.com', to, subject, text: body });
}

import (
	"encoding/json"
	"fmt"

	"go.cadenya.com/cadenya-go"
)

func notify(event *cadenya.UnwrapWebhookEvent) {
	objective := event.Data.Objective
	to := objective.Labels["notify_email"]
	if to == "" {
		return // this run did not ask for email
	}

	ref := objective.ExternalID
	if ref == "" {
		ref = objective.ID
	}
	e := event.Data.ObjectiveEvent.Data

	switch event.Type {
	case "objective_event.finalized":
		body := "The agent finished with no structured output."
		if e.Finalized.Output != nil {
			out, _ := json.MarshalIndent(e.Finalized.Output, "", "  ")
			body = string(out)
		}
		send(to, fmt.Sprintf("Objective %s finished", ref), body)
	case "objective_event.error":
		send(to, fmt.Sprintf("Objective %s failed", ref), e.Error.Message)
	}
}

func send(to, subject, body string) {
	auth := smtp.PlainAuth("", os.Getenv("SMTP_USER"), os.Getenv("SMTP_PASS"), os.Getenv("SMTP_HOST"))
	msg := []byte("To: " + to + "\r\nSubject: " + subject + "\r\n\r\n" + body)
	if err := smtp.SendMail(os.Getenv("SMTP_HOST")+":587", auth, "agents@acme.com", []string{to}, msg); err != nil {
		fmt.Println("email failed:", err)
	}
}