Method Run

backend/Src/main.ts:151–230

()

    }

    public Run(): void {
        if (!this.IsDataMounted()) {
            Logger.Get.Log('\'/app/data\' folder doesn\'t exist. Maybe forgot to mount it');
            process.exit(1);
        }

        this.db = new Sqlite3(DB_LOCATION);
        this.storage = new SqliteAdapter(this.db);


        if (!this.storage.IsInitialized()) {
            Logger.Get.Log('Database doesn\'t initialized or malformed. Initialization...');
            this.InitializeDb();
        }

        this.settings = new Settings(this.storage);

        Logger.Get.AddWriter(new SqliteWriter(this.storage));

        try {
            this.PrepareFileSystem();
        } catch (e) {
            Logger.Get.Log(`Preparing filesystem error. ${e}`);
            process.exit(1);
        }

        this.notificationCenter = new NotificationCenter(this.storage);

        this.LoadData();

        process.on('SIGTERM', () => {
            Logger.Get.Log('SIGTERM received');
            this.Shutdown();
        });

        this.io.on('connection', socket => {
            Logger.Get.Log(`[${socket.id}][${socket.request.connection.remoteAddress}] client connected`);
            new RpcRequestHandlerImpl(
                socket,
                this.broadcaster,
                this.observables,
                this.pluginManager,
                this.pluginManagerController,
                this.pluginManagerListener,
                this.storage,
                this.linkedStreams,
                this.archive,
                this.archiveRefCounter,
                this.clipProgress,
                this.archiveFilters,
                this.observablesFilters,
                this.recorder,
                this.systemResourcesMonitor,
                this.notificationCenter,
                this.settings,
                this.facade,
                () => this.Shutdown());