Skip to content

Commit f36621e

Browse files
committed
refactor(Events repo): Move isQueuePriorityEnabled to redis factory config
1 parent 554ddb2 commit f36621e

3 files changed

Lines changed: 9 additions & 5 deletions

File tree

src/apps/statements/repo/eventsRepo/FactoryConfig.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,5 +3,4 @@ import RedisFactoryConfig from './utils/redisEvents/FactoryConfig';
33
export default interface FactoryConfig {
44
readonly facade?: string;
55
readonly redis?: RedisFactoryConfig;
6-
readonly isQueuePriorityEnabled?: boolean;
76
}

src/apps/statements/repo/index.ts

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,11 @@
11
import config from '../../../config';
22
import factory from './factory';
33
import Repo from './Repo';
4+
import RepoFactoryConfig from '../repo/FactoryConfig';
45
import connectToMongoDb from './utils/connectToMongoDb';
56
import connectToRedis from './utils/connectToRedis';
67

7-
const repo: Repo = factory({
8+
export const repoFactoryConfig: RepoFactoryConfig = {
89
auth: {
910
facade: config.repoFactory.authRepoName,
1011
fake: {},
@@ -17,8 +18,8 @@ const repo: Repo = factory({
1718
redis: {
1819
client: connectToRedis(),
1920
prefix: config.redis.prefix,
21+
isQueuePriorityEnabled: config.isQueuePriorityEnabled,
2022
},
21-
isQueuePriorityEnabled: config.isQueuePriorityEnabled,
2223
},
2324
models: {
2425
facade: config.repoFactory.modelsRepoName,
@@ -50,6 +51,8 @@ const repo: Repo = factory({
5051
subFolder: config.azureStorageRepo.subFolder,
5152
},
5253
},
53-
});
54+
};
55+
56+
const repo: Repo = factory(repoFactoryConfig);
5457

5558
export default repo;

src/apps/statements/serviceFactory/index.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,10 @@ import logger from '../../../logger';
33
import tracker from '../../../tracker';
44
import repo from '../repo';
55
import service from '../service';
6+
import Config from '../service/Config';
67
import Service from './Service';
78

8-
export default (): Service => {
9+
export default (configOverrides?: Partial<Config>): Service => {
910
return service({
1011
repo,
1112
tracker,
@@ -21,5 +22,6 @@ export default (): Service => {
2122
enableStatementCreation: config.statementsService.enableStatementCreation,
2223
enableVoiding: config.statementsService.enableVoiding,
2324
enableVoidingChecks: config.statementsService.enableVoidingChecks,
25+
...configOverrides,
2426
});
2527
};

0 commit comments

Comments
 (0)