123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224
import { Client, Options, SendData, TemplateData, Type } from './types.ts';import { encode, typeByExtension } from './deps.ts';import * as Html from './html.ts';import * as Text from './text.ts';
// import jwt from './jwt.ts';
// type Key = {//     type?: string;//     project_id?: string;//     private_key_id?: string;//     private_key: string;//     client_email: string;//     client_id?: string;//     auth_uri?: string;//     token_uri?: string;//     auth_provider_x509_cert_url?: string;//     client_x509_cert_url?: string;// };
export default class Email {    #key?: any;    #type: Type = 'json';    #client?: Client;    #sandbox: boolean = false;
    constructor(options?: Options) {        this.#key = options?.key ?? this.#key;        this.#client = options?.client ?? this.#client;        this.#type = options?.type ?? this.#type;        this.#sandbox = options?.sandbox ?? this.#sandbox;    }
    #sendGrid(data: SendData) {        if (!this.#key) throw new Error('key required');
        const body: any = {            content: [],            subject: data.subject,            from: { email: data.from },            personalizations: [],        };
        if (this.#sandbox === true) {            body.mail_settings = { sandbox_mode: { enable: true } };        }
        if (data.to?.constructor === String) {            body.personalizations.push({ to: [{ email: data.to }] });        }
        if (data.to?.constructor === Array) {            body.personalizations.push({                to: data.to.map((email) => ({ email })),            });        }
        if (data.name) body.from.name = data.name;        // if (data.reply) body.replay_to = { email: data.reply };
        if (data.text) {            body.content.push({ type: 'text/plain', value: data.text });        }        if (data.html) {            body.content.push({ type: 'text/html', value: data.html });        }
        if (data.attachments) {            body.attachments = [];
            if (data.attachments?.constructor !== Object) {                throw new Error('attachments object type not valid');            }
            for (const name in data.attachments) {                const value = data.attachments[name];                body.attachments.push({                    filename: name,                    content: encode(value),                    disposition: 'attachment',                    type: typeByExtension(name),                });            }        }
        return fetch('https://api.sendgrid.com/v3/mail/send', {            method: 'POST',            body: JSON.stringify(body),            headers: {                'Content-Type': 'application/json',                'Authorization': `Bearer ${this.#key}`,            },        });    }
    // #token?: string;    // #expires?: number;    // async #auth () {    //     if (this.#expires && this.#expires >= Date.now()) return;
    //     let response;
    //     if (this.#key) {    //         const iss = this.#key.client_email;    //         const iat = Math.round(Date.now() / 1000);    //         const exp = iat + (30 * 60);    //         const aud = 'https://oauth2.googleapis.com/token';    //         const scope = 'https://www.googleapis.com/auth/datastore';    //         const assertion = await jwt({ typ: 'JWT', alg: 'RS256', }, { exp, iat, iss, aud, scope }, this.#key.private_key);    //         response = await fetch('https://oauth2.googleapis.com/token', {    //             method: 'POST',    //             body: [    //                 `assertion=${encodeURIComponent(assertion)}`,    //                 `grant_type=${encodeURIComponent('urn:ietf:params:oauth:grant-type:jwt-bearer')}`    //             ].join('&'),    //             headers: { 'Content-Type': 'application/x-www-form-urlencoded' }    //         });    //     } else {    //         response = await fetch('http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/default/token', {    //             method: 'GET',    //             headers: { 'Metadata-Flavor':'Google' }    //         });    //     }
    //     const result = await response.json();
    //     if (result.error) {    //         throw new Error(JSON.stringify(result.error, null, '\t'));    //     }
    //     this.#token = result.access_token;    //     this.#expires = Date.now() + (result.expires_in * 1000);    // }
    // #gmail (data: Data) {    //     if (!this.#key) throw new Error('key required');
    //     this.#auth();
    //     const raw = btoa(    //         "From: alex.steven.elias@gmail.com\r\n" +    //         "To: alex@arcdev.io\r\n" +    //         "Subject: Subject Text\r\n\r\n" +    //         "The message text goes here"    //       ).replace(/\+/g, '-').replace(/\//g, '_').replace(/=+$/, '');
    //     return fetch('https://gmail.googleapis.com/gmail/v1/users/alex.steven.elias%40gmail.com/messages/send', {    //         method: 'POST',    //         body: JSON.stringify({    //             raw    //         }),    //         headers: {    //             'Accept': 'application/json',    //             'Content-Type': 'application/json',    //             'Authorization': `Bearer ${this.#token}`    //         }    //     });    // }
    key(key: string) {        this.#key = key;        return this;    }
    client(client: Client) {        this.#client = client;        return this;    }
    type(type: Type) {        this.#type = type;        return this;    }
    sandbox(sandbox: boolean) {        this.#sandbox = sandbox;        return sandbox;    }
    template(data: TemplateData) {        if (typeof data.content !== 'object') {            throw new Error('content not valid');        }
        const textLines = [];        const htmlLines = [];        const csvHead = [];        const csvLine = [];
        for (const name in data.content) {            const value = data.content[name];            htmlLines.push(Html.line(name, value));            textLines.push(Text.line(name, value));            csvHead.push(name);            csvLine.push(value);        }
        const text = Text.body(data, textLines);        const html = Html.body(data, htmlLines);
        const attachments = {            'data.csv': `${csvHead.join(',')}\n"${csvLine.join('","')}"`,        };
        return { text, html, attachments };    }
    send(data: SendData) {        if (!data) throw new Error('data required');        if (!data.to) throw new Error('to required');        if (!data.from) throw new Error('from required');
        data = { ...data };
        switch (this.#client) {            // case 'gmail': return this.#gmail(data);            case 'sendgrid':                return this.#sendGrid(data);            default:                throw new Error('client required');        }    }}