mirror of
https://github.com/GSA/notifications-api.git
synced 2025-12-21 07:51:13 -05:00
@@ -28,6 +28,7 @@ from app.organization.organization_schema import (
|
|||||||
post_update_invited_org_user_status_schema,
|
post_update_invited_org_user_status_schema,
|
||||||
)
|
)
|
||||||
from app.schema_validation import validate
|
from app.schema_validation import validate
|
||||||
|
from app.utils import hilite
|
||||||
|
|
||||||
organization_invite_blueprint = Blueprint("organization_invite", __name__)
|
organization_invite_blueprint = Blueprint("organization_invite", __name__)
|
||||||
|
|
||||||
@@ -88,7 +89,12 @@ def invite_user_to_org(organization_id):
|
|||||||
organization_id,
|
organization_id,
|
||||||
ex=3600 * 24,
|
ex=3600 * 24,
|
||||||
)
|
)
|
||||||
|
current_app.logger.info(
|
||||||
|
hilite(f"STORING THIS ORGANIZATION ID IN REDIS {redis_store.get(redis_key)}")
|
||||||
|
)
|
||||||
|
current_app.logger.info(
|
||||||
|
hilite(f"URL: {os.environ['LOGIN_DOT_GOV_REGISTRATION_URL']}")
|
||||||
|
)
|
||||||
send_notification_to_queue(saved_notification, queue=QueueNames.NOTIFY)
|
send_notification_to_queue(saved_notification, queue=QueueNames.NOTIFY)
|
||||||
|
|
||||||
return jsonify(data=invited_org_user.serialize()), 201
|
return jsonify(data=invited_org_user.serialize()), 201
|
||||||
|
|||||||
@@ -25,6 +25,7 @@ from app.notifications.process_notifications import (
|
|||||||
send_notification_to_queue,
|
send_notification_to_queue,
|
||||||
)
|
)
|
||||||
from app.schemas import invited_user_schema
|
from app.schemas import invited_user_schema
|
||||||
|
from app.utils import hilite
|
||||||
|
|
||||||
service_invite = Blueprint("service_invite", __name__)
|
service_invite = Blueprint("service_invite", __name__)
|
||||||
|
|
||||||
@@ -80,6 +81,9 @@ def _create_service_invite(invited_user, invite_link_host):
|
|||||||
json.dumps(data),
|
json.dumps(data),
|
||||||
ex=3600 * 24,
|
ex=3600 * 24,
|
||||||
)
|
)
|
||||||
|
current_app.logger.info(
|
||||||
|
hilite(f"STORING ALL THIS IN REDIS FOR SERVICE INVITE {json.dumps(data)}")
|
||||||
|
)
|
||||||
send_notification_to_queue(saved_notification, queue=QueueNames.NOTIFY)
|
send_notification_to_queue(saved_notification, queue=QueueNames.NOTIFY)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -123,3 +123,11 @@ def get_reference_from_personalisation(personalisation):
|
|||||||
if personalisation:
|
if personalisation:
|
||||||
return personalisation.get("reference")
|
return personalisation.get("reference")
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
# Function used for debugging.
|
||||||
|
# Do print(hilite(message)) while debugging, then remove your print statements
|
||||||
|
def hilite(message):
|
||||||
|
ansi_green = "\033[32m"
|
||||||
|
ansi_reset = "\033[0m"
|
||||||
|
return f"{ansi_green}{message}{ansi_reset}"
|
||||||
|
|||||||
Reference in New Issue
Block a user