install.go 28 KB

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