;; 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.

;;mock implementation of INimbusCredentialPlugin,IAutoCredentials and ICredentialsRenewer for testing only.
(ns backtype.storm.MockAutoCred
  (:use [backtype.storm testing config])
  (:import [backtype.storm.security.INimbusCredentialPlugin]
           [backtype.storm.security.auth   ICredentialsRenewer])
  (:gen-class
    :implements [backtype.storm.security.INimbusCredentialPlugin
                 backtype.storm.security.auth.IAutoCredentials
                 backtype.storm.security.auth.ICredentialsRenewer]))

(def nimbus-cred-key "nimbusCredTestKey")
(def nimbus-cred-val "nimbusTestCred")
(def nimbus-cred-renew-val "renewedNimbusTestCred")
(def gateway-cred-key "gatewayCredTestKey")
(def gateway-cred-val "gatewayTestCred")
(def gateway-cred-renew-val "renewedGatewayTestCred")

(defn -populateCredentials
  ([this creds conf]
  (.put creds nimbus-cred-key nimbus-cred-val))
  ([this creds]
  (.put creds gateway-cred-key gateway-cred-val)))

(defn -prepare
  [this conf])

(defn -renew
  [this cred conf]
  (.put cred nimbus-cred-key nimbus-cred-renew-val)
  (.put cred gateway-cred-key gateway-cred-renew-val))

(defn -populateSubject
  [subject credentials]
  (.add (.getPublicCredentials subject) (.get credentials nimbus-cred-key))
  (.add (.getPublicCredentials subject) (.get credentials gateway-cred-key)))

(defn -updateSubject
  [subject credentials]
  (-populateSubject subject credentials))