install.go 22 KB

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