install.go 22 KB

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