Pg to bun (#148)

* start moving to bun

* changing more stuff

* more

* and yet more

* tests passing

* seems stable now

* more big changes

* small fix

* little fixes

1 files changed, 4 insertions, 4 deletions

diff --git a/internal/processing/streaming/authorize.go b/internal/processing/streaming/authorize.go
index 8bbf1856d..f938a0c0c 100644
--- a/internal/processing/streaming/authorize.go
+++ b/internal/processing/streaming/authorize.go
@@ -7,7 +7,7 @@ import (
 	"github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
 )
 
-func (p *processor) AuthorizeStreamingRequest(accessToken string) (*gtsmodel.Account, error) {
+func (p *processor) AuthorizeStreamingRequest(ctx context.Context, accessToken string) (*gtsmodel.Account, error) {
 	ti, err := p.oauthServer.LoadAccessToken(context.Background(), accessToken)
 	if err != nil {
 		return nil, fmt.Errorf("AuthorizeStreamingRequest: error loading access token: %s", err)
@@ -20,12 +20,12 @@ func (p *processor) AuthorizeStreamingRequest(accessToken string) (*gtsmodel.Acc
 
 	// fetch user's and account for this user id
 	user := &gtsmodel.User{}
-	if err := p.db.GetByID(uid, user); err != nil || user == nil {
+	if err := p.db.GetByID(ctx, uid, user); err != nil || user == nil {
 		return nil, fmt.Errorf("AuthorizeStreamingRequest: no user found for validated uid %s", uid)
 	}
 
-	acct := &gtsmodel.Account{}
-	if err := p.db.GetByID(user.AccountID, acct); err != nil || acct == nil {
+	acct, err := p.db.GetAccountByID(ctx, user.AccountID)
+	if err != nil || acct == nil {
 		return nil, fmt.Errorf("AuthorizeStreamingRequest: no account retrieved for user with id %s", uid)
 	}