让我看看你在干嘛——利用 SSE 实现博客展示个人动态

WM_NAME(UTF8_STRING) = "让我看看你在干嘛——利用 SSE 实现博客展示个人动态 - roitium-personal-vault - Obsidian v1.8.4"
WM_CLASS(STRING) = "obsidian", "obsidian"

func matchApplicationPatterns(wmName, wmClass string) (newAppName string, message string) {
    switch wmClass {
    case "Code":
        return "VSCode", "正在使用 VSCode 写代码👨‍💻"
    case "CherryStudio":
        return "CherryStudio", "正在与 AI 激情对线🤖"
    }
    return wmClass, ""
}

func listenSystemEvents(ctx context.Context, notifyChan chan<- SystemEvent) {
	conn, err := dbus.SystemBus()
	if err != nil {
		log.Printf("无法连接系统总线: %v\n", err)
		return
	}
	defer conn.Close()

	// 匹配系统事件信号
	matchRules := []dbus.MatchOption{
		dbus.WithMatchInterface("org.freedesktop.login1.Manager"),
	}

	if err := conn.AddMatchSignal(matchRules...); err != nil {
		log.Printf("添加信号匹配失败: %v\n", err)
		return
	}

	sigChan := make(chan *dbus.Signal, 10)
	conn.Signal(sigChan)

	for {
		select {
		case sig := <-sigChan:
			log.Printf("捕获到信号: %v\n", sig)
			switch sig.Name {
			case "org.freedesktop.login1.Manager.PrepareForSleep":
				if entering, ok := sig.Body[0].(bool); ok {
					if entering {
						log.Println("捕获到休眠开始信号")
						notifyChan <- EventSuspend
					} else {
						log.Println("捕获到休眠恢复信号")
						notifyChan <- EventResume
					}
				}

			case "org.freedesktop.login1.Manager.PrepareForShutdown":
				if entering, ok := sig.Body[0].(bool); ok && entering {
					log.Println("捕获到关机信号")
					notifyChan <- EventShutdown
				}
			}

		case <-ctx.Done():
			log.Println("停止系统事件监听...")
			return
		}
	}
}

[Unit]
+ After=network-online.target
+ Wants=network-online.target

[Service]
+ Environment="DISPLAY=:1" // 通过 echo $DISPLAY 获取
+ User=your-user-name // 你当前用户的用户名和组（不是 root 的）
+ Group=your-user-group
+ Environment="XAUTHORITY=/home/your-user-name/.Xauthority"

func main() {
	// ...略

	// 设置路由
	mux := http.NewServeMux()
	mux.HandleFunc("/events", sseHandler)
	mux.HandleFunc("/update-status", authMiddleware(updateStatusHandler))
	mux.HandleFunc("/update-software", authMiddleware(updateSoftwareHandler))

	// 添加CORS中间件
	handler := corsMiddleware(mux)
	
	log.Fatal(http.ListenAndServe(":8080", handler))
}

func sseHandler(w http.ResponseWriter, r *http.Request) {
	// 设置请求头，告知客户端保持连接
	w.Header (). Set ("Content-Type", "text/event-stream")
	w.Header (). Set ("Cache-Control", "no-cache")
	w.Header (). Set ("Connection", "keep-alive")

	Ticker := time.NewTicker (1 * time. Second)
	Defer ticker.Stop ()

	log.Printf ("新的 SSE 客户端连接来自: %s", r.RemoteAddr)

	For {
		Select {
		Case <-ticker. C:
			Mu.Lock ()
			Data, _ := currentState.MarshalJSON ()
			Mu.Unlock ()

			Fmt.Fprintf (w, "data: %s\n\n", data)
			w.(http. Flusher). Flush ()

		case <-r.Context (). Done ():
			log.Printf ("SSE 客户端断开连接来自: %s", r.RemoteAddr)
			Return
		}
	}
}

Dumpsys activity activities | grep -E 'mCurrentFocus|mFocusedApp'

MCurrentFocus=Window{a 2 e 2 c 21 u 0 tw. Nekomimi. Nekogram/org. Telegram. Messenger. DefaultIcon}                         mFocusedApp=ActivityRecord{ee 3 aa 1 f u 0 tw. Nekomimi. Nekogram/org. Telegram. Messenger. DefaultIcon t 9712}

Let reconnectFrequencySeconds = 1
Let evtSource: EventSource

Function reconnectFunc (url: string, setStatus: SetStatus) {
	SetTimeout (() => {
		SetupEventSource (url, setStatus)
	}, reconnectFrequencySeconds * 1000)

	ReconnectFrequencySeconds *= 2

	If (reconnectFrequencySeconds >= 64) {
		ReconnectFrequencySeconds = 64
	}
} 

Function setupEventSource (url: string, setStatus: SetStatus) {
	EvtSource = new EventSource (url)
	If (evtSource. ReadyState === evtSource. CLOSED) return
	EvtSource. Onmessage = (e: MessageEvent) => {
		setStatus (JSON.Parse (e.data))
	}

	EvtSource. Onopen = () => {
		ReconnectFrequencySeconds = 1
	}

	EvtSource. Onerror = () => {
		EvtSource.Close ()
		ReconnectFunc (url, setStatus)
	}
}