(t *testing.T)
| 3892 | } |
| 3893 | |
| 3894 | func Test_updateAllPrincipalsSequences(t *testing.T) { |
| 3895 | db, ctx := setupTestDB(t) |
| 3896 | defer db.Close(ctx) |
| 3897 | |
| 3898 | auth := db.Authenticator(ctx) |
| 3899 | roleSequences := [5]uint64{} |
| 3900 | userSequences := [5]uint64{} |
| 3901 | |
| 3902 | collection := GetSingleDatabaseCollection(t, db.DatabaseContext) |
| 3903 | |
| 3904 | for i := 0; i < 5; i++ { |
| 3905 | role, err := auth.NewRole(fmt.Sprintf("role%d", i), base.SetOf("ABC")) |
| 3906 | require.NoError(t, err) |
| 3907 | assert.NotEmpty(t, role) |
| 3908 | err = auth.Save(role) |
| 3909 | require.NoError(t, err) |
| 3910 | roleSequences[i] = role.Sequence() |
| 3911 | |
| 3912 | user, err := auth.NewUser(fmt.Sprintf("user%d", i), "letmein", base.SetOf("ABC")) |
| 3913 | require.NoError(t, err) |
| 3914 | assert.NotEmpty(t, user) |
| 3915 | err = auth.Save(user) |
| 3916 | require.NoError(t, err) |
| 3917 | userSequences[i] = user.Sequence() |
| 3918 | } |
| 3919 | err := collection.updateAllPrincipalsSequences(ctx) |
| 3920 | require.NoError(t, err) |
| 3921 | |
| 3922 | for i := 0; i < 5; i++ { |
| 3923 | role, err := auth.GetRole(fmt.Sprintf("role%d", i)) |
| 3924 | assert.NoError(t, err) |
| 3925 | assert.Greater(t, role.Sequence(), roleSequences[i]) |
| 3926 | |
| 3927 | user, err := auth.GetUser(fmt.Sprintf("user%d", i)) |
| 3928 | assert.NoError(t, err) |
| 3929 | assert.Greater(t, user.Sequence(), userSequences[i]) |
| 3930 | } |
| 3931 | } |
| 3932 | |
| 3933 | func Test_invalidateAllPrincipalsCache(t *testing.T) { |
| 3934 | base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll) |
nothing calls this directly
no test coverage detected