mirror of
https://github.com/Jguer/yay
synced 2024-09-06 16:43:03 +00:00
850 lines
22 KiB
Go
850 lines
22 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
"strconv"
|
|
"strings"
|
|
"sync"
|
|
|
|
alpm "github.com/Jguer/go-alpm/v2"
|
|
gosrc "github.com/Morganamilo/go-srcinfo"
|
|
"github.com/leonelquinteros/gotext"
|
|
|
|
"github.com/Jguer/yay/v11/pkg/completion"
|
|
"github.com/Jguer/yay/v11/pkg/db"
|
|
"github.com/Jguer/yay/v11/pkg/dep"
|
|
"github.com/Jguer/yay/v11/pkg/download"
|
|
"github.com/Jguer/yay/v11/pkg/menus"
|
|
"github.com/Jguer/yay/v11/pkg/pgp"
|
|
"github.com/Jguer/yay/v11/pkg/query"
|
|
"github.com/Jguer/yay/v11/pkg/settings"
|
|
"github.com/Jguer/yay/v11/pkg/settings/parser"
|
|
"github.com/Jguer/yay/v11/pkg/stringset"
|
|
"github.com/Jguer/yay/v11/pkg/text"
|
|
)
|
|
|
|
func asdeps(ctx context.Context, cmdArgs *parser.Arguments, pkgs []string) (err error) {
|
|
if len(pkgs) == 0 {
|
|
return nil
|
|
}
|
|
|
|
cmdArgs = cmdArgs.CopyGlobal()
|
|
_ = cmdArgs.AddArg("q", "D", "asdeps")
|
|
cmdArgs.AddTarget(pkgs...)
|
|
|
|
err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
cmdArgs, config.Runtime.Mode, settings.NoConfirm))
|
|
if err != nil {
|
|
return errors.New(gotext.Get("error updating package install reason to dependency"))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func asexp(ctx context.Context, cmdArgs *parser.Arguments, pkgs []string) (err error) {
|
|
if len(pkgs) == 0 {
|
|
return nil
|
|
}
|
|
|
|
cmdArgs = cmdArgs.CopyGlobal()
|
|
_ = cmdArgs.AddArg("q", "D", "asexplicit")
|
|
cmdArgs.AddTarget(pkgs...)
|
|
|
|
err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
cmdArgs, config.Runtime.Mode, settings.NoConfirm))
|
|
if err != nil {
|
|
return errors.New(gotext.Get("error updating package install reason to explicit"))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// Install handles package installs.
|
|
func install(ctx context.Context, cmdArgs *parser.Arguments, dbExecutor db.Executor, ignoreProviders bool) error {
|
|
var (
|
|
incompatible stringset.StringSet
|
|
do *dep.Order
|
|
srcinfos map[string]*gosrc.Srcinfo
|
|
noDeps = cmdArgs.ExistsDouble("d", "nodeps")
|
|
noCheck = strings.Contains(config.MFlags, "--nocheck")
|
|
assumeInstalled = cmdArgs.GetArgs("assume-installed")
|
|
sysupgradeArg = cmdArgs.ExistsArg("u", "sysupgrade")
|
|
refreshArg = cmdArgs.ExistsArg("y", "refresh")
|
|
warnings = query.NewWarnings()
|
|
)
|
|
|
|
if noDeps {
|
|
config.Runtime.CmdBuilder.AddMakepkgFlag("-d")
|
|
}
|
|
|
|
if config.Runtime.Mode.AtLeastRepo() {
|
|
if config.CombinedUpgrade {
|
|
if refreshArg {
|
|
if errR := earlyRefresh(ctx, cmdArgs); errR != nil {
|
|
return errors.New(gotext.Get("error refreshing databases"))
|
|
}
|
|
}
|
|
} else if refreshArg || sysupgradeArg || len(cmdArgs.Targets) > 0 {
|
|
if errP := earlyPacmanCall(ctx, cmdArgs, dbExecutor); errP != nil {
|
|
return errP
|
|
}
|
|
}
|
|
}
|
|
|
|
// we may have done -Sy, our handle now has an old
|
|
// database.
|
|
if errRefresh := dbExecutor.RefreshHandle(); errRefresh != nil {
|
|
return errRefresh
|
|
}
|
|
|
|
localNames, remoteNames, err := query.GetPackageNamesBySource(dbExecutor)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
remoteNamesCache := stringset.FromSlice(remoteNames)
|
|
localNamesCache := stringset.FromSlice(localNames)
|
|
|
|
requestTargets := cmdArgs.Copy().Targets
|
|
|
|
// create the arguments to pass for the repo install
|
|
arguments := cmdArgs.Copy()
|
|
arguments.DelArg("asdeps", "asdep")
|
|
arguments.DelArg("asexplicit", "asexp")
|
|
arguments.Op = "S"
|
|
arguments.ClearTargets()
|
|
|
|
if config.Runtime.Mode == parser.ModeAUR {
|
|
arguments.DelArg("u", "sysupgrade")
|
|
}
|
|
|
|
// if we are doing -u also request all packages needing update
|
|
if sysupgradeArg {
|
|
ignore, targets, errUp := sysupgradeTargets(ctx, dbExecutor, cmdArgs.ExistsDouble("u", "sysupgrade"))
|
|
if errUp != nil {
|
|
return errUp
|
|
}
|
|
|
|
for _, up := range targets {
|
|
cmdArgs.AddTarget(up)
|
|
requestTargets = append(requestTargets, up)
|
|
}
|
|
|
|
if len(ignore) > 0 {
|
|
arguments.CreateOrAppendOption("ignore", ignore.ToSlice()...)
|
|
}
|
|
}
|
|
|
|
targets := stringset.FromSlice(cmdArgs.Targets)
|
|
|
|
dp, err := dep.GetPool(ctx, requestTargets,
|
|
warnings, dbExecutor, config.Runtime.AURClient, config.Runtime.Mode,
|
|
ignoreProviders, settings.NoConfirm, config.Provides, config.ReBuild, config.RequestSplitN, noDeps, noCheck, assumeInstalled)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if errC := dp.CheckMissing(noDeps, noCheck); errC != nil {
|
|
return errC
|
|
}
|
|
|
|
if len(dp.Aur) == 0 {
|
|
if !config.CombinedUpgrade {
|
|
if sysupgradeArg {
|
|
fmt.Println(gotext.Get(" there is nothing to do"))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
cmdArgs.Op = "S"
|
|
cmdArgs.DelArg("y", "refresh")
|
|
|
|
if arguments.ExistsArg("ignore") {
|
|
cmdArgs.CreateOrAppendOption("ignore", arguments.GetArgs("ignore")...)
|
|
}
|
|
|
|
return config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
cmdArgs, config.Runtime.Mode, settings.NoConfirm))
|
|
}
|
|
|
|
conflicts, errCC := dp.CheckConflicts(config.UseAsk, settings.NoConfirm, noDeps)
|
|
if errCC != nil {
|
|
return errCC
|
|
}
|
|
|
|
do = dep.GetOrder(dp, noDeps, noCheck)
|
|
|
|
for _, pkg := range do.Repo {
|
|
arguments.AddTarget(pkg.DB().Name() + "/" + pkg.Name())
|
|
}
|
|
|
|
for _, pkg := range dp.Groups {
|
|
arguments.AddTarget(pkg)
|
|
}
|
|
|
|
if len(do.Aur) == 0 && len(arguments.Targets) == 0 &&
|
|
(!cmdArgs.ExistsArg("u", "sysupgrade") || config.Runtime.Mode == parser.ModeAUR) {
|
|
fmt.Println(gotext.Get(" there is nothing to do"))
|
|
return nil
|
|
}
|
|
|
|
do.Print()
|
|
fmt.Println()
|
|
|
|
if config.CleanAfter {
|
|
defer cleanAfter(ctx, do.Aur)
|
|
}
|
|
|
|
if do.HasMake() {
|
|
switch config.RemoveMake {
|
|
case "yes":
|
|
defer func() {
|
|
err = removeMake(ctx, do)
|
|
}()
|
|
|
|
case "no":
|
|
break
|
|
default:
|
|
if text.ContinueTask(gotext.Get("Remove make dependencies after install?"), false, settings.NoConfirm) {
|
|
defer func() {
|
|
err = removeMake(ctx, do)
|
|
}()
|
|
}
|
|
}
|
|
}
|
|
|
|
if errCleanMenu := menus.Clean(config.CleanMenu,
|
|
config.BuildDir, do.Aur,
|
|
remoteNamesCache, settings.NoConfirm, config.AnswerClean); errCleanMenu != nil {
|
|
if errors.As(errCleanMenu, &settings.ErrUserAbort{}) {
|
|
return errCleanMenu
|
|
}
|
|
|
|
text.Errorln(errCleanMenu)
|
|
}
|
|
|
|
toSkip := pkgbuildsToSkip(do.Aur, targets)
|
|
toClone := make([]string, 0, len(do.Aur))
|
|
|
|
for _, base := range do.Aur {
|
|
if !toSkip.Get(base.Pkgbase()) {
|
|
toClone = append(toClone, base.Pkgbase())
|
|
}
|
|
}
|
|
|
|
if toSkipSlice := toSkip.ToSlice(); len(toSkipSlice) != 0 {
|
|
text.OperationInfoln(
|
|
gotext.Get("PKGBUILD up to date, Skipping (%d/%d): %s",
|
|
len(toSkipSlice), len(toClone), text.Cyan(strings.Join(toSkipSlice, ", "))))
|
|
}
|
|
|
|
cloned, errA := download.AURPKGBUILDRepos(ctx,
|
|
config.Runtime.CmdBuilder, toClone, config.AURURL, config.BuildDir, false)
|
|
if errA != nil {
|
|
return errA
|
|
}
|
|
|
|
if errDiffMenu := menus.Diff(ctx, config.Runtime.CmdBuilder, config.BuildDir,
|
|
config.DiffMenu, do.Aur, remoteNamesCache,
|
|
cloned, settings.NoConfirm, config.AnswerDiff); errDiffMenu != nil {
|
|
if errors.As(errDiffMenu, &settings.ErrUserAbort{}) {
|
|
return errDiffMenu
|
|
}
|
|
|
|
text.Errorln(errDiffMenu)
|
|
}
|
|
|
|
if errM := mergePkgbuilds(ctx, do.Aur); errM != nil {
|
|
return errM
|
|
}
|
|
|
|
srcinfos, err = parseSrcinfoFiles(do.Aur, true)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if errEditMenu := menus.Edit(config.EditMenu, config.BuildDir, do.Aur,
|
|
config.Editor, config.EditorFlags, remoteNamesCache, srcinfos,
|
|
settings.NoConfirm, config.AnswerEdit); errEditMenu != nil {
|
|
if errors.As(errEditMenu, &settings.ErrUserAbort{}) {
|
|
return errEditMenu
|
|
}
|
|
|
|
text.Errorln(errEditMenu)
|
|
}
|
|
|
|
incompatible, err = getIncompatible(do.Aur, srcinfos, dbExecutor)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if config.PGPFetch {
|
|
if errCPK := pgp.CheckPgpKeys(do.Aur, srcinfos, config.GpgBin, config.GpgFlags, settings.NoConfirm); errCPK != nil {
|
|
return errCPK
|
|
}
|
|
}
|
|
|
|
if !config.CombinedUpgrade {
|
|
arguments.DelArg("u", "sysupgrade")
|
|
}
|
|
|
|
if len(arguments.Targets) > 0 || arguments.ExistsArg("u") {
|
|
if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
|
|
return errors.New(gotext.Get("error installing repo packages"))
|
|
}
|
|
|
|
deps := make([]string, 0)
|
|
exp := make([]string, 0)
|
|
|
|
for _, pkg := range do.Repo {
|
|
if !dp.Explicit.Get(pkg.Name()) && !localNamesCache.Get(pkg.Name()) && !remoteNamesCache.Get(pkg.Name()) {
|
|
deps = append(deps, pkg.Name())
|
|
|
|
continue
|
|
}
|
|
|
|
if cmdArgs.ExistsArg("asdeps", "asdep") && dp.Explicit.Get(pkg.Name()) {
|
|
deps = append(deps, pkg.Name())
|
|
} else if cmdArgs.ExistsArg("asexp", "asexplicit") && dp.Explicit.Get(pkg.Name()) {
|
|
exp = append(exp, pkg.Name())
|
|
}
|
|
}
|
|
|
|
if errDeps := asdeps(ctx, cmdArgs, deps); errDeps != nil {
|
|
return errDeps
|
|
}
|
|
|
|
if errExp := asexp(ctx, cmdArgs, exp); errExp != nil {
|
|
return errExp
|
|
}
|
|
}
|
|
|
|
go func() {
|
|
_ = completion.Update(ctx, config.Runtime.HTTPClient, dbExecutor,
|
|
config.AURURL, config.Runtime.CompletionPath, config.CompletionInterval, false)
|
|
}()
|
|
|
|
if errP := downloadPKGBUILDSourceFanout(ctx, config.Runtime.CmdBuilder, config.BuildDir,
|
|
do.Aur, incompatible, config.MaxConcurrentDownloads); errP != nil {
|
|
text.Errorln(errP)
|
|
}
|
|
|
|
if errB := buildInstallPkgbuilds(ctx, cmdArgs, dbExecutor, dp, do, srcinfos, incompatible, conflicts, noDeps, noCheck); errB != nil {
|
|
return errB
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func removeMake(ctx context.Context, do *dep.Order) error {
|
|
removeArguments := parser.MakeArguments()
|
|
|
|
err := removeArguments.AddArg("R", "u")
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, pkg := range do.GetMake() {
|
|
removeArguments.AddTarget(pkg)
|
|
}
|
|
|
|
oldValue := settings.NoConfirm
|
|
settings.NoConfirm = true
|
|
err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
removeArguments, config.Runtime.Mode, settings.NoConfirm))
|
|
settings.NoConfirm = oldValue
|
|
|
|
return err
|
|
}
|
|
|
|
func inRepos(dbExecutor db.Executor, pkg string) bool {
|
|
target := dep.ToTarget(pkg)
|
|
|
|
if target.DB == "aur" {
|
|
return false
|
|
} else if target.DB != "" {
|
|
return true
|
|
}
|
|
|
|
previousHideMenus := settings.HideMenus
|
|
settings.HideMenus = true
|
|
exists := dbExecutor.SyncSatisfierExists(target.DepString())
|
|
settings.HideMenus = previousHideMenus
|
|
|
|
return exists || len(dbExecutor.PackagesFromGroup(target.Name)) > 0
|
|
}
|
|
|
|
func earlyPacmanCall(ctx context.Context, cmdArgs *parser.Arguments, dbExecutor db.Executor) error {
|
|
arguments := cmdArgs.Copy()
|
|
arguments.Op = "S"
|
|
targets := cmdArgs.Targets
|
|
cmdArgs.ClearTargets()
|
|
arguments.ClearTargets()
|
|
|
|
if config.Runtime.Mode == parser.ModeRepo {
|
|
arguments.Targets = targets
|
|
} else {
|
|
// separate aur and repo targets
|
|
for _, target := range targets {
|
|
if inRepos(dbExecutor, target) {
|
|
arguments.AddTarget(target)
|
|
} else {
|
|
cmdArgs.AddTarget(target)
|
|
}
|
|
}
|
|
}
|
|
|
|
if cmdArgs.ExistsArg("y", "refresh") || cmdArgs.ExistsArg("u", "sysupgrade") || len(arguments.Targets) > 0 {
|
|
if err := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
arguments, config.Runtime.Mode, settings.NoConfirm)); err != nil {
|
|
return errors.New(gotext.Get("error installing repo packages"))
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func earlyRefresh(ctx context.Context, cmdArgs *parser.Arguments) error {
|
|
arguments := cmdArgs.Copy()
|
|
cmdArgs.DelArg("y", "refresh")
|
|
arguments.DelArg("u", "sysupgrade")
|
|
arguments.DelArg("s", "search")
|
|
arguments.DelArg("i", "info")
|
|
arguments.DelArg("l", "list")
|
|
arguments.ClearTargets()
|
|
|
|
return config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
arguments, config.Runtime.Mode, settings.NoConfirm))
|
|
}
|
|
|
|
func alpmArchIsSupported(alpmArch []string, arch string) bool {
|
|
if arch == "any" {
|
|
return true
|
|
}
|
|
|
|
for _, a := range alpmArch {
|
|
if a == arch {
|
|
return true
|
|
}
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func getIncompatible(bases []dep.Base, srcinfos map[string]*gosrc.Srcinfo, dbExecutor db.Executor) (stringset.StringSet, error) {
|
|
incompatible := make(stringset.StringSet)
|
|
basesMap := make(map[string]dep.Base)
|
|
|
|
alpmArch, err := dbExecutor.AlpmArchitectures()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
nextpkg:
|
|
for _, base := range bases {
|
|
for _, arch := range srcinfos[base.Pkgbase()].Arch {
|
|
if alpmArchIsSupported(alpmArch, arch) {
|
|
continue nextpkg
|
|
}
|
|
}
|
|
|
|
incompatible.Set(base.Pkgbase())
|
|
basesMap[base.Pkgbase()] = base
|
|
}
|
|
|
|
if len(incompatible) > 0 {
|
|
text.Warnln(gotext.Get("The following packages are not compatible with your architecture:"))
|
|
|
|
for pkg := range incompatible {
|
|
fmt.Print(" " + text.Cyan(basesMap[pkg].String()))
|
|
}
|
|
|
|
fmt.Println()
|
|
|
|
if !text.ContinueTask(gotext.Get("Try to build them anyway?"), true, settings.NoConfirm) {
|
|
return nil, &settings.ErrUserAbort{}
|
|
}
|
|
}
|
|
|
|
return incompatible, nil
|
|
}
|
|
|
|
func parsePackageList(ctx context.Context, dir string) (pkgdests map[string]string, pkgVersion string, err error) {
|
|
stdout, stderr, err := config.Runtime.CmdBuilder.Capture(
|
|
config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, "--packagelist"))
|
|
if err != nil {
|
|
return nil, "", fmt.Errorf("%s %s", stderr, err)
|
|
}
|
|
|
|
lines := strings.Split(stdout, "\n")
|
|
pkgdests = make(map[string]string)
|
|
|
|
for _, line := range lines {
|
|
if line == "" {
|
|
continue
|
|
}
|
|
|
|
fileName := filepath.Base(line)
|
|
split := strings.Split(fileName, "-")
|
|
|
|
if len(split) < 4 {
|
|
return nil, "", errors.New(gotext.Get("cannot find package name: %v", split))
|
|
}
|
|
|
|
// pkgname-pkgver-pkgrel-arch.pkgext
|
|
// This assumes 3 dashes after the pkgname, Will cause an error
|
|
// if the PKGEXT contains a dash. Please no one do that.
|
|
pkgName := strings.Join(split[:len(split)-3], "-")
|
|
pkgVersion = strings.Join(split[len(split)-3:len(split)-1], "-")
|
|
pkgdests[pkgName] = line
|
|
}
|
|
|
|
return pkgdests, pkgVersion, nil
|
|
}
|
|
|
|
func parseSrcinfoFiles(bases []dep.Base, errIsFatal bool) (map[string]*gosrc.Srcinfo, error) {
|
|
srcinfos := make(map[string]*gosrc.Srcinfo)
|
|
|
|
for k, base := range bases {
|
|
pkg := base.Pkgbase()
|
|
dir := filepath.Join(config.BuildDir, pkg)
|
|
|
|
text.OperationInfoln(gotext.Get("(%d/%d) Parsing SRCINFO: %s", k+1, len(bases), text.Cyan(base.String())))
|
|
|
|
pkgbuild, err := gosrc.ParseFile(filepath.Join(dir, ".SRCINFO"))
|
|
if err != nil {
|
|
if !errIsFatal {
|
|
text.Warnln(gotext.Get("failed to parse %s -- skipping: %s", base.String(), err))
|
|
continue
|
|
}
|
|
|
|
return nil, errors.New(gotext.Get("failed to parse %s: %s", base.String(), err))
|
|
}
|
|
|
|
srcinfos[pkg] = pkgbuild
|
|
}
|
|
|
|
return srcinfos, nil
|
|
}
|
|
|
|
func pkgbuildsToSkip(bases []dep.Base, targets stringset.StringSet) stringset.StringSet {
|
|
toSkip := make(stringset.StringSet)
|
|
|
|
for _, base := range bases {
|
|
isTarget := false
|
|
for _, pkg := range base {
|
|
isTarget = isTarget || targets.Get(pkg.Name)
|
|
}
|
|
|
|
if (config.ReDownload == "yes" && isTarget) || config.ReDownload == "all" {
|
|
continue
|
|
}
|
|
|
|
dir := filepath.Join(config.BuildDir, base.Pkgbase(), ".SRCINFO")
|
|
pkgbuild, err := gosrc.ParseFile(dir)
|
|
|
|
if err == nil {
|
|
if db.VerCmp(pkgbuild.Version(), base.Version()) >= 0 {
|
|
toSkip.Set(base.Pkgbase())
|
|
}
|
|
}
|
|
}
|
|
|
|
return toSkip
|
|
}
|
|
|
|
func gitMerge(ctx context.Context, path, name string) error {
|
|
_, stderr, err := config.Runtime.CmdBuilder.Capture(
|
|
config.Runtime.CmdBuilder.BuildGitCmd(ctx,
|
|
filepath.Join(path, name), "reset", "--hard", "HEAD"))
|
|
if err != nil {
|
|
return errors.New(gotext.Get("error resetting %s: %s", name, stderr))
|
|
}
|
|
|
|
_, stderr, err = config.Runtime.CmdBuilder.Capture(
|
|
config.Runtime.CmdBuilder.BuildGitCmd(ctx,
|
|
filepath.Join(path, name), "merge", "--no-edit", "--ff"))
|
|
if err != nil {
|
|
return errors.New(gotext.Get("error merging %s: %s", name, stderr))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func mergePkgbuilds(ctx context.Context, bases []dep.Base) error {
|
|
for _, base := range bases {
|
|
err := gitMerge(ctx, config.BuildDir, base.Pkgbase())
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func buildInstallPkgbuilds(
|
|
ctx context.Context,
|
|
cmdArgs *parser.Arguments,
|
|
dbExecutor db.Executor,
|
|
dp *dep.Pool,
|
|
do *dep.Order,
|
|
srcinfos map[string]*gosrc.Srcinfo,
|
|
incompatible stringset.StringSet,
|
|
conflicts stringset.MapStringSet, noDeps, noCheck bool,
|
|
) error {
|
|
arguments := cmdArgs.Copy()
|
|
arguments.ClearTargets()
|
|
arguments.Op = "U"
|
|
arguments.DelArg("confirm")
|
|
arguments.DelArg("noconfirm")
|
|
arguments.DelArg("c", "clean")
|
|
arguments.DelArg("q", "quiet")
|
|
arguments.DelArg("q", "quiet")
|
|
arguments.DelArg("y", "refresh")
|
|
arguments.DelArg("u", "sysupgrade")
|
|
arguments.DelArg("w", "downloadonly")
|
|
|
|
deps := make([]string, 0)
|
|
exp := make([]string, 0)
|
|
oldConfirm := settings.NoConfirm
|
|
settings.NoConfirm = true
|
|
|
|
// remotenames: names of all non repo packages on the system
|
|
localNames, remoteNames, err := query.GetPackageNamesBySource(dbExecutor)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// cache as a stringset. maybe make it return a string set in the first
|
|
// place
|
|
remoteNamesCache := stringset.FromSlice(remoteNames)
|
|
localNamesCache := stringset.FromSlice(localNames)
|
|
|
|
for _, base := range do.Aur {
|
|
pkg := base.Pkgbase()
|
|
dir := filepath.Join(config.BuildDir, pkg)
|
|
built := true
|
|
|
|
satisfied := true
|
|
all:
|
|
for _, pkg := range base {
|
|
for _, deps := range dep.ComputeCombinedDepList(pkg, noDeps, noCheck) {
|
|
for _, dep := range deps {
|
|
if !dp.AlpmExecutor.LocalSatisfierExists(dep) {
|
|
satisfied = false
|
|
text.Warnln(gotext.Get("%s not satisfied, flushing install queue", dep))
|
|
|
|
break all
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if !satisfied || !config.BatchInstall {
|
|
err = doInstall(ctx, arguments, cmdArgs, deps, exp)
|
|
arguments.ClearTargets()
|
|
|
|
deps = make([]string, 0)
|
|
exp = make([]string, 0)
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
srcinfo := srcinfos[pkg]
|
|
|
|
args := []string{"--nobuild", "-fC"}
|
|
|
|
if incompatible.Get(pkg) {
|
|
args = append(args, "--ignorearch")
|
|
}
|
|
|
|
// pkgver bump
|
|
if err = config.Runtime.CmdBuilder.Show(
|
|
config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, args...)); err != nil {
|
|
return errors.New(gotext.Get("error making: %s", base.String()))
|
|
}
|
|
|
|
pkgdests, pkgVersion, errList := parsePackageList(ctx, dir)
|
|
if errList != nil {
|
|
return errList
|
|
}
|
|
|
|
isExplicit := false
|
|
for _, b := range base {
|
|
isExplicit = isExplicit || dp.Explicit.Get(b.Name)
|
|
}
|
|
|
|
if config.ReBuild == "no" || (config.ReBuild == "yes" && !isExplicit) {
|
|
for _, split := range base {
|
|
pkgdest, ok := pkgdests[split.Name]
|
|
if !ok {
|
|
return errors.New(gotext.Get("could not find PKGDEST for: %s", split.Name))
|
|
}
|
|
|
|
if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
|
|
built = false
|
|
} else if errStat != nil {
|
|
return errStat
|
|
}
|
|
}
|
|
} else {
|
|
built = false
|
|
}
|
|
|
|
if cmdArgs.ExistsArg("needed") {
|
|
installed := true
|
|
for _, split := range base {
|
|
installed = dp.AlpmExecutor.IsCorrectVersionInstalled(split.Name, pkgVersion)
|
|
}
|
|
|
|
if installed {
|
|
err = config.Runtime.CmdBuilder.Show(
|
|
config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
|
|
dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
|
|
if err != nil {
|
|
return errors.New(gotext.Get("error making: %s", err))
|
|
}
|
|
|
|
fmt.Fprintln(os.Stdout, gotext.Get("%s is up to date -- skipping", text.Cyan(pkg+"-"+pkgVersion)))
|
|
|
|
continue
|
|
}
|
|
}
|
|
|
|
if built {
|
|
err = config.Runtime.CmdBuilder.Show(
|
|
config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
|
|
dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
|
|
if err != nil {
|
|
return errors.New(gotext.Get("error making: %s", err))
|
|
}
|
|
|
|
text.Warnln(gotext.Get("%s already made -- skipping build", text.Cyan(pkg+"-"+pkgVersion)))
|
|
} else {
|
|
args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
|
|
|
|
if incompatible.Get(pkg) {
|
|
args = append(args, "--ignorearch")
|
|
}
|
|
|
|
if errMake := config.Runtime.CmdBuilder.Show(
|
|
config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
|
|
dir, args...)); errMake != nil {
|
|
return errors.New(gotext.Get("error making: %s", base.String()))
|
|
}
|
|
}
|
|
|
|
// conflicts have been checked so answer y for them
|
|
if config.UseAsk && cmdArgs.ExistsArg("ask") {
|
|
ask, _ := strconv.Atoi(cmdArgs.Options["ask"].First())
|
|
uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
|
|
cmdArgs.Options["ask"].Set(fmt.Sprint(uask))
|
|
} else {
|
|
for _, split := range base {
|
|
if _, ok := conflicts[split.Name]; ok {
|
|
settings.NoConfirm = false
|
|
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
var errAdd error
|
|
|
|
for _, split := range base {
|
|
for suffix, optional := range map[string]bool{"": false, "-debug": true} {
|
|
deps, exp, errAdd = doAddTarget(dp, localNamesCache, remoteNamesCache,
|
|
arguments, cmdArgs, pkgdests, deps, exp, split.Name+suffix, optional)
|
|
if errAdd != nil {
|
|
return errAdd
|
|
}
|
|
}
|
|
}
|
|
|
|
var (
|
|
mux sync.Mutex
|
|
wg sync.WaitGroup
|
|
)
|
|
|
|
for _, pkg := range base {
|
|
wg.Add(1)
|
|
|
|
go config.Runtime.VCSStore.Update(ctx, pkg.Name, srcinfo.Source, &mux, &wg)
|
|
}
|
|
|
|
wg.Wait()
|
|
}
|
|
|
|
err = doInstall(ctx, arguments, cmdArgs, deps, exp)
|
|
settings.NoConfirm = oldConfirm
|
|
|
|
return err
|
|
}
|
|
|
|
func doInstall(ctx context.Context, arguments, cmdArgs *parser.Arguments, pkgDeps, pkgExp []string) error {
|
|
if len(arguments.Targets) == 0 {
|
|
return nil
|
|
}
|
|
|
|
if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
|
|
arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
|
|
return errShow
|
|
}
|
|
|
|
if errStore := config.Runtime.VCSStore.Save(); errStore != nil {
|
|
fmt.Fprintln(os.Stderr, errStore)
|
|
}
|
|
|
|
if errDeps := asdeps(ctx, cmdArgs, pkgDeps); errDeps != nil {
|
|
return errDeps
|
|
}
|
|
|
|
return asexp(ctx, cmdArgs, pkgExp)
|
|
}
|
|
|
|
func doAddTarget(dp *dep.Pool, localNamesCache, remoteNamesCache stringset.StringSet,
|
|
arguments, cmdArgs *parser.Arguments, pkgdests map[string]string,
|
|
deps, exp []string, name string, optional bool,
|
|
) (newDeps, newExp []string, err error) {
|
|
pkgdest, ok := pkgdests[name]
|
|
if !ok {
|
|
if optional {
|
|
return deps, exp, nil
|
|
}
|
|
|
|
return deps, exp, errors.New(gotext.Get("could not find PKGDEST for: %s", name))
|
|
}
|
|
|
|
if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
|
|
if optional {
|
|
return deps, exp, nil
|
|
}
|
|
|
|
return deps, exp, errors.New(
|
|
gotext.Get(
|
|
"the PKGDEST for %s is listed by makepkg but does not exist: %s",
|
|
name, pkgdest))
|
|
}
|
|
|
|
arguments.AddTarget(pkgdest)
|
|
|
|
switch {
|
|
case cmdArgs.ExistsArg("asdeps", "asdep"):
|
|
deps = append(deps, name)
|
|
case cmdArgs.ExistsArg("asexplicit", "asexp"):
|
|
exp = append(exp, name)
|
|
case !dp.Explicit.Get(name) && !localNamesCache.Get(name) && !remoteNamesCache.Get(name):
|
|
deps = append(deps, name)
|
|
}
|
|
|
|
return deps, exp, nil
|
|
}
|