Client onboarding

import json, os, uuid
from http.server import BaseHTTPRequestHandler, HTTPServer
from urllib.parse import parse_qs, urlparse
import requests

API = "https://api-sandbox.prepared.com.au"
key = os.environ["PREPARED_API_KEY"]  # prep_test_...

def token():
    return requests.post(f"{API}/v1/token", headers={"Authorization": f"Bearer {key}"}).json()["access_token"]

PAGE = """<!doctype html><title>Sign up</title>
<div id="prepared-form"></div>
<script src="%(api)s/onboarding.js"></script>
<script>
  Prepared.onboarding.mount({
    container: document.getElementById("prepared-form"),
    sessionToken: "%(session_token)s",
    onSubmitted: function () { fetch("/submitted?onboarding=%(id)s"); }
  });
</script>"""

class Handler(BaseHTTPRequestHandler):
    def do_GET(self):
        url = urlparse(self.path)
        if url.path == "/":
            # One sign-up per visit. The reference is your own ID for it.
            session = requests.post(f"{API}/v1/clients/onboardings/sessions",
                headers={"Authorization": f"Bearer {token()}"}, json={"reference": f"signup-{uuid.uuid4()}"}).json()
            page = PAGE % {"api": API, "session_token": session["session_token"], "id": session["id"]}
            self.send_response(200)
            self.send_header("Content-Type", "text/html; charset=utf-8")
            self.end_headers()
            self.wfile.write(page.encode())
        elif url.path == "/submitted":
            # The page says the form was sent: read who signed up.
            onboarding = requests.get(f"{API}/v1/clients/onboardings/{parse_qs(url.query)['onboarding'][0]}",
                headers={"Authorization": f"Bearer {token()}"}).json()
            for client in onboarding["clients"]:
                print(client["id"], client["first_name"], client["last_name"], client["email"])
            self.send_response(204)
            self.end_headers()
        else:
            self.send_response(404)
            self.end_headers()

    def do_POST(self):
        # Your webhook endpoint: one message per buyer.
        event = json.loads(self.rfile.read(int(self.headers["Content-Length"])))
        if event["type"] == "clients.submitted":
            print("webhook:", event["data"]["client_id"], event["data"]["email"])
        self.send_response(204)
        self.end_headers()

HTTPServer(("localhost", 8000), Handler).serve_forever()

import { createServer } from "node:http";
import { randomUUID } from "node:crypto";

const API = "https://api-sandbox.prepared.com.au";
const key = process.env.PREPARED_API_KEY; // prep_test_...

const token = async () => (await (await fetch(`${API}/v1/token`, {
  method: "POST", headers: { Authorization: `Bearer ${key}` },
})).json()).access_token;

createServer(async (req, res) => {
  const url = new URL(req.url, "http://localhost:8000");
  if (req.method === "GET" && url.pathname === "/") {
    // One sign-up per visit. The reference is your own ID for it.
    const session = await (await fetch(`${API}/v1/clients/onboardings/sessions`, {
      method: "POST",
      headers: { Authorization: `Bearer ${await token()}`, "Content-Type": "application/json" },
      body: JSON.stringify({ reference: `signup-${randomUUID()}` }),
    })).json();
    res.writeHead(200, { "Content-Type": "text/html; charset=utf-8" });
    res.end(`<!doctype html><title>Sign up</title>
<div id="prepared-form"></div>
<script src="${API}/onboarding.js"></script>
<script>
  Prepared.onboarding.mount({
    container: document.getElementById("prepared-form"),
    sessionToken: "${session.session_token}",
    onSubmitted: () => fetch("/submitted?onboarding=${session.id}"),
  });
</script>`);
  } else if (req.method === "GET" && url.pathname === "/submitted") {
    // The page says the form was sent: read who signed up.
    const onboarding = await (await fetch(`${API}/v1/clients/onboardings/${url.searchParams.get("onboarding")}`, {
      headers: { Authorization: `Bearer ${await token()}` },
    })).json();
    for (const client of onboarding.clients) console.log(client.id, client.first_name, client.last_name, client.email);
    res.writeHead(204).end();
  } else if (req.method === "POST") {
    // Your webhook endpoint: one message per buyer.
    let body = "";
    for await (const chunk of req) body += chunk;
    const event = JSON.parse(body);
    if (event.type === "clients.submitted") console.log("webhook:", event.data.client_id, event.data.email);
    res.writeHead(204).end();
  } else {
    res.writeHead(404).end();
  }
}).listen(8000, "localhost");