Fixed token source client

rjtokenring · rjtokenring · commit cc96e989de6b · 2024-06-17T17:28:56.000+02:00
diff --git a/internal/iot/token.go b/internal/iot/token.go
@@ -58,12 +58,12 @@ func NewUserTokenSource(client, secret, baseURL string) oauth2.TokenSource {
 
 func ctxWithToken(ctx context.Context, src oauth2.TokenSource) (context.Context, error) {
 	// Retrieve a valid token from the src.
-	tok, err := src.Token()
+	_, err := src.Token()
 	if err != nil {
 		if strings.Contains(err.Error(), "401") {
 			return nil, errors.New("wrong credentials")
 		}
 		return nil, fmt.Errorf("cannot retrieve a valid token: %w", err)
 	}
-	return context.WithValue(ctx, iotclient.ContextOAuth2, tok.AccessToken), nil
+	return context.WithValue(ctx, iotclient.ContextOAuth2, src), nil
 }

Original file line number	Diff line number	Diff line change
`@@ -58,12 +58,12 @@ func NewUserTokenSource(client, secret, baseURL string) oauth2.TokenSource {`
`58`	`58`
`59`	`59`	`func ctxWithToken(ctx context.Context, src oauth2.TokenSource) (context.Context, error) {`
`60`	`60`	`// Retrieve a valid token from the src.`
`61`		`- tok, err := src.Token()`
	`61`	`+ _, err := src.Token()`
`62`	`62`	`if err != nil {`
`63`	`63`	`if strings.Contains(err.Error(), "401") {`
`64`	`64`	`return nil, errors.New("wrong credentials")`
`65`	`65`	`}`
`66`	`66`	`return nil, fmt.Errorf("cannot retrieve a valid token: %w", err)`
`67`	`67`	`}`
`68`		`- return context.WithValue(ctx, iotclient.ContextOAuth2, tok.AccessToken), nil`
	`68`	`+ return context.WithValue(ctx, iotclient.ContextOAuth2, src), nil`
`69`	`69`	`}`