Email as verifier PK

multichannel
HeNine 3 years ago
parent 341b22a3ef
commit 6e31b1df2f

@ -43,8 +43,8 @@ CREATE TABLE buscribe_speakers
CREATE TABLE buscribe_verifiers CREATE TABLE buscribe_verifiers
( (
id SERIAL PRIMARY KEY, -- id SERIAL PRIMARY KEY,
email TEXT NOT NULL, email TEXT PRIMARY KEY,
name TEXT NOT NULL name TEXT NOT NULL
); );
@ -57,7 +57,7 @@ CREATE TABLE buscribe_line_speakers
-- id BIGSERIAL PRIMARY KEY, -- id BIGSERIAL PRIMARY KEY,
line BIGINT NOT NULL REFERENCES buscribe_transcriptions, line BIGINT NOT NULL REFERENCES buscribe_transcriptions,
speaker BIGINT NOT NULL REFERENCES buscribe_speakers, speaker BIGINT NOT NULL REFERENCES buscribe_speakers,
verifier INT NOT NULL REFERENCES buscribe_verifiers, verifier text NOT NULL REFERENCES buscribe_verifiers,
PRIMARY KEY (line, speaker, verifier) PRIMARY KEY (line, speaker, verifier)
); );
@ -66,6 +66,6 @@ CREATE TABLE buscribe_verified_lines
-- id BIGSERIAL PRIMARY KEY, -- id BIGSERIAL PRIMARY KEY,
line BIGINT NOT NULL REFERENCES buscribe_transcriptions, line BIGINT NOT NULL REFERENCES buscribe_transcriptions,
verified_line TEXT NOT NULL, verified_line TEXT NOT NULL,
verifier INT REFERENCES buscribe_verifiers, verifier text REFERENCES buscribe_verifiers,
PRIMARY KEY (line, verifier) PRIMARY KEY (line, verifier)
); );

@ -54,11 +54,11 @@ def update_line(line_id):
# Simpler than dealing with uniqueness # Simpler than dealing with uniqueness
database.query(db_conn, database.query(db_conn,
"DELETE FROM buscribe_line_speakers WHERE line = %(line_id)s AND verifier = %(verifier)s;", "DELETE FROM buscribe_line_speakers WHERE line = %(line_id)s AND verifier = %(verifier)s;",
line_id=line_id, verifier=1) line_id=line_id, verifier="placeholder@example.com")
execute_values(db_conn.cursor(), execute_values(db_conn.cursor(),
"INSERT INTO buscribe_line_speakers(line, speaker, verifier) " "INSERT INTO buscribe_line_speakers(line, speaker, verifier) "
"VALUES %s;", "VALUES %s;",
[(line_id, speaker, 1) for speaker in [(line_id, speaker, "placeholder@example.com") for speaker in
request.json["speakers"]]) request.json["speakers"]])
if "transcription" in request.json and isinstance(request.json["transcription"], str): if "transcription" in request.json and isinstance(request.json["transcription"], str):
verified_line = request.json["transcription"].lower() verified_line = request.json["transcription"].lower()
@ -66,11 +66,11 @@ def update_line(line_id):
database.query(db_conn, database.query(db_conn,
"DELETE FROM buscribe_verified_lines WHERE line = %(line_id)s AND verifier = %(verifier)s;", "DELETE FROM buscribe_verified_lines WHERE line = %(line_id)s AND verifier = %(verifier)s;",
line_id=line_id, verifier=1) line_id=line_id, verifier="placeholder@example.com")
database.query(db_conn, database.query(db_conn,
"INSERT INTO buscribe_verified_lines(line, verified_line, verifier) " "INSERT INTO buscribe_verified_lines(line, verified_line, verifier) "
"VALUES (%(line)s, %(verified_line)s, %(verifier)s)", "VALUES (%(line)s, %(verified_line)s, %(verifier)s)",
line=line_id, verified_line=verified_line, verifier=1) line=line_id, verified_line=verified_line, verifier="placeholder@example.com")
return "", 204 return "", 204

Loading…
Cancel
Save