gilles/go2rtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add path to ONVIF requests

Browse Source
This commit is contained in:
Alexey Khit
2023-05-02 11:07:12 +03:00
parent 53967fc72a
commit 9c8a1d8b19
2 changed files with 36 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/onvif/client.go
+31 -15
View File
@@ -104,6 +104,7 @@ func (c *Client) HasSnapshots() bool {
func (c *Client) GetCapabilities() ([]byte, error) { func (c *Client) GetCapabilities() ([]byte, error) {
return c.Request( return c.Request(
PathDevice,
`<tds:GetCapabilities xmlns:tds="http://www.onvif.org/ver10/device/wsdl"> `<tds:GetCapabilities xmlns:tds="http://www.onvif.org/ver10/device/wsdl">
<tds:Category>All</tds:Category> <tds:Category>All</tds:Category>
</tds:GetCapabilities>`, </tds:GetCapabilities>`,
@@ -111,64 +112,79 @@ func (c *Client) GetCapabilities() ([]byte, error) {
} }
func (c *Client) GetNetworkInterfaces() ([]byte, error) { func (c *Client) GetNetworkInterfaces() ([]byte, error) {
return c.Request(`<tds:GetNetworkInterfaces xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`) return c.Request(
PathDevice, `<tds:GetNetworkInterfaces xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`,
)
} }
func (c *Client) GetDeviceInformation() ([]byte, error) { func (c *Client) GetDeviceInformation() ([]byte, error) {
return c.Request(`<tds:GetDeviceInformation xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`) return c.Request(
PathDevice, `<tds:GetDeviceInformation xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`,
)
} }
func (c *Client) GetProfiles() ([]byte, error) { func (c *Client) GetProfiles() ([]byte, error) {
return c.Request(`<trt:GetProfiles xmlns:trt="http://www.onvif.org/ver10/media/wsdl"/>`) return c.Request(
PathMedia, `<trt:GetProfiles xmlns:trt="http://www.onvif.org/ver10/media/wsdl"/>`,
)
} }
func (c *Client) GetStreamUri(token string) ([]byte, error) { func (c *Client) GetStreamUri(token string) ([]byte, error) {
return c.Request( return c.Request(
PathMedia,
`<trt:GetStreamUri xmlns:trt="http://www.onvif.org/ver10/media/wsdl" xmlns:tt="http://www.onvif.org/ver10/schema"> `<trt:GetStreamUri xmlns:trt="http://www.onvif.org/ver10/media/wsdl" xmlns:tt="http://www.onvif.org/ver10/schema">
<trt:StreamSetup> <trt:StreamSetup>
<tt:Stream>RTP-Unicast</tt:Stream> <tt:Stream>RTP-Unicast</tt:Stream>
<tt:Transport><tt:Protocol>RTSP</tt:Protocol></tt:Transport> <tt:Transport><tt:Protocol>RTSP</tt:Protocol></tt:Transport>
</trt:StreamSetup> </trt:StreamSetup>
<trt:ProfileToken>` + token + `</trt:ProfileToken> <trt:ProfileToken>`+token+`</trt:ProfileToken>
</trt:GetStreamUri>`) </trt:GetStreamUri>`,
)
} }
func (c *Client) GetSnapshotUri(token string) ([]byte, error) { func (c *Client) GetSnapshotUri(token string) ([]byte, error) {
return c.Request( return c.Request(
PathMedia,
`<trt:GetSnapshotUri xmlns:trt="http://www.onvif.org/ver10/media/wsdl"> `<trt:GetSnapshotUri xmlns:trt="http://www.onvif.org/ver10/media/wsdl">
<trt:ProfileToken>` + token + `</trt:ProfileToken> <trt:ProfileToken>`+token+`</trt:ProfileToken>
</trt:GetSnapshotUri>`) </trt:GetSnapshotUri>`,
)
} }
func (c *Client) GetSystemDateAndTime() ([]byte, error) { func (c *Client) GetSystemDateAndTime() ([]byte, error) {
return c.Request( return c.Request(
`<ns0:GetSystemDateAndTime xmlns:ns0="http://www.onvif.org/ver10/device/wsdl"/>`, PathDevice, `<tds:GetSystemDateAndTime xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`,
) )
} }
func (c *Client) GetServiceCapabilities() ([]byte, error) { func (c *Client) GetServiceCapabilities() ([]byte, error) {
// some cameras answer GetServiceCapabilities for media only for path = "/onvif/media"
return c.Request( return c.Request(
`<ns0:GetServiceCapabilities xmlns:ns0="http://www.onvif.org/ver10/media/wsdl"/>`, PathMedia, `<trt:GetServiceCapabilities xmlns:trt="http://www.onvif.org/ver10/media/wsdl"/>`,
) )
} }
func (c *Client) SystemReboot() ([]byte, error) { func (c *Client) SystemReboot() ([]byte, error) {
return c.Request( return c.Request(
`<tds:SystemReboot xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`, PathDevice, `<tds:SystemReboot xmlns:tds="http://www.onvif.org/ver10/device/wsdl"/>`,
) )
} }
func (c *Client) GetServices() ([]byte, error) { func (c *Client) GetServices() ([]byte, error) {
return c.Request(`<tds:GetServices xmlns:tds="http://www.onvif.org/ver10/device/wsdl"> return c.Request(
PathDevice, `<tds:GetServices xmlns:tds="http://www.onvif.org/ver10/device/wsdl">
<tds:IncludeCapability>true</tds:IncludeCapability> <tds:IncludeCapability>true</tds:IncludeCapability>
</tds:GetServices>`) </tds:GetServices>`,
)
} }
func (c *Client) GetScopes() ([]byte, error) { func (c *Client) GetScopes() ([]byte, error) {
return c.Request(`<tds:GetScopes xmlns:tds="http://www.onvif.org/ver10/device/wsdl" />`) return c.Request(
PathDevice, `<tds:GetScopes xmlns:tds="http://www.onvif.org/ver10/device/wsdl" />`,
)
} }
func (c *Client) Request(body string) ([]byte, error) { func (c *Client) Request(path, body string) ([]byte, error) {
buf := bytes.NewBuffer(nil) buf := bytes.NewBuffer(nil)
buf.WriteString( buf.WriteString(
`<?xml version="1.0" encoding="UTF-8"?><s:Envelope xmlns:s="http://www.w3.org/2003/05/soap-envelope">`, `<?xml version="1.0" encoding="UTF-8"?><s:Envelope xmlns:s="http://www.w3.org/2003/05/soap-envelope">`,
@@ -198,7 +214,7 @@ func (c *Client) Request(body string) ([]byte, error) {
client := &http.Client{Timeout: time.Second * 5000} client := &http.Client{Timeout: time.Second * 5000}
res, err := client.Post( res, err := client.Post(
"http://"+c.url.Host+"/onvif/", "http://"+c.url.Host+path,
`application/soap+xml;charset=utf-8`, `application/soap+xml;charset=utf-8`,
buf, buf,
) )
pkg/onvif/helpers.go
+5
View File
@@ -10,6 +10,11 @@ import (
"time" "time"
) )
const (
PathDevice = "/onvif/device_service"
PathMedia = "/onvif/media_service"
)
func FindTagValue(b []byte, tag string) string { func FindTagValue(b []byte, tag string) string {
re := regexp.MustCompile(tag + `[^>]*>([^<]+)`) re := regexp.MustCompile(tag + `[^>]*>([^<]+)`)
m := re.FindSubmatch(b) m := re.FindSubmatch(b)