1 files changed, 33 insertions, 0 deletions
diff --git a/src/services/create_reply_service.py b/src/services/create_reply_service.py
new file mode 100644
index 0000000..12600dd
--- /dev/null
+++ b/src/services/create_reply_service.py
@@ -0,0 +1,33 @@
+from sqlalchemy import select
+from src.database.models import Blog, Comment, Reply
+from src.database import db
+from src.services.reply_creation_callback import ReplyCreationCallbacks
+
+class CreateReplyService:
+    def __init__(self, reply_data, comment_id):
+        self._comment_id = comment_id
+        self._content = reply_data.get('content')
+        self._email = reply_data.get('email')
+        self._author = reply_data.get('author')
+
+    def call(self):
+        if not self._comment_exists():
+            return 404
+
+        reply = ReplyCreationCallbacks(
+            Reply(comment_id=self._comment_id,
+                  content=self._content, email=self._email,
+                  author=self._author)
+        ).run_callbacks()
+        db.session.add(reply)
+        db.session.commit()
+
+        return 200
+
+    def _comment_exists(self):
+        search_comment_statement = select(Comment).where(
+            Comment.id == self._comment_id
+        )
+
+        return db.session.execute(search_comment_statement) \
+                         .scalars().first() is not None