import pathlib import typing import urllib.parse import aiohttp import quart.flask_patch from quart import ( Blueprint, render_template, redirect, url_for, session as http_session, ) import wtforms import flask_wtf from flask_babel import lazy_gettext as _l from .infra import client, selected_locale bp = Blueprint("invite", __name__) INVITE_SESSION_JID = "invite-session-jid" # https://play.google.com/store/apps/details?id=org.snikket.android&referrer={uri|urlescape}&pcampaignid=pcampaignidMKT-Other-global-all-co-prtnr-py-PartBadge-Mar2515-1 def apple_store_badge() -> str: locale = selected_locale() filename = "{}.svg".format(locale) static_path = pathlib.Path(__file__).parent / "static" / "img" / "apple" if (static_path / filename).exists(): return url_for("static", filename="img/apple/{}".format(filename)) return url_for("static", filename="img/apple/en.svg") @bp.context_processor def context() -> typing.Mapping[str, typing.Any]: return { "apple_store_badge": apple_store_badge, } @bp.route("/") async def view(id_: str) -> str: try: invite = await client.get_public_invite_by_id(id_) except aiohttp.ClientResponseError as exc: if exc.status == 404: # invite expired return await render_template("invite_invalid.html") raise play_store_url = ( "https://play.google.com/store/apps/details?" + urllib.parse.urlencode( ( ("id", "org.snikket.android"), ("referrer", invite.xmpp_uri), ("pcampaignid", "pcampaignidMKT-Other-global-all-co-prtnr-py-" "PartBadge-Mar2515-1"), ), ) ) apple_store_url = ( "https://apps.apple.com/us/app/tigase-messenger/id1153516838" ) return await render_template( "invite_view.html", invite=invite, play_store_url=play_store_url, apple_store_url=apple_store_url, invite_id=id_, ) class RegisterForm(flask_wtf.FlaskForm): # type:ignore localpart = wtforms.StringField( _l("Username"), ) password = wtforms.PasswordField( _l("Password"), ) password_confirm = wtforms.PasswordField( _l("Confirm password"), validators=[wtforms.validators.InputRequired(), wtforms.validators.EqualTo( "password", _l("The passwords must match") )] ) action_register = wtforms.SubmitField( _l("Create account") ) @bp.route("//register", methods=["GET", "POST"]) async def register(id_: str) -> typing.Union[str, quart.Response]: invite = await client.get_public_invite_by_id(id_) form = RegisterForm() if form.validate_on_submit(): # log the user in? show a guide? no idea. try: jid = await client.register_with_token( username=form.localpart.data, password=form.password.data, token=id_, ) except aiohttp.ClientResponseError as exc: if exc.status == 409: form.localpart.errors.append( _l("That user name is already taken") ) elif exc.status == 403: form.localpart.errors.append( _l("Registration was declined for unknown reasons") ) elif exc.status == 400: form.localpart.errors.append( _l("The user name was not valid") ) elif exc.status == 404: return redirect(url_for(".view", id_=id_)) else: raise else: http_session[INVITE_SESSION_JID] = jid return redirect(url_for(".success")) return await render_template( "invite_register.html", invite=invite, form=form, ) @bp.route("/success", methods=["GET", "POST"]) async def success() -> str: return await render_template( "invite_success.html", jid=http_session.get(INVITE_SESSION_JID, ""), ) @bp.route("/-") async def index() -> quart.Response: return redirect(url_for("index"))