fluidtrends/carmel

import { Channel } from './index.js';
import debug from 'debug';
const LOG = debug("carmel:station");
export class Station {
    constructor(session) {
        this._session = session;
        this._channels = this.session.config.channels || {};
        this._openChannel = this.openChannel.bind(this);
        this._closeChannel = this.closeChannel.bind(this);
    }
    get session() {
        return this._session;
    }
    get channels() {
        return this._channels;
    }
    channel(id) {
        return this.channels[id];
    }
    async flush() {
        await Promise.all(Object.values(this.channels).map((channel) => channel.flush && channel.flush()));
    }
    async openChannel(id) {
        if (this.channels[id] && this.channels[id].isOpen)
            return this.channels[id];
        LOG(`opening [${id}] channel ...`);
        const channel = new Channel(id, this.channels[id], this);
        await channel.open();
        this.channels[id] = channel;
        LOG(`channel [${id}] ready`);
        return this.channels[id];
    }
    async closeChannel(id) {
        if (!this.channels[id])
            return;
        LOG(`closing [${id}] channel ...`);
        if (this.channels[id].close) {
            await this.channels[id].close();
        }
        this.channels[id] = undefined;
        delete this.channels[id];
        LOG(`channel [${id}] is ready`);
    }
    async addChannel(id, data) {
        if (this.channels[id])
            return this.channels[id];
        this.channels[id] = { ...data };
        return this.openChannel(id);
    }
    async start() {
        LOG("starting the station ...");
        if (this.session.config.isOperator) {
            this.channels[Channel.SYSTEM_OPERATORS_ID] = this.channels[Channel.SYSTEM_OPERATORS_ID] || {};
            this.channels[Channel.SYSTEM_OPERATORS_ID].events = this.channels[Channel.SYSTEM_OPERATORS_ID].events || {};
            this.channels[Channel.SYSTEM_OPERATORS_ID].events[Channel.ACCEPT_EVENT_ID] = true;
        }
        else {
            this.channels[Channel.SYSTEM_PEERS_ID] = this.channels[Channel.SYSTEM_PEERS_ID] || {};
            this.channels[Channel.SYSTEM_PEERS_ID].events = this.channels[Channel.SYSTEM_PEERS_ID].events || {};
            this.channels[Channel.SYSTEM_PEERS_ID].events[Channel.ACCEPT_EVENT_ID] = true;
        }
        await Promise.all(Object.keys(this.channels).map(this._openChannel));
        LOG("started the station");
    }
    async stop() {
        LOG("stopping the station ...");
        await Promise.all(Object.keys(this.channels).map(this._closeChannel));
        LOG("stopped the station");
    }
}
//# sourceMappingURL=Station.js.map