import Core from './Core'
import Provider from './Provider'
import Message from './Message'

export default abstract class BaseProvider implements Provider {
    core: Core
    params: any

    constructor(core: Core, params: any) {
        this.core = core
        this.params = params
    }

    abstract connectDataSource(): void

    onMessage(topic: string, msg: any): void {
        const message = new Message(topic, msg, parseInt(msg["createTimeStamp"]))
        this.core.input(message)
    }
}