mirror of
https://github.com/creyD/creyPY.git
synced 2026-04-13 11:50:31 +02:00
Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d471b86a25 | ||
|
|
aa99fc6226 | ||
|
|
30a5e417eb | ||
|
|
1f5ba9210f | ||
|
|
f805b3f508 |
2
.gitignore
vendored
2
.gitignore
vendored
@@ -158,3 +158,5 @@ cython_debug/
|
|||||||
# and can be added to the global gitignore or merged into this file. For a more nuclear
|
# and can be added to the global gitignore or merged into this file. For a more nuclear
|
||||||
# option (not recommended) you can uncomment the following to ignore the entire idea folder.
|
# option (not recommended) you can uncomment the following to ignore the entire idea folder.
|
||||||
#.idea/
|
#.idea/
|
||||||
|
|
||||||
|
.DS_*
|
||||||
|
|||||||
@@ -1,2 +1,3 @@
|
|||||||
from .auth0 import * # noqa
|
from .auth0 import * # noqa
|
||||||
from .stripe import * # noqa
|
from .stripe import * # noqa
|
||||||
|
from .aws import * # noqa
|
||||||
|
|||||||
@@ -145,3 +145,21 @@ def password_change_mail(email: str) -> bool:
|
|||||||
if re.status_code != 200:
|
if re.status_code != 200:
|
||||||
raise HTTPException(re.status_code, re.json())
|
raise HTTPException(re.status_code, re.json())
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
|
||||||
|
def user_password_change_ticket(user_id: str) -> str:
|
||||||
|
re = requests.post(
|
||||||
|
f"https://{AUTH0_DOMAIN}/api/v2/tickets/password-change",
|
||||||
|
headers={"Authorization": f"Bearer {get_management_token()}"},
|
||||||
|
json={
|
||||||
|
"user_id": user_id,
|
||||||
|
"client_id": AUTH0_CLIENT_ID,
|
||||||
|
"ttl_sec": 0,
|
||||||
|
"mark_email_as_verified": False,
|
||||||
|
"includeEmailInRedirect": False,
|
||||||
|
},
|
||||||
|
timeout=5,
|
||||||
|
)
|
||||||
|
if re.status_code != 201:
|
||||||
|
raise HTTPException(re.status_code, re.json())
|
||||||
|
return re.json()["ticket"]
|
||||||
|
|||||||
1
creyPY/services/aws/__init__.py
Normal file
1
creyPY/services/aws/__init__.py
Normal file
@@ -0,0 +1 @@
|
|||||||
|
from .email import * # noqa
|
||||||
32
creyPY/services/aws/email.py
Normal file
32
creyPY/services/aws/email.py
Normal file
@@ -0,0 +1,32 @@
|
|||||||
|
import os
|
||||||
|
|
||||||
|
import boto3
|
||||||
|
from botocore.exceptions import ClientError
|
||||||
|
|
||||||
|
AWS_CLIENT_ID = os.getenv("AWS_CLIENT_ID")
|
||||||
|
AWS_CLIENT_SECRET = os.getenv("AWS_CLIENT_SECRET")
|
||||||
|
AWS_SENDER_EMAIL = os.getenv("AWS_SENDER_EMAIL")
|
||||||
|
AWS_REGION = os.getenv("AWS_REGION", "eu-central-1")
|
||||||
|
|
||||||
|
|
||||||
|
async def send_email_ses(recipient_email, subject, html_body):
|
||||||
|
ses_client = boto3.client(
|
||||||
|
"ses",
|
||||||
|
aws_access_key_id=AWS_CLIENT_ID,
|
||||||
|
aws_secret_access_key=AWS_CLIENT_SECRET,
|
||||||
|
region_name=AWS_REGION,
|
||||||
|
)
|
||||||
|
email_message = {
|
||||||
|
"Source": AWS_SENDER_EMAIL,
|
||||||
|
"Destination": {"ToAddresses": [recipient_email]},
|
||||||
|
"Message": {
|
||||||
|
"Subject": {"Data": subject, "Charset": "UTF-8"},
|
||||||
|
"Body": {"Html": {"Data": html_body, "Charset": "UTF-8"}},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
try:
|
||||||
|
response = ses_client.send_email(**email_message)
|
||||||
|
return response["MessageId"]
|
||||||
|
except ClientError as e:
|
||||||
|
return None
|
||||||
@@ -1 +1 @@
|
|||||||
stripe==12.2.0 # Stripe
|
stripe==12.3.0 # Stripe
|
||||||
|
|||||||
Reference in New Issue
Block a user