rumsan · sarojsht · Mar 11, 2024 · Mar 15, 2024 · Mar 15, 2024 · Mar 15, 2024
diff --git a/apps/sample/src/assets/wallet-verification.hbs b/apps/sample/src/assets/wallet-verification.hbs
@@ -0,0 +1,16 @@
+<!DOCTYPE html>
+<html lang="en">
+
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Wallet Verification</title>
+</head>
+
+<body>
+    <div class="container">
+        <p>Hi {{name}},</p>
+    </div>
+</body>
+
+</html>
diff --git a/libs/extensions/src/mailer/adapters/ejs.adapter.ts b/libs/extensions/src/mailer/adapters/ejs.adapter.ts
@@ -0,0 +1,78 @@
+import { inline } from '@css-inline/css-inline';
+import {
+  AsyncTemplateFunction,
+  ClientFunction,
+  TemplateFunction,
+  compile,
+} from 'ejs';
+import * as fs from 'fs';
+import { get } from 'lodash';
+import * as path from 'path';
+import {
+  MailerOptions,
+  TemplateAdapter,
+  TemplateAdapterConfig,
+} from '../../../../sdk/src/interfaces';
+
+export class EjsAdapter implements TemplateAdapter {
+  private precompiledTemplates: {
+    [name: string]: TemplateFunction | AsyncTemplateFunction | ClientFunction;
+  } = {};
+  private config: TemplateAdapterConfig = {
+    inlineCssOptions: {},
+    inlineCssEnabled: true,
+  };
+
+  constructor(config?: TemplateAdapterConfig) {
+    Object.assign(this.config, config);
+  }
+
+  public compile(mail: any, callback: any, mailerOptions: MailerOptions): void {
+    const { context, template } = mail.data;
+    const templateBaseDir = get(mailerOptions, 'template.dir', '');
+    const templateExt = path.extname(template) || '.ejs';
+    let templateName = path.basename(template, path.extname(template));
+    const templateDir = path.isAbsolute(template)
+      ? path.dirname(template)
+      : path.join(templateBaseDir, path.dirname(template));
+    const templatePath = path.join(
+      templateDir,
+      `${templateName}${templateExt}`,
+    );
+    templateName = path
+      .relative(templateBaseDir, templatePath)
+      .replace(templateExt, '');
+
+    if (!this.precompiledTemplates[templateName]) {
+      try {
+        const template = fs.readFileSync(templatePath, 'utf8');
+        this.precompiledTemplates[templateName] = compile(template, {
+          ...get(mailerOptions, 'template.ejs', {}),
+          filename: templatePath,
+        });
+      } catch (error) {
+        return callback(error);
+      }
+    }
+    const rendered = this.precompiledTemplates[templateName](context);
+
+    const render = (html: string) => {
+      if (this.config.inlineCssEnabled) {
+        try {
+          mail.data.html = inline(html, this.config.inlineCssOptions);
+        } catch (error) {
+          return callback(error);
+        }
+      } else {
+        mail.data.html = html;
+      }
+      return callback();
+    };
+
+    if (typeof rendered === 'string') {
+      render(rendered);
+    } else {
+      rendered.then(render);
+    }
+  }
+}
diff --git a/libs/extensions/src/mailer/adapters/handlebars.adapter.ts b/libs/extensions/src/mailer/adapters/handlebars.adapter.ts
@@ -0,0 +1,117 @@
+import { inline } from '@css-inline/css-inline';
+import * as fs from 'fs';
+import * as glob from 'glob';
+import * as handlebars from 'handlebars';
+import { HelperDeclareSpec } from 'handlebars';
+import { get } from 'lodash';
+import * as path from 'path';
+import {
+  MailerOptions,
+  TemplateAdapter,
+  TemplateAdapterConfig,
+} from '../../../../sdk/src/interfaces';
+
+export class HandlebarsAdapter implements TemplateAdapter {
+  private precompiledTemplates: {
+    [name: string]: handlebars.TemplateDelegate;
+  } = {};
+
+  private config: TemplateAdapterConfig = {
+    inlineCssOptions: {},
+    inlineCssEnabled: true,
+  };
+
+  constructor(helpers?: HelperDeclareSpec, config?: TemplateAdapterConfig) {
+    handlebars.registerHelper('concat', (...args) => {
+      args.pop;
+      return args.join('');
+    });
+    handlebars.registerHelper(helpers || {});
+    Object.assign(this.config, config);
+  }
+
+  public compile(mail: any, callback: any, mailerOptions: MailerOptions): void {
+    const precompile = (template: any, callback: any, options: any) => {
+      const templateBaseDir = get(options, 'dir', '');
+      const templateExt = path.extname(template) || '.hbs';
+      let templateName = path.basename(template, path.extname(template));
+      const templateDir = path.isAbsolute(template)
+        ? path.dirname(template)
+        : path.join(templateBaseDir, path.dirname(template));
+      const templatePath = path.join(templateDir, templateName + templateExt);
+      templateName = path
+        .relative(templateBaseDir, templatePath)
+        .replace(templateExt, '');
+      if (!this.precompiledTemplates[templateName]) {
+        try {
+          const template = fs.readFileSync(templatePath, 'utf8');
+          this.precompiledTemplates[templateName] = handlebars.compile(
+            template,
+            get(options, 'options', {}),
+          );
+        } catch (error) {
+          return callback(error);
+        }
+      }
+
+      return {
+        templateExt,
+        templateName,
+        templateDir,
+        templatePath,
+      };
+    };
+    const { templateName } = precompile(
+      mail.data.template,
+      callback,
+      mailerOptions.template,
+    );
+
+    const runtimeOptions = get(mailerOptions, 'options', {
+      partials: false,
+      data: {},
+    });
+
+    if (runtimeOptions.partials) {
+      const partialPath = path
+        .join(runtimeOptions.partials.dir, '**', '*.hbs')
+        .replace(/\\/g, '/');
+      const files = glob.sync(partialPath);
+
+      files.forEach((file) => {
+        const { templateName, templatePath } = precompile(
+          file,
+          () => {},
+          runtimeOptions.partials,
+        );
+        const templateDir = path.relative(
+          runtimeOptions.partials.dir,
+          path.dirname(templatePath),
+        );
+        handlebars.registerPartial(
+          path.join(templateDir, templateName),
+          fs.readFileSync(templatePath, 'utf8'),
+        );
+      });
+    }
+
+    const rendered = this.precompiledTemplates[templateName](
+      mail.data.context,
+      {
+        ...runtimeOptions,
+        partials: this.precompiledTemplates,
+      },
+    );
+
+    if (this.config.inlineCssEnabled) {
+      try {
+        mail.data.html = inline(rendered, this.config.inlineCssOptions);
+      } catch (error) {
+        callback(error);
+      }
+    } else {
+      mail.data.html = rendered;
+    }
+    return callback();
+  }
+}
diff --git a/libs/extensions/src/mailer/adapters/index.ts b/libs/extensions/src/mailer/adapters/index.ts
@@ -0,0 +1,2 @@
+export * from './ejs.adapter';
+export * from './handlebars.adapter';
diff --git a/libs/extensions/src/mailer/index.ts b/libs/extensions/src/mailer/index.ts
@@ -0,0 +1,5 @@
+export * from './adapters';
+export * from './mailer-core.module';
+export * from './mailer-transport.factory';
+export * from './mailer.module';
+export * from './mailer.service';
diff --git a/libs/extensions/src/mailer/mailer-core.module.ts b/libs/extensions/src/mailer/mailer-core.module.ts
@@ -0,0 +1,77 @@
+import {
+  DynamicModule,
+  Global,
+  Module,
+  Provider,
+  ValueProvider,
+} from '@nestjs/common';
+import { MAILER_OPTIONS } from '../../../sdk/src/constants';
+import {
+  MailerAsyncOptions,
+  MailerOptions,
+  MailerOptionsFactory,
+} from '../../../sdk/src/interfaces';
+import { MailerService } from './mailer.service';
+
+@Global()
+@Module({})
+export class MailerCoreModule {
+  public static forRoot(options: MailerOptions): DynamicModule {
+    const MailerOptionsProvider: ValueProvider<MailerOptions> = {
+      provide: MAILER_OPTIONS,
+      useValue: options,
+    };
+
+    return {
+      module: MailerCoreModule,
+      providers: [MailerOptionsProvider, MailerService],
+      exports: [MailerService],
+    };
+  }
+
+  public static forRootAsync(options: MailerAsyncOptions): DynamicModule {
+    const providers: Provider[] = this.createAsyncProviders(options);
+    return {
+      module: MailerCoreModule,
+      providers: [
+        ...providers,
+        MailerService,
+        ...(options.extraProviders || []),
+      ],
+      imports: options.imports,
+      exports: [MailerService],
+    };
+  }
+
+  private static createAsyncProviders(options: MailerAsyncOptions): Provider[] {
+    const providers: Provider[] = [this.createAsyncOptionsProvider(options)];
+
+    if (options.useClass) {
+      providers.push({
+        provide: options.useClass,
+        useClass: options.useClass,
+      });
+    }
+    return providers;
+  }
+
+  public static createAsyncOptionsProvider(
+    options: MailerAsyncOptions,
+  ): Provider {
+    if (options.useFactory) {
+      return {
+        provide: MAILER_OPTIONS,
+        useFactory: options.useFactory,
+        inject: options.inject || [],
+      };
+    }
+
+    return {
+      provide: MAILER_OPTIONS,
+      useFactory: async (optionsFactory: MailerOptionsFactory) => {
+        return optionsFactory.createMailerOptions();
+      },
+      inject: [options?.useExisting! || options?.useClass!],
+    };
+  }
+}
diff --git a/libs/extensions/src/mailer/mailer-transport.factory.ts b/libs/extensions/src/mailer/mailer-transport.factory.ts
@@ -0,0 +1,21 @@
+import { Inject } from '@nestjs/common';
+import { MAILER_OPTIONS } from '@rumsan/sdk/constants';
+import { createTransport } from 'nodemailer';
+import {
+  MailerTransportFactory as IMailerTransportFactory,
+  MailerOptions,
+} from '../../../sdk/src/interfaces';
+import { TransportType } from '../../../sdk/src/types';
+
+export class MailerTransportFactory implements IMailerTransportFactory {
+  constructor(
+    @Inject(MAILER_OPTIONS) private readonly options: MailerOptions,
+  ) {}
+
+  public createTransport(opts?: TransportType): any {
+    return createTransport(
+      opts || this.options.transport,
+      this.options.defaults,
+    );
+  }
+}
diff --git a/libs/extensions/src/mailer/mailer.module.ts b/libs/extensions/src/mailer/mailer.module.ts
@@ -0,0 +1,19 @@
+import { DynamicModule, Module } from '@nestjs/common';
+import { MailerAsyncOptions, MailerOptions } from '../../../sdk/src/interfaces';
+import { MailerCoreModule } from './mailer-core.module';
+@Module({})
+export class MailerModule {
+  public static forRoot(options?: MailerOptions): DynamicModule {
+    return {
+      module: MailerModule,
+      imports: [MailerCoreModule.forRoot(options!)],
+    };
+  }
+
+  public static forRootAsync(options: MailerAsyncOptions): DynamicModule {
+    return {
+      module: MailerModule,
+      imports: [MailerCoreModule.forRootAsync(options)],
+    };
+  }
+}
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		export * from './ejs.adapter';
		export * from './handlebars.adapter';