mirror of
https://github.com/m1k1o/neko.git
synced 2024-07-24 14:40:50 +12:00
103 lines
2.5 KiB
Go
103 lines
2.5 KiB
Go
package desktop
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
"sync"
|
|
|
|
"github.com/kataras/go-events"
|
|
"github.com/rs/zerolog"
|
|
"github.com/rs/zerolog/log"
|
|
|
|
"demodesk/neko/internal/config"
|
|
"demodesk/neko/internal/desktop/xorg"
|
|
"demodesk/neko/internal/desktop/xevent"
|
|
)
|
|
|
|
var mu = sync.Mutex{}
|
|
|
|
type DesktopManagerCtx struct {
|
|
logger zerolog.Logger
|
|
cleanup *time.Ticker
|
|
shutdown chan bool
|
|
emmiter events.EventEmmiter
|
|
display string
|
|
config *config.Desktop
|
|
}
|
|
|
|
func New(display string, config *config.Desktop) *DesktopManagerCtx {
|
|
return &DesktopManagerCtx{
|
|
logger: log.With().Str("module", "desktop").Logger(),
|
|
cleanup: time.NewTicker(1 * time.Second),
|
|
shutdown: make(chan bool),
|
|
emmiter: events.New(),
|
|
display: display,
|
|
config: config,
|
|
}
|
|
}
|
|
|
|
func (manager *DesktopManagerCtx) Start() {
|
|
if err := xorg.DisplayOpen(manager.display); err != nil {
|
|
manager.logger.Warn().Err(err).Msg("unable to open dispaly")
|
|
}
|
|
|
|
xorg.GetScreenConfigurations()
|
|
|
|
manager.logger.Info().
|
|
Str("screen_size", fmt.Sprintf("%dx%d@%d", manager.config.ScreenWidth, manager.config.ScreenHeight, manager.config.ScreenRate)).
|
|
Msgf("setting initial screen size")
|
|
|
|
if err := xorg.ChangeScreenSize(manager.config.ScreenWidth, manager.config.ScreenHeight, manager.config.ScreenRate); err != nil {
|
|
manager.logger.Warn().Err(err).Msg("unable to set initial screen size")
|
|
}
|
|
|
|
go xevent.EventLoop(manager.display)
|
|
|
|
go manager.fileChooserDialogStart()
|
|
|
|
manager.OnEventError(func(error_code uint8, message string, request_code uint8, minor_code uint8) {
|
|
manager.logger.Warn().
|
|
Uint8("error_code", error_code).
|
|
Str("message", message).
|
|
Uint8("request_code", request_code).
|
|
Uint8("minor_code", minor_code).
|
|
Msg("X event error occured")
|
|
})
|
|
|
|
go func() {
|
|
defer func() {
|
|
xorg.DisplayClose()
|
|
manager.logger.Info().Msg("shutdown")
|
|
}()
|
|
|
|
for {
|
|
select {
|
|
case <-manager.shutdown:
|
|
return
|
|
case <-manager.cleanup.C:
|
|
xorg.CheckKeys(time.Second * 10)
|
|
}
|
|
}
|
|
}()
|
|
}
|
|
|
|
func (manager *DesktopManagerCtx) OnBeforeScreenSizeChange(listener func()) {
|
|
manager.emmiter.On("before_screen_size_change", func(payload ...interface{}) {
|
|
listener()
|
|
})
|
|
}
|
|
|
|
func (manager *DesktopManagerCtx) OnAfterScreenSizeChange(listener func()) {
|
|
manager.emmiter.On("after_screen_size_change", func(payload ...interface{}) {
|
|
listener()
|
|
})
|
|
}
|
|
|
|
func (manager *DesktopManagerCtx) Shutdown() error {
|
|
manager.logger.Info().Msgf("desktop shutting down")
|
|
|
|
manager.cleanup.Stop()
|
|
manager.shutdown <- true
|
|
return nil
|
|
}
|