import { BitField } from "@node-lightning/core";
import { ILogger } from "@node-lightning/logger";
import { NoiseSocket } from "@node-lightning/noise";
import { NoiseServer } from "@node-lightning/noise";
import { EventEmitter } from "events";
import { InitFeatureFlags } from "./flags/InitFeatureFlags";
import { Peer } from "./Peer";

export class PeerServer extends EventEmitter {
    protected _server: NoiseServer;

    constructor(
        readonly host: string,
        readonly port: number,
        readonly localSecret: Buffer,
        readonly localFeatures: BitField<InitFeatureFlags>,
        readonly localChains: Buffer[],
        readonly logger: ILogger,
    ) {
        super();
        this._server = new NoiseServer({ ls: localSecret }, this._onSocket.bind(this));
        this._server.on("listening", () => this.emit("listening"));
    }

    /**
     * Starts the peer manager listening
     * @param host
     * @param port
     */
    public listen() {
        this._server.listen({ host: this.host, port: this.port });
    }

    /**
     * Shuts down the server
     */
    public shutdown() {
        this._server.close();
    }

    /**
     * Handles when a socket connects to us
     * @param socket
     */
    protected _onSocket(socket: NoiseSocket) {
        this.logger.info("peer connected");
        const peer = new Peer(this.localSecret, this.localFeatures, this.localChains, this.logger);
        peer.attach(socket);
        this.emit("peer", peer);
    }
}