package user import ( "database/sql" "fmt" "github.com/stretchr/testify/require" "github.com/stripe/stripe-go/v74" "golang.org/x/crypto/bcrypt" "heckel.io/ntfy/util" "net/netip" "path/filepath" "strings" "testing" "time" ) const minBcryptTimingMillis = int64(50) // Ideally should be >100ms, but this should also run on a Raspberry Pi without massive resources func TestManager_FullScenario_Default_DenyAll(t *testing.T) { a := newTestManagerFromFile(t, filepath.Join(t.TempDir(), "user.db"), "", PermissionDenyAll, DefaultUserPasswordBcryptCost, DefaultUserStatsQueueWriterInterval) require.Nil(t, a.AddUser("phil", "phil", RoleAdmin)) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) require.Nil(t, a.AllowAccess("ben", "mytopic", PermissionReadWrite)) require.Nil(t, a.AllowAccess("ben", "readme", PermissionRead)) require.Nil(t, a.AllowAccess("ben", "writeme", PermissionWrite)) require.Nil(t, a.AllowAccess("ben", "everyonewrite", PermissionDenyAll)) // How unfair! require.Nil(t, a.AllowAccess(Everyone, "announcements", PermissionRead)) require.Nil(t, a.AllowAccess(Everyone, "everyonewrite", PermissionReadWrite)) require.Nil(t, a.AllowAccess(Everyone, "up*", PermissionWrite)) // Everyone can write to /up* phil, err := a.Authenticate("phil", "phil") require.Nil(t, err) require.Equal(t, "phil", phil.Name) require.True(t, strings.HasPrefix(phil.Hash, "$2a$10$")) require.Equal(t, RoleAdmin, phil.Role) philGrants, err := a.Grants("phil") require.Nil(t, err) require.Equal(t, []Grant{}, philGrants) ben, err := a.Authenticate("ben", "ben") require.Nil(t, err) require.Equal(t, "ben", ben.Name) require.True(t, strings.HasPrefix(ben.Hash, "$2a$10$")) require.Equal(t, RoleUser, ben.Role) benGrants, err := a.Grants("ben") require.Nil(t, err) require.Equal(t, []Grant{ {"mytopic", PermissionReadWrite}, {"writeme", PermissionWrite}, {"readme", PermissionRead}, {"everyonewrite", PermissionDenyAll}, }, benGrants) notben, err := a.Authenticate("ben", "this is wrong") require.Nil(t, notben) require.Equal(t, ErrUnauthenticated, err) // Admin can do everything require.Nil(t, a.Authorize(phil, "sometopic", PermissionWrite)) require.Nil(t, a.Authorize(phil, "mytopic", PermissionRead)) require.Nil(t, a.Authorize(phil, "readme", PermissionWrite)) require.Nil(t, a.Authorize(phil, "writeme", PermissionWrite)) require.Nil(t, a.Authorize(phil, "announcements", PermissionWrite)) require.Nil(t, a.Authorize(phil, "everyonewrite", PermissionWrite)) // User cannot do everything require.Nil(t, a.Authorize(ben, "mytopic", PermissionWrite)) require.Nil(t, a.Authorize(ben, "mytopic", PermissionRead)) require.Nil(t, a.Authorize(ben, "readme", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "readme", PermissionWrite)) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "writeme", PermissionRead)) require.Nil(t, a.Authorize(ben, "writeme", PermissionWrite)) require.Nil(t, a.Authorize(ben, "writeme", PermissionWrite)) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "everyonewrite", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "everyonewrite", PermissionWrite)) require.Nil(t, a.Authorize(ben, "announcements", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "announcements", PermissionWrite)) // Everyone else can do barely anything require.Equal(t, ErrUnauthorized, a.Authorize(nil, "sometopicnotinthelist", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "sometopicnotinthelist", PermissionWrite)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "mytopic", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "mytopic", PermissionWrite)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "readme", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "readme", PermissionWrite)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "writeme", PermissionRead)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "writeme", PermissionWrite)) require.Equal(t, ErrUnauthorized, a.Authorize(nil, "announcements", PermissionWrite)) require.Nil(t, a.Authorize(nil, "announcements", PermissionRead)) require.Nil(t, a.Authorize(nil, "everyonewrite", PermissionRead)) require.Nil(t, a.Authorize(nil, "everyonewrite", PermissionWrite)) require.Nil(t, a.Authorize(nil, "up1234", PermissionWrite)) // Wildcard permission require.Nil(t, a.Authorize(nil, "up5678", PermissionWrite)) } func TestManager_AddUser_Invalid(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Equal(t, ErrInvalidArgument, a.AddUser(" invalid ", "pass", RoleAdmin)) require.Equal(t, ErrInvalidArgument, a.AddUser("validuser", "pass", "invalid-role")) } func TestManager_AddUser_Timing(t *testing.T) { a := newTestManagerFromFile(t, filepath.Join(t.TempDir(), "user.db"), "", PermissionDenyAll, DefaultUserPasswordBcryptCost, DefaultUserStatsQueueWriterInterval) start := time.Now().UnixMilli() require.Nil(t, a.AddUser("user", "pass", RoleAdmin)) require.GreaterOrEqual(t, time.Now().UnixMilli()-start, minBcryptTimingMillis) } func TestManager_AddUser_And_Query(t *testing.T) { a := newTestManagerFromFile(t, filepath.Join(t.TempDir(), "user.db"), "", PermissionDenyAll, DefaultUserPasswordBcryptCost, DefaultUserStatsQueueWriterInterval) require.Nil(t, a.AddUser("user", "pass", RoleAdmin)) require.Nil(t, a.ChangeBilling("user", &Billing{ StripeCustomerID: "acct_123", StripeSubscriptionID: "sub_123", StripeSubscriptionStatus: stripe.SubscriptionStatusActive, StripeSubscriptionInterval: stripe.PriceRecurringIntervalMonth, StripeSubscriptionPaidUntil: time.Now().Add(time.Hour), StripeSubscriptionCancelAt: time.Unix(0, 0), })) u, err := a.User("user") require.Nil(t, err) require.Equal(t, "user", u.Name) u2, err := a.UserByID(u.ID) require.Nil(t, err) require.Equal(t, u.Name, u2.Name) u3, err := a.UserByStripeCustomer("acct_123") require.Nil(t, err) require.Equal(t, u.ID, u3.ID) } func TestManager_MarkUserRemoved_RemoveDeletedUsers(t *testing.T) { a := newTestManager(t, PermissionDenyAll) // Create user, add reservations and token require.Nil(t, a.AddUser("user", "pass", RoleAdmin)) require.Nil(t, a.AddReservation("user", "mytopic", PermissionRead)) u, err := a.User("user") require.Nil(t, err) require.False(t, u.Deleted) token, err := a.CreateToken(u.ID, "", time.Now().Add(time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) u, err = a.Authenticate("user", "pass") require.Nil(t, err) _, err = a.AuthenticateToken(token.Value) require.Nil(t, err) reservations, err := a.Reservations("user") require.Nil(t, err) require.Equal(t, 1, len(reservations)) // Mark deleted: cannot auth anymore, and all reservations are gone require.Nil(t, a.MarkUserRemoved(u)) _, err = a.Authenticate("user", "pass") require.Equal(t, ErrUnauthenticated, err) _, err = a.AuthenticateToken(token.Value) require.Equal(t, ErrUnauthenticated, err) reservations, err = a.Reservations("user") require.Nil(t, err) require.Equal(t, 0, len(reservations)) // Make sure user is still there u, err = a.User("user") require.Nil(t, err) require.True(t, u.Deleted) _, err = a.db.Exec("UPDATE user SET deleted = ? WHERE id = ?", time.Now().Add(-1*(userHardDeleteAfterDuration+time.Hour)).Unix(), u.ID) require.Nil(t, err) require.Nil(t, a.RemoveDeletedUsers()) _, err = a.User("user") require.Equal(t, ErrUserNotFound, err) } func TestManager_UserManagement(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("phil", "phil", RoleAdmin)) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) require.Nil(t, a.AllowAccess("ben", "mytopic", PermissionReadWrite)) require.Nil(t, a.AllowAccess("ben", "readme", PermissionRead)) require.Nil(t, a.AllowAccess("ben", "writeme", PermissionWrite)) require.Nil(t, a.AllowAccess("ben", "everyonewrite", PermissionDenyAll)) // How unfair! require.Nil(t, a.AllowAccess(Everyone, "announcements", PermissionRead)) require.Nil(t, a.AllowAccess(Everyone, "everyonewrite", PermissionReadWrite)) // Query user details phil, err := a.User("phil") require.Nil(t, err) require.Equal(t, "phil", phil.Name) require.True(t, strings.HasPrefix(phil.Hash, "$2a$04$")) // Min cost for testing require.Equal(t, RoleAdmin, phil.Role) philGrants, err := a.Grants("phil") require.Nil(t, err) require.Equal(t, []Grant{}, philGrants) ben, err := a.User("ben") require.Nil(t, err) require.Equal(t, "ben", ben.Name) require.True(t, strings.HasPrefix(ben.Hash, "$2a$04$")) // Min cost for testing require.Equal(t, RoleUser, ben.Role) benGrants, err := a.Grants("ben") require.Nil(t, err) require.Equal(t, []Grant{ {"mytopic", PermissionReadWrite}, {"writeme", PermissionWrite}, {"readme", PermissionRead}, {"everyonewrite", PermissionDenyAll}, }, benGrants) everyone, err := a.User(Everyone) require.Nil(t, err) require.Equal(t, "*", everyone.Name) require.Equal(t, "", everyone.Hash) require.Equal(t, RoleAnonymous, everyone.Role) everyoneGrants, err := a.Grants(Everyone) require.Nil(t, err) require.Equal(t, []Grant{ {"everyonewrite", PermissionReadWrite}, {"announcements", PermissionRead}, }, everyoneGrants) // Ben: Before revoking require.Nil(t, a.AllowAccess("ben", "mytopic", PermissionReadWrite)) // Overwrite! require.Nil(t, a.AllowAccess("ben", "readme", PermissionRead)) require.Nil(t, a.AllowAccess("ben", "writeme", PermissionWrite)) require.Nil(t, a.Authorize(ben, "mytopic", PermissionRead)) require.Nil(t, a.Authorize(ben, "mytopic", PermissionWrite)) require.Nil(t, a.Authorize(ben, "readme", PermissionRead)) require.Nil(t, a.Authorize(ben, "writeme", PermissionWrite)) // Revoke access for "ben" to "mytopic", then check again require.Nil(t, a.ResetAccess("ben", "mytopic")) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "mytopic", PermissionWrite)) // Revoked require.Equal(t, ErrUnauthorized, a.Authorize(ben, "mytopic", PermissionRead)) // Revoked require.Nil(t, a.Authorize(ben, "readme", PermissionRead)) // Unchanged require.Nil(t, a.Authorize(ben, "writeme", PermissionWrite)) // Unchanged // Revoke rest of the access require.Nil(t, a.ResetAccess("ben", "")) require.Equal(t, ErrUnauthorized, a.Authorize(ben, "readme", PermissionRead)) // Revoked require.Equal(t, ErrUnauthorized, a.Authorize(ben, "wrtiteme", PermissionWrite)) // Revoked // User list users, err := a.Users() require.Nil(t, err) require.Equal(t, 3, len(users)) require.Equal(t, "phil", users[0].Name) require.Equal(t, "ben", users[1].Name) require.Equal(t, "*", users[2].Name) // Remove user require.Nil(t, a.RemoveUser("ben")) _, err = a.User("ben") require.Equal(t, ErrUserNotFound, err) users, err = a.Users() require.Nil(t, err) require.Equal(t, 2, len(users)) require.Equal(t, "phil", users[0].Name) require.Equal(t, "*", users[1].Name) } func TestManager_ChangePassword(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("phil", "phil", RoleAdmin)) _, err := a.Authenticate("phil", "phil") require.Nil(t, err) require.Nil(t, a.ChangePassword("phil", "newpass")) _, err = a.Authenticate("phil", "phil") require.Equal(t, ErrUnauthenticated, err) _, err = a.Authenticate("phil", "newpass") require.Nil(t, err) } func TestManager_ChangeRole(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) require.Nil(t, a.AllowAccess("ben", "mytopic", PermissionReadWrite)) require.Nil(t, a.AllowAccess("ben", "readme", PermissionRead)) ben, err := a.User("ben") require.Nil(t, err) require.Equal(t, RoleUser, ben.Role) benGrants, err := a.Grants("ben") require.Nil(t, err) require.Equal(t, 2, len(benGrants)) require.Nil(t, a.ChangeRole("ben", RoleAdmin)) ben, err = a.User("ben") require.Nil(t, err) require.Equal(t, RoleAdmin, ben.Role) benGrants, err = a.Grants("ben") require.Nil(t, err) require.Equal(t, 0, len(benGrants)) } func TestManager_Reservations(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("phil", "phil", RoleUser)) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) require.Nil(t, a.AddReservation("ben", "ztopic", PermissionDenyAll)) require.Nil(t, a.AddReservation("ben", "readme", PermissionRead)) require.Nil(t, a.AllowAccess("ben", "something-else", PermissionRead)) reservations, err := a.Reservations("ben") require.Nil(t, err) require.Equal(t, 2, len(reservations)) require.Equal(t, Reservation{ Topic: "readme", Owner: PermissionReadWrite, Everyone: PermissionRead, }, reservations[0]) require.Equal(t, Reservation{ Topic: "ztopic", Owner: PermissionReadWrite, Everyone: PermissionDenyAll, }, reservations[1]) b, err := a.HasReservation("ben", "readme") require.Nil(t, err) require.True(t, b) b, err = a.HasReservation("notben", "readme") require.Nil(t, err) require.False(t, b) b, err = a.HasReservation("ben", "something-else") require.Nil(t, err) require.False(t, b) count, err := a.ReservationsCount("ben") require.Nil(t, err) require.Equal(t, int64(2), count) count, err = a.ReservationsCount("phil") require.Nil(t, err) require.Equal(t, int64(0), count) err = a.AllowReservation("phil", "readme") require.Equal(t, errTopicOwnedByOthers, err) err = a.AllowReservation("phil", "not-reserved") require.Nil(t, err) // Now remove them again require.Nil(t, a.RemoveReservations("ben", "ztopic", "readme")) count, err = a.ReservationsCount("ben") require.Nil(t, err) require.Equal(t, int64(0), count) } func TestManager_ChangeRoleFromTierUserToAdmin(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddTier(&Tier{ Code: "pro", Name: "ntfy Pro", StripeMonthlyPriceID: "price123", MessageLimit: 5_000, MessageExpiryDuration: 3 * 24 * time.Hour, EmailLimit: 50, ReservationLimit: 5, AttachmentFileSizeLimit: 52428800, AttachmentTotalSizeLimit: 524288000, AttachmentExpiryDuration: 24 * time.Hour, })) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) require.Nil(t, a.ChangeTier("ben", "pro")) require.Nil(t, a.AddReservation("ben", "mytopic", PermissionDenyAll)) ben, err := a.User("ben") require.Nil(t, err) require.Equal(t, RoleUser, ben.Role) require.Equal(t, "pro", ben.Tier.Code) require.Equal(t, int64(5000), ben.Tier.MessageLimit) require.Equal(t, 3*24*time.Hour, ben.Tier.MessageExpiryDuration) require.Equal(t, int64(50), ben.Tier.EmailLimit) require.Equal(t, int64(5), ben.Tier.ReservationLimit) require.Equal(t, int64(52428800), ben.Tier.AttachmentFileSizeLimit) require.Equal(t, int64(524288000), ben.Tier.AttachmentTotalSizeLimit) require.Equal(t, 24*time.Hour, ben.Tier.AttachmentExpiryDuration) benGrants, err := a.Grants("ben") require.Nil(t, err) require.Equal(t, 1, len(benGrants)) require.Equal(t, PermissionReadWrite, benGrants[0].Allow) everyoneGrants, err := a.Grants(Everyone) require.Nil(t, err) require.Equal(t, 1, len(everyoneGrants)) require.Equal(t, PermissionDenyAll, everyoneGrants[0].Allow) benReservations, err := a.Reservations("ben") require.Nil(t, err) require.Equal(t, 1, len(benReservations)) require.Equal(t, "mytopic", benReservations[0].Topic) require.Equal(t, PermissionReadWrite, benReservations[0].Owner) require.Equal(t, PermissionDenyAll, benReservations[0].Everyone) // Switch to admin, this should remove all grants and owned ACL entries require.Nil(t, a.ChangeRole("ben", RoleAdmin)) benGrants, err = a.Grants("ben") require.Nil(t, err) require.Equal(t, 0, len(benGrants)) everyoneGrants, err = a.Grants(Everyone) require.Nil(t, err) require.Equal(t, 0, len(everyoneGrants)) } func TestManager_Token_Valid(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) u, err := a.User("ben") require.Nil(t, err) // Create token for user token, err := a.CreateToken(u.ID, "some label", time.Now().Add(72*time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) require.NotEmpty(t, token.Value) require.Equal(t, "some label", token.Label) require.True(t, time.Now().Add(71*time.Hour).Unix() < token.Expires.Unix()) u2, err := a.AuthenticateToken(token.Value) require.Nil(t, err) require.Equal(t, u.Name, u2.Name) require.Equal(t, token.Value, u2.Token) token2, err := a.Token(u.ID, token.Value) require.Nil(t, err) require.Equal(t, token.Value, token2.Value) require.Equal(t, "some label", token2.Label) tokens, err := a.Tokens(u.ID) require.Nil(t, err) require.Equal(t, 1, len(tokens)) require.Equal(t, "some label", tokens[0].Label) tokens, err = a.Tokens("u_notauser") require.Nil(t, err) require.Equal(t, 0, len(tokens)) // Remove token and auth again require.Nil(t, a.RemoveToken(u2.ID, u2.Token)) u3, err := a.AuthenticateToken(token.Value) require.Equal(t, ErrUnauthenticated, err) require.Nil(t, u3) tokens, err = a.Tokens(u.ID) require.Nil(t, err) require.Equal(t, 0, len(tokens)) } func TestManager_Token_Invalid(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) u, err := a.AuthenticateToken(strings.Repeat("x", 32)) // 32 == token length require.Nil(t, u) require.Equal(t, ErrUnauthenticated, err) u, err = a.AuthenticateToken("not long enough anyway") require.Nil(t, u) require.Equal(t, ErrUnauthenticated, err) } func TestManager_Token_NotFound(t *testing.T) { a := newTestManager(t, PermissionDenyAll) _, err := a.Token("u_bla", "notfound") require.Equal(t, ErrTokenNotFound, err) } func TestManager_Token_Expire(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) u, err := a.User("ben") require.Nil(t, err) // Create tokens for user token1, err := a.CreateToken(u.ID, "", time.Now().Add(72*time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) require.NotEmpty(t, token1.Value) require.True(t, time.Now().Add(71*time.Hour).Unix() < token1.Expires.Unix()) token2, err := a.CreateToken(u.ID, "", time.Now().Add(72*time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) require.NotEmpty(t, token2.Value) require.NotEqual(t, token1.Value, token2.Value) require.True(t, time.Now().Add(71*time.Hour).Unix() < token2.Expires.Unix()) // See that tokens work _, err = a.AuthenticateToken(token1.Value) require.Nil(t, err) _, err = a.AuthenticateToken(token2.Value) require.Nil(t, err) // Modify token expiration in database _, err = a.db.Exec("UPDATE user_token SET expires = 1 WHERE token = ?", token1.Value) require.Nil(t, err) // Now token1 shouldn't work anymore _, err = a.AuthenticateToken(token1.Value) require.Equal(t, ErrUnauthenticated, err) result, err := a.db.Query("SELECT * from user_token WHERE token = ?", token1.Value) require.Nil(t, err) require.True(t, result.Next()) // Still a matching row require.Nil(t, result.Close()) // Expire tokens and check database rows require.Nil(t, a.RemoveExpiredTokens()) result, err = a.db.Query("SELECT * from user_token WHERE token = ?", token1.Value) require.Nil(t, err) require.False(t, result.Next()) // No matching row! require.Nil(t, result.Close()) } func TestManager_Token_Extend(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) // Try to extend token for user without token u, err := a.User("ben") require.Nil(t, err) _, err = a.ChangeToken(u.ID, u.Token, util.String("some label"), util.Time(time.Now().Add(time.Hour))) require.Equal(t, errNoTokenProvided, err) // Create token for user token, err := a.CreateToken(u.ID, "", time.Now().Add(72*time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) require.NotEmpty(t, token.Value) userWithToken, err := a.AuthenticateToken(token.Value) require.Nil(t, err) extendedToken, err := a.ChangeToken(userWithToken.ID, userWithToken.Token, util.String("changed label"), util.Time(time.Now().Add(100*time.Hour))) require.Nil(t, err) require.Equal(t, token.Value, extendedToken.Value) require.Equal(t, "changed label", extendedToken.Label) require.True(t, token.Expires.Unix() < extendedToken.Expires.Unix()) require.True(t, time.Now().Add(99*time.Hour).Unix() < extendedToken.Expires.Unix()) } func TestManager_Token_MaxCount_AutoDelete(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) // Try to extend token for user without token u, err := a.User("ben") require.Nil(t, err) // Tokens baseTime := time.Now().Add(24 * time.Hour) tokens := make([]string, 0) for i := 0; i < 22; i++ { token, err := a.CreateToken(u.ID, "", time.Now().Add(72*time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) require.NotEmpty(t, token.Value) tokens = append(tokens, token.Value) // Manually modify expiry date to avoid sorting issues (this is a hack) _, err = a.db.Exec(`UPDATE user_token SET expires=? WHERE token=?`, baseTime.Add(time.Duration(i)*time.Minute).Unix(), token.Value) require.Nil(t, err) } _, err = a.AuthenticateToken(tokens[0]) require.Equal(t, ErrUnauthenticated, err) _, err = a.AuthenticateToken(tokens[1]) require.Equal(t, ErrUnauthenticated, err) for i := 2; i < 22; i++ { userWithToken, err := a.AuthenticateToken(tokens[i]) require.Nil(t, err, "token[%d]=%s failed", i, tokens[i]) require.Equal(t, "ben", userWithToken.Name) require.Equal(t, tokens[i], userWithToken.Token) } var count int rows, err := a.db.Query(`SELECT COUNT(*) FROM user_token`) require.Nil(t, err) require.True(t, rows.Next()) require.Nil(t, rows.Scan(&count)) require.Equal(t, 20, count) } func TestManager_EnqueueStats_ResetStats(t *testing.T) { a, err := NewManager(filepath.Join(t.TempDir(), "db"), "", PermissionReadWrite, bcrypt.MinCost, 1500*time.Millisecond) require.Nil(t, err) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) // Baseline: No messages or emails u, err := a.User("ben") require.Nil(t, err) require.Equal(t, int64(0), u.Stats.Messages) require.Equal(t, int64(0), u.Stats.Emails) a.EnqueueUserStats(u.ID, &Stats{ Messages: 11, Emails: 2, }) // Still no change, because it's queued asynchronously u, err = a.User("ben") require.Nil(t, err) require.Equal(t, int64(0), u.Stats.Messages) require.Equal(t, int64(0), u.Stats.Emails) // After 2 seconds they should be persisted time.Sleep(2 * time.Second) u, err = a.User("ben") require.Nil(t, err) require.Equal(t, int64(11), u.Stats.Messages) require.Equal(t, int64(2), u.Stats.Emails) // Now reset stats (enqueued stats will be thrown out) a.EnqueueUserStats(u.ID, &Stats{ Messages: 99, Emails: 23, }) require.Nil(t, a.ResetStats()) u, err = a.User("ben") require.Nil(t, err) require.Equal(t, int64(0), u.Stats.Messages) require.Equal(t, int64(0), u.Stats.Emails) } func TestManager_EnqueueTokenUpdate(t *testing.T) { a, err := NewManager(filepath.Join(t.TempDir(), "db"), "", PermissionReadWrite, bcrypt.MinCost, 500*time.Millisecond) require.Nil(t, err) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) // Create user and token u, err := a.User("ben") require.Nil(t, err) token, err := a.CreateToken(u.ID, "", time.Now().Add(time.Hour), netip.IPv4Unspecified()) require.Nil(t, err) // Queue token update a.EnqueueTokenUpdate(token.Value, &TokenUpdate{ LastAccess: time.Unix(111, 0).UTC(), LastOrigin: netip.MustParseAddr("1.2.3.3"), }) // Token has not changed yet. token2, err := a.Token(u.ID, token.Value) require.Nil(t, err) require.Equal(t, token.LastAccess.Unix(), token2.LastAccess.Unix()) require.Equal(t, token.LastOrigin, token2.LastOrigin) // After a second or so they should be persisted time.Sleep(time.Second) token3, err := a.Token(u.ID, token.Value) require.Nil(t, err) require.Equal(t, time.Unix(111, 0).UTC().Unix(), token3.LastAccess.Unix()) require.Equal(t, netip.MustParseAddr("1.2.3.3"), token3.LastOrigin) } func TestManager_ChangeSettings(t *testing.T) { a, err := NewManager(filepath.Join(t.TempDir(), "db"), "", PermissionReadWrite, bcrypt.MinCost, 1500*time.Millisecond) require.Nil(t, err) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) // No settings u, err := a.User("ben") require.Nil(t, err) require.Nil(t, u.Prefs.Subscriptions) require.Nil(t, u.Prefs.Notification) require.Nil(t, u.Prefs.Language) // Save with new settings prefs := &Prefs{ Language: util.String("de"), Notification: &NotificationPrefs{ Sound: util.String("ding"), MinPriority: util.Int(2), }, Subscriptions: []*Subscription{ { BaseURL: "https://ntfy.sh", Topic: "mytopic", DisplayName: util.String("My Topic"), }, }, } require.Nil(t, a.ChangeSettings(u.ID, prefs)) // Read again u, err = a.User("ben") require.Nil(t, err) require.Equal(t, util.String("de"), u.Prefs.Language) require.Equal(t, util.String("ding"), u.Prefs.Notification.Sound) require.Equal(t, util.Int(2), u.Prefs.Notification.MinPriority) require.Nil(t, u.Prefs.Notification.DeleteAfter) require.Equal(t, "https://ntfy.sh", u.Prefs.Subscriptions[0].BaseURL) require.Equal(t, "mytopic", u.Prefs.Subscriptions[0].Topic) require.Equal(t, util.String("My Topic"), u.Prefs.Subscriptions[0].DisplayName) } func TestManager_Tier_Create_Update_List_Delete(t *testing.T) { a := newTestManager(t, PermissionDenyAll) // Create tier and user require.Nil(t, a.AddTier(&Tier{ Code: "supporter", Name: "Supporter", MessageLimit: 1, MessageExpiryDuration: time.Second, EmailLimit: 1, ReservationLimit: 1, AttachmentFileSizeLimit: 1, AttachmentTotalSizeLimit: 1, AttachmentExpiryDuration: time.Second, AttachmentBandwidthLimit: 1, StripeMonthlyPriceID: "price_1", })) require.Nil(t, a.AddTier(&Tier{ Code: "pro", Name: "Pro", MessageLimit: 123, MessageExpiryDuration: 86400 * time.Second, EmailLimit: 32, ReservationLimit: 2, AttachmentFileSizeLimit: 1231231, AttachmentTotalSizeLimit: 123123, AttachmentExpiryDuration: 10800 * time.Second, AttachmentBandwidthLimit: 21474836480, StripeMonthlyPriceID: "price_2", })) require.Nil(t, a.AddUser("phil", "phil", RoleUser)) require.Nil(t, a.ChangeTier("phil", "pro")) ti, err := a.Tier("pro") require.Nil(t, err) u, err := a.User("phil") require.Nil(t, err) // These are populated by different SQL queries require.Equal(t, ti, u.Tier) // Fields require.True(t, strings.HasPrefix(ti.ID, "ti_")) require.Equal(t, "pro", ti.Code) require.Equal(t, "Pro", ti.Name) require.Equal(t, int64(123), ti.MessageLimit) require.Equal(t, 86400*time.Second, ti.MessageExpiryDuration) require.Equal(t, int64(32), ti.EmailLimit) require.Equal(t, int64(2), ti.ReservationLimit) require.Equal(t, int64(1231231), ti.AttachmentFileSizeLimit) require.Equal(t, int64(123123), ti.AttachmentTotalSizeLimit) require.Equal(t, 10800*time.Second, ti.AttachmentExpiryDuration) require.Equal(t, int64(21474836480), ti.AttachmentBandwidthLimit) require.Equal(t, "price_2", ti.StripeMonthlyPriceID) // Update tier ti.EmailLimit = 999999 require.Nil(t, a.UpdateTier(ti)) // List tiers tiers, err := a.Tiers() require.Nil(t, err) require.Equal(t, 2, len(tiers)) ti = tiers[0] require.Equal(t, "supporter", ti.Code) require.Equal(t, "Supporter", ti.Name) require.Equal(t, int64(1), ti.MessageLimit) require.Equal(t, time.Second, ti.MessageExpiryDuration) require.Equal(t, int64(1), ti.EmailLimit) require.Equal(t, int64(1), ti.ReservationLimit) require.Equal(t, int64(1), ti.AttachmentFileSizeLimit) require.Equal(t, int64(1), ti.AttachmentTotalSizeLimit) require.Equal(t, time.Second, ti.AttachmentExpiryDuration) require.Equal(t, int64(1), ti.AttachmentBandwidthLimit) require.Equal(t, "price_1", ti.StripeMonthlyPriceID) ti = tiers[1] require.Equal(t, "pro", ti.Code) require.Equal(t, "Pro", ti.Name) require.Equal(t, int64(123), ti.MessageLimit) require.Equal(t, 86400*time.Second, ti.MessageExpiryDuration) require.Equal(t, int64(999999), ti.EmailLimit) // Updatedd! require.Equal(t, int64(2), ti.ReservationLimit) require.Equal(t, int64(1231231), ti.AttachmentFileSizeLimit) require.Equal(t, int64(123123), ti.AttachmentTotalSizeLimit) require.Equal(t, 10800*time.Second, ti.AttachmentExpiryDuration) require.Equal(t, int64(21474836480), ti.AttachmentBandwidthLimit) require.Equal(t, "price_2", ti.StripeMonthlyPriceID) ti, err = a.TierByStripePrice("price_1") require.Nil(t, err) require.Equal(t, "supporter", ti.Code) require.Equal(t, "Supporter", ti.Name) require.Equal(t, int64(1), ti.MessageLimit) require.Equal(t, time.Second, ti.MessageExpiryDuration) require.Equal(t, int64(1), ti.EmailLimit) require.Equal(t, int64(1), ti.ReservationLimit) require.Equal(t, int64(1), ti.AttachmentFileSizeLimit) require.Equal(t, int64(1), ti.AttachmentTotalSizeLimit) require.Equal(t, time.Second, ti.AttachmentExpiryDuration) require.Equal(t, int64(1), ti.AttachmentBandwidthLimit) require.Equal(t, "price_1", ti.StripeMonthlyPriceID) // Cannot remove tier, since user has this tier require.Error(t, a.RemoveTier("pro")) // CAN remove this tier require.Nil(t, a.RemoveTier("supporter")) tiers, err = a.Tiers() require.Nil(t, err) require.Equal(t, 1, len(tiers)) require.Equal(t, "pro", tiers[0].Code) require.Equal(t, "pro", tiers[0].Code) } func TestAccount_Tier_Create_With_ID(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddTier(&Tier{ ID: "ti_123", Code: "pro", })) ti, err := a.Tier("pro") require.Nil(t, err) require.Equal(t, "ti_123", ti.ID) } func TestManager_Tier_Change_And_Reset(t *testing.T) { a := newTestManager(t, PermissionDenyAll) // Create tier and user require.Nil(t, a.AddTier(&Tier{ Code: "supporter", Name: "Supporter", ReservationLimit: 3, })) require.Nil(t, a.AddTier(&Tier{ Code: "pro", Name: "Pro", ReservationLimit: 4, })) require.Nil(t, a.AddUser("phil", "phil", RoleUser)) require.Nil(t, a.ChangeTier("phil", "pro")) // Add 10 reservations (pro tier allows that) for i := 0; i < 4; i++ { require.Nil(t, a.AddReservation("phil", fmt.Sprintf("topic%d", i), PermissionWrite)) } // Downgrading will not work (too many reservations) require.Equal(t, ErrTooManyReservations, a.ChangeTier("phil", "supporter")) // Downgrade after removing a reservation require.Nil(t, a.RemoveReservations("phil", "topic0")) require.Nil(t, a.ChangeTier("phil", "supporter")) // Resetting will not work (too many reservations) require.Equal(t, ErrTooManyReservations, a.ResetTier("phil")) // Resetting after removing all reservations require.Nil(t, a.RemoveReservations("phil", "topic1", "topic2", "topic3")) require.Nil(t, a.ResetTier("phil")) } func TestUser_PhoneNumberAddListRemove(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("phil", "phil", RoleUser)) phil, err := a.User("phil") require.Nil(t, err) require.Nil(t, a.AddPhoneNumber(phil.ID, "+1234567890")) phoneNumbers, err := a.PhoneNumbers(phil.ID) require.Nil(t, err) require.Equal(t, 1, len(phoneNumbers)) require.Equal(t, "+1234567890", phoneNumbers[0]) require.Nil(t, a.RemovePhoneNumber(phil.ID, "+1234567890")) phoneNumbers, err = a.PhoneNumbers(phil.ID) require.Nil(t, err) require.Equal(t, 0, len(phoneNumbers)) // Paranoia check: We do NOT want to keep phone numbers in there rows, err := a.db.Query(`SELECT * FROM user_phone`) require.Nil(t, err) require.False(t, rows.Next()) require.Nil(t, rows.Close()) } func TestUser_PhoneNumberAdd_Multiple_Users_Same_Number(t *testing.T) { a := newTestManager(t, PermissionDenyAll) require.Nil(t, a.AddUser("phil", "phil", RoleUser)) require.Nil(t, a.AddUser("ben", "ben", RoleUser)) phil, err := a.User("phil") require.Nil(t, err) ben, err := a.User("ben") require.Nil(t, err) require.Nil(t, a.AddPhoneNumber(phil.ID, "+1234567890")) require.Nil(t, a.AddPhoneNumber(ben.ID, "+1234567890")) } func TestSqliteCache_Migration_From1(t *testing.T) { filename := filepath.Join(t.TempDir(), "user.db") db, err := sql.Open("sqlite3", filename) require.Nil(t, err) // Create "version 1" schema _, err = db.Exec(` BEGIN; CREATE TABLE IF NOT EXISTS user ( user TEXT NOT NULL PRIMARY KEY, pass TEXT NOT NULL, role TEXT NOT NULL ); CREATE TABLE IF NOT EXISTS access ( user TEXT NOT NULL, topic TEXT NOT NULL, read INT NOT NULL, write INT NOT NULL, PRIMARY KEY (topic, user) ); CREATE TABLE IF NOT EXISTS schemaVersion ( id INT PRIMARY KEY, version INT NOT NULL ); INSERT INTO schemaVersion (id, version) VALUES (1, 1); COMMIT; `) require.Nil(t, err) // Insert a bunch of users and ACL entries _, err = db.Exec(` BEGIN; INSERT INTO user (user, pass, role) VALUES ('ben', '$2a$10$EEp6gBheOsqEFsXlo523E.gBVoeg1ytphXiEvTPlNzkenBlHZBPQy', 'user'); INSERT INTO user (user, pass, role) VALUES ('phil', '$2a$10$YLiO8U21sX1uhZamTLJXHuxgVC0Z/GKISibrKCLohPgtG7yIxSk4C', 'admin'); INSERT INTO access (user, topic, read, write) VALUES ('ben', 'stats', 1, 1); INSERT INTO access (user, topic, read, write) VALUES ('ben', 'secret', 1, 0); INSERT INTO access (user, topic, read, write) VALUES ('*', 'stats', 1, 0); COMMIT; `) require.Nil(t, err) // Create manager to trigger migration a := newTestManagerFromFile(t, filename, "", PermissionDenyAll, bcrypt.MinCost, DefaultUserStatsQueueWriterInterval) checkSchemaVersion(t, a.db) users, err := a.Users() require.Nil(t, err) require.Equal(t, 3, len(users)) phil, ben, everyone := users[0], users[1], users[2] philGrants, err := a.Grants("phil") require.Nil(t, err) benGrants, err := a.Grants("ben") require.Nil(t, err) everyoneGrants, err := a.Grants(Everyone) require.Nil(t, err) require.True(t, strings.HasPrefix(phil.ID, "u_")) require.Equal(t, "phil", phil.Name) require.Equal(t, RoleAdmin, phil.Role) require.Equal(t, syncTopicLength, len(phil.SyncTopic)) require.Equal(t, 0, len(philGrants)) require.True(t, strings.HasPrefix(ben.ID, "u_")) require.NotEqual(t, phil.ID, ben.ID) require.Equal(t, "ben", ben.Name) require.Equal(t, RoleUser, ben.Role) require.Equal(t, syncTopicLength, len(ben.SyncTopic)) require.NotEqual(t, ben.SyncTopic, phil.SyncTopic) require.Equal(t, 2, len(benGrants)) require.Equal(t, "stats", benGrants[0].TopicPattern) require.Equal(t, PermissionReadWrite, benGrants[0].Allow) require.Equal(t, "secret", benGrants[1].TopicPattern) require.Equal(t, PermissionRead, benGrants[1].Allow) require.Equal(t, "u_everyone", everyone.ID) require.Equal(t, Everyone, everyone.Name) require.Equal(t, RoleAnonymous, everyone.Role) require.Equal(t, 1, len(everyoneGrants)) require.Equal(t, "stats", everyoneGrants[0].TopicPattern) require.Equal(t, PermissionRead, everyoneGrants[0].Allow) } func checkSchemaVersion(t *testing.T, db *sql.DB) { rows, err := db.Query(`SELECT version FROM schemaVersion`) require.Nil(t, err) require.True(t, rows.Next()) var schemaVersion int require.Nil(t, rows.Scan(&schemaVersion)) require.Equal(t, currentSchemaVersion, schemaVersion) require.Nil(t, rows.Close()) } func newTestManager(t *testing.T, defaultAccess Permission) *Manager { return newTestManagerFromFile(t, filepath.Join(t.TempDir(), "user.db"), "", defaultAccess, bcrypt.MinCost, DefaultUserStatsQueueWriterInterval) } func newTestManagerFromFile(t *testing.T, filename, startupQueries string, defaultAccess Permission, bcryptCost int, statsWriterInterval time.Duration) *Manager { a, err := NewManager(filename, startupQueries, defaultAccess, bcryptCost, statsWriterInterval) require.Nil(t, err) return a }