Adds static www content to binary

README.md

@@ -2,30 +2,39 @@
 
 **go2rtc** - ultimate camera streaming application with support RTSP, WebRTC, FFmpeg, RTMP, etc.
 
-- zero-dependency and zero-config small app for all OS (Windows, macOS, Linux, ARM, etc.)
+- zero-dependency and zero-config small [app for all OS](#installation) (Windows, macOS, Linux, ARM)
 - zero-delay for all supported protocols (lowest possible streaming latency)
 - zero-load on CPU for supported codecs
-- on the fly transcoding for unsupported codecs via FFmpeg
-- multi-source two-way [codecs negotiation](#codecs-negotiation)
-- streaming from private networks via Ngrok or SSH-tunnels
+- on the fly transcoding for unsupported codecs [via FFmpeg](#source-ffmpeg)
+- multi-source 2-way [codecs negotiation](#codecs-negotiation)
+- streaming from private networks via [Ngrok or SSH-tunnels](#module-webrtc)
+
+**Inspired by:**
+
+- [webrtc](https://github.com/pion/webrtc) go library and whole [@pion](https://github.com/pion) team
+- series of streaming projects from [@deepch](https://github.com/deepch)
+- [rtsp-simple-server](https://github.com/aler9/rtsp-simple-server) idea from [@aler9](https://github.com/aler9)
+- [GStreamer](https://gstreamer.freedesktop.org/) multimedia framework pipeline idea
+- [MediaSoup](https://mediasoup.org/) framework routing idea
 
 ## Codecs negotiation
 
-For example, you want to watch stream from [Dahua IPC-K42](https://www.dahuasecurity.com/fr/products/All-Products/Network-Cameras/Wireless-Series/Wi-Fi-Series/4MP/IPC-K42) camera in your browser.
+For example, you want to watch RTSP-stream from [Dahua IPC-K42](https://www.dahuasecurity.com/fr/products/All-Products/Network-Cameras/Wireless-Series/Wi-Fi-Series/4MP/IPC-K42) camera in your Chrome browser.
 
+- this camera support 2-way audio standard **ONVIF Profile T**
 - this camera support codecs **H264, H265** for send video, and you select `H264` in camera settings
 - this camera support codecs **AAC, PCMU, PCMA** for send audio (from mic), and you select `AAC/16000` in camera settings
 - this camera support codecs **AAC, PCMU, PCMA** for receive audio (to speaker), you don't need to select them
 - your browser support codecs **H264, VP8, VP9, AV1** for receive video, you don't need to select them
 - your browser support codecs **OPUS, PCMU, PCMA** for send and receive audio, you don't need to select them
-- you can't get camera audio directly, because their audio codecs doesn't match with your browser codecs 
+- you can't get camera audio directly, because its audio codecs doesn't match with your browser codecs 
    - so you decide to use transcoding via FFmpeg and add this setting to config YAML file
-   - you have chosen `OPUS/48000/2` codec, because it is higher quality than the PCMU/8000 or PCMA/8000
+   - you have chosen `OPUS/48000/2` codec, because it is higher quality than the `PCMU/8000` or `PCMA/8000`
 - now you have stream with two sources - **RTSP and FFmpeg**
 
-`go2rtc` automatically match codecs for you browser and all your stream sources. This called **multi-source two-way codecs negotiation**. And this is one of the main features of this app.
+**go2rtc** automatically match codecs for you browser and all your stream sources. This called **multi-source 2-way codecs negotiation**. And this is one of the main features of this app.
 
-**PS.** You can select PCMU or PCMA codec in camera setting and don't use transcoding at all. Or you can select AAC codec for main stream and PCMU codec for second stream and add both RTSP to YAML config, this also will work fine.
+**PS.** You can select `PCMU` or `PCMA` codec in camera setting and don't use transcoding at all. Or you can select `AAC` codec for main stream and `PCMU` codec for second stream and add both RTSP to YAML config, this also will work fine.
 
 ```yaml
 streams:
@@ -36,45 +45,79 @@ streams:
 
 ![](codecs.svg)
 
+## Installation
+
+Download binary for your OS from [latest release](https://github.com/AlexxIT/go2rtc/releases/):
+
+- `go2rtc_win64.exe` - Windows 64-bit
+- `go2rtc_win32.exe` - Windows 32-bit
+- `go2rtc_linux_amd64` - Linux 64-bit
+- `go2rtc_linux_i386` - Linux 32-bit
+- `go2rtc_linux_arm64` - Linux ARM 64-bit (ex. Raspberry 64-bit OS)
+- `go2rtc_linux_arm` - Linux ARM 32-bit (ex. Raspberry 32-bit OS)
+- `go2rtc_linux_mipsel` - Linux on MIPS (ex. [Xiaomi Gateway 3](https://github.com/AlexxIT/XiaomiGateway3))
+- `go2rtc_mac_amd64` - Mac with Intel
+- `go2rtc_mac_arm64` - Mac with M1
+
+Don't forget to fix the rights `chmod +x go2rtc_linux_xxx` on Linux and Mac.
+
 ## Configuration
 
-Create file `go2rtc.yaml` next to the app. Modules:
+Create file `go2rtc.yaml` next to the app.
 
-- [Streams](#streams)
+- by default, you need to config only your `streams` links
+- `api` server will start on default **1984 port**
+- `rtsp` server will start on default **8554 port**
+- `webrtc` will use random UDP port for each connection
+- `ffmpeg` will use default transcoding options (you need to install it [manually](https://ffmpeg.org/))
 
-### Streams
+Available modules:
 
-**go2rtc** support different stream source types. You can setup only one link as stream source or multiple.
+- [streams](#module-streams)
+- [api](#module-api) - HTTP API (important for WebRTC support)
+- [rtsp](#module-rtsp) - RTSP Server (important for FFmpeg support)
+- [webrtc](#module-webrtc) - WebRTC Server (important for external access)
+- [ngrok](#module-ngrok) - Ngrok integration (external access for private network)
+- [ffmpeg](#source-ffmpeg) - FFmpeg integration
+- [hass](#module-hass) - Home Assistant integration
+- [log](#module-log) - logs config
 
-- [RTSP/RTSPS](#rtsp-source) - most cameras on market
-- [RTMP](#rtmp-source)
-- [FFmpeg/Exec](#ffmpeg-source) - FFmpeg integration
-- [Hass](#hass-source) - Home Assistant integration
+### Module: Streams
 
-#### RTSP source
+**go2rtc** support different stream source types. You can config only one link as stream source or multiple.
+
+Available source types:
+
+- [rtsp](#source-rtsp) - most cameras on market
+- [rtmp](#source-rtmp)
+- [ffmpeg](#source-ffmpeg) - FFmpeg integration
+- [exec](#source-exec) - advanced FFmpeg and GStreamer integration
+- [hass](#source-hass) - Home Assistant integration
+
+#### Source: RTSP
 
 - Support **RTSP and RTSPS** links with multiple video and audio tracks
-- Support **2 way audio** ONLY for [ONVIF Profile T](https://www.onvif.org/specs/stream/ONVIF-Streaming-Spec.pdf) cameras (back channel connection)
+- Support **2-way audio** ONLY for [ONVIF Profile T](https://www.onvif.org/specs/stream/ONVIF-Streaming-Spec.pdf) cameras (back channel connection)
 
-**Attention:** proprietary 2 way audio standards are not supported!
+**Attention:** proprietary 2-way audio standards are not supported!
 
 ```yaml
 streams:
-  rtsp_camera: rtsp://rtsp:12345678@192.168.1.123:554/av_stream/ch0
+  sonoff_camera: rtsp://rtsp:12345678@192.168.1.123/av_stream/ch0
 ```
 
-If your camera support two RTSP links - you can add both of them as sources. This is useful when streams has different codecs, as example AAC audio with main stream and PCMU/PCMA audio with second stream:
+If your camera has two RTSP links - you can add both of them as sources. This is useful when streams has different codecs, as example AAC audio with main stream and PCMU/PCMA audio with second stream.
 
-**Attention:** Dahua cameras has different capabilities for different RTSP links. For example, it has support multiple codecs for two way audio with `&proto=Onvif` in link and only one coded without it.
+**Attention:** Dahua cameras has different capabilities for different RTSP links. For example, it has support multiple codecs for 2-way audio with `&proto=Onvif` in link and only one codec without it.
 
 ```yaml
 streams:
-  onvif_camera:
+  dahua_camera:
     - rtsp://admin:password@192.168.1.123/cam/realmonitor?channel=1&subtype=0&unicast=true&proto=Onvif
     - rtsp://admin:password@192.168.1.123/cam/realmonitor?channel=1&subtype=1
 ```
 
-#### RTMP source
+#### Source: RTMP
 
 You can get stream from RTMP server, for example [Frigate](https://docs.frigate.video/configuration/rtmp). Support ONLY `H264` video codec without audio.
 
@@ -83,9 +126,9 @@ streams:
   rtmp_stream: rtmp://192.168.1.123/live/camera1
 ```
 
-#### FFmpeg source
+#### Source: FFmpeg
 
-You can get any stream or file or device via FFmpeg and push it to go2rtc via RTSP protocol.
+You can get any stream or file or device via FFmpeg and push it to go2rtc. The app will automatically start FFmpeg with the proper arguments when someone starts watching the stream.
 
 Format: `ffmpeg:{input}#{params}`. Examples:
 
@@ -107,10 +150,10 @@ streams:
   mjpeg: ffmpeg:http://185.97.122.128/cgi-bin/faststream.jpg?stream=half&fps=15#video=h264
 
   # [RTSP] video and audio will be copied
-  rtsp: ffmpeg:rtsp://rtsp:12345678@192.168.1.123:554/av_stream/ch0#video=copy&audio=copy
+  rtsp: ffmpeg:rtsp://rtsp:12345678@192.168.1.123/av_stream/ch0#video=copy&audio=copy
 ```
 
-All trascoding formats has built-in templates. But you can override them via YAML config:
+All trascoding formats has built-in templates. But you can override them via YAML config. You can also add your own formats to config and use them with source params.
 
 ```yaml
 ffmpeg:
@@ -134,7 +177,7 @@ ffmpeg:
   aac/16000:  "-codec:a aac -ar 16000 -ac 1"
 ```
 
-#### Exec source
+#### Source: Exec
 
 FFmpeg source just a shortcut to exec source. You can get any stream or file or device via FFmpeg or GStreamer and push it to go2rtc via RTSP protocol: 
 
@@ -143,9 +186,9 @@ streams:
   stream1: exec:ffmpeg -hide_banner -re -stream_loop -1 -i ~/media/BigBuckBunny.mp4 -c copy -rtsp_transport tcp -f rtsp {output}
 ```
 
-#### Hass source
+#### Source: Hass
 
-Support import camera links from [Home Assistant](https://www.home-assistant.io/) config files.
+Support import camera links from [Home Assistant](https://www.home-assistant.io/) config files:
 
 - support ONLY [Generic Camera](https://www.home-assistant.io/integrations/generic/), setup via GUI
 
@@ -157,31 +200,97 @@ streams:
   generic_camera: hass:Camera1  # Settings > Integrations > Integration Name
 ```
 
-### API server
+### Module: API
+
+The HTTP API is the main part for interacting with the application.
+
+- you can use WebRTC only when HTTP API enabled
+- you can disable HTTP API with `listen: ""` and use, for example, only RTSP client/server protocol
+- you can enable HTTP API only on localhost with `listen: "127.0.0.1:1984"` setting
+- you can change API `base_path` and host go2rtc on your main app webserver suburl
+- all files from `static_dir` hosted on root path: `/`
 
 ```yaml
 api:
-  listen: ":3000"    # HTTP API port
+  listen: ":1984"    # HTTP API port ("" - disabled)
   base_path: ""      # API prefix for serve on suburl
-  static_dir: "www"  # folder for static files
+  static_dir: "www"  # folder for static files ("" - disabled)
 ```
 
-### RTSP server
+### Module: RTSP
+
+You can get any stream as RTSP-stream with codecs filter:
+
+```
+rtsp://192.168.1.123/{stream_name}?video={codec}&audio={codec1}&audio={codec2}
+```
+
+- you can omit the codecs, so one first video and one first audio will be selected
+- you can set `?video=copy` or just `?video`, so only one first video without audio will be selected
+- you can set multiple video or audio, so all of them will be selected
 
 ```yaml
 rtsp:
-  listen: ":554"
+  listen: ":8554"
 ```
 
-### WebRTC server
+### Module: WebRTC
+
+WebRTC usually works without problems in the local network. But external access may require additional settings. It depends on what type of internet do you have.
+
+- by default, WebRTC use two random UDP ports for each connection (for video and audio)
+- you can enable one additional TCP port for all connections and use it for external access
+
+**Static public IP**
+
+- add some TCP port to YAML config (ex. 8555)
+- forward this port on your router (you can use same 8555 port or any other)
+- add your external IP-address and external port to YAML config
 
 ```yaml
 webrtc:
   listen: ":8555"  # address of your local server (TCP)
   candidates:
     - 216.58.210.174:8555  # if you have static public IP-address
-    - 192.168.1.123:8555   # ip you have problems with UDP in LAN
-    - stun   # if you have dynamic public IP-address (auto discovery via STUN)
+```
+
+**Dynamic public IP**
+
+- add some TCP port to YAML config (ex. 8555)
+- forward this port on your router (you can use same 8555 port or any other)
+- add `stun` word and external port to YAML config
+  - go2rtc automatically detects your external address with STUN-server
+
+```yaml
+webrtc:
+  listen: ":8555"  # address of your local server (TCP)
+  candidates:
+    - stun:8555  # if you have dynamic public IP-address
+```
+
+**Private IP**
+
+- add some TCP port to YAML config (ex. 8555)
+- setup integration with [Ngrok service](#module-ngrok)
+
+```yaml
+webrtc:
+  listen: ":8555"  # address of your local server (TCP)
+
+ngrok:
+  command: ...
+```
+
+**Own TCP-tunnel**
+
+If you have personal VPS, you can create TCP-tunnel and setup in the same way as "Static public IP". But use your VPS IP-address in YAML config.
+
+**Using TURN-server**
+
+TODO...
+
+```yaml
+webrtc:
   ice_servers:
     - urls: [stun:stun.l.google.com:19302]
     - urls: [turn:123.123.123.123:3478]
@@ -189,21 +298,73 @@ webrtc:
       credential: your_pass
 ```
 
-### Ngrok
+### Module: Ngrok
+
+With Ngrok integration you can get external access to your streams in situation when you have Internet with private IP-address.
+
+- you may need external access for two different things:
+  - WebRTC stream, so you need tunnel WebRTC TCP port (ex. 8555)
+  - go2rtc web interface, so you need tunnel API HTTP port (ex. 1984)
+- Ngrok support authorization for your web interface
+- Ngrok automatically adds HTTPS to your web interface
+
+Ngrok free subscription limitations:
+
+- you will always get random external address (not a problem for webrtc stream)
+- you can forward multiple ports but use only one Ngrok app
+
+go2rtc will automatically get your external TCP address (if you enable it in ngrok config) and use it with WebRTC connection (if you enable it in webrtc config).
+
+You need manually download [Ngrok agent app](https://ngrok.com/download) for your OS and register in [Ngrok service](https://ngrok.com/).
+
+**Tunnel for only WebRTC Stream**
+
+You need to add your [Ngrok token](https://dashboard.ngrok.com/get-started/your-authtoken) and WebRTC TCP port to YAML:
 
 ```yaml
 ngrok:
   command: ngrok tcp 8555 --authtoken eW91IHNoYWxsIG5vdCBwYXNzCnlvdSBzaGFsbCBub3QgcGFzcw
 ```
 
-or
+**Tunnel for WebRTC and Web interface**
+
+You need to create `ngrok.yaml` config file and add it to go2rtc config:
 
 ```yaml
 ngrok:
-  command: ngrok start --all --config ngrok.yml
+  command: ngrok start --all --config ngrok.yaml
 ```
 
-### Log
+Ngrok config example:
+
+```yaml
+version: "2"
+authtoken: eW91IHNoYWxsIG5vdCBwYXNzCnlvdSBzaGFsbCBub3QgcGFzcw
+tunnels:
+  api:
+    addr: 1984  # use the same port as in go2rtc config
+    proto: http
+    basic_auth:
+      - admin:password  # you can set login/pass for your web interface
+  webrtc:
+    addr: 8555  # use the same port as in go2rtc config
+    proto: tcp
+```
+
+### Module: Hass
+
+go2rtc compatible with Home Assistant [RTSPtoWebRTC](https://www.home-assistant.io/integrations/rtsp_to_webrtc/) integration API.
+
+- add integration with link to go2rtc HTTP API:
+  - Hass > Settings > Integrations > Add Integration > RTSPtoWebRTC > `http://192.168.1.123:1984/`
+- add generic camera with RTSP link:
+  - Hass > Settings > Integrations > Add Integration > Generic Camera > `rtsp://...`
+- use Picture Entity or Picture Glance lovelace card
+- open full screen card - this is should be WebRTC stream
+
+### Module: Log
+
+You can set different log levels for different modules.
 
 ```yaml
 log:

cmd/api/api.go

@@ -21,8 +21,7 @@ func Init() {
 	}
 
 	// default config
-	cfg.Mod.Listen = ":3000"
-	cfg.Mod.StaticDir = "www"
+	cfg.Mod.Listen = ":1984"
 
 	// load config from YAML
 	app.LoadConfig(&cfg)
@@ -34,11 +33,10 @@ func Init() {
 	basePath = cfg.Mod.BasePath
 	log = app.GetLogger("api")
 
-	if cfg.Mod.StaticDir != "" {
-		fileServer = http.FileServer(http.Dir(cfg.Mod.StaticDir))
-		HandleFunc("/", fileServerHandlder)
-	}
+	initStatic(cfg.Mod.StaticDir)
 
+	HandleFunc("/api/frame.mp4", frameHandler)
+	HandleFunc("/api/frame.raw", frameHandler)
 	HandleFunc("/api/stack", stackHandler)
 	HandleFunc("/api/stats", statsHandler)
 	HandleFunc("/api/ws", apiWS)
@@ -68,20 +66,12 @@ func HandleWS(msgType string, handler WSHandler) {
 }
 
 var basePath string
-var fileServer http.Handler
 var log zerolog.Logger
 var wsHandlers = make(map[string]WSHandler)
 
-func fileServerHandlder(w http.ResponseWriter, r *http.Request) {
-	if basePath != "" {
-		r.URL.Path = r.URL.Path[len(basePath):]
-	}
-	fileServer.ServeHTTP(w, r)
-}
-
 func statsHandler(w http.ResponseWriter, _ *http.Request) {
 	v := map[string]interface{}{
-		"streams": streams.Streams,
+		"streams": streams.All(),
 	}
 	data, err := json.Marshal(v)
 	if err != nil {

cmd/api/keyframe.go

@@ -0,0 +1,40 @@
+package api
+
+import (
+	"github.com/AlexxIT/go2rtc/cmd/streams"
+	"github.com/AlexxIT/go2rtc/pkg/keyframe"
+	"net/http"
+	"strings"
+)
+
+func frameHandler(w http.ResponseWriter, r *http.Request) {
+	url := r.URL.Query().Get("url")
+	stream := streams.Get(url)
+	if stream == nil {
+		return
+	}
+
+	var ch = make(chan []byte)
+
+	cons := new(keyframe.Consumer)
+	cons.IsMP4 = strings.HasSuffix(r.URL.Path, ".mp4")
+	cons.Listen(func(msg interface{}) {
+		switch msg.(type) {
+		case []byte:
+			ch <- msg.([]byte)
+		}
+	})
+
+	if err := stream.AddConsumer(cons); err != nil {
+		log.Warn().Err(err).Msg("[api.frame] add consumer")
+		return
+	}
+
+	data := <-ch
+
+	stream.RemoveConsumer(cons)
+
+	if _, err := w.Write(data); err != nil {
+		log.Error().Err(err).Msg("[api.frame] write")
+	}
+}

cmd/api/static.go

@@ -0,0 +1,25 @@
+package api
+
+import (
+	"github.com/AlexxIT/go2rtc/www"
+	"net/http"
+)
+
+func initStatic(staticDir string) {
+	var root http.FileSystem
+	if staticDir != "" {
+		root = http.Dir(staticDir)
+	} else {
+		root = http.FS(www.Static)
+	}
+
+	fileServer := http.FileServer(root)
+
+	HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		if basePath != "" {
+			r.URL.Path = r.URL.Path[len(basePath):]
+		}
+
+		fileServer.ServeHTTP(w, r)
+	})
+}

cmd/app/app.go

@@ -49,11 +49,17 @@ func LoadConfig(v interface{}) {
 }
 
 func GetLogger(module string) zerolog.Logger {
-	lvl, err := zerolog.ParseLevel(modules[module])
-	if err != nil {
-		return log
+	if s, ok := modules[module]; ok {
+		lvl, err := zerolog.ParseLevel(s)
+		if err != nil {
+			log.Warn().Err(err).Msg("[log]")
+			return log
+		}
+
+		return log.Level(lvl)
 	}
-	return log.Level(lvl)
+
+	return log
 }
 
 // internal

cmd/cmd.go

@@ -1,41 +0,0 @@
-package cmd
-
-import (
-	"github.com/AlexxIT/go2rtc/cmd/api"
-	"github.com/AlexxIT/go2rtc/cmd/app"
-	"github.com/AlexxIT/go2rtc/cmd/exec"
-	"github.com/AlexxIT/go2rtc/cmd/ffmpeg"
-	"github.com/AlexxIT/go2rtc/cmd/hass"
-	"github.com/AlexxIT/go2rtc/cmd/mse"
-	"github.com/AlexxIT/go2rtc/cmd/ngrok"
-	"github.com/AlexxIT/go2rtc/cmd/rtmp"
-	"github.com/AlexxIT/go2rtc/cmd/rtsp"
-	"github.com/AlexxIT/go2rtc/cmd/streams"
-	"github.com/AlexxIT/go2rtc/cmd/webrtc"
-	"os"
-	"os/signal"
-)
-
-func Run() {
-	app.Init()     // init config and logs
-	streams.Init() // load streams list
-
-	rtsp.Init()   // add support RTSP client and RTSP server
-	rtmp.Init()   // add support RTMP client
-	exec.Init()   // add support exec scheme (depends on RTSP server)
-	ffmpeg.Init() // add support ffmpeg scheme (depends on exec scheme)
-	hass.Init()   // add support hass scheme
-
-	api.Init() // init HTTP API server
-
-	webrtc.Init()
-	mse.Init()
-
-	ngrok.Init()
-
-	c := make(chan os.Signal)
-	signal.Notify(c)
-	<-c
-
-	println("exit OK")
-}

cmd/hass/hass.go

@@ -1,11 +1,16 @@
 package hass
 
 import (
+	"encoding/base64"
 	"encoding/json"
 	"fmt"
+	"github.com/AlexxIT/go2rtc/cmd/api"
 	"github.com/AlexxIT/go2rtc/cmd/app"
 	"github.com/AlexxIT/go2rtc/cmd/streams"
+	"github.com/AlexxIT/go2rtc/cmd/webrtc"
 	"github.com/AlexxIT/go2rtc/pkg/streamer"
+	"github.com/rs/zerolog"
+	"net/http"
 	"os"
 	"path"
 )
@@ -19,6 +24,15 @@ func Init() {
 
 	app.LoadConfig(&conf)
 
+	log = app.GetLogger("api")
+
+	// support https://www.home-assistant.io/integrations/rtsp_to_webrtc/
+	api.HandleFunc("/static", func(w http.ResponseWriter, r *http.Request) {
+		w.WriteHeader(http.StatusOK)
+	})
+	api.HandleFunc("/stream", handler)
+
+	// support load cameras from Hass config file
 	filename := path.Join(conf.Mod.Config, ".storage/core.config_entries")
 	data, err := os.ReadFile(filename)
 	if err != nil {
@@ -49,6 +63,49 @@ func Init() {
 	})
 }
 
+var log zerolog.Logger
+
+func handler(w http.ResponseWriter, r *http.Request) {
+	if err := r.ParseForm(); err != nil {
+		log.Error().Err(err).Msg("[api.hass] parse form")
+		return
+	}
+
+	url := r.FormValue("url")
+	str := r.FormValue("sdp64")
+
+	offer, err := base64.StdEncoding.DecodeString(str)
+	if err != nil {
+		log.Error().Err(err).Msg("[api.hass] sdp64 decode")
+		return
+	}
+
+	stream := streams.Get(url)
+	str, err = webrtc.ExchangeSDP(stream, string(offer), r.UserAgent())
+	if err != nil {
+		log.Error().Err(err).Msg("[api.hass] exchange SDP")
+		return
+	}
+
+	resp := struct {
+		Answer string `json:"sdp64"`
+	}{
+		Answer: base64.StdEncoding.EncodeToString([]byte(str)),
+	}
+
+	data, err := json.Marshal(resp)
+	if err != nil {
+		log.Error().Err(err).Msg("[api.hass] marshal JSON")
+		return
+	}
+
+	w.Header().Set("Content-Type", "application/json")
+	if _, err = w.Write(data); err != nil {
+		log.Error().Err(err).Msg("[api.hass] write")
+		return
+	}
+}
+
 type entries struct {
 	Data struct {
 		Entries []struct {

cmd/ngrok/ngrok.go

@@ -12,9 +12,6 @@ import (
 
 func Init() {
 	var cfg struct {
-		Log struct {
-			Level string `yaml:"ngrok"`
-		} `yaml:"log"`
 		Mod struct {
 			Cmd string `yaml:"command"`
 		} `yaml:"ngrok"`
@@ -26,7 +23,7 @@ func Init() {
 		return
 	}
 
-	log = app.GetLogger(cfg.Log.Level)
+	log = app.GetLogger("ngrok")
 
 	ngr, err := ngrok.NewNgrok(cfg.Mod.Cmd)
 	if err != nil {
@@ -49,6 +46,9 @@ func Init() {
 					log.Warn().Err(err).Msg("[ngrok] add candidate")
 					return
 				}
+
+				log.Info().Str("addr", address).Msg("[ngrok] add external candidate for WebRTC")
+
 				webrtc.AddCandidate(address)
 			}
 		}

cmd/rtsp/rtsp.go

@@ -18,7 +18,7 @@ func Init() {
 	}
 
 	// default config
-	conf.Mod.Listen = ":554"
+	conf.Mod.Listen = ":8554"
 
 	app.LoadConfig(&conf)
 

cmd/streams/handlers.go

@@ -17,6 +17,11 @@ func HandleFunc(scheme string, handler Handler) {
 	handlers[scheme] = handler
 }
 
+func HasProducer(url string) bool {
+	i := strings.IndexByte(url, ':')
+	return handlers[url[:i]] != nil
+}
+
 func GetProducer(url string) (streamer.Producer, error) {
 	i := strings.IndexByte(url, ':')
 	handler := handlers[url[:i]]
@@ -24,4 +29,4 @@ func GetProducer(url string) (streamer.Producer, error) {
 		return nil, fmt.Errorf("unsupported scheme: %s", url)
 	}
 	return handler(url)
-}
+}

cmd/streams/producer.go

@@ -2,7 +2,6 @@ package streams
 
 import (
 	"github.com/AlexxIT/go2rtc/pkg/streamer"
-	"strings"
 )
 
 type state byte
@@ -26,17 +25,10 @@ type Producer struct {
 
 func (p *Producer) GetMedias() []*streamer.Media {
 	if p.state == stateNone {
-		i := strings.IndexByte(p.url, ':')
-		handler := handlers[p.url[:i]]
-		if handler == nil {
-			log.Warn().Str("url", p.url).Msg("[streams] unsupported scheme")
-			return nil
-		}
-
 		log.Debug().Str("url", p.url).Msg("[streams] probe producer")
 
 		var err error
-		p.element, err = handler(p.url)
+		p.element, err = GetProducer(p.url)
 		if err != nil {
 			log.Error().Err(err).Str("url", p.url).Msg("[streams] probe producer")
 			return nil

cmd/streams/stream.go

@@ -15,7 +15,7 @@ type Stream struct {
 	consumers []*Consumer
 }
 
-func newStream(source interface{}) *Stream {
+func NewStream(source interface{}) *Stream {
 	s := new(Stream)
 
 	switch source := source.(type) {
@@ -28,7 +28,7 @@ func newStream(source interface{}) *Stream {
 			s.producers = append(s.producers, prod)
 		}
 	case map[string]interface{}:
-		return newStream(source["url"])
+		return NewStream(source["url"])
 	default:
 		panic("wrong source type")
 	}
@@ -120,6 +120,20 @@ func (s *Stream) RemoveProducer(prod streamer.Producer) {
 	panic("not implemented")
 }
 
+func (s *Stream) Active() bool {
+	if len(s.consumers) > 0{
+		return true
+	}
+
+	for _, prod := range s.producers {
+		if prod.element != nil {
+			return true
+		}
+	}
+
+	return false
+}
+
 func (s *Stream) MarshalJSON() ([]byte, error) {
 	var v []interface{}
 	for _, prod := range s.producers {

cmd/streams/stream_test.go

@@ -115,7 +115,7 @@ func TestRouting(t *testing.T) {
 	assert.Len(t, cons.Medias, 3)
 
 	// setup stream with one producer
-	stream := newStream("fake:")
+	stream := NewStream("fake:")
 
 	// main check:
 	err := stream.AddConsumer(cons)

cmd/streams/streams.go

@@ -5,8 +5,6 @@ import (
 	"github.com/rs/zerolog"
 )
 
-var Streams = map[string]*Stream{}
-
 func Init() {
 	var cfg struct {
 		Mod map[string]interface{} `yaml:"streams"`
@@ -17,12 +15,34 @@ func Init() {
 	log = app.GetLogger("streams")
 
 	for name, item := range cfg.Mod {
-		Streams[name] = newStream(item)
+		streams[name] = NewStream(item)
 	}
 }
 
 func Get(name string) *Stream {
-	return Streams[name]
+	if stream, ok := streams[name]; ok {
+		return stream
+	}
+
+	if HasProducer(name) {
+		log.Info().Str("url", name).Msg("[streams] create new stream")
+		stream := NewStream(name)
+		streams[name] = stream
+		return stream
+	}
+
+	return nil
+}
+
+func All() map[string]interface{} {
+	active := map[string]interface{}{}
+	for name, stream := range streams {
+		if stream.Active() {
+			active[name] = stream
+		}
+	}
+	return active
 }
 
 var log zerolog.Logger
+var streams = map[string]*Stream{}

cmd/webrtc/webrtc.go

@@ -34,14 +34,14 @@ func Init() {
 	address := cfg.Mod.Listen
 	pionAPI, err := webrtc.NewAPI(address)
 	if pionAPI == nil {
-		log.Error().Err(err).Msg("[webrtc] Init API")
+		log.Error().Err(err).Msg("[webrtc] init API")
 		return
 	}
 
 	if err != nil {
-		log.Warn().Err(err).Msg("[webrtc] Listen")
+		log.Warn().Err(err).Msg("[webrtc] listen")
 	} else if address != "" {
-		log.Info().Str("addr", address).Msg("[webrtc] Listen")
+		log.Info().Str("addr", address).Msg("[webrtc] listen")
 		_, Port, _ = net.SplitHostPort(address)
 	}
 
@@ -63,7 +63,6 @@ func Init() {
 }
 
 func AddCandidate(address string) {
-	log.Info().Str("addr", address).Msg("[webrtc] new candidate")
 	candidates = append(candidates, address)
 }
 
@@ -238,6 +237,8 @@ func offerHandler(ctx *api.Context, msg *streamer.Message) {
 				continue
 			}
 			address = ip.String() + address[4:]
+
+			log.Debug().Str("addr", address).Msg("[webrtc] stun public address")
 		}
 
 		cand, err := webrtc.NewCandidate(address)
@@ -254,12 +255,61 @@ func offerHandler(ctx *api.Context, msg *streamer.Message) {
 	ctx.Consumer = conn
 }
 
+func ExchangeSDP(
+	stream *streams.Stream, offer string, userAgent string,
+) (answer string, err error) {
+	// create new webrtc instance
+	conn := new(webrtc.Conn)
+	conn.Conn, err = NewPConn()
+	if err != nil {
+		log.Error().Err(err).Msg("[webrtc] new conn")
+		return
+	}
+
+	conn.UserAgent = userAgent
+	conn.Listen(func(msg interface{}) {
+		switch msg := msg.(type) {
+		case streamer.EventType:
+			if msg == streamer.StateNull {
+				stream.RemoveConsumer(conn)
+			}
+		}
+	})
+
+	// 1. SetOffer, so we can get remote client codecs
+	log.Trace().Msgf("[webrtc] offer:\n%s", offer)
+
+	if err = conn.SetOffer(offer); err != nil {
+		log.Warn().Err(err).Msg("[api.webrtc] set offer")
+		return
+	}
+
+	// 2. AddConsumer, so we get new tracks
+	if err = stream.AddConsumer(conn); err != nil {
+		log.Warn().Err(err).Msg("[api.webrtc] add consumer")
+		return
+	}
+
+	conn.Init()
+
+	// exchange sdp without waiting all candidates
+	//answer, err := conn.ExchangeSDP(offer, false)
+	answer, err = conn.GetCompleteAnswer()
+	log.Trace().Msgf("[webrtc] answer\n%s", answer)
+
+	if err != nil {
+		log.Error().Err(err).Msg("[webrtc] get answer")
+	}
+
+	return
+}
+
 func candidateHandler(ctx *api.Context, msg *streamer.Message) {
 	if ctx.Consumer == nil {
 		return
 	}
 	if conn := ctx.Consumer.(*webrtc.Conn); conn != nil {
-		log.Trace().Str("candidate", msg.Value.(string)).Msg("[webrtc] Remote")
+		log.Trace().Str("candidate", msg.Value.(string)).Msg("[webrtc] remote")
 		conn.Push(msg)
 	}
 }

go.mod

@@ -7,7 +7,6 @@ require (
 	github.com/gorilla/websocket v1.5.0
 	github.com/pion/ice/v2 v2.2.6
 	github.com/pion/interceptor v0.1.11
-	github.com/pion/logging v0.2.2
 	github.com/pion/rtcp v1.2.9
 	github.com/pion/rtp v1.7.13
 	github.com/pion/sdp/v3 v3.0.5
@@ -25,6 +24,7 @@ require (
 	github.com/mattn/go-isatty v0.0.14 // indirect
 	github.com/pion/datachannel v1.5.2 // indirect
 	github.com/pion/dtls/v2 v2.1.5 // indirect
+	github.com/pion/logging v0.2.2 // indirect
 	github.com/pion/mdns v0.0.5 // indirect
 	github.com/pion/randutil v0.1.0 // indirect
 	github.com/pion/sctp v1.8.2 // indirect

main.go

@@ -1,9 +1,42 @@
 package main
 
 import (
-	"github.com/AlexxIT/go2rtc/cmd"
+	"github.com/AlexxIT/go2rtc/cmd/api"
+	"github.com/AlexxIT/go2rtc/cmd/app"
+	"github.com/AlexxIT/go2rtc/cmd/exec"
+	"github.com/AlexxIT/go2rtc/cmd/ffmpeg"
+	"github.com/AlexxIT/go2rtc/cmd/hass"
+	"github.com/AlexxIT/go2rtc/cmd/mse"
+	"github.com/AlexxIT/go2rtc/cmd/ngrok"
+	"github.com/AlexxIT/go2rtc/cmd/rtmp"
+	"github.com/AlexxIT/go2rtc/cmd/rtsp"
+	"github.com/AlexxIT/go2rtc/cmd/streams"
+	"github.com/AlexxIT/go2rtc/cmd/webrtc"
+	"os"
+	"os/signal"
+	"syscall"
 )
 
 func main() {
-	cmd.Run()
+	app.Init()     // init config and logs
+	streams.Init() // load streams list
+
+	rtsp.Init()   // add support RTSP client and RTSP server
+	rtmp.Init()   // add support RTMP client
+	exec.Init()   // add support exec scheme (depends on RTSP server)
+	ffmpeg.Init() // add support ffmpeg scheme (depends on exec scheme)
+	hass.Init()   // add support hass scheme
+
+	api.Init() // init HTTP API server
+
+	webrtc.Init()
+	mse.Init()
+
+	ngrok.Init()
+
+	sigs := make(chan os.Signal, 1)
+	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
+	<-sigs
+
+	println("exit OK")
 }

pkg/h264/avc.go

@@ -0,0 +1,60 @@
+package h264
+
+import (
+	"encoding/binary"
+	"github.com/AlexxIT/go2rtc/pkg/streamer"
+	"github.com/pion/rtp"
+)
+
+const PayloadTypeAVC = 255
+
+func IsAVC(codec *streamer.Codec) bool {
+	return codec.PayloadType == PayloadTypeAVC
+}
+
+func EncodeAVC(raw []byte) (avc []byte) {
+	avc = make([]byte, len(raw)+4)
+	binary.BigEndian.PutUint32(avc, uint32(len(raw)))
+	copy(avc[4:], raw)
+	return
+}
+
+func RepairAVC(track *streamer.Track) streamer.WrapperFunc {
+	sps, pps := GetParameterSet(track.Codec.FmtpLine)
+	sps = EncodeAVC(sps)
+	pps = EncodeAVC(pps)
+
+	return func(push streamer.WriterFunc) streamer.WriterFunc {
+		return func(packet *rtp.Packet) (err error) {
+			naluType := NALUType(packet.Payload)
+			switch naluType {
+			case NALUTypeSPS:
+				sps = packet.Payload
+				return
+			case NALUTypePPS:
+				pps = packet.Payload
+				return
+			}
+
+			var clone rtp.Packet
+
+			if naluType == NALUTypeIFrame {
+				clone = *packet
+				clone.Payload = sps
+				if err = push(&clone); err != nil {
+					return
+				}
+
+				clone = *packet
+				clone.Payload = pps
+				if err = push(&clone); err != nil {
+					return
+				}
+			}
+
+			clone = *packet
+			clone.Payload = packet.Payload
+			return push(&clone)
+		}
+	}
+}

pkg/h264/helper.go

@@ -2,7 +2,6 @@ package h264
 
 import (
 	"encoding/base64"
-	"encoding/binary"
 	"github.com/AlexxIT/go2rtc/pkg/streamer"
 	"strings"
 )
@@ -12,25 +11,12 @@ const (
 	NALUTypeIFrame = 5
 	NALUTypeSPS    = 7
 	NALUTypePPS    = 8
-
-	PayloadTypeAVC = 255
 )
 
 func NALUType(b []byte) byte {
 	return b[4] & 0x1F
 }
 
-func EncodeAVC(raw []byte) (avc []byte) {
-	avc = make([]byte, len(raw)+4)
-	binary.BigEndian.PutUint32(avc, uint32(len(raw)))
-	copy(avc[4:], raw)
-	return
-}
-
-func IsAVC(codec *streamer.Codec) bool {
-	return codec.PayloadType == PayloadTypeAVC
-}
-
 func GetParameterSet(fmtp string) (sps, pps []byte) {
 	if fmtp == "" {
 		return

pkg/keyframe/consumer.go

@@ -0,0 +1,72 @@
+package keyframe
+
+import (
+	"github.com/AlexxIT/go2rtc/pkg/h264"
+	"github.com/AlexxIT/go2rtc/pkg/mp4"
+	"github.com/AlexxIT/go2rtc/pkg/streamer"
+	"github.com/pion/rtp"
+)
+
+var annexB = []byte{0, 0, 0, 1}
+
+type Consumer struct {
+	streamer.Element
+	IsMP4 bool
+}
+
+func (k *Consumer) GetMedias() []*streamer.Media {
+	// support keyframe extraction only for one coded...
+	codec := streamer.NewCodec(streamer.CodecH264)
+	return []*streamer.Media{
+		{
+			Kind: streamer.KindVideo, Direction: streamer.DirectionRecvonly,
+			Codecs: []*streamer.Codec{codec},
+		},
+	}
+}
+
+func (k *Consumer) AddTrack(media *streamer.Media, track *streamer.Track) *streamer.Track {
+	// sps and pps without AVC headers
+	sps, pps := h264.GetParameterSet(track.Codec.FmtpLine)
+
+	push := func(packet *rtp.Packet) error {
+		// TODO: remove it, unnecessary
+		if packet.Version != h264.RTPPacketVersionAVC {
+			panic("wrong packet type")
+		}
+
+		switch h264.NALUType(packet.Payload) {
+		case h264.NALUTypeSPS:
+			sps = packet.Payload[4:] // remove AVC header
+		case h264.NALUTypePPS:
+			pps = packet.Payload[4:] // remove AVC header
+		case h264.NALUTypeIFrame:
+			if sps == nil || pps == nil {
+				return nil
+			}
+
+			var data []byte
+
+			if k.IsMP4 {
+				data = mp4.MarshalMP4(sps, pps, packet.Payload)
+			} else {
+				data = append(data, annexB...)
+				data = append(data, sps...)
+				data = append(data, annexB...)
+				data = append(data, pps...)
+				data = append(data, annexB...)
+				data = append(data, packet.Payload[4:]...)
+			}
+
+			k.Fire(data)
+		}
+		return nil
+	}
+
+	if !h264.IsAVC(track.Codec) {
+		wrapper := h264.RTPDepay(track)
+		push = wrapper(push)
+	}
+
+	return track.Bind(push)
+}

pkg/mp4/helpers.go

@@ -0,0 +1,47 @@
+package mp4
+
+import (
+	"errors"
+	"io"
+)
+
+type MemoryWriter struct {
+	buf []byte
+	pos int
+}
+
+func (m *MemoryWriter) Write(p []byte) (n int, err error) {
+	minCap := m.pos + len(p)
+	if minCap > cap(m.buf) { // Make sure buf has enough capacity:
+		buf2 := make([]byte, len(m.buf), minCap+len(p)) // add some extra
+		copy(buf2, m.buf)
+		m.buf = buf2
+	}
+	if minCap > len(m.buf) {
+		m.buf = m.buf[:minCap]
+	}
+	copy(m.buf[m.pos:], p)
+	m.pos += len(p)
+	return len(p), nil
+}
+
+func (m *MemoryWriter) Seek(offset int64, whence int) (int64, error) {
+	newPos, offs := 0, int(offset)
+	switch whence {
+	case io.SeekStart:
+		newPos = offs
+	case io.SeekCurrent:
+		newPos = m.pos + offs
+	case io.SeekEnd:
+		newPos = len(m.buf) + offs
+	}
+	if newPos < 0 {
+		return 0, errors.New("negative result pos")
+	}
+	m.pos = newPos
+	return int64(newPos), nil
+}
+
+func (m *MemoryWriter) Bytes() []byte {
+	return m.buf
+}

pkg/mp4/muxer.go

@@ -0,0 +1,37 @@
+package mp4
+
+import (
+	"github.com/deepch/vdk/av"
+	"github.com/deepch/vdk/codec/h264parser"
+	"github.com/deepch/vdk/format/mp4"
+	"time"
+)
+
+func MarshalMP4(sps, pps, frame []byte) []byte {
+	writer := &MemoryWriter{}
+	muxer := mp4.NewMuxer(writer)
+
+	stream, err := h264parser.NewCodecDataFromSPSAndPPS(sps, pps)
+	if err != nil {
+		panic(err)
+	}
+
+	if err = muxer.WriteHeader([]av.CodecData{stream}); err != nil {
+		panic(err)
+	}
+
+	pkt := av.Packet{
+		CompositionTime: time.Millisecond,
+		IsKeyFrame:      true,
+		Duration:        time.Second,
+		Data:            frame,
+	}
+	if err = muxer.WritePacket(pkt); err != nil {
+		panic(err)
+	}
+	if err = muxer.WriteTrailer(); err != nil {
+		panic(err)
+	}
+
+	return writer.buf
+}

pkg/rtmp/client.go

@@ -22,6 +22,8 @@ type Client struct {
 
 	conn   *rtmp.Conn
 	closed bool
+
+	receive int
 }
 
 func NewClient(uri string) *Client {
@@ -94,6 +96,8 @@ func (c *Client) Handle() (err error) {
 			return
 		}
 
+		c.receive += len(pkt.Data)
+
 		track := c.tracks[int(pkt.Idx)]
 
 		timestamp := uint32(pkt.Time / time.Duration(track.Codec.ClockRate))

pkg/rtmp/streamer.go

@@ -1,7 +1,9 @@
 package rtmp
 
 import (
+	"encoding/json"
 	"github.com/AlexxIT/go2rtc/pkg/streamer"
+	"strconv"
 )
 
 func (c *Client) GetMedias() []*streamer.Media {
@@ -24,3 +26,21 @@ func (c *Client) Start() error {
 func (c *Client) Stop() error {
 	return c.Close()
 }
+
+func (c *Client) MarshalJSON() ([]byte, error) {
+	v := map[string]interface{}{
+		streamer.JSONReceive:    c.receive,
+		streamer.JSONType:       "RTMP client producer",
+		streamer.JSONRemoteAddr: c.conn.NetConn().RemoteAddr().String(),
+		"url":                   c.URI,
+	}
+	for i, media := range c.medias {
+		k := "media:" + strconv.Itoa(i)
+		v[k] = media.String()
+	}
+	for i, track := range c.tracks {
+		k := "track:" + strconv.Itoa(i)
+		v[k] = track.String()
+	}
+	return json.Marshal(v)
+}

pkg/rtsp/conn.go

@@ -7,6 +7,7 @@ import (
 	"encoding/binary"
 	"errors"
 	"fmt"
+	"github.com/AlexxIT/go2rtc/pkg/h264"
 	"github.com/AlexxIT/go2rtc/pkg/streamer"
 	"github.com/AlexxIT/go2rtc/pkg/tcp"
 	"github.com/pion/rtcp"
@@ -671,6 +672,11 @@ func (c *Conn) bindTrack(
 		return nil
 	}
 
+	if h264.IsAVC(track.Codec) {
+		wrapper := h264.RTPPay(1500)
+		push = wrapper(push)
+	}
+
 	return track.Bind(push)
 }
 

pkg/streamer/media.go

@@ -281,7 +281,7 @@ func UnmarshalCodec(md *sdp.MediaDescription, payloadType string) *Codec {
 			c.Name = "PCMA"
 			c.ClockRate = 8000
 		default:
-			panic("unknown codec")
+			c.Name = payloadType
 		}
 	}
 

pkg/webrtc/conn.go

@@ -186,6 +186,15 @@ func (c *Conn) GetAnswer() (answer string, err error) {
 	return sdAnswer.SDP, nil
 }
 
+func (c *Conn) GetCompleteAnswer() (answer string, err error) {
+	if _, err = c.GetAnswer(); err != nil {
+		return
+	}
+
+	<-webrtc.GatheringCompletePromise(c.Conn)
+	return c.Conn.LocalDescription().SDP, nil
+}
+
 func (c *Conn) remote() string {
 	for _, trans := range c.Conn.GetTransceivers() {
 		pair, _ := trans.Receiver().Transport().ICETransport().GetSelectedCandidatePair()

pkg/webrtc/streamer.go

@@ -55,10 +55,12 @@ func (c *Conn) AddTrack(media *streamer.Media, track *streamer.Track) *streamer.
 			wrapper := h264.RTPPay(1200)
 			push = wrapper(push)
 
-			if codec.PayloadType != 255 {
+			if h264.IsAVC(codec) {
+				wrapper = h264.RepairAVC(track)
+			} else {
 				wrapper = h264.RTPDepay(track)
-				push = wrapper(push)
 			}
+			push = wrapper(push)
 		}
 
 		track = track.Bind(push)

scripts/README.md

@@ -0,0 +1,12 @@
+## Build
+
+- UPX-3.96 pack broken bin for `linux_mipsel`
+- UPX-3.95 pack broken bin for `mac_amd64`
+- `aarch64` = `arm64`
+- `armv7` = `arm`
+
+## Useful links
+
+- https://github.com/golang/go/wiki/GoArm
+- https://gist.github.com/asukakenji/f15ba7e588ac42795f421b48b8aede63
+- https://en.wikipedia.org/wiki/AArch64

scripts/build.cmd

@@ -3,45 +3,45 @@
 @SET GOOS=windows
 @SET GOARCH=amd64
 @SET FILENAME=go2rtc_win64.exe
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=windows
 @SET GOARCH=386
 @SET FILENAME=go2rtc_win32.exe
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=linux
 @SET GOARCH=amd64
 @SET FILENAME=go2rtc_linux_amd64
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=linux
 @SET GOARCH=386
 @SET FILENAME=go2rtc_linux_i386
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=linux
 @SET GOARCH=arm64
 @SET FILENAME=go2rtc_linux_arm64
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=linux
 @SET GOARCH=arm
 @SET GOARM=7
 @SET FILENAME=go2rtc_linux_arm
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=linux
 @SET GOARCH=mipsle
 @SET FILENAME=go2rtc_linux_mipsel
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.95 %FILENAME%
 
 @SET GOOS=darwin
 @SET GOARCH=amd64
 @SET FILENAME=go2rtc_mac_amd64
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%
 
 @SET GOOS=darwin
 @SET GOARCH=arm64
 @SET FILENAME=go2rtc_mac_arm64
-go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx %FILENAME%
+go build -ldflags "-s -w" -trimpath -o %FILENAME% && upx-3.96 %FILENAME%

www/index.html

@@ -15,12 +15,13 @@
     );
 
     const header = document.getElementById('header');
-    header.innerHTML = `<a href="api/stats">stats</a>` +
-        `<a href="webcam.html?url=webcam">webcam</a>`;
+    header.innerHTML = `<a href="api/stats">stats</a>`;
 
     const links = [
         '<a href="webrtc-async.html?url={name}">webrtc-async</a>',
-        '<a href="webrtc-sync.html?url={name}">webrtc-sync</a>',
+        // '<a href="webrtc-sync.html?url={name}">webrtc-sync</a>',
+        '<a href="api/frame.mp4?url={name}">frame.mp4</a>',
+        '<a href="api/frame.raw?url={name}">frame.raw</a>',
         '<a href="mse.html?url={name}">mse</a>',
     ];
 

www/static.go

@@ -0,0 +1,6 @@
+package www
+
+import "embed"
+
+//go:embed *.html
+var Static embed.FS

www/webrtc-async.html

@@ -21,11 +21,8 @@
             background: black;
         }
     </style>
-    <!-- Fix bugs for example with Safari... -->
-<!--    <script src="https://webrtc.github.io/adapter/adapter-latest.js"></script>-->
 </head>
 <body>
-<!-- muted is important for autoplay -->
 <video id="video" autoplay controls playsinline muted></video>
 <script>
     function init(stream) {
@@ -38,11 +35,7 @@
         ws.onopen = () => {
             console.debug('ws.onopen');
 
-            pc.createOffer({
-                // this is adds two media to SDP with recvonly direction
-                // offerToReceiveAudio: true,
-                // offerToReceiveVideo: true,
-            }).then(offer => {
+            pc.createOffer().then(offer => {
                 pc.setLocalDescription(offer).then(() => {
                     console.log(offer.sdp);
                     const msg = {type: 'webrtc/offer', value: pc.localDescription.sdp};