Sockets

Procfile

@@ -0,0 +1,2 @@
+release: python migrate.py
+web: gunicorn start:app --worker-class eventlet -w 1 --preload 

README.md

@@ -52,7 +52,7 @@ Since this app uses Pooled Connections, you may also want to set:
 
 ```
 DB_TIMEOUT=300 # 5 minutes
-DB_POOL=5
+DB_POOL=10
 ```
 
 _(see `database.py`)_

app.py

@@ -1,12 +1,30 @@
+from flask_wtf.csrf import CSRFProtect
 import os
 import config
 from flask import Flask
 from models.base_model import db
+from flask_socketio import SocketIO, emit
+
+# import logging
+# import redis
+# import gevent
+# from flask_sockets import Sockets
+
+# REDIS_URL = os.environ['REDIS_URL']
+# REDIS_CHAN = 'chat'
+
+# app.debug = 'DEBUG' in os.environ
+
+# sockets = Sockets(app)
+# redis = redis.from_url(REDIS_URL)
 
 web_dir = os.path.join(os.path.dirname(
     os.path.abspath(__file__)), 'instagram_web')
 
 app = Flask('NEXTAGRAM', root_path=web_dir)
+csrf = CSRFProtect(app)
+socketio = SocketIO(app)
+
 
 if os.getenv('FLASK_ENV') == 'production':
     app.config.from_object("config.ProductionConfig")

config.py

@@ -9,9 +9,21 @@ class Config(object):
         'SECRET_KEY') or os.urandom(32)
 
 
+S3_BUCKET = os.environ.get("S3_BUCKET")
+S3_KEY = os.environ.get("S3_KEY")
+S3_SECRET = os.environ.get("S3_SECRET_ACCESS_KEY")
+S3_LOCATION = 'http://{}.s3.amazonaws.com/'.format(S3_BUCKET)
+
+SECRET_KEY = os.environ.get('SECRET_KEY') or os.urandom(32)
+DEBUG = True
+PORT = 5000
+
+
 class ProductionConfig(Config):
     DEBUG = False
     ASSETS_DEBUG = False
+    GOOGLE_CLIENT_ID = os.getenv('GC_ID')
+    GOOGLE_CLIENT_SECRET = os.getenv('GC_SECRET')
 
 
 class StagingConfig(Config):
@@ -24,6 +36,9 @@ class DevelopmentConfig(Config):
     DEVELOPMENT = True
     DEBUG = True
     ASSETS_DEBUG = False
+    GOOGLE_CLIENT_ID = os.getenv('GC_ID')
+    GOOGLE_CLIENT_SECRET = os.getenv('GC_SECRET')
+
 
 class TestingConfig(Config):
     TESTING = True

helpers.py

@@ -0,0 +1,24 @@
+import boto3
+import botocore
+from config import S3_KEY, S3_SECRET, S3_BUCKET
+
+s3 = boto3.client(
+    "s3",
+    aws_access_key_id=S3_KEY,
+    aws_secret_access_key=S3_SECRET
+)
+
+
+def upload_file_to_s3(file, bucket_name):
+    try:
+        s3.upload_fileobj(
+            file,
+            bucket_name,
+            file.filename,
+            ExtraArgs={
+                "ACL": "public-read",
+                "ContentType": file.content_type
+            }
+        )
+    except Exception as e:
+        return e

instagram_api/blueprints/users/views.py

@@ -1,9 +1,21 @@
-from flask import Blueprint
+from flask import Blueprint, jsonify
+from models.user import User
+from playhouse.shortcuts import model_to_dict
+
 
 users_api_blueprint = Blueprint('users_api',
-                             __name__,
-                             template_folder='templates')
+                                __name__,
+                                template_folder='templates')
+
 
 @users_api_blueprint.route('/', methods=['GET'])
 def index():
-    return "USERS API"
+    users = User.select()
+    user_list = []
+    for user in users:
+        user = model_to_dict(user)
+        user_list.append(user)
+        # data = (user.__dict__)
+        # user_list.append(data['__data__'])
+
+    return jsonify(user_list)

instagram_web/__init__.py

@@ -1,19 +1,42 @@
 from app import app
-from flask import render_template
+from flask import render_template, redirect, url_for
 from instagram_web.blueprints.users.views import users_blueprint
+from instagram_web.blueprints.sessions.views import sessions_blueprint
 from flask_assets import Environment, Bundle
 from .util.assets import bundles
+from instagram_web.blueprints.images.views import images_blueprint
+from instagram_web.blueprints.donations.views import donations_blueprint
+from instagram_web.util.google_oauth import oauth
+from instagram_web.blueprints.follows.views import follows_blueprint
+from instagram_web.blueprints.monopoly.views import monopoly_blueprint
+from instagram_web.blueprints.mon_prop.views import mon_prop_blueprint
+from instagram_web.blueprints.cards.views import cards_blueprint
 
 assets = Environment(app)
 assets.register(bundles)
+oauth.init_app(app)
 
 app.register_blueprint(users_blueprint, url_prefix="/users")
+app.register_blueprint(sessions_blueprint, url_prefix="/sessions")
+app.register_blueprint(images_blueprint, url_prefix='/images')
+app.register_blueprint(donations_blueprint, url_prefix='/donations')
+app.register_blueprint(follows_blueprint, url_prefix='/follows')
+app.register_blueprint(monopoly_blueprint, url_prefix='/monopoly')
+app.register_blueprint(mon_prop_blueprint, url_prefix='/mon_prop')
+app.register_blueprint(cards_blueprint, url_prefix='/cards')
+
 
 @app.errorhandler(500)
 def internal_server_error(e):
     return render_template('500.html'), 500
 
 
+@app.errorhandler(404)
+def page_not_found(e):
+    return render_template('404.html'), 404
+
+
 @app.route("/")
 def home():
-    return render_template('home.html')
+    # return render_template('home.html')
+    return redirect(url_for('users.index'))

instagram_web/blueprints/cards/templates/cards/index.html

@@ -0,0 +1,19 @@
+<!DOCTYPE html>
+<html lang="en">
+
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Document</title>
+</head>
+
+<body>
+    {% for card in cards %}
+    <p>
+        <img src="{{card.image_url}}" width='300px' alt="">
+        {{card.category}}
+    </p>
+    {% endfor %}
+</body>
+
+</html>

instagram_web/blueprints/cards/templates/cards/new.html

@@ -0,0 +1,48 @@
+<!DOCTYPE html>
+<html lang="en">
+
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    {% assets "home_css" %}
+    <link rel="stylesheet" href="{{ ASSET_URL }}">
+    {% endassets %}
+    {% assets "home_js" %}
+    <script src="https://kit.fontawesome.com/1816c993a6.js" crossorigin="anonymous"></script>
+    <script type="text/javascript" src="{{ ASSET_URL }}"></script>
+    {% endassets %}
+    <title>New Property!</title>
+</head>
+
+<body>
+    {% with messages = get_flashed_messages(with_categories=true) %}
+    {% if messages %}
+    <div class=flashes>
+        {% for category, message in messages %}
+        <div class="alert alert-{{category}}">{{ message }}</div>
+        {% endfor %}
+    </div>
+    {% endif %}
+    {% endwith %}
+    <form action="{{url_for('cards.create')}}" method='POST' enctype="multipart/form-data">
+        <input type="hidden" name="csrf_token" value="{{ csrf_token() }}" />
+        <label for="description-input">Description:</label>
+        <input type="text" name="description" id='description-input'>
+        <label for="category-input">Category(chance or community)</label>
+        <input type="text" name='category' id='category-input'>
+        <hr>
+        <input type="file" name="image-file" id="image-file">
+        <img src="" width='300px' id='mon-preview' alt="">
+        <button type="submit">Submit</button>
+    </form>
+    <script>
+        $(document).ready(() => {
+            $('#image-file').change((e) => {
+                $('#mon-preview').attr('src', URL.createObjectURL(e.target.files[0]))
+                console.log(e.target)
+            })
+        })
+    </script>
+</body>
+
+</html>

instagram_web/blueprints/cards/views.py

@@ -0,0 +1,44 @@
+from flask import request, redirect, url_for, render_template, flash, Blueprint
+from models.cards import Card
+import json
+from flask_socketio import send, emit
+from app import socketio
+from flask_login import current_user
+from models.user import User
+from werkzeug.utils import secure_filename
+from helpers import upload_file_to_s3
+from config import S3_BUCKET
+
+cards_blueprint = Blueprint('cards', __name__, template_folder='templates')
+
+
+@cards_blueprint.route('/new')
+def new():
+    return render_template('cards/new.html')
+
+
+@cards_blueprint.route('/create', methods=['POST'])
+def create():
+    description = request.form.get('description')
+    category = request.form.get('category')
+    if 'image-file' not in request.files:
+        flash('no file was chosen!', 'warning')
+        return redirect(request.referrer)
+    file = request.files.get('image-file')
+    file_name = secure_filename(file.filename)
+    img_upload_err = str(upload_file_to_s3(file, S3_BUCKET))
+    new_card = Card(description=description,
+                    category=category, image=file_name)
+
+    if new_card.save():
+        flash('new card was saved', 'success')
+    else:
+        flash(f'saving failed, {img_upload_err}', 'danger')
+
+    return redirect(request.referrer)
+
+
+@cards_blueprint.route('/')
+def index():
+    cards = Card.select()
+    return render_template('cards/index.html', cards=cards)

instagram_web/blueprints/donations/templates/donations/new.html

@@ -0,0 +1,53 @@
+{% extends '_layout.html' %}
+
+{% block header %}
+<script src="https://js.braintreegateway.com/web/dropin/1.22.1/js/dropin.min.js"></script>
+{% endblock %}
+
+{% block content%}
+<main>
+    <form action="{{url_for('donations.create', image_id=image_id)}}" method="POST" id='payment_form'>
+        <input type="hidden" name='csrf_token' value="{{ csrf_token() }}">
+        <input type='hidden' id='payment_nonce' name='payment_nonce'>
+        <div id="dropin-container"></div>
+        <label for="amount">Donation amount:</label>
+        <div id='amount-warning'></div>
+        <input type="number" name='amount'>
+    </form>
+    <summary>
+        100% of the donations will go to user you have chosen to donate to.
+        <br>
+        Non-refundable.
+        <br>
+        Please be noted no exchange of goods is occuring.
+    </summary>
+    <hr>
+    <button class="btn-primary" id="dono-button">Confirm</button>
+</main>
+<div>
+    {{result}}
+</div>
+
+<script>
+    const button = document.querySelector('#dono-button');
+
+    braintree.dropin.create({
+        authorization: '{{client_token}}',
+        container: '#dropin-container'
+    }, function (createErr, instance) {
+        button.addEventListener('click', function () {
+            instance.requestPaymentMethod(function (err, payload) {
+                if (payload) {
+                    //implement amount checking please.
+                    $('#payment_nonce').val(payload.nonce)
+                    $('#payment_form').submit()
+                }
+                console.log(err)
+                console.log(payload)
+            });
+        });
+    });
+
+
+</script>
+{% endblock %}