Create video service

Author: ncsyvn

video_service/requirements.txt

@@ -0,0 +1,16 @@
+Flask==2.0.1
+Flask-And-Redis==1.0.0
+Flask-Cors==3.0.10
+Flask-JWT-Extended==3.24.0
+Flask-SQLAlchemy==2.5.1
+Flask-Migrate==3.1.0
+gunicorn==20.1.0
+Jinja2==3.0.1
+marshmallow==3.12.2
+greenlet==1.1.0
+SQLAlchemy==1.4.21
+mysqlclient==2.0.3
+Werkzeug==2.0.1
+pytz==2021.1
+MarkupSafe==2.0.1
+PyJWT==1.7.1

video_service/server.py

@@ -0,0 +1,9 @@
+from video_app.app import create_app
+
+app = create_app()
+if __name__ == '__main__':
+ """
+ Main Video Application
+ python manage.py
+ """
+ app.run(host='0.0.0.0', port=5012)

video_service/video_app/__init__.py

@@ -0,0 +1,61 @@
+import os
+from flask import jsonify
+from video_app.settings import ProdConfig, StgConfig
+
+CONFIG = ProdConfig if os.environ.get('ENV') == 'prd' else StgConfig
+
+
+def send_result(data: any = None, message: str = "OK", code: int = 200,
+ status: str = 'success', show: bool = False, duration: int = 0):
+ """
+ Args:
+ :param data: whatever you want
+ :param message: error message
+ :param code: 200 is success
+ :param status: error
+ :param show: show popup or not (useful for Frontend team)
+ :param duration: show popup for duration second
+ :return:
+ """
+ message_dict = {
+ "text": message,
+ "status": status,
+ "show": show,
+ "duration": duration,
+ }
+ res = {
+ "code": code,
+ "data": data,
+ "message": message_dict,
+ }
+
+ return jsonify(res), 200
+
+
+def send_error(data: any = None, message: str = "Error", code: int = 200,
+ status: str = 'error', show: bool = False, duration: int = 0):
+ """
+ Args:
+ :param data: whatever you want
+ :param message: error message
+ :param code: you can use 4xx
+ :param status: error
+ :param show: show popup or not (useful for Frontend team)
+ :param duration: show popup for duration second
+ :return:
+ """
+ message_dict = {
+ "text": message,
+ "status": status,
+ "show": show,
+ "duration": duration,
+ }
+ res = {
+ "code": code,
+ "data": data,
+ "message": message_dict,
+ }
+
+ return jsonify(res), code
+
+

video_service/video_app/api/helper.py

@@ -0,0 +1 @@
+from video_app.api.v1 import video

video_service/video_app/api/v1/__init__.py

@@ -0,0 +1,73 @@
+import json
+import uuid
+
+from flask import Blueprint, request
+from video_app.utils import logged_input, get_timestamp_now
+from video_app.validator import CreateVideoSchema, VideoSchema
+from video_app.models import Video
+from video_app.api.helper import send_error, send_result
+from video_app.extensions import db
+
+
+api = Blueprint('videos', __name__)
+
+
+@api.route('', methods=['GET'])
+def search_videos():
+ """
+ Search video api
+ Requests params:
+ keyword: string, optional
+ Returns:
+ list videos
+ """
+
+ keyword = request.args.get('keyword', '').strip()
+ videos = Video.query.filter(Video.title.ilike(f'%{keyword}%')).all()
+ videos_dumped = VideoSchema(many=True).dumps(videos)
+ return send_result(data=json.loads(videos_dumped))
+
+
+@api.route('', methods=['POST'])
+def create_new_video():
+ """
+ Create new video API.
+ Requests Body:
+ title: string, require
+ url: string, optional
+ thumbnail_url: string, optional
+ Returns:
+ id of new video
+ """
+
+ try:
+ json_req = request.get_json()
+ except Exception as ex:
+ return send_error(message="Request Body incorrect json format: " + str(ex), code=442)
+
+ logged_input(json.dumps(json_req))
+ if json_req is None:
+ return send_error(message='Please check your json requests', code=442)
+
+ # trim input body
+ json_body = {}
+ for key, value in json_req.items():
+ json_body.setdefault(key, str(value).strip())
+
+ # validate request body
+ is_not_validate = CreateVideoSchema().validate(json_body) # Dictionary show detail error fields
+ if is_not_validate:
+ return send_error(data=is_not_validate, message="Invalid params")
+
+ title = json_body.get("title")
+ url = json_body.get("url", "")
+ thumbnail_url = json_body.get("thumbnail_url", "")
+ _id = str(uuid.uuid4())
+ # Store video to db
+ new_video = Video(id=_id, title=title, url=url, thumbnail_url=thumbnail_url)
+ db.session.add(new_video)
+ db.session.commit()
+ data = {
+ "video_id": _id
+ }
+ return send_result(data)

video_service/video_app/api/v1/video.py

@@ -0,0 +1,41 @@
+# -*- coding: utf-8 -*-
+
+from flask import Flask
+from video_app.api.helper import CONFIG
+from video_app.extensions import db, migrate
+from .api import v1 as api_v1
+from video_app.models import Video # Must have to migrate db
+
+
+def create_app(config_object=CONFIG):
+ """
+ Init App
+ :param config_object:
+ :return:
+ """
+ app = Flask(__name__, static_url_path="", static_folder="./static-files")
+ app.config.from_object(config_object)
+ register_extensions(app)
+ register_blueprints(app)
+ return app
+
+
+def register_extensions(app):
+ """
+ Init extension
+ :param app:
+ :return:
+ """
+
+ db.app = app
+ db.init_app(app) # SQLAlchemy
+ migrate.init_app(app, db)
+
+
+def register_blueprints(app):
+ """
+ Init blueprint for api url
+ :param app:
+ :return:
+ """
+ app.register_blueprint(api_v1.video.api, url_prefix='/api/v1/videos')

video_service/video_app/app.py

@@ -0,0 +1,2 @@
+# coding: utf-8
+TIME_FORMAT_LOG = "[%Y-%b-%d %H:%M]"

video_service/video_app/enums.py

@@ -0,0 +1,18 @@
+import logging
+import os
+from flask_sqlalchemy import SQLAlchemy
+from flask_migrate import Migrate
+from logging.handlers import RotatingFileHandler
+
+
+# init SQLAlchemy
+db = SQLAlchemy()
+migrate = Migrate()
+
+os.makedirs("logs", exist_ok=True)
+app_log_handler = RotatingFileHandler('logs/app.log', maxBytes=1000000, backupCount=30, encoding="UTF-8")
+
+# logger
+logger = logging.getLogger('api')
+logger.setLevel(logging.DEBUG)
+logger.addHandler(app_log_handler)

video_service/video_app/extensions.py

@@ -0,0 +1,17 @@
+# coding: utf-8
+from sqlalchemy.dialects.mysql import INTEGER
+from video_app.extensions import db
+from video_app.utils import get_timestamp_now
+
+
+class Video(db.Model):
+ __tablename__ = 'video'
+
+ id = db.Column(db.String(50), primary_key=True)
+ title = db.Column(db.String(500), primary_key=True)
+ url = db.Column(db.String(1000))
+ thumbnail_url = db.Column(db.String(1000))
+ created_date = db.Column(INTEGER(unsigned=True), default=get_timestamp_now(), index=True)
+ modified_date = db.Column(INTEGER(unsigned=True), default=0)
+ is_deleted = db.Column(db.Boolean, default=0)
+ is_active = db.Column(db.Boolean, default=1)