install.go 20 KB

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