Ensure Cache manifest for new PlanLimit queries is periodically updated

packages/Manager/src/main/kotlin/nz/govt/eop/plan_limits/Manifest.kt

@@ -3,6 +3,7 @@ package nz.govt.eop.plan_limits
 import java.math.BigInteger
 import java.security.MessageDigest
 import java.time.Instant
+import org.jooq.DSLContext
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.cache.annotation.CachePut
 import org.springframework.cache.annotation.Cacheable
@@ -11,13 +12,23 @@ import org.springframework.stereotype.Component
 const val MANIFEST_CACHE_KEY = "QUERY_MANIFEST"
 
 @Component
-class Manifest(@Autowired val queries: Queries) {
+class Manifest(@Autowired val queries: Queries, val context: DSLContext) {
 
  @Cacheable(cacheNames = [MANIFEST_CACHE_KEY])
  fun get(councilId: Int): Map<String, String> {
  return generate(councilId)
  }
 
+ fun updateAll() {
+ // Hard coded to just Wellington until we have more data since empty results
+ // for individual queries cause errors
+ update(9)
+
+ // val councils = context.selectFrom(COUNCILS).fetch()
+ // for (council in councils) {
+ // update(council.id!!)
+ // }
+ }
  @CachePut(cacheNames = [MANIFEST_CACHE_KEY])
  fun update(councilId: Int): Map<String, String> {
  return generate(councilId)

packages/Manager/src/main/kotlin/nz/govt/eop/tasks/PlanLimitsManifestUpdater.kt

@@ -0,0 +1,22 @@
+package nz.govt.eop.tasks
+
+import java.util.concurrent.TimeUnit
+import mu.KotlinLogging
+import net.javacrumbs.shedlock.spring.annotation.SchedulerLock
+import nz.govt.eop.plan_limits.Manifest
+import org.jooq.DSLContext
+import org.springframework.scheduling.annotation.Scheduled
+import org.springframework.stereotype.Component
+
+@Component
+class PlanLimitsManifestUpdater(val context: DSLContext, val manifest: Manifest) {
+
+ private val logger = KotlinLogging.logger {}
+ @Scheduled(fixedDelay = 1, timeUnit = TimeUnit.MINUTES)
+ @SchedulerLock(name = "planLimitsManifestUpdater")
+ fun updateManifest() {
+ logger.debug { startTaskMessage("planLimitsManifestUpdater") }
+ manifest.updateAll()
+ logger.debug { endTaskMessage("planLimitsManifestUpdater") }
+ }
+}