Revision d818f53c src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala
| b/src/main/scala/gr/grnet/aquarium/actor/service/user/UserActor.scala | ||
|---|---|---|
| 41 | 41 |
import gr.grnet.aquarium.user._ |
| 42 | 42 |
|
| 43 | 43 |
import gr.grnet.aquarium.util.shortClassNameOf |
| 44 |
import gr.grnet.aquarium.actor.message.service.router._ |
|
| 45 | 44 |
import message.config.{ActorProviderConfigured, AquariumPropertiesLoaded}
|
| 46 | 45 |
import gr.grnet.aquarium.event.im.IMEventModel |
| 47 | 46 |
import akka.config.Supervision.Temporary |
| 48 |
import gr.grnet.aquarium.{AquariumInternalError, AquariumException, Configurator}
|
|
| 49 |
import gr.grnet.aquarium.util.date.{MutableDateCalc, TimeHelpers}
|
|
| 50 |
|
|
| 47 |
import gr.grnet.aquarium.Configurator |
|
| 48 |
import gr.grnet.aquarium.util.date.{TimeHelpers, MutableDateCalc}
|
|
| 49 |
import gr.grnet.aquarium.actor.message.event.{ProcessResourceEvent, ProcessIMEvent}
|
|
| 50 |
import gr.grnet.aquarium.actor.message.{GetUserStateResponse, GetUserBalanceResponse, GetUserStateRequest, GetUserBalanceRequest}
|
|
| 51 | 51 |
|
| 52 | 52 |
/** |
| 53 | 53 |
* |
| ... | ... | |
| 129 | 129 |
DEBUG("%s %s", if(isUpdate) "Update" else "Set", shortClassNameOf(this._imState))
|
| 130 | 130 |
} |
| 131 | 131 |
|
| 132 |
def onRequestUserBalance(event: RequestUserBalance): Unit = {
|
|
| 132 |
def onGetUserBalanceRequest(event: GetUserBalanceRequest): Unit = {
|
|
| 133 | 133 |
val userId = event.userID |
| 134 |
// FIXME: Implement threshold
|
|
| 135 |
self reply UserResponseGetBalance(userId, _userState.creditsSnapshot.creditAmount)
|
|
| 134 |
// FIXME: Implement |
|
| 135 |
self reply GetUserBalanceResponse(userId, Right(_userState.creditsSnapshot.creditAmount))
|
|
| 136 | 136 |
} |
| 137 | 137 |
|
| 138 |
def onUserRequestGetState(event: UserRequestGetState): Unit = {
|
|
| 138 |
def onGetUserStateRequest(event: GetUserStateRequest): Unit = {
|
|
| 139 | 139 |
val userId = event.userID |
| 140 |
// FIXME: implement
|
|
| 141 |
self reply UserResponseGetState(userId, this._userState)
|
|
| 140 |
// FIXME: Implement
|
|
| 141 |
self reply GetUserStateResponse(userId, Right(this._userState))
|
|
| 142 | 142 |
} |
| 143 | 143 |
|
| 144 | 144 |
def onProcessResourceEvent(event: ProcessResourceEvent): Unit = {
|
Also available in: Unified diff