add freeze and unfreeze view port messages

Author: tanjjj

vuu/src/main/scala/org/finos/vuu/client/ClientHelperFns.scala

@@ -66,6 +66,14 @@ object ClientHelperFns {
     vsClient.send(JsonViewServerMessage(requestId, sessionId, token, user, DisableViewPortRequest(vpId)))
   }
 
+  def freezeViewPort(sessionId: String, token: String, user: String, requestId: String, vpId: String)(implicit vsClient: ViewServerClient): Unit = {
+    vsClient.send(JsonViewServerMessage(requestId, sessionId, token, user, FreezeViewPortRequest(vpId)))
+  }
+
+  def unfreezeViewPort(sessionId: String, token: String, user: String, requestId: String, vpId: String)(implicit vsClient: ViewServerClient): Unit = {
+    vsClient.send(JsonViewServerMessage(requestId, sessionId, token, user, UnfreezeViewPortRequest(vpId)))
+  }
+
   def closeTreeNodeAsync(sessionId: String, token: String, user: String, requestId: String, vpId: String, treeKey: String)(implicit vsClient: ViewServerClient): Unit = {
     vsClient.send(JsonViewServerMessage(requestId, sessionId, token, user, CloseTreeNodeRequest(vpId, treeKey)))
   }
@@ -79,7 +87,7 @@ object ClientHelperFns {
   }
 
   def rpcTableUpdate(sessionId: String, token: String, user: String, table: ViewPortTable, key: String, data: Map[String, Any])(implicit vsClient: ViewServerClient): Unit = {
-    vsClient.send(JsonViewServerMessage(RequestId.oneNew().toString, sessionId, token, user, RpcUpdate(table, key, data)))
+    vsClient.send(JsonViewServerMessage(RequestId.oneNew(), sessionId, token, user, RpcUpdate(table, key, data)))
   }
 
   def getViewPortMenusAsync(sessionId: String, token: String, user: String, vpId: String)(implicit vsClient: ViewServerClient): Unit = {

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

@@ -170,6 +170,28 @@ class CoreServerApiHandler(val viewPortContainer: ViewPortContainer,
     }
   }
 
+  override def process(msg: FreezeViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage] = {
+    Try(viewPortContainer.freezeViewPort(msg.viewPortId)) match {
+      case Success(_) =>
+        logger.debug("View port froze")
+        vsMsg(FreezeViewPortSuccess(msg.viewPortId))(ctx)
+      case Failure(e) =>
+        logger.warn("Failed to freeze viewport", e)
+        vsMsg(FreezeViewPortReject(msg.viewPortId))(ctx)
+    }
+  }
+
+  override def process(msg: UnfreezeViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage] = {
+    Try(viewPortContainer.unfreezeViewPort(msg.viewPortId)) match {
+      case Success(_) =>
+        logger.debug("View port unfroze")
+        vsMsg(UnfreezeViewPortSuccess(msg.viewPortId))(ctx)
+      case Failure(e) =>
+        logger.warn("Failed to unfreeze viewport", e)
+        vsMsg(UnfreezeViewPortReject(msg.viewPortId))(ctx)
+    }
+  }
+
   def vsMsg(body: MessageBody)(ctx: RequestContext): Option[JsonViewServerMessage] = {
     Some(VsMsg(ctx.requestId, ctx.session.sessionId, ctx.token, ctx.session.user, body))
   }

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

@@ -145,6 +145,8 @@ class DefaultMessageHandler(val channel: Channel,
       case req: RemoveViewPortRequest => serverApi.process(req)(ctx)
       case req: EnableViewPortRequest => serverApi.process(req)(ctx)
       case req: DisableViewPortRequest => serverApi.process(req)(ctx)
+      case req: FreezeViewPortRequest => serverApi.process(req)(ctx)
+      case req: UnfreezeViewPortRequest => serverApi.process(req)(ctx)
       case req: GetViewPortMenusRequest => serverApi.process(req)(ctx)
       case req: ViewPortMenuSelectionRpcCall => serverApi.process(req)(ctx)
       case req: ViewPortMenuRowRpcCall => serverApi.process(req)(ctx)

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

@@ -102,6 +102,18 @@ case class EnableViewPortSuccess(viewPortId: String) extends MessageBody
 
 case class EnableViewPortReject(viewPortId: String) extends MessageBody
 
+case class FreezeViewPortRequest(viewPortId: String) extends MessageBody
+
+case class FreezeViewPortSuccess(viewPortId: String) extends MessageBody
+
+case class FreezeViewPortReject(viewPortId: String) extends MessageBody
+
+case class UnfreezeViewPortRequest(viewPortId: String) extends MessageBody
+
+case class UnfreezeViewPortSuccess(viewPortId: String) extends MessageBody
+
+case class UnfreezeViewPortReject(viewPortId: String) extends MessageBody
+
 case class ChangeViewPortRequest(viewPortId: String, columns: Array[String], sort: SortSpec = SortSpec(List()), groupBy: Array[String] = Array(), filterSpec: FilterSpec = null, aggregations: Array[Aggregations] = Array()) extends MessageBody
 
 case class ChangeViewPortSuccess(viewPortId: String, columns: Array[String], sort: SortSpec = SortSpec(List()), groupBy: Array[String] = Array(), filterSpec: FilterSpec = null, aggregations: Array[Aggregations] = Array()) extends MessageBody

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

@@ -7,6 +7,10 @@ trait ServerApi {
 
   def process(msg: EnableViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage]
 
+  def process(msg: FreezeViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage]
+
+  def process(msg: UnfreezeViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage]
+
   def process(msg: ChangeViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage]
 
   def process(msg: CreateViewPortRequest)(ctx: RequestContext): Option[ViewServerMessage]

vuu/src/main/scala/org/finos/vuu/net/json/CoreJsonSerializationMixin.scala

@@ -17,6 +17,12 @@ import org.finos.vuu.net._
   new Type(value = classOf[EnableViewPortRequest], name = "ENABLE_VP"),
   new Type(value = classOf[EnableViewPortSuccess], name = "ENABLE_VP_SUCCESS"),
   new Type(value = classOf[EnableViewPortReject], name = "ENABLE_VP_REJECT"),
+  new Type(value = classOf[FreezeViewPortRequest], name = "FREEZE_VP"),
+  new Type(value = classOf[FreezeViewPortSuccess], name = "FREEZE_VP_SUCCESS"),
+  new Type(value = classOf[FreezeViewPortReject], name = "FREEZE_VP_REJECT"),
+  new Type(value = classOf[UnfreezeViewPortRequest], name = "UNFREEZE_VP"),
+  new Type(value = classOf[UnfreezeViewPortSuccess], name = "UNFREEZE_VP_SUCCESS"),
+  new Type(value = classOf[UnfreezeViewPortReject], name = "UNFREEZE_VP_REJECT"),
   new Type(value = classOf[RemoveViewPortRequest], name = "REMOVE_VP"),
   new Type(value = classOf[RemoveViewPortSuccess], name = "REMOVE_VP_SUCCESS"),
   new Type(value = classOf[RemoveViewPortReject], name = "REMOVE_VP_REJECT"),

vuu/src/main/scala/org/finos/vuu/viewport/ViewPort.scala

@@ -72,6 +72,10 @@ trait ViewPort {
 
   def setEnabled(enabled: Boolean): Unit
 
+  def freeze(): Unit
+
+  def unfreeze(): Unit
+
   def isEnabled: Boolean
 
   def hasGroupBy: Boolean = getGroupBy != NoGroupBy
@@ -203,6 +207,14 @@ class ViewPortImpl(val id: String,
 
   override def isEnabled: Boolean = this.enabled
 
+  override def freeze(): Unit = {
+
+  }
+
+  override def unfreeze(): Unit = {
+
+  }
+
   @volatile
   private var viewPortVisualLink: Option[ViewPortVisualLink] = None
 

vuu/src/main/scala/org/finos/vuu/viewport/ViewPortContainer.scala

@@ -317,6 +317,26 @@ class ViewPortContainer(val tableContainer: TableContainer, val providerContaine
     }
   }
 
+  def freezeViewPort(vpId: String): Unit = {
+    this.viewPorts.get(vpId) match {
+      case null =>
+        logger.error(s"Could not find viewport to freeze $vpId")
+      case vp: ViewPort =>
+        vp.freeze()
+        logger.debug(s"Froze $vpId in container")
+    }
+  }
+
+  def unfreezeViewPort(vpId: String): Unit = {
+    this.viewPorts.get(vpId) match {
+      case null =>
+        logger.error(s"Could not find viewport to unfreeze $vpId")
+      case vp: ViewPort =>
+        vp.unfreeze()
+        logger.debug(s"Unfroze $vpId in container")
+    }
+  }
+
   override def openGroupByKey(vpId: String, treeKey: String): String = {
     Try(this.openNode(vpId, treeKey)) match {
       case Success(_) => "Done"