GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-07-08 18:42:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: check video changed

Browse Source
This commit is contained in:
lilong.129
2023-09-07 13:45:54 +08:00
parent 72db1b0bc7
commit 948b403946
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
hrp/pkg/uixt/video_crawler.go
View File

@@ -178,14 +178,17 @@ func (vc *VideoCrawler) startLiveCrawler(enterPoint PointF) error {
swipeFinishTime := time.Now() swipeFinishTime := time.Now()
liveRoom, err := vc.getCurrentVideo() liveRoom, err := vc.getCurrentVideo()
if err != nil { if err != nil || liveRoom.Type != VideoType_Live {
if vc.failedCount >= 5 { if vc.failedCount >= 5 {
// failed 5 consecutive times // failed 5 consecutive times
return errors.New("get current live event trackings failed 5 consecutive times") return errors.New("get current live event trackings failed 5 consecutive times")
} }
// retry // retry
vc.failedCount++ vc.failedCount++
log.Warn().Int64("failedCount", vc.failedCount).Msg("get current live room failed") log.Warn().
Int64("failedCount", vc.failedCount).
Str("videoType", string(liveRoom.Type)).
Msg("get current live room failed")
continue continue
} }
@@ -315,7 +318,9 @@ func (dExt *DriverExt) VideoCrawler(configs *VideoCrawlerConfigs) (err error) {
continue continue
} }
if feedVideo.VideoID == crawler.lastVideo.VideoID { if feedVideo.VideoID == crawler.lastVideo.VideoID &&
feedVideo.CacheKey == crawler.lastVideo.CacheKey &&
feedVideo.UserName == crawler.lastVideo.UserName {
// app event tracking not changed // app event tracking not changed
// check and handle popups // check and handle popups
log.Warn().Msg("feed video event tracking not changed") log.Warn().Msg("feed video event tracking not changed")
@@ -333,8 +338,6 @@ func (dExt *DriverExt) VideoCrawler(configs *VideoCrawlerConfigs) (err error) {
// check if live video && run live crawler // check if live video && run live crawler
if enterPoint, isLive := crawler.checkLiveVideo(feedVideo); isLive { if enterPoint, isLive := crawler.checkLiveVideo(feedVideo); isLive {
// 直播预览流 // 直播预览流
// TODO
// screenResult.Live = feedVideo
log.Info().Msg("live video found") log.Info().Msg("live video found")
if !crawler.isLiveTargetAchieved() { if !crawler.isLiveTargetAchieved() {
if err := crawler.startLiveCrawler(enterPoint); err != nil { if err := crawler.startLiveCrawler(enterPoint); err != nil {
@@ -460,7 +463,7 @@ func (vc *VideoCrawler) getCurrentVideo() (video *Video, err error) {
} }
log.Info(). log.Info().
Interface("videoCaption", video.Caption). Interface("userName", video.UserName).
Msg("get current video success") Msg("get current video success")
return video, nil return video, nil
} }