82 lines
3.2 KiB
Python
82 lines
3.2 KiB
Python
import json
|
|
import logging
|
|
import random
|
|
import sys
|
|
import smpplib.consts
|
|
import smpplib.gsm
|
|
import ssl
|
|
|
|
with open("config.json", "r") as config_file:
|
|
data = json.load(config_file)
|
|
|
|
smppserverhostname = data["SMPPServer"]["Hostname"]
|
|
smppserverport = data["SMPPServer"]["Port"]
|
|
smppserverusername = data["SMPPServer"]["Username"]
|
|
smppserverpassword = data["SMPPServer"]["Password"]
|
|
usessl = data["SMPPServer"]["SSL"]
|
|
smssendsource = data["SMSSend"]["Source"]
|
|
smssenddest = data["SMSSend"]["Destination"]
|
|
smssendcont = data["SMSSend"]["Content"]
|
|
numberofmsgtosend = data["SMSSend"]["Count"]
|
|
validityperiod = data["SMSSend"]["ValidityPeriod"]
|
|
othersettingsloglevel = data["OtherSettings"]["LogLevel"]
|
|
|
|
logging.basicConfig(level=othersettingsloglevel)
|
|
|
|
if usessl == "1":
|
|
ssl_context = ssl.create_default_context()
|
|
ssl_context.check_hostname = False
|
|
ssl_context.verify_mode = ssl.CERT_NONE
|
|
ssl_context.options = ssl.OP_NO_SSLv2
|
|
client = smpplib.client.Client(smppserverhostname, smppserverport, allow_unknown_opt_params=True,
|
|
ssl_context=ssl_context)
|
|
else:
|
|
client = smpplib.client.Client(smppserverhostname, smppserverport, allow_unknown_opt_params=True)
|
|
|
|
client.set_message_sent_handler(
|
|
lambda pdu: sys.stdout.write('Sent msg with sequence ID {}, got ID back {}\n'.format(pdu.sequence, pdu.message_id)))
|
|
|
|
client.set_message_received_handler(
|
|
lambda pdu: sys.stdout.write('Delivered msg with ID {}, and state {}\n'.format(pdu.receipted_message_id,
|
|
pdu.message_state)))
|
|
|
|
try:
|
|
print("Connecting to SMPP Server", smppserverhostname, "on port", smppserverport)
|
|
client.connect()
|
|
client.bind_transceiver(system_id=smppserverusername, password=smppserverpassword)
|
|
print("Connected to SMPP Server", smppserverhostname, "on port", smppserverport)
|
|
print("Sending", numberofmsgtosend, "messages towards server", smppserverhostname)
|
|
except:
|
|
print("Error connecting to SMPP Server", smppserverhostname, "on port", smppserverport,
|
|
"Will exit with return code 1.")
|
|
client.disconnect()
|
|
exit(1)
|
|
|
|
for i in range(numberofmsgtosend):
|
|
parts, encoding_flag, msg_type_flag = smpplib.gsm.make_parts(smssendcont + str(random.randint(1, 10000)))
|
|
for part in parts:
|
|
pdu = client.send_message(
|
|
# source_addr_ton=smpplib.consts.SMPP_TON_INTL,
|
|
source_addr_ton=smpplib.consts.SMPP_TON_ALNUM,
|
|
# source_addr_npi=smpplib.consts.SMPP_NPI_ISDN,
|
|
# Make sure it is a byte string, not unicode:
|
|
source_addr=smssendsource,
|
|
dest_addr_ton=smpplib.consts.SMPP_TON_INTL,
|
|
# dest_addr_npi=smpplib.consts.SMPP_NPI_ISDN,
|
|
# Make sure these two params are byte strings, not unicode:
|
|
destination_addr=smssenddest,
|
|
short_message=part,
|
|
data_coding=encoding_flag,
|
|
esm_class=msg_type_flag,
|
|
# validity_period=validityperiod,
|
|
registered_delivery=True,
|
|
)
|
|
|
|
# Enters a loop, waiting for incoming PDUs
|
|
print('Starting thread to listen for incoming delivery reports. Ctrl+C to exit.')
|
|
while True:
|
|
try:
|
|
client.listen()
|
|
except KeyboardInterrupt:
|
|
break
|