mirror of
https://github.com/p1neappleXpress/OpenFlux.git
synced 2026-10-02 05:04:39 +08:00
Oleg NovikovandClaude Opus 5.5
96a0f95205
Renames the Go module path from openflux to github.com/p1neappleXpress/OpenFlux and updates every internal import (root module and mobile/), so the packages can be fetched and imported by other Go projects. Regenerated on main after #132, #122 and #125 (the same mechanical rename, imports sorted by gofmt). Co-authored-by: Claude Opus 5.5 <noreply@anthropic.com>
61 lines
2.1 KiB
Go
61 lines
2.1 KiB
Go
package main
|
|
|
|
import (
|
|
"github.com/p1neappleXpress/OpenFlux/transport"
|
|
"github.com/p1neappleXpress/OpenFlux/transport/ipc"
|
|
"github.com/p1neappleXpress/OpenFlux/transport/manager"
|
|
"github.com/p1neappleXpress/OpenFlux/utils"
|
|
)
|
|
|
|
// coreIPCHandler is the app-facing side of the IPC bridge.
|
|
//
|
|
// It receives commands and cookies from the mobile app and forwards them
|
|
// to the manager. When the core needs fresh cookies (SmartCaptcha), the
|
|
// manager calls SetCaptchaNotifier, whose callback fires into IPC.
|
|
type coreIPCHandler struct {
|
|
manager *manager.Manager
|
|
// exchanger takes the cookies on the classic path without a Session
|
|
// (manager nil). Nil when that carrier keeps no cookies.
|
|
exchanger transport.CookieExchanger
|
|
}
|
|
|
|
func (h *coreIPCHandler) OnConnect() { utils.Debugf("[IPC] app connected") }
|
|
func (h *coreIPCHandler) OnDisconnect() { utils.Debugf("[IPC] app disconnected") }
|
|
|
|
func (h *coreIPCHandler) OnCommand(p *ipc.CommandPayload) {
|
|
utils.Debugf("[IPC] command action=%q params=%v", p.Action, p.Params)
|
|
// No dynamic commands yet. Reserved for start/stop/restart from the UI.
|
|
}
|
|
|
|
func (h *coreIPCHandler) OnCookies(p *ipc.CookiesOfferPayload) {
|
|
if p == nil || p.Transport == "" || len(p.Jar) == 0 {
|
|
utils.Debugf("[IPC] empty cookies offer, ignoring")
|
|
return
|
|
}
|
|
if h.manager == nil {
|
|
if h.exchanger == nil || p.Remote {
|
|
utils.Debugf("[IPC] cookies for %q: nothing on this path takes them", p.Transport)
|
|
return
|
|
}
|
|
if err := h.exchanger.ApplyCookies(p.Jar); err != nil {
|
|
utils.Debugf("[IPC] apply cookies for %q: %v", p.Transport, err)
|
|
return
|
|
}
|
|
utils.Debugf("[IPC] applied %d cookies for %q", len(p.Jar), p.Transport)
|
|
return
|
|
}
|
|
if p.Remote {
|
|
if err := h.manager.OfferCookies(p.Transport, p.Jar); err != nil {
|
|
utils.Debugf("[IPC] offer cookies to exit for %q: %v", p.Transport, err)
|
|
return
|
|
}
|
|
utils.Debugf("[IPC] sent %d cookies to exit for %q", len(p.Jar), p.Transport)
|
|
return
|
|
}
|
|
if err := h.manager.AcceptCookies(p.Transport, p.Jar); err != nil {
|
|
utils.Debugf("[IPC] apply cookies for %q: %v", p.Transport, err)
|
|
return
|
|
}
|
|
utils.Debugf("[IPC] applied %d cookies for %q", len(p.Jar), p.Transport)
|
|
}
|