Stalled trial Slack alert: template and code

{
  "name": "Stalled trial alert",
  "cancelation_token": "trial-check-{{data.account_id}}",
  "nodes": [
    {
      "type": "trigger",
      "trigger_type": "api-invoke"
    },
    {
      "type": "delay",
      "mode": "duration",
      "duration": "P5D"
    },
    {
      "type": "fetch",
      "method": "post",
      "url": "https://app.acme.com/api/trials/activation",
      "merge_strategy": "overwrite",
      "headers": {
        "Content-Type": "application/json"
      },
      "body": "{\"account_id\": \"{{data.account_id}}\"}"
    },
    {
      "type": "branch",
      "paths": [
        {
          "label": "10 or more seats",
          "conditions": ["data.seats", "greater than or equal", "10"],
          "nodes": [
            {
              "type": "send",
              "channel": "slack",
              "message": {
                "template": "@stalled-trial-slack",
                "context": {
                  "tenant_id": "sales-alerts"
                }
              }
            }
          ]
        }
      ],
      "default": {
        "label": "Smaller trials",
        "nodes": [
          {
            "type": "send",
            "channel": "email",
            "message": {
              "template": "@trial-nudge-email"
            }
          }
        ]
      }
    },
    {
      "type": "exit"
    }
  ]
}

// Creates this recipe's journey from journey.json and the templates/ folder,
// then publishes it. Run it once per workspace:
//
//   COURIER_API_KEY=pk_... node --experimental-strip-types setup.ts
//
// It prints the journey ID and the template IDs it created.
import Courier from "@trycourier/courier";
import { readFileSync, readdirSync } from "node:fs";

const client = new Courier();
const here = new URL(".", import.meta.url);
const readJson = (path: string) =>
  JSON.parse(readFileSync(new URL(path, here), "utf8"));

const spec = readJson("journey.json");

// 1. Create the journey, then the templates its send nodes use.
const journey = await client.journeys.create({
  name: spec.name,
  nodes: [spec.nodes[0], spec.nodes.at(-1)],
});

const templateIds: Record<string, string> = {};
for (const file of readdirSync(new URL("templates/", here))) {
  const key = file.replace(/\.json$/, "");
  const template = await client.journeys.templates.create(
    journey.id,
    readJson(`templates/${file}`)
  );
  await client.journeys.templates.publish(template.id, {
    templateId: journey.id,
  });
  templateIds[key] = template.id;
}

// 2. Save the nodes. In journey.json, "@<template>" stands for the ID of the
// template with that file name. Node IDs must be unique across a workspace,
// so any node ID journey.json names (used by "send_status.<id>" conditions)
// gets this journey's ID added.
const nodeIds = [
  ...JSON.stringify(spec.nodes).matchAll(/"id":"([\w-]+)"/g),
].map((m) => m[1]);
let nodes = JSON.stringify(spec.nodes).replace(/"@([\w-]+)"/g, (_, key) =>
  JSON.stringify(templateIds[key])
);
for (const id of nodeIds)
  nodes = nodes.replace(
    new RegExp(`(?<=[".])${id}(?=")`, "g"),
    `${id}-${journey.id}`
  );
await client.journeys.replace(journey.id, {
  name: spec.name,
  cancelation_token: spec.cancelation_token,
  nodes: JSON.parse(nodes),
});

// 3. Publish, so new runs use this version.
await client.journeys.publish(journey.id);
console.log(JSON.stringify({ journeyId: journey.id, templateIds }));

// Stores your Slack bot token and alert channel once, on a Courier tenant that
// stands for your company's Slack workspace. The Slack node in journey.json
// names this tenant ("sales-alerts") and has no token or channel of its own: it
// uses the ones on the tenant. Run it once, after setup.ts, and again to rotate
// the token:
//
//   COURIER_API_KEY=pk_... SLACK_BOT_TOKEN=xoxb-... SLACK_ALERT_CHANNEL=C012AB3CD \
//     node --experimental-strip-types setup-slack.ts
//
// SLACK_ALERT_CHANNEL is the channel ID for your sales channel. To use another
// tenant ID, change it here and in the Slack node's context in journey.json.
import Courier from "@trycourier/courier";

const client = new Courier();

const requireEnv = (name: string) => {
  const value = process.env[name];
  if (!value) throw new Error(`Missing environment variable ${name}`);
  return value;
};

const tenantId = "sales-alerts";
await client.tenants.update(tenantId, {
  name: "Sales alerts (Slack)",
  user_profile: {
    slack: {
      access_token: requireEnv("SLACK_BOT_TOKEN"),
      channel: requireEnv("SLACK_ALERT_CHANNEL"),
    },
  },
});
console.log(JSON.stringify({ tenantId }));

{
  "channel": "slack",
  "notification": {
    "name": "Stalled trial alert (Slack)",
    "tags": ["recipe", "stalled-trial-slack-alert"],
    "brand": null,
    "subscription": null,
    "content": {
      "version": "2022-01-01",
      "elements": [
        {
          "type": "channel",
          "channel": "slack",
          "elements": [
            {
              "type": "text",
              "content": "Stalled trial: {{account_name}} has {{seats}} seats and hasn't activated yet."
            },
            {
              "type": "text",
              "content": "Owner: {{profile.first_name}} {{profile.last_name}} ({{profile.email}})"
            },
            {
              "type": "text",
              "content": "So far: {{activity_summary}}"
            },
            {
              "type": "action",
              "content": "Open the account",
              "href": "https://admin.acme.com/accounts/{{account_id}}"
            }
          ]
        }
      ]
    }
  }
}

{
  "channel": "email",
  "notification": {
    "name": "Trial nudge (email)",
    "tags": ["recipe", "stalled-trial-slack-alert"],
    "brand": null,
    "subscription": null,
    "content": {
      "version": "2022-01-01",
      "elements": [
        {
          "type": "channel",
          "channel": "email",
          "elements": [
            {
              "type": "meta",
              "title": "Need a hand getting started, {{default profile.first_name \"there\"}}?"
            },
            {
              "type": "text",
              "content": "Hi {{default profile.first_name \"there\"}},"
            },
            {
              "type": "text",
              "content": "You're a few days into your Acme trial. If something's in the way, reply to this email and we'll help you get it sorted."
            },
            {
              "type": "action",
              "content": "Pick up where you left off",
              "href": "https://app.acme.com/setup"
            }
          ]
        }
      ]
    }
  }
}