Refactor avatar upload control flow

api/resolvers/upload.js

@@ -21,30 +21,38 @@ export default {
         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 imgParams = {
-
-      const data = {
         type,
         size,
         width,
         height,
-        userId: me?.id || ANON_USER_ID,
+        userId: me?.id || ANON_USER_ID
-        // avatar uploads are always free
-        paid: avatar && !!me ? undefined : false
       }
 
+      if (avatar) {
+        if (!me) throw new GraphQLError('you must be logged in', { extensions: { code: 'FORBIDDEN' } })
+        return avatarGetSignedPOST({ me, models, imgParams })
+      }
+
+      const upload = await models.upload.create({ data: { ...imgParams, paid: false } })
+      return createPresignedPost({ key: String(upload.id), type, size })
+    }
+  }
+}
+
+async function avatarGetSignedPOST ({ me, models, imgParams }) {
+  // avatar uploads are always free
+  imgParams.paid = undefined
+
+  const { photoId } = await models.user.findUnique({ where: { id: me.id } })
   let uploadId
-      // avatar uploads overwrite the previous avatar
+  if (photoId) {
-      if (avatar && photoId) uploadId = photoId
+    await models.upload.update({ data: imgParams, where: { id: photoId } })
-      if (uploadId) {
+    uploadId = photoId
-        await models.upload.update({ data, where: { id: uploadId } })
   } else {
-        const upload = await models.upload.create({ data })
+    const upload = await models.upload.create({ data: imgParams })
     uploadId = upload.id
   }
 
-      // get presigned POST url
+  return createPresignedPost({ key: String(uploadId), type: imgParams.type, size: imgParams.size })
-      return createPresignedPost({ key: String(uploadId), type, size })
-    }
-  }
 }