wip

Author: juliangruber

README.md

@@ -4,5 +4,18 @@ WIP public electron update server.
 
 ## Routes
 
-### `/:owner/:repo/:platform/:version`
-### `/:owner/:repo/win32/:version/RELEASES`
+### `/:owner/:repo/update/:platform/:version`
+
+Check for updates
+
+### `/:owner/:repo/update/win32/:version/RELEASES`
+### `/:owner/:repo/download/:platform`
+
+Download latest
+
+## Development
+
+```bash
+$ npm install
+$ npm start
+```

bin/update-server.js

@@ -0,0 +1,12 @@
+#!/usr/bin/env node
+
+'use strict'
+
+process.title = 'update-server'
+
+const Updates = require('..')
+
+const updates = new Updates()
+const server = updates.listen(3000, () => {
+  console.log(`http://localhost:${server.address().port}`)
+})

index.js

@@ -1,17 +1,80 @@
 'use strict'
 
 const http = require('http')
-const hazel = require('hazel-server')
-
-const server = http.createServer((req, res) => {
-  const segs = req.url.split('/').filter(Boolean)
-  const [account, repository] = segs
-  if (!account || !repository) {
-    res.statusCode = 404
-    return res.end('Not found')
+
+class Updates {
+  constructor () {
+    this.cache = new Map()
+  }
+
+  listen (port, cb) {
+    const server = http.createServer((req, res) => {
+      this.handle(req, res).catch(err => {
+        console.error(err.stack)
+        res.statusCode = err.statusCode || 500
+        res.end(err.stack)
+      })
+    })
+    server.listen(port, cb)
+    return server
+  }
+
+  async handle (req, res) {
+    const segs = req.url.split('/').filter(Boolean)
+    const [account, repository, method, platform, version] = segs
+
+    if (account && repository && method === 'update' && platform && version) {
+      this.handleUpdate(res, account, repository, platform, version)
+    } else if (account && repository && method === 'download' && platform) {
+      this.handleDownload(res, account, repository, platform)
+    } else {
+      notFound(res)
+    }
+  }
+
+  handleUpdate (res, account, repository, platform, version) {
+    const key = `${account}/${repository}/${platform}`
+    if (this.cache.has(key)) {
+      const latest = this.cache.get(key)
+      if (latest.version === version) return noContent(res)
+      json(res, {
+        name: latest.version,
+        url: `/${account}/${repository}/download/${platform}`
+      })
+    } else {
+      if (this.cache.has(`${account / repository}`)) return notFound(res)
+    }
+  }
+
+  handleDownload (res, account, repository, platform) {
+    const key = `${account}/${repository}/${platform}`
+    if (this.cache.has(key)) {
+      const latest = this.cache.get(key)
+      redirect(res, latest.url)
+    } else {
+    }
   }
-  req.url = '/' + segs.slice(2).join('/')
-  hazel({ account, repository })(req, res)
-})
+}
+
+const notFound = res => {
+  res.statusCode = 404
+  res.end('Not found')
+}
+
+const noContent = res => {
+  res.statusCode = 204
+  res.end()
+}
+
+const json = (res, obj) => {
+  res.setHeader('Content-Type', 'application/json')
+  res.end(JSON.stringify(obj))
+}
+
+const redirect = (res, url) => {
+  res.statusCode = 302
+  res.setHeader('Location', url)
+  res.end(url)
+}
 
-server.listen(3000, () => console.log(`http://localhost:${server.address().port}`))
+module.exports = Updates