#!/usr/bin/env python3
+import base64
import errno
import os
import posix
print("Channel %s does not exist!" % sys.argv[1], file=sys.stderr)
sys.exit(3)
+inBytes = sys.stdin.read().encode("UTF-8")
+inB64 = base64.b64encode(inBytes)
+
for i in range(0, 10):
fifo = -1
try:
fifo = posix.open(fifo_path, posix.O_WRONLY | posix.O_NONBLOCK)
- posix.write(fifo, sys.stdin.read().encode())
+ posix.write(fifo, inB64)
sys.exit(0)
except OSError as e:
if e.errno == errno.ENXIO:
import aiofiles
import asyncio
+import base64
import errno
import logging
import posix
if self._stop:
break
if self._joined_room_id != None:
+ try:
+ msgB64Bytes = line.rstrip("\n").encode("UTF-8")
+ msgBytes = base64.b64decode(msgB64Bytes)
+ except:
+ self._log(logging.WARNING, "Error decoding message")
+ continue
await client.room_send(
room_id=self._joined_room_id,
message_type="m.room.message",
content={
"msgtype": "m.text",
- "body": line.rstrip("\n")
+ "body": msgBytes.decode("UTF-8")
}
)
else: