install.go 24 KB

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