Wiki Notify for Google Chat

@@ -45,6 +45,8 @@ DEFAULT_CONFIG = {     "maxRows": 40,     "boardTitle": "Wiki Notifications",     "style": "table",+    "meName": "You",+    "fullName": "", }  OPEN_COLOR, CLOSED_COLOR = "#22c55e", "#94a3b8"@@ -184,6 +186,31 @@ EVENT_PATTERNS = [ ]  +def page_author(page, state):+    """Author of a wiki page via `adom-wiki page stats` (cached in state)."""+    cache = state.setdefault("pageAuthors", {})+    if page in cache:+        return cache[page]+    author = ""+    code, out, _ = run_cmd(["adom-wiki", "page", "stats", page, "--json"])+    if code == 0:+        try:+            j = json.loads(out)+            author = ((j.get("data", j) or {}).get("page") or {}).get("author_name") or ""+        except Exception:+            pass+    cache[page] = author+    save_state(state)+    return author+++def annotate_page_ownership(state, me_full):+    """Mark items whose wiki page the user authored (drives 'owns this page')."""+    for it in state.get("items", {}).values():+        author = page_author(it["page"], state)+        it["ownsPage"] = bool(me_full) and author == me_full++ def parse_notification(msg):     """Return an event dict for a wiki notification email, or None."""     import html@@ -362,8 +389,11 @@ def render_table_widgets(shown, tz, me="You"):             dim(f"Created by {creator} on {fmt_datetime(it['openedAt'], tz)}"),             dim(f"{event} by {actor} on {fmt_datetime(it['lastAt'], tz)}"),         ]-        if it.get("invLabel"):-            fields.append(dim(f"{me} {it['invLabel']}"))+        inv = it.get("invLabel", "")+        if it.get("ownsPage") and it.get("invRank", 0) < 3:+            inv = "owns this page"  # page authorship beats mention/comment/watch, not opened/assigned+        if inv:+            fields.append(dim(f"{me} {inv}"))         widgets.append({"columns": {"columnItems": [             {"horizontalSizeStyle": "FILL_MINIMUM_SPACE", "verticalAlignment": "TOP",              "widgets": [{"textParagraph": {"text": f"<b>{item}</b><br>{status}"}}]},@@ -477,6 +507,10 @@ def ingest(cfg, state, query, sweep_mail=True, dry_run=False):                 if not ev:                     skipped += 1                     continue+                if not state.get("meFullName"):+                    tm = re.match(r'\s*"?([^"<]+?)"?\s*<', headers_of(msg).get("to", ""))+                    if tm:+                        state["meFullName"] = tm.group(1).strip()                 if not dry_run:                     apply_event(state["items"], ev)                     if sweep_mail:@@ -565,6 +599,7 @@ def cmd_run(as_json, dry_run=False, quiet=False):     board_changed = False     if not dry_run:         try:+            annotate_page_ownership(state, cfg.get("fullName") or state.get("meFullName", ""))             board_changed = push_board(cfg, state)         except Exception as e:             errors.append(f"board: {e}")@@ -598,6 +633,7 @@ def cmd_backfill(as_json, days=30, dry_run=False):     board_changed = False     if not dry_run:         try:+            annotate_page_ownership(state, cfg.get("fullName") or state.get("meFullName", ""))             board_changed = push_board(cfg, state)         except Exception as e:             errors.append(f"board: {e}")@@ -623,6 +659,7 @@ def cmd_board(as_json, dry_run=False):         card = render_card(state["items"], cfg)         print(json.dumps(card, indent=2)[:6000])         return+    annotate_page_ownership(state, cfg.get("fullName") or state.get("meFullName", ""))     changed = push_board(cfg, state, force=True)     emit(f"OK: board {'reposted' if changed else 'unchanged'} ({len(state['items'])} item(s)).")