graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-11-10 05:23:09 +02:00
Code Issues Projects Releases Packages Wiki Activity

upd: move TTL after pipeline execution

Browse source
This commit is contained in:
Mar0xy 2023-11-01 14:51:50 +01:00
parent 4fbd9dcfbf
commit 61c66b3825
No known key found for this signature in database
GPG key ID: 56569BBE47D2C828
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
packages/backend/src/core/HashtagService.ts
View file

@ -177,29 +177,29 @@ export class HashtagService {
// チャート用
redisPipeline.pfadd(`hashtagUsers:${hashtag}:${window}`, userId);
const TTLwindow = await this.redisClient.ttl(`hashtagUsers:${hashtag}:${window}`);
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 を使うようにしても良さそう
redisPipeline.sadd(`hashtagUsers:${hashtag}`, userId);
await redisPipeline.exec();
const TTL = await this.redisClient.ttl(`hashtagUsers:${hashtag}`);
if (TTL === -1) {
redisPipeline.expire(`hashtagUsers:${hashtag}`,
this.redisClient.expire(`hashtagUsers:${hashtag}`,
60 * 60, // 1時間
//'NX', // "NX -- Set expiry only when the key has no expiry" = 有効期限がないときだけ設定
);
}
redisPipeline.exec();
const TTLwindow = await this.redisClient.ttl(`hashtagUsers:${hashtag}:${window}`);
if (TTLwindow === -1) {
this.redisClient.expire(`hashtagUsers:${hashtag}:${window}`,
60 * 60 * 24 * 3, // 3日間
//'NX', // "NX -- Set expiry only when the key has no expiry" = 有効期限がないときだけ設定
);
}
}
@bindThis