Skip to content

Commit 30c660d

Browse files
committed
Code cleanup and commenting
1 parent 70c9b79 commit 30c660d

File tree

2 files changed

+22
-7
lines changed

2 files changed

+22
-7
lines changed

app/authorization/AuthProvider.scala

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,10 @@
1616
package authorization
1717

1818

19-
import afu.org.checkerframework.checker.units.qual.A
19+
2020
import pdi.jwt.{Jwt, JwtAlgorithm, JwtClaim}
2121
import play.api.Configuration
22-
import javax.inject.Inject
23-
import play.api.libs.json.Json
24-
import play.api.mvc._
25-
import scala.concurrent.{Future, ExecutionContext}
22+
2623

2724

2825
object AuthProvider {
@@ -50,6 +47,12 @@ import scala.concurrent.{Future, ExecutionContext}
5047
Token
5148
}
5249

50+
/**
51+
* This method receives a token and validates if it is valid
52+
* @param token
53+
* @param configuration
54+
* @return
55+
*/
5356

5457
def validateJwt(token: String)(implicit configuration: Configuration): Boolean = {
5558
val jwtSecretKey = configuration.get[String]("play.http.secret.JWTkey")

app/controllers/InstanceRegistryController.scala

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,7 @@ import akka.stream.Materializer
2727
import play.api.libs.streams.ActorFlow
2828
import actors.{ClientSocketActor, PublishSocketMessageActor}
2929
import play.api.mvc._
30-
import pdi.jwt.Jwt
31-
import scala.concurrent.{ExecutionContext, Future}
30+
import scala.concurrent.ExecutionContext
3231
import authorization.AuthProvider
3332
import authorization.AuthAction
3433
import play.api.libs.json.Json
@@ -149,6 +148,13 @@ class InstanceRegistryController @Inject()(implicit system: ActorSystem, mat: Ma
149148
}(myExecutionContext)
150149
}
151150

151+
/**
152+
* This method is called to assign a new instance to the instance with specified ID.
153+
* @param from
154+
* @param to
155+
* @return
156+
*/
157+
152158
def reconnect(from: Int, to: Int): Action[AnyContent] = authAction.async { request =>
153159

154160
ws.url(instanceRegistryUri + "/instances/" + from + "/assignInstance"
@@ -217,6 +223,12 @@ class InstanceRegistryController @Inject()(implicit system: ActorSystem, mat: Ma
217223
}(myExecutionContext)
218224
}
219225

226+
/**
227+
* This function is used to add a label to specific instance.
228+
* @param instanceID ID of the instance on which label is to be added
229+
* @param label
230+
* @return
231+
*/
220232

221233
def labelInstance(instanceID: String, label: String): Action[AnyContent] = authAction.async
222234
{

0 commit comments

Comments
 (0)