Read talk updates with payload

Author: anders88

src/main/kotlin/no/java/moresleep/HttpMethod.kt

@@ -24,6 +24,7 @@ enum class HttpMethod {
                         Pair("/data/session/:id", ReadOneTalk::class),
                         Pair("/data/conference/:conferenceId/session", ReadAllTalks::class),
                         Pair("/data/conference/:conferenceId/substatistics", TalkSubmissionStatistics::class),
+                        Pair("/data/fullTalkUpdate/:id",TalkUpdatesWithPayload::class),
 
                         Pair("/data/submitter/:email/session", ReadTalksBySubmitter::class),
                         Pair("/public/allSessions/:slug", ReadAllPublicTalks::class),

src/main/kotlin/no/java/moresleep/talk/TalkRepo.kt

@@ -60,6 +60,20 @@ class TalkUpdates(
         )
 }
 
+class TalkUpdateWithPayload(
+    val talkid: String,
+    val updatedBy: String,
+    val updatedAt:String,
+    val payload:JsonObject?
+) {
+    constructor(resultSet: ResultSet):this(
+        updatedBy = SystemId.valueOf(resultSet.requiredString("updatedby")).name,
+        updatedAt = resultSet.requiredLocalDateTime("updatedat").toString(),
+        talkid = resultSet.requiredString("talkid"),
+        payload = resultSet.getString("payload")?.let { JsonObject.parse(it) }
+    )
+}
+
 
 object TalkRepo {
     fun addNewTalk(talkid:String,conferenceid:String,status: SessionStatus,postedBy:String?,data:JsonObject,lastUpdated: LocalDateTime, publicdata:JsonObject?,publishedAt:LocalDateTime?) {
@@ -155,9 +169,16 @@ object TalkRepo {
         statement.allFromQuery { TalkUpdates(it) }
     }
 
+    fun updatesWithPayloadOnTalk(talkid:String):List<TalkUpdateWithPayload> = ServiceExecutor.connection().preparedStatement("select * from talkupdate where talkid = ? order by updatedat") { statement ->
+        statement.setString(1,talkid)
+        statement.allFromQuery { TalkUpdateWithPayload(it) }
+    }
+
     fun talkUpdatesOnConference(conferenceid: String) = ServiceExecutor.connection().preparedStatement("select * from talkupdate where conferenceid = ? order by updatedat") { statement ->
         statement.setString(1,conferenceid)
         statement.allFromQuery { TalkUpdates(it) }
     }
 
+
+
 }

src/main/kotlin/no/java/moresleep/talk/TalkUpdateSummary.kt

@@ -0,0 +1,7 @@
+package no.java.moresleep.talk
+
+import no.java.moresleep.*
+
+class TalkUpdateSummary(
+    val updateList:List<TalkUpdateWithPayload>
+): ServiceResult()

src/main/kotlin/no/java/moresleep/talk/TalkUpdatesWithPayload.kt

@@ -0,0 +1,14 @@
+package no.java.moresleep.talk
+
+import no.java.moresleep.*
+
+class TalkUpdatesWithPayload:Command {
+    override fun execute(systemUser: SystemUser, parameters: Map<String, String>): TalkUpdateSummary {
+        val talkid = parameters["id"]?:throw BadRequest("Missing id")
+        val updateList = TalkRepo.updatesWithPayloadOnTalk(talkid)
+        return TalkUpdateSummary(updateList)
+    }
+
+    override val requiredAccess: UserType = UserType.READ_ONLY
+
+}