E-mail als schakel in AI-pijplijnen

import { Wesender } from "@wesender/node"
import { createHash } from "crypto"

const client = new Wesender(process.env.WESENDER_API_KEY!)

// In-memory set — gebruik Redis in productie
const verstuurd = new Set<string>()

interface RapportTaak {
  runId:      string
  ontvanger:  string
  onderwerp:  string
  html:       string
  maxRetries: number
}

async function verwerkTaak(taak: RapportTaak, poging = 1): Promise<void> {
  const sleutel = createHash("sha256")
    .update(taak.runId + taak.ontvanger)
    .digest("hex")

  if (verstuurd.has(sleutel)) {
    console.log("Al verstuurd, sla over:", sleutel)
    return
  }

  try {
    await client.emails.send({
      from:    "pijplijn@jouwdomein.nl",
      to:      taak.ontvanger,
      subject: taak.onderwerp,
      html:    taak.html,
    })
    verstuurd.add(sleutel)
    console.log("Verstuurd naar", taak.ontvanger)
  } catch (err) {
    if (poging < taak.maxRetries) {
      const wacht = 2 ** poging * 1000
      console.warn(`Poging ${poging} mislukt, wacht ${wacht}ms`)
      await new Promise(r => setTimeout(r, wacht))
      return verwerkTaak(taak, poging + 1)
    }
    console.error("Max pogingen bereikt voor:", taak.ontvanger)
    throw err
  }
}

import { generateText, tool } from "ai"
import { openai }               from "@ai-sdk/openai"
import { z }                    from "zod"
import { Wesender }             from "@wesender/node"

const emailClient = new Wesender(process.env.WESENDER_API_KEY!)

const { text } = await generateText({
  model:    openai("gpt-4o"),
  maxSteps: 5,
  system:
    "Je bent een pijplijn-agent. Genereer een HTML-rapport van de meegeleverde data " +
    "en verstuur het daarna via send_report.",
  prompt: JSON.stringify({ verkopen: 1240, retouren: 38, datum: new Date().toISOString().slice(0, 10) }),

  tools: {
    send_report: tool({
      description: "Verstuur het nachtelijke rapport per e-mail",
      parameters: z.object({
        ontvanger: z.string().email().describe("Ontvanger-e-mailadres"),
        onderwerp: z.string().describe("Onderwerpregel"),
        html:      z.string().describe("HTML-inhoud van het rapport"),
      }),
      execute: async ({ ontvanger, onderwerp, html }) => {
        await emailClient.emails.send({
          from:    "pijplijn@jouwdomein.nl",
          to:      ontvanger,
          subject: onderwerp,
          html,
        })
        return { status: "verstuurd" }
      },
    }),
  },
})

console.log("Agent-uitvoer:", text)