moris/misskey
1
0
Fork 0
forked from mirror/misskey
Code Pull Requests Activity

fix

Browse Source
This commit is contained in:
tamaina 2023-07-20 10:26:02 +00:00
parent dfd6b4f213
commit 227f19ff3a
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/backend/src/config.ts
View File

@ -108,9 +108,9 @@ export type Mixin = {
mediaProxy: string;
externalMediaProxyEnabled: boolean;
videoThumbnailGenerator: string | null;
redis: RedisOptions & RedisOptionsSource;
redisForPubsub: RedisOptions & RedisOptionsSource;
redisForJobQueue: RedisOptions & RedisOptionsSource;
redis: RedisOptions;
redisForPubsub: RedisOptions;
redisForJobQueue: RedisOptions;
};
export type Config = Source & Mixin;
@ -188,10 +188,12 @@ function tryCreateUrl(url: string) {
}
function convertRedisOptions(options: RedisOptionsSource, host: string): RedisOptions {
return {
const result = {
...options,
family: options.family == null ? 0 : options.family,
keyPrefix: `${options.prefix ?? host}:`,
db: options.db ?? 0,
};
delete result.prefix;
return result;
}

2
packages/backend/src/queue/const.ts
View File

@ -18,6 +18,6 @@ export function baseQueueOptions(config: Config, queueName: typeof QUEUE[keyof t
...config.redisForJobQueue,
keyPrefix: undefined
},
prefix: config.redisForJobQueue.prefix ? `${config.redisForJobQueue.prefix}:queue:${queueName}` : `queue:${queueName}`,
prefix: config.redisForJobQueue.keyPrefix ? `${config.redisForJobQueue.keyPrefix}queue:${queueName}` : `queue:${queueName}`,
};
}