Accepting or rejecting requests updates the corresponding db row

Closes #48

src/main/kotlin/com/timcastelijns/room15bot/bot/eventhandlers/MessageEventHandler.kt

@@ -25,6 +25,7 @@ class MessageEventHandler(
         private val getStarsDataUseCase: GetStarsDataUseCase,
         private val acceptUserUseCase: AcceptUserUseCase,
         private val rejectUserUseCase: RejectUserUseCase,
+        private val updateAccessRequestUseCase: UpdateAccessRequestUseCase,
         private val syncStarsDataUseCase: SyncStarsDataUseCase,
         private val setReminderUseCase: SetReminderUseCase,
         private val updateUseCase: UpdateUseCase,
@@ -53,7 +54,7 @@ class MessageEventHandler(
         handleMessage(event.message)
     }
 
-    private suspend fun handleMessage(message: Message)= coroutineScope {
+    private suspend fun handleMessage(message: Message) = coroutineScope {
         if (message.isCommand()) {
             val time = measureTimeMillis {
                 launch { processCommandMessage(message) }.join()
@@ -152,10 +153,12 @@ class MessageEventHandler(
         }
 
         if (username != null) {
-            acceptUserByName(username)
+//            acceptUserByName(username)
+            actor.acceptReply("Accepting by name is currently not supported", messageId)
         } else {
             actor.provideLatestAccessRequestee()?.let { requestee ->
                 acceptUserByName(requestee.name)
+                updateAccessRequest(requestee, user, true)
             } ?: actor.acceptMessage(messageFormatter.asRequesteeNotFound())
         }
     }
@@ -174,10 +177,12 @@ class MessageEventHandler(
         }
 
         if (username != null) {
-            rejectUserByName(username)
+//            rejectUserByName(username)
+            actor.acceptReply("Rejecting by name is currently not supported", messageId)
         } else {
             actor.provideLatestAccessRequestee()?.let { requestee ->
                 rejectUserByName(requestee.name)
+                updateAccessRequest(requestee, user, false)
             } ?: actor.acceptMessage(messageFormatter.asRequesteeNotFound())
         }
     }
@@ -199,6 +204,11 @@ class MessageEventHandler(
         }
     }
 
+    private fun updateAccessRequest(requestee: User, user: User, accessGranted: Boolean) =
+        updateAccessRequestUseCase.execute(
+                UpdateAccessRequestParams(requestee.id, true, user.name, accessGranted)
+        )
+
     private fun processLeaveCommand(user: User) {
         if (user.id == 1843331L) {
             actor.acceptMessage(messageFormatter.asLeavingString())

src/main/kotlin/com/timcastelijns/room15bot/bot/usecases/UpdateAccessRequestUseCase.kt

@@ -0,0 +1,25 @@
+package com.timcastelijns.room15bot.bot.usecases
+
+import com.timcastelijns.room15bot.data.db.AccessRequestDao
+
+class UpdateAccessRequestUseCase(
+        private val accessRequestDao: AccessRequestDao
+) : UseCase<UpdateAccessRequestParams, Unit> {
+
+    override fun execute(params: UpdateAccessRequestParams) {
+        accessRequestDao.update(
+                params.userId,
+                params.processed,
+                params.processedBy,
+                params.accessGranted
+        )
+    }
+
+}
+
+data class UpdateAccessRequestParams(
+        val userId: Long,
+        val processed: Boolean,
+        val processedBy: String,
+        val accessGranted: Boolean
+)

src/main/kotlin/com/timcastelijns/room15bot/data/db/AccessRequestDao.kt

@@ -2,6 +2,8 @@ package com.timcastelijns.room15bot.data.db
 
 import org.jetbrains.exposed.sql.insert
 import org.jetbrains.exposed.sql.transactions.transaction
+import org.jetbrains.exposed.sql.update
+import java.time.Instant
 
 class AccessRequestDao {
 
@@ -10,6 +12,18 @@ class AccessRequestDao {
             AccessRequests.insert {
                 it[this.userId] = userId
                 it[this.username] = username
+                it[this.createdAt] = Instant.now().toEpochMilli()
+            }
+        }
+    }
+
+    fun update(userId: Long, processed: Boolean, processedBy: String, accessGranted: Boolean) {
+        transaction {
+            AccessRequests.update({ AccessRequests.userId eq userId }) {
+                it[this.processed] = processed
+                it[this.processedBy] = processedBy
+                it[this.processedAt] = Instant.now().toEpochMilli()
+                it[this.accessGranted] = accessGranted
             }
         }
     }

src/main/kotlin/com/timcastelijns/room15bot/data/db/Schema.kt

@@ -2,7 +2,6 @@ package com.timcastelijns.room15bot.data.db
 
 import org.jetbrains.exposed.dao.IntIdTable
 import org.jetbrains.exposed.dao.LongIdTable
-import java.time.Instant
 
 object StarredMessages : LongIdTable() {
     val username = varchar("username", 255)
@@ -21,6 +20,8 @@ object AccessRequests: IntIdTable() {
     val userId = long("userId")
     val username = varchar("username", 255)
     val processed = bool("processed").default(false)
+    val processedAt = long("processedAt").nullable()
     val processedBy = varchar("processedBy", 255).nullable()
-    val timestamp = long("timestamp").default(Instant.now().toEpochMilli())
+    val createdAt = long("createdAt")
+    val accessGranted = bool("accessGranted").nullable()
 }

src/main/kotlin/com/timcastelijns/room15bot/di/module.kt

@@ -46,6 +46,7 @@ private val module: Module = module {
     factory<AcceptUserUseCase>()
     factory<RejectUserUseCase>()
     factory<CreateAccessRequestUseCase>()
+    factory<UpdateAccessRequestUseCase>()
 
     factory { UpdateUseCase(Runtime.getRuntime()) }