install.go 20 KB

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