first commit 🎉

Author: mathieudutour

.gitignore

@@ -0,0 +1,6 @@
+# package directories
+node_modules
+jspm_packages
+
+# Serverless directories
+.serverless

.vscode/settings.json

@@ -0,0 +1,5 @@
+// Place your settings in this file to overwrite default and user settings.
+{
+  "standard.enable": true,
+  "eslint.enable": false
+}

api/_cleanBody.js

@@ -0,0 +1,12 @@
+module.exports = function cleanBody (body) {
+  const res = {
+    githubId: body.githubId
+  }
+  if (body.email) {
+    res.email = body.email
+  }
+  if (body.login) {
+    res.login = body.login
+  }
+  return res
+}

api/getOne.js

@@ -0,0 +1,14 @@
+const storage = require('../storage')()
+
+module.exports.handler = (event, context, callback) => {
+  storage
+    .findOne(event.githubId)
+    .then(item => {
+      if (!item) {
+        callback(new Error('[404] Not found'))
+        return
+      }
+      callback(null, item)
+    })
+    .catch(callback)
+}

api/login.js

@@ -0,0 +1,34 @@
+const storage = require('../storage')()
+const cleanBody = require('./_cleanBody')
+
+module.exports.handler = (event, context, callback) => {
+  let parsedBody
+  try {
+    parsedBody = JSON.parse(event.body || {})
+  } catch (e) {
+    callback(new Error('[400] Could not parse the body'))
+    return
+  }
+
+  const body = cleanBody(parsedBody)
+  if (!body.githubId) {
+    callback(new Error('[400] Missing github ID'))
+    return
+  }
+
+  storage
+    .findOne(body.githubId)
+    .then(found => {
+      if (found) {
+        return callback(null, {
+          ok: true,
+          message: 'Already logged in'
+        })
+      }
+      return storage.create(body).then(() => callback(null, {
+        ok: true,
+        message: 'Logged in'
+      }))
+    })
+    .catch(callback)
+}

api/unlock.js

@@ -0,0 +1,70 @@
+const stripe = require('stripe')(process.env.STRIPE_SECRET)
+const storage = require('../storage')()
+const cleanBody = require('./_cleanBody')
+
+module.exports.handler = (event, context, callback) => {
+  let parsedBody
+  try {
+    parsedBody = JSON.parse(event.body || {})
+  } catch (e) {
+    callback(new Error('[400] Could not parse the body'))
+    return
+  }
+
+  const body = cleanBody(parsedBody)
+  if (!body.githubId) {
+    callback(new Error('[400] Missing github ID'))
+    return
+  }
+
+  const token = parsedBody.token
+  let method
+  let bailout = false
+
+  storage
+    .findOne(body.githubId)
+    .then(found => {
+      if (found) {
+        if (found.valid) {
+          callback(new Error('[403] Already unlocked'))
+          bailout = true
+          return
+        }
+        method = 'update'
+        return
+      }
+      method = 'create'
+    })
+    .then(() => {
+      if (bailout) { return }
+      return stripe.customers.create({
+        email: body.email,
+        source: token
+      })
+    })
+    .then(customer => {
+      if (bailout) { return }
+      console.log(customer)
+      body.stripeId = customer.id
+      return stripe.subscriptions.create({
+        customer: customer.id,
+        plan: 'kactus-1-month'
+      })
+    })
+    .then(res => {
+      if (bailout) { return }
+      console.log(res)
+      body.valid = true
+    })
+    .then(() => {
+      if (bailout) { return }
+      return storage[method](body)
+    })
+    .then(res => {
+      if (bailout) { return }
+      callback(null, {
+        message: 'Unlocked full access'
+      })
+    })
+    .catch(callback)
+}