install.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843
  1. package main
  2. import (
  3. "fmt"
  4. "os"
  5. "os/exec"
  6. "path/filepath"
  7. "strconv"
  8. "strings"
  9. alpm "github.com/jguer/go-alpm"
  10. rpc "github.com/mikkeloscar/aur"
  11. gopkg "github.com/mikkeloscar/gopkgbuild"
  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 toClean []*rpc.Pkg
  19. var toEdit []*rpc.Pkg
  20. var aurUp upSlice
  21. var repoUp upSlice
  22. requestTargets := parser.copy().targets
  23. warnings := &aurWarnings{}
  24. removeMake := false
  25. srcinfosStale := make(map[string]*gopkg.PKGBUILD)
  26. //remotenames: names of all non repo packages on the system
  27. _, _, localNames, remoteNames, err := filterPackages()
  28. if err != nil {
  29. return err
  30. }
  31. //cache as a stringset. maybe make it return a string set in the first
  32. //place
  33. remoteNamesCache := sliceToStringSet(remoteNames)
  34. localNamesCache := sliceToStringSet(localNames)
  35. //create the arguments to pass for the repo install
  36. arguments := parser.copy()
  37. arguments.delArg("y", "refresh")
  38. arguments.delArg("asdeps", "asdep")
  39. arguments.delArg("asexplicit", "asexp")
  40. arguments.op = "S"
  41. arguments.clearTargets()
  42. if mode == ModeAUR {
  43. arguments.delArg("u", "sysupgrade")
  44. }
  45. //if we are doing -u also request all packages needing update
  46. if parser.existsArg("u", "sysupgrade") {
  47. aurUp, repoUp, err = upList(warnings)
  48. if err != nil {
  49. return err
  50. }
  51. warnings.print()
  52. ignore, aurUp, err := upgradePkgs(aurUp, repoUp)
  53. if err != nil {
  54. return err
  55. }
  56. for _, up := range repoUp {
  57. if !ignore.get(up.Name) {
  58. requestTargets = append(requestTargets, up.Name)
  59. parser.addTarget(up.Name)
  60. }
  61. }
  62. for up := range aurUp {
  63. requestTargets = append(requestTargets, up)
  64. }
  65. value, _, exists := cmdArgs.getArg("ignore")
  66. if len(ignore) > 0 {
  67. ignoreStr := strings.Join(ignore.toSlice(), ",")
  68. if exists {
  69. ignoreStr += "," + value
  70. }
  71. arguments.options["ignore"] = ignoreStr
  72. }
  73. fmt.Println()
  74. for pkg := range aurUp {
  75. parser.addTarget(pkg)
  76. }
  77. }
  78. targets := sliceToStringSet(parser.targets)
  79. dp, err := getDepPool(requestTargets, warnings)
  80. if err != nil {
  81. return err
  82. }
  83. err = dp.CheckMissing()
  84. if err != nil {
  85. return err
  86. }
  87. err = dp.CheckConflicts()
  88. if err != nil {
  89. return err
  90. }
  91. hasAur := len(dp.Aur) > 0
  92. if hasAur && 0 == os.Geteuid() {
  93. return fmt.Errorf(bold(red(arrow)) + " Refusing to install AUR Packages as root, Aborting.")
  94. }
  95. do = getDepOrder(dp)
  96. if err != nil {
  97. return err
  98. }
  99. for _, pkg := range do.Repo {
  100. arguments.addTarget(pkg.DB().Name() + "/" + pkg.Name())
  101. }
  102. for _, pkg := range dp.Groups {
  103. arguments.addTarget(pkg)
  104. }
  105. if len(do.Aur) == 0 && len(arguments.targets) == 0 && (!parser.existsArg("u", "sysupgrade") || mode == ModeAUR) {
  106. fmt.Println("There is nothing to do")
  107. return nil
  108. }
  109. if hasAur {
  110. hasAur = len(do.Aur) != 0
  111. do.Print()
  112. fmt.Println()
  113. if do.HasMake() {
  114. if !continueTask("Remove make dependencies after install?", "yY") {
  115. removeMake = true
  116. }
  117. }
  118. toClean, toEdit, err = cleanEditNumberMenu(do.Aur, do.Bases, remoteNamesCache)
  119. if err != nil {
  120. return err
  121. }
  122. cleanBuilds(toClean)
  123. oldHashes, err := getHashes(do.Aur)
  124. if err != nil {
  125. return err
  126. }
  127. toSkip := pkgBuildsToSkip(do.Aur, targets)
  128. err = downloadPkgBuilds(do.Aur, do.Bases, toSkip)
  129. if err != nil {
  130. return err
  131. }
  132. err = mergePkgBuilds(do.Aur)
  133. if err != nil {
  134. return err
  135. }
  136. if len(toEdit) > 0 {
  137. if config.ShowDiffs {
  138. err = showPkgBuildDiffs(toEdit, do.Bases, oldHashes)
  139. } else {
  140. err = editPkgBuilds(toEdit, do.Bases, oldHashes)
  141. }
  142. if err != nil {
  143. return err
  144. }
  145. oldValue := config.NoConfirm
  146. config.NoConfirm = false
  147. if !continueTask(bold(green("Proceed with install?")), "nN") {
  148. return fmt.Errorf("Aborting due to user")
  149. }
  150. config.NoConfirm = oldValue
  151. }
  152. //initial srcinfo parse before pkgver() bump
  153. err = parseSRCINFOFiles(do.Aur, srcinfosStale, do.Bases)
  154. if err != nil {
  155. return err
  156. }
  157. incompatible, err = getIncompatible(do.Aur, srcinfosStale, do.Bases)
  158. if err != nil {
  159. return err
  160. }
  161. if config.PGPFetch {
  162. err = checkPgpKeys(do.Aur, do.Bases, srcinfosStale)
  163. if err != nil {
  164. return err
  165. }
  166. }
  167. }
  168. if len(arguments.targets) > 0 || arguments.existsArg("u") {
  169. err := passToPacman(arguments)
  170. if err != nil {
  171. return fmt.Errorf("Error installing repo packages")
  172. }
  173. depArguments := makeArguments()
  174. depArguments.addArg("D", "asdeps")
  175. expArguments := makeArguments()
  176. expArguments.addArg("D", "asexplicit")
  177. for _, pkg := range do.Repo {
  178. if !dp.Explicit.get(pkg.Name()) && !localNamesCache.get(pkg.Name()) && !remoteNamesCache.get(pkg.Name()) {
  179. depArguments.addTarget(pkg.Name())
  180. continue
  181. }
  182. if parser.existsArg("asdeps", "asdep") && dp.Explicit.get(pkg.Name()) {
  183. depArguments.addTarget(pkg.Name())
  184. } else if parser.existsArg("asexp", "asexplicit") && dp.Explicit.get(pkg.Name()) {
  185. expArguments.addTarget(pkg.Name())
  186. }
  187. }
  188. if len(depArguments.targets) > 0 {
  189. _, stderr, err := passToPacmanCapture(depArguments)
  190. if err != nil {
  191. return fmt.Errorf("%s%s", stderr, err)
  192. }
  193. }
  194. if len(expArguments.targets) > 0 {
  195. _, stderr, err := passToPacmanCapture(expArguments)
  196. if err != nil {
  197. return fmt.Errorf("%s%s", stderr, err)
  198. }
  199. }
  200. }
  201. if hasAur {
  202. //conflicts have been checked so answer y for them
  203. ask, _ := strconv.Atoi(cmdArgs.globals["ask"])
  204. uask := alpm.QuestionType(ask) | alpm.QuestionTypeConflictPkg
  205. cmdArgs.globals["ask"] = fmt.Sprint(uask)
  206. err = downloadPkgBuildsSources(do.Aur, do.Bases, incompatible)
  207. if err != nil {
  208. return err
  209. }
  210. err = buildInstallPkgBuilds(dp, do, srcinfosStale, parser, incompatible)
  211. if err != nil {
  212. return err
  213. }
  214. if removeMake {
  215. removeArguments := makeArguments()
  216. removeArguments.addArg("R", "u")
  217. for _, pkg := range do.getMake() {
  218. removeArguments.addTarget(pkg)
  219. }
  220. oldValue := config.NoConfirm
  221. config.NoConfirm = true
  222. err = passToPacman(removeArguments)
  223. config.NoConfirm = oldValue
  224. if err != nil {
  225. return err
  226. }
  227. }
  228. if config.CleanAfter {
  229. clean(do.Aur)
  230. }
  231. return nil
  232. }
  233. return nil
  234. }
  235. func getIncompatible(pkgs []*rpc.Pkg, srcinfos map[string]*gopkg.PKGBUILD, bases map[string][]*rpc.Pkg) (stringSet, error) {
  236. incompatible := make(stringSet)
  237. alpmArch, err := alpmHandle.Arch()
  238. if err != nil {
  239. return nil, err
  240. }
  241. nextpkg:
  242. for _, pkg := range pkgs {
  243. for _, arch := range srcinfos[pkg.PackageBase].Arch {
  244. if arch == "any" || arch == alpmArch {
  245. continue nextpkg
  246. }
  247. }
  248. incompatible.set(pkg.PackageBase)
  249. }
  250. if len(incompatible) > 0 {
  251. fmt.Println()
  252. fmt.Print(bold(yellow(arrow)) + " The following packages are not compatible with your architecture:")
  253. for pkg := range incompatible {
  254. fmt.Print(" " + cyan(pkg))
  255. }
  256. fmt.Println()
  257. if !continueTask("Try to build them anyway?", "nN") {
  258. return nil, fmt.Errorf("Aborting due to user")
  259. }
  260. }
  261. return incompatible, nil
  262. }
  263. func parsePackageList(dir string) (map[string]string, string, error) {
  264. stdout, stderr, err := passToMakepkgCapture(dir, "--packagelist")
  265. if err != nil {
  266. return nil, "", fmt.Errorf("%s%s", stderr, err)
  267. }
  268. var version string
  269. lines := strings.Split(stdout, "\n")
  270. pkgdests := make(map[string]string)
  271. for _, line := range lines {
  272. if line == "" {
  273. continue
  274. }
  275. fileName := filepath.Base(line)
  276. split := strings.Split(fileName, "-")
  277. if len(split) < 4 {
  278. return nil, "", fmt.Errorf("Can not find package name : %s", split)
  279. }
  280. // pkgname-pkgver-pkgrel-arch.pkgext
  281. // This assumes 3 dashes after the pkgname, Will cause an error
  282. // if the PKGEXT contains a dash. Please no one do that.
  283. pkgname := strings.Join(split[:len(split)-3], "-")
  284. version = strings.Join(split[len(split)-3:len(split)-2], "-")
  285. pkgdests[pkgname] = line
  286. }
  287. return pkgdests, version, nil
  288. }
  289. func cleanEditNumberMenu(pkgs []*rpc.Pkg, bases map[string][]*rpc.Pkg, installed stringSet) ([]*rpc.Pkg, []*rpc.Pkg, error) {
  290. toPrint := ""
  291. askClean := false
  292. toClean := make([]*rpc.Pkg, 0)
  293. toEdit := make([]*rpc.Pkg, 0)
  294. for n, pkg := range pkgs {
  295. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  296. toPrint += fmt.Sprintf(magenta("%3d")+" %-40s", len(pkgs)-n,
  297. bold(formatPkgbase(pkg, bases)))
  298. if installed.get(pkg.Name) {
  299. toPrint += bold(green(" (Installed)"))
  300. }
  301. if _, err := os.Stat(dir); !os.IsNotExist(err) {
  302. toPrint += bold(green(" (Build Files Exist)"))
  303. askClean = true
  304. }
  305. toPrint += "\n"
  306. }
  307. fmt.Print(toPrint)
  308. if askClean {
  309. fmt.Println(bold(green(arrow + " Packages to cleanBuild?")))
  310. fmt.Println(bold(green(arrow) + cyan(" [N]one ") + "[A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)"))
  311. fmt.Print(bold(green(arrow + " ")))
  312. cleanInput, err := getInput(config.AnswerClean)
  313. if err != nil {
  314. return nil, nil, err
  315. }
  316. cInclude, cExclude, cOtherInclude, cOtherExclude := parseNumberMenu(cleanInput)
  317. cIsInclude := len(cExclude) == 0 && len(cOtherExclude) == 0
  318. if cOtherInclude.get("abort") || cOtherInclude.get("ab") {
  319. return nil, nil, fmt.Errorf("Aborting due to user")
  320. }
  321. if !cOtherInclude.get("n") && !cOtherInclude.get("none") {
  322. for i, pkg := range pkgs {
  323. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  324. if _, err := os.Stat(dir); os.IsNotExist(err) {
  325. continue
  326. }
  327. if !cIsInclude && cExclude.get(len(pkgs)-i) {
  328. continue
  329. }
  330. if installed.get(pkg.Name) && (cOtherInclude.get("i") || cOtherInclude.get("installed")) {
  331. toClean = append(toClean, pkg)
  332. continue
  333. }
  334. if !installed.get(pkg.Name) && (cOtherInclude.get("no") || cOtherInclude.get("notinstalled")) {
  335. toClean = append(toClean, pkg)
  336. continue
  337. }
  338. if cOtherInclude.get("a") || cOtherInclude.get("all") {
  339. toClean = append(toClean, pkg)
  340. continue
  341. }
  342. if cIsInclude && (cInclude.get(len(pkgs)-i) || cOtherInclude.get(pkg.PackageBase)) {
  343. toClean = append(toClean, pkg)
  344. continue
  345. }
  346. if !cIsInclude && (!cExclude.get(len(pkgs)-i) && !cOtherExclude.get(pkg.PackageBase)) {
  347. toClean = append(toClean, pkg)
  348. continue
  349. }
  350. }
  351. }
  352. }
  353. if config.ShowDiffs {
  354. fmt.Println(bold(green(arrow + " Diffs to show?")))
  355. } else {
  356. fmt.Println(bold(green(arrow + " PKGBUILDs to edit?")))
  357. }
  358. fmt.Println(bold(green(arrow) + cyan(" [N]one ") + "[A]ll [Ab]ort [I]nstalled [No]tInstalled or (1 2 3, 1-3, ^4)"))
  359. fmt.Print(bold(green(arrow + " ")))
  360. editInput, err := getInput(config.AnswerEdit)
  361. if err != nil {
  362. return nil, nil, err
  363. }
  364. eInclude, eExclude, eOtherInclude, eOtherExclude := parseNumberMenu(editInput)
  365. eIsInclude := len(eExclude) == 0 && len(eOtherExclude) == 0
  366. if eOtherInclude.get("abort") || eOtherInclude.get("ab") {
  367. return nil, nil, fmt.Errorf("Aborting due to user")
  368. }
  369. if !eOtherInclude.get("n") && !eOtherInclude.get("none") {
  370. for i, pkg := range pkgs {
  371. if !eIsInclude && eExclude.get(len(pkgs)-i) {
  372. continue
  373. }
  374. if installed.get(pkg.Name) && (eOtherInclude.get("i") || eOtherInclude.get("installed")) {
  375. toEdit = append(toEdit, pkg)
  376. continue
  377. }
  378. if !installed.get(pkg.Name) && (eOtherInclude.get("no") || eOtherInclude.get("notinstalled")) {
  379. toEdit = append(toEdit, pkg)
  380. continue
  381. }
  382. if eOtherInclude.get("a") || eOtherInclude.get("all") {
  383. toEdit = append(toEdit, pkg)
  384. continue
  385. }
  386. if eIsInclude && (eInclude.get(len(pkgs)-i) || eOtherInclude.get(pkg.PackageBase)) {
  387. toEdit = append(toEdit, pkg)
  388. }
  389. if !eIsInclude && (!eExclude.get(len(pkgs)-i) && !eOtherExclude.get(pkg.PackageBase)) {
  390. toEdit = append(toEdit, pkg)
  391. }
  392. }
  393. }
  394. return toClean, toEdit, nil
  395. }
  396. func cleanBuilds(pkgs []*rpc.Pkg) {
  397. for i, pkg := range pkgs {
  398. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  399. fmt.Printf(bold(cyan("::")+" Deleting (%d/%d): %s\n"), i+1, len(pkgs), cyan(dir))
  400. os.RemoveAll(dir)
  401. }
  402. }
  403. func showPkgBuildDiffs(pkgs []*rpc.Pkg, bases map[string][]*rpc.Pkg, hashes map[string]string) error {
  404. for _, pkg := range pkgs {
  405. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  406. if shouldUseGit(dir) {
  407. hash, _ := hashes[pkg.PackageBase]
  408. if hash == "" {
  409. hash = gitEmptyTree
  410. }
  411. head, err := gitGetHash(config.BuildDir, pkg.PackageBase)
  412. if err != nil {
  413. return err
  414. }
  415. if head == hash {
  416. fmt.Printf("%s %s: %s\n", bold(yellow(arrow)), cyan(formatPkgbase(pkg, bases)), bold("No changes -- skipping"))
  417. continue
  418. }
  419. args := []string{"diff", hash + "..HEAD", "--src-prefix", dir + "/", "--dst-prefix", dir + "/"}
  420. if useColor {
  421. args = append(args, "--color=always")
  422. } else {
  423. args = append(args, "--color=never")
  424. }
  425. err = passToGit(dir, args...)
  426. if err != nil {
  427. return err
  428. }
  429. } else {
  430. editor, editorArgs := editor()
  431. editorArgs = append(editorArgs, filepath.Join(dir, "PKGBUILD"))
  432. editcmd := exec.Command(editor, editorArgs...)
  433. editcmd.Stdin, editcmd.Stdout, editcmd.Stderr = os.Stdin, os.Stdout, os.Stderr
  434. err := editcmd.Run()
  435. if err != nil {
  436. return fmt.Errorf("Editor did not exit successfully, Aborting: %s", err)
  437. }
  438. }
  439. }
  440. return nil
  441. }
  442. func editPkgBuilds(pkgs []*rpc.Pkg, bases map[string][]*rpc.Pkg, hashes map[string]string) error {
  443. pkgbuilds := make([]string, 0, len(pkgs))
  444. for _, pkg := range pkgs {
  445. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  446. pkgbuilds = append(pkgbuilds, filepath.Join(dir, "PKGBUILD"))
  447. }
  448. if len(pkgbuilds) > 0 {
  449. editor, editorArgs := editor()
  450. editorArgs = append(editorArgs, pkgbuilds...)
  451. editcmd := exec.Command(editor, editorArgs...)
  452. editcmd.Stdin, editcmd.Stdout, editcmd.Stderr = os.Stdin, os.Stdout, os.Stderr
  453. err := editcmd.Run()
  454. if err != nil {
  455. return fmt.Errorf("Editor did not exit successfully, Aborting: %s", err)
  456. }
  457. }
  458. return nil
  459. }
  460. func parseSRCINFOFiles(pkgs []*rpc.Pkg, srcinfos map[string]*gopkg.PKGBUILD, bases map[string][]*rpc.Pkg) error {
  461. for k, pkg := range pkgs {
  462. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  463. str := bold(cyan("::") + " Parsing SRCINFO (%d/%d): %s\n")
  464. fmt.Printf(str, k+1, len(pkgs), cyan(formatPkgbase(pkg, bases)))
  465. pkgbuild, err := gopkg.ParseSRCINFO(filepath.Join(dir, ".SRCINFO"))
  466. if err != nil {
  467. return fmt.Errorf("%s: %s", pkg.Name, err)
  468. }
  469. srcinfos[pkg.PackageBase] = pkgbuild
  470. }
  471. return nil
  472. }
  473. func tryParsesrcinfosFile(pkgs []*rpc.Pkg, srcinfos map[string]*gopkg.PKGBUILD, bases map[string][]*rpc.Pkg) {
  474. for k, pkg := range pkgs {
  475. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  476. str := bold(cyan("::") + " Parsing SRCINFO (%d/%d): %s\n")
  477. fmt.Printf(str, k+1, len(pkgs), cyan(formatPkgbase(pkg, bases)))
  478. pkgbuild, err := gopkg.ParseSRCINFO(filepath.Join(dir, ".SRCINFO"))
  479. if err != nil {
  480. fmt.Printf("cannot parse %s skipping: %s\n", pkg.Name, err)
  481. continue
  482. }
  483. srcinfos[pkg.PackageBase] = pkgbuild
  484. }
  485. }
  486. func pkgBuildsToSkip(pkgs []*rpc.Pkg, targets stringSet) stringSet {
  487. toSkip := make(stringSet)
  488. for _, pkg := range pkgs {
  489. if config.ReDownload == "no" || (config.ReDownload == "yes" && !targets.get(pkg.Name)) {
  490. dir := filepath.Join(config.BuildDir, pkg.PackageBase, ".SRCINFO")
  491. pkgbuild, err := gopkg.ParseSRCINFO(dir)
  492. if err == nil {
  493. versionRPC, errR := gopkg.NewCompleteVersion(pkg.Version)
  494. versionPKG, errP := gopkg.NewCompleteVersion(pkgbuild.Version())
  495. if errP == nil && errR == nil {
  496. if !versionRPC.Newer(versionPKG) {
  497. toSkip.set(pkg.PackageBase)
  498. }
  499. }
  500. }
  501. }
  502. }
  503. return toSkip
  504. }
  505. func getHashes(pkgs []*rpc.Pkg) (map[string]string, error) {
  506. hashes := make(map[string]string)
  507. for _, pkg := range pkgs {
  508. if shouldUseGit(filepath.Join(config.BuildDir, pkg.PackageBase)) {
  509. hash, err := gitGetHash(config.BuildDir, pkg.PackageBase)
  510. if err != nil {
  511. return hashes, err
  512. }
  513. hashes[pkg.PackageBase] = hash
  514. }
  515. }
  516. return hashes, nil
  517. }
  518. func mergePkgBuilds(pkgs []*rpc.Pkg) error {
  519. for _, pkg := range pkgs {
  520. if shouldUseGit(filepath.Join(config.BuildDir, pkg.PackageBase)) {
  521. err := gitMerge(baseURL + "/" + pkg.PackageBase + ".git", config.BuildDir, pkg.PackageBase)
  522. if err != nil {
  523. return err
  524. }
  525. }
  526. }
  527. return nil
  528. }
  529. func downloadPkgBuilds(pkgs []*rpc.Pkg, bases map[string][]*rpc.Pkg, toSkip stringSet) error {
  530. for k, pkg := range pkgs {
  531. if toSkip.get(pkg.PackageBase) {
  532. str := bold(cyan("::") + " PKGBUILD up to date, Skipping (%d/%d): %s\n")
  533. fmt.Printf(str, k+1, len(pkgs), cyan(formatPkgbase(pkg, bases)))
  534. continue
  535. }
  536. str := bold(cyan("::") + " Downloading PKGBUILD (%d/%d): %s\n")
  537. fmt.Printf(str, k+1, len(pkgs), cyan(formatPkgbase(pkg, bases)))
  538. if shouldUseGit(filepath.Join(config.BuildDir, pkg.PackageBase)) {
  539. err := gitDownload(baseURL + "/" + pkg.PackageBase + ".git", config.BuildDir, pkg.PackageBase)
  540. if err != nil {
  541. return err
  542. }
  543. } else {
  544. err := downloadAndUnpack(baseURL+pkg.URLPath, config.BuildDir)
  545. if err != nil {
  546. return err
  547. }
  548. }
  549. }
  550. return nil
  551. }
  552. func downloadPkgBuildsSources(pkgs []*rpc.Pkg, bases map[string][]*rpc.Pkg, incompatible stringSet) (err error) {
  553. for _, pkg := range pkgs {
  554. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  555. args := []string{"--verifysource", "-Ccf"}
  556. if incompatible.get(pkg.PackageBase) {
  557. args = append(args, "--ignorearch")
  558. }
  559. err = passToMakepkg(dir, args...)
  560. if err != nil {
  561. return fmt.Errorf("Error downloading sources: %s", cyan(formatPkgbase(pkg, bases)))
  562. }
  563. }
  564. return
  565. }
  566. func buildInstallPkgBuilds(dp *depPool, do *depOrder, srcinfos map[string]*gopkg.PKGBUILD, parser *arguments, incompatible stringSet) error {
  567. for _, pkg := range do.Aur {
  568. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  569. built := true
  570. srcinfo := srcinfos[pkg.PackageBase]
  571. args := []string{"--nobuild", "-fC"}
  572. if incompatible.get(pkg.PackageBase) {
  573. args = append(args, "--ignorearch")
  574. }
  575. //pkgver bump
  576. err := passToMakepkg(dir, args...)
  577. if err != nil {
  578. return fmt.Errorf("Error making: %s", pkg.Name)
  579. }
  580. pkgdests, version, err := parsePackageList(dir)
  581. if err != nil {
  582. return err
  583. }
  584. if config.ReBuild == "no" || (config.ReBuild == "yes" && !dp.Explicit.get(pkg.Name)) {
  585. for _, split := range do.Bases[pkg.PackageBase] {
  586. pkgdest, ok := pkgdests[split.Name]
  587. if !ok {
  588. return fmt.Errorf("Could not find PKGDEST for: %s", split.Name)
  589. }
  590. _, err := os.Stat(pkgdest)
  591. if os.IsNotExist(err) {
  592. built = false
  593. } else if err != nil {
  594. return err
  595. }
  596. }
  597. } else {
  598. built = false
  599. }
  600. if built {
  601. fmt.Println(bold(yellow(arrow)),
  602. cyan(pkg.Name+"-"+version)+bold(" Already made -- skipping build"))
  603. } else {
  604. args := []string{"-cf", "--noconfirm", "--noextract", "--noprepare", "--holdver"}
  605. if incompatible.get(pkg.PackageBase) {
  606. args = append(args, "--ignorearch")
  607. }
  608. err := passToMakepkg(dir, args...)
  609. if err != nil {
  610. return fmt.Errorf("Error making: %s", pkg.Name)
  611. }
  612. }
  613. arguments := parser.copy()
  614. arguments.clearTargets()
  615. arguments.op = "U"
  616. arguments.delArg("confirm")
  617. arguments.delArg("c", "clean")
  618. arguments.delArg("q", "quiet")
  619. arguments.delArg("q", "quiet")
  620. arguments.delArg("y", "refresh")
  621. arguments.delArg("u", "sysupgrade")
  622. arguments.delArg("w", "downloadonly")
  623. depArguments := makeArguments()
  624. depArguments.addArg("D", "asdeps")
  625. expArguments := makeArguments()
  626. expArguments.addArg("D", "asexplicit")
  627. //remotenames: names of all non repo packages on the system
  628. _, _, localNames, remoteNames, err := filterPackages()
  629. if err != nil {
  630. return err
  631. }
  632. //cache as a stringset. maybe make it return a string set in the first
  633. //place
  634. remoteNamesCache := sliceToStringSet(remoteNames)
  635. localNamesCache := sliceToStringSet(localNames)
  636. for _, split := range do.Bases[pkg.PackageBase] {
  637. pkgdest, ok := pkgdests[split.Name]
  638. if !ok {
  639. return fmt.Errorf("Could not find PKGDEST for: %s", split.Name)
  640. }
  641. arguments.addTarget(pkgdest)
  642. if !dp.Explicit.get(split.Name) && !localNamesCache.get(split.Name) && !remoteNamesCache.get(split.Name) {
  643. depArguments.addTarget(split.Name)
  644. }
  645. if dp.Explicit.get(split.Name) {
  646. if parser.existsArg("asdeps", "asdep") {
  647. depArguments.addTarget(split.Name)
  648. } else if parser.existsArg("asexplicit", "asexp") {
  649. expArguments.addTarget(split.Name)
  650. }
  651. }
  652. }
  653. oldConfirm := config.NoConfirm
  654. config.NoConfirm = true
  655. err = passToPacman(arguments)
  656. if err != nil {
  657. return err
  658. }
  659. for _, pkg := range do.Bases[pkg.PackageBase] {
  660. updateVCSData(pkg.Name, srcinfo.Source)
  661. }
  662. if len(depArguments.targets) > 0 {
  663. _, stderr, err := passToPacmanCapture(depArguments)
  664. if err != nil {
  665. return fmt.Errorf("%s%s", stderr, err)
  666. }
  667. }
  668. config.NoConfirm = oldConfirm
  669. }
  670. return nil
  671. }
  672. func clean(pkgs []*rpc.Pkg) {
  673. for _, pkg := range pkgs {
  674. dir := filepath.Join(config.BuildDir, pkg.PackageBase)
  675. fmt.Println(bold(green(arrow +
  676. " CleanAfter enabled. Deleting " + pkg.Name + " source folder.")))
  677. os.RemoveAll(dir)
  678. }
  679. }