refactor: restructure

hrp/internal/uixt/ext.go

@@ -7,9 +7,6 @@ import (
 	"image"
 	"image/jpeg"
 	"image/png"
-	"mime"
-	"mime/multipart"
-	"net/http"
 	"os"
 	"path/filepath"
 	"strings"
@@ -148,61 +145,6 @@ func extend(driver WebDriver) (dExt *DriverExt, err error) {
 	return dExt, nil
 }
 
-func (dExt *DriverExt) ConnectMjpegStream(httpClient *http.Client) (err error) {
-	if httpClient == nil {
-		return errors.New(`'httpClient' can't be nil`)
-	}
-
-	var req *http.Request
-	if req, err = http.NewRequest(http.MethodGet, "http://*", nil); err != nil {
-		return err
-	}
-
-	var resp *http.Response
-	if resp, err = httpClient.Do(req); err != nil {
-		return err
-	}
-	// defer func() { _ = resp.Body.Close() }()
-
-	var boundary string
-	if _, param, err := mime.ParseMediaType(resp.Header.Get("Content-Type")); err != nil {
-		return err
-	} else {
-		boundary = strings.Trim(param["boundary"], "-")
-	}
-
-	mjpegReader := multipart.NewReader(resp.Body, boundary)
-
-	go func() {
-		for {
-			select {
-			case <-dExt.doneMjpegStream:
-				_ = resp.Body.Close()
-				return
-			default:
-				var part *multipart.Part
-				if part, err = mjpegReader.NextPart(); err != nil {
-					dExt.frame = nil
-					continue
-				}
-
-				raw := new(bytes.Buffer)
-				if _, err = raw.ReadFrom(part); err != nil {
-					dExt.frame = nil
-					continue
-				}
-				dExt.frame = raw
-			}
-		}
-	}()
-
-	return
-}
-
-func (dExt *DriverExt) CloseMjpegStream() {
-	dExt.doneMjpegStream <- true
-}
-
 func (dExt *DriverExt) takeScreenShot() (raw *bytes.Buffer, err error) {
 	// 优先使用 MJPEG 流进行截图，性能最优
 	// 如果 MJPEG 流未开启，则使用 WebDriver 的截图接口