import { AcknowledgementService } from "../services/acknowledgement.service"; import { StreamingService } from "./test-streamOBS"; import { MessageAuditorService } from "../services/message-auditor.service"; import { IncomingMessageService } from "../services/incomingMessage.service"; import { map, Observable } from "rxjs"; import { LogSetting, MessageLog } from "../dependencies/log/type/datatype"; import { BaseMessage } from "../dependencies/fisappmessagejsutilty/dependencies/dependencies"; const incoming = new IncomingMessageService() const acknowledge = new AcknowledgementService() const syncrhonize = new MessageAuditorService() const streamService = new StreamingService() /* -------------- TEST -------------------- */ // change payload into Observable const payload: Observable = streamService.stream(); // Configure Log Setting let storage: LogSetting = { storage: "File", setting: { appName: 'Default from client', appLocName: 'To be generated in client', logLocName: 'To be generated in client', } } let dataSet: LogSetting & { incomingObservable: Observable } = { storage: storage.storage, setting: storage.setting, customSetting: storage.customSetting, incomingObservable: payload } // incoming.init(dataSet) acknowledge.init(storage).then(() => { acknowledge.subscribe(dataSet.incomingObservable) })