initial commit

Author: techird

.gitignore

@@ -0,0 +1 @@
+node_modules

README.md

@@ -0,0 +1,22 @@
+开发日志阅读器（DLR）
+=================
+
+本工具适合阅读开发环境的日志。
+
+传统的开发日志在终端输出，很多时候对日志进行跟踪、筛选、查找、格式化等工作会浪费较大的精力。
+
+DLR (Development Log Reader) 把本地开发进程的输出内容通过 WebSocket 重定向到浏览器，支持实时查看、筛选、查找以及 JSON 自动识别和格式化工作，可以大幅提升日志阅读的效率。
+
+![DLR 截图](./screenshot/1.png)
+
+## 安装
+
+```
+npm install dev-log-reader --global
+```
+
+## 使用
+
+``` 
+dlr -p 1234 -t QC_MAIN
+```

bin/reader.js

@@ -0,0 +1,104 @@
+#!/usr/bin/env node
+
+const fs = require('fs');
+const path = require('path');
+const http = require('http');
+const child_process = require('child_process');
+const WebSocket = require('ws');
+
+/** @type {WebSocket[]} */
+const clients = [];
+const logs = [];
+
+let lastLineTial = {}, lastLineSendTimer = {};
+const produce = (data, source) => {
+  clearTimeout(lastLineSendTimer[source]);
+  const chunk = (lastLineTial[source] || '') + data;
+  const lines = chunk.split(/\r?\n/g);
+  lastLineTial[source] = lines.pop();
+  for (let line of lines) {
+    console.log(line);
+    logs.push(line);
+  }
+  consume();
+  lastLineSendTimer[source] = setTimeout(() => {
+    if (lastLineTial[source]) {
+      logs.push(lastLineTial[source]);
+      lastLineTial[source] = '';
+      consume();
+    }
+  }, 100);
+}
+
+const consume = () => {
+  if (clients.length) {
+    for (let client of clients) {
+      while (logs.length) {
+        client.send(logs.shift());
+      }
+    }
+  }
+};
+
+const usage = () => {
+  console.log('Usage: dlr [-p,--port=number] [-t,--title=title] -- command');
+  process.exit(-1);
+};
+const args = process.argv.slice(2);
+const splitIndex = args.indexOf('--');
+
+if (splitIndex === -1) usage();
+
+const bootArgs = args.slice(0, splitIndex);
+const [taskCommand, ...taskArgs] = args.slice(splitIndex + 1);
+
+let port = 1234, title = 'LogReader';
+
+while (arg = bootArgs.shift()) {
+  let value;
+  if (arg === '-p' && (value = bootArgs.shift()) || /--port=(\d+)/.test(arg)) {
+    port = parseInt(value || RegExp.$1, 10);
+    if (isNaN(port)) {
+      usage();
+      break;
+    }
+    continue;
+  }
+  if (arg === '-t' && (value = bootArgs.shift()) || /--title=(.+)/.test(arg)) {
+    title = value || RegExp.$1;
+    if (!title) {
+      usage();
+      break;
+    }
+    continue;
+  }
+}
+
+const task = child_process.spawn(taskCommand, taskArgs);
+
+task.stdout.on('data', data => produce(data.toString('utf8'), 'stdout'));
+task.stderr.on('data', data => produce(data.toString('utf8'), 'stderr'));
+
+const server = http.createServer((req, res) => {
+  res.writeHead(200, {
+    'Content-Type': 'text/html',
+  });
+  res.write(fs.readFileSync(path.join(__dirname, '../static/index.html'), { encoding: 'utf8' }));
+  res.end();
+});
+
+const ws = new WebSocket.Server({ server });
+
+ws.on('connection', client => {
+  clients.push(client);
+  client.on('close', () => {
+    const index = clients.indexOf(client);
+    if (index > -1) {
+      clients.splice(index, 1);
+    }
+  });
+  consume();
+});
+
+server.listen(port);
+console.log(`Read logs in http://127.0.0.1:${port}?title=${encodeURIComponent(title)}`);

jsconfig.json

@@ -0,0 +1,10 @@
+{
+	"compilerOptions": {
+		"lib": [
+			"es2016"
+		]
+	},
+	"typeAcquisition": {
+		"enable": true
+	}
+}

package-lock.json

@@ -0,0 +1,18 @@
+{
+  "name": "dev-log-reader",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "bin": {
+    "dlr": "./bin/reader.js"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "@types/node": "^8.0.33",
+    "ws": "^3.2.0"
+  }
+}