install.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125
  1. package main
  2. import (
  3. "context"
  4. "errors"
  5. "fmt"
  6. "os"
  7. "os/exec"
  8. "path/filepath"
  9. "strconv"
  10. "strings"
  11. "sync"
  12. alpm "github.com/Jguer/go-alpm/v2"
  13. gosrc "github.com/Morganamilo/go-srcinfo"
  14. "github.com/leonelquinteros/gotext"
  15. "github.com/Jguer/yay/v10/pkg/completion"
  16. "github.com/Jguer/yay/v10/pkg/db"
  17. "github.com/Jguer/yay/v10/pkg/dep"
  18. "github.com/Jguer/yay/v10/pkg/download"
  19. "github.com/Jguer/yay/v10/pkg/intrange"
  20. "github.com/Jguer/yay/v10/pkg/multierror"
  21. "github.com/Jguer/yay/v10/pkg/pgp"
  22. "github.com/Jguer/yay/v10/pkg/query"
  23. "github.com/Jguer/yay/v10/pkg/settings"
  24. "github.com/Jguer/yay/v10/pkg/settings/parser"
  25. "github.com/Jguer/yay/v10/pkg/stringset"
  26. "github.com/Jguer/yay/v10/pkg/text"
  27. )
  28. const gitEmptyTree = "4b825dc642cb6eb9a060e54bf8d69288fbee4904"
  29. func asdeps(ctx context.Context, cmdArgs *parser.Arguments, pkgs []string) (err error) {
  30. if len(pkgs) == 0 {
  31. return nil
  32. }
  33. cmdArgs = cmdArgs.CopyGlobal()
  34. _ = cmdArgs.AddArg("q", "D", "asdeps")
  35. cmdArgs.AddTarget(pkgs...)
  36. err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  37. cmdArgs, config.Runtime.Mode, settings.NoConfirm))
  38. if err != nil {
  39. return fmt.Errorf(gotext.Get("error updating package install reason to dependency"))
  40. }
  41. return nil
  42. }
  43. func asexp(ctx context.Context, cmdArgs *parser.Arguments, pkgs []string) (err error) {
  44. if len(pkgs) == 0 {
  45. return nil
  46. }
  47. cmdArgs = cmdArgs.CopyGlobal()
  48. _ = cmdArgs.AddArg("q", "D", "asexplicit")
  49. cmdArgs.AddTarget(pkgs...)
  50. err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  51. cmdArgs, config.Runtime.Mode, settings.NoConfirm))
  52. if err != nil {
  53. return fmt.Errorf(gotext.Get("error updating package install reason to explicit"))
  54. }
  55. return nil
  56. }
  57. // Install handles package installs.
  58. func install(ctx context.Context, cmdArgs *parser.Arguments, dbExecutor db.Executor, ignoreProviders bool) error {
  59. var (
  60. incompatible stringset.StringSet
  61. do *dep.Order
  62. srcinfos map[string]*gosrc.Srcinfo
  63. noDeps = cmdArgs.ExistsDouble("d", "nodeps")
  64. noCheck = strings.Contains(config.MFlags, "--nocheck")
  65. assumeInstalled = cmdArgs.GetArgs("assume-installed")
  66. sysupgradeArg = cmdArgs.ExistsArg("u", "sysupgrade")
  67. refreshArg = cmdArgs.ExistsArg("y", "refresh")
  68. warnings = query.NewWarnings()
  69. )
  70. if noDeps {
  71. config.Runtime.CmdBuilder.AddMakepkgFlag("-d")
  72. }
  73. if config.Runtime.Mode.AtLeastRepo() {
  74. if config.CombinedUpgrade {
  75. if refreshArg {
  76. if errR := earlyRefresh(ctx, cmdArgs); errR != nil {
  77. return fmt.Errorf(gotext.Get("error refreshing databases"))
  78. }
  79. }
  80. } else if refreshArg || sysupgradeArg || len(cmdArgs.Targets) > 0 {
  81. if errP := earlyPacmanCall(ctx, cmdArgs, dbExecutor); errP != nil {
  82. return errP
  83. }
  84. }
  85. }
  86. // we may have done -Sy, our handle now has an old
  87. // database.
  88. if errRefresh := dbExecutor.RefreshHandle(); errRefresh != nil {
  89. return errRefresh
  90. }
  91. localNames, remoteNames, err := query.GetPackageNamesBySource(dbExecutor)
  92. if err != nil {
  93. return err
  94. }
  95. remoteNamesCache := stringset.FromSlice(remoteNames)
  96. localNamesCache := stringset.FromSlice(localNames)
  97. requestTargets := cmdArgs.Copy().Targets
  98. // create the arguments to pass for the repo install
  99. arguments := cmdArgs.Copy()
  100. arguments.DelArg("asdeps", "asdep")
  101. arguments.DelArg("asexplicit", "asexp")
  102. arguments.Op = "S"
  103. arguments.ClearTargets()
  104. if config.Runtime.Mode == parser.ModeAUR {
  105. arguments.DelArg("u", "sysupgrade")
  106. }
  107. // if we are doing -u also request all packages needing update
  108. if sysupgradeArg {
  109. ignore, targets, errUp := sysupgradeTargets(ctx, dbExecutor, cmdArgs.ExistsDouble("u", "sysupgrade"))
  110. if errUp != nil {
  111. return errUp
  112. }
  113. for _, up := range targets {
  114. cmdArgs.AddTarget(up)
  115. requestTargets = append(requestTargets, up)
  116. }
  117. if len(ignore) > 0 {
  118. arguments.CreateOrAppendOption("ignore", ignore.ToSlice()...)
  119. }
  120. }
  121. targets := stringset.FromSlice(cmdArgs.Targets)
  122. dp, err := dep.GetPool(ctx, requestTargets,
  123. warnings, dbExecutor, config.Runtime.AURClient, config.Runtime.Mode,
  124. ignoreProviders, settings.NoConfirm, config.Provides, config.ReBuild, config.RequestSplitN, noDeps, noCheck, assumeInstalled)
  125. if err != nil {
  126. return err
  127. }
  128. if errC := dp.CheckMissing(noDeps, noCheck); errC != nil {
  129. return errC
  130. }
  131. if len(dp.Aur) == 0 {
  132. if !config.CombinedUpgrade {
  133. if sysupgradeArg {
  134. fmt.Println(gotext.Get(" there is nothing to do"))
  135. }
  136. return nil
  137. }
  138. cmdArgs.Op = "S"
  139. cmdArgs.DelArg("y", "refresh")
  140. if arguments.ExistsArg("ignore") {
  141. cmdArgs.CreateOrAppendOption("ignore", arguments.GetArgs("ignore")...)
  142. }
  143. return config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  144. cmdArgs, config.Runtime.Mode, settings.NoConfirm))
  145. }
  146. if len(dp.Aur) > 0 && os.Geteuid() == 0 {
  147. return fmt.Errorf(gotext.Get("refusing to install AUR packages as root, aborting"))
  148. }
  149. conflicts, errCC := dp.CheckConflicts(config.UseAsk, settings.NoConfirm, noDeps)
  150. if errCC != nil {
  151. return errCC
  152. }
  153. do = dep.GetOrder(dp, noDeps, noCheck)
  154. for _, pkg := range do.Repo {
  155. arguments.AddTarget(pkg.DB().Name() + "/" + pkg.Name())
  156. }
  157. for _, pkg := range dp.Groups {
  158. arguments.AddTarget(pkg)
  159. }
  160. if len(do.Aur) == 0 && len(arguments.Targets) == 0 &&
  161. (!cmdArgs.ExistsArg("u", "sysupgrade") || config.Runtime.Mode == parser.ModeAUR) {
  162. fmt.Println(gotext.Get(" there is nothing to do"))
  163. return nil
  164. }
  165. do.Print()
  166. fmt.Println()
  167. if config.CleanAfter {
  168. defer cleanAfter(ctx, do.Aur)
  169. }
  170. if do.HasMake() {
  171. switch config.RemoveMake {
  172. case "yes":
  173. defer func() {
  174. err = removeMake(ctx, do)
  175. }()
  176. case "no":
  177. break
  178. default:
  179. if text.ContinueTask(gotext.Get("Remove make dependencies after install?"), false, settings.NoConfirm) {
  180. defer func() {
  181. err = removeMake(ctx, do)
  182. }()
  183. }
  184. }
  185. }
  186. if config.CleanMenu {
  187. if anyExistInCache(do.Aur) {
  188. askClean := pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  189. toClean, errClean := cleanNumberMenu(do.Aur, remoteNamesCache, askClean)
  190. if errClean != nil {
  191. return errClean
  192. }
  193. cleanBuilds(toClean)
  194. }
  195. }
  196. toSkip := pkgbuildsToSkip(do.Aur, targets)
  197. toClone := make([]string, 0, len(do.Aur))
  198. for _, base := range do.Aur {
  199. if !toSkip.Get(base.Pkgbase()) {
  200. toClone = append(toClone, base.Pkgbase())
  201. }
  202. }
  203. toSkipSlice := toSkip.ToSlice()
  204. if 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. var toDiff, toEdit []dep.Base
  215. if config.DiffMenu {
  216. pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  217. toDiff, err = diffNumberMenu(do.Aur, remoteNamesCache)
  218. if err != nil {
  219. return err
  220. }
  221. if len(toDiff) > 0 {
  222. err = showPkgbuildDiffs(ctx, toDiff, cloned)
  223. if err != nil {
  224. return err
  225. }
  226. }
  227. }
  228. if len(toDiff) > 0 {
  229. oldValue := settings.NoConfirm
  230. settings.NoConfirm = false
  231. fmt.Println()
  232. if !text.ContinueTask(gotext.Get("Proceed with install?"), true, settings.NoConfirm) {
  233. return fmt.Errorf(gotext.Get("aborting due to user"))
  234. }
  235. err = updatePkgbuildSeenRef(ctx, toDiff)
  236. if err != nil {
  237. text.Errorln(err.Error())
  238. }
  239. settings.NoConfirm = oldValue
  240. }
  241. if errM := mergePkgbuilds(ctx, do.Aur); errM != nil {
  242. return errM
  243. }
  244. srcinfos, err = parseSrcinfoFiles(do.Aur, true)
  245. if err != nil {
  246. return err
  247. }
  248. if config.EditMenu {
  249. pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  250. toEdit, err = editNumberMenu(do.Aur, remoteNamesCache)
  251. if err != nil {
  252. return err
  253. }
  254. if len(toEdit) > 0 {
  255. err = editPkgbuilds(toEdit, srcinfos)
  256. if err != nil {
  257. return err
  258. }
  259. }
  260. }
  261. if len(toEdit) > 0 {
  262. oldValue := settings.NoConfirm
  263. settings.NoConfirm = false
  264. fmt.Println()
  265. if !text.ContinueTask(gotext.Get("Proceed with install?"), true, settings.NoConfirm) {
  266. return errors.New(gotext.Get("aborting due to user"))
  267. }
  268. settings.NoConfirm = oldValue
  269. }
  270. incompatible, err = getIncompatible(do.Aur, srcinfos, dbExecutor)
  271. if err != nil {
  272. return err
  273. }
  274. if config.PGPFetch {
  275. if errCPK := pgp.CheckPgpKeys(do.Aur, srcinfos, config.GpgBin, config.GpgFlags, settings.NoConfirm); errCPK != nil {
  276. return errCPK
  277. }
  278. }
  279. if !config.CombinedUpgrade {
  280. arguments.DelArg("u", "sysupgrade")
  281. }
  282. if len(arguments.Targets) > 0 || arguments.ExistsArg("u") {
  283. if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  284. arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
  285. return errors.New(gotext.Get("error installing repo packages"))
  286. }
  287. deps := make([]string, 0)
  288. exp := make([]string, 0)
  289. for _, pkg := range do.Repo {
  290. if !dp.Explicit.Get(pkg.Name()) && !localNamesCache.Get(pkg.Name()) && !remoteNamesCache.Get(pkg.Name()) {
  291. deps = append(deps, pkg.Name())
  292. continue
  293. }
  294. if cmdArgs.ExistsArg("asdeps", "asdep") && dp.Explicit.Get(pkg.Name()) {
  295. deps = append(deps, pkg.Name())
  296. } else if cmdArgs.ExistsArg("asexp", "asexplicit") && dp.Explicit.Get(pkg.Name()) {
  297. exp = append(exp, pkg.Name())
  298. }
  299. }
  300. if errDeps := asdeps(ctx, cmdArgs, deps); errDeps != nil {
  301. return errDeps
  302. }
  303. if errExp := asexp(ctx, cmdArgs, exp); errExp != nil {
  304. return errExp
  305. }
  306. }
  307. go func() {
  308. _ = completion.Update(ctx, config.Runtime.HTTPClient, dbExecutor,
  309. config.AURURL, config.Runtime.CompletionPath, config.CompletionInterval, false)
  310. }()
  311. if errP := downloadPKGBUILDSourceFanout(ctx, config.Runtime.CmdBuilder, config.BuildDir, do.Aur, incompatible); errP != nil {
  312. text.Errorln(errP)
  313. }
  314. if errB := buildInstallPkgbuilds(ctx, cmdArgs, dbExecutor, dp, do, srcinfos, incompatible, conflicts, noDeps, noCheck); errB != nil {
  315. return errB
  316. }
  317. return nil
  318. }
  319. func removeMake(ctx context.Context, do *dep.Order) error {
  320. removeArguments := parser.MakeArguments()
  321. err := removeArguments.AddArg("R", "u")
  322. if err != nil {
  323. return err
  324. }
  325. for _, pkg := range do.GetMake() {
  326. removeArguments.AddTarget(pkg)
  327. }
  328. oldValue := settings.NoConfirm
  329. settings.NoConfirm = true
  330. err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  331. removeArguments, config.Runtime.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, cmdArgs *parser.Arguments, dbExecutor db.Executor) error {
  349. arguments := cmdArgs.Copy()
  350. arguments.Op = "S"
  351. targets := cmdArgs.Targets
  352. cmdArgs.ClearTargets()
  353. arguments.ClearTargets()
  354. if config.Runtime.Mode == parser.ModeRepo {
  355. arguments.Targets = targets
  356. } else {
  357. // separate aur and repo targets
  358. for _, target := range targets {
  359. if inRepos(dbExecutor, target) {
  360. arguments.AddTarget(target)
  361. } else {
  362. cmdArgs.AddTarget(target)
  363. }
  364. }
  365. }
  366. if cmdArgs.ExistsArg("y", "refresh") || cmdArgs.ExistsArg("u", "sysupgrade") || len(arguments.Targets) > 0 {
  367. if err := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  368. arguments, config.Runtime.Mode, settings.NoConfirm)); err != nil {
  369. return errors.New(gotext.Get("error installing repo packages"))
  370. }
  371. }
  372. return nil
  373. }
  374. func earlyRefresh(ctx context.Context, cmdArgs *parser.Arguments) error {
  375. arguments := cmdArgs.Copy()
  376. cmdArgs.DelArg("y", "refresh")
  377. arguments.DelArg("u", "sysupgrade")
  378. arguments.DelArg("s", "search")
  379. arguments.DelArg("i", "info")
  380. arguments.DelArg("l", "list")
  381. arguments.ClearTargets()
  382. return config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  383. arguments, config.Runtime.Mode, settings.NoConfirm))
  384. }
  385. func alpmArchIsSupported(alpmArch []string, arch string) bool {
  386. if arch == "any" {
  387. return true
  388. }
  389. for _, a := range alpmArch {
  390. if a == arch {
  391. return true
  392. }
  393. }
  394. return false
  395. }
  396. func getIncompatible(bases []dep.Base, srcinfos map[string]*gosrc.Srcinfo, dbExecutor db.Executor) (stringset.StringSet, error) {
  397. incompatible := make(stringset.StringSet)
  398. basesMap := make(map[string]dep.Base)
  399. alpmArch, err := dbExecutor.AlpmArchitectures()
  400. if err != nil {
  401. return nil, err
  402. }
  403. nextpkg:
  404. for _, base := range bases {
  405. for _, arch := range srcinfos[base.Pkgbase()].Arch {
  406. if alpmArchIsSupported(alpmArch, arch) {
  407. continue nextpkg
  408. }
  409. }
  410. incompatible.Set(base.Pkgbase())
  411. basesMap[base.Pkgbase()] = base
  412. }
  413. if len(incompatible) > 0 {
  414. text.Warnln(gotext.Get("The following packages are not compatible with your architecture:"))
  415. for pkg := range incompatible {
  416. fmt.Print(" " + text.Cyan(basesMap[pkg].String()))
  417. }
  418. fmt.Println()
  419. if !text.ContinueTask(gotext.Get("Try to build them anyway?"), true, settings.NoConfirm) {
  420. return nil, errors.New(gotext.Get("aborting due to user"))
  421. }
  422. }
  423. return incompatible, nil
  424. }
  425. func parsePackageList(ctx context.Context, dir string) (pkgdests map[string]string, pkgVersion string, err error) {
  426. stdout, stderr, err := config.Runtime.CmdBuilder.Capture(
  427. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, "--packagelist"))
  428. if err != nil {
  429. return nil, "", fmt.Errorf("%s %s", stderr, err)
  430. }
  431. lines := strings.Split(stdout, "\n")
  432. pkgdests = make(map[string]string)
  433. for _, line := range lines {
  434. if line == "" {
  435. continue
  436. }
  437. fileName := filepath.Base(line)
  438. split := strings.Split(fileName, "-")
  439. if len(split) < 4 {
  440. return nil, "", errors.New(gotext.Get("cannot find package name: %v", split))
  441. }
  442. // pkgname-pkgver-pkgrel-arch.pkgext
  443. // This assumes 3 dashes after the pkgname, Will cause an error
  444. // if the PKGEXT contains a dash. Please no one do that.
  445. pkgName := strings.Join(split[:len(split)-3], "-")
  446. pkgVersion = strings.Join(split[len(split)-3:len(split)-1], "-")
  447. pkgdests[pkgName] = line
  448. }
  449. return pkgdests, pkgVersion, nil
  450. }
  451. func anyExistInCache(bases []dep.Base) bool {
  452. for _, base := range bases {
  453. pkg := base.Pkgbase()
  454. dir := filepath.Join(config.BuildDir, pkg)
  455. if _, err := os.Stat(dir); !os.IsNotExist(err) {
  456. return true
  457. }
  458. }
  459. return false
  460. }
  461. func pkgbuildNumberMenu(bases []dep.Base, installed stringset.StringSet) bool {
  462. toPrint := ""
  463. askClean := false
  464. for n, base := range bases {
  465. pkg := base.Pkgbase()
  466. dir := filepath.Join(config.BuildDir, pkg)
  467. toPrint += fmt.Sprintf(text.Magenta("%3d")+" %-40s", len(bases)-n,
  468. text.Bold(base.String()))
  469. anyInstalled := false
  470. for _, b := range base {
  471. anyInstalled = anyInstalled || installed.Get(b.Name)
  472. }
  473. if anyInstalled {
  474. toPrint += text.Bold(text.Green(gotext.Get(" (Installed)")))
  475. }
  476. if _, err := os.Stat(dir); !os.IsNotExist(err) {
  477. toPrint += text.Bold(text.Green(gotext.Get(" (Build Files Exist)")))
  478. askClean = true
  479. }
  480. toPrint += "\n"
  481. }
  482. fmt.Print(toPrint)
  483. return askClean
  484. }
  485. func cleanNumberMenu(bases []dep.Base, installed stringset.StringSet, hasClean bool) ([]dep.Base, error) {
  486. toClean := make([]dep.Base, 0)
  487. if !hasClean {
  488. return toClean, nil
  489. }
  490. text.Infoln(gotext.Get("Packages to cleanBuild?"))
  491. text.Infoln(gotext.Get("%s [A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)", text.Cyan(gotext.Get("[N]one"))))
  492. cleanInput, err := getInput(config.AnswerClean)
  493. if err != nil {
  494. return nil, err
  495. }
  496. cInclude, cExclude, cOtherInclude, cOtherExclude := intrange.ParseNumberMenu(cleanInput)
  497. cIsInclude := len(cExclude) == 0 && len(cOtherExclude) == 0
  498. if cOtherInclude.Get("abort") || cOtherInclude.Get("ab") {
  499. return nil, fmt.Errorf(gotext.Get("aborting due to user"))
  500. }
  501. if !cOtherInclude.Get("n") && !cOtherInclude.Get("none") {
  502. for i, base := range bases {
  503. pkg := base.Pkgbase()
  504. anyInstalled := false
  505. for _, b := range base {
  506. anyInstalled = anyInstalled || installed.Get(b.Name)
  507. }
  508. dir := filepath.Join(config.BuildDir, pkg)
  509. if _, err := os.Stat(dir); os.IsNotExist(err) {
  510. continue
  511. }
  512. if !cIsInclude && cExclude.Get(len(bases)-i) {
  513. continue
  514. }
  515. if anyInstalled && (cOtherInclude.Get("i") || cOtherInclude.Get("installed")) {
  516. toClean = append(toClean, base)
  517. continue
  518. }
  519. if !anyInstalled && (cOtherInclude.Get("no") || cOtherInclude.Get("notinstalled")) {
  520. toClean = append(toClean, base)
  521. continue
  522. }
  523. if cOtherInclude.Get("a") || cOtherInclude.Get("all") {
  524. toClean = append(toClean, base)
  525. continue
  526. }
  527. if cIsInclude && (cInclude.Get(len(bases)-i) || cOtherInclude.Get(pkg)) {
  528. toClean = append(toClean, base)
  529. continue
  530. }
  531. if !cIsInclude && (!cExclude.Get(len(bases)-i) && !cOtherExclude.Get(pkg)) {
  532. toClean = append(toClean, base)
  533. continue
  534. }
  535. }
  536. }
  537. return toClean, nil
  538. }
  539. func editNumberMenu(bases []dep.Base, installed stringset.StringSet) ([]dep.Base, error) {
  540. return editDiffNumberMenu(bases, installed, false)
  541. }
  542. func diffNumberMenu(bases []dep.Base, installed stringset.StringSet) ([]dep.Base, error) {
  543. return editDiffNumberMenu(bases, installed, true)
  544. }
  545. func editDiffNumberMenu(bases []dep.Base, installed stringset.StringSet, diff bool) ([]dep.Base, error) {
  546. var (
  547. toEdit = make([]dep.Base, 0)
  548. editInput string
  549. err error
  550. )
  551. if diff {
  552. text.Infoln(gotext.Get("Diffs to show?"))
  553. text.Infoln(gotext.Get("%s [A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)", text.Cyan(gotext.Get("[N]one"))))
  554. editInput, err = getInput(config.AnswerDiff)
  555. if err != nil {
  556. return nil, err
  557. }
  558. } else {
  559. text.Infoln(gotext.Get("PKGBUILDs to edit?"))
  560. text.Infoln(gotext.Get("%s [A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)", text.Cyan(gotext.Get("[N]one"))))
  561. editInput, err = getInput(config.AnswerEdit)
  562. if err != nil {
  563. return nil, err
  564. }
  565. }
  566. eInclude, eExclude, eOtherInclude, eOtherExclude := intrange.ParseNumberMenu(editInput)
  567. eIsInclude := len(eExclude) == 0 && len(eOtherExclude) == 0
  568. if eOtherInclude.Get("abort") || eOtherInclude.Get("ab") {
  569. return nil, fmt.Errorf(gotext.Get("aborting due to user"))
  570. }
  571. if !eOtherInclude.Get("n") && !eOtherInclude.Get("none") {
  572. for i, base := range bases {
  573. pkg := base.Pkgbase()
  574. anyInstalled := false
  575. for _, b := range base {
  576. anyInstalled = anyInstalled || installed.Get(b.Name)
  577. }
  578. if !eIsInclude && eExclude.Get(len(bases)-i) {
  579. continue
  580. }
  581. if anyInstalled && (eOtherInclude.Get("i") || eOtherInclude.Get("installed")) {
  582. toEdit = append(toEdit, base)
  583. continue
  584. }
  585. if !anyInstalled && (eOtherInclude.Get("no") || eOtherInclude.Get("notinstalled")) {
  586. toEdit = append(toEdit, base)
  587. continue
  588. }
  589. if eOtherInclude.Get("a") || eOtherInclude.Get("all") {
  590. toEdit = append(toEdit, base)
  591. continue
  592. }
  593. if eIsInclude && (eInclude.Get(len(bases)-i) || eOtherInclude.Get(pkg)) {
  594. toEdit = append(toEdit, base)
  595. }
  596. if !eIsInclude && (!eExclude.Get(len(bases)-i) && !eOtherExclude.Get(pkg)) {
  597. toEdit = append(toEdit, base)
  598. }
  599. }
  600. }
  601. return toEdit, nil
  602. }
  603. func updatePkgbuildSeenRef(ctx context.Context, bases []dep.Base) error {
  604. var errMulti multierror.MultiError
  605. for _, base := range bases {
  606. pkg := base.Pkgbase()
  607. if err := gitUpdateSeenRef(ctx, config.BuildDir, pkg); err != nil {
  608. errMulti.Add(err)
  609. }
  610. }
  611. return errMulti.Return()
  612. }
  613. func editPkgbuilds(bases []dep.Base, srcinfos map[string]*gosrc.Srcinfo) error {
  614. pkgbuilds := make([]string, 0, len(bases))
  615. for _, base := range bases {
  616. pkg := base.Pkgbase()
  617. dir := filepath.Join(config.BuildDir, pkg)
  618. pkgbuilds = append(pkgbuilds, filepath.Join(dir, "PKGBUILD"))
  619. for _, splitPkg := range srcinfos[pkg].SplitPackages() {
  620. if splitPkg.Install != "" {
  621. pkgbuilds = append(pkgbuilds, filepath.Join(dir, splitPkg.Install))
  622. }
  623. }
  624. }
  625. if len(pkgbuilds) > 0 {
  626. editor, editorArgs := editor()
  627. editorArgs = append(editorArgs, pkgbuilds...)
  628. editcmd := exec.Command(editor, editorArgs...)
  629. editcmd.Stdin, editcmd.Stdout, editcmd.Stderr = os.Stdin, os.Stdout, os.Stderr
  630. if err := editcmd.Run(); err != nil {
  631. return errors.New(gotext.Get("editor did not exit successfully, aborting: %s", err))
  632. }
  633. }
  634. return nil
  635. }
  636. func parseSrcinfoFiles(bases []dep.Base, errIsFatal bool) (map[string]*gosrc.Srcinfo, error) {
  637. srcinfos := make(map[string]*gosrc.Srcinfo)
  638. for k, base := range bases {
  639. pkg := base.Pkgbase()
  640. dir := filepath.Join(config.BuildDir, pkg)
  641. text.OperationInfoln(gotext.Get("(%d/%d) Parsing SRCINFO: %s", k+1, len(bases), text.Cyan(base.String())))
  642. pkgbuild, err := gosrc.ParseFile(filepath.Join(dir, ".SRCINFO"))
  643. if err != nil {
  644. if !errIsFatal {
  645. text.Warnln(gotext.Get("failed to parse %s -- skipping: %s", base.String(), err))
  646. continue
  647. }
  648. return nil, errors.New(gotext.Get("failed to parse %s: %s", base.String(), err))
  649. }
  650. srcinfos[pkg] = pkgbuild
  651. }
  652. return srcinfos, nil
  653. }
  654. func pkgbuildsToSkip(bases []dep.Base, targets stringset.StringSet) stringset.StringSet {
  655. toSkip := make(stringset.StringSet)
  656. for _, base := range bases {
  657. isTarget := false
  658. for _, pkg := range base {
  659. isTarget = isTarget || targets.Get(pkg.Name)
  660. }
  661. if (config.ReDownload == "yes" && isTarget) || config.ReDownload == "all" {
  662. continue
  663. }
  664. dir := filepath.Join(config.BuildDir, base.Pkgbase(), ".SRCINFO")
  665. pkgbuild, err := gosrc.ParseFile(dir)
  666. if err == nil {
  667. if alpm.VerCmp(pkgbuild.Version(), base.Version()) >= 0 {
  668. toSkip.Set(base.Pkgbase())
  669. }
  670. }
  671. }
  672. return toSkip
  673. }
  674. func mergePkgbuilds(ctx context.Context, bases []dep.Base) error {
  675. for _, base := range bases {
  676. err := gitMerge(ctx, config.BuildDir, base.Pkgbase())
  677. if err != nil {
  678. return err
  679. }
  680. }
  681. return nil
  682. }
  683. func buildInstallPkgbuilds(
  684. ctx context.Context,
  685. cmdArgs *parser.Arguments,
  686. dbExecutor db.Executor,
  687. dp *dep.Pool,
  688. do *dep.Order,
  689. srcinfos map[string]*gosrc.Srcinfo,
  690. incompatible stringset.StringSet,
  691. conflicts stringset.MapStringSet, noDeps, noCheck bool,
  692. ) error {
  693. arguments := cmdArgs.Copy()
  694. arguments.ClearTargets()
  695. arguments.Op = "U"
  696. arguments.DelArg("confirm")
  697. arguments.DelArg("noconfirm")
  698. arguments.DelArg("c", "clean")
  699. arguments.DelArg("q", "quiet")
  700. arguments.DelArg("q", "quiet")
  701. arguments.DelArg("y", "refresh")
  702. arguments.DelArg("u", "sysupgrade")
  703. arguments.DelArg("w", "downloadonly")
  704. deps := make([]string, 0)
  705. exp := make([]string, 0)
  706. oldConfirm := settings.NoConfirm
  707. settings.NoConfirm = true
  708. // remotenames: names of all non repo packages on the system
  709. localNames, remoteNames, err := query.GetPackageNamesBySource(dbExecutor)
  710. if err != nil {
  711. return err
  712. }
  713. // cache as a stringset. maybe make it return a string set in the first
  714. // place
  715. remoteNamesCache := stringset.FromSlice(remoteNames)
  716. localNamesCache := stringset.FromSlice(localNames)
  717. for _, base := range do.Aur {
  718. pkg := base.Pkgbase()
  719. dir := filepath.Join(config.BuildDir, pkg)
  720. built := true
  721. satisfied := true
  722. all:
  723. for _, pkg := range base {
  724. for _, deps := range dep.ComputeCombinedDepList(pkg, noDeps, noCheck) {
  725. for _, dep := range deps {
  726. if !dp.AlpmExecutor.LocalSatisfierExists(dep) {
  727. satisfied = false
  728. text.Warnln(gotext.Get("%s not satisfied, flushing install queue", dep))
  729. break all
  730. }
  731. }
  732. }
  733. }
  734. if !satisfied || !config.BatchInstall {
  735. err = doInstall(ctx, arguments, cmdArgs, deps, exp)
  736. arguments.ClearTargets()
  737. deps = make([]string, 0)
  738. exp = make([]string, 0)
  739. if err != nil {
  740. return err
  741. }
  742. }
  743. srcinfo := srcinfos[pkg]
  744. args := []string{"--nobuild", "-fC"}
  745. if incompatible.Get(pkg) {
  746. args = append(args, "--ignorearch")
  747. }
  748. // pkgver bump
  749. if err = config.Runtime.CmdBuilder.Show(
  750. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, args...)); err != nil {
  751. return errors.New(gotext.Get("error making: %s", base.String()))
  752. }
  753. pkgdests, pkgVersion, errList := parsePackageList(ctx, dir)
  754. if errList != nil {
  755. return errList
  756. }
  757. isExplicit := false
  758. for _, b := range base {
  759. isExplicit = isExplicit || dp.Explicit.Get(b.Name)
  760. }
  761. if config.ReBuild == "no" || (config.ReBuild == "yes" && !isExplicit) {
  762. for _, split := range base {
  763. pkgdest, ok := pkgdests[split.Name]
  764. if !ok {
  765. return errors.New(gotext.Get("could not find PKGDEST for: %s", split.Name))
  766. }
  767. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  768. built = false
  769. } else if errStat != nil {
  770. return errStat
  771. }
  772. }
  773. } else {
  774. built = false
  775. }
  776. if cmdArgs.ExistsArg("needed") {
  777. installed := true
  778. for _, split := range base {
  779. installed = dp.AlpmExecutor.IsCorrectVersionInstalled(split.Name, pkgVersion)
  780. }
  781. if installed {
  782. err = config.Runtime.CmdBuilder.Show(
  783. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  784. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  785. if err != nil {
  786. return errors.New(gotext.Get("error making: %s", err))
  787. }
  788. fmt.Fprintln(os.Stdout, gotext.Get("%s is up to date -- skipping", text.Cyan(pkg+"-"+pkgVersion)))
  789. continue
  790. }
  791. }
  792. if built {
  793. err = config.Runtime.CmdBuilder.Show(
  794. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  795. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  796. if err != nil {
  797. return errors.New(gotext.Get("error making: %s", err))
  798. }
  799. text.Warnln(gotext.Get("%s already made -- skipping build", text.Cyan(pkg+"-"+pkgVersion)))
  800. } else {
  801. args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
  802. if incompatible.Get(pkg) {
  803. args = append(args, "--ignorearch")
  804. }
  805. if errMake := config.Runtime.CmdBuilder.Show(
  806. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  807. dir, args...)); errMake != nil {
  808. return errors.New(gotext.Get("error making: %s", base.String()))
  809. }
  810. }
  811. // conflicts have been checked so answer y for them
  812. if config.UseAsk && cmdArgs.ExistsArg("ask") {
  813. ask, _ := strconv.Atoi(cmdArgs.Options["ask"].First())
  814. uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
  815. cmdArgs.Options["ask"].Set(fmt.Sprint(uask))
  816. } else {
  817. for _, split := range base {
  818. if _, ok := conflicts[split.Name]; ok {
  819. settings.NoConfirm = false
  820. break
  821. }
  822. }
  823. }
  824. var errAdd error
  825. for _, split := range base {
  826. for suffix, optional := range map[string]bool{"": false, "-debug": true} {
  827. deps, exp, errAdd = doAddTarget(dp, localNamesCache, remoteNamesCache,
  828. arguments, cmdArgs, pkgdests, deps, exp, split.Name+suffix, optional)
  829. if errAdd != nil {
  830. return errAdd
  831. }
  832. }
  833. }
  834. var (
  835. mux sync.Mutex
  836. wg sync.WaitGroup
  837. )
  838. for _, pkg := range base {
  839. wg.Add(1)
  840. go config.Runtime.VCSStore.Update(ctx, pkg.Name, srcinfo.Source, &mux, &wg)
  841. }
  842. wg.Wait()
  843. }
  844. err = doInstall(ctx, arguments, cmdArgs, deps, exp)
  845. settings.NoConfirm = oldConfirm
  846. return err
  847. }
  848. func doInstall(ctx context.Context, arguments, cmdArgs *parser.Arguments, pkgDeps, pkgExp []string) error {
  849. if len(arguments.Targets) == 0 {
  850. return nil
  851. }
  852. if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  853. arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
  854. return errShow
  855. }
  856. if errStore := config.Runtime.VCSStore.Save(); errStore != nil {
  857. fmt.Fprintln(os.Stderr, errStore)
  858. }
  859. if errDeps := asdeps(ctx, cmdArgs, pkgDeps); errDeps != nil {
  860. return errDeps
  861. }
  862. return asexp(ctx, cmdArgs, pkgExp)
  863. }
  864. func doAddTarget(dp *dep.Pool, localNamesCache, remoteNamesCache stringset.StringSet,
  865. arguments, cmdArgs *parser.Arguments, pkgdests map[string]string,
  866. deps, exp []string, name string, optional bool) (newDeps, newExp []string, err error) {
  867. pkgdest, ok := pkgdests[name]
  868. if !ok {
  869. if optional {
  870. return deps, exp, nil
  871. }
  872. return deps, exp, errors.New(gotext.Get("could not find PKGDEST for: %s", name))
  873. }
  874. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  875. if optional {
  876. return deps, exp, nil
  877. }
  878. return deps, exp, errors.New(
  879. gotext.Get(
  880. "the PKGDEST for %s is listed by makepkg but does not exist: %s",
  881. name, pkgdest))
  882. }
  883. arguments.AddTarget(pkgdest)
  884. switch {
  885. case cmdArgs.ExistsArg("asdeps", "asdep"):
  886. deps = append(deps, name)
  887. case cmdArgs.ExistsArg("asexplicit", "asexp"):
  888. exp = append(exp, name)
  889. case !dp.Explicit.Get(name) && !localNamesCache.Get(name) && !remoteNamesCache.Get(name):
  890. deps = append(deps, name)
  891. }
  892. return deps, exp, nil
  893. }