Skip to content

Commit 0bc1175

Browse files
naleehakeikeicheung
authored andcommitted
#1434 rename to none action to avoid clash with no action viewport action
1 parent 3e2506f commit 0bc1175

File tree

3 files changed

+52
-21
lines changed

3 files changed

+52
-21
lines changed

vuu/src/main/scala/org/finos/vuu/core/CoreServerApiHandler.scala

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -389,7 +389,6 @@ class CoreServerApiHandler(val viewPortContainer: ViewPortContainer,
389389
}
390390
}
391391

392-
393392
override def process(msg: RemoveVisualLinkRequest)(ctx: RequestContext): Option[ViewServerMessage] = {
394393
Try(viewPortContainer.unlinkViewPorts(ctx.session, ctx.queue, msg.childVpId)) match {
395394
case Success(_) =>
@@ -410,15 +409,14 @@ class CoreServerApiHandler(val viewPortContainer: ViewPortContainer,
410409
vsMsg(CloseTreeNodeSuccess(msg.vpId, msg.treeKey))(ctx)
411410
}
412411

413-
414412
override def process(msg: RpcRequest)(ctx: RequestContext): Option[ViewServerMessage] = {
415413
val response = Try(viewPortContainer.handleRpcRequest(msg.context.viewPortId, msg.rpcName, msg.params)(ctx)) match {
416414
case Success(functionResult) =>
417415
logger.info(s"Processed VP RPC call ${ctx.requestId}" + msg)
418416
functionResult match {
419417
case RpcFunctionSuccess(data) =>
420-
RpcResponseNew(rpcName = msg.rpcName, result = RpcResult(isSuccess = true, data, null), null)
421-
case RpcFunctionFailure(_, error, exception) =>
418+
RpcResponseNew(rpcName = msg.rpcName, result = RpcResult.fromSuccess(data), NoneAction())
419+
case RpcFunctionFailure(errorCode, error, exception) =>
422420
createErrorRpcResponse(msg, error)
423421
}
424422
case Failure(e) =>
@@ -431,7 +429,7 @@ class CoreServerApiHandler(val viewPortContainer: ViewPortContainer,
431429
private def createErrorRpcResponse(msg: RpcRequest, errorMessage: String) = {
432430
RpcResponseNew(
433431
rpcName = msg.rpcName,
434-
result = RpcResult(isSuccess = false, null, errorMessage = errorMessage),
435-
action = ShowNotificationAction("Error", s"Failed to process ${msg.rpcName} request", errorMessage))
432+
result = RpcResult.fromError(errorMessage),
433+
action = ShowNotificationAction(NotificationType.Error, s"Failed to process ${msg.rpcName} request", errorMessage))
436434
}
437435
}

vuu/src/main/scala/org/finos/vuu/net/Messages.scala

Lines changed: 45 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,7 @@ case class ChangeViewPortRangeSuccess(viewPortId: String, from: Int, to: Int) ex
115115
case class OpenTreeNodeRequest(vpId: String, treeKey: String) extends MessageBody
116116

117117
case class ViewPortRpcCall(vpId: String, rpcName: String, params: Array[Any], namedParams: Map[String, Any]) extends MessageBody
118+
118119
case class ViewPortRpcResponse(vpId: String, method: String, action: ViewPortAction) extends MessageBody
119120

120121

@@ -131,12 +132,17 @@ case class ViewPortMenuRpcResponse(vpId: String, rpcName: String, action: ViewPo
131132
case class ViewPortMenuRpcReject(vpId: String, rpcName: String, error: String) extends MessageBody
132133

133134
case class ViewPortEditRowRpcCall(vpId: String, rowKey: String, data: Map[String, Object]) extends MessageBody
135+
134136
case class ViewPortEditCellRpcCall(vpId: String, rowKey: String, field: String, value: Object) extends MessageBody
137+
135138
case class ViewPortEditSubmitFormRpcCall(vpId: String) extends MessageBody
136139

137140
case class ViewPortEditCloseFormRpcCall(vpId: String, field: String, value: Object) extends MessageBody
141+
138142
case class ViewPortAddRowRpcCall(vpId: String, rowKey: String, data: Map[String, Any]) extends MessageBody
139-
case class ViewPortDeleteCellRpcCall(vpId: String, rowKey: String, field: String) extends MessageBody{}
143+
144+
case class ViewPortDeleteCellRpcCall(vpId: String, rowKey: String, field: String) extends MessageBody {}
145+
140146
case class ViewPortDeleteRowRpcCall(vpId: String, rowKey: String) extends MessageBody
141147

142148

@@ -145,7 +151,6 @@ case class ViewPortEditRpcResponse(vpId: String, rpcName: String, action: ViewPo
145151
case class ViewPortEditRpcReject(vpId: String, rpcName: String, error: String) extends MessageBody
146152

147153

148-
149154
case class CloseTreeNodeRequest(vpId: String, treeKey: String) extends MessageBody
150155

151156
case class CloseTreeNodeSuccess(vpId: String, treeKey: String) extends MessageBody
@@ -212,27 +217,52 @@ case class RowUpdate(vpVersion: String, viewPortId: String, vpSize: Int, rowInde
212217
case class RpcRequest(context: RpcContext, rpcName: String, params: Any) extends MessageBody
213218
case class RpcContext(viewPortId: String)
214219

220+
//case class RpcContext(viewPortId: String, rowKey: String)
221+
//object RpcContext {
222+
// def forViewPort(viewPortId: String) = RpcContext(viewPortId)
223+
// def forViewPortRow(viewPortId: String, rowKey: String) = RpcContext(viewPortId)
224+
//}
225+
//@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type")
226+
//@JsonSubTypes(Array(
227+
// new Type(value = classOf[GlobalContext], name = "GLOBAL_CONTEXT"),
228+
// new Type(value = classOf[ViewPortContext], name = "VIEWPORT_CONTEXT"),
229+
// new Type(value = classOf[ViewPortRowContext], name = "VIEWPORT_ROW_CONTEXT"),
230+
//))
231+
//trait RpcContext
232+
//case class GlobalContext() extends RpcContext
233+
//case class ViewPortContext(viewPortId: String) extends RpcContext
234+
//case class ViewPortRowContext(viewPortId: String, rowKey: String) extends RpcContext
235+
215236
case class RpcResponseNew(rpcName: String, result: RpcResult, action: UIAction) extends MessageBody
216237
case class RpcResult(isSuccess: Boolean, data: Any, errorMessage: String)
217238

239+
object RpcResult {
240+
def fromError(errorMessage: String): RpcResult = RpcResult(isSuccess = false, data = null, errorMessage = errorMessage)
241+
def fromSuccess(data: Any): RpcResult = RpcResult(isSuccess = true, data = data, errorMessage = null)
242+
}
218243

219-
//trait RpcResult {
220-
// val isSuccess: Boolean // todo use status enums? does that work with java
221-
//}
222-
//
223-
//case class RpcSuccessResult(data: Any) extends RpcResult {
224-
// override val isSuccess: Boolean = true
225-
//}
226-
//case class RpcErrorResult(errorMessage: String) extends RpcResult {
227-
// override val isSuccess: Boolean = false
228-
//}
244+
//@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type")
245+
//@JsonSubTypes(Array(
246+
// new Type(value = classOf[RpcSuccessResult], name = "SUCCESS_RESULT"),
247+
// new Type(value = classOf[RpcErrorResult], name = "ERROR_RESULT"),
248+
//))
249+
//trait RpcResult
250+
//case class RpcSuccessResult(data: Any) extends RpcResult
251+
//case class RpcErrorResult(errorMessage: String) extends RpcResult
229252

230253
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type")
231254
@JsonSubTypes(Array(
232-
new Type(value = classOf[NoAction], name = "NO_ACTION"),
255+
new Type(value = classOf[NoneAction], name = "NO_ACTION"),
233256
new Type(value = classOf[ShowNotificationAction], name = "SHOW_NOTIFICATION_ACTION"),
234257
))
235258
trait UIAction
236259

237-
case class NoAction() extends UIAction
238-
case class ShowNotificationAction(notificationType: String, title: String, message: String) extends UIAction
260+
case class NoneAction() extends UIAction
261+
262+
case class ShowNotificationAction(notificationType: String, title: String, message: String) extends UIAction
263+
264+
object NotificationType {
265+
final val Error = "Error"
266+
final val Warning = "Warning"
267+
final val Info = "Info"
268+
}

vuu/src/test/scala/org/finos/vuu/wsapi/TypeAheadWSApiTest.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,9 @@ class TypeAheadWSApiTest extends WebSocketApiTestBase {
3737

3838
responseBody.result.isSuccess shouldEqual true
3939
responseBody.result.data shouldEqual List("12355", "45321", "89564", "42262", "65879", "88875", "45897", "23564", "33657", "99854")
40+
41+
And("return No Action")
42+
responseBody.action shouldBe a[NoneAction]
4043
}
4144

4245
Scenario("Start with a specified string for a column") {

0 commit comments

Comments
 (0)