feat/qg-290: реализованы уведомления о заполнении расписания (#292)

Author: d-r-q

app/build.gradle.kts

@@ -1,6 +1,8 @@
+import com.gorylenko.GenerateGitPropertiesTask
 import kotlinx.kover.gradle.plugin.dsl.AggregationType
 import kotlinx.kover.gradle.plugin.dsl.CoverageUnit
 import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
+import java.util.*
 
 plugins {
 	alias(libs.plugins.kotlin.spring)
@@ -43,6 +45,8 @@ dependencies {
     implementation(libs.google.oauth.client)
     implementation(platform(libs.google.auth.bom))
     implementation("com.google.auth:google-auth-library-oauth2-http")
+    implementation(libs.web.push)
+    implementation(libs.bouncycastle)
 
 	developmentOnly("org.springframework.boot:spring-boot-docker-compose")
 
@@ -224,3 +228,20 @@ val compileKotlin: KotlinCompile by tasks
 compileKotlin.compilerOptions {
     freeCompilerArgs.set(listOf("-Xannotation-default-target=param-property"))
 }
+
+val generateGitProperties = tasks.named<GenerateGitPropertiesTask>("generateGitProperties")
+
+val gitHash: Provider<String> = generateGitProperties.map { task ->
+    val props = Properties()
+    task.output.get().asFile.inputStream().use(props::load)
+    props.getProperty("git.commit.id.abbrev")
+}
+
+tasks.processResources {
+    dependsOn(generateGitProperties)
+    filesMatching("static/sw.js") {
+        expand(
+            "APP_VERSION" to gitHash.get()
+        )
+    }
+}

app/src/main/kotlin/pro/azhidkov/platform/java/sql/ResultSetExt.kt

@@ -12,4 +12,8 @@ inline operator fun <reified T> ResultSet.get(colName: String): T = when (T::cla
     Duration::class -> (this.getObject(colName) as PGInterval).toDuration()
     List::class -> (this.getArray(colName).array as Array<*>).toList()
     else -> this.getObject(colName)
-} as T
+} as T
+
+inline operator fun <reified T> ResultSet.get(colIdx: Int): T =
+    this.metaData.getColumnName(colIdx)
+        .let { colName -> this[colName] }

app/src/main/kotlin/pro/azhidkov/platform/spring/sdj/converters/ObjectToJsonbConverters.kt

@@ -0,0 +1,54 @@
+package pro.azhidkov.platform.spring.sdj.converters
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import org.postgresql.util.PGobject
+import org.springframework.core.convert.converter.Converter
+import org.springframework.data.convert.ReadingConverter
+import org.springframework.data.convert.WritingConverter
+import kotlin.reflect.KClass
+
+
+@WritingConverter
+fun interface ObjectToJsonbWriter<T : Any> : Converter<T, PGobject>
+
+@ReadingConverter
+fun interface JsonbToObjectReader<T : Any> : Converter<PGobject, T>
+
+abstract class JacksonObjectToJsonbWriter<T : Any>(
+    private val objectMapper: ObjectMapper
+) : ObjectToJsonbWriter<T> {
+
+    override fun convert(source: T): PGobject =
+        source.let {
+            PGobject().apply {
+                type = "jsonb"
+                value = objectMapper.writeValueAsString(source)
+            }
+        }
+
+}
+
+@ReadingConverter
+abstract class JacksonJsonbToObjectReader<T : Any>(
+    private val objectMapper: ObjectMapper,
+    private val type: KClass<T>
+) : JsonbToObjectReader<T> {
+
+    override fun convert(source: PGobject): T? =
+        if (source.isNull) {
+            null
+        } else {
+            objectMapper.readValue(source.value!!, type.java)
+        }
+
+}
+
+object ObjectToJsonbConverters {
+
+    inline fun <reified T : Any> convertersFor(objectMapper: ObjectMapper) =
+        setOf(
+            object : JacksonObjectToJsonbWriter<T>(objectMapper) {},
+            object : JacksonJsonbToObjectReader<T>(objectMapper, T::class) {},
+        )
+
+}

app/src/main/kotlin/pro/azhidkov/platform/spring/sdj/ergo/hydration/AggregateReferenceTarget.kt

@@ -12,8 +12,24 @@ data class AggregateReferenceTarget<T : Identifiable<ID>, ID : Any>(
     @JsonIgnore
     override fun getId(): ID = entity.id
 
+    override fun equals(other: Any?): Boolean {
+        if (this === other) return true
+        if (other !is AggregateReference<*, *>) return false
+
+        return if (other is AggregateReferenceTarget<*, *>) {
+            entity == other.entity
+        } else {
+            getId() == other.getId()
+        }
+    }
+
+    override fun hashCode(): Int {
+        return entity.id.hashCode()
+    }
+
 }
 
+@Suppress("UNCHECKED_CAST")
 fun <R : AggregateReference<T, ID>?, ID : Any, T : Identifiable<ID>> R.resolveOrThrow(): T =
     (this as? AggregateReferenceTarget<T, ID>)?.entity
         ?: error("$this is not instance of AggregateReferenceTarget")

app/src/main/kotlin/pro/azhidkov/platform/spring/sdj/ergo/hydration/Identifiable.kt

@@ -9,4 +9,5 @@ interface Identifiable<T : Any> {
 
 }
 
-fun <E : Identifiable<T>, T : Any> E.ref(): AggregateReference<E, T> = AggregateReferenceTarget(this)
+fun <E : Identifiable<T>, T : Any> E.ref(): AggregateReference<E, T> =
+    AggregateReferenceTarget(this)

app/src/main/kotlin/pro/azhidkov/platform/spring/sdj/query/QueryBuilder.kt

@@ -50,6 +50,10 @@ class QueryBuilder {
         }
     }
 
+    infix fun <T : Any> KProperty1<*, T?>.`in`(value: Iterable<T>) {
+        criteria.addLast(Criteria.where(this.name).`in`(value))
+    }
+
     fun build() = Query.query(toCriteriaDefinition())
 
     private fun toCriteriaDefinition() =
@@ -74,4 +78,4 @@ fun query(body: QueryBuilder.() -> Unit): Query {
     val builder = QueryBuilder()
     builder.body()
     return builder.build()
-}
+}

app/src/main/kotlin/pro/qyoga/app/QYogaApp.kt

@@ -16,6 +16,7 @@ import pro.qyoga.core.users.UsersConfig
 import pro.qyoga.i9ns.calendars.google.GoogleCalendarConf
 import pro.qyoga.i9ns.calendars.ical.ICalCalendarsConfig
 import pro.qyoga.i9ns.email.EmailsConfig
+import pro.qyoga.i9ns.pushes.web.WebPushesConf
 import pro.qyoga.infra.auth.AuthConfig
 import pro.qyoga.infra.cache.CacheConf
 import pro.qyoga.infra.db.SdjConfig
@@ -42,6 +43,7 @@ import pro.qyoga.tech.captcha.CaptchaConf
     EmailsConfig::class,
     ICalCalendarsConfig::class,
     GoogleCalendarConf::class,
+    WebPushesConf::class,
 
     // Tech
     CaptchaConf::class,

app/src/main/kotlin/pro/qyoga/app/infra/WebSecurityConfig.kt

@@ -50,22 +50,36 @@ class WebSecurityConfig(
                 requests
                     // Therapist
                     .requestMatchers("/therapist/**").hasAnyAuthority(Role.ROLE_THERAPIST.toString())
+                    .requestMatchers(HttpMethod.POST, "/pushes/web/subscriptions")
+                    .hasAnyAuthority(Role.ROLE_THERAPIST.toString())
+                    .requestMatchers(HttpMethod.DELETE, "/pushes/web/subscriptions/*")
+                    .hasAnyAuthority(Role.ROLE_THERAPIST.toString())
 
                     // Public
                     .requestMatchers(
                         HttpMethod.GET,
                         "/",
+
+                        "/manifest.json",
+                        "/sw.js",
                         "/offline.html",
+
                         "/privacy-policy.html",
-                        "/manifest.json",
+
                         "/register",
+
                         "/oauth2/**",
+
+                        "/pushes/web/public-key",
+
                         "/components/**",
+
                         "/styles/**",
                         "/img/**",
                         "/js/**",
                         "/fonts/**",
                         "/vendor/**",
+
                         "/test/*"
                     )
                     .permitAll()

app/src/main/kotlin/pro/qyoga/app/publc/pushes/web/PushesPublicKeyController.kt

@@ -0,0 +1,30 @@
+package pro.qyoga.app.publc.pushes.web
+
+import org.springframework.http.CacheControl
+import org.springframework.http.MediaType
+import org.springframework.http.ResponseEntity
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.RestController
+import pro.qyoga.i9ns.pushes.web.WebPushesConfProps
+import java.time.Duration
+
+
+@RestController
+class PushesPublicKeyController(
+    private val webPushesConfProps: WebPushesConfProps
+) {
+
+    @GetMapping(PUBLIC_KEY_PATH, produces = [MediaType.TEXT_PLAIN_VALUE])
+    fun publicKey(): ResponseEntity<String> {
+        return ResponseEntity.ok()
+            .cacheControl(CacheControl.maxAge(Duration.ofHours(1)).cachePublic())
+            .body(webPushesConfProps.publicKey)
+    }
+
+    companion object {
+
+        const val PUBLIC_KEY_PATH = "/pushes/web/public-key"
+
+    }
+
+}

app/src/main/kotlin/pro/qyoga/app/pushes/web/RegisterSubscriptionOp.kt

@@ -0,0 +1,28 @@
+package pro.qyoga.app.pushes.web
+
+import org.springframework.stereotype.Component
+import pro.qyoga.core.appointments.notifications.fill_schedule.FillScheduleNotificationsSettings
+import pro.qyoga.core.appointments.notifications.fill_schedule.FillScheduleNotificationsSettingsRepo
+import pro.qyoga.core.users.therapists.TherapistRef
+import pro.qyoga.i9ns.pushes.web.WebPushSubscriptionsRepo
+import pro.qyoga.i9ns.pushes.web.model.TherapistWebPushSubscription
+import pro.qyoga.i9ns.pushes.web.model.WebPushSubscription
+
+
+@Component
+class RegisterSubscriptionOp(
+    private val webPushSubscriptionsRepo: WebPushSubscriptionsRepo,
+    private val fillScheduleNotificationsSettingsRepo: FillScheduleNotificationsSettingsRepo
+) : (TherapistRef, WebPushSubscription) -> Unit {
+
+    override fun invoke(
+        therapistRef: TherapistRef,
+        subscription: WebPushSubscription,
+    ) {
+        webPushSubscriptionsRepo.addSubscription(TherapistWebPushSubscription(therapistRef, subscription))
+        fillScheduleNotificationsSettingsRepo.createIfNotExists(
+            FillScheduleNotificationsSettings.defaultSettingsFor(therapistRef)
+        )
+    }
+
+}