Spruce - Cabebe & Zandra

app/__init__.py

@@ -8,6 +8,7 @@
 migrate = Migrate()
 load_dotenv()
 
+
 def create_app(test_config=None):
     app = Flask(__name__)
     app.url_map.strict_slashes = False
@@ -21,7 +22,6 @@ def create_app(test_config=None):
         app.config["SQLALCHEMY_DATABASE_URI"] = os.environ.get(
             "SQLALCHEMY_TEST_DATABASE_URI")
 
-
     # import models for Alembic Setup
     from app.models.customer import Customer
     from app.models.video import Video
@@ -31,6 +31,12 @@ def create_app(test_config=None):
     db.init_app(app)
     migrate.init_app(app, db)
 
-    #Register Blueprints Here
+    # Register Blueprints Here
+    from .video_routes import video_bp
+    app.register_blueprint(video_bp)
+    from .customer_routes import customers_bp
+    app.register_blueprint(customers_bp)
+    from .rental_routes import rentals_bp
+    app.register_blueprint(rentals_bp)
 
-    return app
+    return app

app/customer_routes.py

@@ -0,0 +1,95 @@
+from app import db
+from app.models.customer import Customer
+from flask import Blueprint, jsonify, request
+from datetime import datetime
+
+customers_bp = Blueprint("customers_bp", __name__, url_prefix="/customers")
+
+
+@customers_bp.route("", methods=["POST"])
+def customer_create():
+    request_body = request.get_json()
+
+    if "name" not in request_body or "phone" not in request_body or "postal_code" not in request_body:
+        response_body ={}
+        if "name" not in request_body:
+            response_body["details"] = "Request body must include name."
+        elif "phone" not in request_body:
+            response_body["details"] = "Request body must include phone."
+        elif "postal_code" not in request_body:
+            response_body["details"] = "Request body must include postal_code."
+        return jsonify(response_body), 400
+
+    new_customer = Customer(
+        name=request_body["name"],
+        phone=request_body["phone"],
+        postal_code=request_body["postal_code"],
+
+    )
+    db.session.add(new_customer)
+    db.session.commit()
+
+    return jsonify({"id": new_customer.customer_id}), 201
+
+
+@customers_bp.route("", methods=["GET"])
+def handle_customers():
+    customers = Customer.query.all()
+    response_body = []
+    for customer in customers:
+        response_body.append(customer.customer_dict())
+
+    return jsonify(response_body), 200
+
+
+@customers_bp.route("/<customer_id>", methods=["GET"])
+def customer_get(customer_id):
+    try:
+        customer = Customer.query.get(customer_id)
+    except:
+        return jsonify({"message": f"Customer {customer_id} was not found"}), 400
+
+    if customer is None:
+        return jsonify({"message": f"Customer {customer_id} was not found"}), 404
+
+    return jsonify(customer.customer_dict()), 200
+
+    return jsonify(customer.customer_dict()), 200
+
+# WORK IN PROGRESS
+@customers_bp.route("/<customer_id>", methods=["PUT"])
+def customer_put(customer_id):
+    customer = Customer.query.get(customer_id)
+    if customer == None:
+        return jsonify({"message": f"Customer {customer_id} was not found"}), 404
+
+    request_body = request.get_json()
+    if "name" not in request_body or "phone" not in request_body or "postal_code" not in request_body:
+        return jsonify(), 400 
+
+    customer.name = request_body["name"]
+    customer.phone = request_body["phone"]
+    customer.postal_code = request_body["postal_code"]
+
+    if "name" in request_body or "phone" in request_body or "postal_code" in request_body:
+        response_body ={}
+        response_body["name"] = customer.name
+        response_body["phone"] = customer.phone 
+        response_body["postal_code"] = customer.postal_code 
+
+    db.session.commit()
+
+    return jsonify(response_body), 200
+
+
+@customers_bp.route("/<customer_id>", methods=["DELETE"])
+def customer_delete(customer_id):
+    customer = Customer.query.get(customer_id)
+
+    if customer == None:
+        return jsonify({"message": f"Customer {customer_id} was not found"}), 404
+
+    db.session.delete(customer)
+    db.session.commit()
+
+    return jsonify({"id": customer.customer_id}), 200

app/models/customer.py

@@ -1,4 +1,31 @@
 from app import db
+from sqlalchemy.sql.functions import func
 
 class Customer(db.Model):
-    id = db.Column(db.Integer, primary_key=True)
+    customer_id = db.Column(db.Integer, primary_key=True, autoincrement=True)
+    name = db.Column(db.String)
+    phone = db.Column(db.String)
+    postal_code = db.Column(db.String)
+    # server_default tells sqlA to pass the default value as part of the CREATE TABLE
+    # func.now() or func.current_timestamp() - they are aliases of each other. This tells DB to calcaate the timestamp itself
+    registered_at = db.Column(db.DateTime(timezone=True), server_default=func.now())
+    #I DON'T KNOW IF THIS IS CORRECT
+    #adding videos attribute to Customer Model
+    videos = db.relationship("Video", secondary="rental", backref="customers")
+    #videos = db.relationship("Rental", back_populates="customer")
+
+
+    def customer_dict(self):
+        dict = {
+            "id": self.customer_id,
+            "name": self.name,
+            "phone": self.phone,
+            "postal_code": self.postal_code,
+            # weekday|day of month (16)|month name|year|local version of time|, UTC offset +HHMM or -HHMM
+            "registered_at": self.registered_at.strftime("%a, %-d %b %Y %X %z")
+    }
+    #     if self.registered_at is not None:
+    #         dict["registered_at"] = self.registered_at.strfttime("%a, %-d %b %Y %X %z")
+
+        return dict
+

app/models/rental.py

@@ -1,4 +1,13 @@
 from app import db
+from datetime import datetime, timedelta
 
 class Rental(db.Model):
-    id = db.Column(db.Integer, primary_key=True)
+    rental_id = db.Column(db.Integer, primary_key=True, autoincrement=True)
+    customer_id = db.Column(db.Integer, db.ForeignKey('customer.customer_id'), primary_key=True,nullable=False)
+    video_id = db.Column(db.Integer, db.ForeignKey('video.video_id'), primary_key=True,nullable=False)
+    due_date = db.Column(db.DateTime, nullable=False, default=datetime.utcnow() + timedelta(days = 7))
+    #bool is truthy and falsey
+    checked_out = db.Column(db.Boolean, default=False)
+    #need to update check_in and check_out routes. Change check_in to True and False for checkout
+    #video = db.relationship("Video", back_populates="customers")
+    #customer = db.releationship("Customer", back_populates="videos")

app/models/video.py

@@ -1,4 +1,17 @@
 from app import db
 
 class Video(db.Model):
-    id = db.Column(db.Integer, primary_key=True)
+    video_id = db.Column(db.Integer, primary_key=True, autoincrement=True)
+    title = db.Column(db.String)
+    release_date = db.Column(db.DateTime)
+    #how many I own
+    total_inventory = db.Column(db.Integer)
+    #customers = db.relationship("Rental", back_populates="video")
+    #checked_out column
+    def to_dict(self):
+        return {
+            "id": self.video_id,
+            "title": self.title,
+            "release_date": self.release_date,
+            "total_inventory": self.total_inventory
+        }

app/rental_routes.py

@@ -0,0 +1,174 @@
+from flask.wrappers import Response
+from app import db
+from app.customer_routes import customers_bp
+from app.video_routes import video_bp
+from app.models.customer import Customer
+from app.models.video import Video
+from app.models.rental import Rental
+from flask import Blueprint, jsonify, request
+from datetime import datetime
+
+rentals_bp = Blueprint("rentals_bp", __name__, url_prefix="/rentals")
+
+
+@rentals_bp.route("/check-out", methods=["POST"])
+def rentals_checkout():
+    #{"c_id": [1], "v_id": [4]}
+    request_body = request.get_json()
+
+    # is this key string not in the request_body return 400
+    if "customer_id" not in request_body or "video_id" not in request_body:
+        return jsonify(), 400
+
+    # get instance of a customer and an instance of a video and return 404 if it's None
+    customer = Customer.query.get(request_body["customer_id"])
+    video = Video.query.get(request_body["video_id"])
+    if video is None or customer is None:
+        return jsonify(), 404
+
+    # filtering the video ID & checked_out attributes and count the records
+    rentals = Rental.query.filter_by(
+        video_id=video.video_id, checked_out=True).count()
+
+    # finding avaliable inventory
+    available_inventory = video.total_inventory - rentals
+
+    if available_inventory == 0:
+        return jsonify({"message": "Could not perform checkout"}), 400
+
+    # Instantiate a new instance for rental
+    new_rental = Rental(
+        video_id=video.video_id,
+        customer_id=customer.customer_id
+    )
+
+    # staging rental instance to database
+    db.session.add(new_rental)
+    # set rental instance to True
+    new_rental.checked_out = True
+    # commit to database
+    db.session.commit()
+
+    # count() - tells how many rentals are currently checked out
+    videos_checked_out = Rental.query.filter_by(
+        video_id=video.video_id, checked_out=True).count()
+
+    available_inventory = video.total_inventory - videos_checked_out
+
+    # return the response body and status code
+    return jsonify({
+        "video_id": new_rental.video_id,
+        "customer_id": new_rental.customer_id,
+        "videos_checked_out_count": videos_checked_out,
+        "available_inventory": available_inventory
+    }), 200
+
+
+@rentals_bp.route("/check-in", methods=["POST"])
+def rentals_checkin():
+    request_body = request.get_json()
+
+    # checks that the required request body parameters are in request
+    if "customer_id" not in request_body or "video_id" not in request_body:
+        return jsonify(), 400
+
+    # store customer/video instance into variables. If customer/video does not exist, returns 404
+    customer = Customer.query.get(request_body["customer_id"])
+    video = Video.query.get(request_body["video_id"])
+    if customer is None or video is None:
+        return jsonify(), 404
+
+    # query through Rental to find matching customer and video ids and return first on the list
+    rental = Rental.query.filter_by(
+        customer_id=customer.customer_id, video_id=video.video_id).first()
+    # (customer_id=customer.customer_id, video_id=video.video_id, checked_out=True).first() #this also passed the test
+
+    # "is" (compare location in memory) is 50% faster than "==" (comparing values)
+    if rental is None:
+        return jsonify({"message": f"No outstanding rentals for customer {customer.customer_id} and video {video.video_id}"}), 400
+
+    # rental.checked_out = True
+    db.session.commit()
+
+    # return response body
+    videos_checked_out = Rental.query.filter_by(
+        video_id=video.video_id, checked_out=False).count()
+
+    # finding avaiable inventory
+    available_inventory = video.total_inventory - videos_checked_out
+
+    return jsonify({
+        "video_id": video.video_id,
+        "customer_id": customer.customer_id,
+        "videos_checked_out_count": videos_checked_out,
+        "available_inventory": available_inventory
+    })
+
+
+@customers_bp.route("/<customer_id>/rentals", methods=["GET"])
+def customer_read(customer_id):
+    """ List the videos a customer currently has checked out """
+    request_body = request.get_json()
+
+    # checks to see if customer exists. If not, returns 404
+    customer = Customer.query.get(customer_id)
+    if customer is None:
+        return jsonify({"message": f"Customer {customer_id} was not found"}), 404
+
+    # sets up empty list to store a customer's checked out videos & iterates through customer.videos to retreive all videos a customer currently has
+    checked_out = []
+    for video in customer.videos:
+        checked_out.append(video)
+
+    # gets rental instance for each video a customer has
+    rentals = Rental.query.all()
+    customer_rentals = []
+    for video in checked_out:
+        for rental in rentals:
+            if video.video_id == rental.video_id and customer.customer_id == rental.customer_id:
+                customer_rentals.append(rental)
+
+    # create response body
+    response_body = []
+    for rental in customer_rentals:
+        response_body.append({
+            "release_date": video.release_date,
+            "title": video.title,
+            "due_date": rental.due_date
+        })
+    return jsonify(response_body)
+
+
+@video_bp.route("/<video_id>/rentals", methods=["GET"])
+def video_read(video_id):
+    """ List the customers who currently have the video checked out """
+    request_body = request.get_json()
+
+    # checks to see if video exists. If not, returns 404
+    video = Video.query.get(video_id)
+    if video is None:
+        return jsonify({"message": f"Video {video_id} was not found"}), 404
+
+    # sets up empty list to store the video's current customers & iterates through video.customers to retreive all customers that currently have the video
+    current_customers = []
+    for customer in video.customers:
+        current_customers.append(customer)
+
+    # gets rental instance for each customer a video has
+    rentals = Rental.query.all()
+    video_rentals = []
+    for customer in current_customers:
+        for rental in rentals:
+            if video.video_id == rental.video_id and customer.customer_id == rental.customer_id:
+                video_rentals.append(rental)
+
+    # create response body
+    response_body = []
+    for rental in video_rentals:
+        response_body.append({
+            "due_date": rental.due_date,
+            "name": customer.name,
+            "phone": customer.phone,
+            "postal_code": customer.postal_code
+        })
+    return jsonify(response_body)