From 1e9ed7db9489ddcc8238655e9235f5cca99b0adf Mon Sep 17 00:00:00 2001
From: Stavros Korokithakis <hi@stavros.io>
Date: Thu, 6 Dec 2018 05:06:18 +0200
Subject: Initial commit

---
 signald/main.py | 85 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 85 insertions(+)
 create mode 100644 signald/main.py

(limited to 'signald/main.py')

diff --git a/signald/main.py b/signald/main.py
new file mode 100644
index 0000000..61ae1a5
--- /dev/null
+++ b/signald/main.py
@@ -0,0 +1,85 @@
+import json
+import random
+import socket
+from typing import Iterator, List  # noqa
+
+from .types import Message
+
+
+def readlines(s: socket.socket) -> Iterator[bytes]:
+    "Read a socket, line by line."
+    buf = []  # type: List[bytes]
+    while True:
+        char = s.recv(1)
+        if not char:
+            raise ConnectionResetError("connection was reset")
+
+        if char == b"\n":
+            yield b"".join(buf)
+            buf = []
+        else:
+            buf.append(char)
+
+
+class Signal:
+    def __init__(self, username, socket_path="/var/run/signald/signald.sock"):
+        self.username = username
+        self.socket_path = socket_path
+
+    def _get_id(self):
+        "Generate a random ID."
+        return "".join(random.choice("abcdefghijklmnopqrstuvwxyz0123456789") for _ in range(10))
+
+    def _get_socket(self) -> socket.socket:
+        "Create a socket, connect to the server and return it."
+        s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
+        s.connect(self.socket_path)
+        return s
+
+    def _send_command(self, payload: dict):
+        s = self._get_socket()
+        msg_id = self._get_id()
+        payload["id"] = msg_id
+        s.recv(1024)  # Flush the buffer.
+        s.send(json.dumps(payload).encode("utf8") + b"\n")
+
+        response = s.recv(4 * 1024)
+        for line in response.split(b"\n"):
+            if msg_id.encode("utf8") not in line:
+                continue
+
+            data = json.loads(line)
+
+            if data.get("id") != msg_id:
+                continue
+
+            if data["type"] == "unexpected_error":
+                raise ValueError("unexpected error occurred")
+
+    def register(self, voice=False):
+        payload = {"type": "register", "username": self.username, "voice": voice}
+        self._send_command(payload)
+
+    def verify(self, code: str):
+        payload = {"type": "verify", "username": self.username, "code": code}
+        self._send_command(payload)
+
+    def receive_messages(self) -> Iterator[Message]:
+        "Keep returning received messages."
+        s = self._get_socket()
+        s.send(json.dumps({"type": "subscribe", "username": self.username}).encode("utf8") + b"\n")
+
+        for line in readlines(s):
+            try:
+                message = json.loads(line.decode())
+            except json.JSONDecodeError:
+                print("Invalid JSON")
+
+            if message.get("type") != "message":
+                continue
+
+            yield message
+
+    def send_message(self, recipient: str, message: str) -> None:
+        payload = {"type": "send", "username": self.username, "recipientNumber": recipient, "messageBody": message}
+        self._send_command(payload)
-- 
cgit v1.2.3-54-g00ecf