2011-07-31 23:55:18 +02:00
|
|
|
from collections import defaultdict
|
|
|
|
|
2011-07-30 15:46:53 +02:00
|
|
|
from flask import (Flask, session, request, redirect, url_for, render_template,
|
|
|
|
flash)
|
|
|
|
from flaskext.mail import Mail, Message
|
2011-07-23 18:45:40 +02:00
|
|
|
|
|
|
|
# local modules
|
|
|
|
from models import db, Project, Person, Bill
|
2011-07-30 15:46:53 +02:00
|
|
|
from forms import ProjectForm, AuthenticationForm, BillForm, MemberForm, InviteForm
|
2011-07-23 18:45:40 +02:00
|
|
|
from utils import get_billform_for, requires_auth
|
|
|
|
|
|
|
|
# create the application, initialize stuff
|
|
|
|
app = Flask(__name__)
|
2011-08-09 19:22:09 +02:00
|
|
|
app.config.from_object("default_settings")
|
2011-07-30 15:46:53 +02:00
|
|
|
mail = Mail()
|
2011-07-23 18:45:40 +02:00
|
|
|
|
2011-07-29 15:44:15 +02:00
|
|
|
@app.route("/")
|
|
|
|
def home():
|
|
|
|
project_form = ProjectForm()
|
|
|
|
auth_form = AuthenticationForm()
|
2011-07-31 00:53:12 +02:00
|
|
|
return render_template("home.html", project_form=project_form,
|
|
|
|
auth_form=auth_form, session=session)
|
2011-07-29 15:44:15 +02:00
|
|
|
|
|
|
|
@app.route("/authenticate", methods=["GET", "POST"])
|
|
|
|
def authenticate(redirect_url=None):
|
2011-07-23 18:45:40 +02:00
|
|
|
form = AuthenticationForm()
|
2011-07-29 15:44:15 +02:00
|
|
|
|
2011-07-30 01:32:55 +02:00
|
|
|
project_id = form.id.data
|
|
|
|
|
|
|
|
redirect_url = redirect_url or url_for("list_bills", project_id=project_id)
|
|
|
|
project = Project.query.get(project_id)
|
2011-08-09 17:29:44 +02:00
|
|
|
create_project = False # We don't want to create the project by default
|
2011-07-30 01:32:55 +02:00
|
|
|
if not project:
|
2011-08-09 17:29:44 +02:00
|
|
|
# But if the user try to connect to an unexisting project, we will
|
|
|
|
# propose him a link to the creation form.
|
|
|
|
create_project = project_id
|
2011-07-30 01:32:55 +02:00
|
|
|
|
2011-08-09 19:28:50 +02:00
|
|
|
else:
|
|
|
|
# if credentials are already in session, redirect
|
|
|
|
if project_id in session and project.password == session[project_id]:
|
|
|
|
return redirect(redirect_url)
|
|
|
|
|
|
|
|
# else process the form
|
|
|
|
if request.method == "POST":
|
|
|
|
if form.validate():
|
|
|
|
if not form.password.data == project.password:
|
|
|
|
form.errors['password'] = ["The password is not the right one"]
|
|
|
|
else:
|
|
|
|
# maintain a list of visited projects
|
|
|
|
if "projects" not in session:
|
|
|
|
session["projects"] = []
|
|
|
|
# add the project on the top of the list
|
|
|
|
session["projects"].insert(0, (project_id, project.name))
|
|
|
|
session[project_id] = form.password.data
|
|
|
|
session.update()
|
|
|
|
return redirect(redirect_url)
|
2011-07-29 15:44:15 +02:00
|
|
|
|
2011-08-09 17:29:44 +02:00
|
|
|
return render_template("authenticate.html", form=form,
|
|
|
|
create_project=create_project)
|
2011-07-23 19:11:24 +02:00
|
|
|
|
|
|
|
@app.route("/create", methods=["GET", "POST"])
|
|
|
|
def create_project():
|
2011-07-26 16:03:00 +02:00
|
|
|
form = ProjectForm()
|
2011-07-23 19:11:24 +02:00
|
|
|
if request.method == "GET" and 'project_id' in request.values:
|
|
|
|
form.name.data = request.values['project_id']
|
|
|
|
|
|
|
|
if request.method == "POST":
|
|
|
|
if form.validate():
|
|
|
|
# save the object in the db
|
|
|
|
project = form.save()
|
|
|
|
db.session.add(project)
|
|
|
|
db.session.commit()
|
|
|
|
|
|
|
|
# create the session object (authenticate)
|
|
|
|
session[project.id] = project.password
|
|
|
|
session.update()
|
|
|
|
|
|
|
|
# redirect the user to the next step (invite)
|
|
|
|
return redirect(url_for("invite", project_id=project.id))
|
|
|
|
|
|
|
|
return render_template("create_project.html", form=form)
|
|
|
|
|
2011-08-09 23:48:13 +02:00
|
|
|
@app.route("/exit")
|
|
|
|
def exit():
|
2011-07-29 15:44:15 +02:00
|
|
|
# delete the session
|
2011-07-30 01:32:55 +02:00
|
|
|
session.clear()
|
|
|
|
return redirect(url_for("home"))
|
2011-07-29 15:44:15 +02:00
|
|
|
|
2011-07-30 15:46:53 +02:00
|
|
|
@app.route("/<string:project_id>/invite", methods=["GET", "POST"])
|
2011-07-23 19:11:24 +02:00
|
|
|
@requires_auth
|
|
|
|
def invite(project):
|
2011-07-30 15:46:53 +02:00
|
|
|
|
|
|
|
form = InviteForm()
|
|
|
|
|
|
|
|
if request.method == "POST":
|
|
|
|
if form.validate():
|
|
|
|
# send the email
|
|
|
|
|
|
|
|
message_body = render_template("invitation_mail",
|
|
|
|
email=project.contact_email, project=project)
|
|
|
|
|
2011-08-09 23:48:13 +02:00
|
|
|
message_title = "You have been invited to share your"\
|
|
|
|
+ " expenses for %s" % project.name
|
2011-07-30 15:46:53 +02:00
|
|
|
msg = Message(message_title,
|
|
|
|
body=message_body,
|
2011-08-09 23:48:13 +02:00
|
|
|
recipients=[email.strip()
|
|
|
|
for email in form.emails.data.split(",")])
|
2011-07-30 15:46:53 +02:00
|
|
|
mail.send(msg)
|
|
|
|
return redirect(url_for("list_bills", project_id=project.id))
|
|
|
|
|
|
|
|
return render_template("send_invites.html", form=form, project=project)
|
2011-07-23 19:11:24 +02:00
|
|
|
|
|
|
|
@app.route("/<string:project_id>/")
|
|
|
|
@requires_auth
|
|
|
|
def list_bills(project):
|
2011-08-09 18:05:55 +02:00
|
|
|
bills = Bill.query.join(Person, Project)\
|
|
|
|
.filter(Bill.payer_id == Person.id)\
|
|
|
|
.filter(Person.project_id == Project.id)\
|
|
|
|
.filter(Project.id == project.id)\
|
|
|
|
.order_by(Bill.date.desc())
|
2011-07-23 19:11:24 +02:00
|
|
|
return render_template("list_bills.html",
|
2011-07-31 23:55:18 +02:00
|
|
|
bills=bills, project=project,
|
|
|
|
member_form=MemberForm(project),
|
|
|
|
bill_form=get_billform_for(project)
|
|
|
|
)
|
2011-07-23 20:36:13 +02:00
|
|
|
|
|
|
|
@app.route("/<string:project_id>/members/add", methods=["GET", "POST"])
|
|
|
|
@requires_auth
|
|
|
|
def add_member(project):
|
|
|
|
# FIXME manage form errors on the list_bills page
|
|
|
|
form = MemberForm(project)
|
|
|
|
if request.method == "POST":
|
|
|
|
if form.validate():
|
|
|
|
db.session.add(Person(name=form.name.data, project=project))
|
|
|
|
db.session.commit()
|
|
|
|
return redirect(url_for("list_bills", project_id=project.id))
|
|
|
|
return render_template("add_member.html", form=form, project=project)
|
2011-07-23 18:45:40 +02:00
|
|
|
|
2011-07-31 23:55:18 +02:00
|
|
|
@app.route("/<string:project_id>/members/<int:member_id>/delete", methods=["GET", "POST"])
|
|
|
|
@requires_auth
|
|
|
|
def remove_member(project, member_id):
|
|
|
|
person = Person.query.get_or_404(member_id)
|
|
|
|
if person.project == project:
|
2011-08-09 19:34:46 +02:00
|
|
|
if not person.is_used():
|
|
|
|
db.session.delete(person)
|
|
|
|
db.session.commit()
|
|
|
|
flash("User '%s' has been removed" % person.name)
|
|
|
|
else:
|
|
|
|
person.activated = False
|
|
|
|
db.session.commit()
|
|
|
|
flash("User '%s' has been desactivated" % person.name)
|
2011-07-31 23:55:18 +02:00
|
|
|
return redirect(url_for("list_bills", project_id=project.id))
|
|
|
|
|
2011-07-23 18:45:40 +02:00
|
|
|
@app.route("/<string:project_id>/add", methods=["GET", "POST"])
|
|
|
|
@requires_auth
|
|
|
|
def add_bill(project):
|
2011-07-31 23:55:18 +02:00
|
|
|
form = get_billform_for(project)
|
2011-07-23 18:45:40 +02:00
|
|
|
if request.method == 'POST':
|
|
|
|
if form.validate():
|
2011-07-31 00:41:28 +02:00
|
|
|
db.session.add(form.save())
|
2011-07-23 18:45:40 +02:00
|
|
|
db.session.commit()
|
2011-07-31 00:41:28 +02:00
|
|
|
|
2011-07-23 18:45:40 +02:00
|
|
|
flash("The bill have been added")
|
2011-07-31 00:41:28 +02:00
|
|
|
return redirect(url_for('list_bills', project_id=project.id))
|
2011-07-23 18:45:40 +02:00
|
|
|
|
|
|
|
return render_template("add_bill.html", form=form, project=project)
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/<string:project_id>/compute")
|
|
|
|
@requires_auth
|
|
|
|
def compute_bills(project):
|
|
|
|
"""Compute the sum each one have to pay to each other and display it"""
|
2011-07-31 23:55:18 +02:00
|
|
|
return render_template("compute_bills.html", project=project)
|
2011-07-23 18:45:40 +02:00
|
|
|
|
|
|
|
|
|
|
|
@app.route("/<string:project_id>/reset")
|
|
|
|
@requires_auth
|
|
|
|
def reset_bills(project):
|
|
|
|
"""Reset the list of bills"""
|
2011-07-23 19:11:24 +02:00
|
|
|
# FIXME replace with the archive feature
|
2011-07-23 18:45:40 +02:00
|
|
|
# get all the bills which are not processed
|
|
|
|
bills = Bill.query.filter(Bill.processed == False)
|
|
|
|
for bill in bills:
|
|
|
|
bill.processed = True
|
|
|
|
db.session.commit()
|
|
|
|
|
|
|
|
return redirect(url_for('list_bills'))
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/<string:project_id>/delete/<int:bill_id>")
|
|
|
|
@requires_auth
|
|
|
|
def delete_bill(project, bill_id):
|
|
|
|
Bill.query.filter(Bill.id == bill_id).delete()
|
|
|
|
BillOwer.query.filter(BillOwer.bill_id == bill_id).delete()
|
|
|
|
db.session.commit()
|
|
|
|
flash("the bill was deleted")
|
|
|
|
|
|
|
|
return redirect(url_for('list_bills'))
|
|
|
|
|
|
|
|
@app.route("/debug/")
|
|
|
|
def debug():
|
|
|
|
from ipdb import set_trace; set_trace()
|
|
|
|
return render_template("debug.html")
|
|
|
|
|
|
|
|
|
|
|
|
def main():
|
2011-07-30 15:46:53 +02:00
|
|
|
# db
|
2011-07-23 18:45:40 +02:00
|
|
|
db.init_app(app)
|
|
|
|
db.app = app
|
|
|
|
db.create_all()
|
|
|
|
|
2011-07-30 15:46:53 +02:00
|
|
|
# mail
|
|
|
|
mail.init_app(app)
|
|
|
|
|
2011-07-23 18:45:40 +02:00
|
|
|
app.run(host="0.0.0.0", debug=True)
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
main()
|