Handle participant picture upload

Author: Ismaila Abdoulahi

package.json

@@ -32,6 +32,7 @@
     "dotenv": "^8.0.0",
     "graphql": "^14.4.2",
     "graphql-tools": "^4.0.5",
+    "graphql-upload": "^8.0.7",
     "mongoose": "^5.6.5",
     "reflect-metadata": "^0.1.12",
     "rimraf": "^2.6.2",

schema.gql

@@ -10,7 +10,7 @@ type Mutation {
 input NewParticipantInput {
   firstName: String!
   lastName: String!
-  picture: String
+  picture: Upload
 
   """Participant status (e.g. Student, Coach, etc.). Default = Student"""
   status: String
@@ -39,3 +39,6 @@ input SocialMediaInput {
   url: String!
   platform: String
 }
+
+"""The `Upload` scalar type represents a file upload."""
+scalar Upload

src/file/file.module.ts

@@ -5,5 +5,6 @@ import { ConfigModule } from '../config/config.module';
 @Module({
   imports: [ConfigModule],
   providers: [FileService],
+  exports: [FileService],
 })
 export class FileModule {}

src/file/file.service.ts

@@ -15,14 +15,14 @@ export class FileService {
 
   /**
    * Stores file by passing it to the cloud storage
-   * @param {Stream} file a file stream
+   * @param file a file stream
    * @param {string} tags tags to give to the file
    * @param {string} folder folder in which to store the file
    * @param {object} cloudinary cloudinary functions
    * @param {boolean} generated flag that tells whether the file has been generated by the backend or not
    * @returns {Promise} Promise that represents the file
    */
-  store(file: Stream, folder: string, tags: string): Promise<any> {
+  store(file, folder: string, tags?: string): Promise<any> {
     const country = this.configService.get('COUNTRY');
     const edition = this.configService.get('EDITION');
     return new Promise((resolve, reject) => {
@@ -35,7 +35,7 @@ export class FileService {
           return reject(err);
         },
       );
-      file.pipe(uploadStream);
+      file.createReadStream().pipe(uploadStream);
     });
   }
 }

src/participant/inputs/new.particpant.input.ts

@@ -1,4 +1,5 @@
 import { InputType, Field } from 'type-graphql';
+import { GraphQLUpload } from 'graphql-upload';
 import { SocialMediaInput } from './social.media.input';
 
 @InputType()
@@ -9,8 +10,8 @@ export class NewParticipantInput {
   @Field()
   lastName: string;
 
-  @Field({ nullable: true })
-  picture?: string;
+  @Field(type => GraphQLUpload, { nullable: true })
+  picture?: any;
 
   @Field({
     nullable: true,

src/participant/participant.module.ts

@@ -3,9 +3,15 @@ import { ParticipantService } from './participant.service';
 import { ParticipantResolver } from './participant.resolver';
 import { MongooseModule } from '@nestjs/mongoose';
 import { ParticipantSchema } from './schemas/participant.schema';
+import { FileModule } from '../file/file.module';
 
 @Module({
-  imports: [MongooseModule.forFeature([{ name: 'Participant', schema: ParticipantSchema }])],
+  imports: [
+    MongooseModule.forFeature([
+      { name: 'Participant', schema: ParticipantSchema },
+    ]),
+    FileModule,
+  ],
   providers: [ParticipantResolver, ParticipantService],
 })
 export class StudentModule {}

src/participant/participant.service.ts

@@ -2,15 +2,22 @@ import { Injectable } from '@nestjs/common';
 import { IParticipant } from './interfaces/participant.interface';
 import { InjectModel } from '@nestjs/mongoose';
 import { Model } from 'mongoose';
+import { FileService } from '../file/file.service';
 
 @Injectable()
 export class ParticipantService {
   constructor(
     @InjectModel('Participant')
     private readonly participantModel: Model<IParticipant>,
+    private readonly fileService: FileService,
   ) {}
 
   async create(input: any): Promise<IParticipant> {
+    const { picture } = input;
+    if (picture) {
+      const file = await this.fileService.store(await picture, 'participants');
+      input.picture = file.secure_url;
+    }
     return this.participantModel.create(input);
   }