queries.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596
  1. package plugins
  2. import (
  3. "github.com/grafana/grafana/pkg/bus"
  4. m "github.com/grafana/grafana/pkg/models"
  5. )
  6. func GetOrgAppSettings(orgId int64) (map[string]*m.AppSettings, error) {
  7. query := m.GetAppSettingsQuery{OrgId: orgId}
  8. if err := bus.Dispatch(&query); err != nil {
  9. return nil, err
  10. }
  11. orgAppsMap := make(map[string]*m.AppSettings)
  12. for _, orgApp := range query.Result {
  13. orgAppsMap[orgApp.AppId] = orgApp
  14. }
  15. return orgAppsMap, nil
  16. }
  17. func GetEnabledPlugins(orgId int64) (*EnabledPlugins, error) {
  18. enabledPlugins := NewEnabledPlugins()
  19. orgApps, err := GetOrgAppSettings(orgId)
  20. if err != nil {
  21. return nil, err
  22. }
  23. seenPanels := make(map[string]bool)
  24. seenApi := make(map[string]bool)
  25. for appType, installedApp := range Apps {
  26. var app AppPlugin
  27. app = *installedApp
  28. // check if the app is stored in the DB for this org and if so, use the
  29. // state stored there.
  30. if b, ok := orgApps[appType]; ok {
  31. app.Enabled = b.Enabled
  32. app.Pinned = b.Pinned
  33. }
  34. // if app.Enabled {
  35. // for _, d := range app.DatasourcePlugins {
  36. // if ds, ok := DataSources[d]; ok {
  37. // enabledPlugins.DataSourcePlugins[d] = ds
  38. // }
  39. // }
  40. // for _, p := range app.PanelPlugins {
  41. // if panel, ok := Panels[p]; ok {
  42. // if _, ok := seenPanels[p]; !ok {
  43. // seenPanels[p] = true
  44. // enabledPlugins.PanelPlugins = append(enabledPlugins.PanelPlugins, panel)
  45. // }
  46. // }
  47. // }
  48. // for _, a := range app.ApiPlugins {
  49. // if api, ok := ApiPlugins[a]; ok {
  50. // if _, ok := seenApi[a]; !ok {
  51. // seenApi[a] = true
  52. // enabledPlugins.ApiPlugins = append(enabledPlugins.ApiPlugins, api)
  53. // }
  54. // }
  55. // }
  56. // enabledPlugins.AppPlugins = append(enabledPlugins.AppPlugins, &app)
  57. // }
  58. }
  59. // add all plugins that are not part of an App.
  60. for d, installedDs := range DataSources {
  61. if installedDs.App == "" {
  62. enabledPlugins.DataSources[d] = installedDs
  63. }
  64. }
  65. for p, panel := range Panels {
  66. if panel.App == "" {
  67. if _, ok := seenPanels[p]; !ok {
  68. seenPanels[p] = true
  69. enabledPlugins.Panels = append(enabledPlugins.Panels, panel)
  70. }
  71. }
  72. }
  73. for a, api := range ApiPlugins {
  74. if api.App == "" {
  75. if _, ok := seenApi[a]; !ok {
  76. seenApi[a] = true
  77. enabledPlugins.ApiList = append(enabledPlugins.ApiList, api)
  78. }
  79. }
  80. }
  81. return &enabledPlugins, nil
  82. }