You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by se...@apache.org on 2015/04/08 18:18:22 UTC
cxf git commit: Adding the missing resource
Repository: cxf
Updated Branches:
refs/heads/master 50eea2dc5 -> f7f5abdfc
Adding the missing resource
Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/f7f5abdf
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/f7f5abdf
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/f7f5abdf
Branch: refs/heads/master
Commit: f7f5abdfc908cb33e2739d8ef6d54496a60045bb
Parents: 50eea2d
Author: Sergey Beryozkin <sb...@talend.com>
Authored: Wed Apr 8 17:18:07 2015 +0100
Committer: Sergey Beryozkin <sb...@talend.com>
Committed: Wed Apr 8 17:18:07 2015 +0100
----------------------------------------------------------------------
.../oauth2/client/CodeAuthSupplier.java | 72 ++++++++++++++++++++
1 file changed, 72 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cxf/blob/f7f5abdf/rt/rs/security/oauth-parent/oauth2/src/main/java/org/apache/cxf/rs/security/oauth2/client/CodeAuthSupplier.java
----------------------------------------------------------------------
diff --git a/rt/rs/security/oauth-parent/oauth2/src/main/java/org/apache/cxf/rs/security/oauth2/client/CodeAuthSupplier.java b/rt/rs/security/oauth-parent/oauth2/src/main/java/org/apache/cxf/rs/security/oauth2/client/CodeAuthSupplier.java
new file mode 100644
index 0000000..c85a8de
--- /dev/null
+++ b/rt/rs/security/oauth-parent/oauth2/src/main/java/org/apache/cxf/rs/security/oauth2/client/CodeAuthSupplier.java
@@ -0,0 +1,72 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.cxf.rs.security.oauth2.client;
+
+import java.net.URI;
+
+import org.apache.cxf.configuration.security.AuthorizationPolicy;
+import org.apache.cxf.jaxrs.client.WebClient;
+import org.apache.cxf.message.Message;
+import org.apache.cxf.rs.security.oauth2.common.ClientAccessToken;
+import org.apache.cxf.rs.security.oauth2.grants.code.AuthorizationCodeGrant;
+import org.apache.cxf.transport.http.auth.HttpAuthSupplier;
+
+public class CodeAuthSupplier implements HttpAuthSupplier {
+ private volatile String code;
+ private BearerAuthSupplier tokenSupplier = new BearerAuthSupplier();
+ public CodeAuthSupplier() {
+ }
+
+ public boolean requiresRequestCaching() {
+ return true;
+ }
+
+ public String getAuthorization(AuthorizationPolicy authPolicy,
+ URI currentURI,
+ Message message,
+ String fullHeader) {
+ if (code != null) {
+ synchronized (tokenSupplier) {
+ if (tokenSupplier.getClientAccessToken().getTokenKey() == null) {
+ WebClient wc = tokenSupplier.createAccessTokenServiceClient();
+ ClientAccessToken at = OAuthClientUtils.getAccessToken(wc,
+ tokenSupplier.getConsumer(),
+ new AuthorizationCodeGrant(code));
+ code = null;
+ tokenSupplier.setClientAccessToken(at);
+ }
+ }
+ }
+ return tokenSupplier.getAuthorization(authPolicy, currentURI, message, fullHeader);
+ }
+
+ public void setCode(String code) {
+ this.code = code;
+ }
+ public void setRefreshEarly(boolean refreshEarly) {
+ tokenSupplier.setRefreshEarly(refreshEarly);
+ }
+ public void setAccessTokenServiceUri(String uri) {
+ tokenSupplier.setAccessTokenServiceUri(uri);
+ }
+ public void setConsumer(Consumer consumer) {
+ tokenSupplier.setConsumer(consumer);
+ }
+}