Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Periodically add blacklisted items to redis #4532

Merged
merged 6 commits into from
Dec 27, 2022
Merged

Periodically add blacklisted items to redis #4532

Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
eaf18e0
Periodically add to redis
dmanjunath Dec 23, 2022
841b9ec
Add log
dmanjunath Dec 23, 2022
7034ffb
Change to 1 hour for testing
dmanjunath Dec 24, 2022
1f4e7fd
Merge branch 'main' of github.com:AudiusProject/audius-protocol into …
dmanjunath Dec 24, 2022
8e720d1
Convert to arrow fn
dmanjunath Dec 25, 2022
c74b67d
Adjust interval
dmanjunath Dec 27, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions creator-node/src/blacklistManager.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,21 @@ class BlacklistManager {
userIdsToBlacklist,
segmentsToBlacklist
})

// add items to redis periodically in case redis restarts
setInterval(async () => {
const {
trackIdsToBlacklist,
userIdsToBlacklist,
segmentsToBlacklist
} = await this._getDataToBlacklist()
await this._fetchCIDsAndAddToRedis({
trackIdsToBlacklist,
userIdsToBlacklist,
segmentsToBlacklist
})
this._log(`Re-added to redis`)
}, 1000 * 60 * 60 * 2 /* two hours */)
}

this.initialized = true
Expand Down