install.go 20 KB

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