mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
pkg/services: fix ineffassign issues
This commit is contained in:
parent
3a48ea8dde
commit
6eb00000fe
@ -3,13 +3,14 @@ package notifiers
|
|||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"io"
|
||||||
|
"mime/multipart"
|
||||||
|
"os"
|
||||||
|
|
||||||
"github.com/grafana/grafana/pkg/bus"
|
"github.com/grafana/grafana/pkg/bus"
|
||||||
"github.com/grafana/grafana/pkg/log"
|
"github.com/grafana/grafana/pkg/log"
|
||||||
m "github.com/grafana/grafana/pkg/models"
|
m "github.com/grafana/grafana/pkg/models"
|
||||||
"github.com/grafana/grafana/pkg/services/alerting"
|
"github.com/grafana/grafana/pkg/services/alerting"
|
||||||
"io"
|
|
||||||
"mime/multipart"
|
|
||||||
"os"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@ -133,6 +134,9 @@ func (this *TelegramNotifier) buildMessageInlineImage(evalContext *alerting.Eval
|
|||||||
}
|
}
|
||||||
|
|
||||||
ruleUrl, err := evalContext.GetRuleUrl()
|
ruleUrl, err := evalContext.GetRuleUrl()
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
metrics := generateMetricsMessage(evalContext)
|
metrics := generateMetricsMessage(evalContext)
|
||||||
message := generateImageCaption(evalContext, ruleUrl, metrics)
|
message := generateImageCaption(evalContext, ruleUrl, metrics)
|
||||||
|
@ -83,27 +83,6 @@ func (this *VictoropsNotifier) Notify(evalContext *alerting.EvalContext) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
fields := make([]map[string]interface{}, 0)
|
|
||||||
fieldLimitCount := 4
|
|
||||||
for index, evt := range evalContext.EvalMatches {
|
|
||||||
fields = append(fields, map[string]interface{}{
|
|
||||||
"title": evt.Metric,
|
|
||||||
"value": evt.Value,
|
|
||||||
"short": true,
|
|
||||||
})
|
|
||||||
if index > fieldLimitCount {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if evalContext.Error != nil {
|
|
||||||
fields = append(fields, map[string]interface{}{
|
|
||||||
"title": "Error message",
|
|
||||||
"value": evalContext.Error.Error(),
|
|
||||||
"short": false,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
messageType := evalContext.Rule.State
|
messageType := evalContext.Rule.State
|
||||||
if evalContext.Rule.State == models.AlertStateAlerting { // translate 'Alerting' to 'CRITICAL' (Victorops analog)
|
if evalContext.Rule.State == models.AlertStateAlerting { // translate 'Alerting' to 'CRITICAL' (Victorops analog)
|
||||||
messageType = AlertStateCritical
|
messageType = AlertStateCritical
|
||||||
|
@ -649,6 +649,9 @@ func (sc *scenarioContext) verifyUpdateChildDashboardPermissionsWithOverrideShou
|
|||||||
}
|
}
|
||||||
|
|
||||||
_, err := sc.g.CheckPermissionBeforeUpdate(m.PERMISSION_ADMIN, permissionList)
|
_, err := sc.g.CheckPermissionBeforeUpdate(m.PERMISSION_ADMIN, permissionList)
|
||||||
|
if err != nil {
|
||||||
|
sc.reportFailure(tc, nil, err)
|
||||||
|
}
|
||||||
sc.updatePermissions = permissionList
|
sc.updatePermissions = permissionList
|
||||||
ok, err := sc.g.CheckPermissionBeforeUpdate(m.PERMISSION_ADMIN, permissionList)
|
ok, err := sc.g.CheckPermissionBeforeUpdate(m.PERMISSION_ADMIN, permissionList)
|
||||||
|
|
||||||
|
@ -235,7 +235,6 @@ func getOrCreateFolderId(cfg *DashboardsAsConfig, service dashboards.DashboardPr
|
|||||||
func resolveSymlink(fileinfo os.FileInfo, path string) (os.FileInfo, error) {
|
func resolveSymlink(fileinfo os.FileInfo, path string) (os.FileInfo, error) {
|
||||||
checkFilepath, err := filepath.EvalSymlinks(path)
|
checkFilepath, err := filepath.EvalSymlinks(path)
|
||||||
if path != checkFilepath {
|
if path != checkFilepath {
|
||||||
path = checkFilepath
|
|
||||||
fi, err := os.Lstat(checkFilepath)
|
fi, err := os.Lstat(checkFilepath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
@ -256,6 +256,7 @@ func TestAnnotations(t *testing.T) {
|
|||||||
annotationId := items[0].Id
|
annotationId := items[0].Id
|
||||||
|
|
||||||
err = repo.Delete(&annotations.DeleteParams{Id: annotationId})
|
err = repo.Delete(&annotations.DeleteParams{Id: annotationId})
|
||||||
|
So(err, ShouldBeNil)
|
||||||
|
|
||||||
items, err = repo.Find(query)
|
items, err = repo.Find(query)
|
||||||
So(err, ShouldBeNil)
|
So(err, ShouldBeNil)
|
||||||
|
@ -77,7 +77,7 @@ func saveDashboard(sess *DBSession, cmd *m.SaveDashboardCommand) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
parentVersion := dash.Version
|
parentVersion := dash.Version
|
||||||
affectedRows := int64(0)
|
var affectedRows int64
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
if dash.Id == 0 {
|
if dash.Id == 0 {
|
||||||
|
@ -154,6 +154,7 @@ func TestDashboardAclDataAccess(t *testing.T) {
|
|||||||
DashboardId: savedFolder.Id,
|
DashboardId: savedFolder.Id,
|
||||||
Permission: m.PERMISSION_EDIT,
|
Permission: m.PERMISSION_EDIT,
|
||||||
})
|
})
|
||||||
|
So(err, ShouldBeNil)
|
||||||
|
|
||||||
q1 := &m.GetDashboardAclInfoListQuery{DashboardId: savedFolder.Id, OrgId: 1}
|
q1 := &m.GetDashboardAclInfoListQuery{DashboardId: savedFolder.Id, OrgId: 1}
|
||||||
err = GetDashboardAclInfoList(q1)
|
err = GetDashboardAclInfoList(q1)
|
||||||
|
@ -27,7 +27,7 @@ func TestMigrations(t *testing.T) {
|
|||||||
|
|
||||||
sqlutil.CleanDB(x)
|
sqlutil.CleanDB(x)
|
||||||
|
|
||||||
has, err := x.SQL(sql).Get(&r)
|
_, err = x.SQL(sql).Get(&r)
|
||||||
So(err, ShouldNotBeNil)
|
So(err, ShouldNotBeNil)
|
||||||
|
|
||||||
mg := NewMigrator(x)
|
mg := NewMigrator(x)
|
||||||
@ -36,7 +36,7 @@ func TestMigrations(t *testing.T) {
|
|||||||
err = mg.Start()
|
err = mg.Start()
|
||||||
So(err, ShouldBeNil)
|
So(err, ShouldBeNil)
|
||||||
|
|
||||||
has, err = x.SQL(sql).Get(&r)
|
has, err := x.SQL(sql).Get(&r)
|
||||||
So(err, ShouldBeNil)
|
So(err, ShouldBeNil)
|
||||||
So(has, ShouldBeTrue)
|
So(has, ShouldBeTrue)
|
||||||
expectedMigrations := mg.MigrationsCount() - 2 //we currently skip to migrations. We should rewrite skipped migrations to write in the log as well. until then we have to keep this
|
expectedMigrations := mg.MigrationsCount() - 2 //we currently skip to migrations. We should rewrite skipped migrations to write in the log as well. until then we have to keep this
|
||||||
|
@ -22,6 +22,9 @@ func CreatePlaylist(cmd *m.CreatePlaylistCommand) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
_, err := x.Insert(&playlist)
|
_, err := x.Insert(&playlist)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
playlistItems := make([]m.PlaylistItem, 0)
|
playlistItems := make([]m.PlaylistItem, 0)
|
||||||
for _, item := range cmd.Items {
|
for _, item := range cmd.Items {
|
||||||
|
@ -48,6 +48,9 @@ func UpdatePluginSetting(cmd *m.UpdatePluginSettingCmd) error {
|
|||||||
var pluginSetting m.PluginSetting
|
var pluginSetting m.PluginSetting
|
||||||
|
|
||||||
exists, err := sess.Where("org_id=? and plugin_id=?", cmd.OrgId, cmd.PluginId).Get(&pluginSetting)
|
exists, err := sess.Where("org_id=? and plugin_id=?", cmd.OrgId, cmd.PluginId).Get(&pluginSetting)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
sess.UseBool("enabled")
|
sess.UseBool("enabled")
|
||||||
sess.UseBool("pinned")
|
sess.UseBool("pinned")
|
||||||
if !exists {
|
if !exists {
|
||||||
|
@ -72,6 +72,9 @@ func SavePreferences(cmd *m.SavePreferencesCommand) error {
|
|||||||
|
|
||||||
var prefs m.Preferences
|
var prefs m.Preferences
|
||||||
exists, err := sess.Where("org_id=? AND user_id=?", cmd.OrgId, cmd.UserId).Get(&prefs)
|
exists, err := sess.Where("org_id=? AND user_id=?", cmd.OrgId, cmd.UserId).Get(&prefs)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
if !exists {
|
if !exists {
|
||||||
prefs = m.Preferences{
|
prefs = m.Preferences{
|
||||||
|
@ -74,6 +74,7 @@ func TestTeamCommandsAndQueries(t *testing.T) {
|
|||||||
Convey("Should be able to return all teams a user is member of", func() {
|
Convey("Should be able to return all teams a user is member of", func() {
|
||||||
groupId := group2.Result.Id
|
groupId := group2.Result.Id
|
||||||
err := AddTeamMember(&m.AddTeamMemberCommand{OrgId: testOrgId, TeamId: groupId, UserId: userIds[0]})
|
err := AddTeamMember(&m.AddTeamMemberCommand{OrgId: testOrgId, TeamId: groupId, UserId: userIds[0]})
|
||||||
|
So(err, ShouldBeNil)
|
||||||
|
|
||||||
query := &m.GetTeamsByUserQuery{OrgId: testOrgId, UserId: userIds[0]}
|
query := &m.GetTeamsByUserQuery{OrgId: testOrgId, UserId: userIds[0]}
|
||||||
err = GetTeamsByUser(query)
|
err = GetTeamsByUser(query)
|
||||||
@ -103,7 +104,7 @@ func TestTeamCommandsAndQueries(t *testing.T) {
|
|||||||
err = AddTeamMember(&m.AddTeamMemberCommand{OrgId: testOrgId, TeamId: groupId, UserId: userIds[2]})
|
err = AddTeamMember(&m.AddTeamMemberCommand{OrgId: testOrgId, TeamId: groupId, UserId: userIds[2]})
|
||||||
So(err, ShouldBeNil)
|
So(err, ShouldBeNil)
|
||||||
err = testHelperUpdateDashboardAcl(1, m.DashboardAcl{DashboardId: 1, OrgId: testOrgId, Permission: m.PERMISSION_EDIT, TeamId: groupId})
|
err = testHelperUpdateDashboardAcl(1, m.DashboardAcl{DashboardId: 1, OrgId: testOrgId, Permission: m.PERMISSION_EDIT, TeamId: groupId})
|
||||||
|
So(err, ShouldBeNil)
|
||||||
err = DeleteTeam(&m.DeleteTeamCommand{OrgId: testOrgId, Id: groupId})
|
err = DeleteTeam(&m.DeleteTeamCommand{OrgId: testOrgId, Id: groupId})
|
||||||
So(err, ShouldBeNil)
|
So(err, ShouldBeNil)
|
||||||
|
|
||||||
|
@ -168,11 +168,9 @@ func GetUserByLogin(query *m.GetUserByLoginQuery) error {
|
|||||||
return m.ErrUserNotFound
|
return m.ErrUserNotFound
|
||||||
}
|
}
|
||||||
|
|
||||||
user := new(m.User)
|
|
||||||
|
|
||||||
// Try and find the user by login first.
|
// Try and find the user by login first.
|
||||||
// It's not sufficient to assume that a LoginOrEmail with an "@" is an email.
|
// It's not sufficient to assume that a LoginOrEmail with an "@" is an email.
|
||||||
user = &m.User{Login: query.LoginOrEmail}
|
user := &m.User{Login: query.LoginOrEmail}
|
||||||
has, err := x.Get(user)
|
has, err := x.Get(user)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -202,9 +200,7 @@ func GetUserByEmail(query *m.GetUserByEmailQuery) error {
|
|||||||
return m.ErrUserNotFound
|
return m.ErrUserNotFound
|
||||||
}
|
}
|
||||||
|
|
||||||
user := new(m.User)
|
user := &m.User{Email: query.Email}
|
||||||
|
|
||||||
user = &m.User{Email: query.Email}
|
|
||||||
has, err := x.Get(user)
|
has, err := x.Get(user)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user