shr-txt.sh

@@ -1,6 +0,0 @@
-#!/bin/bash
-# Share a text file to shrlok.
-cat <(printf '{"type":"txt"}\0') "$1" \
-        | socat - UNIX-CONNECT:/run/shrlok/shr.sock \
-        | sed 's|/var/www/files|https://files.dece.space|' \
-        ; echo

shrlok/shr-txt.py

@@ -0,0 +1,2 @@
+#!/usr/bin/env python3
+

shrlok/shrlok.py

@@ -1,27 +1,4 @@
 #!/usr/bin/env python3
-"""shrlok server: receive text/files from a socket, put them on a Web server.
-
-The server expects messages with the following format to come through the
-socket:
-
-1. a length, as ASCII digits,
-2. a null byte,
-3. a JSON object containing at least the "type" key with a known value,
-4. another null byte,
-5. the text or file itself.
-
-The length is of the JSON object + the null char + the content itself.
-
-Example, with \\0 representing a null byte:
-
-28\\0{"type":"txt"}\\0hello shrlok!
-
-The content is 13 bytes (assuming no LF at the end), the header is 14 bytes,
-plus the null byte it is 13 + 14 + 1 = 28 bytes, thus the prefixed length.
-
-After the content is succesfully retrieved and put on an appropriate location,
-the server will reply the file path through the socket and close the connection.
-"""
 
 import argparse
 import json
@@ -52,9 +29,11 @@ HTML_TEMPLATE = """\
 class Handler(socketserver.StreamRequestHandler):
 
     def handle(self):
-        data = self.receive_input()
+        fragments = []
+        while (chunk := self.request.recv(4096)):
+            fragments.append(chunk)
+        data = b"".join(fragments)
 
-        # Extract header.
         try:
             first_zero = data.index(b"\0")
             header_data, data = data[:first_zero], data[first_zero + 1:]
@@ -63,38 +42,17 @@ class Handler(socketserver.StreamRequestHandler):
             print("Bad header.")
             return
 
-        file_name = None
         if header.get("type") == "txt":
             file_name = write_text(data, title=header.get("title"))
         else:
             print("Unknown type.")
-        if file_name is None:
+            return
+
+        if not file_name:
             return
 
         print(f"{len(data)} bytes — {header} — '{file_name}'.")
-        try:
         self.request.sendall(file_name.encode())
-        except BrokenPipeError:
-            print("Broken pipe.")
-
-    def receive_input(self):
-        length = None
-        data = b""
-        while True:
-            chunk = self.request.recv(4096)
-            if not chunk:
-                break
-            data += chunk
-            if length is None:
-                try:
-                    first_zero = data.index(b"\0")
-                except ValueError:
-                    return b""
-                length_data, data = data[:first_zero], data[first_zero + 1:]
-                length = int(length_data.decode())
-            if len(data) >= length:  # retrieval completed
-                break
-        return data
 
 
 def write_text(data: bytes, title=None):
@@ -134,7 +92,6 @@ def main():
 
     try:
         with socketserver.UnixStreamServer(socket_path, Handler) as server:
-            os.chmod(socket_path, 0o664)
             server.serve_forever()
     except KeyboardInterrupt:
         print("Stopping server.")