Slack custom emoji: two-way sync + saveCustomEmoji SDK

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});

.changeset/integrations-save-custom-emoji.md

@@ -0,0 +1,5 @@
+---
+"@plotday/twister": minor
+---
+
+Added: `Integrations.saveCustomEmoji(emoji: NewCustomEmoji[])` — connectors can populate Plot's custom-emoji cache so workspace emoji (e.g. Slack `:party_parrot:`) render as images and round-trip as reactions. New `NewCustomEmoji` type exported.

connectors/slack/src/slack-api.ts

@@ -254,6 +254,18 @@ export class SlackApi {
  }
  }
 
+ /** Lists workspace custom emoji. Values are an image URL or `alias:<name>`. */
+ public async listEmoji(cursor?: string): Promise<{
+ emoji: Record<string, string>;
+ nextCursor?: string;
+ }> {
+ const data = await this.call("emoji.list", cursor ? { cursor } : {});
+ return {
+ emoji: (data.emoji as Record<string, string>) || {},
+ nextCursor: data.response_metadata?.next_cursor || undefined,
+ };
+ }
+
  public async getConversationHistory(
  channelId: string,
  cursor?: string,
@@ -576,26 +588,38 @@ export function formatSlackText(text: string): string {
 }
 
 /**
- * Extract per-message Slack reactions as Plot reactions. Unmapped
- * shortcodes are skipped; deduplication is by source.accountId so
- * repeated reactors don't double-count.
+ * Extract per-message Slack reactions as Plot reactions. Standard shortcodes
+ * map to their Unicode emoji. A shortcode that isn't standard but IS a known
+ * workspace custom emoji (passed via `teamId` + `customEmojiNames`) becomes a
+ * `slack:<teamId>/<name>` ref so Plot can render and round-trip it. Truly
+ * unknown names are dropped. Deduplication is by source.accountId so repeated
+ * reactors don't double-count.
  */
-function extractSlackMessageReactions(
+export function extractSlackMessageReactions(
  msg: SlackMessage,
- userInfos?: SlackUserInfoMap
+ userInfos?: SlackUserInfoMap,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewReactions | undefined {
  if (!msg.reactions || msg.reactions.length === 0) return undefined;
  const byEmoji = new Map<string, NewActor[]>();
 
  for (const reaction of msg.reactions) {
- const unicode = slackNameToUnicode(reaction.name);
- if (!unicode) continue;
+ let key = slackNameToUnicode(reaction.name);
+ if (!key) {
+ // Strip any ::skin-tone suffix Slack can't apply to custom emoji.
+ const base = reaction.name.split("::")[0];
+ if (teamId && customEmojiNames?.has(base)) {
+ key = `slack:${teamId}/${base}`;
+ }
+ }
+ if (!key) continue; // truly unknown — drop
 
  const actors = reaction.users.map((userId) =>
  slackUserToNewActor(userId, userInfos?.get(userId))
  );
- const existing = byEmoji.get(unicode) ?? [];
- byEmoji.set(unicode, [...existing, ...actors]);
+ const existing = byEmoji.get(key) ?? [];
+ byEmoji.set(key, [...existing, ...actors]);
  }
 
  if (byEmoji.size === 0) return undefined;
@@ -621,7 +645,9 @@ export function transformSlackThread(
  messages: SlackMessage[],
  channelId: string,
  userInfos?: SlackUserInfoMap,
- initialSync?: boolean
+ initialSync?: boolean,
+ teamId?: string,
+ customEmojiNames?: ReadonlySet<string>
 ): NewLinkWithNotes {
  const parentMessage = messages[0];
 
@@ -664,7 +690,12 @@ export function transformSlackThread(
  if (!userId) continue; // Skip messages without user
 
  const text = formatSlackText(message.text);
- const reactions = extractSlackMessageReactions(message, userInfos);
+ const reactions = extractSlackMessageReactions(
+ message,
+ userInfos,
+ teamId,
+ customEmojiNames
+ );
 
  // Build fileRef actions for any files attached to this message
  const actions: Action[] = (message.files ?? []).map((f) => ({

connectors/slack/src/slack.test.ts

@@ -1,6 +1,10 @@
 import { describe, expect, it, vi } from "vitest";
 import { AuthProvider, type Authorization } from "@plotday/twister/tools/integrations";
 import { Slack } from "./slack";
+import {
+ extractSlackMessageReactions,
+ type SlackMessage,
+} from "./slack-api";
 
 /**
  * In-memory store backing `this.get` / `this.set` (which delegate to
@@ -123,3 +127,264 @@ describe("setupChannelWebhook", () => {
  expect(createWebhook).not.toHaveBeenCalled();
  });
 });
+
+describe("syncCustomEmoji", () => {
+ /** Build a Slack with the tool set needed by syncCustomEmoji. */
+ function makeEmojiSlack(opts: {
+ store: ReturnType<typeof makeStore>;
+ integrationsGet: ReturnType<typeof vi.fn>;
+ saveCustomEmoji: ReturnType<typeof vi.fn>;
+ }) {
+ const create = vi.fn(async () => ({ token: "cb" }) as never);
+ const runTask = vi.fn(async () => "task-token");
+ const tools = {
+ store: opts.store,
+ integrations: {
+ get: opts.integrationsGet,
+ saveCustomEmoji: opts.saveCustomEmoji,
+ },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ callbacks: { create },
+ tasks: { runTask },
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+ return { slack, create, runTask };
+ }
+
+ /** Mock global.fetch to answer one `emoji.list` call with `emoji`. */
+ function mockEmojiListFetch(emoji: Record<string, string>) {
+ return vi.fn(async () =>
+ ({
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true, emoji }),
+ }) as never
+ );
+ }
+
+ it("saves refs with alias resolution and caches the name set", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["emoji:read"],
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({
+ party_parrot: "https://e/pp.gif",
+ pp2: "alias:party_parrot",
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).toHaveBeenCalledTimes(1);
+ const saved = saveCustomEmoji.mock.calls[0][0] as Array<{
+ id: string;
+ imageUrl: string | null;
+ aliasOf: string | null;
+ name: string;
+ workspace: string;
+ provider: string;
+ }>;
+ const parrot = saved.find((e) => e.id === "slack:T0/party_parrot")!;
+ expect(parrot).toBeDefined();
+ expect(parrot.imageUrl).toBe("https://e/pp.gif");
+ expect(parrot.aliasOf).toBeNull();
+ expect(parrot.provider).toBe("slack");
+ expect(parrot.workspace).toBe("T0");
+ const alias = saved.find((e) => e.id === "slack:T0/pp2")!;
+ expect(alias).toBeDefined();
+ expect(alias.imageUrl).toBeNull();
+ expect(alias.aliasOf).toBe("slack:T0/party_parrot");
+
+ // Name set cached for the inbound transform.
+ expect(store.map.get("custom_emoji_T0")).toEqual(["party_parrot", "pp2"]);
+ });
+
+ it("no-ops when emoji:read is not granted", async () => {
+ const store = makeStore({});
+ const integrationsGet = vi.fn().mockResolvedValue({
+ token: "xoxp-test",
+ scopes: ["channels:history"], // no emoji:read
+ provider: { team_id: "T0" },
+ });
+ const saveCustomEmoji = vi.fn().mockResolvedValue(undefined);
+ const { slack } = makeEmojiSlack({ store, integrationsGet, saveCustomEmoji });
+
+ const fetchMock = mockEmojiListFetch({ party_parrot: "https://e/pp.gif" });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await (slack as unknown as {
+ syncCustomEmoji: (c: string) => Promise<void>;
+ }).syncCustomEmoji("C1");
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(saveCustomEmoji).not.toHaveBeenCalled();
+ expect(fetchMock).not.toHaveBeenCalled();
+ expect(store.map.has("custom_emoji_T0")).toBe(false);
+ });
+});
+
+describe("extractSlackMessageReactions (custom emoji)", () => {
+ it("emits a slack: ref for a known workspace custom emoji", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot", users: ["U1", "U2"], count: 2 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ expect(result!["slack:T0/party_parrot"]).toHaveLength(2);
+ });
+
+ it("strips a ::skin-tone suffix before matching the custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "party_parrot::skin-tone-3", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeDefined();
+ expect(Object.keys(result!)).toEqual(["slack:T0/party_parrot"]);
+ });
+
+ it("still drops a truly-unknown name (not standard, not custom)", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "not_a_real_emoji_xyz", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(
+ msg,
+ undefined,
+ "T0",
+ new Set(["party_parrot"])
+ );
+
+ expect(result).toBeUndefined();
+ });
+
+ it("maps a standard unicode reaction without a custom set", () => {
+ const msg = {
+ ts: "1.0",
+ user: "U1",
+ reactions: [{ name: "thumbsup", users: ["U1"], count: 1 }],
+ } as unknown as SlackMessage;
+
+ const result = extractSlackMessageReactions(msg);
+ expect(result).toBeDefined();
+ // Standard mapping resolves to a unicode key (not a slack: ref).
+ expect(Object.keys(result!)[0]?.startsWith("slack:")).toBe(false);
+ });
+});
+
+describe("onNoteReactionChanged (custom emoji outbound)", () => {
+ it("unwraps a slack: ref to the bare name for reactions.add", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const calls: Array<{ method: string; params: URLSearchParams }> = [];
+ const fetchMock = vi.fn(async (url: string, init: { body: string }) => {
+ calls.push({
+ method: String(url).split("/api/")[1] ?? String(url),
+ params: new URLSearchParams(init.body),
+ });
+ return {
+ ok: true,
+ status: 200,
+ headers: { get: () => null },
+ json: async () => ({ ok: true }),
+ } as never;
+ });
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "slack:T0/party_parrot",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ const add = calls.find((c) => c.method.startsWith("reactions.add"));
+ expect(add).toBeDefined();
+ expect(add!.params.get("name")).toBe("party_parrot");
+ expect(add!.params.get("channel")).toBe("C1");
+ expect(add!.params.get("timestamp")).toBe("111.000");
+ });
+
+ it("drops an unknown custom emoji ref with no Slack equivalent", async () => {
+ const store = makeStore({ sync_enabled_C1: true });
+ const integrationsGet = vi.fn().mockResolvedValue({ token: "xoxp-test" });
+ const tools = {
+ store,
+ integrations: { get: integrationsGet },
+ network: { createWebhook: vi.fn() },
+ files: {},
+ };
+ const slack = new Slack(
+ "twist-instance-1" as never,
+ { getTools: () => tools } as never
+ );
+
+ const fetchMock = vi.fn();
+ vi.stubGlobal("fetch", fetchMock);
+ try {
+ await slack.onNoteReactionChanged(
+ { key: "111.000" } as never,
+ { meta: { channelId: "C1" } } as never,
+ { id: "actor-1" } as never,
+ "not-a-mappable-emoji",
+ true
+ );
+ } finally {
+ vi.unstubAllGlobals();
+ }
+
+ expect(fetchMock).not.toHaveBeenCalled();
+ });
+});