mirror of
https://github.com/gravitational/teleport.git
synced 2026-10-12 02:15:01 +00:00
chore: Bump golangci-lint to v1.56.0 (#37854)
* chore: Bump golangci-lint to v1.56.0 * Use only enable linters for testifylint * Fix various testifylint offenders * Fix testifylint offenders in api/
This commit is contained in:
@@ -24,7 +24,7 @@ jobs:
|
||||
image: ghcr.io/gravitational/teleport-buildbox:teleport15
|
||||
|
||||
env:
|
||||
GOLANGCI_LINT_VERSION: v1.55.2
|
||||
GOLANGCI_LINT_VERSION: v1.56.0
|
||||
|
||||
steps:
|
||||
- name: Checkout
|
||||
|
||||
@@ -85,6 +85,7 @@ linters-settings:
|
||||
key-naming-case: snake
|
||||
static-msg: true
|
||||
testifylint:
|
||||
disable-all: true
|
||||
enable:
|
||||
- bool-compare
|
||||
- compares
|
||||
|
||||
@@ -122,14 +122,14 @@ func TestAlertAcknowledgement_Check(t *testing.T) {
|
||||
expires := time.Now().Add(5 * time.Minute)
|
||||
|
||||
testcases := []struct {
|
||||
desc string
|
||||
ack *AlertAcknowledgement
|
||||
expectedErr error
|
||||
desc string
|
||||
ack *AlertAcknowledgement
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
desc: "empty",
|
||||
ack: &AlertAcknowledgement{},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
desc: "empty",
|
||||
ack: &AlertAcknowledgement{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "missing reason",
|
||||
@@ -137,7 +137,7 @@ func TestAlertAcknowledgement_Check(t *testing.T) {
|
||||
AlertID: "alert-id",
|
||||
Expires: expires,
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "missing alert ID",
|
||||
@@ -145,7 +145,7 @@ func TestAlertAcknowledgement_Check(t *testing.T) {
|
||||
Expires: expires,
|
||||
Reason: "some reason",
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "missing expiry",
|
||||
@@ -153,7 +153,7 @@ func TestAlertAcknowledgement_Check(t *testing.T) {
|
||||
AlertID: "alert-id",
|
||||
Reason: "some reason",
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "success",
|
||||
@@ -162,7 +162,6 @@ func TestAlertAcknowledgement_Check(t *testing.T) {
|
||||
Expires: expires,
|
||||
Reason: "some reason",
|
||||
},
|
||||
expectedErr: nil,
|
||||
},
|
||||
}
|
||||
|
||||
@@ -170,12 +169,15 @@ func TestAlertAcknowledgement_Check(t *testing.T) {
|
||||
t.Run(tc.desc, func(t *testing.T) {
|
||||
err := tc.ack.Check()
|
||||
|
||||
if tc.expectedErr == nil {
|
||||
if !tc.wantErr {
|
||||
require.NoError(t, err)
|
||||
return
|
||||
}
|
||||
|
||||
require.ErrorAs(t, err, &tc.expectedErr)
|
||||
require.Error(t, err)
|
||||
require.True(t,
|
||||
trace.IsBadParameter(err),
|
||||
"want BadParameter, got %v (%T)", err, trace.Unwrap(err))
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
@@ -43,7 +43,7 @@ func TestIntegrationJSONMarshalCycle(t *testing.T) {
|
||||
err = json.Unmarshal(bs, &ig2)
|
||||
require.NoError(t, err)
|
||||
|
||||
require.Equal(t, ig, &ig2)
|
||||
require.Equal(t, &ig2, ig)
|
||||
}
|
||||
|
||||
func TestIntegrationCheckAndSetDefaults(t *testing.T) {
|
||||
|
||||
@@ -28,15 +28,15 @@ import (
|
||||
|
||||
func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
testcases := []struct {
|
||||
desc string
|
||||
token *ProvisionTokenV2
|
||||
expected *ProvisionTokenV2
|
||||
expectedErr error
|
||||
desc string
|
||||
token *ProvisionTokenV2
|
||||
expected *ProvisionTokenV2
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
desc: "empty",
|
||||
token: &ProvisionTokenV2{},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
desc: "empty",
|
||||
token: &ProvisionTokenV2{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "missing roles",
|
||||
@@ -45,7 +45,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
Name: "test",
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "invalid role",
|
||||
@@ -57,7 +57,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
Roles: []SystemRole{RoleNode, "not a role"},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "simple token",
|
||||
@@ -158,7 +158,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
JoinMethod: "ec2",
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "ec2 method with aws_arn",
|
||||
@@ -177,7 +177,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "ec2 method empty rule",
|
||||
@@ -191,7 +191,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
Allow: []*TokenRule{{}},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "iam method",
|
||||
@@ -237,7 +237,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "iam method with aws_regions",
|
||||
@@ -256,7 +256,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "github valid",
|
||||
@@ -316,7 +316,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "github slug and ghes set",
|
||||
@@ -338,7 +338,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "circleci valid",
|
||||
@@ -375,7 +375,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "circleci and no org id",
|
||||
@@ -395,7 +395,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "circleci allow rule blank",
|
||||
@@ -413,7 +413,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "kubernetes: in_cluster defaults",
|
||||
@@ -516,7 +516,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "kubernetes: missing static_jwks.jwks",
|
||||
@@ -538,7 +538,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "kubernetes: wrong service account name",
|
||||
@@ -558,7 +558,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "kubernetes: allow rule blank",
|
||||
@@ -576,7 +576,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "gitlab empty allow rules",
|
||||
@@ -592,7 +592,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "gitlab missing config",
|
||||
@@ -606,7 +606,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
GitLab: nil,
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "gitlab empty allow rule",
|
||||
@@ -624,7 +624,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "gitlab defaults",
|
||||
@@ -724,7 +724,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "spacelift",
|
||||
@@ -781,7 +781,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "spacelift rule missing fields",
|
||||
@@ -798,7 +798,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "spacelift missing hostname",
|
||||
@@ -818,7 +818,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "spacelift incorrect hostname",
|
||||
@@ -839,7 +839,7 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
desc: "gcp method",
|
||||
@@ -899,18 +899,22 @@ func TestProvisionTokenV2_CheckAndSetDefaults(t *testing.T) {
|
||||
},
|
||||
},
|
||||
},
|
||||
expectedErr: &trace.BadParameterError{},
|
||||
wantErr: true,
|
||||
},
|
||||
}
|
||||
|
||||
for _, tc := range testcases {
|
||||
t.Run(tc.desc, func(t *testing.T) {
|
||||
err := tc.token.CheckAndSetDefaults()
|
||||
if tc.expectedErr != nil {
|
||||
require.ErrorAs(t, err, &tc.expectedErr)
|
||||
if tc.wantErr {
|
||||
require.Error(t, err)
|
||||
require.True(t,
|
||||
trace.IsBadParameter(err),
|
||||
"want BadParameter, got %v (%T)", err, trace.Unwrap(err))
|
||||
return
|
||||
}
|
||||
require.NoError(t, err)
|
||||
|
||||
if tc.expected != nil {
|
||||
require.Equal(t, tc.expected, tc.token)
|
||||
}
|
||||
|
||||
@@ -319,7 +319,7 @@ RUN go install github.com/daixiang0/[email protected]
|
||||
RUN go install gotest.tools/[email protected]
|
||||
|
||||
# Install golangci-lint.
|
||||
RUN VERSION='v1.55.2'; \
|
||||
RUN VERSION='v1.56.0'; \
|
||||
curl -fsSL "https://raw.githubusercontent.com/golangci/golangci-lint/$VERSION/install.sh" | \
|
||||
sh -s -- -b "$(go env GOPATH)/bin" "$VERSION"
|
||||
|
||||
|
||||
@@ -2293,7 +2293,7 @@ func TestGetAndList_ApplicationServers(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
servers, err := clt.GetApplicationServers(ctx, apidefaults.Namespace)
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, 1, len(servers))
|
||||
require.Len(t, servers, 1)
|
||||
require.Empty(t, cmp.Diff(testServers[0:1], servers))
|
||||
resp, err := clt.ListResources(ctx, listRequest)
|
||||
require.NoError(t, err)
|
||||
@@ -2363,7 +2363,7 @@ func TestGetAndList_ApplicationServers(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
servers, err = clt.GetApplicationServers(ctx, apidefaults.Namespace)
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, 0, len(servers))
|
||||
require.Empty(t, servers)
|
||||
resp, err = clt.ListResources(ctx, listRequest)
|
||||
require.NoError(t, err)
|
||||
require.Empty(t, resp.Resources)
|
||||
@@ -2459,7 +2459,7 @@ func TestGetAndList_AppServersAndSAMLIdPServiceProviders(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
servers, err := clt.GetApplicationServers(ctx, apidefaults.Namespace)
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, 1, len(servers))
|
||||
require.Len(t, servers, 1)
|
||||
require.Empty(t, cmp.Diff(testAppServers[0:1], servers))
|
||||
resp, err := clt.ListResources(ctx, listRequestAppsOnly)
|
||||
require.NoError(t, err)
|
||||
@@ -2541,7 +2541,7 @@ func TestGetAndList_AppServersAndSAMLIdPServiceProviders(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
servers, err = clt.GetApplicationServers(ctx, apidefaults.Namespace)
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, 0, len(servers))
|
||||
require.Empty(t, servers)
|
||||
resp, err = clt.ListResources(ctx, listRequest)
|
||||
require.NoError(t, err)
|
||||
require.Empty(t, resp.Resources)
|
||||
@@ -3488,7 +3488,7 @@ func TestGetAndList_WindowsDesktops(t *testing.T) {
|
||||
|
||||
desktops, err := clt.GetWindowsDesktops(ctx, types.WindowsDesktopFilter{})
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, 1, len(desktops))
|
||||
require.Len(t, desktops, 1)
|
||||
require.Empty(t, cmp.Diff(testDesktops[0:1], desktops))
|
||||
|
||||
resp, err := clt.ListResources(ctx, listRequest)
|
||||
@@ -3574,7 +3574,7 @@ func TestGetAndList_WindowsDesktops(t *testing.T) {
|
||||
|
||||
desktops, err = clt.GetWindowsDesktops(ctx, types.WindowsDesktopFilter{})
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, 0, len(desktops))
|
||||
require.Empty(t, desktops)
|
||||
require.Empty(t, cmp.Diff([]types.WindowsDesktop{}, desktops))
|
||||
|
||||
resp, err = clt.ListResources(ctx, listRequest)
|
||||
|
||||
@@ -843,11 +843,11 @@ func TestLogin_scopeAndReuse(t *testing.T) {
|
||||
}
|
||||
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, loginData, &wanlib.LoginData{
|
||||
require.Equal(t, &wanlib.LoginData{
|
||||
Device: device,
|
||||
User: user,
|
||||
AllowReuse: loginData.AllowReuse,
|
||||
})
|
||||
}, loginData)
|
||||
|
||||
// Session data should only be deleted if reuse was not requested on begin.
|
||||
if test.challengeExt.AllowReuse == mfav1.ChallengeAllowReuse_CHALLENGE_ALLOW_REUSE_YES {
|
||||
|
||||
@@ -69,10 +69,10 @@ func TestUpsertIAMJoinToken(t *testing.T) {
|
||||
require.Equal(t, "t", iamToken.GetName())
|
||||
require.Contains(t, iamToken.GetRoles(), types.RoleDatabase)
|
||||
require.Len(t, iamToken.GetAllowRules(), 1)
|
||||
require.Equal(t, iamToken.GetAllowRules()[0], &types.TokenRule{
|
||||
require.Equal(t, &types.TokenRule{
|
||||
AWSAccount: "123456789012",
|
||||
AWSARN: "arn:aws:sts::123456789012:assumed-role/myrole/*",
|
||||
})
|
||||
}, iamToken.GetAllowRules()[0])
|
||||
})
|
||||
|
||||
t.Run("when token exist but is missing the required allow rule and system role, it is updated", func(t *testing.T) {
|
||||
@@ -104,10 +104,10 @@ func TestUpsertIAMJoinToken(t *testing.T) {
|
||||
require.Equal(t, "t", iamToken.GetName())
|
||||
require.Len(t, iamToken.GetAllowRules(), 1)
|
||||
require.Contains(t, iamToken.GetRoles(), types.RoleDatabase)
|
||||
require.Equal(t, iamToken.GetAllowRules()[0], &types.TokenRule{
|
||||
require.Equal(t, &types.TokenRule{
|
||||
AWSAccount: "123456789012",
|
||||
AWSARN: "arn:aws:sts::123456789012:assumed-role/myrole/*",
|
||||
})
|
||||
}, iamToken.GetAllowRules()[0])
|
||||
})
|
||||
|
||||
t.Run("when token exist but has an invalid join method, it returns an error", func(t *testing.T) {
|
||||
|
||||
@@ -232,11 +232,11 @@ func TestBuffer(t *testing.T) {
|
||||
|
||||
b.append(bytes.Repeat([]byte("a"), 9999))
|
||||
require.EqualValues(t, 10000, b.len())
|
||||
require.EqualValues(t, 16384, len(b.data))
|
||||
require.Len(t, b.data, 16384)
|
||||
|
||||
b.advance(5000)
|
||||
require.EqualValues(t, 5000, b.len())
|
||||
require.EqualValues(t, 16384, len(b.data))
|
||||
require.Len(t, b.data, 16384)
|
||||
|
||||
b1, b2 := b.free()
|
||||
require.NotEmpty(t, b1)
|
||||
@@ -245,12 +245,12 @@ func TestBuffer(t *testing.T) {
|
||||
|
||||
b.append(bytes.Repeat([]byte("a"), 7000))
|
||||
require.EqualValues(t, 12000, b.len())
|
||||
require.EqualValues(t, 16384, len(b.data))
|
||||
require.Len(t, b.data, 16384)
|
||||
|
||||
b1, b2 = b.free()
|
||||
require.NotEmpty(t, b1)
|
||||
require.Empty(t, b2)
|
||||
require.EqualValues(t, 16384-12000, len(b1))
|
||||
require.Len(t, b1, 16384-12000)
|
||||
|
||||
b1, b2 = b.buffered()
|
||||
require.NotEmpty(t, b1)
|
||||
|
||||
@@ -651,10 +651,12 @@ func TestAccessListReviewCRUD(t *testing.T) {
|
||||
// Verify changes to access list.
|
||||
accessList1Updated, err := service.GetAccessList(ctx, accessList1.GetName())
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, accessList1Updated.Spec.Audit.NextAuditDate,
|
||||
require.Equal(t,
|
||||
time.Date(accessList1OrigDate.Year(),
|
||||
accessList1OrigDate.Month()+time.Month(accessList1Updated.Spec.Audit.Recurrence.Frequency),
|
||||
int(accessList1Updated.Spec.Audit.Recurrence.DayOfMonth), 0, 0, 0, 0, time.UTC))
|
||||
int(accessList1Updated.Spec.Audit.Recurrence.DayOfMonth), 0, 0, 0, 0, time.UTC),
|
||||
accessList1Updated.Spec.Audit.NextAuditDate,
|
||||
)
|
||||
require.Empty(t, cmp.Diff(*(accessList1Review1.Spec.Changes.MembershipRequirementsChanged), accessList1Updated.Spec.MembershipRequires))
|
||||
require.Equal(t, accessList1Review1.Spec.Changes.ReviewFrequencyChanged, accessList1Updated.Spec.Audit.Recurrence.Frequency)
|
||||
require.Equal(t, accessList1Review1.Spec.Changes.ReviewDayOfMonthChanged, accessList1Updated.Spec.Audit.Recurrence.DayOfMonth)
|
||||
@@ -673,10 +675,12 @@ func TestAccessListReviewCRUD(t *testing.T) {
|
||||
// Verify changes to the access list again.
|
||||
accessList1Updated, err = service.GetAccessList(ctx, accessList1.GetName())
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, accessList1Updated.Spec.Audit.NextAuditDate,
|
||||
require.Equal(t,
|
||||
time.Date(accessList1OrigDate.Year(),
|
||||
accessList1OrigDate.Month()+time.Month(accessList1Updated.Spec.Audit.Recurrence.Frequency)*2,
|
||||
int(accessList1Updated.Spec.Audit.Recurrence.DayOfMonth), 0, 0, 0, 0, time.UTC))
|
||||
int(accessList1Updated.Spec.Audit.Recurrence.DayOfMonth), 0, 0, 0, 0, time.UTC),
|
||||
accessList1Updated.Spec.Audit.NextAuditDate,
|
||||
)
|
||||
|
||||
// Attempting to apply changes already reflected in the access list should modify the original review.
|
||||
require.Nil(t, accessList1Review2.Spec.Changes.MembershipRequirementsChanged)
|
||||
@@ -695,10 +699,12 @@ func TestAccessListReviewCRUD(t *testing.T) {
|
||||
|
||||
accessList2Updated, err := service.GetAccessList(ctx, accessList2.GetName())
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, accessList2Updated.Spec.Audit.NextAuditDate,
|
||||
require.Equal(t,
|
||||
time.Date(accessList2OrigDate.Year(),
|
||||
accessList2OrigDate.Month()+time.Month(accessList2Updated.Spec.Audit.Recurrence.Frequency),
|
||||
int(accessList2Updated.Spec.Audit.Recurrence.DayOfMonth), 0, 0, 0, 0, time.UTC))
|
||||
int(accessList2Updated.Spec.Audit.Recurrence.DayOfMonth), 0, 0, 0, 0, time.UTC),
|
||||
accessList2Updated.Spec.Audit.NextAuditDate,
|
||||
)
|
||||
require.Empty(t, cmp.Diff(accessList2.Spec.MembershipRequires, accessList2Updated.Spec.MembershipRequires))
|
||||
require.Equal(t, accessList2.Spec.Audit.Recurrence.Frequency, accessList2Updated.Spec.Audit.Recurrence.Frequency)
|
||||
require.Equal(t, accessList2.Spec.Audit.Recurrence.DayOfMonth, accessList2Updated.Spec.Audit.Recurrence.DayOfMonth)
|
||||
|
||||
@@ -423,7 +423,7 @@ func TestNodeCRUD(t *testing.T) {
|
||||
// Get all nodes, transparently handle limit exceeded errors
|
||||
nodes, err := presence.GetNodes(ctx, apidefaults.Namespace)
|
||||
require.NoError(t, err)
|
||||
require.EqualValues(t, len(nodes), 2)
|
||||
require.Len(t, nodes, 2)
|
||||
require.Empty(t, cmp.Diff([]types.Server{node1, node2}, nodes,
|
||||
cmpopts.IgnoreFields(types.Metadata{}, "ID", "Revision")))
|
||||
|
||||
|
||||
@@ -756,7 +756,7 @@ func TestRoleParse(t *testing.T) {
|
||||
|
||||
role2, err := UnmarshalRole(out)
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, role2, &tc.role)
|
||||
require.Equal(t, &tc.role, role2)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
@@ -143,7 +143,7 @@ func TestServerDeepCopy(t *testing.T) {
|
||||
|
||||
// verify
|
||||
require.Empty(t, cmp.Diff(srv, srv2))
|
||||
require.IsType(t, srv2, &types.ServerV2{})
|
||||
require.IsType(t, &types.ServerV2{}, srv2)
|
||||
|
||||
// Mutate the second value but expect the original to be unaffected
|
||||
srv2.(*types.ServerV2).Metadata.Labels["foo"] = "bar"
|
||||
|
||||
@@ -275,7 +275,7 @@ func TestDiscoveryServer(t *testing.T) {
|
||||
emitter: &mockEmitter{
|
||||
eventHandler: func(t *testing.T, ae events.AuditEvent, server *Server) {
|
||||
t.Helper()
|
||||
require.Equal(t, ae, &events.SSMRun{
|
||||
require.Equal(t, &events.SSMRun{
|
||||
Metadata: events.Metadata{
|
||||
Type: libevents.SSMRunEvent,
|
||||
Code: libevents.SSMRunSuccessCode,
|
||||
@@ -286,7 +286,7 @@ func TestDiscoveryServer(t *testing.T) {
|
||||
Region: "eu-central-1",
|
||||
ExitCode: 0,
|
||||
Status: ssm.CommandStatusSuccess,
|
||||
})
|
||||
}, ae)
|
||||
},
|
||||
},
|
||||
staticMatchers: defaultStaticMatcher,
|
||||
@@ -423,7 +423,7 @@ func TestDiscoveryServer(t *testing.T) {
|
||||
emitter: &mockEmitter{
|
||||
eventHandler: func(t *testing.T, ae events.AuditEvent, server *Server) {
|
||||
t.Helper()
|
||||
require.Equal(t, ae, &events.SSMRun{
|
||||
require.Equal(t, &events.SSMRun{
|
||||
Metadata: events.Metadata{
|
||||
Type: libevents.SSMRunEvent,
|
||||
Code: libevents.SSMRunSuccessCode,
|
||||
@@ -434,7 +434,7 @@ func TestDiscoveryServer(t *testing.T) {
|
||||
Region: "eu-central-1",
|
||||
ExitCode: 0,
|
||||
Status: ssm.CommandStatusSuccess,
|
||||
})
|
||||
}, ae)
|
||||
},
|
||||
},
|
||||
staticMatchers: Matchers{},
|
||||
|
||||
@@ -32,7 +32,9 @@ func TestRejectsInvalidPEMData(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
_, err := ReadCertificates([]byte("no data"))
|
||||
require.IsType(t, trace.Unwrap(err), &trace.NotFoundError{})
|
||||
require.True(t,
|
||||
trace.IsNotFound(err),
|
||||
"want trace.NotFoundError, got %v (%T)", err, trace.Unwrap(err))
|
||||
}
|
||||
|
||||
func TestRejectsSelfSignedCertificate(t *testing.T) {
|
||||
|
||||
@@ -6780,9 +6780,9 @@ func TestDiagnoseKubeConnection(t *testing.T) {
|
||||
}
|
||||
|
||||
foundTrace = true
|
||||
require.Equal(t, returnedTrace.Status, expectedTrace.Status.String())
|
||||
require.Equal(t, returnedTrace.Details, expectedTrace.Details)
|
||||
require.Contains(t, returnedTrace.Error, expectedTrace.Error)
|
||||
require.Equal(t, expectedTrace.Status.String(), returnedTrace.Status)
|
||||
require.Equal(t, expectedTrace.Details, returnedTrace.Details)
|
||||
require.Contains(t, expectedTrace.Error, returnedTrace.Error)
|
||||
}
|
||||
|
||||
require.True(t, foundTrace, expectedTrace)
|
||||
|
||||
@@ -401,7 +401,7 @@ func TestHandleDatabaseServicesGet(t *testing.T) {
|
||||
require.Len(t, respDBService.ResourceMatchers, 1)
|
||||
respResourceMatcher := respDBService.ResourceMatchers[0]
|
||||
|
||||
require.Equal(t, respResourceMatcher.Labels, &types.Labels{"env": []string{"prod"}})
|
||||
require.Equal(t, &types.Labels{"env": []string{"prod"}}, respResourceMatcher.Labels)
|
||||
}
|
||||
|
||||
func TestHandleSQLServerConfigureScript(t *testing.T) {
|
||||
|
||||
@@ -289,12 +289,12 @@ version: v2
|
||||
|
||||
item, err := ui.NewResourceItem(cluster)
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, item, &ui.ResourceItem{
|
||||
require.Equal(t, &ui.ResourceItem{
|
||||
ID: "trusted_cluster:tcName",
|
||||
Kind: types.KindTrustedCluster,
|
||||
Name: "tcName",
|
||||
Content: contents,
|
||||
})
|
||||
}, item)
|
||||
}
|
||||
|
||||
func TestGetRoles(t *testing.T) {
|
||||
|
||||
@@ -156,15 +156,15 @@ func TestCreateNode(t *testing.T) {
|
||||
node, err := env.proxies[0].client.GetNode(ctx, "default", tt.req.Name)
|
||||
require.NoError(t, err)
|
||||
|
||||
require.Equal(t, node.GetName(), tt.req.Name)
|
||||
require.Equal(t, node.GetAWSInfo(), &types.AWSInfo{
|
||||
require.Equal(t, tt.req.Name, node.GetName())
|
||||
require.Equal(t, &types.AWSInfo{
|
||||
AccountID: tt.req.AWSInfo.AccountID,
|
||||
InstanceID: tt.req.AWSInfo.InstanceID,
|
||||
Region: tt.req.AWSInfo.Region,
|
||||
VPCID: tt.req.AWSInfo.VPCID,
|
||||
Integration: tt.req.AWSInfo.Integration,
|
||||
SubnetID: tt.req.AWSInfo.SubnetID,
|
||||
})
|
||||
}, node.GetAWSInfo())
|
||||
}
|
||||
})
|
||||
|
||||
|
||||
Reference in New Issue
Block a user