Repository: incubator-nifi Updated Branches: refs/heads/NIFI-65 e67eb4f53 -> 71ab084d3
NIFI-65: - Adding methods to the AuthorityProvider to authorize the downloading of content. Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/71ab084d Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/71ab084d Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/71ab084d Branch: refs/heads/NIFI-65 Commit: 71ab084d399bd09dd273942f42bceda66cf410d6 Parents: e67eb4f Author: Matt Gilman <[email protected]> Authored: Tue Dec 23 09:46:35 2014 -0500 Committer: Matt Gilman <[email protected]> Committed: Tue Dec 23 09:46:35 2014 -0500 ---------------------------------------------------------------------- .../cluster/authorization/NodeAuthorizationProvider.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/71ab084d/nar-bundles/framework-bundle/framework/cluster-authorization-provider/src/main/java/org/apache/nifi/cluster/authorization/NodeAuthorizationProvider.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/cluster-authorization-provider/src/main/java/org/apache/nifi/cluster/authorization/NodeAuthorizationProvider.java b/nar-bundles/framework-bundle/framework/cluster-authorization-provider/src/main/java/org/apache/nifi/cluster/authorization/NodeAuthorizationProvider.java index c81e9d0..840422f 100644 --- a/nar-bundles/framework-bundle/framework/cluster-authorization-provider/src/main/java/org/apache/nifi/cluster/authorization/NodeAuthorizationProvider.java +++ b/nar-bundles/framework-bundle/framework/cluster-authorization-provider/src/main/java/org/apache/nifi/cluster/authorization/NodeAuthorizationProvider.java @@ -22,12 +22,15 @@ import org.apache.nifi.cluster.authorization.protocol.message.ProtocolMessage; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; +import java.util.List; +import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; import org.apache.nifi.authorization.Authority; import org.apache.nifi.authorization.AuthorityProvider; import org.apache.nifi.authorization.AuthorityProviderConfigurationContext; import org.apache.nifi.authorization.AuthorityProviderInitializationContext; +import org.apache.nifi.authorization.DownloadAuthorization; import org.apache.nifi.authorization.annotation.AuthorityProviderContext; import org.apache.nifi.authorization.exception.AuthorityAccessException; import org.apache.nifi.authorization.exception.IdentityAlreadyExistsException; @@ -283,6 +286,11 @@ public class NodeAuthorizationProvider implements AuthorityProvider, Application } @Override + public DownloadAuthorization authorizeDownload(List<String> dnChain, Map<String, String> attributes) throws UnknownIdentityException, AuthorityAccessException { + return DownloadAuthorization.approved(); + } + + @Override public String getGroupForUser(String dn) throws UnknownIdentityException, AuthorityAccessException { // create message final GetGroupForUserMessage msg = new GetGroupForUserMessage();
