-
Notifications
You must be signed in to change notification settings - Fork 0
/
app.py
92 lines (78 loc) · 2.79 KB
/
app.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import json
import logging
import os
import asyncio
import redis2
import aiohttp.web as web
from dotenv import load_dotenv
from twilio.base.exceptions import TwilioRestException
from twilio.rest import Client
class SMSHandler:
def __init__(self, account_sid, auth_token, number, redis_pool):
self.client = Client(account_sid, auth_token)
self.redis_pool = redis_pool
self.number = number
async def handle_request(self, request):
if request.method != 'POST':
return web.Response(status=405)
try:
data = await request.json()
except json.JSONDecodeError:
return web.Response(status=400)
if self.redis_pool.get(data['to']):
response = {'message': 'SMS already sent to this phone number'}
return web.json_response(response)
try:
message = await self.send_sms(data['to'], data['body'])
response = {'message_id': message.sid}
self.redis_pool.set(data['to'], 'sent', ex=3600)
return web.json_response(response)
except TwilioRestException as e:
logging.error(str(e))
return web.Response(status=500)
async def send_sms(self, to, body):
try:
message = self.client.messages.create(
body=body,
from_=self.number, # Replace with your Twilio phone number
to=to
)
return message
except TwilioRestException as e:
logging.error(str(e))
raise
async def start_server():
load_dotenv()
account_sid = os.getenv("TWILIO_ACCOUNT_SID")
auth_token = os.getenv("TWILIO_AUTH_TOKEN")
number = os.getenv("TWILIO_NUMBER")
redis_url = os.getenv('REDIS_URL')
redis_password = os.getenv('REDIS_PASSWORD')
try:
redis_pool = redis2.StrictRedis.from_url(
redis_url, decode_responses=True, max_connections=10, password=redis_password
)
except Exception as e:
logging.error(str(e))
raise e
logging.basicConfig(level=logging.INFO,
format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
handler = SMSHandler(account_sid, auth_token, number, redis_pool)
app = web.Application()
app.add_routes([web.post('/sms', handler.handle_request)])
port = int(os.getenv('PORT', 8081))
logging.info(f'SMS server is listening on port {port}...')
runner = web.AppRunner(app)
await runner.setup()
site = web.TCPSite(runner, '0.0.0.0', port)
await site.start()
if __name__ == '__main__':
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
try:
loop.run_until_complete(start_server())
loop.run_forever()
except KeyboardInterrupt:
pass
finally:
loop.close()