// ==UserScript==
// @name         New Userscript
// @namespace    http://tampermonkey.net/
// @version      0.1
// @description  try to take over the world!
// @author       You
// @match        https://www.netflix.com/watch/*
// @grant GM_xmlhttpRequest
// @grant GM_log
// @require      http://code.jquery.com/jquery-latest.js
// ==/UserScript==

$(document).ready(function() {
    var host_name = 'nbn_test4';
    function loop() {
        var content = $('.player-info').find('textarea')["0"];
        if (content) {
            var dumped_data = content.value;
            var split_data = dumped_data.split("\n");
            var influx_data = "";
            $.each(split_data, function( index, value ) {
                if (value.startsWith("Throughput:")) {
                    console.log(value);
                    var data = value.split(" ")[1];
                    influx_data += "throughput,host=test_box1 value=";
                    influx_data += data;
                    influx_data += "\n";
                } else if (value.startsWith("Playing bitrate")) {
                    var data = value.split(" ");
                    var bitrate = data[5];
                    var res = data[8].split("x");
                    var res_up = res[0];
                    var res_across = res[1].replace(/\D/g,'');
                    influx_data += "bitrate,host=" + host_name + " value=";
                    influx_data += bitrate;
                    influx_data += "\n";
                    influx_data += "res_up,host=" + host_name + " value=";
                    influx_data += res_up;
                    influx_data += "\n";
                    influx_data += "res_across,host=" + host_name + " value=";
                    influx_data += res_across;
                    influx_data += "\n";
                    console.log(value);
                } else if (value.startsWith("Playing/Buffering vmaf")) {
                    var data = value.split(" ")[2].split("/");
                    var play_vamf = data[0];
                    var buffer_vamf = data[1];
                    influx_data += "play_vamf,host=" + host_name + " value=";
                    influx_data += play_vamf;
                    influx_data += "\n";
                    influx_data += "buffer_vamf,host=" + host_name + " value=";
                    influx_data += buffer_vamf;
                    influx_data += "\n";
                    console.log(value);
                } else if (value.startsWith("Buffering bitrate")) {
                    var buffer_bitrate = value.split(" ")[5];
                    influx_data += "buffer_bitrate,host=" + host_name + " value=";
                    influx_data += buffer_bitrate;
                    influx_data += "\n";
                    console.log(value);
                } else if (value.startsWith("Buffer size in Bytes:")) {
                    var buffer_size = value.split(" ")[4];
                    influx_data += "buffer_size,host=" + host_name + " value=";
                    influx_data += buffer_size;
                    influx_data += "\n";
                    console.log(value);
                } else if (value.startsWith("Total Frames:")) {
                    var total_frames = value.split(" ")[2];
                    influx_data += "total_frames,host=" + host_name + " value=";
                    influx_data += total_frames;
                    influx_data += "\n";
                    console.log(value);
                } else if (value.startsWith("Total Dropped Frames:")) {
                    var total_dropped_frames = value.split(" ")[3];
                    influx_data += "total_dropped_frames,host=" + host_name + " value=";
                    influx_data += total_dropped_frames;
                    influx_data += "\n";
                    console.log(value);
                }
            });
            console.log(influx_data);
            GM_xmlhttpRequest({
                method: "POST",
                url: "http://150.101.87.82:8086/write?db=netflix_clients",
                data: influx_data,
                //binary: true,
                headers: {
                  "Content-Type": "application/x-www-form-urlencoded"
                },
                onload: function(response) {
                    GM_log([
                      response.status,
                      response.statusText,
                      response.readyState,
                      response.responseHeaders,
                      response.responseText,
                      response.finalUrl,
                    ].join("\n"));
                }
            });
        }
    }

    setInterval(loop, 10000);

});