blob: c8ed8e239bba2849789c656981e868711f94d2c8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
#!/bin/sh
# managed by herdr; reinstalling the integration replaces this file.
# HERDR_INTEGRATION_ID=kimi
# HERDR_INTEGRATION_VERSION=7
action="${1:-}"
case "$action" in
session|working|blocked|idle) ;;
*) exit 0 ;;
esac
[ "${HERDR_ENV:-}" = "1" ] || exit 0
[ -n "${HERDR_SOCKET_PATH:-}" ] || exit 0
[ -n "${HERDR_PANE_ID:-}" ] || exit 0
command -v python3 >/dev/null 2>&1 || exit 0
python3 -c '
import json
import os
import socket
import sys
import time
action = sys.argv[1]
try:
payload = json.load(sys.stdin)
except Exception:
payload = {}
session_id = payload.get("session_id")
if not isinstance(session_id, str) or not session_id:
session_id = None
seq = time.time_ns()
params = {
"pane_id": os.environ["HERDR_PANE_ID"],
"source": "herdr:kimi",
"agent": "kimi",
"seq": seq,
}
if action == "session":
if session_id is None:
raise SystemExit(0)
method = "pane.report_agent_session"
params["session_start_source"] = "startup"
else:
method = "pane.report_agent"
params["state"] = action
if session_id is not None:
params["agent_session_id"] = session_id
request = json.dumps({"id": f"herdr:kimi:{seq}", "method": method, "params": params})
try:
with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as client:
client.settimeout(0.5)
client.connect(os.environ["HERDR_SOCKET_PATH"])
client.sendall((request + "\n").encode())
client.recv(4096)
except Exception:
pass
' "$action" 2>/dev/null || true
|
