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

chore: change live preview prob

Browse Source 
* chore: change live preview prob
* chore: change exit liveroom

https://code.byted.org/iesqa/httprunner/merge_requests/33
This commit is contained in:
曹帅
2024-04-16 06:40:43 +00:00
parent 140901b7c6
commit b82cfb58b3
4 changed files with 26 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hrp/pkg/uixt/android_device.go
View File

@@ -154,6 +154,10 @@ type AndroidDevice struct {
LogOn bool `json:"log_on,omitempty" yaml:"log_on,omitempty"` LogOn bool `json:"log_on,omitempty" yaml:"log_on,omitempty"`
} }
func (dev *AndroidDevice) System() string {
return "android"
}
func (dev *AndroidDevice) UUID() string { func (dev *AndroidDevice) UUID() string {
return dev.SerialNumber return dev.SerialNumber
} }

3
hrp/pkg/uixt/interface.go
View File

@@ -466,7 +466,8 @@ func WithDriverPlugin(plugin funplugin.IPlugin) DriverOption {
// current implemeted device: IOSDevice, AndroidDevice // current implemeted device: IOSDevice, AndroidDevice
type Device interface { type Device interface {
UUID() string // ios udid or android serial System() string // ios or android
UUID() string // ios udid or android serial
LogEnabled() bool LogEnabled() bool
NewDriver(...DriverOption) (driverExt *DriverExt, err error) NewDriver(...DriverOption) (driverExt *DriverExt, err error)

4
hrp/pkg/uixt/ios_device.go
View File

@@ -289,6 +289,10 @@ type IOSDevice struct {
pcapFile string // saved pcap file path pcapFile string // saved pcap file path
} }
func (dev *IOSDevice) System() string {
return "ios"
}
func (dev *IOSDevice) UUID() string { func (dev *IOSDevice) UUID() string {
return dev.UDID return dev.UDID
} }

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

@@ -197,6 +197,9 @@ func (dExt *DriverExt) VideoCrawler(configs *VideoCrawlerConfigs) (err error) {
continue continue
} }
// 直播预览流线上概率
livePreviewProb := crawler.getLivePreviewProb()
switch currentVideo.Type { switch currentVideo.Type {
case VideoType_PreviewLive: case VideoType_PreviewLive:
// 直播预览流 // 直播预览流
@@ -205,9 +208,8 @@ func (dExt *DriverExt) VideoCrawler(configs *VideoCrawlerConfigs) (err error) {
log.Info().Interface("video", currentVideo). log.Info().Interface("video", currentVideo).
Msg("live count achieved, skip entering live room") Msg("live count achieved, skip entering live room")
skipEnterLive = true skipEnterLive = true
} else if rand.Float64() <= 0.10 { } else if rand.Float64() <= livePreviewProb {
// 10% chance skip entering live room log.Info().Interface("livePreviewProb", livePreviewProb).Msg("skip entering preview")
log.Info().Msg("skip entering preview live by 10% chance")
skipEnterLive = true skipEnterLive = true
} }
@@ -272,9 +274,8 @@ func (dExt *DriverExt) VideoCrawler(configs *VideoCrawlerConfigs) (err error) {
log.Info().Interface("live", currentVideo). log.Info().Interface("live", currentVideo).
Msg("live count achieved, exit live room") Msg("live count achieved, exit live room")
exitLive = true exitLive = true
} else if rand.Float64() <= 0.10 { } else if rand.Float64() <= livePreviewProb {
// 10% chance exit live room log.Info().Interface("livePreviewProb", livePreviewProb).Msg("exit live room by preview live chance")
log.Info().Msg("exit live room by 10% chance")
exitLive = true exitLive = true
} }
if exitLive && currentVideo.Type == VideoType_Live { if exitLive && currentVideo.Type == VideoType_Live {
@@ -427,3 +428,12 @@ func (vc *VideoCrawler) getCurrentVideo() (video *Video, err error) {
Msg("get current video success") Msg("get current video success")
return video, nil return video, nil
} }
func (vc *VideoCrawler) getLivePreviewProb() float64 {
if vc.driverExt.Device.System() == "ios" {
return 0.5326
} else if vc.driverExt.Device.System() == "android" {
return 0.3414
}
return -1
}