;; 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.
(ns org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer-test
  (:use [clojure test])
  (:import [org.mockito Mockito])
  (:import [org.apache.storm Config])
  (:import [org.apache.storm.security.auth ReqContext SingleUserPrincipal])
  (:import [org.apache.storm.security.auth.authorizer DRPCSimpleACLAuthorizer])
  (:use [org.apache.storm config util])
  )

(defn- mk-mock-context [user]
  (let [mock-context (Mockito/mock ReqContext)]
    (. (Mockito/when (.principal mock-context)) thenReturn
       (SingleUserPrincipal. user))
    mock-context))

(let [function "jump"
      partial-function "partial"
      alice-context (mk-mock-context "alice")
      alice-kerb-context (mk-mock-context "alice@SOME.RELM")
      bob-context (mk-mock-context "bob")
      charlie-context (mk-mock-context "charlie")
      acl-file "drpc-simple-acl-test-scenario.yaml"
      strict-handler (doto (DRPCSimpleACLAuthorizer.)
                           (.prepare {DRPC-AUTHORIZER-ACL-STRICT true
                                      DRPC-AUTHORIZER-ACL-FILENAME acl-file
                                      STORM-PRINCIPAL-TO-LOCAL-PLUGIN "org.apache.storm.security.auth.KerberosPrincipalToLocal"}))
      permissive-handler (doto (DRPCSimpleACLAuthorizer.)
                               (.prepare {DRPC-AUTHORIZER-ACL-STRICT false
                                          DRPC-AUTHORIZER-ACL-FILENAME acl-file
                                          STORM-PRINCIPAL-TO-LOCAL-PLUGIN "org.apache.storm.security.auth.KerberosPrincipalToLocal"}))]

  (deftest test-partial-authorization
    (testing "deny execute to unauthorized user"
      (is (not
            (.permit strict-handler
                     (ReqContext/context)
                     "execute"
                     {DRPCSimpleACLAuthorizer/FUNCTION_KEY partial-function}))))

    (testing "allow execute to authorized kerb user for correct function"
      (is
        (.permit
          strict-handler
          alice-kerb-context
          "execute"
          {DRPCSimpleACLAuthorizer/FUNCTION_KEY partial-function})))

      (testing "deny fetchRequest to unauthorized user for correct function"
        (is (not
              (.permit
                strict-handler
                alice-kerb-context
                "fetchRequest"
                {DRPCSimpleACLAuthorizer/FUNCTION_KEY partial-function}))))
    )

  (deftest test-client-authorization-strict
    (testing "deny execute to unauthorized user"
      (is (not
            (.permit strict-handler
                     (ReqContext/context)
                     "execute"
                     {DRPCSimpleACLAuthorizer/FUNCTION_KEY function}))))

    (testing "deny execute to valid user for incorrect function"
      (is (not
            (.permit
              strict-handler
              alice-context
              "execute"
              {DRPCSimpleACLAuthorizer/FUNCTION_KEY "wrongFunction"}))))

    (testing "allow execute to authorized kerb user for correct function"
      (is
        (.permit
          strict-handler
          alice-kerb-context
          "execute"
          {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))

    (testing "allow execute to authorized user for correct function"
      (is
        (.permit
          strict-handler
          alice-context
          "execute"
          {DRPCSimpleACLAuthorizer/FUNCTION_KEY function}))))


  (deftest test-client-authorization-permissive
    (testing "deny execute to unauthorized user for correct function"
      (is (not
            (.permit permissive-handler
                     (ReqContext/context)
                     "execute"
                     {DRPCSimpleACLAuthorizer/FUNCTION_KEY function}))))

    (testing "allow execute for user for incorrect function when permissive"
      (is
        (.permit permissive-handler
                 alice-context
                 "execute"
                 {DRPCSimpleACLAuthorizer/FUNCTION_KEY "wrongFunction"})))

    (testing "allow execute for user for incorrect function when permissive"
      (is
        (.permit permissive-handler
                 alice-kerb-context
                 "execute"
                 {DRPCSimpleACLAuthorizer/FUNCTION_KEY "wrongFunction"})))

    (testing "allow execute to authorized user for correct function"
      (is
        (.permit permissive-handler
                 bob-context
                 "execute"
                 {DRPCSimpleACLAuthorizer/FUNCTION_KEY function}))))

  (deftest test-invocation-authorization-strict
    (doseq [operation ["fetchRequest" "failRequest" "result"]]

      (testing (str "deny " operation
                    " to unauthorized user for correct function")
        (is (not
              (.permit
                strict-handler
                alice-context
                operation
                {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))

      (testing (str "deny " operation
                    " to user for incorrect function when strict")
        (is (not
              (.permit
                strict-handler
                charlie-context
                operation
                {DRPCSimpleACLAuthorizer/FUNCTION_KEY "wrongFunction"}))))

      (testing (str "allow " operation
                    " to authorized user for correct function")
        (is
          (.permit
            strict-handler
            charlie-context
            operation
            {DRPCSimpleACLAuthorizer/FUNCTION_KEY function}))))))

  (deftest test-invocation-authorization-permissive
    (doseq [operation ["fetchRequest" "failRequest" "result"]]

      (testing (str "deny " operation
                    " to unauthorized user for correct function")
        (is (not
              (.permit
                permissive-handler
                bob-context
                operation
                {DRPCSimpleACLAuthorizer/FUNCTION_KEY function}))))

        (testing (str "allow " operation
                      " to user for incorrect function when permissive")
          (is
            (.permit
              permissive-handler
              charlie-context
              operation
              {DRPCSimpleACLAuthorizer/FUNCTION_KEY "wrongFunction"})))

      (testing (str operation " is allowed for authorized user")
        (is
          (.permit
            permissive-handler
            charlie-context
            operation
            {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))))

  (deftest test-deny-when-no-function-given
    (is (not
         (.permit strict-handler alice-context "execute" {})))

    (is (not
         (.permit
           strict-handler
           alice-context
           "execute"
           {DRPCSimpleACLAuthorizer/FUNCTION_KEY nil})))

    (is (not
         (.permit permissive-handler bob-context "execute" {})))

    (is (not
         (.permit
           permissive-handler
           bob-context
           "execute"
           {DRPCSimpleACLAuthorizer/FUNCTION_KEY nil}))))

  (deftest test-deny-when-invalid-user-given
    (is (not
          (.permit
            strict-handler
            (Mockito/mock ReqContext)
            "execute"
            {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))

    (is (not
          (.permit
            strict-handler
            nil
            "execute"
            {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))

    (is (not
          (.permit
            permissive-handler
            (Mockito/mock ReqContext)
            "execute"
            {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))

    (is (not
          (.permit
            permissive-handler
            nil
            "execute"
            {DRPCSimpleACLAuthorizer/FUNCTION_KEY function})))))