mirror of
https://github.com/OpenBankProject/OBP-API.git
synced 2026-02-06 14:06:56 +00:00
157 lines
7.0 KiB
Scala
157 lines
7.0 KiB
Scala
package code.remotedata
|
|
|
|
import akka.actor.Actor
|
|
import code.actorsystem.ObpActorHelper
|
|
import code.views.{MapperViews, RemotedataViewsCaseClasses}
|
|
import code.model._
|
|
import code.util.Helper.MdcLoggable
|
|
import net.liftweb.common._
|
|
|
|
class RemotedataViewsActor extends Actor with ObpActorHelper with MdcLoggable {
|
|
|
|
val mapper = MapperViews
|
|
val cc = RemotedataViewsCaseClasses
|
|
|
|
def receive = {
|
|
|
|
case cc.addPermissions(views : List[ViewUID], user : User) =>
|
|
logger.debug("addPermissions(" + views +"," + user +")")
|
|
sender ! extractResult(mapper.addPermissions(views, user))
|
|
|
|
case cc.addPermission(viewUID : ViewUID, user : User) =>
|
|
logger.debug("addPermission(" + viewUID +"," + user +")")
|
|
sender ! extractResult(mapper.addPermission(viewUID, user))
|
|
|
|
case cc.permission(account : BankAccountUID, user: User) =>
|
|
logger.debug("permission(" + account +"," + user +")")
|
|
sender ! extractResult(mapper.permission(account, user))
|
|
|
|
case cc.revokePermission(viewUID : ViewUID, user : User) =>
|
|
logger.debug("revokePermission(" + viewUID +"," + user +")")
|
|
sender ! extractResult(mapper.revokePermission(viewUID, user))
|
|
|
|
case cc.revokeAllPermissions(bankId : BankId, accountId : AccountId, user : User) =>
|
|
logger.debug("revokeAllPermissions(" + bankId +"," + accountId +","+ user +")")
|
|
sender ! extractResult(mapper.revokeAllPermissions(bankId, accountId, user))
|
|
|
|
case cc.view(viewUID : ViewUID) =>
|
|
logger.debug("view(" + viewUID +")")
|
|
sender ! extractResult(mapper.view(viewUID))
|
|
|
|
case cc.view(viewId: ViewId, bankAccountId: BankAccountUID) =>
|
|
logger.debug("view(" + viewId +", "+ bankAccountId + ")")
|
|
sender ! extractResult(mapper.view(viewId, bankAccountId))
|
|
|
|
case cc.createView(bankAccountId : BankAccountUID, view: CreateViewJson) =>
|
|
logger.debug("createView(" + bankAccountId +","+ view +")")
|
|
sender ! extractResult(mapper.createView(bankAccountId, view))
|
|
|
|
case cc.updateView(bankAccountId : BankAccountUID, viewId : ViewId, viewUpdateJson : UpdateViewJSON) =>
|
|
logger.debug("updateView(" + bankAccountId +","+ viewId +","+ viewUpdateJson +")")
|
|
sender ! extractResult(mapper.updateView(bankAccountId, viewId, viewUpdateJson))
|
|
|
|
case cc.removeView(viewId : ViewId, bankAccountId: BankAccountUID) =>
|
|
logger.debug("removeView(" + viewId +","+ bankAccountId +")")
|
|
sender ! extractResult(mapper.removeView(viewId, bankAccountId))
|
|
|
|
case cc.permissions(bankAccountId : BankAccountUID) =>
|
|
logger.debug("premissions(" + bankAccountId +")")
|
|
sender ! extractResult(mapper.permissions(bankAccountId))
|
|
|
|
case cc.views(bankAccountId : BankAccountUID) =>
|
|
logger.debug("views(" + bankAccountId +")")
|
|
sender ! extractResult(mapper.views(bankAccountId))
|
|
|
|
case cc.permittedViews(user: User, bankAccountId: BankAccountUID) =>
|
|
logger.debug("permittedViews(" + user +", " + bankAccountId +")")
|
|
sender ! extractResult(mapper.permittedViews(user, bankAccountId))
|
|
|
|
case cc.publicViews(bankAccountId : BankAccountUID) =>
|
|
logger.debug("publicViews(" + bankAccountId +")")
|
|
sender ! extractResult(mapper.publicViews(bankAccountId))
|
|
|
|
case cc.getAllPublicAccounts() =>
|
|
logger.debug("getAllPublicAccounts()")
|
|
sender ! extractResult(mapper.getAllPublicAccounts)
|
|
|
|
case cc.getPublicBankAccounts(bank : Bank) =>
|
|
logger.debug("getPublicBankAccounts(" + bank +")")
|
|
sender ! extractResult(mapper.getPublicBankAccounts(bank))
|
|
|
|
case cc.getAllAccountsUserCanSee(user : Box[User]) =>
|
|
logger.debug("getAllAccountsUserCanSee(" + user +")")
|
|
sender ! extractResult(mapper.getAllAccountsUserCanSee(user))
|
|
|
|
case cc.getAllAccountsUserCanSee(user : User) =>
|
|
logger.debug("getAllAccountsUserCanSee(" + user +")")
|
|
sender ! extractResult(mapper.getAllAccountsUserCanSee(Full(user)))
|
|
|
|
case cc.getAllAccountsUserCanSee(bank: Bank, user : Box[User]) =>
|
|
logger.debug("getAllAccountsUserCanSee(" + bank +", "+ user +")")
|
|
sender ! extractResult(mapper.getAllAccountsUserCanSee(bank, user))
|
|
|
|
case cc.getAllAccountsUserCanSee(bank: Bank, user : User) =>
|
|
logger.debug("getAllAccountsUserCanSee(" + bank +", "+ user +")")
|
|
sender ! extractResult(mapper.getAllAccountsUserCanSee(bank, Full(user)))
|
|
|
|
case cc.getNonPublicBankAccounts(user: User, bankId: BankId) =>
|
|
logger.debug("getNonPublicBankAccounts(" + user +", "+ bankId +")")
|
|
sender ! extractResult(mapper.getNonPublicBankAccounts(user, bankId))
|
|
|
|
case cc.getNonPublicBankAccounts(user: User) =>
|
|
logger.debug("getNonPublicBankAccounts(" + user +")")
|
|
sender ! extractResult(mapper.getNonPublicBankAccounts(user))
|
|
|
|
case cc.createOwnerView(bankId, accountId, description) =>
|
|
logger.info("createOwnerView(" + bankId +", "+ accountId +", "+ description +")")
|
|
val res = extractResult(mapper.createOwnerView(bankId, accountId, description))
|
|
println("------------------------------------> res=" + res)
|
|
sender ! res.asInstanceOf[code.model.View]
|
|
|
|
case cc.createPublicView(bankId, accountId, description) =>
|
|
logger.debug("createPublicView(" + bankId +", "+ accountId +", "+ description +")")
|
|
sender ! extractResult(mapper.createPublicView(bankId, accountId, description))
|
|
|
|
case cc.createAccountantsView(bankId, accountId, description) =>
|
|
logger.debug("createAccountantsView(" + bankId +", "+ accountId +", "+ description +")")
|
|
sender ! extractResult(mapper.createAccountantsView(bankId, accountId, description))
|
|
|
|
case cc.createAuditorsView(bankId, accountId, description) =>
|
|
logger.debug("createAuditorsView(" + bankId +", "+ accountId +", "+ description +")")
|
|
sender ! extractResult(mapper.createAuditorsView(bankId, accountId, description))
|
|
|
|
case cc.createRandomView(bankId, accountId) =>
|
|
logger.debug("createRandomView(" + bankId +", "+ accountId +")")
|
|
sender ! extractResult(mapper.createRandomView(bankId, accountId))
|
|
|
|
case cc.getOwners(view) =>
|
|
logger.debug("getOwners(" + view +")")
|
|
sender ! extractResult(mapper.getOwners(view))
|
|
|
|
case cc.grantAccessToView(user, view) =>
|
|
logger.debug("grantAccessToView(" + user +", "+ view +")")
|
|
sender ! extractResult(mapper.grantAccessToView(user, view))
|
|
|
|
case cc.grantAccessToAllExistingViews(user) =>
|
|
logger.debug("grantAccessToAllExistingViews(" + user +")")
|
|
sender ! extractResult(mapper.grantAccessToAllExistingViews(user))
|
|
|
|
case cc.removeAllPermissions(bankId, accountId) =>
|
|
logger.debug("removeAllPermissions(" + bankId +", "+ accountId +")")
|
|
sender ! extractResult(mapper.removeAllPermissions(bankId, accountId))
|
|
|
|
case cc.removeAllViews(bankId, accountId) =>
|
|
logger.debug("removeAllViews(" + bankId +", "+ accountId +")")
|
|
sender ! extractResult(mapper.removeAllViews(bankId, accountId))
|
|
|
|
case cc.bulkDeleteAllPermissionsAndViews() =>
|
|
logger.debug("bulkDeleteAllPermissionsAndViews()")
|
|
sender ! extractResult(mapper.bulkDeleteAllPermissionsAndViews())
|
|
|
|
case message => logger.warn("[AKKA ACTOR ERROR - REQUEST NOT RECOGNIZED] " + message)
|
|
|
|
}
|
|
|
|
}
|
|
|