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, take } from "rxjs"; import { LogSetting, MessageLog } from "../dependencies/fisloggingservice/type/datatype"; import { BaseMessage } from "../dependencies/fisappmessagejsutilty/dependencies/dependencies"; const incoming = new IncomingMessageService() const syncrhonize = new MessageAuditorService() const acknowledge = new AcknowledgementService() const streamService = new StreamingService() /* -------------- TEST -------------------- */ // change payload into Observable const payload: Observable = streamService.stream().pipe(take(3)); // Configure Log Setting let storage: LogSetting = { storage: "MongoDB", cacheMessageLimit: 0, setting: { appName: 'Default from client', appLocName: 'To be generated in client', logLocName: 'To be generated in client', }, customSetting: { srv: true, user: "testDB", password: "h1nt1OyXw6QeUnzS", server: "cluster0.29sklte.mongodb.net", database: "log", } } let dataSet: LogSetting & { incomingObservable: Observable } = { storage: storage.storage, setting: storage.setting, customSetting: storage.customSetting, incomingObservable: payload } acknowledge.init(storage).then(() => { acknowledge.subscribe(dataSet.incomingObservable) })