diff options
Diffstat (limited to 'backend/fetchers/app.bsky.actor.go')
| -rw-r--r-- | backend/fetchers/app.bsky.actor.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/backend/fetchers/app.bsky.actor.go b/backend/fetchers/app.bsky.actor.go index e07f5be..0752223 100644 --- a/backend/fetchers/app.bsky.actor.go +++ b/backend/fetchers/app.bsky.actor.go @@ -4,6 +4,7 @@ import ( "encoding/json" "fmt" "io" + "llostre/backend/auth" "llostre/backend/general" "llostre/backend/notes" "log/slog" @@ -130,13 +131,13 @@ func FetchHandleAndPDS(did string) (string, string, error) { return handle, pds, nil } -func FetchAppBskyActorProfile(logger *slog.Logger, did, pdsURL, slingshotURL string, cache *Cache) (*notes.Author, error) { +func FetchAppBskyActorProfile(logger *slog.Logger, did, pdsURL, slingshotURL string, session *auth.OAuthState, cache *Cache) (*notes.Author, error) { // construct profile record URI uri := fmt.Sprintf("at://%s/app.bsky.actor.profile/self", did) // try slingshot first if slingshotURL != "" { - rawRecord, err := general.FetchRawRecordByURI(logger, uri, slingshotURL) + rawRecord, err := general.FetchRawRecordByURI(logger, uri, slingshotURL, session) if err != nil { logger.Warn("slingshot profile fetch failed", "did", did, "error", err) } else { @@ -145,7 +146,7 @@ func FetchAppBskyActorProfile(logger *slog.Logger, did, pdsURL, slingshotURL str } // fallback to PDS - rawRecord, err := general.FetchRawRecordByURI(logger, uri, pdsURL) + rawRecord, err := general.FetchRawRecordByURI(logger, uri, pdsURL, session) if err != nil { return nil, err } @@ -153,10 +154,10 @@ func FetchAppBskyActorProfile(logger *slog.Logger, did, pdsURL, slingshotURL str return parseAppBskyActorProfile(did, rawRecord, cache) } -func FetchAppBskyActorProfiles(logger *slog.Logger, dids []string, pdsURL, slingshotURL string, cache *Cache) map[string]notes.Author { +func FetchAppBskyActorProfiles(logger *slog.Logger, dids []string, pdsURL, slingshotURL string, session *auth.OAuthState, cache *Cache) map[string]notes.Author { authors := make(map[string]notes.Author) for _, did := range dids { - author, err := FetchAppBskyActorProfile(logger, did, pdsURL, slingshotURL, cache) + author, err := FetchAppBskyActorProfile(logger, did, pdsURL, slingshotURL, session, cache) if err == nil { authors[did] = *author } |