From c0ca073b2dbf7844263e746a190e5ac0cfbbf914 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= <sedivy.miro@gmail.com>
Date: Mon, 12 Sep 2022 22:16:08 +0200
Subject: [PATCH] move gst and broadcast under capture.

---
 .../internal/{broadcast/manager.go => capture/broadcast.go} | 6 +++---
 server/internal/{ => capture}/gst/gst.c                     | 0
 server/internal/{ => capture}/gst/gst.go                    | 0
 server/internal/{ => capture}/gst/gst.h                     | 0
 server/internal/capture/manager.go                          | 2 +-
 server/neko.go                                              | 5 ++---
 6 files changed, 6 insertions(+), 7 deletions(-)
 rename server/internal/{broadcast/manager.go => capture/broadcast.go} (92%)
 rename server/internal/{ => capture}/gst/gst.c (100%)
 rename server/internal/{ => capture}/gst/gst.go (100%)
 rename server/internal/{ => capture}/gst/gst.h (100%)

diff --git a/server/internal/broadcast/manager.go b/server/internal/capture/broadcast.go
similarity index 92%
rename from server/internal/broadcast/manager.go
rename to server/internal/capture/broadcast.go
index 3ab92cb8..c3394ad2 100644
--- a/server/internal/broadcast/manager.go
+++ b/server/internal/capture/broadcast.go
@@ -1,4 +1,4 @@
-package broadcast
+package capture
 
 import (
 	"sync"
@@ -6,7 +6,7 @@ import (
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
 
-	"m1k1o/neko/internal/gst"
+	"m1k1o/neko/internal/capture/gst"
 	"m1k1o/neko/internal/types/config"
 )
 
@@ -20,7 +20,7 @@ type BroadcastManager struct {
 	url      string
 }
 
-func New(capture *config.Capture, config *config.Broadcast) *BroadcastManager {
+func NewBroadcast(capture *config.Capture, config *config.Broadcast) *BroadcastManager {
 	return &BroadcastManager{
 		logger:  log.With().Str("module", "broadcast").Logger(),
 		capture: capture,
diff --git a/server/internal/gst/gst.c b/server/internal/capture/gst/gst.c
similarity index 100%
rename from server/internal/gst/gst.c
rename to server/internal/capture/gst/gst.c
diff --git a/server/internal/gst/gst.go b/server/internal/capture/gst/gst.go
similarity index 100%
rename from server/internal/gst/gst.go
rename to server/internal/capture/gst/gst.go
diff --git a/server/internal/gst/gst.h b/server/internal/capture/gst/gst.h
similarity index 100%
rename from server/internal/gst/gst.h
rename to server/internal/capture/gst/gst.h
diff --git a/server/internal/capture/manager.go b/server/internal/capture/manager.go
index 934d0afa..d0494be3 100644
--- a/server/internal/capture/manager.go
+++ b/server/internal/capture/manager.go
@@ -4,8 +4,8 @@ import (
 	"fmt"
 	"time"
 
+	"m1k1o/neko/internal/capture/gst"
 	"m1k1o/neko/internal/desktop/xorg"
-	"m1k1o/neko/internal/gst"
 	"m1k1o/neko/internal/types"
 	"m1k1o/neko/internal/types/config"
 
diff --git a/server/neko.go b/server/neko.go
index 99204174..804fe69a 100644
--- a/server/neko.go
+++ b/server/neko.go
@@ -6,7 +6,6 @@ import (
 	"os/signal"
 	"runtime"
 
-	"m1k1o/neko/internal/broadcast"
 	"m1k1o/neko/internal/capture"
 	"m1k1o/neko/internal/desktop"
 	"m1k1o/neko/internal/http"
@@ -114,7 +113,7 @@ type Neko struct {
 	sessionManager   *session.SessionManager
 	captureManager   *capture.CaptureManagerCtx
 	desktopManager   *desktop.DesktopManagerCtx
-	broadcastManager *broadcast.BroadcastManager
+	broadcastManager *capture.BroadcastManager
 	webRTCManager    *webrtc.WebRTCManager
 	webSocketHandler *websocket.WebSocketHandler
 }
@@ -124,7 +123,7 @@ func (neko *Neko) Preflight() {
 }
 
 func (neko *Neko) Start() {
-	broadcastManager := broadcast.New(neko.Capture, neko.Broadcast)
+	broadcastManager := capture.NewBroadcast(neko.Capture, neko.Broadcast)
 
 	desktopManager := desktop.New(neko.Desktop, broadcastManager)
 	desktopManager.Start()