From aa8a0d08501cbb22400a67ece85c45fdfbdc6131 Mon Sep 17 00:00:00 2001
From: Tobi Smethurst <31960611+tsmethurst@users.noreply.github.com>
Date: Sat, 19 Jun 2021 11:18:55 +0200
Subject: Streaming (#49)

Add new status and notification websocket streaming capabilities
---
 internal/oauth/server.go | 5 +++++
 1 file changed, 5 insertions(+)

(limited to 'internal/oauth/server.go')

diff --git a/internal/oauth/server.go b/internal/oauth/server.go
index fb84743cd..1289b18af 100644
--- a/internal/oauth/server.go
+++ b/internal/oauth/server.go
@@ -56,6 +56,7 @@ type Server interface {
 	HandleAuthorizeRequest(w http.ResponseWriter, r *http.Request) error
 	ValidationBearerToken(r *http.Request) (oauth2.TokenInfo, error)
 	GenerateUserAccessToken(ti oauth2.TokenInfo, clientSecret string, userID string) (accessToken oauth2.TokenInfo, err error)
+	LoadAccessToken(ctx context.Context, access string) (accessToken oauth2.TokenInfo, err error)
 }
 
 // s fulfils the Server interface using the underlying oauth2 server
@@ -171,3 +172,7 @@ func (s *s) GenerateUserAccessToken(ti oauth2.TokenInfo, clientSecret string, us
 	s.log.Tracef("obtained user-level access token: %+v", accessToken)
 	return accessToken, nil
 }
+
+func (s *s) LoadAccessToken(ctx context.Context, access string) (accessToken oauth2.TokenInfo, err error) {
+	return s.server.Manager.LoadAccessToken(ctx, access)
+}
-- 
cgit v1.2.3