REDROOM
PHP 8.2.31
Path:
Logout
Edit File
Size: 815 B
Close
/opt/imunify360/venv/lib64/python3.11/site-packages/nats/protocol/command.py
Text
Base64
from __future__ import annotations from typing import Callable PUB_OP = "PUB" HPUB_OP = "HPUB" SUB_OP = "SUB" UNSUB_OP = "UNSUB" _CRLF_ = "\r\n" Command = Callable[..., bytes] def pub_cmd(subject, reply, payload) -> bytes: return f"{PUB_OP} {subject} {reply} {len(payload)}{_CRLF_}".encode() + payload + _CRLF_.encode() def hpub_cmd(subject, reply, hdr, payload) -> bytes: hdr_len = len(hdr) total_size = len(payload) + hdr_len return f"{HPUB_OP} {subject} {reply} {hdr_len} {total_size}{_CRLF_}".encode() + hdr + payload + _CRLF_.encode() def sub_cmd(subject, queue, sid) -> bytes: return f"{SUB_OP} {subject} {queue} {sid}{_CRLF_}".encode() def unsub_cmd(sid, limit) -> bytes: limit_s = "" if limit == 0 else f"{limit}" return f"{UNSUB_OP} {sid} {limit_s}{_CRLF_}".encode()
Save
Close
Exit & Reset
Text mode: syntax highlighting auto-detects file type.
Directory Contents
Dirs: 1 × Files: 3
Delete Selected
Select All
Select None
Sort:
Name
Size
Modified
Enable drag-to-move
Name
Size
Perms
Modified
Actions
__pycache__
DIR
-
drwxr-xr-x
2026-05-27 11:14:26
Edit
Download
Rename
Chmod
Change Date
Delete
OK
Cancel
recursive
OK
Cancel
recursive
OK
Cancel
command.py
815 B
lrw-r--r--
2026-04-14 09:45:18
Edit
Download
Rename
Chmod
Change Date
Delete
OK
Cancel
recursive
OK
Cancel
recursive
OK
Cancel
parser.py
7.09 KB
lrw-r--r--
2026-04-14 09:45:18
Edit
Download
Rename
Chmod
Change Date
Delete
OK
Cancel
recursive
OK
Cancel
recursive
OK
Cancel
__init__.py
581 B
lrw-r--r--
2026-04-14 09:45:18
Edit
Download
Rename
Chmod
Change Date
Delete
OK
Cancel
recursive
OK
Cancel
recursive
OK
Cancel
Zip Selected
If ZipArchive is unavailable, a
.tar
will be created (no compression).