blob: de939f884a0e41323bf4c0cdf5b864b7ff4ba1ef [file] [log] [blame]
/*
* Copyright 2019 WeBank
*
* Licensed 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 com.webank.wedatasphere.linkis.httpclient.dws.response
import java.util
import com.ning.http.client.Response
import com.ning.http.client.cookie.Cookie
import com.webank.wedatasphere.linkis.httpclient.authentication.{Authentication, AuthenticationResult, HttpAuthentication}
import com.webank.wedatasphere.linkis.httpclient.exception.HttpMessageParseException
import scala.collection.JavaConversions
/**
* created by cooperyang on 2019/5/22.
*/
class DWSAuthenticationResult(response: Response, serverUrl: String) extends AuthenticationResult with DWSResult {
set(response.getResponseBody, response.getStatusCode, response.getUri.toString, response.getContentType)
override def getAuthentication: Authentication = if(getStatus == 0) new HttpAuthentication {
private var lastAccessTime: Long = System.currentTimeMillis
override def authToCookies: Array[Cookie] = JavaConversions.asScalaBuffer(response.getCookies).toArray
override def authToHeaders: util.Map[String, String] = new util.HashMap[String, String]()
override def authToMap: util.Map[String, String] = new util.HashMap[String, String]()
override def getLastAccessTime: Long = lastAccessTime
override def updateLastAccessTime(): Unit = lastAccessTime = System.currentTimeMillis
} else throw new HttpMessageParseException(s"login to gateway $serverUrl failed! Reason: " + getMessage)
}