blob: 4c7e0c0b2aef5c20414bb8241a0c9e12bfc7a615 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
import json
import logging
import requests
from project.basecommunicator import BaseCommunicator
class ShoutboxCommunicator(BaseCommunicator):
"""Class for communication with the shoutbox API"""
url = "http://localhost:8000"
interval = 10
@staticmethod
def fetch():
"""Get and return a list of new messages from the API"""
try:
r = requests.get(ShoutboxCommunicator.url)
logging.info("Response from API OK.")
except:
logging.warning("Failed to get response from API!")
return
content = json.loads(r.text)
if len(content) > 0:
logging.info("Messages from shoutbox:")
for msg in content:
logging.info("{}: {}".format(msg["user"], msg["text"]))
return content
@staticmethod
def send(data):
"""Send a JSON message to the API"""
try:
requests.post(ShoutboxCommunicator.url, data)
user = json.loads(data)["user"]
logging.info("Sent message from {} to shoutbox.".format(user))
except:
logging.warning("Failed to send message to shoutbox API!")
|
