"use strict"; const log = require("../../log"); const fs = require("fs"); const fsextra = require("fs-extra"); const path = require("path"); const filenamify = require("filenamify"); const Helper = require("../../helper"); const Msg = require("../../models/msg"); class TextFileMessageStorage { constructor(client) { this.client = client; this.isEnabled = false; } enable() { this.isEnabled = true; } close(callback) { this.isEnabled = false; if (callback) { callback(); } } index(network, channel, msg) { if (!this.isEnabled) { return; } const logPath = path.join(Helper.getUserLogsPath(), this.client.name, TextFileMessageStorage.getNetworkFolderName(network)); try { fsextra.ensureDirSync(logPath); } catch (e) { log.error("Unable to create logs directory", e); return; } let line = `[${log.getHumanDate(msg.time)}] `; // message types from src/models/msg.js switch (msg.type) { case Msg.Type.ACTION: // [2014-01-01 00:00:00] * @Arnold is eating cookies line += `* ${msg.from.mode}${msg.from.nick} ${msg.text}`; break; case Msg.Type.JOIN: // [2014-01-01 00:00:00] *** Arnold (~arnold@foo.bar) joined line += `*** ${msg.from.nick} (${msg.hostmask}) joined`; break; case Msg.Type.KICK: // [2014-01-01 00:00:00] *** Arnold was kicked by Bernie (Don't steal my cookies!) line += `*** ${msg.target.nick} was kicked by ${msg.from.nick} (${msg.text})`; break; case Msg.Type.MESSAGE: // [2014-01-01 00:00:00] <@Arnold> Put that cookie down.. Now!! line += `<${msg.from.mode}${msg.from.nick}> ${msg.text}`; break; case Msg.Type.MODE: // [2014-01-01 00:00:00] *** Arnold set mode +o Bernie line += `*** ${msg.from.nick} set mode ${msg.text}`; break; case Msg.Type.NICK: // [2014-01-01 00:00:00] *** Arnold changed nick to Bernie line += `*** ${msg.from.nick} changed nick to ${msg.new_nick}`; break; case Msg.Type.NOTICE: // [2014-01-01 00:00:00] -Arnold- pssst, I have cookies! line += `-${msg.from.nick}- ${msg.text}`; break; case Msg.Type.PART: // [2014-01-01 00:00:00] *** Arnold (~arnold@foo.bar) left (Bye all!) line += `*** ${msg.from.nick} (${msg.hostmask}) left (${msg.text})`; break; case Msg.Type.QUIT: // [2014-01-01 00:00:00] *** Arnold (~arnold@foo.bar) quit (Connection reset by peer) line += `*** ${msg.from.nick} (${msg.hostmask}) quit (${msg.text})`; break; case Msg.Type.CHGHOST: // [2014-01-01 00:00:00] *** Arnold changed host to: new@fancy.host line += `*** ${msg.from.nick} changed host to '${msg.new_ident}@${msg.new_host}'`; break; case Msg.Type.TOPIC: // [2014-01-01 00:00:00] *** Arnold changed topic to: welcome everyone! line += `*** ${msg.from.nick} changed topic to '${msg.text}'`; break; default: // unhandled events will not be logged return; } line += "\n"; fs.appendFile(path.join(logPath, `${cleanFilename(channel.name)}.log`), line, (e) => { if (e) { log.error("Failed to write user log", e); } }); } getMessages() { // Not implemented for text log files // They do not contain enough data to fully re-create message objects // Use sqlite storage instead return Promise.resolve([]); } canProvideMessages() { return false; } static getNetworkFolderName(network) { // Limit network name in the folder name to 23 characters // So we can still fit 12 characters of the uuid for de-duplication const networkName = cleanFilename(network.name.substring(0, 23).replace(/ /g, "-")); return `${networkName}-${network.uuid.substring(networkName.length + 1)}`; } } module.exports = TextFileMessageStorage; function cleanFilename(name) { name = filenamify(name, {replacement: "_"}); name = name.toLowerCase(); return name; }