Compare commits
No commits in common. "20ede6e02ac3bf4b63daa257fce765a2092e8e69" and "6ad1a9f9572d41608675f167f21c2885de6d057e" have entirely different histories.
20ede6e02a
...
6ad1a9f957
2
.gitignore
vendored
2
.gitignore
vendored
@ -60,5 +60,3 @@ target/
|
|||||||
|
|
||||||
# Node
|
# Node
|
||||||
node_modules/
|
node_modules/
|
||||||
client/node_modules/
|
|
||||||
server/node_modules/
|
|
||||||
|
@ -1,4 +0,0 @@
|
|||||||
{
|
|
||||||
"url": "",
|
|
||||||
"webhook": ""
|
|
||||||
}
|
|
14
package.json
Normal file
14
package.json
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
{
|
||||||
|
"name": "TellMe",
|
||||||
|
"version": "1.3.0",
|
||||||
|
"description": "TellMe CLI",
|
||||||
|
"scripts": {
|
||||||
|
"dev": "webpack-dev-server --inline --hot"
|
||||||
|
},
|
||||||
|
"author": "Guy Van Sanden <guy@taurix.net>",
|
||||||
|
"license": "AGPL",
|
||||||
|
"dependencies": {
|
||||||
|
"grunt": "~0.4.5",
|
||||||
|
"grunt-version": "~1.1.0"
|
||||||
|
}
|
||||||
|
}
|
@ -1,49 +0,0 @@
|
|||||||
#!/bin/env python3
|
|
||||||
from flask import Flask, request, jsonify
|
|
||||||
# import asyncio
|
|
||||||
import websocket
|
|
||||||
import json
|
|
||||||
import random
|
|
||||||
|
|
||||||
app = Flask(__name__)
|
|
||||||
|
|
||||||
hooks = {}
|
|
||||||
hooks['2345555XE'] = '#Bottest'
|
|
||||||
|
|
||||||
def sendmessage(target, message):
|
|
||||||
print("Sendmessage %s called to %s" % (message, target))
|
|
||||||
uri = "ws://localhost:5080"
|
|
||||||
#message = "#Bottest Hello, world!"
|
|
||||||
msg = ("%s %s" % (target, message))
|
|
||||||
|
|
||||||
# Create a unique correlation ID
|
|
||||||
command = {
|
|
||||||
"corrId": f"id{random.randint(0, 999999)}",
|
|
||||||
"cmd": msg,
|
|
||||||
}
|
|
||||||
json_command = json.dumps(command)
|
|
||||||
|
|
||||||
""" Connects to WebSocket server, sends a message, and returns the response """
|
|
||||||
ws = websocket.create_connection(uri) # Blocking WebSocket connection
|
|
||||||
ws.send(json_command) # Send message to WebSocket
|
|
||||||
response = ws.recv() # Receive response
|
|
||||||
ws.close() # Close WebSocket connection
|
|
||||||
print(response)
|
|
||||||
return response
|
|
||||||
|
|
||||||
@app.route("/webhook/<id>", methods=['POST'])
|
|
||||||
def webhook_receiver(id):
|
|
||||||
print("Webhook id %s" % (id))
|
|
||||||
data = request.json # Get the JSON data from the incoming request
|
|
||||||
# Process the data and perform actions based on the event
|
|
||||||
print("Received webhook data:", data)
|
|
||||||
|
|
||||||
target = hooks.get(id)
|
|
||||||
print(target)
|
|
||||||
sendmessage(target, data.get('message'))
|
|
||||||
|
|
||||||
return jsonify({'message': 'Webhook received successfully'}), 200
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
app.run(debug=True)
|
|
5
src/config.json.dist
Normal file
5
src/config.json.dist
Normal file
@ -0,0 +1,5 @@
|
|||||||
|
{
|
||||||
|
"url": "",
|
||||||
|
"webhook": "",
|
||||||
|
"notify": "",
|
||||||
|
}
|
@ -26,9 +26,9 @@ def sendmessage(message):
|
|||||||
urllib3.disable_warnings()
|
urllib3.disable_warnings()
|
||||||
# http_client.HTTPConnection.debuglevel = 1
|
# http_client.HTTPConnection.debuglevel = 1
|
||||||
|
|
||||||
url = ("%s/webhook/%s" % (baseurl, webhook))
|
url = ("%s/skill/tellops/%s" % (baseurl, webhook))
|
||||||
|
|
||||||
r = requests.post(url, json = { 'message': mymessage })
|
r = requests.post(url, json = { 'message': mymessage, 'notify': notify, 'tts': args.tts })
|
||||||
if r.status_code == 200:
|
if r.status_code == 200:
|
||||||
print("Message has been sent successfully")
|
print("Message has been sent successfully")
|
||||||
# print(message)
|
# print(message)
|
||||||
@ -39,7 +39,7 @@ def sendmessage(message):
|
|||||||
ran = True
|
ran = True
|
||||||
|
|
||||||
|
|
||||||
__version__ = "1.4.0"
|
__version__ = "1.3.1"
|
||||||
versionstring='TellMe v' + __version__
|
versionstring='TellMe v' + __version__
|
||||||
|
|
||||||
signal.signal(signal.SIGINT, signal_handler)
|
signal.signal(signal.SIGINT, signal_handler)
|
||||||
@ -49,8 +49,10 @@ home=os.getenv("HOME")
|
|||||||
|
|
||||||
parser = argparse.ArgumentParser(description='TellMe command line client')
|
parser = argparse.ArgumentParser(description='TellMe command line client')
|
||||||
parser.add_argument("-m", "--message", default="Your process finished", help="Message to send")
|
parser.add_argument("-m", "--message", default="Your process finished", help="Message to send")
|
||||||
|
parser.add_argument('-t', '--tts', default=False, action='store_true', help="Send message to TTS")
|
||||||
parser.add_argument('-v', '--version', action='version', version=versionstring)
|
parser.add_argument('-v', '--version', action='version', version=versionstring)
|
||||||
parser.add_argument('-p', '--pid', action="store", dest="pid", type=int, default=0)
|
parser.add_argument('-p', '--pid', action="store", dest="pid", type=int, default=0)
|
||||||
|
parser.add_argument('-n', '--notify', action="store", dest="notify", default=None, help="Notify specific id")
|
||||||
parser.add_argument('-i', '--interval', action="store", dest="interval", type=int, default=5, help="Set the interval of commands like watch that use it")
|
parser.add_argument('-i', '--interval', action="store", dest="interval", type=int, default=5, help="Set the interval of commands like watch that use it")
|
||||||
parser.add_argument('-w', '--watch', action="store", dest="watchcommand", help="Run the given command every n or 5 minutes")
|
parser.add_argument('-w', '--watch', action="store", dest="watchcommand", help="Run the given command every n or 5 minutes")
|
||||||
parser.add_argument('-c', '--config', default=home +"/.config/tellme/config.json" ,help="Path to config file")
|
parser.add_argument('-c', '--config', default=home +"/.config/tellme/config.json" ,help="Path to config file")
|
Loading…
x
Reference in New Issue
Block a user