@@ -177,13 +177,13 @@ func (p *provider) ListUsers(ctx context.Context, pagination *model.Pagination)
177177 // there is no offset in cassandra
178178 // so we fetch till limit + offset
179179 // and return the results from offset to limit
180- query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, created_at, updated_at FROM %s LIMIT %d" , KeySpace + "." + models .Collections .User , pagination .Limit + pagination .Offset )
180+ query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, app_data, created_at, updated_at FROM %s LIMIT %d" , KeySpace + "." + models .Collections .User , pagination .Limit + pagination .Offset )
181181 scanner := p .db .Query (query ).Iter ().Scanner ()
182182 counter := int64 (0 )
183183 for scanner .Next () {
184184 if counter >= pagination .Offset {
185185 var user models.User
186- err := scanner .Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .CreatedAt , & user .UpdatedAt )
186+ err := scanner .Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .AppData , & user . CreatedAt , & user .UpdatedAt )
187187 if err != nil {
188188 return nil , err
189189 }
@@ -200,8 +200,8 @@ func (p *provider) ListUsers(ctx context.Context, pagination *model.Pagination)
200200// GetUserByEmail to get user information from database using email address
201201func (p * provider ) GetUserByEmail (ctx context.Context , email string ) (* models.User , error ) {
202202 var user models.User
203- query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, created_at, updated_at FROM %s WHERE email = '%s' LIMIT 1 ALLOW FILTERING" , KeySpace + "." + models .Collections .User , email )
204- err := p .db .Query (query ).Consistency (gocql .One ).Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .CreatedAt , & user .UpdatedAt )
203+ query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, app_data, created_at, updated_at FROM %s WHERE email = '%s' LIMIT 1 ALLOW FILTERING" , KeySpace + "." + models .Collections .User , email )
204+ err := p .db .Query (query ).Consistency (gocql .One ).Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .AppData , & user . CreatedAt , & user .UpdatedAt )
205205 if err != nil {
206206 return nil , err
207207 }
@@ -211,8 +211,8 @@ func (p *provider) GetUserByEmail(ctx context.Context, email string) (*models.Us
211211// GetUserByID to get user information from database using user ID
212212func (p * provider ) GetUserByID (ctx context.Context , id string ) (* models.User , error ) {
213213 var user models.User
214- query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, created_at, updated_at FROM %s WHERE id = '%s' LIMIT 1" , KeySpace + "." + models .Collections .User , id )
215- err := p .db .Query (query ).Consistency (gocql .One ).Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .CreatedAt , & user .UpdatedAt )
214+ query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, app_data, created_at, updated_at FROM %s WHERE id = '%s' LIMIT 1" , KeySpace + "." + models .Collections .User , id )
215+ err := p .db .Query (query ).Consistency (gocql .One ).Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .AppData , & user . CreatedAt , & user .UpdatedAt )
216216 if err != nil {
217217 return nil , err
218218 }
@@ -306,8 +306,8 @@ func (p *provider) UpdateUsers(ctx context.Context, data map[string]interface{},
306306// GetUserByPhoneNumber to get user information from database using phone number
307307func (p * provider ) GetUserByPhoneNumber (ctx context.Context , phoneNumber string ) (* models.User , error ) {
308308 var user models.User
309- query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, created_at, updated_at FROM %s WHERE phone_number = '%s' LIMIT 1 ALLOW FILTERING" , KeySpace + "." + models .Collections .User , phoneNumber )
310- err := p .db .Query (query ).Consistency (gocql .One ).Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .CreatedAt , & user .UpdatedAt )
309+ query := fmt .Sprintf ("SELECT id, email, email_verified_at, password, signup_methods, given_name, family_name, middle_name, nickname, birthdate, phone_number, phone_number_verified_at, picture, roles, revoked_timestamp, is_multi_factor_auth_enabled, app_data, created_at, updated_at FROM %s WHERE phone_number = '%s' LIMIT 1 ALLOW FILTERING" , KeySpace + "." + models .Collections .User , phoneNumber )
310+ err := p .db .Query (query ).Consistency (gocql .One ).Scan (& user .ID , & user .Email , & user .EmailVerifiedAt , & user .Password , & user .SignupMethods , & user .GivenName , & user .FamilyName , & user .MiddleName , & user .Nickname , & user .Birthdate , & user .PhoneNumber , & user .PhoneNumberVerifiedAt , & user .Picture , & user .Roles , & user .RevokedTimestamp , & user .IsMultiFactorAuthEnabled , & user .AppData , & user . CreatedAt , & user .UpdatedAt )
311311 if err != nil {
312312 return nil , err
313313 }
0 commit comments