Fis-AuditMessage/services/incomingMessage.service.ts

import { map, Observable, of, tap } from "rxjs";
import { BaseMessage, Command, ResponseMessage, Uuid } from "../dependencies/fisappmessagejsutilty/interface/export"
import { LoggingService } from "../dependencies/fisloggingservice/services/logging-service";
import { LogSetting, MessageLog } from "../dependencies/fisloggingservice/type/datatype";
import { IncomingMessageServiceInterface } from "../type/datatype";

export class IncomingMessageService implements IncomingMessageServiceInterface {

    constructor(private logService?: LoggingService) {
        this.logService = new LoggingService()
    }

    private settings: LogSetting & { incomingObservable: Observable<BaseMessage>; } = {
        storage: '',
        setting: {
            appId: '',
            appName: '',
            logLocName: '',
            logLocId: '',
            appLogLocId: '',
            appLocName: '',
            appLogId: ''
        },
        incomingObservable: null
    }


    /* This function is mainful used for setting the log setting as well as transforming the messages
    into log messages and then storing them in the desiganted location of storage as specified. */
    public init(settings: LogSetting & { incomingObservable: Observable<BaseMessage>; }): void {

        // Restructuring the settings. I think they were some trouble doing this last time
        let newSetting: any = settings
        newSetting.setting = {
            ...this.settings.setting,
            ...settings.setting,
            customSetting: {
                ...this.settings.customSetting,
                ...settings.customSetting,
            }
        }

        this.settings = newSetting // Become stateful???

        // Transform incoming observables into Observable<MessageLog> to be logged
        let transformedOBS: Observable<MessageLog> = settings.incomingObservable.pipe(
            map(message => {
                let finalResponse: MessageLog = {
                    appLogLocId: new Uuid().generateId(),
                    appData: {
                        msgId: message.header.messageID || new Uuid().generateId(),
                        msgLogDateTime: new Date(),
                        msgDateTime: new Date(),
                        msgTag: ['Incoming'],
                        msgPayload: JSON.stringify(message)
                    }
                }
                return finalResponse
            })
        )

        // Once the messages has been transformed, then the logging can be executed
        this.logService.init(this.settings).then(() => {
            this.logService.subscribe(transformedOBS)
        }).catch((e) => console.error(e))

    }
}