install.go 26 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019
  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/v11/pkg/completion"
  16. "github.com/Jguer/yay/v11/pkg/db"
  17. "github.com/Jguer/yay/v11/pkg/dep"
  18. "github.com/Jguer/yay/v11/pkg/download"
  19. "github.com/Jguer/yay/v11/pkg/intrange"
  20. "github.com/Jguer/yay/v11/pkg/multierror"
  21. "github.com/Jguer/yay/v11/pkg/pgp"
  22. "github.com/Jguer/yay/v11/pkg/query"
  23. "github.com/Jguer/yay/v11/pkg/settings"
  24. "github.com/Jguer/yay/v11/pkg/settings/parser"
  25. "github.com/Jguer/yay/v11/pkg/stringset"
  26. "github.com/Jguer/yay/v11/pkg/text"
  27. )
  28. 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. conflicts, errCC := dp.CheckConflicts(config.UseAsk, settings.NoConfirm, noDeps)
  147. if errCC != nil {
  148. return errCC
  149. }
  150. do = dep.GetOrder(dp, noDeps, noCheck)
  151. for _, pkg := range do.Repo {
  152. arguments.AddTarget(pkg.DB().Name() + "/" + pkg.Name())
  153. }
  154. for _, pkg := range dp.Groups {
  155. arguments.AddTarget(pkg)
  156. }
  157. if len(do.Aur) == 0 && len(arguments.Targets) == 0 &&
  158. (!cmdArgs.ExistsArg("u", "sysupgrade") || config.Runtime.Mode == parser.ModeAUR) {
  159. fmt.Println(gotext.Get(" there is nothing to do"))
  160. return nil
  161. }
  162. do.Print()
  163. fmt.Println()
  164. if config.CleanAfter {
  165. defer cleanAfter(ctx, do.Aur)
  166. }
  167. if do.HasMake() {
  168. switch config.RemoveMake {
  169. case "yes":
  170. defer func() {
  171. err = removeMake(ctx, do)
  172. }()
  173. case "no":
  174. break
  175. default:
  176. if text.ContinueTask(gotext.Get("Remove make dependencies after install?"), false, settings.NoConfirm) {
  177. defer func() {
  178. err = removeMake(ctx, do)
  179. }()
  180. }
  181. }
  182. }
  183. if errCleanMenu := cleanMenu(config.CleanMenu, do.Aur, remoteNamesCache); errCleanMenu != nil {
  184. if errors.As(errCleanMenu, &settings.ErrUserAbort{}) {
  185. return errCleanMenu
  186. }
  187. text.Errorln(errCleanMenu)
  188. }
  189. toSkip := pkgbuildsToSkip(do.Aur, targets)
  190. toClone := make([]string, 0, len(do.Aur))
  191. for _, base := range do.Aur {
  192. if !toSkip.Get(base.Pkgbase()) {
  193. toClone = append(toClone, base.Pkgbase())
  194. }
  195. }
  196. if toSkipSlice := toSkip.ToSlice(); len(toSkipSlice) != 0 {
  197. text.OperationInfoln(
  198. gotext.Get("PKGBUILD up to date, Skipping (%d/%d): %s",
  199. len(toSkipSlice), len(toClone), text.Cyan(strings.Join(toSkipSlice, ", "))))
  200. }
  201. cloned, errA := download.AURPKGBUILDRepos(ctx,
  202. config.Runtime.CmdBuilder, toClone, config.AURURL, config.BuildDir, false)
  203. if errA != nil {
  204. return errA
  205. }
  206. var toDiff, toEdit []dep.Base
  207. if config.DiffMenu {
  208. pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  209. toDiff, err = diffNumberMenu(do.Aur, remoteNamesCache)
  210. if err != nil {
  211. return err
  212. }
  213. if len(toDiff) > 0 {
  214. err = showPkgbuildDiffs(ctx, toDiff, cloned)
  215. if err != nil {
  216. return err
  217. }
  218. }
  219. }
  220. if len(toDiff) > 0 {
  221. oldValue := settings.NoConfirm
  222. settings.NoConfirm = false
  223. fmt.Println()
  224. if !text.ContinueTask(gotext.Get("Proceed with install?"), true, settings.NoConfirm) {
  225. return &settings.ErrUserAbort{}
  226. }
  227. err = updatePkgbuildSeenRef(ctx, toDiff)
  228. if err != nil {
  229. text.Errorln(err.Error())
  230. }
  231. settings.NoConfirm = oldValue
  232. }
  233. if errM := mergePkgbuilds(ctx, do.Aur); errM != nil {
  234. return errM
  235. }
  236. srcinfos, err = parseSrcinfoFiles(do.Aur, true)
  237. if err != nil {
  238. return err
  239. }
  240. if config.EditMenu {
  241. pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  242. toEdit, err = editNumberMenu(do.Aur, remoteNamesCache)
  243. if err != nil {
  244. return err
  245. }
  246. if len(toEdit) > 0 {
  247. err = editPkgbuilds(toEdit, srcinfos)
  248. if err != nil {
  249. return err
  250. }
  251. }
  252. }
  253. if len(toEdit) > 0 {
  254. oldValue := settings.NoConfirm
  255. settings.NoConfirm = false
  256. fmt.Println()
  257. if !text.ContinueTask(gotext.Get("Proceed with install?"), true, settings.NoConfirm) {
  258. return &settings.ErrUserAbort{}
  259. }
  260. settings.NoConfirm = oldValue
  261. }
  262. incompatible, err = getIncompatible(do.Aur, srcinfos, dbExecutor)
  263. if err != nil {
  264. return err
  265. }
  266. if config.PGPFetch {
  267. if errCPK := pgp.CheckPgpKeys(do.Aur, srcinfos, config.GpgBin, config.GpgFlags, settings.NoConfirm); errCPK != nil {
  268. return errCPK
  269. }
  270. }
  271. if !config.CombinedUpgrade {
  272. arguments.DelArg("u", "sysupgrade")
  273. }
  274. if len(arguments.Targets) > 0 || arguments.ExistsArg("u") {
  275. if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  276. arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
  277. return errors.New(gotext.Get("error installing repo packages"))
  278. }
  279. deps := make([]string, 0)
  280. exp := make([]string, 0)
  281. for _, pkg := range do.Repo {
  282. if !dp.Explicit.Get(pkg.Name()) && !localNamesCache.Get(pkg.Name()) && !remoteNamesCache.Get(pkg.Name()) {
  283. deps = append(deps, pkg.Name())
  284. continue
  285. }
  286. if cmdArgs.ExistsArg("asdeps", "asdep") && dp.Explicit.Get(pkg.Name()) {
  287. deps = append(deps, pkg.Name())
  288. } else if cmdArgs.ExistsArg("asexp", "asexplicit") && dp.Explicit.Get(pkg.Name()) {
  289. exp = append(exp, pkg.Name())
  290. }
  291. }
  292. if errDeps := asdeps(ctx, cmdArgs, deps); errDeps != nil {
  293. return errDeps
  294. }
  295. if errExp := asexp(ctx, cmdArgs, exp); errExp != nil {
  296. return errExp
  297. }
  298. }
  299. go func() {
  300. _ = completion.Update(ctx, config.Runtime.HTTPClient, dbExecutor,
  301. config.AURURL, config.Runtime.CompletionPath, config.CompletionInterval, false)
  302. }()
  303. if errP := downloadPKGBUILDSourceFanout(ctx, config.Runtime.CmdBuilder, config.BuildDir, do.Aur, incompatible); errP != nil {
  304. text.Errorln(errP)
  305. }
  306. if errB := buildInstallPkgbuilds(ctx, cmdArgs, dbExecutor, dp, do, srcinfos, incompatible, conflicts, noDeps, noCheck); errB != nil {
  307. return errB
  308. }
  309. return nil
  310. }
  311. func removeMake(ctx context.Context, do *dep.Order) error {
  312. removeArguments := parser.MakeArguments()
  313. err := removeArguments.AddArg("R", "u")
  314. if err != nil {
  315. return err
  316. }
  317. for _, pkg := range do.GetMake() {
  318. removeArguments.AddTarget(pkg)
  319. }
  320. oldValue := settings.NoConfirm
  321. settings.NoConfirm = true
  322. err = config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  323. removeArguments, config.Runtime.Mode, settings.NoConfirm))
  324. settings.NoConfirm = oldValue
  325. return err
  326. }
  327. func inRepos(dbExecutor db.Executor, pkg string) bool {
  328. target := dep.ToTarget(pkg)
  329. if target.DB == "aur" {
  330. return false
  331. } else if target.DB != "" {
  332. return true
  333. }
  334. previousHideMenus := settings.HideMenus
  335. settings.HideMenus = true
  336. exists := dbExecutor.SyncSatisfierExists(target.DepString())
  337. settings.HideMenus = previousHideMenus
  338. return exists || len(dbExecutor.PackagesFromGroup(target.Name)) > 0
  339. }
  340. func earlyPacmanCall(ctx context.Context, cmdArgs *parser.Arguments, dbExecutor db.Executor) error {
  341. arguments := cmdArgs.Copy()
  342. arguments.Op = "S"
  343. targets := cmdArgs.Targets
  344. cmdArgs.ClearTargets()
  345. arguments.ClearTargets()
  346. if config.Runtime.Mode == parser.ModeRepo {
  347. arguments.Targets = targets
  348. } else {
  349. // separate aur and repo targets
  350. for _, target := range targets {
  351. if inRepos(dbExecutor, target) {
  352. arguments.AddTarget(target)
  353. } else {
  354. cmdArgs.AddTarget(target)
  355. }
  356. }
  357. }
  358. if cmdArgs.ExistsArg("y", "refresh") || cmdArgs.ExistsArg("u", "sysupgrade") || len(arguments.Targets) > 0 {
  359. if err := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  360. arguments, config.Runtime.Mode, settings.NoConfirm)); err != nil {
  361. return errors.New(gotext.Get("error installing repo packages"))
  362. }
  363. }
  364. return nil
  365. }
  366. func earlyRefresh(ctx context.Context, cmdArgs *parser.Arguments) error {
  367. arguments := cmdArgs.Copy()
  368. cmdArgs.DelArg("y", "refresh")
  369. arguments.DelArg("u", "sysupgrade")
  370. arguments.DelArg("s", "search")
  371. arguments.DelArg("i", "info")
  372. arguments.DelArg("l", "list")
  373. arguments.ClearTargets()
  374. return config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  375. arguments, config.Runtime.Mode, settings.NoConfirm))
  376. }
  377. func alpmArchIsSupported(alpmArch []string, arch string) bool {
  378. if arch == "any" {
  379. return true
  380. }
  381. for _, a := range alpmArch {
  382. if a == arch {
  383. return true
  384. }
  385. }
  386. return false
  387. }
  388. func getIncompatible(bases []dep.Base, srcinfos map[string]*gosrc.Srcinfo, dbExecutor db.Executor) (stringset.StringSet, error) {
  389. incompatible := make(stringset.StringSet)
  390. basesMap := make(map[string]dep.Base)
  391. alpmArch, err := dbExecutor.AlpmArchitectures()
  392. if err != nil {
  393. return nil, err
  394. }
  395. nextpkg:
  396. for _, base := range bases {
  397. for _, arch := range srcinfos[base.Pkgbase()].Arch {
  398. if alpmArchIsSupported(alpmArch, arch) {
  399. continue nextpkg
  400. }
  401. }
  402. incompatible.Set(base.Pkgbase())
  403. basesMap[base.Pkgbase()] = base
  404. }
  405. if len(incompatible) > 0 {
  406. text.Warnln(gotext.Get("The following packages are not compatible with your architecture:"))
  407. for pkg := range incompatible {
  408. fmt.Print(" " + text.Cyan(basesMap[pkg].String()))
  409. }
  410. fmt.Println()
  411. if !text.ContinueTask(gotext.Get("Try to build them anyway?"), true, settings.NoConfirm) {
  412. return nil, &settings.ErrUserAbort{}
  413. }
  414. }
  415. return incompatible, nil
  416. }
  417. func parsePackageList(ctx context.Context, dir string) (pkgdests map[string]string, pkgVersion string, err error) {
  418. stdout, stderr, err := config.Runtime.CmdBuilder.Capture(
  419. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, "--packagelist"))
  420. if err != nil {
  421. return nil, "", fmt.Errorf("%s %s", 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. return pkgdests, pkgVersion, nil
  442. }
  443. func pkgbuildNumberMenu(bases []dep.Base, installed stringset.StringSet) {
  444. toPrint := ""
  445. for n, base := range bases {
  446. pkg := base.Pkgbase()
  447. dir := filepath.Join(config.BuildDir, pkg)
  448. toPrint += fmt.Sprintf(text.Magenta("%3d")+" %-40s", len(bases)-n,
  449. text.Bold(base.String()))
  450. if base.AnyIsInSet(installed) {
  451. toPrint += text.Bold(text.Green(gotext.Get(" (Installed)")))
  452. }
  453. if _, err := os.Stat(dir); !os.IsNotExist(err) {
  454. toPrint += text.Bold(text.Green(gotext.Get(" (Build Files Exist)")))
  455. }
  456. toPrint += "\n"
  457. }
  458. fmt.Print(toPrint)
  459. }
  460. func editNumberMenu(bases []dep.Base, installed stringset.StringSet) ([]dep.Base, error) {
  461. return editDiffNumberMenu(bases, installed, false)
  462. }
  463. func diffNumberMenu(bases []dep.Base, installed stringset.StringSet) ([]dep.Base, error) {
  464. return editDiffNumberMenu(bases, installed, true)
  465. }
  466. func editDiffNumberMenu(bases []dep.Base, installed stringset.StringSet, diff bool) ([]dep.Base, error) {
  467. var (
  468. toEdit = make([]dep.Base, 0)
  469. editInput string
  470. err error
  471. )
  472. if diff {
  473. text.Infoln(gotext.Get("Diffs to show?"))
  474. 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"))))
  475. editInput, err = getInput(config.AnswerDiff)
  476. if err != nil {
  477. return nil, err
  478. }
  479. } else {
  480. text.Infoln(gotext.Get("PKGBUILDs to edit?"))
  481. 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"))))
  482. editInput, err = getInput(config.AnswerEdit)
  483. if err != nil {
  484. return nil, err
  485. }
  486. }
  487. eInclude, eExclude, eOtherInclude, eOtherExclude := intrange.ParseNumberMenu(editInput)
  488. eIsInclude := len(eExclude) == 0 && len(eOtherExclude) == 0
  489. if eOtherInclude.Get("abort") || eOtherInclude.Get("ab") {
  490. return nil, &settings.ErrUserAbort{}
  491. }
  492. if !eOtherInclude.Get("n") && !eOtherInclude.Get("none") {
  493. for i, base := range bases {
  494. pkg := base.Pkgbase()
  495. anyInstalled := base.AnyIsInSet(installed)
  496. if !eIsInclude && eExclude.Get(len(bases)-i) {
  497. continue
  498. }
  499. if anyInstalled && (eOtherInclude.Get("i") || eOtherInclude.Get("installed")) {
  500. toEdit = append(toEdit, base)
  501. continue
  502. }
  503. if !anyInstalled && (eOtherInclude.Get("no") || eOtherInclude.Get("notinstalled")) {
  504. toEdit = append(toEdit, base)
  505. continue
  506. }
  507. if eOtherInclude.Get("a") || eOtherInclude.Get("all") {
  508. toEdit = append(toEdit, base)
  509. continue
  510. }
  511. if eIsInclude && (eInclude.Get(len(bases)-i) || eOtherInclude.Get(pkg)) {
  512. toEdit = append(toEdit, base)
  513. }
  514. if !eIsInclude && (!eExclude.Get(len(bases)-i) && !eOtherExclude.Get(pkg)) {
  515. toEdit = append(toEdit, base)
  516. }
  517. }
  518. }
  519. return toEdit, nil
  520. }
  521. func updatePkgbuildSeenRef(ctx context.Context, bases []dep.Base) error {
  522. var errMulti multierror.MultiError
  523. for _, base := range bases {
  524. pkg := base.Pkgbase()
  525. if err := gitUpdateSeenRef(ctx, config.BuildDir, pkg); err != nil {
  526. errMulti.Add(err)
  527. }
  528. }
  529. return errMulti.Return()
  530. }
  531. func editPkgbuilds(bases []dep.Base, srcinfos map[string]*gosrc.Srcinfo) error {
  532. pkgbuilds := make([]string, 0, len(bases))
  533. for _, base := range bases {
  534. pkg := base.Pkgbase()
  535. dir := filepath.Join(config.BuildDir, pkg)
  536. pkgbuilds = append(pkgbuilds, filepath.Join(dir, "PKGBUILD"))
  537. for _, splitPkg := range srcinfos[pkg].SplitPackages() {
  538. if splitPkg.Install != "" {
  539. pkgbuilds = append(pkgbuilds, filepath.Join(dir, splitPkg.Install))
  540. }
  541. }
  542. }
  543. if len(pkgbuilds) > 0 {
  544. editor, editorArgs := editor()
  545. editorArgs = append(editorArgs, pkgbuilds...)
  546. editcmd := exec.Command(editor, editorArgs...)
  547. editcmd.Stdin, editcmd.Stdout, editcmd.Stderr = os.Stdin, os.Stdout, os.Stderr
  548. if err := editcmd.Run(); err != nil {
  549. return errors.New(gotext.Get("editor did not exit successfully, aborting: %s", err))
  550. }
  551. }
  552. return nil
  553. }
  554. func parseSrcinfoFiles(bases []dep.Base, errIsFatal bool) (map[string]*gosrc.Srcinfo, error) {
  555. srcinfos := make(map[string]*gosrc.Srcinfo)
  556. for k, base := range bases {
  557. pkg := base.Pkgbase()
  558. dir := filepath.Join(config.BuildDir, pkg)
  559. text.OperationInfoln(gotext.Get("(%d/%d) Parsing SRCINFO: %s", k+1, len(bases), text.Cyan(base.String())))
  560. pkgbuild, err := gosrc.ParseFile(filepath.Join(dir, ".SRCINFO"))
  561. if err != nil {
  562. if !errIsFatal {
  563. text.Warnln(gotext.Get("failed to parse %s -- skipping: %s", base.String(), err))
  564. continue
  565. }
  566. return nil, errors.New(gotext.Get("failed to parse %s: %s", base.String(), err))
  567. }
  568. srcinfos[pkg] = pkgbuild
  569. }
  570. return srcinfos, nil
  571. }
  572. func pkgbuildsToSkip(bases []dep.Base, targets stringset.StringSet) stringset.StringSet {
  573. toSkip := make(stringset.StringSet)
  574. for _, base := range bases {
  575. isTarget := false
  576. for _, pkg := range base {
  577. isTarget = isTarget || targets.Get(pkg.Name)
  578. }
  579. if (config.ReDownload == "yes" && isTarget) || config.ReDownload == "all" {
  580. continue
  581. }
  582. dir := filepath.Join(config.BuildDir, base.Pkgbase(), ".SRCINFO")
  583. pkgbuild, err := gosrc.ParseFile(dir)
  584. if err == nil {
  585. if alpm.VerCmp(pkgbuild.Version(), base.Version()) >= 0 {
  586. toSkip.Set(base.Pkgbase())
  587. }
  588. }
  589. }
  590. return toSkip
  591. }
  592. func mergePkgbuilds(ctx context.Context, bases []dep.Base) error {
  593. for _, base := range bases {
  594. err := gitMerge(ctx, config.BuildDir, base.Pkgbase())
  595. if err != nil {
  596. return err
  597. }
  598. }
  599. return nil
  600. }
  601. func buildInstallPkgbuilds(
  602. ctx context.Context,
  603. cmdArgs *parser.Arguments,
  604. dbExecutor db.Executor,
  605. dp *dep.Pool,
  606. do *dep.Order,
  607. srcinfos map[string]*gosrc.Srcinfo,
  608. incompatible stringset.StringSet,
  609. conflicts stringset.MapStringSet, noDeps, noCheck bool,
  610. ) error {
  611. arguments := cmdArgs.Copy()
  612. arguments.ClearTargets()
  613. arguments.Op = "U"
  614. arguments.DelArg("confirm")
  615. arguments.DelArg("noconfirm")
  616. arguments.DelArg("c", "clean")
  617. arguments.DelArg("q", "quiet")
  618. arguments.DelArg("q", "quiet")
  619. arguments.DelArg("y", "refresh")
  620. arguments.DelArg("u", "sysupgrade")
  621. arguments.DelArg("w", "downloadonly")
  622. deps := make([]string, 0)
  623. exp := make([]string, 0)
  624. oldConfirm := settings.NoConfirm
  625. settings.NoConfirm = true
  626. // remotenames: names of all non repo packages on the system
  627. localNames, remoteNames, err := query.GetPackageNamesBySource(dbExecutor)
  628. if err != nil {
  629. return err
  630. }
  631. // cache as a stringset. maybe make it return a string set in the first
  632. // place
  633. remoteNamesCache := stringset.FromSlice(remoteNames)
  634. localNamesCache := stringset.FromSlice(localNames)
  635. for _, base := range do.Aur {
  636. pkg := base.Pkgbase()
  637. dir := filepath.Join(config.BuildDir, pkg)
  638. built := true
  639. satisfied := true
  640. all:
  641. for _, pkg := range base {
  642. for _, deps := range dep.ComputeCombinedDepList(pkg, noDeps, noCheck) {
  643. for _, dep := range deps {
  644. if !dp.AlpmExecutor.LocalSatisfierExists(dep) {
  645. satisfied = false
  646. text.Warnln(gotext.Get("%s not satisfied, flushing install queue", dep))
  647. break all
  648. }
  649. }
  650. }
  651. }
  652. if !satisfied || !config.BatchInstall {
  653. err = doInstall(ctx, arguments, cmdArgs, deps, exp)
  654. arguments.ClearTargets()
  655. deps = make([]string, 0)
  656. exp = make([]string, 0)
  657. if err != nil {
  658. return err
  659. }
  660. }
  661. srcinfo := srcinfos[pkg]
  662. args := []string{"--nobuild", "-fC"}
  663. if incompatible.Get(pkg) {
  664. args = append(args, "--ignorearch")
  665. }
  666. // pkgver bump
  667. if err = config.Runtime.CmdBuilder.Show(
  668. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, args...)); err != nil {
  669. return errors.New(gotext.Get("error making: %s", base.String()))
  670. }
  671. pkgdests, pkgVersion, errList := parsePackageList(ctx, dir)
  672. if errList != nil {
  673. return errList
  674. }
  675. isExplicit := false
  676. for _, b := range base {
  677. isExplicit = isExplicit || dp.Explicit.Get(b.Name)
  678. }
  679. if config.ReBuild == "no" || (config.ReBuild == "yes" && !isExplicit) {
  680. for _, split := range base {
  681. pkgdest, ok := pkgdests[split.Name]
  682. if !ok {
  683. return errors.New(gotext.Get("could not find PKGDEST for: %s", split.Name))
  684. }
  685. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  686. built = false
  687. } else if errStat != nil {
  688. return errStat
  689. }
  690. }
  691. } else {
  692. built = false
  693. }
  694. if cmdArgs.ExistsArg("needed") {
  695. installed := true
  696. for _, split := range base {
  697. installed = dp.AlpmExecutor.IsCorrectVersionInstalled(split.Name, pkgVersion)
  698. }
  699. if installed {
  700. err = config.Runtime.CmdBuilder.Show(
  701. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  702. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  703. if err != nil {
  704. return errors.New(gotext.Get("error making: %s", err))
  705. }
  706. fmt.Fprintln(os.Stdout, gotext.Get("%s is up to date -- skipping", text.Cyan(pkg+"-"+pkgVersion)))
  707. continue
  708. }
  709. }
  710. if built {
  711. err = config.Runtime.CmdBuilder.Show(
  712. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  713. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  714. if err != nil {
  715. return errors.New(gotext.Get("error making: %s", err))
  716. }
  717. text.Warnln(gotext.Get("%s already made -- skipping build", text.Cyan(pkg+"-"+pkgVersion)))
  718. } else {
  719. args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
  720. if incompatible.Get(pkg) {
  721. args = append(args, "--ignorearch")
  722. }
  723. if errMake := config.Runtime.CmdBuilder.Show(
  724. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  725. dir, args...)); errMake != nil {
  726. return errors.New(gotext.Get("error making: %s", base.String()))
  727. }
  728. }
  729. // conflicts have been checked so answer y for them
  730. if config.UseAsk && cmdArgs.ExistsArg("ask") {
  731. ask, _ := strconv.Atoi(cmdArgs.Options["ask"].First())
  732. uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
  733. cmdArgs.Options["ask"].Set(fmt.Sprint(uask))
  734. } else {
  735. for _, split := range base {
  736. if _, ok := conflicts[split.Name]; ok {
  737. settings.NoConfirm = false
  738. break
  739. }
  740. }
  741. }
  742. var errAdd error
  743. for _, split := range base {
  744. for suffix, optional := range map[string]bool{"": false, "-debug": true} {
  745. deps, exp, errAdd = doAddTarget(dp, localNamesCache, remoteNamesCache,
  746. arguments, cmdArgs, pkgdests, deps, exp, split.Name+suffix, optional)
  747. if errAdd != nil {
  748. return errAdd
  749. }
  750. }
  751. }
  752. var (
  753. mux sync.Mutex
  754. wg sync.WaitGroup
  755. )
  756. for _, pkg := range base {
  757. wg.Add(1)
  758. go config.Runtime.VCSStore.Update(ctx, pkg.Name, srcinfo.Source, &mux, &wg)
  759. }
  760. wg.Wait()
  761. }
  762. err = doInstall(ctx, arguments, cmdArgs, deps, exp)
  763. settings.NoConfirm = oldConfirm
  764. return err
  765. }
  766. func doInstall(ctx context.Context, arguments, cmdArgs *parser.Arguments, pkgDeps, pkgExp []string) error {
  767. if len(arguments.Targets) == 0 {
  768. return nil
  769. }
  770. if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  771. arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
  772. return errShow
  773. }
  774. if errStore := config.Runtime.VCSStore.Save(); errStore != nil {
  775. fmt.Fprintln(os.Stderr, errStore)
  776. }
  777. if errDeps := asdeps(ctx, cmdArgs, pkgDeps); errDeps != nil {
  778. return errDeps
  779. }
  780. return asexp(ctx, cmdArgs, pkgExp)
  781. }
  782. func doAddTarget(dp *dep.Pool, localNamesCache, remoteNamesCache stringset.StringSet,
  783. arguments, cmdArgs *parser.Arguments, pkgdests map[string]string,
  784. deps, exp []string, name string, optional bool) (newDeps, newExp []string, err error) {
  785. pkgdest, ok := pkgdests[name]
  786. if !ok {
  787. if optional {
  788. return deps, exp, nil
  789. }
  790. return deps, exp, errors.New(gotext.Get("could not find PKGDEST for: %s", name))
  791. }
  792. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  793. if optional {
  794. return deps, exp, nil
  795. }
  796. return deps, exp, errors.New(
  797. gotext.Get(
  798. "the PKGDEST for %s is listed by makepkg but does not exist: %s",
  799. name, pkgdest))
  800. }
  801. arguments.AddTarget(pkgdest)
  802. switch {
  803. case cmdArgs.ExistsArg("asdeps", "asdep"):
  804. deps = append(deps, name)
  805. case cmdArgs.ExistsArg("asexplicit", "asexp"):
  806. exp = append(exp, name)
  807. case !dp.Explicit.Get(name) && !localNamesCache.Get(name) && !remoteNamesCache.Get(name):
  808. deps = append(deps, name)
  809. }
  810. return deps, exp, nil
  811. }