init pubnub channels

gistfile1.txt

val users = Await.result(ComponentRegistry.institutionUserDao.tableScan, 100.seconds)
users map { user =>
  if (user.pubnubAuthKey.isEmpty) {
    println(s"updating user ${user.id}")
    val updated = user.withAuthKey(echo360.util.IdGenerator.createUuid)
    Await.result(ComponentRegistry.institutionUserDao.update(updated), 10.seconds)
    Thread.sleep(10)
  }
}
 
 
val users = Await.result(ComponentRegistry.institutionUserDao.tableScan, 100.seconds)
users map { user =>
  Await.result(ComponentRegistry.mediaInteractionService.initUserChannel(user), 10.seconds)
  Thread.sleep(1)
}
 
val sections = Await.result(ComponentRegistry.sectionDao.tableScan, 100.seconds)
sections map { section =>
  Await.result(ComponentRegistry.sectionInteractionService.initSectionChannels(section), 10.seconds)
  Thread.sleep(10)
}
 
val userSections = Await.result(ComponentRegistry.userSectionDao.tableScan, 100.seconds)
userSections map { userSection =>
  println(userSection.userId)
  Await.result(ComponentRegistry.sectionInteractionService.authorizeUser(userSection), 10.seconds)
}