✨ Add Cloudinary module

src/app.module.ts

@@ -29,6 +29,7 @@ import { StripeModule } from './modules/stripe/stripe.module';
 import { UsersModule } from './modules/users/users.module';
 import { WebhooksModule } from './modules/webhooks/webhooks.module';
 import { AirtableModule } from './providers/airtable/airtable.module';
+import { CloudinaryModule } from './providers/cloudinary/cloudinary.module';
 import { DnsModule } from './providers/dns/dns.module';
 import { ElasticSearchModule } from './providers/elasticsearch/elasticsearch.module';
 import { GeolocationModule } from './providers/geolocation/geolocation.module';
@@ -70,6 +71,7 @@ import { TasksModule } from './providers/tasks/tasks.module';
     SlackModule,
     AirtableModule,
     S3Module,
+    CloudinaryModule,
   ],
   providers: [
     {

src/config/configuration.interface.ts

@@ -103,4 +103,10 @@ export interface Configuration {
     region: string;
     bucket?: string;
   };
+
+  cloudinary: {
+    cloudName: string;
+    apiKey: string;
+    apiSecret: string;
+  };
 }

src/config/configuration.ts

@@ -115,6 +115,11 @@ const configuration: Configuration = {
     region: process.env.S3_REGION ?? '',
     bucket: process.env.S3_BUCKET,
   },
+  cloudinary: {
+    cloudName: process.env.CLOUDINARY_CLOUD_NAME ?? '',
+    apiKey: process.env.CLOUDINARY_API_KEY ?? '',
+    apiSecret: process.env.CLOUDINARY_API_SECRET ?? '',
+  },
 };
 
 const configFunction: ConfigFactory<Configuration> = () => configuration;

src/providers/cloudinary/cloudinary.module.ts

@@ -0,0 +1,10 @@
+import { Module } from '@nestjs/common';
+import { ConfigModule } from '@nestjs/config';
+import { CloudinaryService } from './cloudinary.service';
+
+@Module({
+  imports: [ConfigModule],
+  providers: [CloudinaryService],
+  exports: [CloudinaryService],
+})
+export class CloudinaryModule {}

src/providers/cloudinary/cloudinary.service.ts

@@ -0,0 +1,64 @@
+import { Injectable, Logger } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
+import cloudinary, { UploadApiResponse } from 'cloudinary';
+import { Readable, Stream } from 'stream';
+import { Configuration } from '../../config/configuration.interface';
+
+/**
+ * MultiStream class helps convert buffers to a streams
+ * @source https://github.com/gagle/node-streamifier
+ */
+class MultiStream extends Readable {
+  _object: Buffer | string | undefined;
+  constructor(object: Buffer | string, options: any = {}) {
+    super();
+    this._object = object;
+    Stream.Readable.call(this, {
+      highWaterMark: options.highWaterMark,
+      encoding: options.encoding,
+    });
+  }
+  _read() {
+    this.push(this._object);
+    this._object = undefined;
+  }
+}
+
+/**
+ *
+ * @param object - Object to convert
+ * @param options - Configuration (encoding and highWaterMark)
+ */
+const createReadStream = (object: Buffer | string, options?: any) =>
+  new MultiStream(object, options);
+
+@Injectable()
+export class CloudinaryService {
+  private logger = new Logger(CloudinaryService.name);
+
+  constructor(private configService: ConfigService) {
+    const config = this.configService.get<Configuration['cloudinary']>(
+      'cloudinary',
+    );
+    if (config.cloudName)
+      cloudinary.v2.config({
+        cloud_name: config.cloudName,
+        api_key: config.apiKey,
+        api_secret: config.apiSecret,
+      });
+    else this.logger.warn('Cloudinary API key not found');
+  }
+
+  upload(buffer: Buffer | string, folder: string): Promise<UploadApiResponse> {
+    return new Promise((resolve, reject) => {
+      const uploadStream = cloudinary.v2.uploader.upload_stream(
+        { folder },
+        (error, result) => {
+          if (result) return resolve(result);
+          reject(error);
+        },
+      );
+      createReadStream(buffer).pipe(uploadStream);
+    });
+  }
+}