apps/go2rtc
1
0
Fork 0
mirror of https://github.com/AlexxIT/go2rtc.git synced 2025-10-18 06:10:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

Adds automatic extention of nest stream before it expires.

Browse Source
This commit is contained in:
René Simonsen
2024-01-03 15:08:21 +01:00
parent 39d87625d7
commit bc516bce7d
2 changed files with 91 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
pkg/nest/api.go
View File

@@ -121,7 +121,7 @@ func (a *API) GetDevices(projectID string) (map[string]string, error) {
return devices, nil
}
func (a *API) ExchangeSDP(projectID, deviceID, offer string) (string, error) {
func (a *API) ExchangeSDP(projectID, deviceID, offer string) (string, string, time.Time, error) {
var reqv struct {
Command string `json:"command"`
Params struct {
@@ -133,14 +133,14 @@ func (a *API) ExchangeSDP(projectID, deviceID, offer string) (string, error) {
b, err := json.Marshal(reqv)
if err != nil {
return "", err
return "", "", time.Time{}, err
}
uri := "https://smartdevicemanagement.googleapis.com/v1/enterprises/" +
projectID + "/devices/" + deviceID + ":executeCommand"
req, err := http.NewRequest("POST", uri, bytes.NewReader(b))
if err != nil {
return "", err
return "", "", time.Time{}, err
}
req.Header.Set("Authorization", "Bearer "+a.Token)
@@ -148,11 +148,11 @@ func (a *API) ExchangeSDP(projectID, deviceID, offer string) (string, error) {
client := &http.Client{Timeout: time.Second * 5000}
res, err := client.Do(req)
if err != nil {
return "", err
return "", "", time.Time{}, err
}
if res.StatusCode != 200 {
return "", errors.New("nest: wrong status: " + res.Status)
return "", "", time.Time{}, errors.New("nest: wrong status: " + res.Status)
}
var resv struct {
@@ -164,10 +164,58 @@ func (a *API) ExchangeSDP(projectID, deviceID, offer string) (string, error) {
}
if err = json.NewDecoder(res.Body).Decode(&resv); err != nil {
return "", err
return "", "", time.Time{}, err
}
return resv.Results.Answer, nil
return resv.Results.Answer, resv.Results.MediaSessionId, resv.Results.ExpiresAt, nil
}
func (a *API) ExtendStream(projectID, deviceID, mediaSessionID string) (string, time.Time, error) {
var reqv struct {
Command string `json:"command"`
Params struct {
MediaSessionID string `json:"mediaSessionId"`
} `json:"params"`
}
reqv.Command = "sdm.devices.commands.CameraLiveStream.ExtendWebRtcStream"
reqv.Params.MediaSessionID = mediaSessionID
b, err := json.Marshal(reqv)
if err != nil {
return "", time.Time{}, err
}
uri := "https://smartdevicemanagement.googleapis.com/v1/enterprises/" +
projectID + "/devices/" + deviceID + ":executeCommand"
req, err := http.NewRequest("POST", uri, bytes.NewReader(b))
if err != nil {
return "", time.Time{}, err
}
req.Header.Set("Authorization", "Bearer "+a.Token)
client := &http.Client{Timeout: time.Second * 5000}
res, err := client.Do(req)
if err != nil {
return "", time.Time{}, err
}
if res.StatusCode != 200 {
return "", time.Time{}, errors.New("nest: wrong status: " + res.Status)
}
var resv struct {
Results struct {
ExpiresAt time.Time `json:"expiresAt"`
MediaSessionId string `json:"mediaSessionId"`
} `json:"results"`
}
if err = json.NewDecoder(res.Body).Decode(&resv); err != nil {
return "", time.Time{}, err
}
return resv.Results.MediaSessionId, resv.Results.ExpiresAt, nil
}
type Device struct {