d61c08c7c7
Use DEBUG environment variable to run debug mode
117 lines
2.8 KiB
Python
117 lines
2.8 KiB
Python
import os
|
|
import sys
|
|
import uuid
|
|
|
|
import redis
|
|
from redis.exceptions import ConnectionError
|
|
|
|
from flask import abort, Flask, render_template, request
|
|
|
|
|
|
NO_SSL = os.environ.get('NO_SSL', False)
|
|
app = Flask(__name__)
|
|
if os.environ.get('DEBUG'):
|
|
app.debug = True
|
|
app.secret_key = os.environ.get('SECRET_KEY', 'Secret Key')
|
|
app.config.update(
|
|
dict(STATIC_URL=os.environ.get('STATIC_URL', 'static')))
|
|
|
|
if os.environ.get('REDIS_URL'):
|
|
redis_client = redis.StrictRedis.from_url(os.environ.get('REDIS_URL'))
|
|
else:
|
|
redis_host = os.environ.get('REDIS_HOST', 'localhost')
|
|
redis_port = os.environ.get('REDIS_PORT', 6379)
|
|
redis_db = os.environ.get('SNAPPASS_REDIS_DB', 0)
|
|
redis_client = redis.StrictRedis(
|
|
host=redis_host, port=redis_port, db=redis_db)
|
|
|
|
time_conversion = {
|
|
'week': 604800,
|
|
'day': 86400,
|
|
'hour': 3600
|
|
}
|
|
|
|
|
|
def check_redis_alive(fn):
|
|
def inner(*args, **kwargs):
|
|
try:
|
|
if fn.__name__ == 'main':
|
|
redis_client.ping()
|
|
return fn(*args, **kwargs)
|
|
except ConnectionError as e:
|
|
print('Failed to connect to redis! %s' % e.message)
|
|
if fn.__name__ == 'main':
|
|
sys.exit(0)
|
|
else:
|
|
return abort(500)
|
|
return inner
|
|
|
|
|
|
@check_redis_alive
|
|
def set_password(password, ttl):
|
|
key = uuid.uuid4().hex
|
|
redis_client.setex(key, ttl, password)
|
|
return key
|
|
|
|
|
|
@check_redis_alive
|
|
def get_password(key):
|
|
password = redis_client.get(key)
|
|
if password is not None:
|
|
password = password.decode('utf-8')
|
|
redis_client.delete(key)
|
|
return password
|
|
|
|
|
|
def clean_input():
|
|
"""
|
|
Make sure we're not getting bad data from the front end,
|
|
format data to be machine readable
|
|
"""
|
|
if 'password' not in request.form:
|
|
abort(400)
|
|
|
|
if 'ttl' not in request.form:
|
|
abort(400)
|
|
|
|
time_period = request.form['ttl'].lower()
|
|
if time_period not in time_conversion:
|
|
abort(400)
|
|
|
|
return time_conversion[time_period], request.form['password']
|
|
|
|
|
|
@app.route('/', methods=['GET'])
|
|
def index():
|
|
return render_template('set_password.html')
|
|
|
|
|
|
@app.route('/', methods=['POST'])
|
|
def handle_password():
|
|
ttl, password = clean_input()
|
|
key = set_password(password, ttl)
|
|
|
|
if NO_SSL:
|
|
base_url = request.url_root
|
|
else:
|
|
base_url = request.url_root.replace("http://", "https://")
|
|
link = base_url + key
|
|
return render_template('confirm.html', password_link=link)
|
|
|
|
|
|
@app.route('/<password_key>', methods=['GET'])
|
|
def show_password(password_key):
|
|
password = get_password(password_key)
|
|
if not password:
|
|
abort(404)
|
|
|
|
return render_template('password.html', password=password)
|
|
|
|
|
|
@check_redis_alive
|
|
def main():
|
|
app.run(host='0.0.0.0')
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|