Code refactoring after #967

This commit is contained in:
Alex X
2024-04-29 06:56:58 +03:00
parent d96701453d
commit e304035f76
2 changed files with 13 additions and 14 deletions
+10 -11
View File
@@ -2,12 +2,13 @@ package isapi
import ( import (
"errors" "errors"
"github.com/AlexxIT/go2rtc/pkg/core"
"github.com/AlexxIT/go2rtc/pkg/tcp"
"io" "io"
"net" "net"
"net/http" "net/http"
"net/url" "net/url"
"github.com/AlexxIT/go2rtc/pkg/core"
"github.com/AlexxIT/go2rtc/pkg/tcp"
) )
type Client struct { type Client struct {
@@ -84,15 +85,13 @@ func (c *Client) Dial() (err error) {
} }
func (c *Client) Open() (err error) { func (c *Client) Open() (err error) {
// Hikvision ISAPI may not accept a new open request if the previous one was not closed (e.g. // Hikvision ISAPI may not accept a new open request if the previous one was not closed (e.g.
// using the test button on-camera or via curl command) but a close request can be sent even if // using the test button on-camera or via curl command) but a close request can be sent even if
// the audio is already closed. So, we send a close request first and then open it again. Seems // the audio is already closed. So, we send a close request first and then open it again. Seems
// janky but it works. // janky but it works.
if err = c.Close(); err != nil {
err = c.Close() return err
if err != nil { }
return err
}
link := c.url + "/ISAPI/System/TwoWayAudio/channels/" + c.channel link := c.url + "/ISAPI/System/TwoWayAudio/channels/" + c.channel
req, err := http.NewRequest("PUT", link+"/open", nil) req, err := http.NewRequest("PUT", link+"/open", nil)
+3 -3
View File
@@ -9,6 +9,8 @@ import (
"net/http" "net/http"
"strings" "strings"
"time" "time"
"github.com/AlexxIT/go2rtc/pkg/core"
) )
// Do - http.Client with support Digest Authorization // Do - http.Client with support Digest Authorization
@@ -115,9 +117,7 @@ func Do(req *http.Request) (*http.Response, error) {
) )
case "auth": case "auth":
nc := "00000001" nc := "00000001"
// TODO: Random cnonce cnonce := core.RandString(32, 64)
// Here is temp static cnonce of required 32 bytes
cnonce := "ZDlmODczZTk2NjQyZTQ4OGQ5ZGEzOTI3YTc5Y2Q0ZGM="
response := HexMD5(ha1, nonce, nc, cnonce, qop, ha2) response := HexMD5(ha1, nonce, nc, cnonce, qop, ha2)
header = fmt.Sprintf( header = fmt.Sprintf(
`Digest username="%s", realm="%s", nonce="%s", uri="%s", qop=%s, nc=%s, cnonce="%s", response="%s"`, `Digest username="%s", realm="%s", nonce="%s", uri="%s", qop=%s, nc=%s, cnonce="%s", response="%s"`,