Amr Gharbeia
e8c66c7e4a
Some checks failed
Deploy-Agent-V15-Stdin / JOB-V15-STDIN (push) Failing after 2s
43 lines
1.3 KiB
Python
43 lines
1.3 KiB
Python
import socket, time, sys
|
|
|
|
def verify():
|
|
try:
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
s.settimeout(20)
|
|
s.connect(("localhost", 9105))
|
|
|
|
# We need to read handshake and status first to clear the pipe
|
|
full_data = b""
|
|
while len(full_data) < 50: # Expecting at least handshake + status
|
|
chunk = s.recv(4096)
|
|
if not chunk: break
|
|
full_data += chunk
|
|
|
|
print(f"Data received: {full_data.decode()}")
|
|
|
|
# Send "Hi"
|
|
# Make sure we use the right length.
|
|
# (:TYPE :EVENT :PAYLOAD (:SENSOR :CHAT-MESSAGE :TEXT "Hi")) is 57 chars.
|
|
# Let s calculate it.
|
|
payload = '(:TYPE :EVENT :PAYLOAD (:SENSOR :CHAT-MESSAGE :TEXT "Hi"))'
|
|
length = len(payload)
|
|
msg = f"{length:06x}{payload}".encode()
|
|
print(f"Sending: {msg.decode()}")
|
|
s.sendall(msg)
|
|
|
|
# Read response
|
|
while True:
|
|
chunk = s.recv(4096)
|
|
if not chunk: break
|
|
print(f"Received chunk: {chunk.decode()}")
|
|
if ":CHAT" in chunk.decode() or "Neural Cascade Failure" in chunk.decode():
|
|
print("SUCCESS: Response received!")
|
|
break
|
|
|
|
s.close()
|
|
except Exception as e:
|
|
print(f"Error: {e}")
|
|
sys.exit(1)
|
|
|
|
verify()
|