neko/internal/capture/manager.go

199 lines
5.7 KiB
Go
Raw Normal View History

2020-11-02 04:09:48 +13:00
package capture
import (
2021-02-06 03:10:41 +13:00
"fmt"
"sync"
2020-11-02 04:09:48 +13:00
"github.com/rs/zerolog"
"github.com/rs/zerolog/log"
"demodesk/neko/internal/types"
2021-02-07 06:18:49 +13:00
"demodesk/neko/internal/types/codec"
2020-11-02 04:09:48 +13:00
"demodesk/neko/internal/config"
)
type CaptureManagerCtx struct {
logger zerolog.Logger
mu sync.Mutex
desktop types.DesktopManager
streaming bool
broadcast *BroacastManagerCtx
screencast *ScreencastManagerCtx
audio *StreamManagerCtx
videos map[string]*StreamManagerCtx
videoIDs []string
2020-11-02 04:09:48 +13:00
}
func New(desktop types.DesktopManager, config *config.Capture) *CaptureManagerCtx {
2021-02-06 01:58:02 +13:00
logger := log.With().Str("module", "capture").Logger()
2021-02-06 03:10:41 +13:00
broadcastPipeline := config.BroadcastPipeline
if broadcastPipeline == "" {
broadcastPipeline = fmt.Sprintf(
"flvmux name=mux ! rtmpsink location='{url} live=1' " +
"pulsesrc device=%s " +
"! audio/x-raw,channels=2 " +
"! audioconvert " +
"! queue " +
"! voaacenc " +
"! mux. " +
"ximagesrc display-name=%s show-pointer=true use-damage=false " +
"! video/x-raw " +
"! videoconvert " +
"! queue " +
"! x264enc threads=4 bitrate=4096 key-int-max=15 byte-stream=true byte-stream=true tune=zerolatency speed-preset=veryfast " +
"! mux.", config.Device, config.Display,
)
}
2021-02-06 01:58:02 +13:00
2021-02-06 03:10:41 +13:00
screencastPipeline := config.ScreencastPipeline
if screencastPipeline == "" {
screencastPipeline = fmt.Sprintf(
"ximagesrc display-name=%s show-pointer=true use-damage=false " +
"! video/x-raw,framerate=%s " +
"! videoconvert " +
"! queue " +
"! jpegenc quality=%s " +
"! appsink name=appsink", config.Display, config.ScreencastRate, config.ScreencastQuality,
)
2021-02-06 01:58:02 +13:00
}
2021-02-06 03:10:41 +13:00
audioPipeline := config.AudioPipeline
if audioPipeline == "" {
audioPipeline = fmt.Sprintf(
"pulsesrc device=%s " +
"! audio/x-raw,channels=2 " +
"! audioconvert " +
"! queue " +
"! %s " +
"! appsink name=appsink", config.Device, config.AudioCodec.Pipeline,
)
}
2021-02-06 01:58:02 +13:00
2020-11-02 04:09:48 +13:00
return &CaptureManagerCtx{
2021-02-06 01:58:02 +13:00
logger: logger,
desktop: desktop,
streaming: false,
2021-02-06 01:58:02 +13:00
broadcast: broadcastNew(broadcastPipeline),
screencast: screencastNew(config.Screencast, screencastPipeline),
audio: streamNew(config.AudioCodec, audioPipeline),
videos: map[string]*StreamManagerCtx{
2021-02-07 06:18:49 +13:00
"hd": streamNew(codec.VP8(), fmt.Sprintf(
"ximagesrc display-name=%s show-pointer=false use-damage=false " +
"! video/x-raw " +
"! videoconvert " +
"! queue " +
"! vp8enc target-bitrate=8192000 cpu-used=16 threads=4 deadline=1 error-resilient=partitions keyframe-max-dist=15 static-threshold=20 " +
"! appsink name=appsink", config.Display,
)),
"hq": streamNew(codec.VP8(), fmt.Sprintf(
"ximagesrc display-name=%s show-pointer=false use-damage=false " +
"! video/x-raw " +
"! videoconvert " +
"! queue " +
"! vp8enc target-bitrate=4096000 cpu-used=16 threads=4 deadline=1 error-resilient=partitions keyframe-max-dist=15 static-threshold=20 " +
"! appsink name=appsink", config.Display,
)),
"mq": streamNew(codec.VP8(), fmt.Sprintf(
"ximagesrc display-name=%s show-pointer=false use-damage=false " +
"! video/x-raw " +
"! videoconvert " +
"! queue " +
"! vp8enc target-bitrate=2048000 cpu-used=16 threads=4 deadline=1 error-resilient=partitions keyframe-max-dist=15 static-threshold=20 " +
"! appsink name=appsink", config.Display,
)),
"lq": streamNew(codec.VP8(), fmt.Sprintf(
"ximagesrc display-name=%s show-pointer=false use-damage=false " +
"! video/x-raw " +
"! videoconvert " +
"! queue " +
"! vp8enc target-bitrate=1024000 cpu-used=16 threads=4 deadline=1 error-resilient=partitions keyframe-max-dist=15 static-threshold=20 " +
"! appsink name=appsink", config.Display,
)),
},
2021-02-07 06:18:49 +13:00
videoIDs: []string{ "hd", "hq", "mq", "lq" },
2020-11-02 04:09:48 +13:00
}
}
func (manager *CaptureManagerCtx) Start() {
2021-02-06 02:03:53 +13:00
if manager.broadcast.Started() {
if err := manager.broadcast.createPipeline(); err != nil {
2020-11-19 11:32:43 +13:00
manager.logger.Panic().Err(err).Msg("unable to create broadcast pipeline")
}
}
2020-11-02 04:09:48 +13:00
manager.desktop.OnBeforeScreenSizeChange(func() {
for _, video := range manager.videos {
if video.Started() {
video.destroyPipeline()
}
}
2021-02-06 02:03:53 +13:00
if manager.broadcast.Started() {
manager.broadcast.destroyPipeline()
}
2021-01-23 06:13:32 +13:00
2021-01-24 03:17:52 +13:00
if manager.screencast.Started() {
2021-01-23 06:13:32 +13:00
manager.screencast.destroyPipeline()
}
})
2020-11-02 04:09:48 +13:00
manager.desktop.OnAfterScreenSizeChange(func() {
for _, video := range manager.videos {
if video.Started() {
if err := video.createPipeline(); err != nil {
manager.logger.Panic().Err(err).Msg("unable to recreate video pipeline")
}
}
}
2021-02-06 02:03:53 +13:00
if manager.broadcast.Started() {
if err := manager.broadcast.createPipeline(); err != nil {
2021-01-23 06:13:32 +13:00
manager.logger.Panic().Err(err).Msg("unable to recreate broadcast pipeline")
}
}
2021-01-24 03:17:52 +13:00
if manager.screencast.Started() {
2021-01-23 06:13:32 +13:00
if err := manager.screencast.createPipeline(); err != nil {
manager.logger.Panic().Err(err).Msg("unable to recreate screencast pipeline")
2020-11-19 11:32:43 +13:00
}
}
2020-11-04 12:27:47 +13:00
})
2020-11-02 04:09:48 +13:00
}
func (manager *CaptureManagerCtx) Shutdown() error {
manager.logger.Info().Msgf("capture shutting down")
2021-02-03 06:28:32 +13:00
2021-02-06 00:18:46 +13:00
manager.broadcast.shutdown()
manager.screencast.shutdown()
manager.audio.shutdown()
for _, video := range manager.videos {
video.shutdown()
}
2020-11-02 04:09:48 +13:00
return nil
}
func (manager *CaptureManagerCtx) Broadcast() types.BroadcastManager {
return manager.broadcast
}
2021-01-23 06:13:32 +13:00
func (manager *CaptureManagerCtx) Screencast() types.ScreencastManager {
return manager.screencast
}
func (manager *CaptureManagerCtx) Audio() types.StreamManager {
return manager.audio
2020-11-02 04:09:48 +13:00
}
2021-02-06 06:07:58 +13:00
func (manager *CaptureManagerCtx) Video(videoID string) (types.StreamManager, bool) {
video, ok := manager.videos[videoID]
return video, ok
}
func (manager *CaptureManagerCtx) VideoIDs() []string {
return manager.videoIDs
2020-11-02 04:09:48 +13:00
}