completion.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  1. package completion
  2. import (
  3. "bufio"
  4. "io"
  5. "net/http"
  6. "os"
  7. "path/filepath"
  8. "time"
  9. alpm "github.com/Jguer/go-alpm"
  10. )
  11. // Show provides completion info for shells
  12. func Show(alpmHandle *alpm.Handle, aurURL string, cacheDir string, interval int, force bool) error {
  13. path := filepath.Join(cacheDir, "completion.cache")
  14. err := Update(alpmHandle, aurURL, cacheDir, interval, force)
  15. if err != nil {
  16. return err
  17. }
  18. in, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE, 0644)
  19. if err != nil {
  20. return err
  21. }
  22. defer in.Close()
  23. _, err = io.Copy(os.Stdout, in)
  24. return err
  25. }
  26. // Update updates completion cache to be used by Complete
  27. func Update(alpmHandle *alpm.Handle, aurURL string, cacheDir string, interval int, force bool) error {
  28. path := filepath.Join(cacheDir, "completion.cache")
  29. info, err := os.Stat(path)
  30. if os.IsNotExist(err) || (interval != -1 && time.Since(info.ModTime()).Hours() >= float64(interval*24)) || force {
  31. os.MkdirAll(filepath.Dir(path), 0755)
  32. out, errf := os.Create(path)
  33. if errf != nil {
  34. return errf
  35. }
  36. if createAURList(aurURL, out) != nil {
  37. defer os.Remove(path)
  38. }
  39. erra := createRepoList(alpmHandle, out)
  40. out.Close()
  41. return erra
  42. }
  43. return nil
  44. }
  45. //CreateAURList creates a new completion file
  46. func createAURList(aurURL string, out io.ReadWriteSeeker) error {
  47. resp, err := http.Get(aurURL + "/packages.gz")
  48. if err != nil {
  49. return err
  50. }
  51. defer resp.Body.Close()
  52. scanner := bufio.NewScanner(resp.Body)
  53. scanner.Scan()
  54. for scanner.Scan() {
  55. _, err = io.WriteString(out, scanner.Text()+"\tAUR\n")
  56. if err != nil {
  57. return err
  58. }
  59. }
  60. return nil
  61. }
  62. //CreatePackageList appends Repo packages to completion cache
  63. func createRepoList(alpmHandle *alpm.Handle, out io.ReadWriteSeeker) error {
  64. dbList, err := alpmHandle.SyncDBs()
  65. if err != nil {
  66. return err
  67. }
  68. _ = dbList.ForEach(func(db alpm.DB) error {
  69. _ = db.PkgCache().ForEach(func(pkg alpm.Package) error {
  70. _, err = io.WriteString(out, pkg.Name()+"\t"+pkg.DB().Name()+"\n")
  71. return err
  72. })
  73. return nil
  74. })
  75. return nil
  76. }