mirror of
https://github.com/OpenBankProject/OBP-API.git
synced 2026-02-06 16:16:47 +00:00
refactor/regenerated the RabbitMQConnector_vOct2024 and RPCServer
This commit is contained in:
hongwei
parent
e69161b622
commit
d86b7d36f1
@ -463,7 +463,7 @@ trait APIMethods140 extends MdcLoggable with APIMethods130 with APIMethods121{
|
||||
}
|
||||
// TODO: Consider storing allowed_transaction_request_types (List of String) in View Definition.
|
||||
// TODO: This would allow us to restrict transaction request types available to the User for an Account
|
||||
transactionRequestTypes <- Future(Connector.connector.vend.getTransactionRequestTypes(u, fromAccount, callContext)) map {
|
||||
(transactionRequestTypes, callContext) <- Future(Connector.connector.vend.getTransactionRequestTypes(u, fromAccount, callContext)) map {
|
||||
connectorEmptyResponse(_, callContext)
|
||||
}
|
||||
(transactionRequestTypeCharges, callContext) <- NewStyle.function.getTransactionRequestTypeCharges(bankId, accountId, viewId, transactionRequestTypes, callContext)
|
||||
|
||||
@ -787,7 +787,7 @@ trait Connector extends MdcLoggable {
|
||||
Failure(setUnimplementedError(nameOf(getTransactionRequestImpl _)))
|
||||
|
||||
|
||||
def getTransactionRequestTypes(initiator : User, fromAccount : BankAccount, callContext: Option[CallContext]) : Box[List[TransactionRequestType]] =Failure(setUnimplementedError(nameOf(createChallengesC3 _)))
|
||||
def getTransactionRequestTypes(initiator : User, fromAccount : BankAccount, callContext: Option[CallContext]) : Box[(List[TransactionRequestType], Option[CallContext])] =Failure(setUnimplementedError(nameOf(createChallengesC3 _)))
|
||||
|
||||
def createTransactionAfterChallengeV210(fromAccount: BankAccount, transactionRequest: TransactionRequest, callContext: Option[CallContext]) : OBPReturnType[Box[TransactionRequest]] =
|
||||
Future{(Failure(setUnimplementedError(nameOf(createTransactionAfterChallengeV210 _))), callContext)}
|
||||
|
||||
@ -360,9 +360,6 @@ object ConnectorBuilderUtil {
|
||||
"deleteCustomerAttribute",
|
||||
"getPhysicalCardsForUser",
|
||||
"getChallengesByBasketId",
|
||||
|
||||
// The follow methods's parameter or return type are special
|
||||
"getCurrentFxRate",
|
||||
"createChallengesC2",
|
||||
"createChallengesC3",
|
||||
"getChallenge",
|
||||
@ -375,29 +372,29 @@ object ConnectorBuilderUtil {
|
||||
"validateChallengeAnswerC5",
|
||||
"validateChallengeAnswerV2",
|
||||
"getCounterpartyByIbanAndBankAccountId",
|
||||
"getStatus",
|
||||
"getChargeValue",
|
||||
"saveTransactionRequestTransaction",
|
||||
"saveTransactionRequestChallenge",
|
||||
"getTransactionRequestTypes",
|
||||
"updateAccountLabel",
|
||||
"getProduct",
|
||||
"createOrUpdateBranch",
|
||||
"createOrUpdateAtm",
|
||||
"createOrUpdateProduct",
|
||||
"createOrUpdateFXRate",
|
||||
"getTransactionRequestTypeCharges",
|
||||
"getCounterpartyFromTransaction",
|
||||
"getCounterpartiesFromTransaction",
|
||||
"saveTransactionRequestStatusImpl"
|
||||
"saveTransactionRequestStatusImpl",
|
||||
"getTransactionRequestTypeCharges"
|
||||
).distinct
|
||||
|
||||
/**
|
||||
* these connector methods have special parameter or return type
|
||||
*/
|
||||
val specialMethods = List(
|
||||
"getStatus",
|
||||
"createOrUpdateBranch",
|
||||
"createOrUpdateBank",
|
||||
"getCurrentFxRate"
|
||||
"createOrUpdateAtm",
|
||||
"createOrUpdateProduct",
|
||||
"createOrUpdateFXRate",
|
||||
"getCurrentFxRate",
|
||||
"getCounterpartyFromTransaction",
|
||||
"getCounterpartiesFromTransaction",
|
||||
).distinct
|
||||
|
||||
val omitMethods = List(
|
||||
|
||||
@ -4578,7 +4578,7 @@ object LocalMappedConnector extends Connector with MdcLoggable {
|
||||
override def notifyTransactionRequest(fromAccount: BankAccount, toAccount: BankAccount, transactionRequest: TransactionRequest, callContext: Option[CallContext]): OBPReturnType[Box[TransactionRequestStatusValue]] =
|
||||
Future((Full(TransactionRequestStatusValue(transactionRequest.status)), callContext))
|
||||
|
||||
override def saveTransactionRequestTransaction(transactionRequestId: TransactionRequestId, transactionId: TransactionId, callContext: Option[CallContext]) = {
|
||||
override def saveTransactionRequestTransaction(transactionRequestId: TransactionRequestId, transactionId: TransactionId, callContext: Option[CallContext]) : OBPReturnType[Box[Boolean]]= {
|
||||
Future{(TransactionRequests.transactionRequestProvider.vend.saveTransactionRequestTransactionImpl(transactionRequestId, transactionId), callContext)}
|
||||
}
|
||||
|
||||
@ -4609,8 +4609,8 @@ object LocalMappedConnector extends Connector with MdcLoggable {
|
||||
override def getTransactionRequestImpl(transactionRequestId: TransactionRequestId, callContext: Option[CallContext]): Box[(TransactionRequest, Option[CallContext])] =
|
||||
TransactionRequests.transactionRequestProvider.vend.getTransactionRequest(transactionRequestId).map(transactionRequest => (transactionRequest, callContext))
|
||||
|
||||
override def getTransactionRequestTypes(initiator: User, fromAccount: BankAccount, callContext: Option[CallContext]): Box[List[TransactionRequestType]] = {
|
||||
Full(APIUtil.getPropsValue("transactionRequests_supported_types", "").split(",").map(x => TransactionRequestType(x)).toList)
|
||||
override def getTransactionRequestTypes(initiator: User, fromAccount: BankAccount, callContext: Option[CallContext]):Box[(List[TransactionRequestType], Option[CallContext])] = {
|
||||
Full((APIUtil.getPropsValue("transactionRequests_supported_types", "").split(",").map(x => TransactionRequestType(x)).toList, callContext))
|
||||
}
|
||||
|
||||
override def createTransactionAfterChallengeV210(fromAccount: BankAccount, transactionRequest: TransactionRequest, callContext: Option[CallContext]): OBPReturnType[Box[TransactionRequest]] = {
|
||||
|
||||
@ -1418,7 +1418,7 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
lastMarketingAgreementSignedDate=Some(toDate(dateExample))))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetPhysicalCardsForUser(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetPhysicalCardsForUser(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( PhysicalCard(cardId=cardIdExample.value,
|
||||
bankId=bankIdExample.value,
|
||||
bankCardNumber=bankCardNumberExample.value,
|
||||
@ -2739,12 +2739,13 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProducts(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProducts(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
bankId=BankId(bankIdExample.value),
|
||||
params=List( GetProductsParam(name=nameExample.value,
|
||||
value=valueExample.value.split("[,;]").toList)))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProducts(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProducts(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -2764,8 +2765,7 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
|
||||
override def getProducts(bankId: BankId, params: List[GetProductsParam], callContext: Option[CallContext]): OBPReturnType[Box[List[Product]]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProducts => InBound, OutBoundGetProducts => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, params)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, params)
|
||||
val response: Future[Box[InBound]] = (southSideActor ? req).mapTo[InBound].recoverWith(recoverFunction).map(Box !! _)
|
||||
response.map(convertToTuple[List[ProductCommons]](callContext))
|
||||
}
|
||||
@ -2778,11 +2778,11 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProduct(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProduct(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext, bankId=BankId(bankIdExample.value),
|
||||
productCode=ProductCode(productCodeExample.value))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProduct(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProduct(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -2802,8 +2802,7 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
|
||||
override def getProduct(bankId: BankId, productCode: ProductCode, callContext: Option[CallContext]): OBPReturnType[Box[Product]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProduct => InBound, OutBoundGetProduct => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, productCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, productCode)
|
||||
val response: Future[Box[InBound]] = (southSideActor ? req).mapTo[InBound].recoverWith(recoverFunction).map(Box !! _)
|
||||
response.map(convertToTuple[ProductCommons](callContext))
|
||||
}
|
||||
@ -3144,12 +3143,12 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetCurrentFxRate(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetCurrentFxRate(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value)
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetCurrentFxRate(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetCurrentFxRate(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= FXRateCommons(bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value,
|
||||
@ -3162,8 +3161,7 @@ object AkkaConnector_vDec2018 extends Connector with AkkaConnectorActorInit {
|
||||
|
||||
override def getCurrentFxRate(bankId: BankId, fromCurrencyCode: String, toCurrencyCode: String, callContext: Option[CallContext]): Box[FXRate] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetCurrentFxRate => InBound, OutBoundGetCurrentFxRate => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val response: Future[Box[InBound]] = (southSideActor ? req).mapTo[InBound].recoverWith(recoverFunction).map(Box !! _)
|
||||
response.map(convertToTuple[FXRateCommons](callContext))
|
||||
}
|
||||
|
||||
@ -43,7 +43,7 @@ object AdapterStubBuilder {
|
||||
val codeList = messageDocs
|
||||
//these are only for debugging.
|
||||
// .filterNot(_.process.equals("obp.getCustomers"))//getBanks is the template code, already in the code.
|
||||
// .filter(_.process.equals("obp.getCustomers"))//getBanks is the template code, already in the code.
|
||||
// .filter(_.process.equals("obp.validateAndCheckIbanNumber"))//getBanks is the template code, already in the code.
|
||||
// .take(80)
|
||||
// .slice(91,1000)
|
||||
.map(
|
||||
@ -137,9 +137,7 @@ object AdapterStubBuilder {
|
||||
else
|
||||
null
|
||||
|
||||
val inboundAdapterCallContext = if(ConnectorBuilderUtil.specialMethods.contains(connectorMethodName) ||
|
||||
connectorMethodName == "getPhysicalCardsForUser" // this need to be check, InBoundGetPhysicalCardsForUser is missing inboundAdapterCallContext field.
|
||||
)
|
||||
val inboundAdapterCallContext = if(ConnectorBuilderUtil.specialMethods.contains(connectorMethodName))
|
||||
""
|
||||
else
|
||||
"""
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -73,7 +73,7 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
val connectorName = "rabbitmq_vOct2024"
|
||||
|
||||
//---------------- dynamic start -------------------please don't modify this line
|
||||
// ---------- created on 2024-10-16T00:14:34Z
|
||||
// ---------- created on 2024-10-28T12:32:40Z
|
||||
|
||||
messageDocs += getAdapterInfoDoc
|
||||
def getAdapterInfoDoc = MessageDoc(
|
||||
@ -1650,7 +1650,8 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
lastMarketingAgreementSignedDate=Some(toDate(dateExample))))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetPhysicalCardsForUser(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetPhysicalCardsForUser(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( PhysicalCard(cardId=cardIdExample.value,
|
||||
bankId=bankIdExample.value,
|
||||
bankCardNumber=bankCardNumberExample.value,
|
||||
@ -2136,6 +2137,33 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[TransactionId](callContext))
|
||||
}
|
||||
|
||||
messageDocs += getChargeValueDoc
|
||||
def getChargeValueDoc = MessageDoc(
|
||||
process = "obp.getChargeValue",
|
||||
messageFormat = messageFormat,
|
||||
description = "Get Charge Value",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetChargeValue(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
chargeLevelAmount=BigDecimal("123.321"),
|
||||
transactionRequestCommonBodyAmount=BigDecimal("123.321"))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetChargeValue(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data="string")
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def getChargeValue(chargeLevelAmount: BigDecimal, transactionRequestCommonBodyAmount: BigDecimal, callContext: Option[CallContext]): OBPReturnType[Box[String]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetChargeValue => InBound, OutBoundGetChargeValue => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, chargeLevelAmount, transactionRequestCommonBodyAmount)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_charge_value", req, callContext)
|
||||
response.map(convertToTuple[String](callContext))
|
||||
}
|
||||
|
||||
messageDocs += createTransactionRequestv210Doc
|
||||
def createTransactionRequestv210Doc = MessageDoc(
|
||||
process = "obp.createTransactionRequestv210",
|
||||
@ -2592,6 +2620,89 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[TransactionRequestBGV1](callContext))
|
||||
}
|
||||
|
||||
messageDocs += saveTransactionRequestTransactionDoc
|
||||
def saveTransactionRequestTransactionDoc = MessageDoc(
|
||||
process = "obp.saveTransactionRequestTransaction",
|
||||
messageFormat = messageFormat,
|
||||
description = "Save Transaction Request Transaction",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundSaveTransactionRequestTransaction(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
transactionRequestId=TransactionRequestId(transactionRequestIdExample.value),
|
||||
transactionId=TransactionId(transactionIdExample.value))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundSaveTransactionRequestTransaction(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=true)
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def saveTransactionRequestTransaction(transactionRequestId: TransactionRequestId, transactionId: TransactionId, callContext: Option[CallContext]): OBPReturnType[Box[Boolean]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundSaveTransactionRequestTransaction => InBound, OutBoundSaveTransactionRequestTransaction => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, transactionRequestId, transactionId)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_save_transaction_request_transaction", req, callContext)
|
||||
response.map(convertToTuple[Boolean](callContext))
|
||||
}
|
||||
|
||||
messageDocs += saveTransactionRequestChallengeDoc
|
||||
def saveTransactionRequestChallengeDoc = MessageDoc(
|
||||
process = "obp.saveTransactionRequestChallenge",
|
||||
messageFormat = messageFormat,
|
||||
description = "Save Transaction Request Challenge",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundSaveTransactionRequestChallenge(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
transactionRequestId=TransactionRequestId(transactionRequestIdExample.value),
|
||||
challenge= TransactionRequestChallenge(id=challengeIdExample.value,
|
||||
allowed_attempts=123,
|
||||
challenge_type="string"))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundSaveTransactionRequestChallenge(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=true)
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def saveTransactionRequestChallenge(transactionRequestId: TransactionRequestId, challenge: TransactionRequestChallenge, callContext: Option[CallContext]): OBPReturnType[Box[Boolean]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundSaveTransactionRequestChallenge => InBound, OutBoundSaveTransactionRequestChallenge => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, transactionRequestId, challenge)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_save_transaction_request_challenge", req, callContext)
|
||||
response.map(convertToTuple[Boolean](callContext))
|
||||
}
|
||||
|
||||
messageDocs += saveTransactionRequestStatusImplDoc
|
||||
def saveTransactionRequestStatusImplDoc = MessageDoc(
|
||||
process = "obp.saveTransactionRequestStatusImpl",
|
||||
messageFormat = messageFormat,
|
||||
description = "Save Transaction Request Status Impl",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundSaveTransactionRequestStatusImpl(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
transactionRequestId=TransactionRequestId(transactionRequestIdExample.value),
|
||||
status=statusExample.value)
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundSaveTransactionRequestStatusImpl(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=true)
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def saveTransactionRequestStatusImpl(transactionRequestId: TransactionRequestId, status: String, callContext: Option[CallContext]): OBPReturnType[Box[Boolean]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundSaveTransactionRequestStatusImpl => InBound, OutBoundSaveTransactionRequestStatusImpl => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, transactionRequestId, status)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_save_transaction_request_status_impl", req, callContext)
|
||||
response.map(convertToTuple[Boolean](callContext))
|
||||
}
|
||||
|
||||
messageDocs += getTransactionRequests210Doc
|
||||
def getTransactionRequests210Doc = MessageDoc(
|
||||
process = "obp.getTransactionRequests210",
|
||||
@ -2827,6 +2938,58 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[TransactionRequest](callContext))
|
||||
}
|
||||
|
||||
messageDocs += getTransactionRequestTypesDoc
|
||||
def getTransactionRequestTypesDoc = MessageDoc(
|
||||
process = "obp.getTransactionRequestTypes",
|
||||
messageFormat = messageFormat,
|
||||
description = "Get Transaction Request Types",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetTransactionRequestTypes(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
initiator= UserCommons(userPrimaryKey=UserPrimaryKey(123),
|
||||
userId=userIdExample.value,
|
||||
idGivenByProvider="string",
|
||||
provider=providerExample.value,
|
||||
emailAddress=emailAddressExample.value,
|
||||
name=userNameExample.value,
|
||||
createdByConsentId=Some("string"),
|
||||
createdByUserInvitationId=Some("string"),
|
||||
isDeleted=Some(true),
|
||||
lastMarketingAgreementSignedDate=Some(toDate(dateExample))),
|
||||
fromAccount= BankAccountCommons(accountId=AccountId(accountIdExample.value),
|
||||
accountType=accountTypeExample.value,
|
||||
balance=BigDecimal(balanceExample.value),
|
||||
currency=currencyExample.value,
|
||||
name=bankAccountNameExample.value,
|
||||
label=labelExample.value,
|
||||
number=bankAccountNumberExample.value,
|
||||
bankId=BankId(bankIdExample.value),
|
||||
lastUpdate=toDate(bankAccountLastUpdateExample),
|
||||
branchId=branchIdExample.value,
|
||||
accountRoutings=List( AccountRouting(scheme=accountRoutingSchemeExample.value,
|
||||
address=accountRoutingAddressExample.value)),
|
||||
accountRules=List( AccountRule(scheme=accountRuleSchemeExample.value,
|
||||
value=accountRuleValueExample.value)),
|
||||
accountHolder=bankAccountAccountHolderExample.value,
|
||||
attributes=Some(List( Attribute(name=attributeNameExample.value,
|
||||
`type`=attributeTypeExample.value,
|
||||
value=attributeValueExample.value)))))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetTransactionRequestTypes(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List(TransactionRequestType(transactionRequestTypeExample.value)))
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def getTransactionRequestTypes(initiator: User, fromAccount: BankAccount, callContext: Option[CallContext]): Box[(List[TransactionRequestType], Option[CallContext])] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetTransactionRequestTypes => InBound, OutBoundGetTransactionRequestTypes => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, initiator, fromAccount)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_transaction_request_types", req, callContext)
|
||||
response.map(convertToTuple[List[TransactionRequestType]](callContext))
|
||||
}
|
||||
|
||||
messageDocs += createTransactionAfterChallengeV210Doc
|
||||
def createTransactionAfterChallengeV210Doc = MessageDoc(
|
||||
process = "obp.createTransactionAfterChallengeV210",
|
||||
@ -3128,6 +3291,34 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[BankAccountCommons](callContext))
|
||||
}
|
||||
|
||||
messageDocs += updateAccountLabelDoc
|
||||
def updateAccountLabelDoc = MessageDoc(
|
||||
process = "obp.updateAccountLabel",
|
||||
messageFormat = messageFormat,
|
||||
description = "Update Account Label",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundUpdateAccountLabel(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
bankId=BankId(bankIdExample.value),
|
||||
accountId=AccountId(accountIdExample.value),
|
||||
label=labelExample.value)
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundUpdateAccountLabel(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=true)
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def updateAccountLabel(bankId: BankId, accountId: AccountId, label: String, callContext: Option[CallContext]): OBPReturnType[Box[Boolean]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundUpdateAccountLabel => InBound, OutBoundUpdateAccountLabel => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, bankId, accountId, label)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_update_account_label", req, callContext)
|
||||
response.map(convertToTuple[Boolean](callContext))
|
||||
}
|
||||
|
||||
messageDocs += getProductsDoc
|
||||
def getProductsDoc = MessageDoc(
|
||||
process = "obp.getProducts",
|
||||
@ -3136,12 +3327,14 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProducts(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProducts(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
bankId=BankId(bankIdExample.value),
|
||||
params=List( GetProductsParam(name=nameExample.value,
|
||||
value=valueExample.value.replace("[","").replace("]","").split(",").toList)))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProducts(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProducts(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -3161,8 +3354,7 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
|
||||
override def getProducts(bankId: BankId, params: List[GetProductsParam], callContext: Option[CallContext]): OBPReturnType[Box[List[Product]]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProducts => InBound, OutBoundGetProducts => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, params)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, bankId, params)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_products", req, callContext)
|
||||
response.map(convertToTuple[List[ProductCommons]](callContext))
|
||||
}
|
||||
@ -3175,11 +3367,13 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProduct(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProduct(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
bankId=BankId(bankIdExample.value),
|
||||
productCode=ProductCode(productCodeExample.value))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProduct(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProduct(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -3199,8 +3393,7 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
|
||||
override def getProduct(bankId: BankId, productCode: ProductCode, callContext: Option[CallContext]): OBPReturnType[Box[Product]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProduct => InBound, OutBoundGetProduct => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, productCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, bankId, productCode)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_product", req, callContext)
|
||||
response.map(convertToTuple[ProductCommons](callContext))
|
||||
}
|
||||
@ -3533,38 +3726,6 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[List[AtmTCommons]](callContext))
|
||||
}
|
||||
|
||||
messageDocs += getCurrentFxRateDoc
|
||||
def getCurrentFxRateDoc = MessageDoc(
|
||||
process = "obp.getCurrentFxRate",
|
||||
messageFormat = messageFormat,
|
||||
description = "Get Current Fx Rate",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetCurrentFxRate(bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value)
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetCurrentFxRate(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= FXRateCommons(bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value,
|
||||
conversionValue=conversionValueExample.value.toDouble,
|
||||
inverseConversionValue=inverseConversionValueExample.value.toDouble,
|
||||
effectiveDate=toDate(effectiveDateExample)))
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def getCurrentFxRate(bankId: BankId, fromCurrencyCode: String, toCurrencyCode: String, callContext: Option[CallContext]): Box[FXRate] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetCurrentFxRate => InBound, OutBoundGetCurrentFxRate => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_current_fx_rate", req, callContext)
|
||||
response.map(convertToTuple[FXRateCommons](callContext))
|
||||
}
|
||||
|
||||
messageDocs += createTransactionAfterChallengev300Doc
|
||||
def createTransactionAfterChallengev300Doc = MessageDoc(
|
||||
process = "obp.createTransactionAfterChallengev300",
|
||||
@ -4104,6 +4265,39 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[CancelPayment](callContext))
|
||||
}
|
||||
|
||||
messageDocs += getTransactionRequestTypeChargesDoc
|
||||
def getTransactionRequestTypeChargesDoc = MessageDoc(
|
||||
process = "obp.getTransactionRequestTypeCharges",
|
||||
messageFormat = messageFormat,
|
||||
description = "Get Transaction Request Type Charges",
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetTransactionRequestTypeCharges(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,
|
||||
bankId=BankId(bankIdExample.value),
|
||||
accountId=AccountId(accountIdExample.value),
|
||||
viewId=ViewId(viewIdExample.value),
|
||||
transactionRequestTypes=List(TransactionRequestType(transactionRequestTypesExample.value)))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetTransactionRequestTypeCharges(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,
|
||||
status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( TransactionRequestTypeChargeCommons(transactionRequestTypeId="string",
|
||||
bankId=bankIdExample.value,
|
||||
chargeCurrency="string",
|
||||
chargeAmount="string",
|
||||
chargeSummary="string")))
|
||||
),
|
||||
adapterImplementation = Some(AdapterImplementation("- Core", 1))
|
||||
)
|
||||
|
||||
override def getTransactionRequestTypeCharges(bankId: BankId, accountId: AccountId, viewId: ViewId, transactionRequestTypes: List[TransactionRequestType], callContext: Option[CallContext]): OBPReturnType[Box[List[TransactionRequestTypeCharge]]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetTransactionRequestTypeCharges => InBound, OutBoundGetTransactionRequestTypeCharges => OutBound}
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull, bankId, accountId, viewId, transactionRequestTypes)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_transaction_request_type_charges", req, callContext)
|
||||
response.map(convertToTuple[List[TransactionRequestTypeChargeCommons]](callContext))
|
||||
}
|
||||
|
||||
messageDocs += createCounterpartyDoc
|
||||
def createCounterpartyDoc = MessageDoc(
|
||||
process = "obp.createCounterparty",
|
||||
@ -6756,8 +6950,8 @@ trait RabbitMQConnector_vOct2024 extends Connector with MdcLoggable {
|
||||
response.map(convertToTuple[Boolean](callContext))
|
||||
}
|
||||
|
||||
// ---------- created on 2024-10-16T00:14:34Z
|
||||
//---------------- dynamic end ---------------------please don't modify this line
|
||||
// ---------- created on 2024-10-28T12:32:40Z
|
||||
//---------------- dynamic end ---------------------please don't modify this line
|
||||
|
||||
private val availableOperation = DynamicEntityOperation.values.map(it => s""""$it"""").mkString("[", ", ", "]")
|
||||
|
||||
|
||||
@ -1559,7 +1559,7 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
lastMarketingAgreementSignedDate=Some(toDate(dateExample))))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetPhysicalCardsForUser(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetPhysicalCardsForUser(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( PhysicalCard(cardId=cardIdExample.value,
|
||||
bankId=bankIdExample.value,
|
||||
bankCardNumber=bankCardNumberExample.value,
|
||||
@ -2910,12 +2910,12 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProducts(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProducts(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,bankId=BankId(bankIdExample.value),
|
||||
params=List( GetProductsParam(name=nameExample.value,
|
||||
value=valueExample.value.replaceAll("\\[","").replaceAll("\\]","").split(",").toList)))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProducts(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProducts(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -2935,8 +2935,7 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
|
||||
override def getProducts(bankId: BankId, params: List[GetProductsParam], callContext: Option[CallContext]): OBPReturnType[Box[List[Product]]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProducts => InBound, OutBoundGetProducts => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, params)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, params)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound](getUrl(callContext, "getProducts"), HttpMethods.POST, req, callContext)
|
||||
response.map(convertToTuple[List[ProductCommons]](callContext))
|
||||
}
|
||||
@ -2949,11 +2948,11 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProduct(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProduct(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext, bankId=BankId(bankIdExample.value),
|
||||
productCode=ProductCode(productCodeExample.value))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProduct(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProduct(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -2973,8 +2972,7 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
|
||||
override def getProduct(bankId: BankId, productCode: ProductCode, callContext: Option[CallContext]): OBPReturnType[Box[Product]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProduct => InBound, OutBoundGetProduct => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, productCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, productCode)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound](getUrl(callContext, "getProduct"), HttpMethods.POST, req, callContext)
|
||||
response.map(convertToTuple[ProductCommons](callContext))
|
||||
}
|
||||
@ -3315,12 +3313,12 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetCurrentFxRate(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetCurrentFxRate(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value)
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetCurrentFxRate(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetCurrentFxRate(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= FXRateCommons(bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value,
|
||||
@ -3333,8 +3331,7 @@ trait RestConnector_vMar2019 extends Connector with KafkaHelper with MdcLoggable
|
||||
|
||||
override def getCurrentFxRate(bankId: BankId, fromCurrencyCode: String, toCurrencyCode: String, callContext: Option[CallContext]): Box[FXRate] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetCurrentFxRate => InBound, OutBoundGetCurrentFxRate => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound](getUrl(callContext, "getCurrentFxRate"), HttpMethods.POST, req, callContext)
|
||||
response.map(convertToTuple[FXRateCommons](callContext))
|
||||
}
|
||||
|
||||
@ -1726,7 +1726,7 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
lastMarketingAgreementSignedDate=Some(toDate(dateExample))))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetPhysicalCardsForUser(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetPhysicalCardsForUser(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( PhysicalCard(cardId=cardIdExample.value,
|
||||
bankId=bankIdExample.value,
|
||||
bankCardNumber=bankCardNumberExample.value,
|
||||
@ -3213,12 +3213,12 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProducts(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProducts(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,bankId=BankId(bankIdExample.value),
|
||||
params=List( GetProductsParam(name=nameExample.value,
|
||||
value=valueExample.value.split("[,;]").toList)))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProducts(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProducts(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data=List( ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -3238,8 +3238,7 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
|
||||
override def getProducts(bankId: BankId, params: List[GetProductsParam], callContext: Option[CallContext]): OBPReturnType[Box[List[Product]]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProducts => InBound, OutBoundGetProducts => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, params)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, params)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_products", req, callContext)
|
||||
response.map(convertToTuple[List[ProductCommons]](callContext))
|
||||
}
|
||||
@ -3252,11 +3251,11 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetProduct(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetProduct(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext, bankId=BankId(bankIdExample.value),
|
||||
productCode=ProductCode(productCodeExample.value))
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetProduct(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetProduct(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext, status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= ProductCommons(bankId=BankId(bankIdExample.value),
|
||||
code=ProductCode(productCodeExample.value),
|
||||
parentProductCode=ProductCode(parentProductCodeExample.value),
|
||||
@ -3276,8 +3275,7 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
|
||||
override def getProduct(bankId: BankId, productCode: ProductCode, callContext: Option[CallContext]): OBPReturnType[Box[Product]] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetProduct => InBound, OutBoundGetProduct => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, productCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, productCode)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_product", req, callContext)
|
||||
response.map(convertToTuple[ProductCommons](callContext))
|
||||
}
|
||||
@ -3618,12 +3616,12 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
outboundTopic = None,
|
||||
inboundTopic = None,
|
||||
exampleOutboundMessage = (
|
||||
OutBoundGetCurrentFxRate(bankId=BankId(bankIdExample.value),
|
||||
OutBoundGetCurrentFxRate(outboundAdapterCallContext=MessageDocsSwaggerDefinitions.outboundAdapterCallContext,bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value)
|
||||
),
|
||||
exampleInboundMessage = (
|
||||
InBoundGetCurrentFxRate(status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
InBoundGetCurrentFxRate(inboundAdapterCallContext=MessageDocsSwaggerDefinitions.inboundAdapterCallContext,status=MessageDocsSwaggerDefinitions.inboundStatus,
|
||||
data= FXRateCommons(bankId=BankId(bankIdExample.value),
|
||||
fromCurrencyCode=fromCurrencyCodeExample.value,
|
||||
toCurrencyCode=toCurrencyCodeExample.value,
|
||||
@ -3636,8 +3634,7 @@ trait StoredProcedureConnector_vDec2019 extends Connector with MdcLoggable {
|
||||
|
||||
override def getCurrentFxRate(bankId: BankId, fromCurrencyCode: String, toCurrencyCode: String, callContext: Option[CallContext]): Box[FXRate] = {
|
||||
import com.openbankproject.commons.dto.{InBoundGetCurrentFxRate => InBound, OutBoundGetCurrentFxRate => OutBound}
|
||||
val callContext: Option[CallContext] = None
|
||||
val req = OutBound(bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val req = OutBound(callContext.map(_.toOutboundAdapterCallContext).orNull,bankId, fromCurrencyCode, toCurrencyCode)
|
||||
val response: Future[Box[InBound]] = sendRequest[InBound]("obp_get_current_fx_rate", req, callContext)
|
||||
response.map(convertToTuple[FXRateCommons](callContext))
|
||||
}
|
||||
|
||||
@ -91,13 +91,6 @@ case class OutBoundGetBankAccountsForUser(outboundAdapterCallContext: OutboundAd
|
||||
case class InBoundGetBankAccountsForUser(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[InboundAccountCommons]) extends InBoundTrait[List[InboundAccountCommons]]
|
||||
|
||||
|
||||
case class OutBoundGetBankAccountOld(
|
||||
bankId: BankId,
|
||||
accountId: AccountId) extends TopicTrait
|
||||
case class InBoundGetBankAccountOld(status: Status, data: BankAccountCommons) extends InBoundTrait[BankAccountCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetBankAccount(outboundAdapterCallContext: OutboundAdapterCallContext,
|
||||
bankId: BankId,
|
||||
accountId: AccountId) extends TopicTrait
|
||||
@ -492,18 +485,6 @@ case class OutBoundGetMeeting(outboundAdapterCallContext: OutboundAdapterCallCon
|
||||
meetingId: String) extends TopicTrait
|
||||
case class InBoundGetMeeting(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: MeetingCommons) extends InBoundTrait[MeetingCommons]
|
||||
|
||||
case class OutBoundGetUser(name: String, password: String) extends TopicTrait
|
||||
|
||||
case class InBoundGetUser(status: Status, data: InboundUser) extends InBoundTrait[InboundUser] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetExternalUser(name: String, password: String) extends TopicTrait
|
||||
|
||||
case class InBoundGetExternalUser(status: Status, data: InboundExternalUser) extends InBoundTrait[InboundExternalUser] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
|
||||
//create bound case classes
|
||||
case class OutBoundCreateChallenge(outboundAdapterCallContext: OutboundAdapterCallContext,
|
||||
bankId: BankId,
|
||||
@ -1025,53 +1006,29 @@ case class OutBoundCreateChallenges(outboundAdapterCallContext: OutboundAdapterC
|
||||
case class InBoundCreateChallenges(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[String]) extends InBoundTrait[List[String]]
|
||||
|
||||
|
||||
case class OutBoundGetCounterpartyFromTransaction(bankId: BankId, accountId: AccountId, counterpartyId: String) extends TopicTrait
|
||||
case class InBoundGetCounterpartyFromTransaction(status: Status, data: Counterparty) extends InBoundTrait[Counterparty] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetCounterpartyFromTransaction(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, accountId: AccountId, counterpartyId: String) extends TopicTrait
|
||||
case class InBoundGetCounterpartyFromTransaction(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Counterparty) extends InBoundTrait[Counterparty]
|
||||
|
||||
case class OutBoundGetCounterpartiesFromTransaction(bankId: BankId, accountId: AccountId) extends TopicTrait
|
||||
case class InBoundGetCounterpartiesFromTransaction(status: Status, data: List[Counterparty]) extends InBoundTrait[List[Counterparty]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetCounterpartiesFromTransaction(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, accountId: AccountId) extends TopicTrait
|
||||
case class InBoundGetCounterpartiesFromTransaction(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[Counterparty]) extends InBoundTrait[List[Counterparty]]
|
||||
|
||||
case class OutBoundGetCounterparty(thisBankId: BankId, thisAccountId: AccountId, couterpartyId: String) extends TopicTrait
|
||||
case class InBoundGetCounterparty(status: Status, data: Counterparty) extends InBoundTrait[Counterparty] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetCounterparty(outboundAdapterCallContext: OutboundAdapterCallContext, thisBankId: BankId, thisAccountId: AccountId, couterpartyId: String) extends TopicTrait
|
||||
case class InBoundGetCounterparty(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Counterparty) extends InBoundTrait[Counterparty]
|
||||
|
||||
case class OutBoundGetPhysicalCardsForUser(outboundAdapterCallContext: OutboundAdapterCallContext, user: User) extends TopicTrait
|
||||
case class InBoundGetPhysicalCardsForUser(status: Status, data: List[PhysicalCard]) extends InBoundTrait[List[PhysicalCard]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetPhysicalCardsForBankLegacy(bank: Bank, user: User,
|
||||
limit: Int,
|
||||
offset: Int,
|
||||
fromDate: String,
|
||||
toDate: String) extends TopicTrait
|
||||
case class InBoundGetPhysicalCardsForBankLegacy(status: Status, data: List[PhysicalCard]) extends InBoundTrait[List[PhysicalCard]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class InBoundGetPhysicalCardsForUser(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[PhysicalCard]) extends InBoundTrait[List[PhysicalCard]]
|
||||
|
||||
|
||||
|
||||
case class OutBoundCreateTransactionRequest(outboundAdapterCallContext: OutboundAdapterCallContext,initiator: User, fromAccount: BankAccount, toAccount: BankAccount, transactionRequestType: TransactionRequestType, body: TransactionRequestBody) extends TopicTrait
|
||||
case class InBoundCreateTransactionRequest(status: Status, data: TransactionRequest) extends InBoundTrait[TransactionRequest] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class InBoundCreateTransactionRequest(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: TransactionRequest) extends InBoundTrait[TransactionRequest]
|
||||
|
||||
case class OutBoundGetStatus(challengeThresholdAmount: BigDecimal, transactionRequestCommonBodyAmount: BigDecimal, transactionRequestType: TransactionRequestType) extends TopicTrait
|
||||
case class InBoundGetStatus(status: Status, statusValue: String) extends InBoundTrait[TransactionRequestStatus.Value] {
|
||||
case class OutBoundGetStatus(outboundAdapterCallContext: OutboundAdapterCallContext, challengeThresholdAmount: BigDecimal, transactionRequestCommonBodyAmount: BigDecimal, transactionRequestType: TransactionRequestType) extends TopicTrait
|
||||
case class InBoundGetStatus(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, statusValue: String, data: TransactionRequestStatus.Value) extends InBoundTrait[TransactionRequestStatus.Value]
|
||||
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
override val data: TransactionRequestStatus.Value = TransactionRequestStatus.withName(statusValue)
|
||||
}
|
||||
|
||||
case class OutBoundGetChargeValue(chargeLevelAmount: BigDecimal, transactionRequestCommonBodyAmount: BigDecimal) extends TopicTrait
|
||||
case class InBoundGetChargeValue(status: Status, data: String) extends InBoundTrait[String] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetChargeValue(outboundAdapterCallContext: OutboundAdapterCallContext, chargeLevelAmount: BigDecimal, transactionRequestCommonBodyAmount: BigDecimal) extends TopicTrait
|
||||
case class InBoundGetChargeValue(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: String) extends InBoundTrait[String]
|
||||
|
||||
case class OutBoundCreateTransactionRequestv400(outboundAdapterCallContext: OutboundAdapterCallContext, initiator: User, viewId: ViewId, fromAccount: BankAccount, toAccount: BankAccount, transactionRequestType: TransactionRequestType,
|
||||
transactionRequestCommonBody: TransactionRequestCommonBodyJSON,
|
||||
@ -1101,150 +1058,64 @@ case class OutBoundCreateTransactionRequestPeriodicSepaCreditTransfersBGV1(
|
||||
|
||||
case class InBoundCreateTransactionRequestPeriodicSepaCreditTransfersBGV1(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: TransactionRequestBGV1) extends InBoundTrait[TransactionRequestBGV1]
|
||||
|
||||
case class OutBoundCreateTransactionRequestImpl(transactionRequestId: TransactionRequestId, transactionRequestType: TransactionRequestType, fromAccount: BankAccount, counterparty: BankAccount, body: TransactionRequestBody, status: String, charge: TransactionRequestCharge) extends TopicTrait
|
||||
case class InBoundCreateTransactionRequestImpl(status: Status, data: TransactionRequest) extends InBoundTrait[TransactionRequest] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundCreateTransactionRequestImpl(outboundAdapterCallContext: OutboundAdapterCallContext, transactionRequestId: TransactionRequestId, transactionRequestType: TransactionRequestType, fromAccount: BankAccount, counterparty: BankAccount, body: TransactionRequestBody, status: String, charge: TransactionRequestCharge) extends TopicTrait
|
||||
case class InBoundCreateTransactionRequestImpl(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: TransactionRequest) extends InBoundTrait[TransactionRequest]
|
||||
|
||||
case class OutBoundSaveTransactionRequestTransaction(transactionRequestId: TransactionRequestId, transactionId: TransactionId) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestTransaction(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundSaveTransactionRequestTransaction(outboundAdapterCallContext: OutboundAdapterCallContext, transactionRequestId: TransactionRequestId, transactionId: TransactionId) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestTransaction(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Boolean) extends InBoundTrait[Boolean]
|
||||
|
||||
case class OutBoundSaveTransactionRequestTransactionImpl(transactionRequestId: TransactionRequestId, transactionId: TransactionId) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestTransactionImpl(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundSaveTransactionRequestTransactionImpl(outboundAdapterCallContext: OutboundAdapterCallContext, transactionRequestId: TransactionRequestId, transactionId: TransactionId) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestTransactionImpl(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Boolean) extends InBoundTrait[Boolean]
|
||||
|
||||
case class OutBoundSaveTransactionRequestChallenge(transactionRequestId: TransactionRequestId, challenge: TransactionRequestChallenge) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestChallenge(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundSaveTransactionRequestChallenge(outboundAdapterCallContext: OutboundAdapterCallContext, transactionRequestId: TransactionRequestId, challenge: TransactionRequestChallenge) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestChallenge(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Boolean) extends InBoundTrait[Boolean]
|
||||
|
||||
case class OutBoundSaveTransactionRequestChallengeImpl(transactionRequestId: TransactionRequestId, challenge: TransactionRequestChallenge) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestChallengeImpl(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundSaveTransactionRequestChallengeImpl(outboundAdapterCallContext: OutboundAdapterCallContext, transactionRequestId: TransactionRequestId, challenge: TransactionRequestChallenge) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestChallengeImpl(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Boolean) extends InBoundTrait[Boolean]
|
||||
|
||||
case class OutBoundSaveTransactionRequestStatusImpl(transactionRequestId: TransactionRequestId, status: String) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestStatusImpl(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundSaveTransactionRequestStatusImpl(outboundAdapterCallContext: OutboundAdapterCallContext, transactionRequestId: TransactionRequestId, status: String) extends TopicTrait
|
||||
case class InBoundSaveTransactionRequestStatusImpl(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Boolean) extends InBoundTrait[Boolean]
|
||||
|
||||
case class OutBoundGetTransactionRequests(outboundAdapterCallContext: OutboundAdapterCallContext,initiator: User, fromAccount: BankAccount) extends TopicTrait
|
||||
case class InBoundGetTransactionRequests(status: Status, data: List[TransactionRequest]) extends InBoundTrait[List[TransactionRequest]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class InBoundGetTransactionRequests(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[TransactionRequest]) extends InBoundTrait[List[TransactionRequest]]
|
||||
|
||||
case class OutBoundGetTransactionRequestTypes(outboundAdapterCallContext: OutboundAdapterCallContext, initiator: User, fromAccount: BankAccount) extends TopicTrait
|
||||
case class InBoundGetTransactionRequestTypes(status: Status, data: List[TransactionRequestType]) extends InBoundTrait[List[TransactionRequestType]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class InBoundGetTransactionRequestTypes(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[TransactionRequestType]) extends InBoundTrait[List[TransactionRequestType]]
|
||||
|
||||
case class OutBoundCreateTransactionAfterChallenge(outboundAdapterCallContext: OutboundAdapterCallContext, initiator: User, transReqId: TransactionRequestId) extends TopicTrait
|
||||
case class InBoundCreateTransactionAfterChallenge(status: Status, data: TransactionRequest) extends InBoundTrait[TransactionRequest] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class InBoundCreateTransactionAfterChallenge(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: TransactionRequest) extends InBoundTrait[TransactionRequest]
|
||||
|
||||
case class BankAndBankAccount(bank: BankCommons, account: BankAccountCommons)
|
||||
case class OutBoundCreateBankAndAccount(bankName: String, bankNationalIdentifier: String, accountNumber: String, accountType: String, accountLabel: String, currency: String, accountHolderName: String, branchId: String, accountRoutingScheme: String, accountRoutingAddress: String) extends TopicTrait
|
||||
case class InBoundCreateBankAndAccount(status: Status, value: BankAndBankAccount) extends InBoundTrait[(Bank, BankAccount)] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
override val data: (Bank, BankAccount) = (value.bank, value.account)
|
||||
}
|
||||
|
||||
case class OutBoundCreateSandboxBankAccount(bankId: BankId, accountId: AccountId, accountNumber: String, accountType: String, accountLabel: String, currency: String, initialBalance: BigDecimal, accountHolderName: String, branchId: String, accountRoutings: List[AccountRouting]) extends TopicTrait
|
||||
case class InBoundCreateSandboxBankAccount(status: Status, data: BankAccountCommons) extends InBoundTrait[BankAccountCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundCreateSandboxBankAccount(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, accountId: AccountId, accountNumber: String, accountType: String, accountLabel: String, currency: String, initialBalance: BigDecimal, accountHolderName: String, branchId: String, accountRoutings: List[AccountRouting]) extends TopicTrait
|
||||
case class InBoundCreateSandboxBankAccount(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: BankAccountCommons) extends InBoundTrait[BankAccountCommons]
|
||||
|
||||
case class OutBoundAccountExists(bankId: BankId, accountNumber: String) extends TopicTrait
|
||||
case class InBoundAccountExists(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundRemoveAccount(bankId: BankId, accountId: AccountId) extends TopicTrait
|
||||
case class InBoundRemoveAccount(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetMatchingTransactionCount(bankNationalIdentifier: String, accountNumber: String, amount: String, completed: Date, otherAccountHolder: String) extends TopicTrait
|
||||
case class InBoundGetMatchingTransactionCount(status: Status, data: Int) extends InBoundTrait[Int] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundUpdateAccountBalance(bankId: BankId, accountId: AccountId, newBalance: BigDecimal) extends TopicTrait
|
||||
case class InBoundUpdateAccountBalance(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundSetBankAccountLastUpdated(bankNationalIdentifier: String, accountNumber: String, updateDate: Date) extends TopicTrait
|
||||
case class InBoundSetBankAccountLastUpdated(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundUpdateAccountLabel(bankId: BankId, accountId: AccountId, label: String) extends TopicTrait
|
||||
case class InBoundUpdateAccountLabel(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundUpdateAccount(bankId: BankId, accountId: AccountId, label: String) extends TopicTrait
|
||||
case class InBoundUpdateAccount(status: Status, data: Boolean) extends InBoundTrait[Boolean] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundUpdateAccountLabel(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, accountId: AccountId, label: String) extends TopicTrait
|
||||
case class InBoundUpdateAccountLabel(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: Boolean) extends InBoundTrait[Boolean]
|
||||
|
||||
case class GetProductsParam(name: String, value: List[String])
|
||||
case class OutBoundGetProducts(bankId: BankId, params: List[GetProductsParam]) extends TopicTrait
|
||||
case class OutBoundGetProducts(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, params: List[GetProductsParam]) extends TopicTrait
|
||||
|
||||
case class InBoundGetProducts(status: Status, data: List[ProductCommons]) extends InBoundTrait[List[ProductCommons]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class InBoundGetProducts(inboundAdapterCallContext: InboundAdapterCallContext ,status: Status, data: List[ProductCommons]) extends InBoundTrait[List[ProductCommons]]
|
||||
|
||||
case class OutBoundGetProduct(bankId: BankId, productCode: ProductCode) extends TopicTrait
|
||||
case class InBoundGetProduct(status: Status, data: ProductCommons) extends InBoundTrait[ProductCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetProduct(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, productCode: ProductCode) extends TopicTrait
|
||||
case class InBoundGetProduct(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: ProductCommons) extends InBoundTrait[ProductCommons]
|
||||
|
||||
case class OutBoundGetCurrentFxRate(outboundAdapterCallContext: OutboundAdapterCallContext,bankId: BankId, fromCurrencyCode: String, toCurrencyCode: String) extends TopicTrait
|
||||
case class InBoundGetCurrentFxRate(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: FXRateCommons) extends InBoundTrait[FXRateCommons]
|
||||
|
||||
case class OutBoundCreateOrUpdateFXRate(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: String, fromCurrencyCode: String, toCurrencyCode: String, conversionValue: Double, inverseConversionValue: Double, effectiveDate: Date) extends TopicTrait
|
||||
case class InBoundCreateOrUpdateFXRate(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: FXRateCommons) extends InBoundTrait[FXRateCommons]
|
||||
|
||||
|
||||
case class OutBoundCreateOrUpdateBranch(branch: BranchT) extends TopicTrait
|
||||
case class InBoundCreateOrUpdateBranch(status: Status, data: BranchTCommons) extends InBoundTrait[BranchTCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetBranchLegacy(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, branchId: BranchId) extends TopicTrait
|
||||
case class InBoundGetBranchLegacy(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: BranchTCommons) extends InBoundTrait[BranchTCommons]
|
||||
|
||||
case class OutBoundCreateOrUpdateBank(bankId: String, fullBankName: String, shortBankName: String, logoURL: String, websiteURL: String, swiftBIC: String, national_identifier: String, bankRoutingScheme: String, bankRoutingAddress: String) extends TopicTrait
|
||||
case class InBoundCreateOrUpdateBank(status: Status, data: BankCommons) extends InBoundTrait[BankCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetAtmLegacy(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, atmId: AtmId) extends TopicTrait
|
||||
case class InBoundGetAtmLegacy(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: AtmTCommons) extends InBoundTrait[AtmTCommons]
|
||||
|
||||
case class OutBoundCreateOrUpdateProduct(bankId: String, code: String, parentProductCode: Option[String], name: String, category: String, family: String, superFamily: String, moreInfoUrl: String, termsAndConditionsUrl: String, details: String, description: String, metaLicenceId: String, metaLicenceName: String) extends TopicTrait
|
||||
case class InBoundCreateOrUpdateProduct(status: Status, data: ProductCommons) extends InBoundTrait[ProductCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundCreateOrUpdateFXRate(bankId: String, fromCurrencyCode: String, toCurrencyCode: String, conversionValue: Double, inverseConversionValue: Double, effectiveDate: Date) extends TopicTrait
|
||||
case class InBoundCreateOrUpdateFXRate(status: Status, data: FXRateCommons) extends InBoundTrait[FXRateCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetBranchLegacy(bankId: BankId, branchId: BranchId) extends TopicTrait
|
||||
case class InBoundGetBranchLegacy(status: Status, data: BranchTCommons) extends InBoundTrait[BranchTCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetAtmLegacy(bankId: BankId, atmId: AtmId) extends TopicTrait
|
||||
case class InBoundGetAtmLegacy(status: Status, data: AtmTCommons) extends InBoundTrait[AtmTCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetCurrentFxRate(bankId: BankId, fromCurrencyCode: String, toCurrencyCode: String) extends TopicTrait
|
||||
case class InBoundGetCurrentFxRate(status: Status, data: FXRateCommons) extends InBoundTrait[FXRateCommons] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
|
||||
case class OutBoundGetTransactionRequestTypeCharges(bankId: BankId, accountId: AccountId, viewId: ViewId, transactionRequestTypes: List[TransactionRequestType]) extends TopicTrait
|
||||
case class InBoundGetTransactionRequestTypeCharges(status: Status, data: List[TransactionRequestTypeChargeCommons]) extends InBoundTrait[List[TransactionRequestTypeChargeCommons]] {
|
||||
override val inboundAdapterCallContext: InboundAdapterCallContext = InboundAdapterCallContext()
|
||||
}
|
||||
case class OutBoundGetTransactionRequestTypeCharges(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, accountId: AccountId, viewId: ViewId, transactionRequestTypes: List[TransactionRequestType]) extends TopicTrait
|
||||
case class InBoundGetTransactionRequestTypeCharges(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[TransactionRequestTypeChargeCommons]) extends InBoundTrait[List[TransactionRequestTypeChargeCommons]]
|
||||
|
||||
case class OutBoundGetCustomersByCustomerPhoneNumber(outboundAdapterCallContext: OutboundAdapterCallContext, bankId: BankId, phoneNumber: String) extends TopicTrait
|
||||
case class InBoundGetCustomersByCustomerPhoneNumber(inboundAdapterCallContext: InboundAdapterCallContext, status: Status, data: List[CustomerCommons]) extends InBoundTrait[List[CustomerCommons]]
|
||||
|
||||
Loading…
Reference in New Issue
Block a user