962cc34432
# What this PR does - Compresses sync data being sent to engine - Minor fix to log messages when JSON parse errors occur ## Which issue(s) this PR closes Related to [issue link here] <!-- *Note*: If you want the issue to be auto-closed once the PR is merged, change "Related to" to "Closes" in the line above. If you have more than one GitHub issue that this PR closes, be sure to preface each issue link with a [closing keyword](https://docs.github.com/en/get-started/writing-on-github/working-with-advanced-formatting/using-keywords-in-issues-and-pull-requests#linking-a-pull-request-to-an-issue). This ensures that the issue(s) are auto-closed once the PR has been merged. --> ## 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.
102 lines
3.4 KiB
Go
102 lines
3.4 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)
|
|
}
|
|
|
|
func (a *App) handleDebugUnlock(w http.ResponseWriter, req *http.Request) {
|
|
a.OnCallSyncCache.syncMutex.Unlock()
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|