install.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899
  1. package main
  2. import (
  3. "context"
  4. "errors"
  5. "fmt"
  6. "os"
  7. "path/filepath"
  8. "strconv"
  9. "strings"
  10. "sync"
  11. alpm "github.com/Jguer/go-alpm/v2"
  12. gosrc "github.com/Morganamilo/go-srcinfo"
  13. mapset "github.com/deckarep/golang-set/v2"
  14. "github.com/leonelquinteros/gotext"
  15. "github.com/Jguer/yay/v11/pkg/completion"
  16. "github.com/Jguer/yay/v11/pkg/db"
  17. "github.com/Jguer/yay/v11/pkg/dep"
  18. "github.com/Jguer/yay/v11/pkg/download"
  19. "github.com/Jguer/yay/v11/pkg/menus"
  20. "github.com/Jguer/yay/v11/pkg/pgp"
  21. "github.com/Jguer/yay/v11/pkg/query"
  22. "github.com/Jguer/yay/v11/pkg/settings"
  23. "github.com/Jguer/yay/v11/pkg/settings/exe"
  24. "github.com/Jguer/yay/v11/pkg/settings/parser"
  25. "github.com/Jguer/yay/v11/pkg/srcinfo"
  26. "github.com/Jguer/yay/v11/pkg/stringset"
  27. "github.com/Jguer/yay/v11/pkg/text"
  28. "github.com/Jguer/yay/v11/pkg/vcs"
  29. )
  30. func setPkgReason(ctx context.Context,
  31. cmdBuilder exe.ICmdBuilder,
  32. mode parser.TargetMode,
  33. cmdArgs *parser.Arguments, pkgs []string, exp bool,
  34. ) error {
  35. if len(pkgs) == 0 {
  36. return nil
  37. }
  38. cmdArgs = cmdArgs.CopyGlobal()
  39. if exp {
  40. if err := cmdArgs.AddArg("q", "D", "asexplicit"); err != nil {
  41. return err
  42. }
  43. } else {
  44. if err := cmdArgs.AddArg("q", "D", "asdeps"); err != nil {
  45. return err
  46. }
  47. }
  48. for _, compositePkgName := range pkgs {
  49. pkgSplit := strings.Split(compositePkgName, "/")
  50. pkgName := pkgSplit[0]
  51. if len(pkgSplit) > 1 {
  52. pkgName = pkgSplit[1]
  53. }
  54. cmdArgs.AddTarget(pkgName)
  55. }
  56. if err := cmdBuilder.Show(cmdBuilder.BuildPacmanCmd(ctx,
  57. cmdArgs, mode, settings.NoConfirm)); err != nil {
  58. return &SetPkgReasonError{exp: exp}
  59. }
  60. return nil
  61. }
  62. func asdeps(ctx context.Context,
  63. cmdBuilder exe.ICmdBuilder,
  64. mode parser.TargetMode, cmdArgs *parser.Arguments, pkgs []string,
  65. ) error {
  66. return setPkgReason(ctx, cmdBuilder, mode, cmdArgs, pkgs, false)
  67. }
  68. func asexp(ctx context.Context,
  69. cmdBuilder exe.ICmdBuilder,
  70. mode parser.TargetMode, cmdArgs *parser.Arguments, pkgs []string,
  71. ) error {
  72. return setPkgReason(ctx, cmdBuilder, mode, cmdArgs, pkgs, true)
  73. }
  74. // Install handles package installs.
  75. func install(ctx context.Context, cmdArgs *parser.Arguments, dbExecutor db.Executor, ignoreProviders bool) error {
  76. var (
  77. do *dep.Order
  78. srcinfos map[string]*gosrc.Srcinfo
  79. noDeps = cmdArgs.ExistsDouble("d", "nodeps")
  80. noCheck = strings.Contains(config.MFlags, "--nocheck")
  81. assumeInstalled = cmdArgs.GetArgs("assume-installed")
  82. sysupgradeArg = cmdArgs.ExistsArg("u", "sysupgrade")
  83. refreshArg = cmdArgs.ExistsArg("y", "refresh")
  84. warnings = query.NewWarnings()
  85. )
  86. if noDeps {
  87. config.Runtime.CmdBuilder.AddMakepkgFlag("-d")
  88. }
  89. if config.Runtime.Mode.AtLeastRepo() {
  90. if config.CombinedUpgrade {
  91. if refreshArg {
  92. if errR := earlyRefresh(ctx, config, config.Runtime.CmdBuilder, cmdArgs); errR != nil {
  93. return fmt.Errorf("%s - %w", gotext.Get("error refreshing databases"), errR)
  94. }
  95. cmdArgs.DelArg("y", "refresh")
  96. }
  97. } else if refreshArg || sysupgradeArg || len(cmdArgs.Targets) > 0 {
  98. if errP := earlyPacmanCall(ctx, cmdArgs, dbExecutor); errP != nil {
  99. return errP
  100. }
  101. }
  102. }
  103. // we may have done -Sy, our handle now has an old
  104. // database.
  105. if errRefresh := dbExecutor.RefreshHandle(); errRefresh != nil {
  106. return errRefresh
  107. }
  108. remoteNames := dbExecutor.InstalledRemotePackageNames()
  109. localNames := dbExecutor.InstalledSyncPackageNames()
  110. remoteNamesCache := mapset.NewThreadUnsafeSet(remoteNames...)
  111. localNamesCache := stringset.FromSlice(localNames)
  112. requestTargets := cmdArgs.Copy().Targets
  113. // create the arguments to pass for the repo install
  114. arguments := cmdArgs.Copy()
  115. arguments.DelArg("asdeps", "asdep")
  116. arguments.DelArg("asexplicit", "asexp")
  117. arguments.Op = "S"
  118. arguments.ClearTargets()
  119. if config.Runtime.Mode == parser.ModeAUR {
  120. arguments.DelArg("u", "sysupgrade")
  121. }
  122. // if we are doing -u also request all packages needing update
  123. if sysupgradeArg {
  124. var errSysUp error
  125. requestTargets, errSysUp = addUpgradeTargetsToArgs(ctx, dbExecutor, cmdArgs, requestTargets, arguments)
  126. if errSysUp != nil {
  127. return errSysUp
  128. }
  129. }
  130. targets := stringset.FromSlice(cmdArgs.Targets)
  131. dp, err := dep.GetPool(ctx, requestTargets,
  132. warnings, dbExecutor, config.Runtime.AURClient, config.Runtime.Mode,
  133. ignoreProviders, settings.NoConfirm, config.Provides, config.ReBuild, config.RequestSplitN, noDeps, noCheck, assumeInstalled)
  134. if err != nil {
  135. return err
  136. }
  137. if errC := dp.CheckMissing(noDeps, noCheck); errC != nil {
  138. return errC
  139. }
  140. if len(dp.Aur) == 0 {
  141. if !config.CombinedUpgrade {
  142. if sysupgradeArg {
  143. fmt.Println(gotext.Get(" there is nothing to do"))
  144. }
  145. return nil
  146. }
  147. cmdArgs.Op = "S"
  148. cmdArgs.DelArg("y", "refresh")
  149. if arguments.ExistsArg("ignore") {
  150. cmdArgs.CreateOrAppendOption("ignore", arguments.GetArgs("ignore")...)
  151. }
  152. return config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  153. cmdArgs, config.Runtime.Mode, settings.NoConfirm))
  154. }
  155. conflicts, errCC := dp.CheckConflicts(config.UseAsk, settings.NoConfirm, noDeps)
  156. if errCC != nil {
  157. return errCC
  158. }
  159. do = dep.GetOrder(dp, noDeps, noCheck)
  160. for _, pkg := range do.Repo {
  161. arguments.AddTarget(pkg.DB().Name() + "/" + pkg.Name())
  162. }
  163. for _, pkg := range dp.Groups {
  164. arguments.AddTarget(pkg)
  165. }
  166. if len(do.Aur) == 0 && len(arguments.Targets) == 0 &&
  167. (!cmdArgs.ExistsArg("u", "sysupgrade") || config.Runtime.Mode == parser.ModeAUR) {
  168. fmt.Println(gotext.Get(" there is nothing to do"))
  169. return nil
  170. }
  171. do.Print()
  172. fmt.Println()
  173. pkgbuildDirs := make(map[string]string, len(do.Aur))
  174. for _, base := range do.Aur {
  175. dir := filepath.Join(config.BuildDir, base.Pkgbase())
  176. pkgbuildDirs[base.Pkgbase()] = dir
  177. }
  178. if config.CleanAfter {
  179. defer func() {
  180. cleanAfter(ctx, config.Runtime.CmdBuilder, pkgbuildDirs)
  181. }()
  182. }
  183. if do.HasMake() {
  184. switch config.RemoveMake {
  185. case "yes":
  186. defer func() {
  187. err = removeMake(ctx, config.Runtime.CmdBuilder, do.GetMake(), cmdArgs)
  188. }()
  189. case "no":
  190. break
  191. default:
  192. if text.ContinueTask(os.Stdin, gotext.Get("Remove make dependencies after install?"), false, settings.NoConfirm) {
  193. defer func() {
  194. err = removeMake(ctx, config.Runtime.CmdBuilder, do.GetMake(), cmdArgs)
  195. }()
  196. }
  197. }
  198. }
  199. if errCleanMenu := menus.Clean(os.Stdout, config.CleanMenu,
  200. pkgbuildDirs,
  201. remoteNamesCache, settings.NoConfirm, config.AnswerClean); errCleanMenu != nil {
  202. if errors.As(errCleanMenu, &settings.ErrUserAbort{}) {
  203. return errCleanMenu
  204. }
  205. text.Errorln(errCleanMenu)
  206. }
  207. toSkip := pkgbuildsToSkip(do.Aur, targets)
  208. toClone := make([]string, 0, len(do.Aur))
  209. for _, base := range do.Aur {
  210. if !toSkip.Get(base.Pkgbase()) {
  211. toClone = append(toClone, base.Pkgbase())
  212. }
  213. }
  214. if toSkipSlice := toSkip.ToSlice(); len(toSkipSlice) != 0 {
  215. text.OperationInfoln(
  216. gotext.Get("PKGBUILD up to date, Skipping (%d/%d): %s",
  217. len(toSkipSlice), len(toClone), text.Cyan(strings.Join(toSkipSlice, ", "))))
  218. }
  219. cloned, errA := download.AURPKGBUILDRepos(ctx,
  220. config.Runtime.CmdBuilder, toClone, config.AURURL, config.BuildDir, false)
  221. if errA != nil {
  222. return errA
  223. }
  224. if errDiffMenu := menus.Diff(ctx, config.Runtime.CmdBuilder, os.Stdout, pkgbuildDirs,
  225. config.DiffMenu, remoteNamesCache,
  226. cloned, settings.NoConfirm, config.AnswerDiff); errDiffMenu != nil {
  227. if errors.As(errDiffMenu, &settings.ErrUserAbort{}) {
  228. return errDiffMenu
  229. }
  230. text.Errorln(errDiffMenu)
  231. }
  232. if errM := mergePkgbuilds(ctx, config.Runtime.CmdBuilder, pkgbuildDirs); errM != nil {
  233. return errM
  234. }
  235. srcinfos, err = srcinfo.ParseSrcinfoFilesByBase(pkgbuildDirs, true)
  236. if err != nil {
  237. return err
  238. }
  239. if errEditMenu := menus.Edit(os.Stdout, config.EditMenu, pkgbuildDirs,
  240. config.Editor, config.EditorFlags, remoteNamesCache, srcinfos,
  241. settings.NoConfirm, config.AnswerEdit); errEditMenu != nil {
  242. if errors.As(errEditMenu, &settings.ErrUserAbort{}) {
  243. return errEditMenu
  244. }
  245. text.Errorln(errEditMenu)
  246. }
  247. if errI := confirmIncompatibleInstall(srcinfos, dbExecutor); errI != nil {
  248. return errI
  249. }
  250. if config.PGPFetch {
  251. if _, errCPK := pgp.CheckPgpKeys(ctx, pkgbuildDirs, srcinfos, config.Runtime.CmdBuilder, settings.NoConfirm); errCPK != nil {
  252. return errCPK
  253. }
  254. }
  255. if !config.CombinedUpgrade {
  256. arguments.DelArg("u", "sysupgrade")
  257. }
  258. if len(arguments.Targets) > 0 || arguments.ExistsArg("u") {
  259. if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  260. arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
  261. return errors.New(gotext.Get("error installing repo packages"))
  262. }
  263. deps := make([]string, 0)
  264. exp := make([]string, 0)
  265. for _, pkg := range do.Repo {
  266. if !dp.Explicit.Get(pkg.Name()) && !localNamesCache.Get(pkg.Name()) && !remoteNamesCache.Contains(pkg.Name()) {
  267. deps = append(deps, pkg.Name())
  268. continue
  269. }
  270. if cmdArgs.ExistsArg("asdeps", "asdep") && dp.Explicit.Get(pkg.Name()) {
  271. deps = append(deps, pkg.Name())
  272. } else if cmdArgs.ExistsArg("asexp", "asexplicit") && dp.Explicit.Get(pkg.Name()) {
  273. exp = append(exp, pkg.Name())
  274. }
  275. }
  276. if errDeps := asdeps(ctx, config.Runtime.CmdBuilder, config.Runtime.Mode, cmdArgs, deps); errDeps != nil {
  277. return errDeps
  278. }
  279. if errExp := asexp(ctx, config.Runtime.CmdBuilder, config.Runtime.Mode, cmdArgs, exp); errExp != nil {
  280. return errExp
  281. }
  282. }
  283. go func() {
  284. _ = completion.Update(ctx, config.Runtime.HTTPClient, dbExecutor,
  285. config.AURURL, config.Runtime.CompletionPath, config.CompletionInterval, false)
  286. }()
  287. if errP := downloadPKGBUILDSourceFanout(ctx,
  288. config.Runtime.CmdBuilder,
  289. pkgbuildDirs,
  290. true, config.MaxConcurrentDownloads); errP != nil {
  291. text.Errorln(errP)
  292. }
  293. if errB := buildInstallPkgbuilds(ctx, cmdArgs, dbExecutor, dp, do, srcinfos, true, conflicts, noDeps, noCheck); errB != nil {
  294. return errB
  295. }
  296. return nil
  297. }
  298. func addUpgradeTargetsToArgs(ctx context.Context, dbExecutor db.Executor,
  299. cmdArgs *parser.Arguments, requestTargets []string, arguments *parser.Arguments,
  300. ) ([]string, error) {
  301. ignore, targets, errUp := sysupgradeTargets(ctx, dbExecutor, cmdArgs.ExistsDouble("u", "sysupgrade"))
  302. if errUp != nil {
  303. return nil, errUp
  304. }
  305. for _, up := range targets {
  306. cmdArgs.AddTarget(up)
  307. requestTargets = append(requestTargets, up)
  308. }
  309. if len(ignore) > 0 {
  310. arguments.CreateOrAppendOption("ignore", ignore.ToSlice()...)
  311. }
  312. return requestTargets, nil
  313. }
  314. func removeMake(ctx context.Context, cmdBuilder exe.ICmdBuilder, makeDeps []string, cmdArgs *parser.Arguments) error {
  315. removeArguments := cmdArgs.CopyGlobal()
  316. err := removeArguments.AddArg("R", "u")
  317. if err != nil {
  318. return err
  319. }
  320. for _, pkg := range makeDeps {
  321. removeArguments.AddTarget(pkg)
  322. }
  323. oldValue := settings.NoConfirm
  324. settings.NoConfirm = true
  325. err = cmdBuilder.Show(cmdBuilder.BuildPacmanCmd(ctx,
  326. removeArguments, config.Runtime.Mode, settings.NoConfirm))
  327. settings.NoConfirm = oldValue
  328. return err
  329. }
  330. func inRepos(dbExecutor db.Executor, pkg string) bool {
  331. target := dep.ToTarget(pkg)
  332. if target.DB == "aur" {
  333. return false
  334. } else if target.DB != "" {
  335. return true
  336. }
  337. previousHideMenus := settings.HideMenus
  338. settings.HideMenus = true
  339. exists := dbExecutor.SyncSatisfierExists(target.DepString())
  340. settings.HideMenus = previousHideMenus
  341. return exists || len(dbExecutor.PackagesFromGroup(target.Name)) > 0
  342. }
  343. func earlyPacmanCall(ctx context.Context, cmdArgs *parser.Arguments, dbExecutor db.Executor) error {
  344. arguments := cmdArgs.Copy()
  345. arguments.Op = "S"
  346. targets := cmdArgs.Targets
  347. cmdArgs.ClearTargets()
  348. arguments.ClearTargets()
  349. if config.Runtime.Mode == parser.ModeRepo {
  350. arguments.Targets = targets
  351. } else {
  352. // separate aur and repo targets
  353. for _, target := range targets {
  354. if inRepos(dbExecutor, target) {
  355. arguments.AddTarget(target)
  356. } else {
  357. cmdArgs.AddTarget(target)
  358. }
  359. }
  360. }
  361. if cmdArgs.ExistsArg("y", "refresh") || cmdArgs.ExistsArg("u", "sysupgrade") || len(arguments.Targets) > 0 {
  362. if err := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  363. arguments, config.Runtime.Mode, settings.NoConfirm)); err != nil {
  364. return errors.New(gotext.Get("error installing repo packages"))
  365. }
  366. }
  367. return nil
  368. }
  369. func earlyRefresh(ctx context.Context, cfg *settings.Configuration, cmdBuilder exe.ICmdBuilder, cmdArgs *parser.Arguments) error {
  370. arguments := cmdArgs.Copy()
  371. arguments.DelArg("u", "sysupgrade")
  372. arguments.DelArg("s", "search")
  373. arguments.DelArg("i", "info")
  374. arguments.DelArg("l", "list")
  375. arguments.ClearTargets()
  376. return cmdBuilder.Show(cmdBuilder.BuildPacmanCmd(ctx,
  377. arguments, cfg.Runtime.Mode, settings.NoConfirm))
  378. }
  379. func confirmIncompatibleInstall(srcinfos map[string]*gosrc.Srcinfo, dbExecutor db.Executor) error {
  380. incompatible := []string{}
  381. alpmArch, err := dbExecutor.AlpmArchitectures()
  382. if err != nil {
  383. return err
  384. }
  385. nextpkg:
  386. for base, srcinfo := range srcinfos {
  387. for _, arch := range srcinfo.Arch {
  388. if db.ArchIsSupported(alpmArch, arch) {
  389. continue nextpkg
  390. }
  391. }
  392. incompatible = append(incompatible, base)
  393. }
  394. if len(incompatible) > 0 {
  395. text.Warnln(gotext.Get("The following packages are not compatible with your architecture:"))
  396. for _, pkg := range incompatible {
  397. fmt.Print(" " + text.Cyan(pkg))
  398. }
  399. fmt.Println()
  400. if !text.ContinueTask(os.Stdin, gotext.Get("Try to build them anyway?"), true, settings.NoConfirm) {
  401. return &settings.ErrUserAbort{}
  402. }
  403. }
  404. return nil
  405. }
  406. func parsePackageList(ctx context.Context, cmdBuilder exe.ICmdBuilder,
  407. dir string,
  408. ) (pkgdests map[string]string, pkgVersion string, err error) {
  409. stdout, stderr, err := cmdBuilder.Capture(
  410. cmdBuilder.BuildMakepkgCmd(ctx, dir, "--packagelist"))
  411. if err != nil {
  412. return nil, "", fmt.Errorf("%s %w", stderr, err)
  413. }
  414. lines := strings.Split(stdout, "\n")
  415. pkgdests = make(map[string]string)
  416. for _, line := range lines {
  417. if line == "" {
  418. continue
  419. }
  420. fileName := filepath.Base(line)
  421. split := strings.Split(fileName, "-")
  422. if len(split) < 4 {
  423. return nil, "", errors.New(gotext.Get("cannot find package name: %v", split))
  424. }
  425. // pkgname-pkgver-pkgrel-arch.pkgext
  426. // This assumes 3 dashes after the pkgname, Will cause an error
  427. // if the PKGEXT contains a dash. Please no one do that.
  428. pkgName := strings.Join(split[:len(split)-3], "-")
  429. pkgVersion = strings.Join(split[len(split)-3:len(split)-1], "-")
  430. pkgdests[pkgName] = line
  431. }
  432. if len(pkgdests) == 0 {
  433. return nil, "", &NoPkgDestsFoundError{dir}
  434. }
  435. return pkgdests, pkgVersion, nil
  436. }
  437. func pkgbuildsToSkip(bases []dep.Base, targets stringset.StringSet) stringset.StringSet {
  438. toSkip := make(stringset.StringSet)
  439. for _, base := range bases {
  440. isTarget := false
  441. for _, pkg := range base {
  442. isTarget = isTarget || targets.Get(pkg.Name)
  443. }
  444. if (config.ReDownload == "yes" && isTarget) || config.ReDownload == "all" {
  445. continue
  446. }
  447. dir := filepath.Join(config.BuildDir, base.Pkgbase(), ".SRCINFO")
  448. pkgbuild, err := gosrc.ParseFile(dir)
  449. if err == nil {
  450. if db.VerCmp(pkgbuild.Version(), base.Version()) >= 0 {
  451. toSkip.Set(base.Pkgbase())
  452. }
  453. }
  454. }
  455. return toSkip
  456. }
  457. func gitMerge(ctx context.Context, cmdBuilder exe.ICmdBuilder, dir string) error {
  458. _, stderr, err := cmdBuilder.Capture(
  459. cmdBuilder.BuildGitCmd(ctx,
  460. dir, "reset", "--hard", "HEAD"))
  461. if err != nil {
  462. return errors.New(gotext.Get("error resetting %s: %s", dir, stderr))
  463. }
  464. _, stderr, err = cmdBuilder.Capture(
  465. cmdBuilder.BuildGitCmd(ctx,
  466. dir, "merge", "--no-edit", "--ff"))
  467. if err != nil {
  468. return errors.New(gotext.Get("error merging %s: %s", dir, stderr))
  469. }
  470. return nil
  471. }
  472. func mergePkgbuilds(ctx context.Context, cmdBuilder exe.ICmdBuilder, pkgbuildDirs map[string]string) error {
  473. for _, dir := range pkgbuildDirs {
  474. err := gitMerge(ctx, cmdBuilder, dir)
  475. if err != nil {
  476. return err
  477. }
  478. }
  479. return nil
  480. }
  481. func buildInstallPkgbuilds(
  482. ctx context.Context,
  483. cmdArgs *parser.Arguments,
  484. dbExecutor db.Executor,
  485. dp *dep.Pool,
  486. do *dep.Order,
  487. srcinfos map[string]*gosrc.Srcinfo,
  488. incompatible bool,
  489. conflicts stringset.MapStringSet, noDeps, noCheck bool,
  490. ) error {
  491. deps := make([]string, 0)
  492. exp := make([]string, 0)
  493. pkgArchives := make([]string, 0)
  494. oldConfirm := settings.NoConfirm
  495. settings.NoConfirm = true
  496. // remotenames: names of all non repo packages on the system
  497. remoteNames := dbExecutor.InstalledRemotePackageNames()
  498. localNames := dbExecutor.InstalledSyncPackageNames()
  499. // cache as a stringset. maybe make it return a string set in the first
  500. // place
  501. remoteNamesCache := stringset.FromSlice(remoteNames)
  502. localNamesCache := stringset.FromSlice(localNames)
  503. for i, base := range do.Aur {
  504. pkg := base.Pkgbase()
  505. dir := filepath.Join(config.BuildDir, pkg)
  506. built := true
  507. satisfied := true
  508. all:
  509. for _, pkg := range base {
  510. for _, dep := range dep.ComputeCombinedDepList(pkg, noDeps, noCheck) {
  511. if !dp.AlpmExecutor.LocalSatisfierExists(dep) {
  512. satisfied = false
  513. text.Warnln(gotext.Get("%s not satisfied, flushing install queue", dep))
  514. break all
  515. }
  516. }
  517. }
  518. if !satisfied || !config.BatchInstall {
  519. text.Debugln("non batch installing archives:", pkgArchives)
  520. errArchive := installPkgArchive(ctx, config.Runtime.CmdBuilder,
  521. config.Runtime.Mode, config.Runtime.VCSStore, cmdArgs, pkgArchives)
  522. errReason := setInstallReason(ctx, config.Runtime.CmdBuilder, config.Runtime.Mode, cmdArgs, deps, exp)
  523. deps = make([]string, 0)
  524. exp = make([]string, 0)
  525. pkgArchives = make([]string, 0) // reset the pkgarchives
  526. if errArchive != nil || errReason != nil {
  527. if i != 0 {
  528. go config.Runtime.VCSStore.RemovePackages([]string{do.Aur[i-1].String()})
  529. }
  530. if errArchive != nil {
  531. return errArchive
  532. }
  533. return errReason
  534. }
  535. }
  536. srcInfo := srcinfos[pkg]
  537. args := []string{"--nobuild", "-fC"}
  538. if incompatible {
  539. args = append(args, "--ignorearch")
  540. }
  541. // pkgver bump
  542. if err := config.Runtime.CmdBuilder.Show(
  543. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, args...)); err != nil {
  544. return errors.New(gotext.Get("error making: %s", base.String()))
  545. }
  546. pkgdests, pkgVersion, errList := parsePackageList(ctx, config.Runtime.CmdBuilder, dir)
  547. if errList != nil {
  548. return errList
  549. }
  550. isExplicit := false
  551. for _, b := range base {
  552. isExplicit = isExplicit || dp.Explicit.Get(b.Name)
  553. }
  554. if config.ReBuild == "no" || (config.ReBuild == "yes" && !isExplicit) {
  555. for _, split := range base {
  556. pkgdest, ok := pkgdests[split.Name]
  557. if !ok {
  558. return &PkgDestNotInListError{split.Name}
  559. }
  560. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  561. built = false
  562. } else if errStat != nil {
  563. return errStat
  564. }
  565. }
  566. } else {
  567. built = false
  568. }
  569. if cmdArgs.ExistsArg("needed") {
  570. installed := true
  571. for _, split := range base {
  572. installed = dp.AlpmExecutor.IsCorrectVersionInstalled(split.Name, pkgVersion)
  573. }
  574. if installed {
  575. err := config.Runtime.CmdBuilder.Show(
  576. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  577. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  578. if err != nil {
  579. return errors.New(gotext.Get("error making: %s", err))
  580. }
  581. fmt.Fprintln(os.Stdout, gotext.Get("%s is up to date -- skipping", text.Cyan(pkg+"-"+pkgVersion)))
  582. continue
  583. }
  584. }
  585. if built {
  586. err := config.Runtime.CmdBuilder.Show(
  587. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  588. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  589. if err != nil {
  590. return errors.New(gotext.Get("error making: %s", err))
  591. }
  592. text.Warnln(gotext.Get("%s already made -- skipping build", text.Cyan(pkg+"-"+pkgVersion)))
  593. } else {
  594. args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
  595. if incompatible {
  596. args = append(args, "--ignorearch")
  597. }
  598. if errMake := config.Runtime.CmdBuilder.Show(
  599. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  600. dir, args...)); errMake != nil {
  601. return errors.New(gotext.Get("error making: %s", base.String()))
  602. }
  603. }
  604. // conflicts have been checked so answer y for them
  605. if config.UseAsk && cmdArgs.ExistsArg("ask") {
  606. ask, _ := strconv.Atoi(cmdArgs.Options["ask"].First())
  607. uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
  608. cmdArgs.Options["ask"].Set(fmt.Sprint(uask))
  609. } else {
  610. for _, split := range base {
  611. if _, ok := conflicts[split.Name]; ok {
  612. settings.NoConfirm = false
  613. break
  614. }
  615. }
  616. }
  617. var errAdd error
  618. for _, split := range base {
  619. for suffix, optional := range map[string]bool{"": false, "-debug": true} {
  620. deps, exp, pkgArchives, errAdd = doAddTarget(dp, localNamesCache, remoteNamesCache,
  621. cmdArgs, pkgdests, deps, exp, split.Name+suffix, optional, pkgArchives)
  622. if errAdd != nil {
  623. return errAdd
  624. }
  625. }
  626. }
  627. text.Debugln("deps:", deps, "exp:", exp, "pkgArchives:", pkgArchives)
  628. var wg sync.WaitGroup
  629. for _, pkg := range base {
  630. if srcInfo == nil {
  631. text.Errorln(gotext.Get("could not find srcinfo for: %s", pkg.Name))
  632. break
  633. }
  634. wg.Add(1)
  635. text.Debugln("checking vcs store for:", pkg.Name)
  636. go func(name string) {
  637. config.Runtime.VCSStore.Update(ctx, name, srcInfo.Source)
  638. wg.Done()
  639. }(pkg.Name)
  640. }
  641. wg.Wait()
  642. }
  643. text.Debugln("installing archives:", pkgArchives)
  644. errArchive := installPkgArchive(ctx, config.Runtime.CmdBuilder, config.Runtime.Mode, config.Runtime.VCSStore, cmdArgs, pkgArchives)
  645. if errArchive != nil {
  646. go config.Runtime.VCSStore.RemovePackages([]string{do.Aur[len(do.Aur)-1].String()})
  647. }
  648. errReason := setInstallReason(ctx, config.Runtime.CmdBuilder, config.Runtime.Mode, cmdArgs, deps, exp)
  649. if errReason != nil {
  650. go config.Runtime.VCSStore.RemovePackages([]string{do.Aur[len(do.Aur)-1].String()})
  651. }
  652. settings.NoConfirm = oldConfirm
  653. return nil
  654. }
  655. func installPkgArchive(ctx context.Context,
  656. cmdBuilder exe.ICmdBuilder,
  657. mode parser.TargetMode,
  658. vcsStore vcs.Store,
  659. cmdArgs *parser.Arguments,
  660. pkgArchives []string,
  661. ) error {
  662. if len(pkgArchives) == 0 {
  663. return nil
  664. }
  665. arguments := cmdArgs.Copy()
  666. arguments.ClearTargets()
  667. arguments.Op = "U"
  668. arguments.DelArg("confirm")
  669. arguments.DelArg("noconfirm")
  670. arguments.DelArg("c", "clean")
  671. arguments.DelArg("i", "install")
  672. arguments.DelArg("q", "quiet")
  673. arguments.DelArg("y", "refresh")
  674. arguments.DelArg("u", "sysupgrade")
  675. arguments.DelArg("w", "downloadonly")
  676. arguments.DelArg("asdeps", "asdep")
  677. arguments.DelArg("asexplicit", "asexp")
  678. arguments.AddTarget(pkgArchives...)
  679. if errShow := cmdBuilder.Show(cmdBuilder.BuildPacmanCmd(ctx,
  680. arguments, mode, settings.NoConfirm)); errShow != nil {
  681. return errShow
  682. }
  683. if errStore := vcsStore.Save(); errStore != nil {
  684. fmt.Fprintln(os.Stderr, errStore)
  685. }
  686. return nil
  687. }
  688. func setInstallReason(ctx context.Context,
  689. cmdBuilder exe.ICmdBuilder, mode parser.TargetMode,
  690. cmdArgs *parser.Arguments, deps, exps []string,
  691. ) error {
  692. if len(deps)+len(exps) == 0 {
  693. return nil
  694. }
  695. if errDeps := asdeps(ctx, cmdBuilder, mode, cmdArgs, deps); errDeps != nil {
  696. return errDeps
  697. }
  698. return asexp(ctx, cmdBuilder, mode, cmdArgs, exps)
  699. }
  700. func doAddTarget(dp *dep.Pool, localNamesCache, remoteNamesCache stringset.StringSet,
  701. cmdArgs *parser.Arguments, pkgdests map[string]string,
  702. deps, exp []string, name string, optional bool, pkgArchives []string,
  703. ) (newDeps, newExp, newPkgArchives []string, err error) {
  704. pkgdest, ok := pkgdests[name]
  705. if !ok {
  706. if optional {
  707. return deps, exp, pkgArchives, nil
  708. }
  709. return deps, exp, pkgArchives, &PkgDestNotInListError{name}
  710. }
  711. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  712. if optional {
  713. return deps, exp, pkgArchives, nil
  714. }
  715. return deps, exp, pkgArchives, &FindPkgDestError{pkgDest: pkgdest, name: name}
  716. }
  717. pkgArchives = append(pkgArchives, pkgdest)
  718. switch {
  719. case cmdArgs.ExistsArg("asdeps", "asdep"):
  720. deps = append(deps, name)
  721. case cmdArgs.ExistsArg("asexplicit", "asexp"):
  722. exp = append(exp, name)
  723. case !dp.Explicit.Get(name) && !localNamesCache.Get(name) && !remoteNamesCache.Get(name):
  724. deps = append(deps, name)
  725. default:
  726. exp = append(exp, name)
  727. }
  728. return deps, exp, pkgArchives, nil
  729. }