install.go 24 KB

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