import { GraphQLError } from 'graphql' import { ANON_USER_ID, IMAGE_PIXELS_MAX, UPLOAD_SIZE_MAX, UPLOAD_TYPES_ALLOW } from '../../lib/constants' import { createPresignedPost } from '../s3' export default { Mutation: { getSignedPOST: async (parent, { type, size, width, height, avatar }, { models, me }) => { if (UPLOAD_TYPES_ALLOW.indexOf(type) === -1) { throw new GraphQLError(`image must be ${UPLOAD_TYPES_ALLOW.map(t => t.replace('image/', '')).join(', ')}`, { extensions: { code: 'BAD_INPUT' } }) } if (size > UPLOAD_SIZE_MAX) { const UPLOAD_SIZE_MAX_MB = UPLOAD_SIZE_MAX / 1024 / 1024 throw new GraphQLError(`image must be less than ${UPLOAD_SIZE_MAX_MB} megabytes`, { extensions: { code: 'BAD_INPUT' } }) } if (width * height > IMAGE_PIXELS_MAX) { throw new GraphQLError(`image must be less than ${IMAGE_PIXELS_MAX} pixels`, { extensions: { code: 'BAD_INPUT' } }) } const { photoId } = me ? await models.user.findUnique({ where: { id: me.id } }) : {} const data = { type, size, width, height, userId: me?.id || ANON_USER_ID, // avatar uploads are always free paid: avatar && !!me ? undefined : false } let uploadId // avatar uploads overwrite the previous avatar if (avatar && photoId) uploadId = photoId if (uploadId) { await models.upload.update({ data, where: { id: uploadId } }) } else { const upload = await models.upload.create({ data }) uploadId = upload.id } // get presigned POST url return createPresignedPost({ key: String(uploadId), type, size }) } } }