exec.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. package main
  2. import (
  3. "bytes"
  4. "fmt"
  5. "golang.org/x/crypto/ssh/terminal"
  6. "os"
  7. "os/exec"
  8. "path/filepath"
  9. "strings"
  10. "time"
  11. )
  12. func show(cmd *exec.Cmd) error {
  13. cmd.Stdin, cmd.Stdout, cmd.Stderr = os.Stdin, os.Stdout, os.Stderr
  14. err := cmd.Run()
  15. if err != nil {
  16. return fmt.Errorf("")
  17. }
  18. return nil
  19. }
  20. func capture(cmd *exec.Cmd) (string, string, error) {
  21. var outbuf, errbuf bytes.Buffer
  22. cmd.Stdout = &outbuf
  23. cmd.Stderr = &errbuf
  24. err := cmd.Run()
  25. stdout := strings.TrimSpace(outbuf.String())
  26. stderr := strings.TrimSpace(errbuf.String())
  27. return stdout, stderr, err
  28. }
  29. func sudoLoopBackground() {
  30. updateSudo()
  31. go sudoLoop()
  32. }
  33. func sudoLoop() {
  34. for {
  35. updateSudo()
  36. time.Sleep(298 * time.Second)
  37. }
  38. }
  39. func updateSudo() {
  40. for {
  41. mSudoFlags := strings.Fields(config.SudoFlags)
  42. mSudoFlags = append([]string{"-v"}, mSudoFlags...)
  43. err := show(exec.Command(config.SudoBin, mSudoFlags...))
  44. if err != nil {
  45. fmt.Fprintln(os.Stderr, err)
  46. } else {
  47. break
  48. }
  49. }
  50. }
  51. // waitLock will lock yay checking the status of db.lck until it does not exist
  52. func waitLock() {
  53. if _, err := os.Stat(filepath.Join(pacmanConf.DBPath, "db.lck")); err != nil {
  54. return
  55. }
  56. fmt.Println(bold(yellow(smallArrow)), filepath.Join(pacmanConf.DBPath, "db.lck"), "is present.")
  57. fmt.Print(bold(yellow(smallArrow)), " There may be another Pacman instance running. Waiting...")
  58. for {
  59. time.Sleep(3 * time.Second)
  60. if _, err := os.Stat(filepath.Join(pacmanConf.DBPath, "db.lck")); err != nil {
  61. fmt.Println()
  62. return
  63. }
  64. }
  65. }
  66. func passToPacman(args *arguments) *exec.Cmd {
  67. argArr := make([]string, 0)
  68. mSudoFlags := strings.Fields(config.SudoFlags)
  69. if args.needRoot() {
  70. argArr = append(argArr, config.SudoBin)
  71. argArr = append(argArr, mSudoFlags...)
  72. }
  73. argArr = append(argArr, config.PacmanBin)
  74. argArr = append(argArr, cmdArgs.formatGlobals()...)
  75. argArr = append(argArr, args.formatArgs()...)
  76. if config.NoConfirm {
  77. argArr = append(argArr, "--noconfirm")
  78. }
  79. argArr = append(argArr, "--config", config.PacmanConf)
  80. argArr = append(argArr, "--")
  81. argArr = append(argArr, args.targets...)
  82. if args.needRoot() {
  83. waitLock()
  84. }
  85. return exec.Command(argArr[0], argArr[1:]...)
  86. }
  87. func passToMakepkg(dir string, args ...string) *exec.Cmd {
  88. mflags := strings.Fields(config.MFlags)
  89. args = append(args, mflags...)
  90. if config.MakepkgConf != "" {
  91. args = append(args, "--config", config.MakepkgConf)
  92. }
  93. cmd := exec.Command(config.MakepkgBin, args...)
  94. cmd.Dir = dir
  95. return cmd
  96. }
  97. func passToGit(dir string, _args ...string) *exec.Cmd {
  98. gitflags := strings.Fields(config.GitFlags)
  99. args := []string{"-C", dir}
  100. args = append(args, gitflags...)
  101. args = append(args, _args...)
  102. cmd := exec.Command(config.GitBin, args...)
  103. return cmd
  104. }
  105. func isTty() bool {
  106. return terminal.IsTerminal(int(os.Stdout.Fd()))
  107. }