@@ -30,8 +30,7 @@ type actionsStruct struct {
3030func (actions *actionsStruct) CreateUserAction(actionInvocationId string, emailAddress string, passwordHash []byte, passwordHashAlgorithmId string, passwordSalt []byte) (userserver.UserStruct, error) {
3131 id := generateRandomId()
3232
33- _, err := actions.db.Exec("INSERT INTO app_user (id, email_address, password_hash, password_hash_algorithm_id, password_salt) VALUES ($1, $2, $3, $4, $5)",
34- id, emailAddress, passwordHash, passwordHashAlgorithmId, passwordSalt)
33+ _, err := actions.db.Exec("INSERT INTO app_user (id, email_address, password_hash, password_hash_algorithm_id, password_salt) VALUES ($1, $2, $3, $4, $5)", id, emailAddress, passwordHash, passwordHashAlgorithmId, passwordSalt)
3534
3635 if err != nil {
3736 if isUniqueConstraintError(err) {
@@ -80,6 +79,7 @@ func (actions *actionsStruct) GetUserAction(actionInvocationId string, userId st
8079 fmt.Println(err)
8180 return userserver.UserStruct{}, userserver.NewActionError("internal_error")
8281 }
82+
8383 return user, nil
8484}
8585
@@ -106,11 +106,12 @@ func (actions *actionsStruct) GetUserByEmailAddressAction(_ string, emailAddress
106106 fmt.Println(err)
107107 return userserver.UserStruct{}, userserver.NewActionError("internal_error")
108108 }
109+
109110 return user, nil
110111}
111112
112113func (actions *actionsStruct) UpdateUserEmailAddressAction(_ string, userId string, emailAddress string, userEmailAddressCounter int32) error {
113- res , err := actions.db.Exec("UPDATE app_user SET email_address = $1, email_address_counter = email_address_counter + 1 WHERE id = $2 AND email_address_counter = $3", emailAddress, userId, userEmailAddressCounter)
114+ result , err := actions.db.Exec("UPDATE app_user SET email_address = $1, email_address_counter = email_address_counter + 1 WHERE id = $2 AND email_address_counter = $3", emailAddress, userId, userEmailAddressCounter)
114115
115116 if err != nil {
116117 if isUniqueConstraintError(err) {
@@ -120,54 +121,57 @@ func (actions *actionsStruct) UpdateUserEmailAddressAction(_ string, userId stri
120121 return userserver.NewActionError("internal_error")
121122 }
122123
123- rowsAffected, _ := res .RowsAffected()
124+ rowsAffected, _ := result .RowsAffected()
124125 if rowsAffected < 1 {
125126 return userserver.NewActionError("user_not_found")
126127 }
128+
127129 return nil
128130}
129131
130132func (actions *actionsStruct) UpdateUserPasswordHashAction(_ string, userId string, passwordHash []byte, passwordHashAlgorithmId string, passwordSalt []byte, userPasswordHashCounter int32) error {
131- res, err := actions.db.Exec("UPDATE app_user SET password_hash = $1, password_hash_algorithm_id = $2, password_salt = $3, password_hash_counter = password_hash_counter + 1 WHERE id = $4 AND password_hash_counter = $5",
132- passwordHash, passwordHashAlgorithmId, passwordSalt, userId, userPasswordHashCounter)
133+ result, err := actions.db.Exec("UPDATE app_user SET password_hash = $1, password_hash_algorithm_id = $2, password_salt = $3, password_hash_counter = password_hash_counter + 1 WHERE id = $4 AND password_hash_counter = $5", passwordHash, passwordHashAlgorithmId, passwordSalt, userId, userPasswordHashCounter)
133134
134135 if err != nil {
135136 fmt.Println(err)
136137 return userserver.NewActionError("internal_error")
137138 }
138139
139- rowsAffected, _ := res .RowsAffected()
140+ rowsAffected, _ := result .RowsAffected()
140141 if rowsAffected < 1 {
141142 return userserver.NewActionError("user_not_found")
142143 }
144+
143145 return nil
144146}
145147
146148func (actions *actionsStruct) IncrementUserSessionsCounterAction(_ string, userId string, userSessionsCounter int32) error {
147- res , err := actions.db.Exec("UPDATE app_user SET sessions_counter = sessions_counter + 1 WHERE id = $1 AND sessions_counter = $2", userId, userSessionsCounter)
149+ result , err := actions.db.Exec("UPDATE app_user SET sessions_counter = sessions_counter + 1 WHERE id = $1 AND sessions_counter = $2", userId, userSessionsCounter)
148150
149151 if err != nil {
150152 fmt.Println(err)
151153 return userserver.NewActionError("internal_error")
152154 }
153155
154- rowsAffected, _ := res .RowsAffected()
156+ rowsAffected, _ := result .RowsAffected()
155157 if rowsAffected < 1 {
156158 return userserver.NewActionError("user_not_found")
157159 }
160+
158161 return nil
159162}
160163
161164func (actions *actionsStruct) DeleteUserAction(_ string, userId string) error {
162- res , err := actions.db.Exec("DELETE FROM app_user WHERE id = $1", userId)
165+ result , err := actions.db.Exec("DELETE FROM app_user WHERE id = $1", userId)
163166 if err != nil {
164167 fmt.Println(err)
165168 return userserver.NewActionError("internal_error")
166169 }
167170
168- rowsAffected, _ := res .RowsAffected()
171+ rowsAffected, _ := result .RowsAffected()
169172 if rowsAffected < 1 {
170173 return userserver.NewActionError("user_not_found")
171174 }
175+
172176 return nil
173177}
0 commit comments