Accelerate - Dena Burd

Procfile

@@ -0,0 +1 @@
+web: gunicorn 'app:create_app()'

app/__init__.py

@@ -1,4 +1,4 @@
-from flask import Flask
+from flask import Flask, render_template
 from flask_sqlalchemy import SQLAlchemy
 from flask_migrate import Migrate
 import os
@@ -12,6 +12,7 @@
 
 def create_app(test_config=None):
     app = Flask(__name__)
+    app.url_map.strict_slashes = False
     app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False
 
     if test_config is None:
@@ -30,5 +31,12 @@ def create_app(test_config=None):
     migrate.init_app(app, db)
 
     # Register Blueprints here
+    from .routes import tasks_bp, goals_bp
+    app.register_blueprint(tasks_bp)
+    app.register_blueprint(goals_bp)
+
+    @app.route("/")
+    def index():
+        return render_template("index.html")
 
     return app

app/models/goal.py

@@ -4,3 +4,5 @@
 
 class Goal(db.Model):
     goal_id = db.Column(db.Integer, primary_key=True)
+    title = db.Column(db.String)
+    tasks = db.relationship("Task", backref="goal", lazy=True)

app/models/task.py

@@ -4,3 +4,8 @@
 
 class Task(db.Model):
     task_id = db.Column(db.Integer, primary_key=True)
+    title = db.Column(db.String)
+    description = db.Column(db.String)
+    completed_at = db.Column(db.DateTime, nullable=True)
+    goal_id = db.Column(db.Integer, db.ForeignKey(
+        'goal.goal_id'), nullable=True)

app/routes.py

@@ -1,2 +1,274 @@
-from flask import Blueprint
+import requests
+from dotenv import load_dotenv
+import os
+import datetime
+from sqlalchemy import desc
+from app import db
+from app.models.task import Task
+from app.models.goal import Goal
+from flask import request, Blueprint, make_response, jsonify
+tasks_bp = Blueprint("tasks", __name__, url_prefix="/tasks")
+goals_bp = Blueprint("goals", __name__, url_prefix="/goals")
 
+load_dotenv()
+
+
+@tasks_bp.route("/", methods=["GET", "POST"])
+def handle_tasks():
+    if request.method == "GET":
+        sort_query = request.args.get("sort")
+        if sort_query == "asc":
+            tasks = Task.query.order_by(Task.title)
+        elif sort_query == "desc":
+            tasks = Task.query.order_by(desc(Task.title))
+        else:
+            tasks = Task.query.all()
+
+        tasks_response = []
+        for task in tasks:
+            if not task.completed_at:
+                is_complete = False
+            else:
+                is_complete = True
+            tasks_response.append({
+                "id": task.task_id,
+                "title": task.title,
+                "description": task.description,
+                "is_complete": is_complete
+            })
+        return make_response(jsonify(tasks_response), 200)
+
+    elif request.method == "POST":
+        request_body = request.get_json()
+        keys = ['title', 'description', 'completed_at']
+        for key in keys:
+            if key not in request_body:
+                task_response = {"details": "Invalid data"}
+                return make_response(task_response, 400)
+
+        new_task = Task(title=request_body["title"],
+                        description=request_body["description"],
+                        completed_at=request_body["completed_at"])
+
+        db.session.add(new_task)
+        db.session.commit()
+        if not request_body["completed_at"]:
+            is_complete = False
+        else:
+            is_complete = True
+        task_response = {"task":
+                         {"id": new_task.task_id,
+                          "title": new_task.title,
+                          "description": new_task.description,
+                          "is_complete": is_complete}
+                         }
+        return make_response(task_response, 201)
+
+
+@tasks_bp.route("/<task_id>", methods=["GET", "PUT", "DELETE"])
+def handle_task(task_id):
+    task = Task.query.get(task_id)
+    if not task:
+        return make_response(f"Task #{task_id} Not Found", 404)
+
+    if request.method == "GET":
+        if not task.completed_at:
+            is_complete = False
+        else:
+            is_complete = True
+        task_response = {"task": {
+            "id": task.task_id,
+            "title": task.title,
+            "description": task.description,
+            "is_complete": is_complete,
+        }}
+        if task.goal_id:
+            task_response["task"]["goal_id"] = task.goal_id
+        return make_response(task_response, 200)
+    elif request.method == "PUT":
+        form_data = request.get_json()
+        if ("completed_at" not in form_data or
+                form_data["completed_at"] == None):
+            is_complete = False
+        else:
+            is_complete = True
+        task.title = form_data["title"]
+        task.description = form_data["description"]
+        task.completed_at = form_data["completed_at"]
+        db.session.commit()
+        task_response = {"task": {
+            "id": task.task_id,
+            "title": task.title,
+            "description": task.description,
+            "is_complete": is_complete
+        }}
+        return make_response(task_response, 200)
+
+    elif request.method == "DELETE":
+        db.session.delete(task)
+        db.session.commit()
+        task_response = {
+            "details": f"Task {task.task_id} \"{task.title}\" successfully deleted"
+        }
+        return make_response(task_response, 200)
+
+
+@tasks_bp.route("/<task_id>/mark_complete", methods=["PATCH"])
+def handle_task_complete(task_id):
+    task = Task.query.get(task_id)
+    if not task:
+        return make_response(f"Task #{task_id} Not Found", 404)
+
+    task.completed_at = datetime.datetime.utcnow()
+    db.session.commit()
+    channel = "channel=task-notifications"
+    text = f"text=Someone just completed the task {task.title}"
+
+    path = f"https://slack.com/api/chat.postMessage?{channel}&{text}"
+
+    SLACKBOT_AUTH = os.environ.get(
+        "SLACKBOT_AUTH")
+
+    requests.post(path, headers={'Authorization': f'Bearer {SLACKBOT_AUTH}'})
+
+    task_response = {"task": {
+        "id": task.task_id,
+        "title": task.title,
+        "description": task.description,
+        "is_complete": True
+    }}
+    return make_response(task_response, 200)
+
+
+@tasks_bp.route("/<task_id>/mark_incomplete", methods=["PATCH"])
+def handle_task_incomplete(task_id):
+    # get current data, set the thing
+    task = Task.query.get(task_id)
+    if not task:
+        return make_response(f"Task #{task_id} Not Found", 404)
+
+    task.completed_at = None
+    db.session.commit()
+
+    task_response = {"task": {
+        "id": task.task_id,
+        "title": task.title,
+        "description": task.description,
+        "is_complete": False
+    }}
+    return make_response(task_response, 200)
+
+
+@goals_bp.route("/", methods=["GET", "POST"])
+def handle_goals():
+    if request.method == "GET":
+        goals = Goal.query.all()
+
+        goals_response = []
+
+        for goal in goals:
+            goals_response.append({
+                "id": goal.goal_id,
+                "title": goal.title
+            })
+        return make_response(jsonify(goals_response), 200)
+
+    elif request.method == "POST":
+        request_body = request.get_json()
+        if 'title' not in request_body:
+            goal_response = {"details": "Invalid data"}
+            return make_response(goal_response, 400)
+
+        new_goal = Goal(title=request_body["title"])
+
+        db.session.add(new_goal)
+        db.session.commit()
+
+        goal_response = {"goal":
+                         {"id": new_goal.goal_id,
+                          "title": new_goal.title,
+                          }}
+        return make_response(goal_response, 201)
+
+
+@goals_bp.route("/<goal_id>", methods=["GET", "PUT", "DELETE"])
+def handle_goal(goal_id):
+    goal = Goal.query.get(goal_id)
+    if not goal:
+        return make_response(f"Goal #{goal_id} Not Found", 404)
+
+    if request.method == "GET":
+        goal_response = {"goal": {
+            "id": goal.goal_id,
+            "title": goal.title
+        }}
+        return make_response(goal_response, 200)
+
+    elif request.method == "PUT":
+        form_data = request.get_json()
+        if not 'title' in form_data:
+            goal_response = {"details": "Invalid data"}
+            return make_response(goal_response, 400)
+
+        goal.title = form_data["title"]
+        db.session.commit()
+
+        goal_response = {"goal": {
+            "id": goal.goal_id,
+            "title": goal.title
+        }}
+        return make_response(goal_response, 200)
+
+    elif request.method == "DELETE":
+        db.session.delete(goal)
+        db.session.commit()
+        goal_response = {
+            "details": f"Goal {goal.goal_id} \"{goal.title}\" successfully deleted"
+        }
+        return make_response(goal_response, 200)
+
+
+@goals_bp.route("/<goal_id>/tasks", methods=["POST", "GET"])
+def handle_goal_tasks(goal_id):
+    goal = Goal.query.get(goal_id)
+    if not goal:
+        return make_response(f"Goal #{goal_id} Not Found", 404)
+
+    if request.method == "POST":
+        request_body = request.get_json()
+        task_ids = request_body["task_ids"]
+        for task_id in task_ids:
+            task = Task.query.get(task_id)
+            # if not task:
+            #     return make_response(f"Task #{task_id} Not Found", 404)
+            task.goal_id = goal_id
+
+        db.session.commit()
+        goal_response = {
+            "id": goal.goal_id,
+            "task_ids": task_ids
+        }
+        return make_response(jsonify(goal_response), 200)
+
+    if request.method == "GET":
+        tasks = Task.query.filter_by(goal_id=goal.goal_id)
+        tasks_response = []
+
+        for task in tasks:
+            if not task.completed_at:
+                is_complete = False
+            else:
+                is_complete = True
+            tasks_response.append({
+                "id": task.task_id,
+                "title": task.title,
+                "description": task.description,
+                "is_complete": is_complete,
+                "goal_id": task.goal_id,
+            })
+        goal_response = {
+            "id": goal.goal_id,
+            "title": goal.title,
+            "tasks": tasks_response
+        }
+        return make_response(jsonify(goal_response), 200)