cli.js

   1 #!/usr/bin/env node
   2
   3 /*
   4  * Copyright (C) 2018 Nick Downing <nick@ndcode.org>
   5  * SPDX-License-Identifier: MIT
   6  *
   7  * Permission is hereby granted, free of charge, to any person obtaining a copy
   8  * of this software and associated documentation files (the "Software"), to
   9  * deal in the Software without restriction, including without limitation the
  10  * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
  11  * sell copies of the Software, and to permit persons to whom the Software is
  12  * furnished to do so, subject to the following conditions:
  13  *
  14  * The above copyright notice and this permission notice shall be included in
  15  * all copies or substantial portions of the Software.
  16  *
  17  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  18  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  19  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  20  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  21  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  22  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  23  * IN THE SOFTWARE.
  24  */
  25
  26 // must load index first, to avoid circular dependency issue
  27 let jst_server = require('./index')
  28
  29 let JSTCache = require('@ndcode/jst_cache')
  30 let Resources = require('./Resources')
  31 let Server = require('./Server')
  32
  33 ;(
  34   async () => {
  35     let resources = new Resources()
  36     let jst_cache = await resources.ref(
  37       'jst_cache:.',
  38       async () => new JSTCache('.', {_jst_server: jst_server}, true)
  39     )
  40     let server = undefined
  41
  42     // refresh the config immediately, then every 1 second,
  43     // use setTimeout() instead of setInterval() to avoid bunches
  44     // of calls after the computer has been suspended for a while
  45     let refresh_config = async () => {
  46       try {
  47         let config = await jst_cache.get('_config/server.jst', true)
  48         if (config !== undefined) {
  49           let prev_server = server
  50           let new_server = await config(resources, prev_server)
  51           await new_server.start() // exception here cancels server change
  52           server = new_server
  53           if (prev_server !== undefined)
  54             await prev_server.stop() // exception here doesn't cancel change
  55         }
  56         await server.kick()
  57       }
  58       catch (err) {
  59         console.error(err.stack || err.message)
  60       }
  61       setTimeout(refresh_config, 1000)
  62       // returned Promise will be ignored
  63     }
  64     refresh_config()
  65   }
  66 )()