Bezpečné transakce při zakládání uživatelů/účastníků/účastí

Closes #314 (closed):

Pokud organizátor odešle POST na přidání nového účastníka soutěže dvakrát rychle po sobě (třeba kvůli nějakému automatickému retry po rozpadu spojení), dvě různé DB transakce se snaží založit uživatele se stejným loginem. Jedna z nich selže na unikátnosti sloupce email.

V defaultní úrovni izolace transakcí (READ COMMITTED) to nemá žádné hezké řešení. Nepomůže SELECT ... FOR UPDATE, jelikož ten zamyká pouze nalezené řádky, nikoliv neexistenci dalších řádků vyhovujících podmínce.

Co by se dalo dělat:

(1) Zvýšit úroveň izolace aspoň na READ REPEATABLE. To vyřeší problém, ale současně může začít víceméně jakákoliv zapisující transakce failovat. Vyžadovalo by dopsat retry do prakticky všech míst v OSMO, kde je nějaký commit.

(2) Retryovat specificky transakce na zakládání užívatelů (a účastí apod.). Tohle nejde snadno, jelikoz jsou i součástí dlouho běžících transakcí v importech (zatím jsme se snažíli, aby byl celý import atomický a v případě selhání se celý rollbackoval). To by možná mohly vyřešit subtransakce.

(3) Zamykat celou tabulku s uživateli, než na ní provedeme první SELECT. To by asi vyřešilo problém, ale byl by potřeba zápisový zámek, takže by paralelně nemohla běžet žádná čtení. A také by se to potenciálně mohlo deadlockovat (potřebujeme v jedné transakci postupně lock na uživatele, účastníky a účasti a locky platí až do konce transakce).

(4) Používat INSERT ... ON CONFLICT <něco>. To vypadá bezpečně, jen to není moc pohodlné, zejména proto, že s tím nepočítá ORM, takže je potřeba dělat všechno ručně.

Zatím jsem zvolil (4), protože mi přijde, že to změny udržuje lokální a funguje i s dlouhými transakcemi při importu. Výhledově bych se ale chtěl zamyslet nad tím, jak takové věci řešit co nejuniverzálněji a nejpohodlněji.

mo/web/acct.py

@@ -498,31 +498,23 @@ class Reg2:
         email = mo.users.normalize_email(rr.email)      # Pro jistotu
         sess = db.get_session()
 
-        if db.get_session().query(db.User).with_for_update().filter_by(email=email).one_or_none():
+        try:
+            user, is_new, _ = mo.users.find_or_create_user(email, first_name, last_name, is_org=False, reason='register')
+        except mo.CheckError as e:
+            app.logger.info(f'Reg2: Založení účtu {email} selhalo: {e}')
+            self.status = RegStatus.already_exists
+            return False
+
+        if not is_new:
             # Účet mohl začít existovat mezi 1. a 2. krokem registrace
             app.logger.info(f'Reg2: Účet s e-mailem {email} začal během registrace existovat')
             self.status = RegStatus.already_exists
             return False
 
-        user = db.User(
-            email=email,
-            first_name=first_name,
-            last_name=last_name,
-        )
         mo.users.set_password(user, passwd)
-
+        mo.users.login(user)
         rr.used_at = mo.now
-        sess.add(user)
-        sess.flush()
 
-        app.logger.info(f'Reg2: Založen uživatel user=#{user.user_id} email=<{user.email}>')
-        mo.util.log(
-            type=db.LogType.user,
-            what=user.user_id,
-            details={'action': 'register', 'new': db.row2dict(user)},
-        )
-
-        mo.users.login(user)
         sess.commit()
         self.user = user
         return True