const qs = require('querystring');
const routeDecode = require('../middleware/route-decode');

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.path) {
        let [, p] = tags.path.split(']');

        p = routeDecode(p) || 'null';
        tags.path = p;
        tags.route = tags.path;
    }

    if (fields.uid && fields.uid === '"undefined"') {
        fields.uid = '0';
    }

    if (!tags.route) {
        tags.route = 'null';
    }

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

function parse(data) {
    data = data.replace(/\"([^\"]*)\"/g, (match) => {
        return encodeURIComponent(match);
    });

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

    return messages;
}

module.exports = {
    parse
};