You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
108 lines
3.3 KiB
108 lines
3.3 KiB
#!/usr/bin/env python3
|
|
|
|
import os
|
|
import urllib
|
|
from importlib import reload
|
|
import requests
|
|
import json
|
|
import pprint
|
|
import time
|
|
import MySQLdb
|
|
import datetime
|
|
import configparser
|
|
from flask import Flask, request
|
|
from flowroutenumbersandmessaging.flowroutenumbersandmessaging_client import FlowroutenumbersandmessagingClient
|
|
|
|
import sys
|
|
reload(sys)
|
|
#sys.setdefaultencoding('utf-8')
|
|
|
|
counter = 1
|
|
config = configparser.ConfigParser()
|
|
config.read('config.ini')
|
|
sqlhost = config.get("sql","sqlhost")
|
|
sqluser = config.get("sql","sqluser")
|
|
sqlpass = config.get("sql","sqlpass")
|
|
sqldb = config.get("sql","sqldb")
|
|
|
|
smsRate = 0.0040
|
|
|
|
basic_auth_user_name = config.get("flowroute","fr_access_key")
|
|
basic_auth_password = config.get("flowroute","fr_secret_key")
|
|
|
|
client = FlowroutenumbersandmessagingClient(basic_auth_user_name, basic_auth_password)
|
|
messages_controller = client.messages
|
|
|
|
#Flowroute API endpoint and reply SMS to be sent
|
|
fr_api_url = "https://api.flowroute.com/v2.1/messages"
|
|
|
|
############ Lets start our stuff
|
|
db = MySQLdb.connect(host=sqlhost, user=sqluser, passwd=sqlpass, db=sqldb)
|
|
|
|
app = Flask(__name__)
|
|
app.debug = True
|
|
|
|
@app.route('/inboundsms', methods=['POST'])
|
|
def inboundsms():
|
|
global counter
|
|
#extract attributes from POSTed JSON of inbound SMS
|
|
json_content = request.json
|
|
reply_to = json_content['data']['attributes']['from']
|
|
reply_from = json_content['data']['attributes']['to']
|
|
msg_id = json_content['data']['id']
|
|
body = json_content['data']['attributes']['body'].decode('utf-8')
|
|
|
|
logmysql(msg_id, json_content['data']['attributes']['timestamp'], 'inbound', reply_from, reply_to,json_content['data']['attributes']['amount_display'], body) # Lets log to our silly db.
|
|
|
|
pprint.pprint(body)
|
|
if body.lower() == u'count'.lower():
|
|
sendreply(reply_to, reply_from, "There have been " + str(counter) + " messages sent to this system.")
|
|
elif body.lower() == u'help'.lower():
|
|
sendreply(reply_to, reply_from, "Right now only the command 'count' works.")
|
|
else: #Echo a reply
|
|
sendreply(reply_to, reply_from, "What? You should type 'help' for a list of valid commands")
|
|
|
|
counter += 1
|
|
return '0'
|
|
|
|
@app.route('/smscount', methods=['GET'])
|
|
def smscount():
|
|
print("Returning the count of " + str(counter) + ".")
|
|
return str(counter)
|
|
|
|
def logmysql(msg_id, msg_ts, direction, to_did, from_did, cost, msg):
|
|
cur = db.cursor()
|
|
cur.execute("INSERT INTO messages (`timestamp`, `provider_timestamp`,`direction`, `source_number`, `dest_number`, `cost`,`pid`, `body`)VALUES \
|
|
(%s, %s, %s, %s, %s, %s, %s, %s)",(int(time.time()),msg_ts, direction, from_did, to_did, cost, msg_id, msg))
|
|
db.commit()
|
|
return '0'
|
|
|
|
|
|
def sendreply(reply_to, reply_from, msg):
|
|
request_body = '{ \
|
|
"data": { \
|
|
"type": "message", \
|
|
"attributes": { \
|
|
"to": "' + str(reply_to) + '", \
|
|
"from": "' + str(reply_from) + '", \
|
|
"body": "' + msg + '", \
|
|
"is_mms": "false" \
|
|
} \
|
|
} \
|
|
}'
|
|
|
|
print ("---Returning message")
|
|
result = messages_controller.send_a_message(request_body)
|
|
pprint.pprint(result)
|
|
|
|
msg_id = result['data']['id']
|
|
logmysql(msg_id, '', 'outbound', reply_to, reply_from,smsRate, msg) # Lets log to our silly db.
|
|
|
|
print ("ID: ", msg_id)
|
|
return '0'
|
|
|
|
if __name__ == '__main__':
|
|
app.run(
|
|
host="0.0.0.0",
|
|
port=int("8790")
|
|
) |