127 lines
3.1 KiB
Go
127 lines
3.1 KiB
Go
// pkg/environment/service.go
|
|
package environment
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"forge.lthn.ai/core/go/pkg/core"
|
|
)
|
|
|
|
// Options holds configuration for the environment service.
|
|
type Options struct{}
|
|
|
|
// Service is a core.Service providing environment queries and theme change events via IPC.
|
|
type Service struct {
|
|
*core.ServiceRuntime[Options]
|
|
platform Platform
|
|
cancelTheme func() // cancel function for theme change listener
|
|
overrideDark *bool
|
|
}
|
|
|
|
// Register creates a factory closure that captures the Platform adapter.
|
|
func Register(p Platform) func(*core.Core) (any, error) {
|
|
return func(c *core.Core) (any, error) {
|
|
return &Service{
|
|
ServiceRuntime: core.NewServiceRuntime[Options](c, Options{}),
|
|
platform: p,
|
|
}, nil
|
|
}
|
|
}
|
|
|
|
// OnStartup registers IPC handlers and the theme change listener.
|
|
func (s *Service) OnStartup(ctx context.Context) error {
|
|
s.Core().RegisterQuery(s.handleQuery)
|
|
s.Core().RegisterTask(s.handleTask)
|
|
|
|
// Register theme change callback — broadcasts ActionThemeChanged via IPC
|
|
s.cancelTheme = s.platform.OnThemeChange(func(isDark bool) {
|
|
_ = s.Core().ACTION(ActionThemeChanged{IsDark: isDark})
|
|
})
|
|
return nil
|
|
}
|
|
|
|
// OnShutdown cancels the theme change listener.
|
|
func (s *Service) OnShutdown(ctx context.Context) error {
|
|
if s.cancelTheme != nil {
|
|
s.cancelTheme()
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// HandleIPCEvents is auto-discovered by core.WithService.
|
|
func (s *Service) HandleIPCEvents(c *core.Core, msg core.Message) error {
|
|
return nil
|
|
}
|
|
|
|
func (s *Service) handleQuery(c *core.Core, q core.Query) (any, bool, error) {
|
|
switch q.(type) {
|
|
case QueryTheme:
|
|
isDark := s.currentTheme()
|
|
theme := "light"
|
|
if isDark {
|
|
theme = "dark"
|
|
}
|
|
return ThemeInfo{IsDark: isDark, Theme: theme}, true, nil
|
|
case QueryInfo:
|
|
return s.platform.Info(), true, nil
|
|
case QueryAccentColour:
|
|
return s.platform.AccentColour(), true, nil
|
|
default:
|
|
return nil, false, nil
|
|
}
|
|
}
|
|
|
|
func (s *Service) handleTask(c *core.Core, t core.Task) (any, bool, error) {
|
|
switch t := t.(type) {
|
|
case TaskOpenFileManager:
|
|
return nil, true, s.platform.OpenFileManager(t.Path, t.Select)
|
|
case TaskSetTheme:
|
|
if err := s.taskSetTheme(t); err != nil {
|
|
return nil, true, err
|
|
}
|
|
return nil, true, nil
|
|
default:
|
|
return nil, false, nil
|
|
}
|
|
}
|
|
|
|
func (s *Service) taskSetTheme(task TaskSetTheme) error {
|
|
shouldApplyTheme := false
|
|
switch task.Theme {
|
|
case "dark":
|
|
isDark := true
|
|
s.overrideDark = &isDark
|
|
shouldApplyTheme = true
|
|
case "light":
|
|
isDark := false
|
|
s.overrideDark = &isDark
|
|
shouldApplyTheme = true
|
|
case "system":
|
|
s.overrideDark = nil
|
|
case "":
|
|
isDark := task.IsDark
|
|
s.overrideDark = &isDark
|
|
shouldApplyTheme = true
|
|
default:
|
|
return fmt.Errorf("invalid theme mode: %s", task.Theme)
|
|
}
|
|
|
|
if shouldApplyTheme {
|
|
if setter, ok := s.platform.(interface{ SetTheme(bool) error }); ok {
|
|
if err := setter.SetTheme(s.currentTheme()); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
|
|
_ = s.Core().ACTION(ActionThemeChanged{IsDark: s.currentTheme()})
|
|
return nil
|
|
}
|
|
|
|
func (s *Service) currentTheme() bool {
|
|
if s.overrideDark != nil {
|
|
return *s.overrideDark
|
|
}
|
|
return s.platform.IsDarkMode()
|
|
}
|