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

Added some very basic logging

Browse Source
This commit is contained in:
Everett Sochowski 2012-03-07 12:56:13 +01:00
parent 71a0b84ea2
commit 183f2fbe33
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
MavLift/src/main/scala/code/actors/EnvelopeInserter.scala
View File

@ -4,8 +4,10 @@ import net.liftweb.actor.LiftActor
import code.model.OBPEnvelope
import net.liftweb.json.JObject
import com.mongodb.QueryBuilder
import net.liftweb.common.Loggable
import net.liftweb.util.Helpers
object EnvelopeInserter extends LiftActor{
object EnvelopeInserter extends LiftActor with Loggable{
/**
* Determines whether two obp envelopes are considered "identical"
@ -38,17 +40,26 @@ object EnvelopeInserter extends LiftActor{
if(identicalEnvelopes.size == 0){
Nil
}else{
//we don't want to be putting people's transaction info in the logs, so we use an id
val insertID = Helpers.randomString(10)
logger.info("Starting insert operation, id: " + insertID)
val toMatch = identicalEnvelopes(0)
val qry = QueryBuilder.start("obp_transaction.details.value.amount").is(toMatch.obp_transaction.get.details.get.value.get.amount.get.toString)
.put("obp_transaction.other_account.holder").is(toMatch.obp_transaction.get.other_account.get.holder.get).get
//TODO: Figure out how to add date queries to the query builder, OR, preferably, use Rogue
val partialMatches = OBPEnvelope.findAll(qry)
logger.info("Insert operation id " + insertID + " # of partial matches: " + partialMatches.size)
val matches = partialMatches.filter(e =>{
e.obp_transaction.get.details.get.completed.get.equals(toMatch.obp_transaction.get.details.get.completed.get)
})
logger.info("Insert operation id " + insertID + " # of full matches: " + matches.size)
val copiesToInsert = identicalEnvelopes drop matches.size
logger.info("Insert operation id " + insertID + " copies being inserted: " + copiesToInsert.size)
copiesToInsert.map(e => {
val record = e.saveTheRecord()
record.get.asMediatedJValue("authorities") //authorities view gives the most information. TODO: This obviously needs to be reworked

5
MavLift/src/main/scala/code/snippet/OBPREST.scala
View File

@ -70,7 +70,7 @@ import code.actors.EnvelopeInserter
// See http://www.assembla.com/spaces/liftweb/wiki/REST_Web_Services
object OBPRest extends RestHelper {
object OBPRest extends RestHelper with Loggable {
println("here we are in OBPRest")
serve {
@ -129,6 +129,9 @@ object OBPRest extends RestHelper {
OBPEnvelope.fromJValue(e)
})
logger.info("Received " + rawEnvelopes.size + " json transactions to insert")
logger.info("Received " + envelopes.size + " valid transactions to insert")
/**
* Using an actor to do insertions avoids concurrency issues with duplicate transactions
* by processing transaction batches one at a time. We'll have to monitor this to see if