graphql upload express

1
2//resolvers.js
3export default {
4	Query: {
5		usersActivation() {
6			return 'Hello Wordl'
7		}
8	},
9	Mutation: {
10		uploadFile: async (parent, { file }) => {
11			const { filename, createReadStream } = await file.promise
12			fileUpload({ filename, stream: createReadStream() })
13			return true
14		}
15	}
16}
17
18//typedefs.js
19export default gql(`
20	 scalar Upload
21
22	 type Query {
23		helloWordl : String!
24	 }
25
26	type Mutation {
27		uploadFile(file: Upload!): Boolean
28	  }
29	`)
30
31// util.upload.js
32const uploadFile = ({ filename, stream }) => {
33	stream
34		.pipe(createWriteStream(resolve(process.cwd(), `src/images/${filename}`)))
35		.on('finish', () => Promise.resolve())
36		.on('error', Promise.reject)
37}
38
39const validateFile = ({ filename, stream }) => {
40	const extFile = filename.replace('.', '')
41    
42	const extPattern = /(jpg|jpeg|png|gif|svg)/gi.test(extFile)
43	if (!extPattern) throw new TypeError('Image format is not valid')
44
45	const fileExits = existsSync(resolve(process.cwd(), `src/images/${filename}`))
46	if (!fileExits) return uploadFile({ filename, stream })
47
48	unlink(resolve(process.cwd(), `src/images/${filename}`), (error) => {
49		if (error) throw error
50		return uploadFile({ filename, stream })
51	})
52}
53
54export const fileUpload = ({ filename, stream }) =>
55	filename ? validateFile({ filename, stream }) : new Error('Image is required')
56
57
58// request query playground
59mutation UPLOAD_FILE($file: Upload!) {
60  uploadFile(file: $file)
61}