moscajs / aedes-logging

Logging module for Aedes, based on Pino
MIT License
8 stars 4 forks source link

[question] is still active this repo? #7

Open thej4ck opened 4 years ago

thej4ck commented 4 years ago

i've installed it but i cannot get any logs.

var wsPort = 1883;
var wsSslPort = 1885;

var fs = require('fs');
var aedes = require('aedes')();
var logging = require('aedes-logging');
var ws = require('websocket-stream');
// WsSsl server
var wsSslServer = require('https').createServer({
    key: fs.readFileSync("./scao.key"),
    cert: fs.readFileSync("./scao.crt"),
    requestCert: false // client send their certificate
    //rejectUnauthorized: true,
    //ca: [ fs.readFileSync("./scao.crt") ]
});
ws.createServer({
  server: wsSslServer
}, aedes.handle);
wsSslServer.listen(wsSslPort, "0.0.0.0", function () {
  console.log('MQTT websocket tls server listening on port', wsSslPort)
});

// Ws server
var wsServer = require('http').createServer();
ws.createServer({
  server: wsServer
}, aedes.handle);
wsServer.listen(wsPort, "0.0.0.0", function () {
    console.log('MQTT websocket server listening on port', wsPort)
});

var servers = [ wsServer, wsSslServer ];
var instance    = aedes;

logging({
    instance: instance,
    servers: servers
  })
*/

  'use strict'

var fs = require('fs')
var path = require('path')
var http = require('http')
var https = require('https')
var websocket = require('websocket-stream')
var net = require('net')
var tls = require('tls')
var aedes = require('aedes')
var logging = require('aedes-logging')
var instance = aedes()

var servers = [
  startHttp(),
  startHttps(),
  startNet(),
  startTLS()
]

logging({
  instance: instance,
  servers: servers
})

function startHttp () {
  var server = http.createServer()
  websocket.createServer({
    server: server
  }, instance.handle)
  server.listen(8880)
  return server
}

function startHttps () {
  var server = https.createServer({
    key: fs.readFileSync(path.join(__dirname, 'cert', 'scao.key')),
    cert: fs.readFileSync(path.join(__dirname, 'cert', 'scao.crt'))
  })
  websocket.createServer({
    server: server
  }, instance.handle)
  server.listen(8881)
  return server
}

function startNet () {
  return net.createServer(instance.handle).listen(8882)
}

function startTLS () {
  return tls.createServer({
    key: fs.readFileSync(path.join(__dirname, 'cert', 'scao.key')),
    cert: fs.readFileSync(path.join(__dirname, 'cert', 'scao.crt'))
  }, instance.handle).listen(8883)
}
mcollina commented 4 years ago

This module likely needs some work, would you like to send a PR?