install.go 24 KB

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