refactor(messaging): moved `reply` function to dedicated folder
MODIFY
packages/messaging/src/eventbus/messaging.eventBus.reader.spec.ts
packages/messaging/src/eventbus/messaging.eventBus.reader.spec.ts
@@ -5,7 +5,7 @@ import { throwError, of } from 'rxjs';
import { delay, map, tap, ignoreElements } from 'rxjs/operators';
import { MsgEffect } from '../effects/messaging.effects.interface';
import { runEventBus, runEventBusClient } from '../util/messaging.test.util';
-import { reply } from '../effects/messaging.effects.helper';
+import { reply } from '../reply/reply';
describe('#eventBus', () => {
test('handles RPC event', async () => {

MODIFY
packages/messaging/src/index.ts
packages/messaging/src/index.ts
@@ -10,7 +10,9 @@ export { LocalStrategyOptions, EVENT_BUS_CHANNEL } from './transport/strategies/
// effects
export * from './effects/messaging.effects.interface';
-export { reply } from './effects/messaging.effects.helper';
+
+// handy functions
+export { reply } from './reply/reply';
// server
export * from './server/messaging.server';

RENAME
packages/messaging/src/effects/specs/messaging.effects.helper.spec.ts
packages/messaging/src/reply/reply.spec.ts
import { Event, EventMetadata } from '@marblejs/core';
-import { reply, MissingEventTypeError, UNKNOWN_TAG } from '../messaging.effects.helper';
+import { reply, MissingEventTypeError, UNKNOWN_TAG } from './reply';
describe('#reply', () => {
test('creates success response based on originated event', () => {

RENAME
packages/messaging/src/effects/messaging.effects.helper.ts
packages/messaging/src/reply/reply.ts
MODIFY
packages/messaging/src/server/specs/messaging.server.amqp.spec.ts
packages/messaging/src/server/specs/messaging.server.amqp.spec.ts
@@ -6,7 +6,7 @@ import { map, tap, delay, mapTo } from 'rxjs/operators';
import { TransportLayerConnection } from '../../transport/transport.interface';
import { MsgEffect } from '../../effects/messaging.effects.interface';
import { MessagingClient } from '../../client/messaging.client.interface';
-import { reply } from '../../effects/messaging.effects.helper';
+import { reply } from '../../reply/reply';
import * as Util from '../../util/messaging.test.util';
describe('messagingServer::AMQP', () => {

MODIFY
packages/messaging/src/server/specs/messaging.server.redis.spec.ts
packages/messaging/src/server/specs/messaging.server.redis.spec.ts
@@ -6,7 +6,7 @@ import { map, tap, delay, mapTo } from 'rxjs/operators';
import { TransportLayerConnection } from '../../transport/transport.interface';
import { MsgEffect } from '../../effects/messaging.effects.interface';
import { MessagingClient } from '../../client/messaging.client.interface';
-import { reply } from '../../effects/messaging.effects.helper';
+import { reply } from '../../reply/reply';
import * as Util from '../../util/messaging.test.util';
describe('messagingServer::Redis', () => {

refactor(messaging): moved `reply` function to dedicated folder