await Promise.resolve();

}

type DeliveryArgs = {

payloads?: Array<{ text?: string; interactive?: unknown }>;

};

function deliveryArgs(deliver: ReturnType<typeof vi.fn>): DeliveryArgs | undefined {

return deliver.mock.calls.at(0)?.at(0) as DeliveryArgs | undefined;

}

function firstDeliveredPayload(deliver: ReturnType<typeof vi.fn>) {

return deliveryArgs(deliver)?.payloads?.at(0);

}

function registerSlackAdapterPlugin(plugin: SlackAdapterPlugin): void {

const registry = createTestRegistry([{ pluginId: "slack", plugin, source: "test" }]);

setActivePluginRegistry(registry);

expect(result).toBe(true);

await flushPendingDelivery();

expect(deliver).toHaveBeenCalled();

const deliveryArgs = deliver.mock.calls[0]?.[0] as

| { payloads?: Array<{ text?: string; interactive?: unknown }> }

| undefined;

const payload = deliveryArgs?.payloads?.[0];

const payload = firstDeliveredPayload(deliver);

const text = payload?.text ?? "";

expect(text).toContain("Plugin approval required");

expect(text).toContain("Sensitive tool call");

);

expect(result).toBe(true);

await flushPendingDelivery();

const deliveryArgs = deliver.mock.calls[0]?.[0] as

| { payloads?: Array<{ text?: string; interactive?: unknown }> }

| undefined;

const payload = deliveryArgs?.payloads?.[0];

const payload = firstDeliveredPayload(deliver);

expect(payload?.text).toContain("Reply with: /approve <id> allow-once|deny");

expect(payload?.text).not.toContain("allow-always");

expect(payload?.interactive).toEqual({

await forwarder.handlePluginApprovalRequested!(request);

await flushPendingDelivery();

expect(deliver).toHaveBeenCalled();

const text =

(deliver.mock.calls[0]?.[0] as { payloads?: Array<{ text?: string }> })?.payloads?.[0]

?.text ?? "";

const text = firstDeliveredPayload(deliver)?.text ?? "";

expect(text).toMatch(/🚨/);

});

await forwarder.handlePluginApprovalRequested!(makePluginRequest());

await flushPendingDelivery();

expect(deliver).toHaveBeenCalled();

const deliveryArgs = deliver.mock.calls[0]?.[0] as

| { payloads?: Array<{ text?: string }> }

| undefined;

expect(deliveryArgs?.payloads?.[0]?.text).toBe("custom adapter payload");

expect(firstDeliveredPayload(deliver)?.text).toBe("custom adapter payload");

});

it("calls outbound beforeDeliverPayload before plugin approval delivery", async () => {

await forwarder.handlePluginApprovalResolved!(makePluginResolved());

await flushPendingDelivery();

expect(deliver).toHaveBeenCalled();

const deliveryArgs = deliver.mock.calls[0]?.[0] as

| { payloads?: Array<{ text?: string }> }

| undefined;

expect(deliveryArgs?.payloads?.[0]?.text).toBe("custom resolved payload");

expect(firstDeliveredPayload(deliver)?.text).toBe("custom resolved payload");

});

});

await forwarder.handlePluginApprovalResolved!(makePluginResolved());

expect(deliver).toHaveBeenCalled();

const text =

(deliver.mock.calls[0]?.[0] as { payloads?: Array<{ text?: string }> })?.payloads?.[0]

?.text ?? "";

const text = firstDeliveredPayload(deliver)?.text ?? "";

expect(text).toContain("Plugin approval");

expect(text).toContain("allowed once");

});

});

expect(deliver).toHaveBeenCalled();

const text =

(deliver.mock.calls[0]?.[0] as { payloads?: Array<{ text?: string }> })?.payloads?.[0]

?.text ?? "";

const text = firstDeliveredPayload(deliver)?.text ?? "";

expect(text).toContain("Plugin approval");

expect(text).toContain("denied");

});