Copy text logging between examples.

examples/json-live-data-server/config.js.example

@@ -30,6 +30,30 @@ const config = {
      */
     loggingFilename: path.resolve(__dirname, 'live-data.json'),
 
+    /**
+     * Text file logging interval in milliseconds. A value of zero disables this functionality.
+     */
+    textLoggingInterval: 0,
+
+    /**
+     * Text file logging time to live in milliseconds.
+     */
+    textLoggingTimeToLive: 60000,
+
+    /**
+     * Text file logging directory.
+     */
+    textLoggingPath: path.resolve(__dirname, 'log'),
+
+    /**
+     * Text file logging options, passed to the `TextConverter` constructor.
+     */
+    textLoggingOptions: {
+        columnSeparator: '\t',
+        lineSeparator: '\r\n',
+        separateDateAndTime: false,
+    },
+
     /**
      * Either 'TcpConnection' or 'SerialConnection' to connect to the VBus.
      * @type {String}

examples/json-live-data-server/index.js

@@ -17,6 +17,7 @@ const {
     Specification,
     SerialConnection,
     TcpConnection,
+    TextConverter,
     VBusRecordingConverter,
     utils: {
         promisify,
@@ -653,13 +654,18 @@ async function main(options) {
         interval: config.loggingInterval,
     });
 
+    const textHeaderSetConsolidator = new HeaderSetConsolidator({
+        timeToLive: config.textLoggingTimeToLive,
+    });
+
     const ConnectionClass = connectionClassByName [config.connectionClassName];
 
     const connection = new ConnectionClass(config.connectionOptions);
 
     connection.on('packet', (packet) => {
         headerSet.addHeader(packet);
         hsc.addHeader(packet);
+        textHeaderSetConsolidator.addHeader(packet);
         processEmSimulatorPacket(connection, packet);
     });
 
@@ -672,6 +678,53 @@ async function main(options) {
         }
     });
 
+    if (config.textLoggingInterval) {
+        let currentDatecode = null;
+
+        let currentConverter = null;
+
+        const onHeaderSet = async (headerSet) => {
+            const datecode = spec.i18n.moment(headerSet.timestamp).format('YYYYMMDD');
+            if (currentDatecode !== datecode) {
+                currentDatecode = datecode;
+
+                if (currentConverter) {
+                    currentConverter.finish();
+                    currentConverter = null;
+                }
+
+                const filename = path.resolve(config.textLoggingPath, datecode + '.csv');
+
+                const file = fs.createWriteStream(filename, { flags: 'a' });
+
+                const options = Object.assign({}, config.textLoggingOptions, {
+                    specification: spec,
+                });
+
+                const converter = new TextConverter(options);
+                converter.pipe(file);
+
+                currentConverter = converter;
+            }
+
+            if (currentConverter) {
+                currentConverter.convertHeaderSet(headerSet);
+            }
+        };
+
+        logger.debug('Starting text logging');
+
+        const hsc = new HeaderSetConsolidator({
+            interval: config.textLoggingInterval,
+        });
+
+        hsc.on('headerSet', () => {
+            onHeaderSet(textHeaderSetConsolidator);
+        });
+
+        hsc.startTimer();
+    }
+
     await connection.connect();
 
     logger.info('Ready to serve from the following URLs:');