diff --git a/internal/onvif/init.go b/internal/onvif/init.go
index 014c5e18..e5ed9a7c 100644
--- a/internal/onvif/init.go
+++ b/internal/onvif/init.go
@@ -70,6 +70,9 @@ func onvifDeviceService(w http.ResponseWriter, r *http.Request) {
// important for Hass: Media section
res = onvif.GetCapabilitiesResponse(r.Host)
+ case onvif.ActionGetServices:
+ res = onvif.GetServicesResponse(r.Host)
+
case onvif.ActionGetSystemDateAndTime:
// important for Hass
res = onvif.GetSystemDateAndTimeResponse()
@@ -97,6 +100,9 @@ func onvifDeviceService(w http.ResponseWriter, r *http.Request) {
// important for Hass: H264 codec, width, height
res = onvif.GetProfilesResponse(streams.GetAll())
+ case onvif.ActionGetVideoSources:
+ res = onvif.GetVideoSourcesResponse(streams.GetAll())
+
case onvif.ActionGetStreamUri:
host, _, err := net.SplitHostPort(r.Host)
if err != nil {
@@ -107,6 +113,10 @@ func onvifDeviceService(w http.ResponseWriter, r *http.Request) {
uri := "rtsp://" + host + ":" + rtsp.Port + "/" + onvif.FindTagValue(b, "ProfileToken")
res = onvif.GetStreamUriResponse(uri)
+ case onvif.ActionGetSnapshotUri:
+ uri := "http://" + r.Host + "/api/frame.jpeg?src=" + onvif.FindTagValue(b, "ProfileToken")
+ res = onvif.GetSnapshotUriResponse(uri)
+
default:
http.Error(w, "unsupported action", http.StatusBadRequest)
log.Debug().Msgf("[onvif] unsupported request:\n%s", b)
diff --git a/pkg/onvif/server.go b/pkg/onvif/server.go
index f8f2883c..bc3f8ffe 100644
--- a/pkg/onvif/server.go
+++ b/pkg/onvif/server.go
@@ -16,6 +16,7 @@ const (
ActionGetServiceCapabilities = "GetServiceCapabilities"
ActionGetProfiles = "GetProfiles"
ActionGetStreamUri = "GetStreamUri"
+ ActionGetSnapshotUri = "GetSnapshotUri"
ActionSystemReboot = "SystemReboot"
ActionGetServices = "GetServices"
@@ -45,23 +46,49 @@ func GetRequestAction(b []byte) string {
func GetCapabilitiesResponse(host string) string {
return `
-
-
-
-
- http://` + host + `/onvif/device_service
-
-
- http://` + host + `/onvif/media_service
-
- false
- false
- true
-
-
-
-
-
+
+
+
+
+ http://` + host + `/onvif/device_service
+
+
+ http://` + host + `/onvif/media_service
+
+ false
+ false
+ true
+
+
+
+
+
+`
+}
+
+func GetServicesResponse(host string) string {
+ return `
+
+
+
+
+ http://www.onvif.org/ver10/device/wsdl
+ http://` + host + `/onvif/device_service
+
+ 2
+ 5
+
+
+
+ http://www.onvif.org/ver10/media/wsdl
+ http://` + host + `/onvif/media_service
+
+ 2
+ 5
+
+
+
+
`
}
@@ -142,7 +169,7 @@ func GetServiceCapabilitiesResponse() string {
-
+
@@ -170,21 +197,55 @@ func GetProfilesResponse(names []string) string {
for i, name := range names {
buf.WriteString(`
-
- ` + name + `
-
- H264
-
- 1920
- 1080
-
-
- `)
+
+ ` + name + `
+
+ ` + name + `
+ H264
+
+ 1920
+ 1080
+
+
+
+
+
+ ` + name + `
+ ` + strconv.Itoa(i) + `
+
+
+ `)
}
buf.WriteString(`
-
-
+
+
+`)
+
+ return buf.String()
+}
+
+
+func GetVideoSourcesResponse(names []string) string {
+ buf := bytes.NewBuffer(nil)
+ buf.WriteString(`
+
+
+ `)
+
+ for i, _ := range names {
+ buf.WriteString(`
+
+
+ 1920
+ 1080
+
+ `)
+ }
+
+ buf.WriteString(`
+
+
`)
return buf.String()
@@ -196,9 +257,22 @@ func GetStreamUriResponse(uri string) string {
- ` + uri + `
+ ` + uri + `
`
}
+
+func GetSnapshotUriResponse(uri string) string {
+ return `
+
+
+
+
+ ` + uri + `
+
+
+
+`
+}