From 8901d5d73a50ce2d426aece1f8ab0ff0216278ef Mon Sep 17 00:00:00 2001
From: Vincent Ambo <mail@tazj.in>
Date: Sun, 27 May 2018 14:12:31 +0200
Subject: feat(db): Prevent responses to closed threads

This concludes the thread-closing implementation!
---
 src/db.rs     | 13 +++++++++++++
 src/errors.rs |  2 +-
 2 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/src/db.rs b/src/db.rs
index bfbdd193c4..3c44172b15 100644
--- a/src/db.rs
+++ b/src/db.rs
@@ -208,6 +208,19 @@ impl Handler<CreatePost> for DbExecutor {
 
         let conn = self.0.get()?;
 
+        let closed: bool = {
+            use schema::threads::dsl::*;
+            threads.select(closed)
+                .find(msg.0.thread_id)
+                .first(&conn)?
+        };
+
+        if closed {
+            return Err(ConverseError::ThreadClosed {
+                id: msg.0.thread_id
+            })
+        }
+
         Ok(diesel::insert_into(posts::table)
            .values(&msg.0)
            .get_result(&conn)?)
diff --git a/src/errors.rs b/src/errors.rs
index c73379f0ca..dd0e12c045 100644
--- a/src/errors.rs
+++ b/src/errors.rs
@@ -124,7 +124,7 @@ impl ResponseError for ConverseError {
         // Everything is mapped to internal server errors for now.
         match *self {
             ConverseError::ThreadClosed { id } => HttpResponse::SeeOther()
-                .header("Location", format!("/thread/{}#edit-post", id))
+                .header("Location", format!("/thread/{}#post-reply", id))
                 .finish(),
             _ => HttpResponse::build(StatusCode::INTERNAL_SERVER_ERROR)
                 .body(format!("An error occured: {}", self))
-- 
cgit 1.4.1