Sneed-Group/pypush-plus-plus
2
0
Fork 0
mirror of https://github.com/Sneed-Group/pypush-plus-plus synced 2025-01-09 17:33:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

make it a bit better

Browse source
This commit is contained in:
JJTech0130 2023-07-31 13:25:19 -04:00
parent 9838294cf0
commit 3ef1b6e716
No known key found for this signature in database
GPG key ID: 23C92EBCCF8F93D6
1 changed files with 39 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
demo.py
View file

@ -17,6 +17,7 @@ logging.basicConfig(
# Set sane log levels # Set sane log levels
logging.getLogger("urllib3").setLevel(logging.WARNING) logging.getLogger("urllib3").setLevel(logging.WARNING)
logging.getLogger("asyncio").setLevel(logging.WARNING)
logging.getLogger("jelly").setLevel(logging.INFO) logging.getLogger("jelly").setLevel(logging.INFO)
logging.getLogger("nac").setLevel(logging.INFO) logging.getLogger("nac").setLevel(logging.INFO)
logging.getLogger("apns").setLevel(logging.INFO) logging.getLogger("apns").setLevel(logging.INFO)
@ -112,8 +113,8 @@ im = imessage.iMessageUser(conn, user)
INPUT_QUEUE = apns.IncomingQueue() INPUT_QUEUE = apns.IncomingQueue()
def input_thread(): def input_thread():
from prompt_toolkit import prompt
while True: while True:
from prompt_toolkit import prompt
try: try:
msg = prompt('>> ') msg = prompt('>> ')
@ -122,29 +123,53 @@ def input_thread():
INPUT_QUEUE.append(msg) INPUT_QUEUE.append(msg)
threading.Thread(target=input_thread, daemon=True).start() threading.Thread(target=input_thread, daemon=True).start()
print("Type 'help' for help")
current_chat = None
while True: while True:
msg = im.receive() msg = im.receive()
if msg is not None: if msg is not None and msg.sender != user.handles[0]:
print(f"Got message {msg}") print(f'[{msg.sender}] {msg.text}')
if len(INPUT_QUEUE) > 0: if len(INPUT_QUEUE) > 0:
msg = INPUT_QUEUE.pop() msg = INPUT_QUEUE.pop()
if msg == '': continue
if msg == 'help' or msg == 'h': if msg == 'help' or msg == 'h':
print('help (h): show this message') print('help (h): show this message')
print('quit (q): quit') print('quit (q): quit')
print('send (s) [recipiant] [message]: send a message') #print('send (s) [recipient] [message]: send a message')
print('filter (f) [recipient]: set the current chat')
print('note: recipient must start with tel: or mailto: and include the country code')
print('\\: escape commands (will be removed from message)')
elif msg == 'quit' or msg == 'q': elif msg == 'quit' or msg == 'q':
break break
elif msg.startswith('send') or msg.startswith('s'): elif msg.startswith('filter') or msg.startswith('f'):
# Set the curernt chat
msg = msg.split(' ') msg = msg.split(' ')
if len(msg) < 3: if len(msg) < 2:
print('send [recipiant] [message]') print('filter [recipient]')
else: else:
im.send(imessage.iMessage( current_chat = msg[1]
text=' '.join(msg[2:]), elif current_chat is not None:
participants=[msg[1], user.handles[0]], if msg.startswith('\\'):
#sender=user.handles[0] msg = msg[1:]
)) im.send(imessage.iMessage(
text=msg,
participants=[current_chat, user.handles[0]],
#sender=user.handles[0]
))
else:
print('No chat selected, use help for help')
# elif msg.startswith('send') or msg.startswith('s'):
# msg = msg.split(' ')
# if len(msg) < 3:
# print('send [recipient] [message]')
# else:
# im.send(imessage.iMessage(
# text=' '.join(msg[2:]),
# participants=[msg[1], user.handles[0]],
# #sender=user.handles[0]
# ))