-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
finos#1434 adding test for type ahead request at a view port level. D…
…ata is loaded into table at initialisation
- Loading branch information
Showing
7 changed files
with
167 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
54 changes: 54 additions & 0 deletions
54
vuu/src/main/scala/org/finos/vuu/core/module/typeahead/ViewPortTypeAheadRpcHandler.scala
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,54 @@ | ||
| package org.finos.vuu.core.module.typeahead | ||
|
|
||
| import com.typesafe.scalalogging.StrictLogging | ||
| import org.finos.vuu.core.table.{DataTable, TableContainer} | ||
| import org.finos.vuu.net.RequestContext | ||
| import org.finos.vuu.net.rpc.{DefaultRpcHandler, RpcMethodCallResult, RpcMethodSuccess, RpcParams} | ||
|
|
||
| class ViewPortTypeAheadRpcHandler(tableContainer: TableContainer) extends DefaultRpcHandler with StrictLogging { | ||
|
|
||
| this.registerRpc("getUniqueFieldValues", params => processGetUniqueFieldValuesRequest(params)) | ||
| this.registerRpc("getUniqueFieldValuesStartingWith", params => processGetUniqueFieldValuesStartWithRequest(params)) | ||
|
|
||
| def processGetUniqueFieldValuesRequest(params: RpcParams): RpcMethodCallResult = { | ||
| val values = getUniqueFieldValues( | ||
| params.namedParams("table").toString, //how to report error when expected param missing or fail to cast to right type | ||
| params.namedParams("module").toString, | ||
| params.namedParams("column").toString, | ||
| null //todo what to do about request context | ||
| ) | ||
| RpcMethodSuccess(values) | ||
| } | ||
|
|
||
| def processGetUniqueFieldValuesStartWithRequest(params: RpcParams): RpcMethodCallResult = { | ||
| val values = getUniqueFieldValuesStartingWith( | ||
| params.namedParams("table").toString, //how to report error when expected param missing or fail to cast to right type | ||
| params.namedParams("module").toString, | ||
| params.namedParams("column").toString, | ||
| params.namedParams("starts").toString, | ||
| null //todo what to do about request context | ||
| ) | ||
| RpcMethodSuccess(values) //how to control what viewport action to trigger? | ||
| } | ||
|
|
||
| def getUniqueFieldValues(tableName: String, moduleName: String, column: String, ctx: RequestContext): Array[String] = { | ||
| tableContainer.getTable(tableName) match { | ||
| case dataTable: DataTable => | ||
| val columValueProvider = dataTable.getColumnValueProvider | ||
| columValueProvider.getUniqueValues(column) | ||
| case null => | ||
| throw new Exception("Could not find table by name:" + tableName) | ||
| } | ||
| } | ||
|
|
||
| def getUniqueFieldValuesStartingWith(tableName: String, moduleName: String, column: String, starts: String, ctx: RequestContext): Array[String] = { | ||
| tableContainer.getTable(tableName) match { | ||
| case dataTable: DataTable => | ||
| val columValueProvider = dataTable.getColumnValueProvider | ||
| columValueProvider.getUniqueValuesStartingWith(column, starts) | ||
| case null => | ||
| throw new Exception("Could not find table by name:" + tableName) | ||
| } | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,39 @@ | ||
| package org.finos.vuu.net | ||
|
|
||
| import com.typesafe.scalalogging.StrictLogging | ||
| import org.finos.toolbox.time.Clock | ||
| import org.finos.vuu.core.table.{DataTable, RowWithData} | ||
| import org.finos.vuu.provider.Provider | ||
|
|
||
| class TestProvider(table: DataTable, fakeDataSource: FakeDataSource)(implicit clock: Clock) extends Provider with StrictLogging { | ||
|
|
||
| override def subscribe(key: String): Unit = {} | ||
|
|
||
| override def doStart(): Unit = { | ||
| logger.info(s"Test Provider for ${table.name}- Starting") | ||
| } | ||
|
|
||
| override def doStop(): Unit = { | ||
| logger.info(s"Test Provider for ${table.name}- Stopping") | ||
| } | ||
|
|
||
| override def doInitialize(): Unit = { | ||
| logger.info(s"Test Provider for ${table.name}- Initialising") | ||
| fakeDataSource.get() | ||
| .foreach(row => { | ||
| table.processUpdate(row._1, RowWithData(row._1, row._2), clock.now()) | ||
| }) | ||
| } | ||
|
|
||
| override def doDestroy(): Unit = {} | ||
|
|
||
| override val lifecycleId: String = s"TestProvider ${table.name}" | ||
| } | ||
| class FakeDataSource(rows: Map[String, Map[String, Any]]) { | ||
| type RowKey = String | ||
| type ColumnName = String | ||
|
|
||
| def get(): Map[RowKey, Map[ColumnName, Any]] = { | ||
| rows | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters