mirror of
https://github.com/fleetdm/fleet
synced 2026-05-23 08:58:41 +00:00
Add logging for Teams endpoints (#1254)
This commit is contained in:
Zach Wasserman
GitHub
parent
b967eabb3d
commit
782020c320
1 changed files with 215 additions and 0 deletions
215
server/service/logging_teams.go
Normal file
215
server/service/logging_teams.go
Normal file
|
|
@ -0,0 +1,215 @@
|
|||
package service
|
||||
|
||||
import (
|
||||
"context"
|
||||
"encoding/json"
|
||||
"time"
|
||||
|
||||
"github.com/fleetdm/fleet/v4/server/contexts/viewer"
|
||||
"github.com/fleetdm/fleet/v4/server/fleet"
|
||||
)
|
||||
|
||||
func (mw loggingMiddleware) NewTeam(ctx context.Context, p fleet.TeamPayload) (*fleet.Team, error) {
|
||||
var (
|
||||
team *fleet.Team
|
||||
loggedInUser = "unauthenticated"
|
||||
err error
|
||||
)
|
||||
|
||||
if vc, ok := viewer.FromContext(ctx); ok {
|
||||
|
||||
loggedInUser = vc.Email()
|
||||
}
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerInfo(err).Log(
|
||||
"method", "NewTeam",
|
||||
"err", err,
|
||||
"user", loggedInUser,
|
||||
"took", time.Since(begin),
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
team, err = mw.Service.NewTeam(ctx, p)
|
||||
return team, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) ModifyTeam(ctx context.Context, id uint, p fleet.TeamPayload) (*fleet.Team, error) {
|
||||
var (
|
||||
team *fleet.Team
|
||||
loggedInUser = "unauthenticated"
|
||||
err error
|
||||
)
|
||||
|
||||
if vc, ok := viewer.FromContext(ctx); ok {
|
||||
|
||||
loggedInUser = vc.Email()
|
||||
}
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerInfo(err).Log(
|
||||
"method", "ModifyTeam",
|
||||
"err", err,
|
||||
"user", loggedInUser,
|
||||
"took", time.Since(begin),
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
team, err = mw.Service.ModifyTeam(ctx, id, p)
|
||||
return team, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) ModifyTeamAgentOptions(ctx context.Context, id uint, options json.RawMessage) (*fleet.Team, error) {
|
||||
var (
|
||||
team *fleet.Team
|
||||
loggedInUser = "unauthenticated"
|
||||
err error
|
||||
)
|
||||
|
||||
if vc, ok := viewer.FromContext(ctx); ok {
|
||||
|
||||
loggedInUser = vc.Email()
|
||||
}
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerInfo(err).Log(
|
||||
"method", "ModifyTeamAgentOptions",
|
||||
"err", err,
|
||||
"user", loggedInUser,
|
||||
"took", time.Since(begin),
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
team, err = mw.Service.ModifyTeamAgentOptions(ctx, id, options)
|
||||
return team, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) AddTeamUsers(ctx context.Context, id uint, users []fleet.TeamUser) (*fleet.Team, error) {
|
||||
var (
|
||||
team *fleet.Team
|
||||
loggedInUser = "unauthenticated"
|
||||
err error
|
||||
)
|
||||
|
||||
if vc, ok := viewer.FromContext(ctx); ok {
|
||||
|
||||
loggedInUser = vc.Email()
|
||||
}
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerInfo(err).Log(
|
||||
"method", "AddTeamUsers",
|
||||
"err", err,
|
||||
"user", loggedInUser,
|
||||
"took", time.Since(begin),
|
||||
"users", users,
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
team, err = mw.Service.AddTeamUsers(ctx, id, users)
|
||||
return team, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) DeleteTeamUsers(ctx context.Context, id uint, users []fleet.TeamUser) (*fleet.Team, error) {
|
||||
var (
|
||||
team *fleet.Team
|
||||
loggedInUser = "unauthenticated"
|
||||
err error
|
||||
)
|
||||
|
||||
if vc, ok := viewer.FromContext(ctx); ok {
|
||||
|
||||
loggedInUser = vc.Email()
|
||||
}
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerInfo(err).Log(
|
||||
"method", "DeleteTeamUsers",
|
||||
"err", err,
|
||||
"user", loggedInUser,
|
||||
"took", time.Since(begin),
|
||||
"users", users,
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
team, err = mw.Service.DeleteTeamUsers(ctx, id, users)
|
||||
return team, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) DeleteTeam(ctx context.Context, id uint) error {
|
||||
var (
|
||||
loggedInUser = "unauthenticated"
|
||||
err error
|
||||
)
|
||||
|
||||
if vc, ok := viewer.FromContext(ctx); ok {
|
||||
|
||||
loggedInUser = vc.Email()
|
||||
}
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerInfo(err).Log(
|
||||
"method", "DeleteTeam",
|
||||
"err", err,
|
||||
"user", loggedInUser,
|
||||
"took", time.Since(begin),
|
||||
"id", id,
|
||||
)
|
||||
}(time.Now())
|
||||
err = mw.Service.DeleteTeam(ctx, id)
|
||||
return err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) ListTeams(ctx context.Context, opt fleet.ListOptions) ([]*fleet.Team, error) {
|
||||
var (
|
||||
teams []*fleet.Team
|
||||
err error
|
||||
)
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerDebug(err).Log(
|
||||
"method", "ListTeams",
|
||||
"err", err,
|
||||
"took", time.Since(begin),
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
teams, err = mw.Service.ListTeams(ctx, opt)
|
||||
return teams, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) ListTeamUsers(ctx context.Context, teamID uint, opt fleet.ListOptions) ([]*fleet.User, error) {
|
||||
var (
|
||||
users []*fleet.User
|
||||
err error
|
||||
)
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerDebug(err).Log(
|
||||
"method", "ListTeamUsers",
|
||||
"err", err,
|
||||
"took", time.Since(begin),
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
users, err = mw.Service.ListTeamUsers(ctx, teamID, opt)
|
||||
return users, err
|
||||
}
|
||||
|
||||
func (mw loggingMiddleware) TeamEnrollSecrets(ctx context.Context, teamID uint) ([]*fleet.EnrollSecret, error) {
|
||||
var (
|
||||
secrets []*fleet.EnrollSecret
|
||||
err error
|
||||
)
|
||||
|
||||
defer func(begin time.Time) {
|
||||
_ = mw.loggerDebug(err).Log(
|
||||
"method", "TeamEnrollSecrets",
|
||||
"err", err,
|
||||
"took", time.Since(begin),
|
||||
)
|
||||
}(time.Now())
|
||||
|
||||
secrets, err = mw.Service.TeamEnrollSecrets(ctx, teamID)
|
||||
return secrets, err
|
||||
}
|
||||
Loading…
Reference in a new issue