flifloo/cyberplanificateur
Archived
1
0
Fork 0
Code Activity

Setup basic streams start

Browse source
This commit is contained in:
Ethanell 2019-05-01 16:59:30 +02:00
parent f81ad0ecd5
commit e9eaf9d1fd
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
app/routes.py
View file

@ -4,7 +4,8 @@ from flask_login import current_user, login_user, logout_user, login_required
from app.forms import LoginForm, RegistrationForm, TrelloAPIForm from app.forms import LoginForm, RegistrationForm, TrelloAPIForm
from app.models import User, TwitterAPI, Tweets, TrelloAPI, Boards from app.models import User, TwitterAPI, Tweets, TrelloAPI, Boards
from werkzeug.urls import url_parse from werkzeug.urls import url_parse
import tweepy, trello, twitter_credentials, trello_credentials from config import basedir
import tweepy, trello, twitter_credentials, trello_credentials, subprocess
@app.route("/login", methods=["GET", "POST"]) @app.route("/login", methods=["GET", "POST"])
def login(): def login():
@ -128,6 +129,8 @@ def dashboard():
else: else:
db.session.add(Tweets(user = current_user, statu_id = tweet, slots = 0, slots_max = slots, keywords = str(request.form["keywords"].split(",")))) db.session.add(Tweets(user = current_user, statu_id = tweet, slots = 0, slots_max = slots, keywords = str(request.form["keywords"].split(","))))
db.session.commit() db.session.commit()
if str(subprocess.check_output(["screen", "-list"])).find(f"stream-{str(current_user.id)}") == -1:
subprocess.check_call(["screen", "-S", f"stream-{str(current_user.id)}", "-d", "-m", "python3.7", "stream.py", str(current_user.id)], cwd = basedir)
return redirect(url_for("dashboard")) return redirect(url_for("dashboard"))
for t in Tweets.query.filter_by(user = current_user): for t in Tweets.query.filter_by(user = current_user):