|
|
@ -10,6 +10,7 @@ object TestEmitter:
|
|
|
|
val PORT = 5457
|
|
|
|
val PORT = 5457
|
|
|
|
|
|
|
|
|
|
|
|
def start(): Unit = {
|
|
|
|
def start(): Unit = {
|
|
|
|
|
|
|
|
println("SETTING UP LOCAL JWT EMITTER FOR TESTS")
|
|
|
|
val emitterPresence = Path.of("/tmp/emitter.presence")
|
|
|
|
val emitterPresence = Path.of("/tmp/emitter.presence")
|
|
|
|
Files.deleteIfExists(emitterPresence)
|
|
|
|
Files.deleteIfExists(emitterPresence)
|
|
|
|
|
|
|
|
|
|
|
@ -26,10 +27,10 @@ object TestEmitter:
|
|
|
|
//the emitter will create the /tmp/emitter.presence file once it started, this is to inform us that the server is OP
|
|
|
|
//the emitter will create the /tmp/emitter.presence file once it started, this is to inform us that the server is OP
|
|
|
|
while (Files.notExists(emitterPresence))
|
|
|
|
while (Files.notExists(emitterPresence))
|
|
|
|
Thread.sleep(500)
|
|
|
|
Thread.sleep(500)
|
|
|
|
|
|
|
|
|
|
|
|
if (Files.readString(emitterPresence) == "A") {
|
|
|
|
if (Files.readString(emitterPresence) == "A") {
|
|
|
|
System.err.println("Emitter did not start successfully")
|
|
|
|
System.err.println("Emitter did not start successfully")
|
|
|
|
System.exit(1)
|
|
|
|
System.exit(1)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
Files.delete(emitterPresence)
|
|
|
|
Files.delete(emitterPresence)
|
|
|
|
|
|
|
|
println("EMITTER PRESENCE DETECTED AND INITIALIZED, CONTINUING...")
|
|
|
|
}
|
|
|
|
}
|
|
|
|