/*---------------------------------------------------------------------------------------------
 *  Copyright (c) Microsoft Corporation. All rights reserved.
 *  Licensed under the MIT License. See License.txt in the project root for license information.
 *--------------------------------------------------------------------------------------------*/
'use strict';
Object.defineProperty(exports, "__esModule", { value: true });
var es = require("event-stream");
var util = require("gulp-util");
var appInsights = require("applicationinsights");
var Entry = /** @class */ (function () {
    function Entry(name, totalCount, totalSize) {
        this.name = name;
        this.totalCount = totalCount;
        this.totalSize = totalSize;
    }
    Entry.prototype.toString = function (pretty) {
        if (!pretty) {
            if (this.totalCount === 1) {
                return this.name + ": " + this.totalSize + " bytes";
            }
            else {
                return this.name + ": " + this.totalCount + " files with " + this.totalSize + " bytes";
            }
        }
        else {
            if (this.totalCount === 1) {
                return "Stats for '" + util.colors.grey(this.name) + "': " + Math.round(this.totalSize / 1204) + "KB";
            }
            else {
                var count = this.totalCount < 100
                    ? util.colors.green(this.totalCount.toString())
                    : util.colors.red(this.totalCount.toString());
                return "Stats for '" + util.colors.grey(this.name) + "': " + count + " files, " + Math.round(this.totalSize / 1204) + "KB";
            }
        }
    };
    return Entry;
}());
var _entries = new Map();
function createStatsStream(group, log) {
    var entry = new Entry(group, 0, 0);
    _entries.set(entry.name, entry);
    return es.through(function (data) {
        var file = data;
        if (typeof file.path === 'string') {
            entry.totalCount += 1;
            if (Buffer.isBuffer(file.contents)) {
                entry.totalSize += file.contents.length;
            }
            else if (file.stat && typeof file.stat.size === 'number') {
                entry.totalSize += file.stat.size;
            }
            else {
                // funky file...
            }
        }
        this.emit('data', data);
    }, function () {
        if (log) {
            if (entry.totalCount === 1) {
                util.log("Stats for '" + util.colors.grey(entry.name) + "': " + Math.round(entry.totalSize / 1204) + "KB");
            }
            else {
                var count = entry.totalCount < 100
                    ? util.colors.green(entry.totalCount.toString())
                    : util.colors.red(entry.totalCount.toString());
                util.log("Stats for '" + util.colors.grey(entry.name) + "': " + count + " files, " + Math.round(entry.totalSize / 1204) + "KB");
            }
        }
        this.emit('end');
    });
}
exports.createStatsStream = createStatsStream;
function submitAllStats(productJson) {
    var sorted = [];
    // move entries for single files to the front
    _entries.forEach(function (value) {
        if (value.totalCount === 1) {
            sorted.unshift(value);
        }
        else {
            sorted.push(value);
        }
    });
    // print to console
    for (var _i = 0, sorted_1 = sorted; _i < sorted_1.length; _i++) {
        var entry = sorted_1[_i];
        console.log(entry.toString(true));
    }
    // send data as telementry event when the
    // product is configured to send telemetry
    if (!productJson || !productJson.aiConfig || typeof productJson.aiConfig.asimovKey !== 'string') {
        return Promise.resolve();
    }
    return new Promise(function (resolve) {
        var measurements = Object.create(null);
        for (var _i = 0, sorted_2 = sorted; _i < sorted_2.length; _i++) {
            var entry = sorted_2[_i];
            measurements[entry.name + ".size"] = entry.totalSize;
            measurements[entry.name + ".count"] = entry.totalCount;
        }
        appInsights.setup(productJson.aiConfig.asimovKey)
            .setAutoCollectConsole(false)
            .setAutoCollectExceptions(false)
            .setAutoCollectPerformance(false)
            .setAutoCollectRequests(false)
            .start();
        var client = appInsights.getClient(productJson.aiConfig.asimovKey);
        client.config.endpointUrl = 'https://vortex.data.microsoft.com/collect/v1';
        /* __GDPR__
            "monacoworkbench/bundleStats" : {
                "outcome" : {"classification": "SystemMetaData", "purpose": "PerformanceAndHealth", "isMeasurement": true }
            }
        */
        client.trackEvent("monacoworkbench/bundleStats", undefined, measurements);
        client.sendPendingData(function () { return resolve(); });
    });
}
exports.submitAllStats = submitAllStats;