forked from sch/Slixfeed
70 lines
1.9 KiB
Python
70 lines
1.9 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
|
|
import os
|
|
# from slixfeed.log import Logger
|
|
import socket
|
|
import sys
|
|
|
|
# logger = Logger(__name__)
|
|
|
|
# IPC parameters
|
|
ipc_socket_filename = '/tmp/slixfeed_xmpp.socket'
|
|
|
|
# Init socket object
|
|
if not os.path.exists(ipc_socket_filename):
|
|
print(f"File {ipc_socket_filename} doesn't exists")
|
|
sys.exit(-1)
|
|
|
|
s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
|
|
s.connect(ipc_socket_filename)
|
|
|
|
# def get_identifier():
|
|
# data = 'identifier'
|
|
# # Send request
|
|
# s.sendall(data.encode('utf-8'))
|
|
# # Wait for response
|
|
# datastream = s.recv(1024)
|
|
# return datastream.decode('utf-8')
|
|
|
|
def send_command(cmd, jid=None):
|
|
data = jid + '~' + cmd if jid else cmd
|
|
# Send request
|
|
s.sendall(data.encode('utf-8'))
|
|
# Wait for response
|
|
datastream = s.recv(1024)
|
|
return datastream.decode('utf-8')
|
|
|
|
# identifier = get_identifier()
|
|
# print('You are logged in as client #{}.format(identifier)')
|
|
print('Type a Jabber ID to commit an action upon.')
|
|
jid = input('slixfeed > ')
|
|
if not jid: jid = 'admin'
|
|
|
|
# TODO if not argument, enter loop.
|
|
try:
|
|
while True:
|
|
# print('Enter an action to act upon Jabber ID {}'.format(jid))
|
|
# print('Enter command:')
|
|
# cmd = input('slixfeed #{} ({}) > '.format(identifier, jid))
|
|
cmd = input('slixfeed ({}) > '.format(jid))
|
|
if cmd != '':
|
|
match cmd:
|
|
case 'switch':
|
|
print('Type a Jabber ID to commit an action upon.')
|
|
jid = input('slixfeed > ')
|
|
if not jid: jid = 'admin'
|
|
cmd = ''
|
|
case 'exit':
|
|
send_command(cmd, jid)
|
|
break
|
|
case _:
|
|
result = send_command(cmd, jid)
|
|
print(result)
|
|
except KeyboardInterrupt as e:
|
|
print(str(e))
|
|
# logger.error(str(e))
|
|
|
|
print('Disconnecting from IPC interface.')
|
|
s.close()
|