Use of app.Ctx as default context for background go light-threads like

WHIP/HTTP/...

Author: PiterWeb

src/bindings/app.go

@@ -58,17 +58,15 @@ func (a *App) Startup(ctx context.Context) {
 	// Perform your setup here
 
 	go func() {
-
-		if err := oninit.Execute(a.assets); err != nil {
+		if err := oninit.Execute(a.ctx, a.assets); err != nil {
 			time.Sleep(time.Second * 5) // Add some time to load the UI
 			wailsRuntime.EventsEmit(ctx, "ERROR", err.Error())
 			log.Println(err)
 		}
-
 	}()
 
 	go func () {
-		if err := streaming_signal.InitWhipServer(streaming_signal.WhipConfig); err != nil {
+		if err := streaming_signal.InitWhipServer(a.ctx, streaming_signal.WhipConfig); err != nil {
 			time.Sleep(time.Second * 5) // Add some time to load the UI
 			wailsRuntime.EventsEmit(ctx, "ERROR", err.Error())
 			log.Println(err)

src/net/http/http.go

@@ -2,17 +2,19 @@
 package http
 
 import (
+	"context"
 	"embed"
 	"errors"
 	"fmt"
 	"io/fs"
+	"net"
 	"net/http"
 	"strings"
 
 	"github.com/PiterWeb/RemoteController/src/cli"
 )
 
-func InitHTTPAssets(serverMux *http.ServeMux, assets embed.FS) error {
+func InitHTTPAssets(ctx context.Context,serverMux *http.ServeMux, assets embed.FS) error {
 
 	config := cli.GetConfig()
 	clientPort := config.GetHTTPPort()
@@ -36,6 +38,9 @@ func InitHTTPAssets(serverMux *http.ServeMux, assets embed.FS) error {
 	httpServer := &http.Server{
 		Handler: serverMux,
 		Addr:    addr,
+		BaseContext: func(l net.Listener) context.Context {
+			return ctx
+		},
 	}
 
 	err = httpServer.ListenAndServe()

src/net/webrtc/streaming_signal/whip.go

@@ -7,6 +7,7 @@ import (
 	"fmt"
 	"io"
 	"log"
+	"net"
 	"net/http"
 	"sync/atomic"
 	"time"
@@ -34,7 +35,7 @@ var WhipConfig = &whipConfig{
 	ICEServers: atomic.Pointer[[]webrtc.ICEServer]{},
 }
 
-func InitWhipServer(config *whipConfig) error {
+func InitWhipServer(ctx context.Context, config *whipConfig) error {
 
 	var answerChan <-chan string = config.AnswerChan
 	var offerChan chan<- string = config.OfferChan
@@ -141,6 +142,9 @@ func InitWhipServer(config *whipConfig) error {
 		Addr:         fmt.Sprintf("127.0.0.1:%d", config.Port),
 		WriteTimeout: time.Second * 30,
 		ReadTimeout:  time.Second * 30,
+		BaseContext: func(l net.Listener) context.Context {
+			return ctx
+		},
 	}
 
 	err := httpServer.ListenAndServe()

src/oninit/oninit_darwin.go

@@ -1,25 +1,25 @@
 package oninit
 
 import (
+	"context"
 	"embed"
 	"log"
-	
+
 	LRPSignals "github.com/PiterWeb/LibreRemotePlaySignals/v1"
 	"github.com/PiterWeb/RemoteController/src/cli"
-	
 )
 
-func Execute(assets embed.FS) error {
+func Execute(ctx context.Context, assets embed.FS) error {
 
 	ips_channel := make(chan []string, 1)
 	defer close(ips_channel)
 
 	options := LRPSignals.ServerOptions{
 		Port: cli.GetConfig().GetEasyConnectPort(),
 	}
-	
+
 	log.Printf("Easy Connect Server started on port %d\n", options.Port)
-	
+
 	err := LRPSignals.InitServer(options, ips_channel)
 
 	return err

src/oninit/oninit_linux.go

@@ -1,6 +1,7 @@
 package oninit
 
 import (
+	"context"
 	"embed"
 	"errors"
 	"log"
@@ -12,7 +13,7 @@ import (
 	"github.com/PiterWeb/RemoteController/src/net/websocket"
 )
 
-func Execute(assets embed.FS) error {
+func Execute(ctx context.Context, assets embed.FS) error {
 
 	httpServerMux := http.NewServeMux()
 
@@ -22,7 +23,7 @@ func Execute(assets embed.FS) error {
 	errChan := make(chan error, 2)
 
 	go func() {
-		err := net_http.InitHTTPAssets(httpServerMux, assets)
+		err := net_http.InitHTTPAssets(ctx, httpServerMux, assets)
 
 		if err != nil {
 			errChan <- err

src/oninit/oninit_windows.go

@@ -1,16 +1,18 @@
 package oninit
 
 import (
+	"context"
 	"embed"
 	"log"
 	"net/http"
+
 	LRPSignals "github.com/PiterWeb/LibreRemotePlaySignals/v1"
-	net_http "github.com/PiterWeb/RemoteController/src/net/http"
 	"github.com/PiterWeb/RemoteController/src/cli"
 	"github.com/PiterWeb/RemoteController/src/devices/gamepad"
+	net_http "github.com/PiterWeb/RemoteController/src/net/http"
 )
 
-func Execute(assets embed.FS) error {
+func Execute(ctx context.Context, assets embed.FS) error {
 	err := gamepad.InitViGEm()
 
 	if err != nil {
@@ -23,19 +25,19 @@ func Execute(assets embed.FS) error {
 	errChan := make(chan error, 2)
 
 	go func() {
-		err := net_http.InitHTTPAssets(httpServerMux, assets)
+		err := net_http.InitHTTPAssets(ctx, httpServerMux, assets)
 
 		if err != nil {
 			errChan <- err
 		}
 	}()
-	
+
 	go func() {
 
 		options := LRPSignals.ServerOptions{
 			Port: cli.GetConfig().GetEasyConnectPort(),
 		}
-		
+
 		log.Printf("Easy Connect Server started on port %d\n", options.Port)
 		err := LRPSignals.InitServer(options, ips_channel)
 		if err != nil {