amechama/sharkey
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

upd: make hashtagservice compatible with redis 6.3

Browse Source
This commit is contained in:
Mar0xy 2023-11-01 14:47:36 +01:00
parent a5efe11350
commit 4fbd9dcfbf
No known key found for this signature in database
GPG Key ID: 56569BBE47D2C828
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
packages/backend/src/core/HashtagService.ts
View File

@ -176,18 +176,28 @@ export class HashtagService {
// チャート用 // チャート用
redisPipeline.pfadd(`hashtagUsers:${hashtag}:${window}`, userId); redisPipeline.pfadd(`hashtagUsers:${hashtag}:${window}`, userId);
redisPipeline.expire(`hashtagUsers:${hashtag}:${window}`,
60 * 60 * 24 * 3, // 3日間 const TTLwindow = await this.redisClient.ttl(`hashtagUsers:${hashtag}:${window}`);
'NX', // "NX -- Set expiry only when the key has no expiry" = 有効期限がないときだけ設定
); if (TTLwindow === -1) {
redisPipeline.expire(`hashtagUsers:${hashtag}:${window}`,
60 * 60 * 24 * 3, // 3日間
//'NX', // "NX -- Set expiry only when the key has no expiry" = 有効期限がないときだけ設定
);
}
// ユニークカウント用 // ユニークカウント用
// TODO: Bloom Filter を使うようにしても良さそう // TODO: Bloom Filter を使うようにしても良さそう
redisPipeline.sadd(`hashtagUsers:${hashtag}`, userId); redisPipeline.sadd(`hashtagUsers:${hashtag}`, userId);
redisPipeline.expire(`hashtagUsers:${hashtag}`,
60 * 60, // 1時間 const TTL = await this.redisClient.ttl(`hashtagUsers:${hashtag}`);
'NX', // "NX -- Set expiry only when the key has no expiry" = 有効期限がないときだけ設定
); if (TTL === -1) {
redisPipeline.expire(`hashtagUsers:${hashtag}`,
60 * 60, // 1時間
//'NX', // "NX -- Set expiry only when the key has no expiry" = 有効期限がないときだけ設定
);
}
redisPipeline.exec(); redisPipeline.exec();
} }