install.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047
  1. package main
  2. import (
  3. "fmt"
  4. "os"
  5. "os/exec"
  6. "path/filepath"
  7. "strconv"
  8. "strings"
  9. "sync"
  10. gosrc "github.com/Morganamilo/go-srcinfo"
  11. alpm "github.com/jguer/go-alpm"
  12. )
  13. // Install handles package installs
  14. func install(parser *arguments) error {
  15. var err error
  16. var incompatible stringSet
  17. var do *depOrder
  18. var aurUp upSlice
  19. var repoUp upSlice
  20. var srcinfos map[string]*gosrc.Srcinfo
  21. warnings := &aurWarnings{}
  22. removeMake := false
  23. if mode == ModeAny || mode == ModeRepo {
  24. if config.CombinedUpgrade {
  25. if parser.existsArg("y", "refresh") {
  26. err = earlyRefresh(parser)
  27. if err != nil {
  28. return fmt.Errorf("Error refreshing databases")
  29. }
  30. }
  31. } else if parser.existsArg("y", "refresh") || parser.existsArg("u", "sysupgrade") || len(parser.targets) > 0 {
  32. err = earlyPacmanCall(parser)
  33. if err != nil {
  34. return err
  35. }
  36. }
  37. }
  38. //we may have done -Sy, our handle now has an old
  39. //database.
  40. err = initAlpmHandle()
  41. if err != nil {
  42. return err
  43. }
  44. _, _, localNames, remoteNames, err := filterPackages()
  45. if err != nil {
  46. return err
  47. }
  48. remoteNamesCache := sliceToStringSet(remoteNames)
  49. localNamesCache := sliceToStringSet(localNames)
  50. requestTargets := parser.copy().targets
  51. //create the arguments to pass for the repo install
  52. arguments := parser.copy()
  53. arguments.delArg("asdeps", "asdep")
  54. arguments.delArg("asexplicit", "asexp")
  55. arguments.op = "S"
  56. arguments.clearTargets()
  57. if mode == ModeAUR {
  58. arguments.delArg("u", "sysupgrade")
  59. }
  60. //if we are doing -u also request all packages needing update
  61. if parser.existsArg("u", "sysupgrade") {
  62. aurUp, repoUp, err = upList(warnings)
  63. if err != nil {
  64. return err
  65. }
  66. warnings.print()
  67. ignore, aurUp, err := upgradePkgs(aurUp, repoUp)
  68. if err != nil {
  69. return err
  70. }
  71. for _, up := range repoUp {
  72. if !ignore.get(up.Name) {
  73. requestTargets = append(requestTargets, up.Name)
  74. parser.addTarget(up.Name)
  75. }
  76. }
  77. for up := range aurUp {
  78. requestTargets = append(requestTargets, "aur/"+up)
  79. parser.addTarget("aur/" + up)
  80. }
  81. value, _, exists := cmdArgs.getArg("ignore")
  82. if len(ignore) > 0 {
  83. ignoreStr := strings.Join(ignore.toSlice(), ",")
  84. if exists {
  85. ignoreStr += "," + value
  86. }
  87. arguments.options["ignore"] = ignoreStr
  88. }
  89. }
  90. targets := sliceToStringSet(parser.targets)
  91. dp, err := getDepPool(requestTargets, warnings)
  92. if err != nil {
  93. return err
  94. }
  95. err = dp.CheckMissing()
  96. if err != nil {
  97. return err
  98. }
  99. if len(dp.Aur) == 0 {
  100. if !config.CombinedUpgrade {
  101. if parser.existsArg("u", "sysupgrade") {
  102. fmt.Println(" there is nothing to do")
  103. }
  104. return nil
  105. }
  106. parser.op = "S"
  107. parser.delArg("y", "refresh")
  108. parser.options["ignore"] = arguments.options["ignore"]
  109. return show(passToPacman(parser))
  110. }
  111. if len(dp.Aur) > 0 && 0 == os.Geteuid() {
  112. return fmt.Errorf(bold(red(arrow)) + " Refusing to install AUR Packages as root, Aborting.")
  113. }
  114. conflicts, err := dp.CheckConflicts()
  115. if err != nil {
  116. return err
  117. }
  118. do = getDepOrder(dp)
  119. if err != nil {
  120. return err
  121. }
  122. for _, pkg := range do.Repo {
  123. arguments.addTarget(pkg.DB().Name() + "/" + pkg.Name())
  124. }
  125. for _, pkg := range dp.Groups {
  126. arguments.addTarget(pkg)
  127. }
  128. if len(do.Aur) == 0 && len(arguments.targets) == 0 && (!parser.existsArg("u", "sysupgrade") || mode == ModeAUR) {
  129. fmt.Println(" there is nothing to do")
  130. return nil
  131. }
  132. do.Print()
  133. fmt.Println()
  134. if do.HasMake() {
  135. if config.RemoveMake == "yes" {
  136. removeMake = true
  137. } else if config.RemoveMake == "no" {
  138. removeMake = false
  139. } else if continueTask("Remove make dependencies after install?", false) {
  140. removeMake = true
  141. }
  142. }
  143. if config.CleanMenu {
  144. askClean := pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  145. toClean, err := cleanNumberMenu(do.Aur, remoteNamesCache, askClean)
  146. if err != nil {
  147. return err
  148. }
  149. cleanBuilds(toClean)
  150. }
  151. toSkip := pkgbuildsToSkip(do.Aur, targets)
  152. cloned, err := downloadPkgbuilds(do.Aur, toSkip)
  153. if err != nil {
  154. return err
  155. }
  156. var toDiff []Base
  157. var toEdit []Base
  158. if config.DiffMenu {
  159. pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  160. toDiff, err = diffNumberMenu(do.Aur, remoteNamesCache)
  161. if err != nil {
  162. return err
  163. }
  164. if len(toDiff) > 0 {
  165. err = showPkgbuildDiffs(toDiff, cloned)
  166. if err != nil {
  167. return err
  168. }
  169. }
  170. }
  171. if len(toDiff) > 0 {
  172. oldValue := config.NoConfirm
  173. config.NoConfirm = false
  174. fmt.Println()
  175. if !continueTask(bold(green("Proceed with install?")), true) {
  176. return fmt.Errorf("Aborting due to user")
  177. }
  178. config.NoConfirm = oldValue
  179. }
  180. err = mergePkgbuilds(do.Aur)
  181. if err != nil {
  182. return err
  183. }
  184. srcinfos, err = parseSrcinfoFiles(do.Aur, true)
  185. if err != nil {
  186. return err
  187. }
  188. if config.EditMenu {
  189. pkgbuildNumberMenu(do.Aur, remoteNamesCache)
  190. toEdit, err = editNumberMenu(do.Aur, remoteNamesCache)
  191. if err != nil {
  192. return err
  193. }
  194. if len(toEdit) > 0 {
  195. err = editPkgbuilds(toEdit, srcinfos)
  196. if err != nil {
  197. return err
  198. }
  199. }
  200. }
  201. if len(toEdit) > 0 {
  202. oldValue := config.NoConfirm
  203. config.NoConfirm = false
  204. fmt.Println()
  205. if !continueTask(bold(green("Proceed with install?")), true) {
  206. return fmt.Errorf("Aborting due to user")
  207. }
  208. config.NoConfirm = oldValue
  209. }
  210. incompatible, err = getIncompatible(do.Aur, srcinfos)
  211. if err != nil {
  212. return err
  213. }
  214. if config.PGPFetch {
  215. err = checkPgpKeys(do.Aur, srcinfos)
  216. if err != nil {
  217. return err
  218. }
  219. }
  220. if !config.CombinedUpgrade {
  221. arguments.delArg("u", "sysupgrade")
  222. }
  223. if len(arguments.targets) > 0 || arguments.existsArg("u") {
  224. err := show(passToPacman(arguments))
  225. if err != nil {
  226. return fmt.Errorf("Error installing repo packages")
  227. }
  228. depArguments := makeArguments()
  229. depArguments.addArg("D", "asdeps")
  230. expArguments := makeArguments()
  231. expArguments.addArg("D", "asexplicit")
  232. for _, pkg := range do.Repo {
  233. if !dp.Explicit.get(pkg.Name()) && !localNamesCache.get(pkg.Name()) && !remoteNamesCache.get(pkg.Name()) {
  234. depArguments.addTarget(pkg.Name())
  235. continue
  236. }
  237. if parser.existsArg("asdeps", "asdep") && dp.Explicit.get(pkg.Name()) {
  238. depArguments.addTarget(pkg.Name())
  239. } else if parser.existsArg("asexp", "asexplicit") && dp.Explicit.get(pkg.Name()) {
  240. expArguments.addTarget(pkg.Name())
  241. }
  242. }
  243. if len(depArguments.targets) > 0 {
  244. _, stderr, err := capture(passToPacman(depArguments))
  245. if err != nil {
  246. return fmt.Errorf("%s%s", stderr, err)
  247. }
  248. }
  249. if len(expArguments.targets) > 0 {
  250. _, stderr, err := capture(passToPacman(expArguments))
  251. if err != nil {
  252. return fmt.Errorf("%s%s", stderr, err)
  253. }
  254. }
  255. }
  256. go updateCompletion(false)
  257. err = downloadPkgbuildsSources(do.Aur, incompatible)
  258. if err != nil {
  259. return err
  260. }
  261. err = buildInstallPkgbuilds(dp, do, srcinfos, parser, incompatible, conflicts)
  262. if err != nil {
  263. return err
  264. }
  265. if removeMake {
  266. removeArguments := makeArguments()
  267. removeArguments.addArg("R", "u")
  268. for _, pkg := range do.getMake() {
  269. removeArguments.addTarget(pkg)
  270. }
  271. oldValue := config.NoConfirm
  272. config.NoConfirm = true
  273. err = show(passToPacman(removeArguments))
  274. config.NoConfirm = oldValue
  275. if err != nil {
  276. return err
  277. }
  278. }
  279. if config.CleanAfter {
  280. cleanBuilds(do.Aur)
  281. }
  282. return nil
  283. }
  284. func inRepos(syncDb alpm.DbList, pkg string) bool {
  285. target := toTarget(pkg)
  286. if target.Db == "aur" {
  287. return false
  288. } else if target.Db != "" {
  289. return true
  290. }
  291. _, err := syncDb.FindSatisfier(target.DepString())
  292. if err == nil {
  293. return true
  294. }
  295. _, err = syncDb.PkgCachebyGroup(target.Name)
  296. if err == nil {
  297. return true
  298. }
  299. return false
  300. }
  301. func earlyPacmanCall(parser *arguments) error {
  302. arguments := parser.copy()
  303. arguments.op = "S"
  304. targets := parser.targets
  305. parser.clearTargets()
  306. arguments.clearTargets()
  307. syncDb, err := alpmHandle.SyncDbs()
  308. if err != nil {
  309. return err
  310. }
  311. if mode == ModeRepo {
  312. arguments.targets = targets
  313. } else {
  314. alpmHandle.SetQuestionCallback(func(alpm.QuestionAny) {})
  315. //seperate aur and repo targets
  316. for _, target := range targets {
  317. if inRepos(syncDb, target) {
  318. arguments.addTarget(target)
  319. } else {
  320. parser.addTarget(target)
  321. }
  322. }
  323. }
  324. if parser.existsArg("y", "refresh") || parser.existsArg("u", "sysupgrade") || len(arguments.targets) > 0 {
  325. err = show(passToPacman(arguments))
  326. if err != nil {
  327. return fmt.Errorf("Error installing repo packages")
  328. }
  329. }
  330. return nil
  331. }
  332. func earlyRefresh(parser *arguments) error {
  333. arguments := parser.copy()
  334. parser.delArg("y", "refresh")
  335. arguments.delArg("u", "sysupgrade")
  336. arguments.delArg("s", "search")
  337. arguments.delArg("i", "info")
  338. arguments.delArg("l", "list")
  339. arguments.clearTargets()
  340. return show(passToPacman(arguments))
  341. }
  342. func getIncompatible(bases []Base, srcinfos map[string]*gosrc.Srcinfo) (stringSet, error) {
  343. incompatible := make(stringSet)
  344. basesMap := make(map[string]Base)
  345. alpmArch, err := alpmHandle.Arch()
  346. if err != nil {
  347. return nil, err
  348. }
  349. nextpkg:
  350. for _, base := range bases {
  351. for _, arch := range srcinfos[base.Pkgbase()].Arch {
  352. if arch == "any" || arch == alpmArch {
  353. continue nextpkg
  354. }
  355. }
  356. incompatible.set(base.Pkgbase())
  357. basesMap[base.Pkgbase()] = base
  358. }
  359. if len(incompatible) > 0 {
  360. fmt.Println()
  361. fmt.Print(bold(yellow(arrow)) + " The following packages are not compatible with your architecture:")
  362. for pkg := range incompatible {
  363. fmt.Print(" " + cyan((basesMap[pkg].String())))
  364. }
  365. fmt.Println()
  366. if !continueTask("Try to build them anyway?", true) {
  367. return nil, fmt.Errorf("Aborting due to user")
  368. }
  369. }
  370. return incompatible, nil
  371. }
  372. func parsePackageList(dir string) (map[string]string, string, error) {
  373. stdout, stderr, err := capture(passToMakepkg(dir, "--packagelist"))
  374. if err != nil {
  375. return nil, "", fmt.Errorf("%s%s", stderr, err)
  376. }
  377. var version string
  378. lines := strings.Split(stdout, "\n")
  379. pkgdests := make(map[string]string)
  380. for _, line := range lines {
  381. if line == "" {
  382. continue
  383. }
  384. fileName := filepath.Base(line)
  385. split := strings.Split(fileName, "-")
  386. if len(split) < 4 {
  387. return nil, "", fmt.Errorf("Can not find package name : %s", split)
  388. }
  389. // pkgname-pkgver-pkgrel-arch.pkgext
  390. // This assumes 3 dashes after the pkgname, Will cause an error
  391. // if the PKGEXT contains a dash. Please no one do that.
  392. pkgname := strings.Join(split[:len(split)-3], "-")
  393. version = strings.Join(split[len(split)-3:len(split)-2], "-")
  394. pkgdests[pkgname] = line
  395. }
  396. return pkgdests, version, nil
  397. }
  398. func pkgbuildNumberMenu(bases []Base, installed stringSet) bool {
  399. toPrint := ""
  400. askClean := false
  401. for n, base := range bases {
  402. pkg := base.Pkgbase()
  403. dir := filepath.Join(config.BuildDir, pkg)
  404. toPrint += fmt.Sprintf(magenta("%3d")+" %-40s", len(bases)-n,
  405. bold(base.String()))
  406. anyInstalled := false
  407. for _, b := range base {
  408. anyInstalled = anyInstalled || installed.get(b.Name)
  409. }
  410. if anyInstalled {
  411. toPrint += bold(green(" (Installed)"))
  412. }
  413. if _, err := os.Stat(dir); !os.IsNotExist(err) {
  414. toPrint += bold(green(" (Build Files Exist)"))
  415. askClean = true
  416. }
  417. toPrint += "\n"
  418. }
  419. fmt.Print(toPrint)
  420. return askClean
  421. }
  422. func cleanNumberMenu(bases []Base, installed stringSet, hasClean bool) ([]Base, error) {
  423. toClean := make([]Base, 0)
  424. if !hasClean {
  425. return toClean, nil
  426. }
  427. fmt.Println(bold(green(arrow + " Packages to cleanBuild?")))
  428. fmt.Println(bold(green(arrow) + cyan(" [N]one ") + "[A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)"))
  429. fmt.Print(bold(green(arrow + " ")))
  430. cleanInput, err := getInput(config.AnswerClean)
  431. if err != nil {
  432. return nil, err
  433. }
  434. cInclude, cExclude, cOtherInclude, cOtherExclude := parseNumberMenu(cleanInput)
  435. cIsInclude := len(cExclude) == 0 && len(cOtherExclude) == 0
  436. if cOtherInclude.get("abort") || cOtherInclude.get("ab") {
  437. return nil, fmt.Errorf("Aborting due to user")
  438. }
  439. if !cOtherInclude.get("n") && !cOtherInclude.get("none") {
  440. for i, base := range bases {
  441. pkg := base.Pkgbase()
  442. anyInstalled := false
  443. for _, b := range base {
  444. anyInstalled = anyInstalled || installed.get(b.Name)
  445. }
  446. dir := filepath.Join(config.BuildDir, pkg)
  447. if _, err := os.Stat(dir); os.IsNotExist(err) {
  448. continue
  449. }
  450. if !cIsInclude && cExclude.get(len(bases)-i) {
  451. continue
  452. }
  453. if anyInstalled && (cOtherInclude.get("i") || cOtherInclude.get("installed")) {
  454. toClean = append(toClean, base)
  455. continue
  456. }
  457. if !anyInstalled && (cOtherInclude.get("no") || cOtherInclude.get("notinstalled")) {
  458. toClean = append(toClean, base)
  459. continue
  460. }
  461. if cOtherInclude.get("a") || cOtherInclude.get("all") {
  462. toClean = append(toClean, base)
  463. continue
  464. }
  465. if cIsInclude && (cInclude.get(len(bases)-i) || cOtherInclude.get(pkg)) {
  466. toClean = append(toClean, base)
  467. continue
  468. }
  469. if !cIsInclude && (!cExclude.get(len(bases)-i) && !cOtherExclude.get(pkg)) {
  470. toClean = append(toClean, base)
  471. continue
  472. }
  473. }
  474. }
  475. return toClean, nil
  476. }
  477. func editNumberMenu(bases []Base, installed stringSet) ([]Base, error) {
  478. return editDiffNumberMenu(bases, installed, false)
  479. }
  480. func diffNumberMenu(bases []Base, installed stringSet) ([]Base, error) {
  481. return editDiffNumberMenu(bases, installed, true)
  482. }
  483. func editDiffNumberMenu(bases []Base, installed stringSet, diff bool) ([]Base, error) {
  484. toEdit := make([]Base, 0)
  485. var editInput string
  486. var err error
  487. fmt.Println(bold(green(arrow) + cyan(" [N]one ") + "[A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)"))
  488. if diff {
  489. fmt.Println(bold(green(arrow + " Diffs to show?")))
  490. fmt.Print(bold(green(arrow + " ")))
  491. editInput, err = getInput(config.AnswerDiff)
  492. if err != nil {
  493. return nil, err
  494. }
  495. } else {
  496. fmt.Println(bold(green(arrow + " PKGBUILDs to edit?")))
  497. fmt.Print(bold(green(arrow + " ")))
  498. editInput, err = getInput(config.AnswerEdit)
  499. if err != nil {
  500. return nil, err
  501. }
  502. }
  503. eInclude, eExclude, eOtherInclude, eOtherExclude := parseNumberMenu(editInput)
  504. eIsInclude := len(eExclude) == 0 && len(eOtherExclude) == 0
  505. if eOtherInclude.get("abort") || eOtherInclude.get("ab") {
  506. return nil, fmt.Errorf("Aborting due to user")
  507. }
  508. if !eOtherInclude.get("n") && !eOtherInclude.get("none") {
  509. for i, base := range bases {
  510. pkg := base.Pkgbase()
  511. anyInstalled := false
  512. for _, b := range base {
  513. anyInstalled = anyInstalled || installed.get(b.Name)
  514. }
  515. if !eIsInclude && eExclude.get(len(bases)-i) {
  516. continue
  517. }
  518. if anyInstalled && (eOtherInclude.get("i") || eOtherInclude.get("installed")) {
  519. toEdit = append(toEdit, base)
  520. continue
  521. }
  522. if !anyInstalled && (eOtherInclude.get("no") || eOtherInclude.get("notinstalled")) {
  523. toEdit = append(toEdit, base)
  524. continue
  525. }
  526. if eOtherInclude.get("a") || eOtherInclude.get("all") {
  527. toEdit = append(toEdit, base)
  528. continue
  529. }
  530. if eIsInclude && (eInclude.get(len(bases)-i) || eOtherInclude.get(pkg)) {
  531. toEdit = append(toEdit, base)
  532. }
  533. if !eIsInclude && (!eExclude.get(len(bases)-i) && !eOtherExclude.get(pkg)) {
  534. toEdit = append(toEdit, base)
  535. }
  536. }
  537. }
  538. return toEdit, nil
  539. }
  540. func cleanBuilds(bases []Base) {
  541. for i, base := range bases {
  542. dir := filepath.Join(config.BuildDir, base.Pkgbase())
  543. fmt.Printf(bold(cyan("::")+" Deleting (%d/%d): %s\n"), i+1, len(bases), cyan(dir))
  544. os.RemoveAll(dir)
  545. }
  546. }
  547. func showPkgbuildDiffs(bases []Base, cloned stringSet) error {
  548. for _, base := range bases {
  549. pkg := base.Pkgbase()
  550. dir := filepath.Join(config.BuildDir, pkg)
  551. if shouldUseGit(dir) {
  552. start := "HEAD"
  553. if cloned.get(pkg) {
  554. start = gitEmptyTree
  555. } else {
  556. hasDiff, err := gitHasDiff(config.BuildDir, pkg)
  557. if err != nil {
  558. return err
  559. }
  560. if !hasDiff {
  561. fmt.Printf("%s %s: %s\n", bold(yellow(arrow)), cyan(base.String()), bold("No changes -- skipping"))
  562. continue
  563. }
  564. }
  565. args := []string{"diff", start + "..HEAD@{upstream}", "--src-prefix", dir + "/", "--dst-prefix", dir + "/", "--", ".", ":(exclude).SRCINFO"}
  566. if useColor {
  567. args = append(args, "--color=always")
  568. } else {
  569. args = append(args, "--color=never")
  570. }
  571. err := show(passToGit(dir, args...))
  572. if err != nil {
  573. return err
  574. }
  575. } else {
  576. args := []string{"diff"}
  577. if useColor {
  578. args = append(args, "--color=always")
  579. } else {
  580. args = append(args, "--color=never")
  581. }
  582. args = append(args, "--no-index", "/var/empty", dir)
  583. // git always returns 1. why? I have no idea
  584. show(passToGit(dir, args...))
  585. }
  586. }
  587. return nil
  588. }
  589. func editPkgbuilds(bases []Base, srcinfos map[string]*gosrc.Srcinfo) error {
  590. pkgbuilds := make([]string, 0, len(bases))
  591. for _, base := range bases {
  592. pkg := base.Pkgbase()
  593. dir := filepath.Join(config.BuildDir, pkg)
  594. pkgbuilds = append(pkgbuilds, filepath.Join(dir, "PKGBUILD"))
  595. for _, splitPkg := range srcinfos[pkg].SplitPackages() {
  596. if splitPkg.Install != "" {
  597. pkgbuilds = append(pkgbuilds, filepath.Join(dir, splitPkg.Install))
  598. }
  599. }
  600. }
  601. if len(pkgbuilds) > 0 {
  602. editor, editorArgs := editor()
  603. editorArgs = append(editorArgs, pkgbuilds...)
  604. editcmd := exec.Command(editor, editorArgs...)
  605. editcmd.Stdin, editcmd.Stdout, editcmd.Stderr = os.Stdin, os.Stdout, os.Stderr
  606. err := editcmd.Run()
  607. if err != nil {
  608. return fmt.Errorf("Editor did not exit successfully, Aborting: %s", err)
  609. }
  610. }
  611. return nil
  612. }
  613. func parseSrcinfoFiles(bases []Base, errIsFatal bool) (map[string]*gosrc.Srcinfo, error) {
  614. srcinfos := make(map[string]*gosrc.Srcinfo)
  615. for k, base := range bases {
  616. pkg := base.Pkgbase()
  617. dir := filepath.Join(config.BuildDir, pkg)
  618. str := bold(cyan("::") + " Parsing SRCINFO (%d/%d): %s\n")
  619. fmt.Printf(str, k+1, len(bases), cyan(base.String()))
  620. pkgbuild, err := gosrc.ParseFile(filepath.Join(dir, ".SRCINFO"))
  621. if err != nil {
  622. if !errIsFatal {
  623. fmt.Printf("failed to parse %s -- skipping: %s\n", base.String(), err)
  624. continue
  625. }
  626. return nil, fmt.Errorf("failed to parse %s: %s", base.String(), err)
  627. }
  628. srcinfos[pkg] = pkgbuild
  629. }
  630. return srcinfos, nil
  631. }
  632. func pkgbuildsToSkip(bases []Base, targets stringSet) stringSet {
  633. toSkip := make(stringSet)
  634. for _, base := range bases {
  635. isTarget := false
  636. for _, pkg := range base {
  637. isTarget = isTarget || targets.get(pkg.Name)
  638. }
  639. if config.ReDownload == "no" || (config.ReDownload == "yes" && isTarget) {
  640. dir := filepath.Join(config.BuildDir, base.Pkgbase(), ".SRCINFO")
  641. pkgbuild, err := gosrc.ParseFile(dir)
  642. if err == nil {
  643. if alpm.VerCmp(pkgbuild.Version(), base.Version()) >= 0 {
  644. toSkip.set(base.Pkgbase())
  645. }
  646. }
  647. }
  648. }
  649. return toSkip
  650. }
  651. func mergePkgbuilds(bases []Base) error {
  652. for _, base := range bases {
  653. if shouldUseGit(filepath.Join(config.BuildDir, base.Pkgbase())) {
  654. err := gitMerge(config.BuildDir, base.Pkgbase())
  655. if err != nil {
  656. return err
  657. }
  658. }
  659. }
  660. return nil
  661. }
  662. func downloadPkgbuilds(bases []Base, toSkip stringSet) (stringSet, error) {
  663. cloned := make(stringSet)
  664. downloaded := 0
  665. var wg sync.WaitGroup
  666. var mux sync.Mutex
  667. var errs MultiError
  668. download := func(k int, base Base) {
  669. defer wg.Done()
  670. pkg := base.Pkgbase()
  671. if toSkip.get(pkg) {
  672. mux.Lock()
  673. downloaded++
  674. str := bold(cyan("::") + " PKGBUILD up to date, Skipping (%d/%d): %s\n")
  675. fmt.Printf(str, downloaded, len(bases), cyan(base.String()))
  676. mux.Unlock()
  677. return
  678. }
  679. if shouldUseGit(filepath.Join(config.BuildDir, pkg)) {
  680. clone, err := gitDownload(baseURL+"/"+pkg+".git", config.BuildDir, pkg)
  681. if err != nil {
  682. errs.Add(err)
  683. return
  684. }
  685. if clone {
  686. mux.Lock()
  687. cloned.set(pkg)
  688. mux.Unlock()
  689. }
  690. } else {
  691. err := downloadAndUnpack(baseURL+base.URLPath(), config.BuildDir)
  692. if err != nil {
  693. errs.Add(err)
  694. return
  695. }
  696. }
  697. mux.Lock()
  698. downloaded++
  699. str := bold(cyan("::") + " Downloaded PKGBUILD (%d/%d): %s\n")
  700. fmt.Printf(str, downloaded, len(bases), cyan(base.String()))
  701. mux.Unlock()
  702. }
  703. for k, base := range bases {
  704. wg.Add(1)
  705. go download(k, base)
  706. }
  707. wg.Wait()
  708. return cloned, errs.Return()
  709. }
  710. func downloadPkgbuildsSources(bases []Base, incompatible stringSet) (err error) {
  711. for _, base := range bases {
  712. pkg := base.Pkgbase()
  713. dir := filepath.Join(config.BuildDir, pkg)
  714. args := []string{"--verifysource", "-Ccf"}
  715. if incompatible.get(pkg) {
  716. args = append(args, "--ignorearch")
  717. }
  718. err = show(passToMakepkg(dir, args...))
  719. if err != nil {
  720. return fmt.Errorf("Error downloading sources: %s", cyan(base.String()))
  721. }
  722. }
  723. return
  724. }
  725. func buildInstallPkgbuilds(dp *depPool, do *depOrder, srcinfos map[string]*gosrc.Srcinfo, parser *arguments, incompatible stringSet, conflicts mapStringSet) error {
  726. for _, base := range do.Aur {
  727. pkg := base.Pkgbase()
  728. dir := filepath.Join(config.BuildDir, pkg)
  729. built := true
  730. srcinfo := srcinfos[pkg]
  731. args := []string{"--nobuild", "-fC"}
  732. if incompatible.get(pkg) {
  733. args = append(args, "--ignorearch")
  734. }
  735. //pkgver bump
  736. err := show(passToMakepkg(dir, args...))
  737. if err != nil {
  738. return fmt.Errorf("Error making: %s", base.String())
  739. }
  740. pkgdests, version, err := parsePackageList(dir)
  741. if err != nil {
  742. return err
  743. }
  744. isExplicit := false
  745. for _, b := range base {
  746. isExplicit = isExplicit || dp.Explicit.get(b.Name)
  747. }
  748. if config.ReBuild == "no" || (config.ReBuild == "yes" && isExplicit) {
  749. for _, split := range base {
  750. pkgdest, ok := pkgdests[split.Name]
  751. if !ok {
  752. return fmt.Errorf("Could not find PKGDEST for: %s", split.Name)
  753. }
  754. _, err := os.Stat(pkgdest)
  755. if os.IsNotExist(err) {
  756. built = false
  757. } else if err != nil {
  758. return err
  759. }
  760. }
  761. } else {
  762. built = false
  763. }
  764. if built {
  765. fmt.Println(bold(yellow(arrow)),
  766. cyan(pkg+"-"+version)+bold(" Already made -- skipping build"))
  767. } else {
  768. args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
  769. if incompatible.get(pkg) {
  770. args = append(args, "--ignorearch")
  771. }
  772. err := show(passToMakepkg(dir, args...))
  773. if err != nil {
  774. return fmt.Errorf("Error making: %s", base.String())
  775. }
  776. }
  777. arguments := parser.copy()
  778. arguments.clearTargets()
  779. arguments.op = "U"
  780. arguments.delArg("confirm")
  781. arguments.delArg("noconfirm")
  782. arguments.delArg("c", "clean")
  783. arguments.delArg("q", "quiet")
  784. arguments.delArg("q", "quiet")
  785. arguments.delArg("y", "refresh")
  786. arguments.delArg("u", "sysupgrade")
  787. arguments.delArg("w", "downloadonly")
  788. oldConfirm := config.NoConfirm
  789. //conflicts have been checked so answer y for them
  790. if config.UseAsk {
  791. ask, _ := strconv.Atoi(cmdArgs.globals["ask"])
  792. uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
  793. cmdArgs.globals["ask"] = fmt.Sprint(uask)
  794. } else {
  795. conflict := false
  796. for _, split := range base {
  797. if _, ok := conflicts[split.Name]; ok {
  798. conflict = true
  799. }
  800. }
  801. if !conflict {
  802. config.NoConfirm = true
  803. }
  804. }
  805. depArguments := makeArguments()
  806. depArguments.addArg("D", "asdeps")
  807. expArguments := makeArguments()
  808. expArguments.addArg("D", "asexplicit")
  809. //remotenames: names of all non repo packages on the system
  810. _, _, localNames, remoteNames, err := filterPackages()
  811. if err != nil {
  812. return err
  813. }
  814. //cache as a stringset. maybe make it return a string set in the first
  815. //place
  816. remoteNamesCache := sliceToStringSet(remoteNames)
  817. localNamesCache := sliceToStringSet(localNames)
  818. for _, split := range base {
  819. pkgdest, ok := pkgdests[split.Name]
  820. if !ok {
  821. return fmt.Errorf("Could not find PKGDEST for: %s", split.Name)
  822. }
  823. arguments.addTarget(pkgdest)
  824. if !dp.Explicit.get(split.Name) && !localNamesCache.get(split.Name) && !remoteNamesCache.get(split.Name) {
  825. depArguments.addTarget(split.Name)
  826. }
  827. if dp.Explicit.get(split.Name) {
  828. if parser.existsArg("asdeps", "asdep") {
  829. depArguments.addTarget(split.Name)
  830. } else if parser.existsArg("asexplicit", "asexp") {
  831. expArguments.addTarget(split.Name)
  832. }
  833. }
  834. }
  835. err = show(passToPacman(arguments))
  836. if err != nil {
  837. return err
  838. }
  839. var mux sync.Mutex
  840. var wg sync.WaitGroup
  841. for _, pkg := range base {
  842. wg.Add(1)
  843. go updateVCSData(pkg.Name, srcinfo.Source, &mux, &wg)
  844. }
  845. wg.Wait()
  846. err = saveVCSInfo()
  847. if err != nil {
  848. fmt.Println(err)
  849. }
  850. if len(depArguments.targets) > 0 {
  851. _, stderr, err := capture(passToPacman(depArguments))
  852. if err != nil {
  853. return fmt.Errorf("%s%s", stderr, err)
  854. }
  855. }
  856. config.NoConfirm = oldConfirm
  857. }
  858. return nil
  859. }