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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
|
#+TITLE: Triage Intake — Telegram Source
#+AUTHOR: Craig Jennings & Claude
#+DATE: 2026-06-09
# Source plugin for the triage-intake engine. See triage-intake.org for the
# contract and the Phase A-D orchestration. This file declares ONE source.
#
# General (personal) source: Telegram via the Emacs telega.el package (tdlib
# backend). It lives in .ai/workflows/ and is template-synced, sitting with the
# other general personal sources (personal-gmail, cmail, personal-calendar,
# signal, github-prs) — not the project plugins. Telegram is personal
# messaging, not project-specific.
#
# Unlike signal-cli (a standalone CLI), Telegram has no headless CLI here. The
# client is telega.el running inside Craig's long-lived `emacs --daemon`, so the
# plugin drives it over `emacsclient -e`. tdlib keeps a persisted session in
# ~/.telega (td.binlog), so a started telega reconnects without re-auth.
* Source: telegram
:PROPERTIES:
:ORDER: 24
:ENABLED: command -v emacsclient && emacsclient -e "(or (featurep 'telega) (fboundp 'telega))" | grep -q t
:ANCHOR: none
:SUBAGENT_OVER: 40
:END:
** Quick reference — full lifecycle
Telega does not autostart with the Emacs daemon. "Down" is its normal state
unless Craig has Telegram open in Emacs. The scan therefore runs the full
lifecycle every time, never skips because the server is down:
1. Record prior state: TELEGA_WAS_RUNNING via (telega-server-live-p).
2. Launch (only if not running):
emacsclient -e "(progn (setq telega-use-docker t) (telega t) 'started)"
The setq is mandatory defense: tdlib segfaults outside docker mode
(2026-06-09), and Craig's daemon currently has telega-use-docker nil.
Wait ~2s for Ready, then (telega--loadChats 'main) until telega--chats
is populated.
3. Check messages: the maphash unread scan in ** Scan Step 2 (filters the
messageContactRegistered join-notice noise).
4. Send (needs the server live; /voice personal first — Telegram
occasionally carries WORK communication to Kostya and Vrezh, so treat
sends with the same care as Slack):
emacsclient -e "(telega-chat-send-msg (telega-chat-get <CHAT-ID>) \"<body>\")"
5. Shutdown (ONLY if step 1 recorded not-running):
emacsclient -e "(progn (telega-server-kill) (ignore-errors (telega-kill t)) 'stopped)"
Verify: telega-server-live-p → nil, no zevlg/telega-server container in
docker ps. If Craig had it running, leave it untouched.
If any lifecycle step fails (docker image missing, server crash, daemon
unreachable), the sweep reports it as SCAN FAILED at the top of the summary
per the engine's failure rule — never as a silent skip. Craig gets real
traffic here.
** Scan
Telegram direct messages and groups via telega.el in the running Emacs daemon.
=ANCHOR: none= because telega reports live unread *state* (each chat's
=:unread_count=), not a since-window — the engine substitutes no cutoff. Phase B
uses each message's timestamp only to order and label recency.
The scan reads the =telega--chats= hash table (chat-id → chat plist), which
telega populates as chats sync. *This is robust to the tdlib server crashing
mid-session* (see the SEGFAULT gotcha below): the hash retains the last-synced
unread counts and =:last_message= even after the server dies, so a scan reading
the hash still returns the most recent known state.
*** Leave-no-trace lifecycle (start only if needed, shut down only if we started it)
telega is a long-lived client inside Craig's daemon. If he already has it
running, the scan must leave it running. If it's *not* running, the scan starts
it for the read and shuts it down cleanly afterward, restoring the daemon to its
prior state. The discipline: *record the prior liveness, branch on it at the
end.*
*** Step 0 — record prior state
#+begin_src bash
# t if telega's tdlib server was ALREADY live before this scan, nil otherwise.
# Hold this value; Step 3 reads it to decide whether to shut telega down.
TELEGA_WAS_RUNNING=$(emacsclient -e "(and (fboundp 'telega-server-live-p) (telega-server-live-p) t)" 2>/dev/null)
#+end_src
*** Step 1 — start (docker mode) if not already running, wait for Ready
#+begin_src bash
# `(telega t)` starts without popping the root buffer. Docker mode (the stable
# path — see the SEGFAULT gotcha) reconnects the persisted ~/.telega session in
# ~2s. Then load the main chat list so telega--chats populates.
emacsclient -e "(progn
(unless (and (fboundp 'telega-server-live-p) (telega-server-live-p)) (telega t))
'started)"
# Poll until Ready with chats synced, or a crash/timeout. Background this with an
# until-loop so the wait doesn't block; exit on Ready-with-chats OR an abnormal
# server exit. Then force a chat-list load if the hash is thin:
emacsclient -e "(progn (ignore-errors (telega--loadChats 'main)) (ignore-errors (telega--loadChats 'main)) 'loaded)"
#+end_src
On a persisted session telega reaches status "Ready" within ~2s; the chat list
loads over a few more. If =(hash-table-count telega--chats)= is 0 or thin,
re-issue =telega--loadChats= and poll until it stabilizes.
*** Step 2 — read unread, classified by last-message type
The single most important filter: =messageContactRegistered=. Telegram counts a
"<name> joined Telegram" service notice as one unread message, so every contact
from Craig's old address book who ever joined shows as a 1-unread "DM" *that
person never actually sent*. On the 2026-06-09 first scan this was 30 of ~50
unread chats. Drop them entirely (tally only).
#+begin_src bash
emacsclient -e "(let (real svc other)
(when (boundp 'telega--chats)
(maphash (lambda (id chat)
(let* ((uc (or (plist-get chat :unread_count) 0))
(lm (plist-get chat :last_message))
(ctype (when lm (plist-get (plist-get lm :content) :@type)))
(title (or (ignore-errors (substring-no-properties (telega-chat-title chat))) \"?\")))
(when (> uc 0)
(cond
((equal ctype \"messageContactRegistered\") (push title svc))
((member ctype '(\"messageText\" \"messagePhoto\" \"messageVideo\" \"messageDocument\" \"messageVoiceNote\" \"messageSticker\" \"messageAnimation\"))
(push (list title uc ctype) real))
(t (push (list title uc (or ctype \"nil\")) other))))))
telega--chats))
(list (cons 'real (nreverse real))
(cons 'joined-telegram-count (length svc))
(cons 'other (nreverse other))))"
#+end_src
For a chat that survives as Action-worthy, pull the last message's text to
classify and summarize:
#+begin_src bash
# <CHAT-ID> from the maphash key (the scan can also return ids alongside titles)
emacsclient -e "(let ((c (gethash <CHAT-ID> telega--chats)))
(substring-no-properties
(or (telega--tl-get c :last_message :content :text :text) \"\")))"
#+end_src
*** Step 3 — restore prior state (shut down only if we started it)
#+begin_src bash
# If telega was NOT running before this scan, shut it down cleanly to leave the
# daemon as we found it. If Craig already had it running, leave it alone.
if [ "$TELEGA_WAS_RUNNING" != "t" ]; then
emacsclient -e "(progn (ignore-errors (telega-server-kill)) (ignore-errors (telega-kill t)) 'killed)"
fi
#+end_src
⚠ *In docker mode, =telega-kill= alone is not enough.* =telega-kill= buries the
telega buffers but leaves the dockerized tdlib server running (=telega-server-live-p=
stays non-nil). =telega-server-kill= is what actually stops the server. Call
*both* — server-kill then kill — for a clean teardown. Verified clean afterward:
=telega-server-live-p= → nil, root buffer gone, no =zevlg/telega-server= container
left in =docker ps=. Skipping this whole branch when =TELEGA_WAS_RUNNING= is t is
the point of Step 0: never tear down a session Craig is actively using.
⚠ *SEGFAULT GOTCHA — docker mode is the fix.* The tdlib =telega-server= can exit
abnormally (code 139, SIGSEGV) during or just after the initial sync. Observed
on the 2026-06-09 first run; the cure was *docker mode* — =telega-use-docker= = t
with the =zevlg/telega-server:latest= image (already pulled on Craig's box).
Restarted under docker, the server reached "Ready" in ~2s, synced 73 chats, and
held through a live re-scan with no crash. So: *ensure docker mode is on before
the sweep.* If =telega-use-docker= is nil, set it (=(setq telega-use-docker t)=)
and restart telega.
Defense in depth: even if the server does die, the scan still works because it
reads the cached =telega--chats= hash, not a live query. A dead server is
*scan-only* — you can still report unread state, but cannot read new bodies, mark
read, or reply until it restarts. Treat that as "scan-only, no actions this run"
and say so.
** Classify
Bias: Craig's personal Telegram is *spam-dominated* with a thin layer of real
signal. The opposite of Signal (high signal/low volume) — here the volume is
high and almost all noise. Filter aggressively; surface only the few real
threads. Kostya and Vrezh occasionally reach Craig here, so a real DM from a
work contact is Action, full stop.
- *Noise-trash (tally only, never itemized):*
- =messageContactRegistered= "joined Telegram" notices — always noise, no
matter whose name is on them. The real contacts Craig knows live here; a
join notice is not a message from them.
- Romance/crypto spam DMs — the signature is an emoji-laden handle or a
two-word "RealName + FantasyWord" suffix (=Gayle ⚾🤎RoyalVineyard=,
=Cherie🌷🏰 InfiniteRhapsody=, =Jane 🍒🔥=, =Luna Skye=). One unread,
unsolicited, no prior thread.
- =Deleted Account-NNNN= threads, blank-title chats, bot channels
(=Z-Library Official=), Telegram's own =✔️Telegram= service notices.
- *FYI:* unread in dev-community groups Craig follows — =GNU Emacs=, =zed=,
=Kitty=, and similar. Worth awareness, no response owed. List the group +
unread count; don't enumerate the messages.
- *Action:* a real text/voice/media message from a *known personal contact* in
an existing one-to-one thread — an explicit ask, a question, a reply owed. On
a spam-heavy account these are rare; when one appears, surface it prominently
with the sender + gist, because it's the needle in the haystack.
The 2026-06-09 calibration run: 30 join-notices + ~10 spam/deleted/bot + 3 dev
groups + 0 real personal DMs. Expect most sweeps to look like this — a clean
"nothing real" is the common, correct result.
** Render
#+begin_example
**Telegram — N unread chats (M real after filtering).** <one-line summary>
- Action: <real DMs from known contacts, sender + gist, reply owed called out>
- FYI: <dev groups — name + count>
- Noise: K joined-Telegram notices, J spam/bot/deleted (tally only)
#+end_example
Omit the block if there are zero unread chats. If the only unread is
join-notices + spam + groups (the common case), render the one-line summary plus
the Noise tally and skip Action entirely.
** Actions
Actions need the tdlib server *live* (see the SEGFAULT gotcha — a dead server is
scan-only). All run through telega in the daemon:
- reply :: =emacsclient -e "(telega-chat-send-msg (telega-chat-get <CHAT-ID>) \"<body>\")"= — public-facing (goes out under Craig's name), so run =/voice personal= before sending. Prefer a body file for multi-line.
- mark-read :: =emacsclient -e "(telega-chat--mark-read (telega-chat-get <CHAT-ID>))"= — clears a specific chat's unread. Never mark the whole account read blindly; the join-notice noise is fine to leave or clear per Craig's call.
- open :: =emacsclient -e "(telega-chat-with (telega-chat-get <CHAT-ID>))"= — pop the chat buffer for Craig to read/handle by hand (useful when a real DM needs a considered reply).
No blanket mark-read verb: the account's unread is mostly join-notices and spam,
and a real DM should be handled deliberately, not swept.
|
