06d19bf6e9
# What this PR does
New OnCall plugin initialization process
## Checklist
- [x] Unit, integration, and e2e (if applicable) tests updated
- [x] Documentation added (or `pr:no public docs` PR label added if not
required)
- [x] Added the relevant release notes label (see labels prefixed w/
`release:`). These labels dictate how your PR will
show up in the autogenerated release notes.
---------
Co-authored-by: Michael Derynck <michael.derynck@grafana.com>
Co-authored-by: Matias Bordese <mbordese@gmail.com>
97 lines
3.2 KiB
Go
97 lines
3.2 KiB
Go
package plugin
|
|
|
|
import (
|
|
"encoding/json"
|
|
"github.com/grafana/grafana-plugin-sdk-go/backend/log"
|
|
"github.com/grafana/grafana-plugin-sdk-go/backend/resource/httpadapter"
|
|
"net/http"
|
|
)
|
|
|
|
type OnCallDebugStats struct {
|
|
SettingsCallCount int32 `json:"settingsCallCount"`
|
|
AllUsersCallCount int32 `json:"allUsersCallCount"`
|
|
PermissionsCallCount int32 `json:"permissionsCallCount"`
|
|
AllPermissionsCallCount int32 `json:"allPermissionsCallCount"`
|
|
TeamForUserCallCount int32 `json:"teamForUserCallCount"`
|
|
AllTeamsCallCount int32 `json:"allTeamsCallCount"`
|
|
TeamMembersForTeamCallCount int32 `json:"teamMembersForTeamCallCount"`
|
|
CheckHealthCallCount int32 `json:"checkHealthCallCount"`
|
|
}
|
|
|
|
func (a *App) handleDebugUser(w http.ResponseWriter, req *http.Request) {
|
|
onCallPluginSettings, err := a.OnCallSettingsFromContext(req.Context())
|
|
if err != nil {
|
|
log.DefaultLogger.Error("Error getting settings from context", "error", err)
|
|
return
|
|
}
|
|
|
|
user := httpadapter.UserFromContext(req.Context())
|
|
onCallUser, err := a.GetUserForHeader(onCallPluginSettings, user)
|
|
if err != nil {
|
|
log.DefaultLogger.Error("Error getting user", "error", err)
|
|
return
|
|
}
|
|
|
|
w.Header().Add("Content-Type", "application/json")
|
|
if err := json.NewEncoder(w).Encode(onCallUser); err != nil {
|
|
http.Error(w, "Failed to encode response", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
|
|
func (a *App) handleDebugSync(w http.ResponseWriter, req *http.Request) {
|
|
onCallPluginSettings, err := a.OnCallSettingsFromContext(req.Context())
|
|
if err != nil {
|
|
log.DefaultLogger.Error("Error getting settings from context", "error", err)
|
|
return
|
|
}
|
|
|
|
onCallSync, err := a.GetSyncData(req.Context(), onCallPluginSettings)
|
|
if err != nil {
|
|
log.DefaultLogger.Error("Error getting sync data", "error", err)
|
|
return
|
|
}
|
|
|
|
w.Header().Add("Content-Type", "application/json")
|
|
if err := json.NewEncoder(w).Encode(onCallSync); err != nil {
|
|
http.Error(w, "Failed to encode response", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
|
|
func (a *App) handleDebugSettings(w http.ResponseWriter, req *http.Request) {
|
|
onCallPluginSettings, err := a.OnCallSettingsFromContext(req.Context())
|
|
if err != nil {
|
|
log.DefaultLogger.Error("Error getting settings from context", "error", err)
|
|
return
|
|
}
|
|
|
|
w.Header().Add("Content-Type", "application/json")
|
|
if err := json.NewEncoder(w).Encode(onCallPluginSettings); err != nil {
|
|
http.Error(w, "Failed to encode response", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
|
|
func (a *App) handleDebugPermissions(w http.ResponseWriter, req *http.Request) {
|
|
pluginContext := httpadapter.PluginConfigFromContext(req.Context())
|
|
|
|
w.Header().Add("Content-Type", "application/json")
|
|
if err := json.NewEncoder(w).Encode(pluginContext); err != nil {
|
|
http.Error(w, "Failed to encode response", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
|
|
func (a *App) handleDebugStats(w http.ResponseWriter, req *http.Request) {
|
|
w.Header().Add("Content-Type", "application/json")
|
|
if err := json.NewEncoder(w).Encode(a.OnCallDebugStats); err != nil {
|
|
http.Error(w, "Failed to encode response", http.StatusInternalServerError)
|
|
return
|
|
}
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|