refactor: shorten imports

src/lib/consumer-groups/consumer-groups.ts

@@ -18,7 +18,7 @@ import {
 import { TRedisSMQEvent } from '../../common/index.js';
 import { RedisClientInstance } from '../../common/redis-client/redis-client-instance.js';
 import { Configuration } from '../../config/index.js';
-import { EventBusRedisInstance } from '../event-bus/event-bus-redis-instance.js';
+import { EventBusRedisInstance } from '../event-bus/index.js';
 import { IQueueParams } from '../queue/index.js';
 import { _parseQueueParams } from '../queue/_/_parse-queue-params.js';
 import { _deleteConsumerGroup } from './_/_delete-consumer-group.js';

src/lib/consumer/consumer-heartbeat/consumer-heartbeat.ts

@@ -22,7 +22,7 @@ import {
 import { TConsumerHeartbeatEvent } from '../../../common/index.js';
 import { RedisClientFactory } from '../../../common/redis-client/redis-client-factory.js';
 import { redisKeys } from '../../../common/redis-keys/redis-keys.js';
-import { Configuration } from '../../../config/configuration.js';
+import { Configuration } from '../../../config/index.js';
 import { EventBusRedisFactory } from '../../event-bus/event-bus-redis-factory.js';
 import { Consumer } from '../consumer/consumer.js';
 import { IConsumerHeartbeat } from '../types/index.js';

src/lib/consumer/consumer-heartbeat/event-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TConsumerHeartbeatEvent } from '../../../common/types/event.js';
+import { TConsumerHeartbeatEvent } from '../../../common/index.js';
 import { EventBusRedisFactory } from '../../event-bus/event-bus-redis-factory.js';
 import { ConsumerHeartbeat } from './consumer-heartbeat.js';
 

src/lib/consumer/consumer/event-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TConsumerEvent } from '../../../common/types/event.js';
+import { TConsumerEvent } from '../../../common/index.js';
 import { EventBusRedisFactory } from '../../event-bus/event-bus-redis-factory.js';
 import { Consumer } from './consumer.js';
 

src/lib/consumer/message-handler-runner/event-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TConsumerMessageHandlerRunnerEvent } from '../../../common/types/event.js';
+import { TConsumerMessageHandlerRunnerEvent } from '../../../common/index.js';
 import { EventBusRedisFactory } from '../../event-bus/event-bus-redis-factory.js';
 import { MessageHandlerRunner } from './message-handler-runner.js';
 

src/lib/consumer/message-handler-runner/message-handler-runner.ts

@@ -9,7 +9,7 @@
 
 import { async, ICallback, ILogger, Runnable } from 'redis-smq-common';
 import { TConsumerMessageHandlerRunnerEvent } from '../../../common/index.js';
-import { Configuration } from '../../../config/configuration.js';
+import { Configuration } from '../../../config/index.js';
 import { IQueueParsedParams } from '../../queue/index.js';
 import { Consumer } from '../consumer/consumer.js';
 import { ConsumerMessageHandlerAlreadyExistsError } from '../errors/index.js';

src/lib/consumer/message-handler/consume-message/event-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TConsumerConsumeMessageEvent } from '../../../../common/types/event.js';
+import { TConsumerConsumeMessageEvent } from '../../../../common/index.js';
 import { EventBusRedisFactory } from '../../../event-bus/event-bus-redis-factory.js';
 import { ConsumeMessage } from './consume-message.js';
 

src/lib/consumer/message-handler/dequeue-message/dequeue-message.ts

@@ -22,7 +22,7 @@ import { TConsumerDequeueMessageEvent } from '../../../../common/index.js';
 import { RedisClientInstance } from '../../../../common/redis-client/redis-client-instance.js';
 import { ELuaScriptName } from '../../../../common/redis-client/scripts/scripts.js';
 import { redisKeys } from '../../../../common/redis-keys/redis-keys.js';
-import { Configuration } from '../../../../config/configuration.js';
+import { Configuration } from '../../../../config/index.js';
 import { _saveConsumerGroup } from '../../../consumer-groups/_/_save-consumer-group.js';
 import { EventBusRedisFactory } from '../../../event-bus/event-bus-redis-factory.js';
 import { _hasRateLimitExceeded } from '../../../queue-rate-limit/_/_has-rate-limit-exceeded.js';

src/lib/consumer/message-handler/dequeue-message/event-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TConsumerDequeueMessageEvent } from '../../../../common/types/event.js';
+import { TConsumerDequeueMessageEvent } from '../../../../common/index.js';
 import { EventBusRedisFactory } from '../../../event-bus/event-bus-redis-factory.js';
 import { DequeueMessage } from './dequeue-message.js';
 

src/lib/consumer/message-handler/message-handler/even-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TConsumerMessageHandlerEvent } from '../../../../common/types/event.js';
+import { TConsumerMessageHandlerEvent } from '../../../../common/index.js';
 import { EventBusRedisFactory } from '../../../event-bus/event-bus-redis-factory.js';
 import { MessageHandler } from './message-handler.js';
 

src/lib/consumer/types/index.ts

@@ -10,4 +10,3 @@
 export * from './message-handler.js';
 export * from './consumer-heartbeat.js';
 export * from './consume-message.js';
-export * from './config.js';

src/lib/consumer/workers/worker.ts

@@ -9,7 +9,7 @@
 
 import { ICallback, ILogger, logger, Runnable, Timer } from 'redis-smq-common';
 import { RedisClientInstance } from '../../../common/redis-client/redis-client-instance.js';
-import { IRedisSMQConfigRequired } from '../../../config/types/config.js';
+import { IRedisSMQConfigRequired } from '../../../config/index.js';
 
 export abstract class Worker extends Runnable<Record<string, never>> {
   protected redisClient;

src/lib/exchange/exchange-direct/_/_get-exchange-direct-transferable.ts

@@ -8,7 +8,7 @@
  */
 
 import { v4 } from 'uuid';
-import { IQueueParams } from '../../../queue/types/queue.js';
+import { IQueueParams } from '../../../queue/index.js';
 import {
   EExchangeType,
   TExchangeDirectTransferable,

src/lib/exchange/exchange-fan-out/exchange-fan-out.ts

@@ -16,8 +16,8 @@ import {
   IQueueParams,
   IQueueProperties,
 } from '../../queue/index.js';
-import { ExchangeFanOutError } from '../errors/exchange-fan-out.error.js';
-import { ExchangeError } from '../errors/exchange.error.js';
+import { ExchangeFanOutError } from '../errors/index.js';
+import { ExchangeError } from '../errors/index.js';
 import { ExchangeAbstract } from '../exchange-abstract.js';
 import { _getFanOutExchangeQueues } from './_/_get-fan-out-exchange-queues.js';
 import { _getQueueFanOutExchange } from './_/_get-queue-fan-out-exchange.js';

src/lib/exchange/exchange-topic/exchange-topic.ts

@@ -8,7 +8,7 @@
  */
 
 import { CallbackEmptyReplyError, ICallback } from 'redis-smq-common';
-import { IQueueParams } from '../../queue/types/queue.js';
+import { IQueueParams } from '../../queue/index.js';
 import { ExchangeAbstract } from '../exchange-abstract.js';
 import { ITopicParams } from '../types/exchange.js';
 import { _getTopicExchangeParams } from './_/_get-topic-exchange-params.js';

src/lib/producer/event-bus-publisher.ts

@@ -8,7 +8,7 @@
  */
 
 import { ILogger } from 'redis-smq-common';
-import { TProducerEvent } from '../../common/types/event.js';
+import { TProducerEvent } from '../../common/index.js';
 import { EventBusRedisFactory } from '../event-bus/event-bus-redis-factory.js';
 import { Producer } from './producer.js';
 

src/lib/queue/queue.ts

@@ -17,7 +17,7 @@ import { RedisClientInstance } from '../../common/redis-client/redis-client-inst
 import { ELuaScriptName } from '../../common/redis-client/scripts/scripts.js';
 import { redisKeys } from '../../common/redis-keys/redis-keys.js';
 import { Configuration } from '../../config/index.js';
-import { EventBusRedisInstance } from '../event-bus/event-bus-redis-instance.js';
+import { EventBusRedisInstance } from '../event-bus/index.js';
 import { _deleteQueue } from './_/_delete-queue.js';
 import { _getQueueProperties } from './_/_get-queue-properties.js';
 import { _getQueues } from './_/_get-queues.js';

tests/common/event-bus-redis.ts

@@ -8,7 +8,7 @@
  */
 
 import bluebird from 'bluebird';
-import { EventBusRedisInstance } from '../../src/lib/event-bus/event-bus-redis-instance.js';
+import { EventBusRedisInstance } from '../../src/lib/index.js';
 
 const eventBus = bluebird.promisifyAll(new EventBusRedisInstance());
 

tests/common/schedule-worker.ts

@@ -9,7 +9,7 @@
 
 import bluebird from 'bluebird';
 import { Runnable } from 'redis-smq-common';
-import { Configuration } from '../../src/config/configuration.js';
+import { Configuration } from '../../src/config/index.js';
 import PublishScheduledWorker from '../../src/lib/consumer/workers/publish-scheduled.worker.js';
 
 let scheduleWorker: Runnable<Record<string, never>> | null = null;

tests/tests/consuming-messages/test00010.test.ts

@@ -9,7 +9,7 @@
 
 import { test, jest } from '@jest/globals';
 import { ICallback } from 'redis-smq-common';
-import { IMessageTransferable } from '../../../src/lib/message/types/message.js';
+import { IMessageTransferable } from '../../../src/lib/index.js';
 import { getConsumer } from '../../common/consumer.js';
 import { untilMessageAcknowledged } from '../../common/events.js';
 import {

tests/tests/workers/test00001.test.ts

@@ -9,7 +9,7 @@
 
 import { test, expect, jest } from '@jest/globals';
 import bluebird from 'bluebird';
-import { Configuration } from '../../../src/config/configuration.js';
+import { Configuration } from '../../../src/config/index.js';
 import {
   IMessageParams,
   IMessageTransferable,

tests/tests/workers/test00002.test.ts

@@ -9,7 +9,7 @@
 
 import { test, expect, jest } from '@jest/globals';
 import bluebird from 'bluebird';
-import { Configuration } from '../../../src/config/configuration.js';
+import { Configuration } from '../../../src/config/index.js';
 import {
   IMessageParams,
   IMessageTransferable,

tests/tests/workers/test00003.test.ts

@@ -9,7 +9,7 @@
 
 import { test, expect } from '@jest/globals';
 import bluebird from 'bluebird';
-import { Configuration } from '../../../src/config/configuration.js';
+import { Configuration } from '../../../src/config/index.js';
 import RequeueUnacknowledgedWorker from '../../../src/lib/consumer/workers/requeue-unacknowledged.worker.js';
 import WatchConsumersWorker from '../../../src/lib/consumer/workers/watch-consumers.worker.js';
 import {