install.go 29 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156
  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 err
  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 = downloadPkgbuildsSources(ctx, do.Aur, incompatible)
  321. if err != nil {
  322. return 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 downloadPkgbuildsSources(ctx context.Context, bases []dep.Base, incompatible stringset.StringSet) (err error) {
  695. for _, base := range bases {
  696. pkg := base.Pkgbase()
  697. dir := filepath.Join(config.BuildDir, pkg)
  698. args := []string{"--verifysource", "-Ccf"}
  699. if incompatible.Get(pkg) {
  700. args = append(args, "--ignorearch")
  701. }
  702. err = config.Runtime.CmdBuilder.Show(
  703. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, args...))
  704. if err != nil {
  705. return errors.New(gotext.Get("error downloading sources: %s", text.Cyan(base.String())))
  706. }
  707. }
  708. return
  709. }
  710. func buildInstallPkgbuilds(
  711. ctx context.Context,
  712. cmdArgs *parser.Arguments,
  713. dbExecutor db.Executor,
  714. dp *dep.Pool,
  715. do *dep.Order,
  716. srcinfos map[string]*gosrc.Srcinfo,
  717. incompatible stringset.StringSet,
  718. conflicts stringset.MapStringSet, noDeps, noCheck bool,
  719. ) error {
  720. arguments := cmdArgs.Copy()
  721. arguments.ClearTargets()
  722. arguments.Op = "U"
  723. arguments.DelArg("confirm")
  724. arguments.DelArg("noconfirm")
  725. arguments.DelArg("c", "clean")
  726. arguments.DelArg("q", "quiet")
  727. arguments.DelArg("q", "quiet")
  728. arguments.DelArg("y", "refresh")
  729. arguments.DelArg("u", "sysupgrade")
  730. arguments.DelArg("w", "downloadonly")
  731. deps := make([]string, 0)
  732. exp := make([]string, 0)
  733. oldConfirm := settings.NoConfirm
  734. settings.NoConfirm = true
  735. // remotenames: names of all non repo packages on the system
  736. localNames, remoteNames, err := query.GetPackageNamesBySource(dbExecutor)
  737. if err != nil {
  738. return err
  739. }
  740. // cache as a stringset. maybe make it return a string set in the first
  741. // place
  742. remoteNamesCache := stringset.FromSlice(remoteNames)
  743. localNamesCache := stringset.FromSlice(localNames)
  744. for _, base := range do.Aur {
  745. pkg := base.Pkgbase()
  746. dir := filepath.Join(config.BuildDir, pkg)
  747. built := true
  748. satisfied := true
  749. all:
  750. for _, pkg := range base {
  751. for _, deps := range dep.ComputeCombinedDepList(pkg, noDeps, noCheck) {
  752. for _, dep := range deps {
  753. if !dp.AlpmExecutor.LocalSatisfierExists(dep) {
  754. satisfied = false
  755. text.Warnln(gotext.Get("%s not satisfied, flushing install queue", dep))
  756. break all
  757. }
  758. }
  759. }
  760. }
  761. if !satisfied || !config.BatchInstall {
  762. err = doInstall(ctx, arguments, cmdArgs, deps, exp)
  763. arguments.ClearTargets()
  764. deps = make([]string, 0)
  765. exp = make([]string, 0)
  766. if err != nil {
  767. return err
  768. }
  769. }
  770. srcinfo := srcinfos[pkg]
  771. args := []string{"--nobuild", "-fC"}
  772. if incompatible.Get(pkg) {
  773. args = append(args, "--ignorearch")
  774. }
  775. // pkgver bump
  776. if err = config.Runtime.CmdBuilder.Show(
  777. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx, dir, args...)); err != nil {
  778. return errors.New(gotext.Get("error making: %s", base.String()))
  779. }
  780. pkgdests, pkgVersion, errList := parsePackageList(ctx, dir)
  781. if errList != nil {
  782. return errList
  783. }
  784. isExplicit := false
  785. for _, b := range base {
  786. isExplicit = isExplicit || dp.Explicit.Get(b.Name)
  787. }
  788. if config.ReBuild == "no" || (config.ReBuild == "yes" && !isExplicit) {
  789. for _, split := range base {
  790. pkgdest, ok := pkgdests[split.Name]
  791. if !ok {
  792. return errors.New(gotext.Get("could not find PKGDEST for: %s", split.Name))
  793. }
  794. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  795. built = false
  796. } else if errStat != nil {
  797. return errStat
  798. }
  799. }
  800. } else {
  801. built = false
  802. }
  803. if cmdArgs.ExistsArg("needed") {
  804. installed := true
  805. for _, split := range base {
  806. installed = dp.AlpmExecutor.IsCorrectVersionInstalled(split.Name, pkgVersion)
  807. }
  808. if installed {
  809. err = config.Runtime.CmdBuilder.Show(
  810. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  811. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  812. if err != nil {
  813. return errors.New(gotext.Get("error making: %s", err))
  814. }
  815. fmt.Fprintln(os.Stdout, gotext.Get("%s is up to date -- skipping", text.Cyan(pkg+"-"+pkgVersion)))
  816. continue
  817. }
  818. }
  819. if built {
  820. err = config.Runtime.CmdBuilder.Show(
  821. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  822. dir, "-c", "--nobuild", "--noextract", "--ignorearch"))
  823. if err != nil {
  824. return errors.New(gotext.Get("error making: %s", err))
  825. }
  826. text.Warnln(gotext.Get("%s already made -- skipping build", text.Cyan(pkg+"-"+pkgVersion)))
  827. } else {
  828. args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
  829. if incompatible.Get(pkg) {
  830. args = append(args, "--ignorearch")
  831. }
  832. if errMake := config.Runtime.CmdBuilder.Show(
  833. config.Runtime.CmdBuilder.BuildMakepkgCmd(ctx,
  834. dir, args...)); errMake != nil {
  835. return errors.New(gotext.Get("error making: %s", base.String()))
  836. }
  837. }
  838. // conflicts have been checked so answer y for them
  839. if config.UseAsk && cmdArgs.ExistsArg("ask") {
  840. ask, _ := strconv.Atoi(cmdArgs.Options["ask"].First())
  841. uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
  842. cmdArgs.Options["ask"].Set(fmt.Sprint(uask))
  843. } else {
  844. for _, split := range base {
  845. if _, ok := conflicts[split.Name]; ok {
  846. settings.NoConfirm = false
  847. break
  848. }
  849. }
  850. }
  851. var errAdd error
  852. for _, split := range base {
  853. for suffix, optional := range map[string]bool{"": false, "-debug": true} {
  854. deps, exp, errAdd = doAddTarget(dp, localNamesCache, remoteNamesCache,
  855. arguments, cmdArgs, pkgdests, deps, exp, split.Name+suffix, optional)
  856. if errAdd != nil {
  857. return errAdd
  858. }
  859. }
  860. }
  861. var (
  862. mux sync.Mutex
  863. wg sync.WaitGroup
  864. )
  865. for _, pkg := range base {
  866. wg.Add(1)
  867. go config.Runtime.VCSStore.Update(ctx, pkg.Name, srcinfo.Source, &mux, &wg)
  868. }
  869. wg.Wait()
  870. }
  871. err = doInstall(ctx, arguments, cmdArgs, deps, exp)
  872. settings.NoConfirm = oldConfirm
  873. return err
  874. }
  875. func doInstall(ctx context.Context, arguments, cmdArgs *parser.Arguments, pkgDeps, pkgExp []string) error {
  876. if len(arguments.Targets) == 0 {
  877. return nil
  878. }
  879. if errShow := config.Runtime.CmdBuilder.Show(config.Runtime.CmdBuilder.BuildPacmanCmd(ctx,
  880. arguments, config.Runtime.Mode, settings.NoConfirm)); errShow != nil {
  881. return errShow
  882. }
  883. if errStore := config.Runtime.VCSStore.Save(); errStore != nil {
  884. fmt.Fprintln(os.Stderr, errStore)
  885. }
  886. if errDeps := asdeps(ctx, cmdArgs, pkgDeps); errDeps != nil {
  887. return errDeps
  888. }
  889. return asexp(ctx, cmdArgs, pkgExp)
  890. }
  891. func doAddTarget(dp *dep.Pool, localNamesCache, remoteNamesCache stringset.StringSet,
  892. arguments, cmdArgs *parser.Arguments, pkgdests map[string]string,
  893. deps, exp []string, name string, optional bool) (newDeps, newExp []string, err error) {
  894. pkgdest, ok := pkgdests[name]
  895. if !ok {
  896. if optional {
  897. return deps, exp, nil
  898. }
  899. return deps, exp, errors.New(gotext.Get("could not find PKGDEST for: %s", name))
  900. }
  901. if _, errStat := os.Stat(pkgdest); os.IsNotExist(errStat) {
  902. if optional {
  903. return deps, exp, nil
  904. }
  905. return deps, exp, errors.New(
  906. gotext.Get(
  907. "the PKGDEST for %s is listed by makepkg but does not exist: %s",
  908. name, pkgdest))
  909. }
  910. arguments.AddTarget(pkgdest)
  911. switch {
  912. case cmdArgs.ExistsArg("asdeps", "asdep"):
  913. deps = append(deps, name)
  914. case cmdArgs.ExistsArg("asexplicit", "asexp"):
  915. exp = append(exp, name)
  916. case !dp.Explicit.Get(name) && !localNamesCache.Get(name) && !remoteNamesCache.Get(name):
  917. deps = append(deps, name)
  918. }
  919. return deps, exp, nil
  920. }