Feature: Use concurrent workers for deb driver (#322)

Author: Zweih

internal/origins/drivers/deb/parser.go

@@ -6,16 +6,17 @@ import (
 	"fmt"
 	"qp/internal/consts"
 	"qp/internal/origins/formats/debstyle"
+	"qp/internal/origins/worker"
 	"qp/internal/pkgdata"
 	"strconv"
 	"strings"
 )
 
 func parseStatusFile(data []byte, origin string, reasonMap map[string]string) ([]*pkgdata.PkgInfo, error) {
-	var collectedErrors []error
-	pkgs := []*pkgdata.PkgInfo{}
+	blocks := bytes.Split(data, []byte("\n\n"))
+	inputChan := make(chan map[string]string, len(blocks))
 
-	for block := range bytes.SplitSeq(data, []byte("\n\n")) {
+	for _, block := range blocks {
 		if len(block) < 1 {
 			continue
 		}
@@ -25,19 +26,21 @@ func parseStatusFile(data []byte, origin string, reasonMap map[string]string) ([
 			continue
 		}
 
-		pkg, err := parseStatusBlock(fields, reasonMap, origin)
-		if err != nil {
-			collectedErrors = append(collectedErrors, err)
-		}
-
-		pkgs = append(pkgs, pkg)
+		inputChan <- fields
 	}
-
-	if len(collectedErrors) > 0 {
-		return pkgs, errors.Join(collectedErrors...)
-	}
-
-	return pkgs, nil
+	close(inputChan)
+
+	resultChan, errorChan := worker.RunWorkers(
+		inputChan,
+		func(fields map[string]string) (*pkgdata.PkgInfo, error) {
+			pkg, err := parseStatusBlock(fields, reasonMap, origin)
+			return pkg, err
+		},
+		0,
+		len(blocks),
+	)
+
+	return worker.CollectOutput(resultChan, errorChan)
 }
 
 func parseStatusBlock(

internal/origins/drivers/opkg/parser.go

@@ -11,6 +11,7 @@ import (
 	"qp/internal/origins/worker"
 	"qp/internal/pkgdata"
 	"strconv"
+	"strings"
 )
 
 func parseStatusFile(data []byte, origin string) ([]*pkgdata.PkgInfo, error) {
@@ -23,7 +24,7 @@ func parseStatusFile(data []byte, origin string) ([]*pkgdata.PkgInfo, error) {
 		}
 
 		fields := debstyle.ParseStatusFields(block)
-		if fields[fieldStatus] == "install ok installed" {
+		if strings.Contains(fields[fieldStatus], "installed") {
 			continue
 		}