OAuth RFC-8628 Device Code Grant Flow (openhab#4632)

Signed-off-by: Andrew Fiddian-Green <[email protected]>

Author: andrewfg

bundles/org.openhab.core.auth.oauth2client/src/main/java/org/openhab/core/auth/oauth2client/internal/OAuthClientServiceImpl.java

@@ -31,6 +31,7 @@
 import org.eclipse.jetty.util.UrlEncoded;
 import org.openhab.core.auth.client.oauth2.AccessTokenRefreshListener;
 import org.openhab.core.auth.client.oauth2.AccessTokenResponse;
+import org.openhab.core.auth.client.oauth2.DeviceCodeResponseDTO;
 import org.openhab.core.auth.client.oauth2.OAuthClientService;
 import org.openhab.core.auth.client.oauth2.OAuthException;
 import org.openhab.core.auth.client.oauth2.OAuthResponseException;
@@ -77,6 +78,7 @@ public class OAuthClientServiceImpl implements OAuthClientService {
     private PersistedParams persistedParams = new PersistedParams();
 
     private @Nullable Fields extraAuthFields = null;
+    private @Nullable OAuthConnectorRFC8628 oAuthConnectorRFC8628 = null;
 
     private volatile boolean closed = false;
 
@@ -392,8 +394,16 @@ public void remove() throws OAuthException {
     public void close() {
         closed = true;
         storeHandler = null;
-
         logger.debug("closing oauth client, handle: {}", handle);
+        closeOAuthConnectorRFC8628();
+    }
+
+    private synchronized void closeOAuthConnectorRFC8628() {
+        OAuthConnectorRFC8628 connector = this.oAuthConnectorRFC8628;
+        if (connector != null) {
+            connector.close();
+        }
+        this.oAuthConnectorRFC8628 = null;
     }
 
     @Override
@@ -440,4 +450,34 @@ public OAuthClientService withGsonBuilder(GsonBuilder gsonBuilder) {
 
         return clientService;
     }
+
+    @Override
+    public @Nullable DeviceCodeResponseDTO getDeviceCodeResponse() throws OAuthException {
+        closeOAuthConnectorRFC8628();
+
+        if (persistedParams.tokenUrl == null) {
+            throw new OAuthException("Missing access token request url");
+        }
+        if (persistedParams.authorizationUrl == null) {
+            throw new OAuthException("Missing device code request url");
+        }
+        if (persistedParams.clientId == null) {
+            throw new OAuthException("Missing client id");
+        }
+        if (persistedParams.scope == null) {
+            throw new OAuthException("Missing scope");
+        }
+
+        OAuthConnectorRFC8628 connector = new OAuthConnectorRFC8628(this, handle, storeHandler, httpClientFactory,
+                gsonBuilder, persistedParams.tokenUrl, persistedParams.authorizationUrl, persistedParams.clientId,
+                persistedParams.scope);
+
+        oAuthConnectorRFC8628 = connector;
+        return connector.getDeviceCodeResponse();
+    }
+
+    @Override
+    public void notifyAccessTokenResponse(AccessTokenResponse atr) {
+        accessTokenRefreshListeners.forEach(l -> l.onAccessTokenResponse(atr));
+    }
 }

bundles/org.openhab.core.auth.oauth2client/src/main/java/org/openhab/core/auth/oauth2client/internal/OAuthConnector.java

@@ -62,12 +62,13 @@ public class OAuthConnector {
 
     private static final String HTTP_CLIENT_CONSUMER_NAME = "OAuthConnector";
 
-    private final HttpClientFactory httpClientFactory;
+    protected final HttpClientFactory httpClientFactory;
 
     private final @Nullable Fields extraFields;
 
     private final Logger logger = LoggerFactory.getLogger(OAuthConnector.class);
-    private final Gson gson;
+
+    protected final Gson gson;
 
     public OAuthConnector(HttpClientFactory httpClientFactory) {
         this(httpClientFactory, null, new GsonBuilder());
@@ -371,7 +372,7 @@ private AccessTokenResponse doRequest(final String grantType, HttpClient httpCli
      * @throws OAuthException If any exception is thrown while starting the http client.
      * @see org.openhab.core.io.net.http.ExtensibleTrustManager
      */
-    private HttpClient createHttpClient(String tokenUrl) throws OAuthException {
+    protected HttpClient createHttpClient(String tokenUrl) throws OAuthException {
         HttpClient httpClient = httpClientFactory.createHttpClient(HTTP_CLIENT_CONSUMER_NAME);
         if (!httpClient.isStarted()) {
             try {
@@ -383,7 +384,7 @@ private HttpClient createHttpClient(String tokenUrl) throws OAuthException {
         return httpClient;
     }
 
-    private void shutdownQuietly(@Nullable HttpClient httpClient) {
+    protected void shutdownQuietly(@Nullable HttpClient httpClient) {
         try {
             if (httpClient != null) {
                 httpClient.stop();