import {createApp, Process} from '@lakutata/core'
import {Service} from '../../Service'
import {registryPort, registryToken} from '../conts/CommonConstant'
import moment from 'moment'

export class ServiceConsumerClientProc extends Process {
    protected initialize(): Promise<void> | void {
        createApp({
            id: 'test.test.app',
            name: 'test.test.app',
            modules: {
                service: {
                    class: Service,
                    port: 6912,
                    registry: `127.0.0.1:${registryPort}`,
                    token: registryToken,
                    logger: false
                }
            }
        }).then(app => {
            const consumer: Service = app.Modules.get<Service>('service')
            consumer.channel('test').onAny(console.log)
            consumer.channel('test').on('test', console.log)
            // consumer.fetchServices().then(console.log)
            setInterval(() => {
                consumer.invoke({
                    serviceId: app.getID(),
                    data: {
                        test: 1,
                        opr: 'add',
                        a: 1,
                        b: 2
                    },
                    transform: response => {
                        response.a = response.sum
                        return response
                    }
                }, {
                    serviceId: app.getID()
                }).then(res => {
                    console.log(res, moment().format('HH:mm:ss'))
                }).catch(console.error)
            }, 1000)
            setInterval(() => {
                consumer.invoke({
                    serviceId: app.getID(),
                    data: {
                        test: 1,
                        opr: 'big',
                        a: 1,
                        b: 2
                    }
                }).then(res => {
                    console.log(res, moment().format('HH:mm:ss'))
                }).catch(console.error)
            }, 3000)
        }).catch(e => {
            console.error(e)
        })
    }
}