import ElectronStore from 'electron-store';
import nets from 'nets';
import * as os from 'os';
import {
    v1 as uuidv1, // semi-persistent client ID
    v4 as uuidv4 // random ID
} from 'uuid';

/**
 * Basic telemetry event data. These fields are filled automatically by the `addEvent` call.
 * @typedef {object} BasicTelemetryEvent
 * @property {string} clientID - a UUID for this client
 * @property {string} id - a UUID for this event/packet
 * @property {string} name - the name of this event (taken from `addEvent`'s `eventName` parameter)
 * @property {int} timestamp - a Unix epoch timestamp for this event
 * @property {int} userTimezone - the difference in minutes between UTC and local time
 */

/**
  * Default telemetry service URLs
  */
const TelemetryServerURL = Object.freeze({
    staging: '',
    production: 'https://telemetry.openblock.cc/'
});
const DefaultServerURL = (
    process.env.NODE_ENV === 'production' ? TelemetryServerURL.production : TelemetryServerURL.staging
);

/**
 * Default name for persistent configuration & queue storage
 */
const DefaultStoreName = 'telemetry';

/**
 * Default interval, in seconds, between delivery attempts
 */
const DefaultDeliveryInterval = 60;

/**
 * Default interval, in seconds, between connectivity checks
 */
const DefaultNetworkCheckInterval = 300;

/**
 * Default limit on the number of queued events
 */
const DefaultQueueLimit = 100;

/**
 * Default limit on the number of delivery attempts for each event
 */
const DeliveryAttemptLimit = 3;

const platform = [
    `${os.platform()} ${os.release()}`, // "win32 10.0.18362", "darwin 18.7.0", etc.
    `Electron ${process.versions.electron}`, // "Electron 4.2.6"
    `Store=${process.mas || process.windowsStore || false}` // "Store=true" or "Store=false"
].join(', ');


/**
 * Client interface for the Scratch telemetry service.
 *
 * This class supports delivering generic telemetry events and is designed to be used by any application or service
 * in the Scratch family.
 */
class TelemetryClient {
    /**
     * Construct and initialize a TelemetryClient instance, optionally overriding configuration defaults. Delivery
     * intervals will begin immediately; if the user has not opted in events will be dropped each interval.
     *
     * @param {object} [options] - optional configuration settings for this client
     * @property {string} [storeName] - optional name for persistent config/queue storage (default: 'telemetry')
     * @property {string} [clientId] - optional UUID for this client (default: automatically determine a UUID)
     * @property {string} [serverURL] - optional telemetry service endpoint URL (default: automatically choose a server)
     * @property {boolean} [didOptIn] - optional flag for whether the user opted into telemetry service (default: false)
     * @property {int} [deliveryInterval] - optional number of seconds between delivery attempts (default: 60)
     * @property {int} [networkCheckInterval] - optional number of seconds between connectivity checks (default: 300)
     * @property {int} [queueLimit] - optional limit on the number of queued events (default: 100)
     * @property {int} [deliveryAttemptLimit] - optional limit on delivery attempts for each event (default: 3)
     */
    constructor ({
        storeName = DefaultStoreName,
        clientID, // undefined = load or create
        serverURL, // undefined = automatic
        didOptIn, // undefined = show prompt
        deliveryInterval = DefaultDeliveryInterval,
        networkCheckInterval = DefaultNetworkCheckInterval,
        queueLimit = DefaultQueueLimit,
        deliveryAttemptLimit = DeliveryAttemptLimit
    } = {}) {
        /**
         * Persistent storage for the client ID, opt in flag, and packet queue.
         */
        this._store = new ElectronStore({
            name: storeName
        });

        if (clientID) {
            this.clientID = clientID;
        } else if (!this._store.has('clientID')) {
            this.clientID = uuidv1();
        }

        if (typeof didOptIn !== 'undefined') {
            this.didOptIn = didOptIn;
        }

        /**
         * Queue for outgoing event packets
         */
        this._packetQueue = this._store.get('packetQueue', []);

        /**
         * Server URL
         */
        this._serverURL = serverURL || DefaultServerURL;

        /**
         * Can we currently reach the telemetry service?
         */
        this._networkIsOnline = false;

        /**
         * Try to deliver telemetry packets at this interval
         */
        this._deliveryInterval = (deliveryInterval > 0) ? deliveryInterval : DefaultDeliveryInterval;

        /**
         * Check for connectivity at this interval
         */
        this._networkCheckInterval = (networkCheckInterval > 0) ? networkCheckInterval : DefaultNetworkCheckInterval;

        /**
         * Queue at most this many events
         */
        this._queueLimit = (queueLimit > 0) ? queueLimit : DefaultQueueLimit;

        /**
         * Attempt to deliver an event at most this many times
         */
        this._deliveryAttemptLimit = (deliveryAttemptLimit > 0) ? deliveryAttemptLimit : DeliveryAttemptLimit;

        /**
         * Bind event handlers
         */
        this._attemptDelivery = this._attemptDelivery.bind(this);
        this._updateNetworkStatus = this._updateNetworkStatus.bind(this);

        /**
         * Begin monitoring network status
         */
        this._networkTimer = setInterval(this._updateNetworkStatus, this._networkCheckInterval * 1000);
        setTimeout(this._updateNetworkStatus, 0);

        /**
         * Begin the delivery interval
         */
        this._deliveryTimer = setInterval(this._attemptDelivery, this._deliveryInterval * 1000);
    }

    /**
     * Stop this client. Do not use this object after disposal.
     */
    dispose () {
        if (this._networkTimer !== null) {
            clearInterval(this._networkTimer);
            this._networkTimer = null;
        }
        if (this._deliveryTimer !== null) {
            clearInterval(this._deliveryTimer);
            this._deliveryTimer = null;
        }
    }

    /**
     * Has the user explicitly opted into this service?
     * @type {boolean}
     */
    get didOptIn () {
        // don't supply a default here: we want to track "opt out" separately from "undecided"
        return this._store.get('optIn');
    }
    set didOptIn (value) {
        this._store.set('optIn', !!value);
    }

    /**
     * Semi-persistent unique ID for this client
     * @type {string}
     */
    get clientID () {
        return this._store.get('clientID');
    }
    set clientID (value) {
        this._store.set('clientID', value);
    }

    /**
     * Save the packet queue to the config store.
     * Call this any time the queue is modified.
     */
    saveQueue () {
        this._store.set('packetQueue', this._packetQueue);
    }

    /**
     * Add an event to the telemetry system. If the user has opted into the telemetry service, this event will be
     * delivered to the telemetry service when possible. Otherwise the event will be ignored.
     *
     * @see {@link BasicTelemetryEvent} for the list of fields which are filled automatically by this method.
     *
     * @param {string} eventName - the name of this telemetry event, such as 'app::open'.
     * @param {object} additionalFields - optional event fields to add or override before sending the event.
     */
    addEvent (eventName, additionalFields = null) {
        const packetId = uuidv4();
        const now = new Date();

        const packet = Object.assign({
            clientID: this.clientID,
            id: packetId,
            name: eventName,
            platform,
            timestamp: now.getTime(),
            userTimezone: now.getTimezoneOffset()
        }, additionalFields);
        const packetInfo = {
            attempts: 0,
            packet
        };
        this._packetQueue.push(packetInfo);
        this._packetQueue.splice(0, this._packetQueue.length - this._queueLimit); // enforce queue length limit
        this.saveQueue();
    }

    /**
     * Attempt to deliver events to the telemetry service. If telemetry is disabled, this will do nothing.
     */
    _attemptDelivery () {
        if (this._busy) {
            return;
        }

        /**
         * Attempt to deliver one event then asynchronously recurse, reenqueueing the event if delivery fails and the
         * event has not yet reached its retry limit. Sets `this._busy` before doing anything else and clears it once
         * the queue is empty or `this.didOptIn` is cleared.
         */
        const stepDelivery = () => {
            this._busy = true;
            if (!this.didOptIn || !this._networkIsOnline || this._packetQueue.length < 1) {
                this._busy = false;
                return;
            }
            // don't saveQueue() here:
            // - if the app exits or crashes before the network request finishes, we'll lose the packet
            // - if the request finishes, we'll save at that time (see below)
            const packetInfo = this._packetQueue.shift();
            ++packetInfo.attempts;
            const packet = packetInfo.packet;
            nets({
                body: JSON.stringify(packet),
                headers: {'Content-Type': 'application/json'},
                method: 'POST',
                url: this._serverURL
            }, (err, res) => {
                // TODO: check if the failure is because there's no Internet connection and if so refund the attempt
                const packetFailed = err || (res.statusCode !== 200);
                if (packetFailed) {
                    if (packetInfo.attempts < this._deliveryAttemptLimit) {
                        this._packetQueue.push(packetInfo);
                    } else {
                        // eslint-disable-next-line no-console
                        console.warn('Dropping packet which exceeded retry limit', packet);
                    }
                }
                this.saveQueue();
                stepDelivery();
            });
        };

        stepDelivery();
    }

    /**
     * Check if the telemetry service is available
     */
    _updateNetworkStatus () {
        nets({
            method: 'GET',
            url: this._serverURL
        }, (err, res) => {
            this._networkIsOnline = !err && (res.statusCode === 200);
        });
    }
}

export default TelemetryClient;