fix: pipe.execute undefined, reexport IClientEventDtoFlp (#61)

src/main/ts/index.ts

@@ -1,6 +1,7 @@
 import { IClientEventDto, LogLevel } from '@qiwi/substrate'
 import { nanoid } from 'nanoid'
 
+import { IPipeOutput } from './interfaces'
 import { createFlpPipeline, eventifyPipe } from './pipes/flp'
 import { createTransmittable, createTransmitter } from './transmitter'
 import { getCookie, setCookie } from './utils/cookie'
@@ -66,7 +67,7 @@ const createFrontLogProxyTransmitter = ({
       })
     }
     return acc
-  }, {} as Record<LogLevel, (data: IClientEventDtoFlp) => Promise<any>>)
+  }, {} as Record<LogLevel, (data: IClientEventDtoFlp) => Promise<IPipeOutput>>)
 }
 
 export {
@@ -78,3 +79,7 @@ export {
   eventifyPipe,
   createFrontLogProxyTransmitter,
 }
+
+export type {
+  IClientEventDtoFlp
+}

src/main/ts/pipes/httpFallback.ts

@@ -15,7 +15,7 @@ export const createHttpPipeFallback = (opts: IHttpPipeOpts[]): IPipe => {
   return {
     type,
     execute(transmittable: ITransmittable): IPromise<IPipeOutput> {
-      return executeFailproof(transmittable, httpPipes)
+      return executeFailproof(transmittable, [...httpPipes])
     },
   }
 }

src/test/ts/createFrontLogProxyTransmitter.ts

@@ -97,4 +97,21 @@ test('createFrontLogProxyTransmitter correctly call fetch with Error', async ()
   }
 })
 
+test('createFrontLogProxyTransmitter does not throw an error on several calls', async () => {
+  const transmitter = createFrontLogProxyTransmitter({
+    appName: 'testApp',
+    url: 'https://reqres.in/api/users/2',
+  })
+
+  const callAndCheck = async (message: string) => {
+    const [err, res] = await transmitter.info({ message })
+    assert.equal(res.message, message)
+    assert.equal(err, null)
+  }
+
+  await callAndCheck('foo')
+  await callAndCheck('bar')
+  await callAndCheck('baz')
+})
+
 test.run()