install.go 23 KB

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