Skip to content

Commit adcd255

Browse files
committed
http service fix to send whole message - fixes #471
1 parent 1abee3d commit adcd255

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

mqttwarn/services/http.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,12 +98,18 @@ def plugin(srv, item):
9898
else:
9999
encoded_params = urllib.parse.urlencode(params)
100100
else:
101-
encoded_params = message
101+
if tojson is not None:
102+
encoded_params = item.payload
103+
request.add_header('Content-Type', 'application/json')
104+
else:
105+
encoded_params = message
106+
102107

103-
request.add_data(encoded_params)
108+
request.data = encoded_params.encode('utf-8')
104109
request.add_header('User-agent', srv.SCRIPTNAME)
105110
if auth is not None:
106111
request.add_header("Authorization", "Basic %s" % auth)
112+
srv.logging.debug("before send")
107113
resp = urllib.request.urlopen(request, timeout=timeout)
108114
data = resp.read()
109115
# print "POST returns ", data

0 commit comments

Comments
 (0)