import utils from '../services/utils.js';
import Mutex from "../services/mutex.js";

export default class Component {
    constructor() {
        this.componentId = `comp-${this.constructor.name}-` + utils.randomString(6);
        /** @type Component[] */
        this.children = [];
        this.initialized = Promise.resolve();
        this.mutex = new Mutex();
    }

    setParent(parent) {
        /** @type Component */
        this.parent = parent;
        return this;
    }

    child(component) {
        component.setParent(this);

        this.children.push(component);

        return this;
    }

    async handleEvent(name, data) {
        await this.initialized;

        const fun = this[name + 'Event'];

        const start = Date.now();

        await this.callMethod(fun, data);

        const end = Date.now();

        if (end - start > 10 && glob.PROFILING_LOG) {
            console.log(`Event ${name} in component ${this.componentId} took ${end-start}ms`);
        }

        await this.handleEventInChildren(name, data);
    }

    async triggerEvent(name, data) {
        await this.parent.triggerEvent(name, data);
    }

    async handleEventInChildren(name, data) {
        const promises = [];

        for (const child of this.children) {
            promises.push(child.handleEvent(name, data));
        }

        await Promise.all(promises);
    }

    async triggerCommand(name, data = {}) {
        const called = await this.handleCommand(name, data);

        if (!called) {
            await this.parent.triggerCommand(name, data);
        }
    }

    async handleCommand(name, data) {
        const fun = this[name + 'Command'];

        return await this.callMethod(fun, data);
    }

    async callMethod(fun, data) {
        if (typeof fun !== 'function') {
            return false;
        }

        let release;

        try {
            release = await this.mutex.acquire();

            await fun.call(this, data);

            return true;
        } finally {
            if (release) {
                release();
            }
        }
    }
}