artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 17:17:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

feature/added rest_connector_http_header_signature props

Browse Source
This commit is contained in:
hongwei 2021-11-01 14:23:53 +01:00
parent ff6f6cc8dd
commit 03305d2be1
1 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
obp-api/src/main/scala/code/bankconnectors/rest/RestConnector_vMar2019.scala
View File

@ -6580,22 +6580,28 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
callContext: Option[CallContext]
): List[HttpHeader] = {
// val generalContext = callContext.flatMap(_.toOutboundAdapterCallContext.generalContext).getOrElse(List.empty[BasicGeneralContext])
// val headersFromGeneralContext = generalContext.map(generalContext => RawHeader(generalContext.key,generalContext.value))
val needSignatureHead = APIUtil.getPropsAsBoolValue("rest_connector_http_header_signature", false)
val generalContext = callContext.flatMap(_.toOutboundAdapterCallContext.generalContext).getOrElse(List.empty[BasicGeneralContext])
val headersFromGeneralContext = generalContext.map(generalContext => RawHeader(generalContext.key,generalContext.value))
val basicUserAuthContexts: List[BasicUserAuthContext] = callContext.flatMap(_.toOutboundAdapterCallContext.outboundAdapterAuthInfo.flatMap(_.userAuthContext)).getOrElse(List.empty[BasicUserAuthContext])
val headersFromUserAuthContext = basicUserAuthContexts.filterNot(_.key == "private-key").map(userAuthContext =>RawHeader(userAuthContext.key,userAuthContext.value))
val timeStamp = Instant.now.getEpochSecond.toString
val inputMessage = s"""${timeStamp}${uri}${entityJsonString}"""
val privateKeyValue = basicUserAuthContexts.find(_.key =="private-key").map(_.value).getOrElse("")
val privateKey = getPrivateKeyFromString(privateKeyValue)
val xSign = computeXSign(inputMessage, privateKey)
val extraHeaders = List(RawHeader("x-timestamp",timeStamp),RawHeader("x-sign",xSign))
val headers = headersFromUserAuthContext++extraHeaders
logger.debug(s"x-timestamp: $timeStamp")
logger.debug(s"x-sign: $xSign")
val extraHeaders = if(needSignatureHead){
val inputMessage = s"""${timeStamp}${uri}${entityJsonString}"""
val privateKeyValue = basicUserAuthContexts.find(_.key =="private-key").map(_.value).getOrElse("")
val privateKey = getPrivateKeyFromString(privateKeyValue)
val xSign = computeXSign(inputMessage, privateKey)
logger.debug(s"x-sign: $xSign")
List(RawHeader("x-timestamp",timeStamp),RawHeader("x-sign",xSign))
} else {
List(RawHeader("x-timestamp",timeStamp))
}
val headers = headersFromUserAuthContext++extraHeaders++headersFromGeneralContext
logger.debug(s"obp headers: ${headers}")
headers