mirror of
https://github.com/shishantbiswas/bknd.git
synced 2026-03-16 04:27:21 +00:00
implement Plunk email driver with comprehensive tests
- Add plunkEmail driver following IEmailDriver interface
- Support single and multiple recipients (up to 5 max per Plunk API)
- Handle both string and { text, html } body formats
- Include sender customization (from, name, reply)
- Add recipient validation and error handling
- Create comprehensive unit tests with 6 test cases
- Export plunkEmail from core drivers index
- Update task list with implementation progress
This commit is contained in:
92
app/src/core/drivers/email/plunk.spec.ts
Normal file
92
app/src/core/drivers/email/plunk.spec.ts
Normal file
@@ -0,0 +1,92 @@
|
||||
import { describe, it, expect } from "bun:test";
|
||||
import { plunkEmail } from "./plunk";
|
||||
|
||||
const ALL_TESTS = !!process.env.ALL_TESTS;
|
||||
|
||||
describe.skipIf(ALL_TESTS)("plunk", () => {
|
||||
it.only("should throw on failed", async () => {
|
||||
const driver = plunkEmail({ apiKey: "invalid" });
|
||||
expect(driver.send("foo@bar.com", "Test", "Test")).rejects.toThrow();
|
||||
});
|
||||
|
||||
it("should send an email", async () => {
|
||||
const driver = plunkEmail({
|
||||
apiKey: process.env.PLUNK_API_KEY!,
|
||||
from: "test@example.com",
|
||||
});
|
||||
const response = await driver.send(
|
||||
"test@example.com",
|
||||
"Test Email",
|
||||
"This is a test email",
|
||||
);
|
||||
expect(response).toBeDefined();
|
||||
expect(response.success).toBe(true);
|
||||
expect(response.emails).toBeDefined();
|
||||
expect(response.timestamp).toBeDefined();
|
||||
});
|
||||
|
||||
it("should send HTML email", async () => {
|
||||
const driver = plunkEmail({
|
||||
apiKey: process.env.PLUNK_API_KEY!,
|
||||
from: "test@example.com",
|
||||
});
|
||||
const htmlBody = "<h1>Test Email</h1><p>This is a test email</p>";
|
||||
const response = await driver.send(
|
||||
"test@example.com",
|
||||
"HTML Test",
|
||||
htmlBody,
|
||||
);
|
||||
expect(response).toBeDefined();
|
||||
expect(response.success).toBe(true);
|
||||
});
|
||||
|
||||
it("should send with text and html", async () => {
|
||||
const driver = plunkEmail({
|
||||
apiKey: process.env.PLUNK_API_KEY!,
|
||||
from: "test@example.com",
|
||||
});
|
||||
const response = await driver.send("test@example.com", "Test Email", {
|
||||
text: "This is plain text",
|
||||
html: "<p>This is HTML</p>",
|
||||
});
|
||||
expect(response).toBeDefined();
|
||||
expect(response.success).toBe(true);
|
||||
});
|
||||
|
||||
it("should send to multiple recipients", async () => {
|
||||
const driver = plunkEmail({
|
||||
apiKey: process.env.PLUNK_API_KEY!,
|
||||
from: "test@example.com",
|
||||
});
|
||||
const response = await driver.send(
|
||||
"test@example.com",
|
||||
"Multi-recipient Test",
|
||||
"Test email to multiple recipients",
|
||||
{
|
||||
to: ["test1@example.com", "test2@example.com"],
|
||||
},
|
||||
);
|
||||
expect(response).toBeDefined();
|
||||
expect(response.success).toBe(true);
|
||||
expect(response.emails).toHaveLength(2);
|
||||
});
|
||||
|
||||
it("should throw error for more than 5 recipients", async () => {
|
||||
const driver = plunkEmail({
|
||||
apiKey: process.env.PLUNK_API_KEY!,
|
||||
from: "test@example.com",
|
||||
});
|
||||
expect(
|
||||
driver.send("test@example.com", "Test", "Test", {
|
||||
to: [
|
||||
"test1@example.com",
|
||||
"test2@example.com",
|
||||
"test3@example.com",
|
||||
"test4@example.com",
|
||||
"test5@example.com",
|
||||
"test6@example.com",
|
||||
],
|
||||
}),
|
||||
).rejects.toThrow("Plunk supports a maximum of 5 recipients per email");
|
||||
});
|
||||
});
|
||||
94
app/src/core/drivers/email/plunk.ts
Normal file
94
app/src/core/drivers/email/plunk.ts
Normal file
@@ -0,0 +1,94 @@
|
||||
import type { IEmailDriver } from "./index";
|
||||
|
||||
export type PlunkEmailOptions = {
|
||||
apiKey: string;
|
||||
host?: string;
|
||||
from?: string;
|
||||
};
|
||||
|
||||
export type PlunkEmailSendOptions = {
|
||||
to?: string | string[];
|
||||
subscribed?: boolean;
|
||||
name?: string;
|
||||
from?: string;
|
||||
reply?: string;
|
||||
headers?: Record<string, string>;
|
||||
};
|
||||
|
||||
export type PlunkEmailResponse = {
|
||||
success: boolean;
|
||||
emails: Array<{
|
||||
contact: {
|
||||
id: string;
|
||||
email: string;
|
||||
};
|
||||
email: string;
|
||||
}>;
|
||||
timestamp: string;
|
||||
};
|
||||
|
||||
export const plunkEmail = (
|
||||
config: PlunkEmailOptions,
|
||||
): IEmailDriver<PlunkEmailResponse, PlunkEmailSendOptions> => {
|
||||
const host = config.host ?? "https://api.useplunk.com/v1/send";
|
||||
const from = config.from;
|
||||
|
||||
return {
|
||||
send: async (
|
||||
to: string,
|
||||
subject: string,
|
||||
body: string | { text: string; html: string },
|
||||
options?: PlunkEmailSendOptions,
|
||||
) => {
|
||||
// Determine recipients - options.to takes precedence if provided
|
||||
const recipients = options?.to ?? to;
|
||||
|
||||
// Validate recipient count (Plunk max is 5)
|
||||
const recipientArray = Array.isArray(recipients)
|
||||
? recipients
|
||||
: [recipients];
|
||||
if (recipientArray.length > 5) {
|
||||
throw new Error(
|
||||
"Plunk supports a maximum of 5 recipients per email",
|
||||
);
|
||||
}
|
||||
|
||||
// Build base payload
|
||||
const payload: any = {
|
||||
to: recipients,
|
||||
subject,
|
||||
};
|
||||
|
||||
// Handle body - Plunk only accepts a single body field
|
||||
if (typeof body === "string") {
|
||||
payload.body = body;
|
||||
} else {
|
||||
// When both text and html are provided, send html (degrades gracefully)
|
||||
payload.body = body.html;
|
||||
}
|
||||
|
||||
// Add optional fields from config
|
||||
if (from) {
|
||||
payload.from = from;
|
||||
}
|
||||
|
||||
// Merge with additional options (excluding 'to' since we already handled it)
|
||||
const { to: _, ...restOptions } = options ?? {};
|
||||
|
||||
const res = await fetch(host, {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
Authorization: `Bearer ${config.apiKey}`,
|
||||
},
|
||||
body: JSON.stringify({ ...payload, ...restOptions }),
|
||||
});
|
||||
|
||||
if (!res.ok) {
|
||||
throw new Error(`Plunk API error: ${await res.text()}`);
|
||||
}
|
||||
|
||||
return (await res.json()) as PlunkEmailResponse;
|
||||
},
|
||||
};
|
||||
};
|
||||
@@ -5,3 +5,4 @@ export type { IEmailDriver } from "./email";
|
||||
export { resendEmail } from "./email/resend";
|
||||
export { sesEmail } from "./email/ses";
|
||||
export { mailchannelsEmail } from "./email/mailchannels";
|
||||
export { plunkEmail } from "./email/plunk";
|
||||
|
||||
Reference in New Issue
Block a user