dev box & FBK so cutegit add .
This commit is contained in:
pictures2333
parent
f2fbba44fe
commit
dc98b7491f
4
.gitignore
vendored
4
.gitignore
vendored
@ -1,2 +1,2 @@
|
||||
__pycache__
|
||||
.env
|
||||
__pycache__
|
||||
*.env
|
||||
86
app.py
86
app.py
@ -1,44 +1,44 @@
|
||||
from flask import Flask
|
||||
from dotenv import load_dotenv
|
||||
load_dotenv()
|
||||
import os
|
||||
from sqlalchemy import create_engine
|
||||
from pgclass import Base, SQLarticle
|
||||
# blueprints
|
||||
from blueprints.article import article
|
||||
|
||||
# Global Variables
|
||||
PG_HOST = os.getenv("PG_HOST")
|
||||
PG_PORT = os.getenv("PG_PORT")
|
||||
PG_NAME = os.getenv("PG_NAME")
|
||||
PG_USER = os.getenv("PG_USER")
|
||||
PG_PASS = os.getenv("PG_PASS")
|
||||
JWT_KEY = os.getenv("JWT_KEY")
|
||||
|
||||
# Postgresql
|
||||
engine = create_engine('postgresql+psycopg2://%s:%s@%s:%s/%s'%(PG_USER, PG_PASS, PG_HOST, PG_PORT, PG_NAME))
|
||||
Base.metadata.create_all(engine)
|
||||
|
||||
# shared class
|
||||
class shared():
|
||||
def __init__(self, engine):
|
||||
self.engine = engine
|
||||
self.SQLarticle = SQLarticle
|
||||
sh = shared(engine)
|
||||
|
||||
# flask app
|
||||
app = Flask(__name__)
|
||||
app.config["SECRET_KEY"] = os.urandom(64)
|
||||
app.shared_resource = sh
|
||||
|
||||
# register blueprints
|
||||
app.register_blueprint(article, url_prefix = "/article")
|
||||
|
||||
# index
|
||||
@app.route("/", methods = ["GET", "POST"])
|
||||
def index():
|
||||
return "Hello, World!"
|
||||
|
||||
# app run
|
||||
if __name__ == "__main__":
|
||||
from flask import Flask
|
||||
# from dotenv import load_dotenv
|
||||
# load_dotenv()
|
||||
import os
|
||||
from sqlalchemy import create_engine
|
||||
from pgclass import Base, SQLarticle
|
||||
# blueprints
|
||||
from blueprints.article import article
|
||||
|
||||
# Global Variables
|
||||
PG_HOST = os.getenv("PG_HOST")
|
||||
PG_PORT = os.getenv("PG_PORT")
|
||||
PG_NAME = os.getenv("PG_NAME")
|
||||
PG_USER = os.getenv("PG_USER")
|
||||
PG_PASS = os.getenv("PG_PASS")
|
||||
JWT_KEY = os.getenv("JWT_KEY")
|
||||
|
||||
# Postgresql
|
||||
engine = create_engine('postgresql+psycopg2://%s:%s@%s:%s/%s'%(PG_USER, PG_PASS, PG_HOST, PG_PORT, PG_NAME))
|
||||
Base.metadata.create_all(engine)
|
||||
|
||||
# shared class
|
||||
class shared():
|
||||
def __init__(self, engine):
|
||||
self.engine = engine
|
||||
self.SQLarticle = SQLarticle
|
||||
sh = shared(engine)
|
||||
|
||||
# flask app
|
||||
app = Flask(__name__)
|
||||
app.config["SECRET_KEY"] = os.urandom(64)
|
||||
app.shared_resource = sh
|
||||
|
||||
# register blueprints
|
||||
app.register_blueprint(article, url_prefix = "/article")
|
||||
|
||||
# index
|
||||
@app.route("/", methods = ["GET", "POST"])
|
||||
def index():
|
||||
return "Hello, World!"
|
||||
|
||||
# app run
|
||||
if __name__ == "__main__":
|
||||
app.run(host="0.0.0.0", port=5000, debug=False)
|
||||
@ -1,110 +1,110 @@
|
||||
from flask import Blueprint, current_app, request, jsonify
|
||||
import hashlib
|
||||
import time
|
||||
from sqlalchemy.orm import sessionmaker
|
||||
from sqlalchemy import desc
|
||||
|
||||
"""
|
||||
TODO:
|
||||
- Image & Video
|
||||
- IG post
|
||||
- LOG
|
||||
"""
|
||||
|
||||
article = Blueprint('article', __name__)
|
||||
|
||||
# 匿名文列表
|
||||
@article.route('/list', methods = ["GET"])
|
||||
def listing():
|
||||
# variables
|
||||
rst = int(request.args.get("start"))
|
||||
count = int(request.args.get("count"))
|
||||
|
||||
# db
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
|
||||
# get ctx
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark).order_by(desc(table.id)).filter(table.mark == 'visible').offset(rst).limit(count).all()
|
||||
|
||||
# mapping
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4]} for r in res ]
|
||||
|
||||
return jsonify(res)
|
||||
|
||||
# 獲取指定文章
|
||||
@article.route("/get/<int:id>", methods = ["GET"])
|
||||
def getarticle(id:int):
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
|
||||
# get ctx
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark).filter(table.id == id).filter(table.mark == 'visible').all()
|
||||
|
||||
# mapping
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4]} for r in res ]
|
||||
|
||||
return jsonify(res)
|
||||
|
||||
# 上傳文章
|
||||
@article.route("/post", methods = ["POST"])
|
||||
def posting():
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
|
||||
# content
|
||||
ctx = str(request.json["ctx"])
|
||||
if ctx is None: return "No brain no content"
|
||||
|
||||
# hash
|
||||
seed = ctx + str(time.time())
|
||||
hash = hashlib.sha256(seed.encode()).hexdigest()
|
||||
|
||||
# file processing
|
||||
|
||||
# ig posting
|
||||
igid = None
|
||||
|
||||
# mark
|
||||
mark = "visible"
|
||||
|
||||
# pg commit
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
data = table(hash = hash, ctx = ctx, igid = igid, mark = mark)
|
||||
session.add(data)
|
||||
session.commit()
|
||||
|
||||
# pg getdata
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark).filter(table.hash == hash).all()
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4]} for r in res ]
|
||||
|
||||
session.close()
|
||||
return jsonify(res)
|
||||
|
||||
# 只有發文者可以看到的獲取指定文章
|
||||
# 只有發文者可以做到的刪除文章
|
||||
@article.route("/own/<sha256>", methods = ["GET", "DELETE"])
|
||||
def owner_getarticle(sha256:str):
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
|
||||
# 獲取指定文章
|
||||
if request.method == "GET":
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark, table.hash).filter(table.hash == sha256).all()
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4], "hash":r[5]} for r in res ]
|
||||
return jsonify(res)
|
||||
# 刪除指定文章
|
||||
elif request.method == "DELETE":
|
||||
res = session.query(table).filter(table.hash == sha256).first()
|
||||
session.delete(res)
|
||||
session.commit()
|
||||
return "OK", 200
|
||||
|
||||
from flask import Blueprint, current_app, request, jsonify
|
||||
import hashlib
|
||||
import time
|
||||
from sqlalchemy.orm import sessionmaker
|
||||
from sqlalchemy import desc
|
||||
|
||||
"""
|
||||
TODO:
|
||||
- Image & Video
|
||||
- IG post
|
||||
- LOG
|
||||
"""
|
||||
|
||||
article = Blueprint('article', __name__)
|
||||
|
||||
# 匿名文列表
|
||||
@article.route('/list', methods = ["GET"])
|
||||
def listing():
|
||||
# variables
|
||||
rst = int(request.args.get("start"))
|
||||
count = int(request.args.get("count"))
|
||||
|
||||
# db
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
|
||||
# get ctx
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark).order_by(desc(table.id)).filter(table.mark == 'visible').offset(rst).limit(count).all()
|
||||
|
||||
# mapping
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4]} for r in res ]
|
||||
|
||||
return jsonify(res)
|
||||
|
||||
# 獲取指定文章
|
||||
@article.route("/get/<int:id>", methods = ["GET"])
|
||||
def getarticle(id:int):
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
|
||||
# get ctx
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark).filter(table.id == id).filter(table.mark == 'visible').all()
|
||||
|
||||
# mapping
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4]} for r in res ]
|
||||
|
||||
return jsonify(res)
|
||||
|
||||
# 上傳文章
|
||||
@article.route("/post", methods = ["POST"])
|
||||
def posting():
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
|
||||
# content
|
||||
ctx = str(request.json["ctx"])
|
||||
if ctx is None: return "No brain no content"
|
||||
|
||||
# hash
|
||||
seed = ctx + str(time.time())
|
||||
hash = hashlib.sha256(seed.encode()).hexdigest()
|
||||
|
||||
# file processing
|
||||
|
||||
# ig posting
|
||||
igid = None
|
||||
|
||||
# mark
|
||||
mark = "visible"
|
||||
|
||||
# pg commit
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
data = table(hash = hash, ctx = ctx, igid = igid, mark = mark)
|
||||
session.add(data)
|
||||
session.commit()
|
||||
|
||||
# pg getdata
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark).filter(table.hash == hash).all()
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4]} for r in res ]
|
||||
|
||||
session.close()
|
||||
return jsonify(res)
|
||||
|
||||
# 只有發文者可以看到的獲取指定文章
|
||||
# 只有發文者可以做到的刪除文章
|
||||
@article.route("/own/<sha256>", methods = ["GET", "DELETE"])
|
||||
def owner_getarticle(sha256:str):
|
||||
db = current_app.shared_resource.engine
|
||||
Session = sessionmaker(bind=db)
|
||||
session = Session()
|
||||
table = current_app.shared_resource.SQLarticle
|
||||
|
||||
# 獲取指定文章
|
||||
if request.method == "GET":
|
||||
res = session.query(table.id, table.ctx, table.igid, table.created_at, table.mark, table.hash).filter(table.hash == sha256).all()
|
||||
res = [ {"id":r[0], "ctx":r[1], "igid":r[2], "created_at":r[3], "mark":r[4], "hash":r[5]} for r in res ]
|
||||
return jsonify(res)
|
||||
# 刪除指定文章
|
||||
elif request.method == "DELETE":
|
||||
res = session.query(table).filter(table.hash == sha256).first()
|
||||
session.delete(res)
|
||||
session.commit()
|
||||
return "OK", 200
|
||||
|
||||
session.close()
|
||||
32
pgclass.py
32
pgclass.py
@ -1,17 +1,17 @@
|
||||
from sqlalchemy import Column, Integer, String, TIMESTAMP, func
|
||||
from sqlalchemy.ext.declarative import declarative_base
|
||||
|
||||
Base = declarative_base()
|
||||
|
||||
class SQLarticle(Base):
|
||||
__tablename__ = 'posts'
|
||||
|
||||
id = Column(Integer, primary_key=True)
|
||||
created_at = Column(TIMESTAMP(timezone=True), server_default=func.now())
|
||||
hash = Column(String)
|
||||
ctx = Column(String)
|
||||
igid = Column(String)
|
||||
mark = Column(String)
|
||||
|
||||
def __repr__(self):
|
||||
from sqlalchemy import Column, Integer, String, TIMESTAMP, func
|
||||
from sqlalchemy.ext.declarative import declarative_base
|
||||
|
||||
Base = declarative_base()
|
||||
|
||||
class SQLarticle(Base):
|
||||
__tablename__ = 'posts'
|
||||
|
||||
id = Column(Integer, primary_key=True)
|
||||
created_at = Column(TIMESTAMP(timezone=True), server_default=func.now())
|
||||
hash = Column(String)
|
||||
ctx = Column(String)
|
||||
igid = Column(String)
|
||||
mark = Column(String)
|
||||
|
||||
def __repr__(self):
|
||||
return f"<article(id={self.id}, hash={self.hash}, ctx={self.ctx}, igid={self.igid}, mark={self.mark}, created_at={self.created_at})>"
|
||||
@ -1,4 +1,4 @@
|
||||
sqlalchemy
|
||||
flask
|
||||
pyjwt
|
||||
sqlalchemy
|
||||
flask
|
||||
pyjwt
|
||||
psycopg2
|
||||
Loading…
Reference in New Issue
Block a user