diff options
| author | Guillermo Serrahima <dev@vylion.com> | 2026-07-16 01:56:37 +0200 |
|---|---|---|
| committer | Guillermo Serrahima <dev@vylion.com> | 2026-07-16 01:56:37 +0200 |
| commit | f0a7593dfa48a254f5a3664cd7ca80178d36f436 (patch) | |
| tree | bf8d2a48bebc28c98b835c469a364021a156db80 /fetchers/jetstream.go | |
| parent | e7a1d76f0562deaf990563394a1f6ede5cef4924 (diff) | |
| download | llostre-f0a7593dfa48a254f5a3664cd7ca80178d36f436.tar.xz llostre-f0a7593dfa48a254f5a3664cd7ca80178d36f436.zip | |
Split note and author TTLs; added TTL refresh on cache access
Diffstat (limited to 'fetchers/jetstream.go')
| -rw-r--r-- | fetchers/jetstream.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/fetchers/jetstream.go b/fetchers/jetstream.go index 78a2550..866533a 100644 --- a/fetchers/jetstream.go +++ b/fetchers/jetstream.go @@ -103,7 +103,7 @@ func handleJetstreamPost(conf *Config, did, uri string, commit *jetstreamCommit) } // only track posts from authors we already care about - author, found := conf.Cache.GetAuthor(did) + author, found := conf.Cache.readAuthor(did) if !found { return } @@ -118,13 +118,13 @@ func handleJetstreamPost(conf *Config, did, uri string, commit *jetstreamCommit) func handleJetstreamProfile(conf *Config, did string, commit *jetstreamCommit) { if commit.Operation == "delete" { - if _, found := conf.Cache.GetAuthor(did); found { + if _, found := conf.Cache.readAuthor(did); found { conf.Cache.DeleteAuthor(did) } return } - existing, found := conf.Cache.GetAuthor(did) + existing, found := conf.Cache.readAuthor(did) if !found { return } |