apps/streamctl
1
0
Fork 0
mirror of https://github.com/xaionaro-go/streamctl.git synced 2025-10-28 01:41:34 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Don't panic if YouTube quota is exceeded

Browse Source
This commit is contained in:
Dmitrii Okunev
2025-06-29 22:40:11 +01:00
parent 829c7b92d0
commit 01feee509a
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/streamcontrol/youtube/youtube_client.go
View File

@@ -2,8 +2,10 @@ package youtube
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"io" "io"
"net/http"
"github.com/facebookincubator/go-belt/tool/logger" "github.com/facebookincubator/go-belt/tool/logger"
"google.golang.org/api/googleapi" "google.golang.org/api/googleapi"
@@ -116,7 +118,17 @@ func (c *YouTubeClientV3) Ping(
) (_err error) { ) (_err error) {
logger.Tracef(ctx, "Ping") logger.Tracef(ctx, "Ping")
defer func() { logger.Tracef(ctx, "/Ping: %v", _err) }() defer func() { logger.Tracef(ctx, "/Ping: %v", _err) }()
return wrapRequestS(ctx, c.RequestWrapper, c.I18nLanguages.List(nil).Context(ctx).Do) err := wrapRequestS(ctx, c.RequestWrapper, c.I18nLanguages.List(nil).Context(ctx).Do)
gErr := &googleapi.Error{}
if err != nil && errors.As(err, &gErr) {
if gErr.Code == http.StatusForbidden && len(gErr.Errors) == 1 {
gErrItem := gErr.Errors[0]
if gErrItem.Reason == "quotaExceeded" { // this is not an authentication or/and connection problem.
return nil
}
}
}
return err
} }
func (c *YouTubeClientV3) GetBroadcasts( func (c *YouTubeClientV3) GetBroadcasts(