Migrate from Amazon SES to Groundmail

Node (@aws-sdk/client-sesv2)

import { SESv2Client, SendEmailCommand } from "@aws-sdk/client-sesv2";

const ses = new SESv2Client({ region: "us-east-1" });

await ses.send(
  new SendEmailCommand({
    FromEmailAddress: "no-reply@acme.com",
    Destination: { ToAddresses: ["ada@example.com"] },
    ReplyToAddresses: ["support@acme.com"],
    Content: {
      Simple: {
        Subject: { Data: "Reset your password" },
        Body: {
          Html: { Data: "<p>Your reset link: https://acme.com/reset/abc123</p>" },
          Text: { Data: "Your reset link: https://acme.com/reset/abc123" },
        },
      },
    },
    EmailTags: [{ Name: "type", Value: "password_reset" }],
    ConfigurationSetName: "transactional",
  })
);

Node (groundmail)

// npm install groundmail
import { Groundmail } from "groundmail";

const gm = new Groundmail(process.env.GROUNDMAIL_API_KEY);

const email = await gm.emails.send({
  from: "no-reply@acme.com",
  to: "ada@example.com",
  replyTo: "support@acme.com",
  subject: "Reset your password",
  html: "<p>Your reset link: https://acme.com/reset/abc123</p>",
  text: "Your reset link: https://acme.com/reset/abc123",
  tags: [{ name: "type", value: "password_reset" }],
  idempotencyKey: "password-reset:abc123",
});

console.log(email.id); // msg_...

curl

curl -X POST https://api.groundmail.dev/emails \
  -H "Authorization: Bearer $GROUNDMAIL_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: password-reset:abc123" \
  -d '{
    "from": "no-reply@acme.com",
    "to": "ada@example.com",
    "reply_to": "support@acme.com",
    "subject": "Reset your password",
    "html": "<p>Your reset link: https://acme.com/reset/abc123</p>",
    "text": "Your reset link: https://acme.com/reset/abc123",
    "tags": [{ "name": "type", "value": "password_reset" }]
  }'

Go

// go get github.com/Groundmail/groundmail-sdks/go
client, err := groundmail.New(os.Getenv("GROUNDMAIL_API_KEY"))
if err != nil {
	log.Fatal(err)
}

result, err := client.Emails.Send(map[string]any{
	"from":     "no-reply@acme.com",
	"to":       "ada@example.com",
	"reply_to": "support@acme.com",
	"subject":  "Reset your password",
	"html":     "<p>Your reset link: https://acme.com/reset/abc123</p>",
	"text":     "Your reset link: https://acme.com/reset/abc123",
})
if err != nil {
	log.Fatal(err)
}
fmt.Println(result["id"], result["status"])

Node (Express)

import express from "express";
import { verifyWebhookSignature } from "groundmail";

const app = express();

app.post("/webhooks/groundmail", express.raw({ type: "application/json" }), (req, res) => {
  const rawBody = req.body.toString("utf8");
  const ok = verifyWebhookSignature(
    process.env.GROUNDMAIL_WEBHOOK_SECRET,
    rawBody,
    req.header("groundmail-signature")
  );
  if (!ok) return res.sendStatus(401);

  const event = JSON.parse(rawBody);
  if (event.type === "email.bounced" || event.type === "email.complained") {
    // same handling your SNS or EventBridge consumer did for Bounce / Complaint
  }
  res.sendStatus(200);
});

bash (aws CLI + jq + curl)

#!/usr/bin/env bash
# Export the SES account-level suppression list for one region and import it into Groundmail.
set -euo pipefail
REGION=us-east-1
: > ses-suppressions.tsv

token=""
while :; do
  if [ -n "$token" ]; then
    page=$(aws sesv2 list-suppressed-destinations --region "$REGION" --next-token "$token" --output json)
  else
    page=$(aws sesv2 list-suppressed-destinations --region "$REGION" --output json)
  fi
  echo "$page" | jq -r '.SuppressedDestinationSummaries[] | [.EmailAddress, .Reason] | @tsv' >> ses-suppressions.tsv
  token=$(echo "$page" | jq -r '.NextToken // empty')
  [ -z "$token" ] && break
done

while IFS=$'\t' read -r email reason; do
  jq -n --arg email "$email" --arg reason "ses $reason" '{email: $email, reason: $reason}' |
    curl -sS -X POST https://api.groundmail.dev/suppressions \
      -H "Authorization: Bearer $GROUNDMAIL_API_KEY" \
      -H "Content-Type: application/json" \
      --data-binary @- > /dev/null
done < ses-suppressions.tsv

echo "Imported $(wc -l < ses-suppressions.tsv) addresses"