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

Merge pull request #125 from marko-md/develop

Browse Source 
Closes #120 - Create KafkaOutBoundTransaciton case class instead of Map
This commit is contained in:
Simon Redfern 2016-08-05 16:46:46 +02:00 committed by GitHub
commit b54947c9db
1 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/scala/code/bankconnectors/KafkaMappedConnector.scala
View File

@ -24,6 +24,7 @@ import net.liftweb.json
import net.liftweb.mapper._
import net.liftweb.util.Helpers._
import net.liftweb.util.Props
import net.liftweb.json._
object KafkaMappedConnector extends Connector with CreateViewImpls with Loggable {
@ -444,16 +445,18 @@ object KafkaMappedConnector extends Connector with CreateViewImpls with Loggable
val reqId: String = UUID.randomUUID().toString
// Create argument list with reqId
// in order to fetch corresponding response
val argList = Map("username" -> OBPUser.getCurrentUserUsername,
"accountId" -> account.accountId.value,
"currency" -> currency,
"amount" -> amt.toString,
"otherAccountId" -> counterparty.accountId.value,
"otherAccountCurrency" -> counterparty.currency,
"transactionType" -> "AC")
val argObj = KafkaOutboundTransaction(username = OBPUser.getCurrentUserUsername,
accountId = account.accountId.value,
currency = currency,
amount = amt.toString,
otherAccountId = counterparty.accountId.value,
otherAccountCurrency = counterparty.currency,
transactionType = "AC")
// Since result is single account, we need only first list entry
implicit val formats = net.liftweb.json.DefaultFormats
val r = process(reqId, "saveTransaction", argList) //.extract[KafkaInboundTransactionId]
val argMap = Extraction.decompose(argObj).values
val r = process(reqId, "saveTransaction", argMap.asInstanceOf[Map[String,String]]) //.extract[KafkaInboundTransactionId]
r.extract[KafkaInboundTransactionId] match {
case r: KafkaInboundTransactionId => Full(TransactionId(r.transactionId))
@ -1097,6 +1100,12 @@ object KafkaMappedConnector extends Connector with CreateViewImpls with Loggable
case class KafkaInboundTransactionId(
transactionId : String
)
case class KafkaOutboundTransaction(username: String,
accountId: String,
currency: String,
amount: String,
otherAccountId: String,
otherAccountCurrency: String,
transactionType: String)
}