Initial commit

Author: Oliver Schneider

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+/cache/

README.md

@@ -0,0 +1,19 @@
+# Pimatic Updater Server API
+
+Install
+
+```
+npm install
+```
+
+Make sure coffeescript is installed.
+
+```
+npm install coffeescript -g
+```
+
+Run
+
+```
+coffee server.coffee
+```

app.json

@@ -0,0 +1,18 @@
+{
+  /**
+   * Application configuration section
+   * http://pm2.keymetrics.io/docs/usage/application-declaration/
+   */
+  "apps" : [
+    {
+      "name"      : "update-server",
+      "script"    : "server.coffee",
+      "env_production" : {
+        "NODE_ENV": "production"
+      },
+      "log_date_format" : "YYYY-MM-DD HH:mm Z",
+      "out_file": "update-server.log",
+      "error_file": "update-server.log"
+    },
+  ],
+}

cache/.gitkeep

@@ -0,0 +1,80 @@
+Promise = require 'bluebird'
+npmregistry = require('./npmregistry')
+events = require('events')
+
+onError = (error) -> console.error error.stack
+
+class PluginMonitor extends events.EventEmitter
+
+  pluginsList: null
+  packageInfos: null
+
+  constructor: ->
+    super()
+    @pluginsList = npmregistry.getPluginListCached().then( (plugins) =>
+      @packageInfos = Promise.map(@pluginsList, (name) =>
+        return npmregistry.getInfoCached(name)
+      ).catch( (error) =>
+        onError(error)
+        @packageInfos = null
+      )
+      return plugins
+    )
+
+  updatePluginList: =>
+    oldPluginsList = @pluginsList or Promise.resolve([])
+    pending = npmregistry.getPluginList()
+      .then( (plugins) =>
+        return oldPluginsList.then( (oldPlugins) =>
+          if plugins.length is 0
+            # something went wrong
+            plugins = oldPlugins
+          @pluginsList = Promise.resolve(plugins)
+          for p in plugins
+            unless p in oldPlugins
+              @emit 'new', p
+          return @pluginsList
+        )
+      ).catch(onError)
+    unless @pluginsList?
+      @pluginsList = pending
+    # reschedule next hour to update
+    setTimeout(@updatePluginList, 60*60*1000)
+
+  updateNpmInfos: =>
+    oldPackageInfos = @packageInfos or Promise.resolve([])
+    pending = oldPackageInfos.then( (oldPackageInfos) =>
+      return @pluginsList.map( (name) =>
+        return npmregistry.getInfo(name).then( (info) =>
+          @_checkForUpdate(oldPackageInfos, info)
+          return info
+        ).catch( (error) =>
+          onError(error)
+          return Promise.resolve()
+        )
+      ).filter( (p) => p? ).then( (infos) =>
+        return @packageInfos = Promise.resolve(infos)
+      )
+    ).catch(onError)
+    unless @packageInfos?
+      @packageInfos = pending
+    # reschedule next 5min
+    setTimeout(@updateNpmInfos, 5*60*1000)
+
+  start: ->
+    @updatePluginList()
+    @updateNpmInfos()
+
+  _checkForUpdate: (oldPackageInfos, info) ->
+    for op in oldPackageInfos
+      if op.name is info.name
+        if op.version isnt info.version
+          @emit 'update', info
+        return
+    @emit 'update', info
+    return
+
+  getPluginList: -> @pluginsList
+  getNpmInfos: -> @packageInfos
+
+module.exports = {PluginMonitor}

monitor.coffee

@@ -0,0 +1,90 @@
+Promise = require 'bluebird'
+prequest = require 'request-promise'
+request = require 'request'
+exec = require('child_process').exec
+
+JSONStream = require('JSONStream')
+es = require('event-stream')
+
+fs = require('fs')
+Promise.promisifyAll(fs)
+
+module.exports = {
+
+  getInfo: (name) ->
+    prequest("https://registry.npmjs.org/#{name}").then( (res) ->
+      info = JSON.parse(res)
+      if info.error?
+        throw new Error("getting info about #{name} failed: #{info.reason}")
+      return fs.writeFileAsync("cache/#{name}.json", res)
+        .then( () => info )
+    )
+
+  getInfoCached: (name) ->
+    return fs.readFileAsync("cache/#{name}.json").then( (data) =>
+      return JSON.parse(data)
+    )
+
+  getAllPlugins: () ->
+    console.log "Fetching plugins"
+    last = null
+    count = 0
+    return new Promise( (resolve, reject) =>
+      packages = []
+      request(url: 'https://registry.npmjs.org/-/v1/search?text=pimatic-&size=250', (error, response, body) =>
+          if error
+            console.error(error, response.statusCode)
+            reject(error)
+        )
+        .pipe(JSONStream.parse('objects..name'))
+        .on('error', (err) ->
+          console.error(err)
+          reject(err)
+        )
+        .pipe es.mapSync (data) ->
+          count++
+          last = data
+          if data.indexOf("pimatic-") is 0
+            return data
+          else
+            return
+        .pipe es.writeArray (err, data) ->
+          if(err)
+            reject(err)
+          else
+            if data.length > 10
+              data.sort()
+              resolve(data)
+            else
+              reject(new Error('Incomplete data from npm registry: ' + data))
+    )
+
+  getPluginListCached: () ->
+    return fs.readFileAsync('cache/pluginlist.json').then( (data) =>
+      return JSON.parse(data)
+    ).catch( (err) ->
+      if(err.code == 'NOENT')
+        return []
+      throw err
+    )
+
+  getPluginList: () ->
+    return this.getAllPlugins().then( (allPlugins) =>
+      blacklist = [
+        'pimatic-plugin-template', 'pimatic-rest-api', 'pimatic-speak-api',
+        "pimatic-datalogger", "pimatic-redirect", "pimatic-datalogger",
+        "pimatic-homeduino-dst-dev", "pimatic-iwy-light-master", "pimatic-weather",
+        "pimatic-pilight", "pimatic-plugin-iwy-light-master", "pimatic-dhtxx",
+        "pimatic-plugin-commons"
+      ]
+      plugins = (
+        for p in allPlugins
+          continue if p.length is 0 or p in blacklist
+          p
+      )
+      plugins = ["pimatic"].concat plugins
+      return fs.writeFileAsync('cache/pluginlist.json', JSON.stringify(plugins))
+        .then( () => plugins )
+    )
+
+}