node_vag/api/server.js

//
//  Created by Mingliang Chen on 17/8/1.
//  illuspas[a]gmail.com
//  Copyright (c) 2018 Nodemedia. All rights reserved.
//


const Fs = require('fs');
const Http = require('http');
const Express = require('express');
const bodyParser = require("body-parser");
const basicAuth = require('basic-auth-connect');
const HTTP_PORT = 80;
const Logger = require('../core/logger');
const context = require('../core/ctx');
const vagRoute = require('./routes/vag');

class NodeHttpServer {
  constructor(config) {

    this.config = config;
    this.port = config.VAG.http.port = config.VAG.http.port ? config.VAG.http.port : HTTP_PORT;
    let app = Express();

    // 使用 body-parser 中间
    app.use(bodyParser.urlencoded({ extended: true }));
    app.use(bodyParser.json());

    if (this.config.VAG.auth && this.config.VAG.auth.api) {
      app.use('/api/*', basicAuth(this.config.VAG.auth.api_user, this.config.VAG.auth.api_pass));
    }

    // ntv 简化
    //app.use('/api/v1/vag', vagRoute(context));
    app.use('/api', vagRoute(context));

    app.get('/', (req, res, next) => {
      res.setHeader('Content-type', 'application/json');
      res.setHeader('Server', 'ntv-api-server on www.ruiboyun.com');
      res.send('{"success":true,"name":"api server","version":"1.1"}');
      res.end();
    });

    this.httpServer = Http.createServer(app);
  }

  run() {
    this.httpServer.listen(this.port, () => {
      Logger.log(`Http API Server started on port: ${this.port}`);
    });

    this.httpServer.on('error', (e) => {
      Logger.error(`Http API Server ${e}`);
    });

    this.httpServer.on('close', () => {
      Logger.log('Http API Server Close.');
    });
  }

  stop() {
    this.httpServer.close();
    if (this.httpsServer) {
      this.httpsServer.close();
    }
  }
}

module.exports = NodeHttpServer