From 93dc51d505d410c38995dc76cda2a7dcdb6b918c Mon Sep 17 00:00:00 2001
From: "Ioannis T." <jtourkos@gmail.com>
Date: Tue, 26 May 2026 10:19:07 +0300
Subject: [PATCH] wave: admin tool to push Intercom wave segments

---
 src/lib/utils/wave/admin/intercom-segments.ts |   7 +
 .../wave/(base-layout)/admin/+page.svelte     |  10 ++
 .../admin/intercom-wave-segments/+page.svelte | 134 ++++++++++++++++++
 .../admin/intercom-wave-segments/+page.ts     |  31 ++++
 4 files changed, 182 insertions(+)
 create mode 100644 src/lib/utils/wave/admin/intercom-segments.ts
 create mode 100644 src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.svelte
 create mode 100644 src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.ts

diff --git a/src/lib/utils/wave/admin/intercom-segments.ts b/src/lib/utils/wave/admin/intercom-segments.ts
new file mode 100644
index 000000000..75c7d30e0
--- /dev/null
+++ b/src/lib/utils/wave/admin/intercom-segments.ts
@@ -0,0 +1,7 @@
+import { authenticatedCall } from '../call';
+
+export async function pushWaveIntercomSegments(f = fetch, waveId: string): Promise<void> {
+  await authenticatedCall(f, `/api/admin/intercom/wave-segments/${waveId}`, {
+    method: 'POST',
+  });
+}
diff --git a/src/routes/(pages)/wave/(base-layout)/admin/+page.svelte b/src/routes/(pages)/wave/(base-layout)/admin/+page.svelte
index a05dfded2..8562371ec 100644
--- a/src/routes/(pages)/wave/(base-layout)/admin/+page.svelte
+++ b/src/routes/(pages)/wave/(base-layout)/admin/+page.svelte
@@ -63,6 +63,16 @@
           },
         ]
       : []),
+    ...(data.user.permissions?.includes('pushIntercomSegments')
+      ? [
+          {
+            name: 'Intercom Wave Segments',
+            description:
+              "Tag a wave's contributors and repo maintainers on Intercom for segmentation.",
+            href: '/wave/admin/intercom-wave-segments',
+          },
+        ]
+      : []),
   ]);
 </script>
 
diff --git a/src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.svelte b/src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.svelte
new file mode 100644
index 000000000..9513ade50
--- /dev/null
+++ b/src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.svelte
@@ -0,0 +1,134 @@
+<script lang="ts">
+  import HeadMeta from '$lib/components/head-meta/head-meta.svelte';
+  import Breadcrumbs from '$lib/components/breadcrumbs/breadcrumbs.svelte';
+  import Section from '$lib/components/section/section.svelte';
+  import FormField from '$lib/components/form-field/form-field.svelte';
+  import Dropdown from '$lib/components/dropdown/dropdown.svelte';
+  import Button from '$lib/components/button/button.svelte';
+  import AnnotationBox from '$lib/components/annotation-box/annotation-box.svelte';
+  import doWithConfirmationModal from '$lib/utils/do-with-confirmation-modal';
+  import doWithErrorModal from '$lib/utils/do-with-error-modal';
+  import { pushWaveIntercomSegments } from '$lib/utils/wave/admin/intercom-segments';
+
+  let { data } = $props();
+
+  const initialProgramId = data.wavePrograms[0]?.id;
+  const initialWaves = initialProgramId ? (data.wavesByProgram[initialProgramId] ?? []) : [];
+  const latestWave =
+    initialWaves.length > 0
+      ? initialWaves.reduce((a, b) => (a.waveNumber > b.waveNumber ? a : b))
+      : undefined;
+
+  let waveProgramId = $state<string | undefined>(initialProgramId);
+  let waveId = $state<string | undefined>(latestWave?.id);
+  let submitting = $state(false);
+
+  let waveProgramOptions = $derived(
+    data.wavePrograms.map((p) => ({
+      value: p.id,
+      title: p.name,
+    })),
+  );
+
+  let waveOptions = $derived(
+    waveProgramId
+      ? (data.wavesByProgram[waveProgramId] ?? []).map((w) => ({
+          value: w.id,
+          title: `Wave ${w.waveNumber}`,
+        }))
+      : [],
+  );
+
+  let selectedProgram = $derived(data.wavePrograms.find((p) => p.id === waveProgramId));
+  let selectedWave = $derived(
+    waveProgramId
+      ? (data.wavesByProgram[waveProgramId] ?? []).find((w) => w.id === waveId)
+      : undefined,
+  );
+
+  let valid = $derived(waveProgramId !== undefined && waveId !== undefined);
+
+  async function handleSubmit() {
+    if (!valid || !waveId || !selectedProgram || !selectedWave) return;
+
+    const targetWaveId = waveId;
+    const message =
+      `You are about to push Intercom segments for Wave ${selectedWave.waveNumber} of ${selectedProgram.name}. ` +
+      `This enqueues a background job that tags every contributor (net positive points) and repo maintainer for the wave on Intercom. ` +
+      `Continue?`;
+
+    submitting = true;
+
+    try {
+      await doWithConfirmationModal(message, async () => {
+        await doWithErrorModal(() => pushWaveIntercomSegments(fetch, targetWaveId), undefined, {
+          message: 'Intercom segment push enqueued.',
+          confetti: false,
+        });
+      });
+    } catch {
+      // Error already handled by doWithErrorModal
+    } finally {
+      submitting = false;
+    }
+  }
+</script>
+
+<HeadMeta title="Intercom Wave Segments | Admin | Wave" />
+
+<div class="page">
+  <Breadcrumbs
+    crumbs={[{ label: 'Admin', href: '/wave/admin' }, { label: 'Intercom Wave Segments' }]}
+  />
+  <Section
+    header={{
+      label: 'Intercom Wave Segments',
+    }}
+    skeleton={{ loaded: true }}
+  >
+    <div class="form">
+      <AnnotationBox type="info">
+        Enqueues a background job that tags every qualifying user on Intercom with the wave's
+        Contributor and Repo Maintainer tags. Tagging is idempotent — running this multiple times is
+        safe.
+      </AnnotationBox>
+
+      <FormField title="Wave Program">
+        <Dropdown
+          options={waveProgramOptions}
+          bind:value={waveProgramId}
+          onchange={() => {
+            waveId = undefined;
+          }}
+        />
+      </FormField>
+
+      <FormField title="Wave" disabled={!waveProgramId}>
+        <Dropdown options={waveOptions} bind:value={waveId} disabled={!waveProgramId} />
+      </FormField>
+
+      <Button disabled={!valid || submitting} onclick={handleSubmit}>
+        {submitting ? 'Submitting...' : 'Push to Intercom'}
+      </Button>
+    </div>
+  </Section>
+</div>
+
+<style>
+  .page {
+    display: flex;
+    max-width: 90rem;
+    margin: 0 auto;
+    width: 100%;
+    flex-direction: column;
+    gap: 1.5rem;
+  }
+
+  .form {
+    display: flex;
+    flex-direction: column;
+    gap: 1.5rem;
+    max-width: 32rem;
+    margin: 0 auto;
+  }
+</style>
diff --git a/src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.ts b/src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.ts
new file mode 100644
index 000000000..764689586
--- /dev/null
+++ b/src/routes/(pages)/wave/(base-layout)/admin/intercom-wave-segments/+page.ts
@@ -0,0 +1,31 @@
+import { getAllPaginated } from '$lib/utils/wave/getAllPaginated.js';
+import { getWavePrograms, getWaves } from '$lib/utils/wave/wavePrograms.js';
+import { redirect } from '@sveltejs/kit';
+
+export const load = async ({ parent, fetch, depends }) => {
+  depends('wave:admin:intercom-wave-segments');
+
+  const { user } = await parent();
+
+  if (!user.permissions?.includes('pushIntercomSegments')) {
+    throw redirect(302, '/wave/admin');
+  }
+
+  const wavePrograms = await getAllPaginated((page, limit) =>
+    getWavePrograms(fetch, { page, limit }),
+  );
+
+  const wavesByProgram: Record<string, Awaited<ReturnType<typeof getWaves>>['data']> = {};
+
+  for (const program of wavePrograms) {
+    const waves = await getAllPaginated((page, limit) =>
+      getWaves(fetch, program.id, { page, limit }),
+    );
+    wavesByProgram[program.id] = waves;
+  }
+
+  return {
+    wavePrograms,
+    wavesByProgram,
+  };
+};