Merge pull request #3120 from antgonza/update-email

basic code to update user email

Author: wasade

qiita_db/support_files/patches/82.sql

@@ -11,3 +11,45 @@ BEGIN
      ALTER TABLE settings ADD COLUMN max_preparation_samples INT DEFAULT 800;
   END IF;
 END $do$;
+
+ALTER TABLE qiita.analysis
+  DROP CONSTRAINT fk_analysis_user,
+  ADD CONSTRAINT fk_analysis_user
+    FOREIGN KEY (email)
+    REFERENCES qiita.qiita_user(email)
+    ON UPDATE CASCADE;
+
+ALTER TABLE qiita.study_users
+  DROP CONSTRAINT fk_study_users_user,
+  ADD CONSTRAINT fk_study_users_user
+    FOREIGN KEY (email)
+    REFERENCES qiita.qiita_user(email)
+    ON UPDATE CASCADE;
+
+ALTER TABLE qiita.message_user
+  DROP CONSTRAINT fk_message_user_0,
+  ADD CONSTRAINT fk_message_user_0
+    FOREIGN KEY (email)
+    REFERENCES qiita.qiita_user(email)
+    ON UPDATE CASCADE;
+
+ALTER TABLE qiita.processing_job
+  DROP CONSTRAINT fk_processing_job_qiita_user,
+  ADD CONSTRAINT fk_processing_job_qiita_user
+    FOREIGN KEY (email)
+    REFERENCES qiita.qiita_user(email)
+    ON UPDATE CASCADE;
+
+ALTER TABLE qiita.processing_job_workflow
+  DROP CONSTRAINT fk_processing_job_workflow,
+  ADD CONSTRAINT fk_processing_job_workflow
+    FOREIGN KEY (email)
+    REFERENCES qiita.qiita_user(email)
+    ON UPDATE CASCADE;
+
+ALTER TABLE qiita.study
+  DROP CONSTRAINT fk_study_user,
+  ADD CONSTRAINT fk_study_user
+    FOREIGN KEY (email)
+    REFERENCES qiita.qiita_user(email)
+    ON UPDATE CASCADE;

qiita_db/test/test_user.py

@@ -498,6 +498,17 @@ def test_jobs(self):
         # no jobs
         self.assertEqual(qdb.user.User('[email protected]').jobs(), [])
 
+    def test_update_email(self):
+        user = qdb.user.User('[email protected]')
+        with self.assertRaisesRegex(IncorrectEmailError, 'Bad email given:'):
+            user.update_email('bladfa.adferqerq@$EWE')
+
+        with self.assertRaisesRegex(IncorrectEmailError,
+                                    'This email already exists'):
+            user.update_email('[email protected]')
+
+        user.update_email('[email protected]')
+
 
 if __name__ == "__main__":
     main()

qiita_db/user.py

@@ -708,6 +708,17 @@ def jobs(self, limit=30, ignore_status=['success'], show_hidden=False):
             return [qdb.processing_job.ProcessingJob(p[0])
                     for p in qdb.sql_connection.TRN.execute_fetchindex()]
 
+    def update_email(self, email):
+        if not validate_email(email):
+            raise IncorrectEmailError(f'Bad email given: {email}')
+
+        if self.exists(email):
+            raise IncorrectEmailError(f'This email already exists: {email}')
+
+        with qdb.sql_connection.TRN:
+            sql = 'UPDATE qiita.qiita_user SET email = %s where email = %s'
+            qdb.sql_connection.TRN.add(sql, [email, self.email])
+
 
 def validate_email(email):
     """Validates an email