apt.go 3.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. package apt
  2. import (
  3. "os/exec"
  4. "runtime"
  5. "net/http"
  6. "errors"
  7. "encoding/json"
  8. "strings"
  9. "log"
  10. "os"
  11. )
  12. /*
  13. Pacakge management tool for Linux OS with APT
  14. ONLY USABLE under Linux environment
  15. */
  16. type AptPackageManager struct{
  17. AllowAutoInstall bool
  18. }
  19. func NewPackageManager(autoInstall bool) *AptPackageManager{
  20. return &AptPackageManager{
  21. AllowAutoInstall: autoInstall,
  22. }
  23. }
  24. //Install the given package if not exists. Set mustComply to true for "panic on failed to install"
  25. func (a *AptPackageManager)InstallIfNotExists(pkgname string, mustComply bool) error{
  26. //Clear the pkgname
  27. pkgname = strings.ReplaceAll(pkgname, "&","")
  28. pkgname = strings.ReplaceAll(pkgname, "|","")
  29. if runtime.GOOS == "windows" {
  30. //Check if the command already exists in windows path paramters.
  31. cmd := exec.Command("where", pkgname, "2>", "nul")
  32. _, err := cmd.CombinedOutput()
  33. if err != nil{
  34. return errors.New("Package " + pkgname + " not found in Windows %PATH%.")
  35. }
  36. return nil
  37. }
  38. if (a.AllowAutoInstall == false){
  39. return errors.New("Package auto install is disabled")
  40. }
  41. cmd := exec.Command("whereis", pkgname)
  42. out, err := cmd.CombinedOutput()
  43. if err != nil{
  44. return err
  45. }
  46. packageInfo := strings.Split(strings.TrimSpace(string(out)), ":")
  47. //log.Println(packageInfo)
  48. if (len(packageInfo) > 1 && packageInfo[1] != ""){
  49. return nil
  50. }else{
  51. //Package not installed. Install if now if running in sudo mode
  52. log.Println("Installing package " + pkgname + "...")
  53. cmd := exec.Command("apt-get", "install", "-y", pkgname)
  54. cmd.Stdout = os.Stdout
  55. cmd.Stderr = os.Stderr
  56. err := cmd.Run()
  57. if err != nil{
  58. if (mustComply){
  59. //Panic and terminate server process
  60. log.Println("Installation failed on package: " + pkgname, string(out))
  61. os.Exit(0)
  62. }else{
  63. log.Println("Installation failed on package: " + pkgname)
  64. log.Println(string(out))
  65. }
  66. return err
  67. }
  68. return nil
  69. }
  70. return nil
  71. }
  72. func HandlePackageListRequest(w http.ResponseWriter, r *http.Request){
  73. if runtime.GOOS == "windows" {
  74. w.Header().Set("Content-Type", "application/json")
  75. w.Write([]byte("{\"error\":\"" + "Function disabled on Windows" + "\"}"))
  76. return
  77. }
  78. cmd := exec.Command("apt", "list", "--installed")
  79. out, err := cmd.CombinedOutput()
  80. if err != nil{
  81. w.Header().Set("Content-Type", "application/json")
  82. w.Write([]byte("{\"error\":\"" + err.Error() + "\"}"))
  83. return
  84. }
  85. results := [][]string{}
  86. //Parse the output string
  87. installedPackages := strings.Split(string(out), "\n")
  88. for _, thisPackage := range installedPackages{
  89. if len(thisPackage) > 0{
  90. packageInfo := strings.Split(thisPackage, "/")
  91. packageName := packageInfo[0]
  92. if len(packageInfo) >= 2{
  93. packageVersion := strings.Split(packageInfo[1], ",")[1]
  94. if (packageVersion[:3] == "now"){
  95. packageVersion = packageVersion[4:]
  96. }
  97. if (strings.Contains(packageVersion, "[installed") && packageVersion[len(packageVersion) - 1:] != "]"){
  98. packageVersion = packageVersion + ",automatic]"
  99. }
  100. results = append(results, []string{packageName, packageVersion})
  101. }
  102. }
  103. }
  104. jsonString, _ := json.Marshal(results);
  105. w.Header().Set("Content-Type", "application/json")
  106. w.Write(jsonString)
  107. return
  108. }