const qs = require('querystring');
const crypto = global.yoho.crypto;
const logger = global.yoho.logger;

class Message {
    constructor(measurement, tags, fields, time) {
        this.measurement = measurement;
        this.tags = tags;
        this.fields = fields;
        this.time = time;
    }
}

function parseMessage(line) {
    let measurement = line.split(',', 1)[0];
    let body = line.substring(measurement.length + 1);
    let tokens = body.split(' ');

    let [tags, fields, time] = [qs.parse(tokens[0], ',', '='), qs.parse(tokens[1], ',', '='), tokens[2]];

    if (tags.route) {
        try {
            let [method, route] = tags.route.split(']');

            route = crypto.decrypt(route);
            tags.route = `${method}]${route}`;
        } catch (e) {
            logger.warn('parse message wrong ', tags.route);
        }
    }

    return new Message(measurement, tags, fields, time);
}

function parse(data) {
    let lines = (data || '').split('\n');
    let messages = lines.map(parseMessage);

    return messages;
}

module.exports = {
    parse
};