digital-asset/daml
1
1
Fork 0
mirror of https://github.com/digital-asset/daml.git synced 2024-11-10 10:46:11 +03:00
Code Issues Projects Releases Wiki Activity

Extend timing for AuthorizationIT (#3422)

Browse Source
This commit is contained in:
Gerolf Seitz 2019-11-12 10:11:43 +01:00 committed by GitHub
parent 964ca64951
commit 89ac004944
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ledger/ledger-api-integration-tests/src/test/itsuite/scala/com/digitalasset/platform/tests/integration/ledger/api/AuthorizationIT.scala
View File

@ -101,7 +101,7 @@ class AuthorizationIT
implicit class AuthServiceJWTPayloadExtensions(payload: AuthServiceJWTPayload) {
def expiresIn(t: java.time.Duration): AuthServiceJWTPayload =
payload.copy(exp = Some(Instant.now.plus(t)))
def expiresInOneSecond: AuthServiceJWTPayload = expiresIn(Duration.ofSeconds(1))
def expiresInFiveSeconds: AuthServiceJWTPayload = expiresIn(Duration.ofSeconds(5))
def expiresTomorrow: AuthServiceJWTPayload = expiresIn(Duration.ofDays(1))
def expired: AuthServiceJWTPayload = expiresIn(Duration.ofDays(-1))
@ -209,14 +209,14 @@ class AuthorizationIT
Some(ledgerBegin)),
observer))
def scheduleCommandInMillis(millis: Long): Unit = {
def scheduleCommand(duration: Duration): Unit = {
val timer = new Timer(true)
timer.schedule(new TimerTask {
override def run(): Unit = {
val _ =
ctxAlice.commandService.submitAndWait(dummySubmitAndWaitRequest(ledgerId, alice))
}
}, millis)
}, duration.toMillis)
}
for {
@ -228,8 +228,8 @@ class AuthorizationIT
_ <- mustBeDenied(call(ctxAliceExpired, alice)) // Reading completions for Alice as Alice after expiration
_ <- call(ctxAlice, alice) // Reading completions for Alice as Alice before expiration
ctxAliceAboutToExpire = ctxNone.withAuthorizationHeader(
alicePayload.expiresInOneSecond.asHeader())
_ = scheduleCommandInMillis(1100)
alicePayload.expiresInFiveSeconds.asHeader())
_ = scheduleCommand(Duration.ofSeconds(10))
_ <- callAndExpectExpiration(ctxAliceAboutToExpire, alice)
} yield {
succeed