added test to GetShardStatsController

app/controllers/GetShardStats.scala → app/controllers/GetShardStatsController.scala

@@ -4,13 +4,15 @@ import models.ShardStats
 
 import scala.concurrent.ExecutionContext.Implicits.global
 
-class GetShardStats extends BaseController {
+class GetShardStatsController extends BaseController {
 
   def processRequest = (request, client) => {
-    client.getShardStats(request.get("index"), request.host).zip(client.getIndexRecovery(request.get("index"), request.host)).map {
+    val index = request.get("index")
+    val shard = request.getInt("shard")
+    val node = request.get("node")
+    client.getShardStats(index, request.host).zip(client.getIndexRecovery(index, request.host)).map {
       case (stats, recovery) =>
-        val shardStats = ShardStats(request.get("index"), request.get("node"), request.getInt("shard"), stats.body, recovery.body)
-        Status(200)(shardStats)
+        Status(200)(ShardStats(index, node, shard, stats.body, recovery.body))
     }
   }
 

conf/routes

@@ -21,7 +21,7 @@ POST       /apis/update_cluster_settings     @controllers.PutClusterSettings.exe
 POST       /apis/get_node_stats              @controllers.NodeStatsController.execute
 POST       /apis/disable_shard_allocation    @controllers.DisableShardAllocationController.execute
 POST       /apis/enable_shard_allocation     @controllers.EnableShardAllocationController.execute
-POST       /apis/get_shard_stats             @controllers.GetShardStats.execute
+POST       /apis/get_shard_stats             @controllers.GetShardStatsController.execute
 
 GET        /apis/hosts                       @controllers.HostsController.index