astra/bsky2tg
1
0
Fork 0
Code Issues Pull requests Packages 1 Activity Actions

RefreshSession code changes

Browse source
This commit is contained in:
Astra 2026-03-11 12:14:42 +00:00
parent 86720ce988
commit 02cef12523
1 changed files with 8 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

14
bsky/bluesky.go
View file

@ -99,7 +99,7 @@ func (bluesky *Bluesky) CreateSession(cfg *BlueskyConfig) error {
return errors.New("unable to authenticate, check handle/password") return errors.New("unable to authenticate, check handle/password")
} }
func (bluesky *Bluesky) RefreshSession() error { func (bluesky *Bluesky) RefreshSession() {
resp := new(BSkySessionResponse) resp := new(BSkySessionResponse)
bluesky.sling.New().Set("Authorization", fmt.Sprintf("Bearer %s", bluesky.Cfg.RefreshJWT)). bluesky.sling.New().Set("Authorization", fmt.Sprintf("Bearer %s", bluesky.Cfg.RefreshJWT)).
@ -109,10 +109,13 @@ func (bluesky *Bluesky) RefreshSession() error {
bluesky.Cfg.RefreshJWT = resp.RefreshJWT bluesky.Cfg.RefreshJWT = resp.RefreshJWT
PersistAuthSession(bluesky.Cfg) PersistAuthSession(bluesky.Cfg)
bluesky.sling.Set("Authorization", fmt.Sprintf("Bearer %s", bluesky.Cfg.AccessJWT)) bluesky.sling.Set("Authorization", fmt.Sprintf("Bearer %s", bluesky.Cfg.AccessJWT))
return nil return
}
if resp.Error != "" {
log.Fatalf("RefreshSession error: %s", resp.Message)
} }
return bluesky.CreateSession(bluesky.Cfg) bluesky.CreateSession(bluesky.Cfg)
} }
func (bluesky *Bluesky) CheckSessionValid() { func (bluesky *Bluesky) CheckSessionValid() {
@ -126,7 +129,7 @@ func (bluesky *Bluesky) CheckSessionValid() {
bluesky.sling.New().Set("Authorization", fmt.Sprintf("Bearer %s", bluesky.Cfg.AccessJWT)). bluesky.sling.New().Set("Authorization", fmt.Sprintf("Bearer %s", bluesky.Cfg.AccessJWT)).
Get("/xrpc/app.bsky.actor.getProfile").QueryStruct(params).Receive(resp, resp) Get("/xrpc/app.bsky.actor.getProfile").QueryStruct(params).Receive(resp, resp)
if resp.Error == "ExpiredToken" { if resp.Error != "" {
bluesky.RefreshSession() bluesky.RefreshSession()
} }
} }
@ -279,7 +282,6 @@ func (bluesky *Bluesky) FetchPost(did string, rkey string) FetchedPost {
}{ }{
URIs: fmt.Sprintf("at://%s/app.bsky.feed.post/%s", did, rkey), URIs: fmt.Sprintf("at://%s/app.bsky.feed.post/%s", did, rkey),
} }
bluesky.sling.New().Base("https://public.api.bsky.app"). bluesky.sling.New().Get("/xrpc/app.bsky.feed.getPosts").QueryStruct(&params).Receive(resp, resp)
Get("/xrpc/app.bsky.feed.getPosts").QueryStruct(&params).Receive(resp, resp)
return resp.Posts[0] return resp.Posts[0]
} }