import { Plugin, ConfigLoader, RPCExporter } from "./Plugin";
import * as Knex from 'knex';
import { SubscriptionResponse, SuccessResponse, ErrorResponse } from "./Types";
import { socketioRPC } from "./RPC";
import { RepoFolderStatus } from './GitUpdater';
export interface EventBus {
    pushNotification(notification: Notification): Promise<void>;
    subscribeNotifications(callback: (notification: Notification) => any): Promise<SubscriptionResponse>;
}
export declare type NotificationSeverity = 'Info' | 'Important' | 'Error';
export declare type Notification = {
    ID?: number;
    severity: NotificationSeverity;
    topic: string;
    message: string;
    time?: number;
};
declare type DbConf<ParentConfT = {}> = ParentConfT & {
    dbConf: Knex.Config;
    eventBusConf: {
        [topic in string]: NotificationSeverity;
    };
};
export declare type TableDefiniton = {
    name: string;
    tableBuilder: (table: Knex.CreateTableBuilder) => void;
};
export declare abstract class KnexBase<ConfType> extends ConfigLoader<DbConf<ConfType>> implements EventBus {
    private notificiationSubscriptions;
    knex: Knex;
    exportRPCs(): socketioRPC[];
    insert(table: string, data: any[], topic?: string, severity?: NotificationSeverity): Promise<void>;
    subscribeNotifications(callback: any): Promise<SubscriptionResponse>;
    getNotificationLog(): Promise<Notification[]>;
    unsubscribeNotifications(uid: string): Promise<SuccessResponse | ErrorResponse>;
    pushNotification(notification: Notification): Promise<void>;
    protected makeKnex(conf: Knex.Config): Promise<Knex>;
    setConfig(conf: DbConf<ConfType>): DbConf<ConfType>;
    setConfigKey(key: string, value: any): DbConf<ConfType>;
    protected initialize(): Promise<void>;
    protected getTableDefinitions(): TableDefiniton[];
}
declare type AdminBaseConf<ParentConf> = {
    httpPort: number;
} & ParentConf;
export declare abstract class AdminBase<ConfType> extends KnexBase<AdminBaseConf<ConfType>> {
    private runningPlugins;
    private express;
    private httpServer;
    private io;
    private wsServer;
    private publicIo;
    private publicWsServer;
    private pluginUpdaters;
    constructor(runningPlugins: Plugin[]);
    exportRPCs(): socketioRPC[];
    protected initialize(): Promise<void>;
    protected destroy(): void;
    private startWebserver;
    private stopWebserver;
    private startWebsocket;
    private startPublicWebsocket;
    protected initApis(socket: any, rpcExporters?: RPCExporter[]): void;
    protected initPublicApis(socket: any): void;
    private selfUpdate;
    installPlugin(name: string, force?: boolean): Promise<RepoFolderStatus>;
    startPlugin(name: string): Promise<boolean>;
    updatePlugin(name: string): Promise<boolean>;
    setPluginVersion(pluginName: string, tag: string): Promise<RepoFolderStatus>;
    addPlugin(plugin: Plugin): void;
    removePlugin(plugin: Plugin): void;
    getPlugins(): Plugin[];
    getTableDefinitions(): TableDefiniton[];
}
export {};