exec.go 2.9 KB

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