UI: Implement creating new genotype datasets.

1 files changed, 58 insertions, 9 deletions

diff --git a/qc_app/upload/rqtl2.py b/qc_app/upload/rqtl2.py
index 9bed4f1..6ddc83f 100644
--- a/qc_app/upload/rqtl2.py
+++ b/qc_app/upload/rqtl2.py
@@ -1,14 +1,14 @@
 """Module to handle uploading of R/qtl2 bundles."""
 from pathlib import Path
-from typing import Optional
+from datetime import date
 from zipfile import ZipFile, is_zipfile
 
+from MySQLdb.cursors import DictCursor
 from flask import (
     flash,
     request,
     url_for,
     redirect,
-    Response,
     Blueprint,
     render_template,
     current_app as app)
@@ -158,12 +158,12 @@ def upload_rqtl2_bundle(species_id: int, population_id: int):
                     "rqtl2/upload-rqtl2-bundle-step-02.html",
                     species=species,
                     population=population,
-                    rqtl2_bundle_file=the_file.name)
+                    rqtl2_bundle_file=the_file.name)#type: ignore[union-attr]
         except (InvalidFormat, __RequestError__) as exc:
             flash("".join(exc.args), "alert-error alert-rqtl2")
             return this_page_with_errors
 
-def check_errors(conn, *args, **kwargs) -> Optional[Response]:
+def check_errors(conn, *args, **kwargs):
     """Check for select errors in the forms and return a page to redirect to."""
     species_id = kwargs.get("species_id") or request.form.get("species_id")
     population_id = (kwargs.get("population_id")
@@ -199,7 +199,7 @@ def check_errors(conn, *args, **kwargs) -> Optional[Response]:
                                 pgsrc="error"),
                         code=307)
 
-    return False
+    return None
 
 @rqtl2.route(("/upload/species/<int:species_id>/population/<int:population_id>"
               "/rqtl2-bundle/dataset-info"),
@@ -230,7 +230,8 @@ def select_dataset_info(species_id: int, population_id: int):
                     datasets=geno_dataset_by_species_and_population(
                         conn, species_id, population_id))
 
-            geno_dataset = geno_dataset_by_id(conn, form["geno-dataset-id"])
+            geno_dataset = geno_dataset_by_id(
+                conn, int(form["geno-dataset-id"]))
 
     return render_template("rqtl2/summary-info.html",
                            species=species,
@@ -240,7 +241,7 @@ def select_dataset_info(species_id: int, population_id: int):
 @rqtl2.route(("/upload/species/<int:species_id>/population/<int:population_id>"
               "/rqtl2-bundle/select-geno-dataset"),
              methods=["POST"])
-def select_geno_dataset(species_id: int, population_id: int) -> Response:
+def select_geno_dataset(species_id: int, population_id: int):
     """Select from existing geno datasets."""
     with database_connection(app.config["SQL_URI"]) as conn:
         error = check_errors(
@@ -269,6 +270,54 @@ def select_geno_dataset(species_id: int, population_id: int) -> Response:
 @rqtl2.route(("/upload/species/<int:species_id>/population/<int:population_id>"
               "/rqtl2-bundle/create-geno-dataset"),
              methods=["POST"])
-def create_geno_dataset(species_id: int, population_id: int) -> Response:
+def create_geno_dataset(species_id: int, population_id: int):
     """Create a new geno dataset."""
-    return "IMPLEMENT THIS!!!"
+    with database_connection(app.config["SQL_URI"]) as conn:
+        error = check_errors(conn, "species", "population", "rqtl2_bundle_file")
+        if bool(error):
+            return error
+
+        sgeno_page = redirect(url_for("upload.rqtl2.select_geno_dataset",
+                                      species_id=species_id,
+                                      population_id=population_id,
+                                      pgsrc="error"),
+                              code=307)
+        if not bool(request.form.get("dataset-name")):
+            flash("You must provide the dataset name",
+                  "alert-error alert-rqtl2")
+            return sgeno_page
+        if not bool(request.form.get("dataset-fullname")):
+            flash("You must provide the dataset full name",
+                  "alert-error alert-rqtl2")
+            return sgeno_page
+        if not bool(request.form.get("dataset-shortname")):
+            flash("You must provide the dataset short name",
+                  "alert-error alert-rqtl2")
+            return sgeno_page
+        public = 2 if request.form.get("dataset-public") == "on" else 0
+
+        with conn.cursor(cursorclass=DictCursor) as cursor:
+            new_dataset = {
+                "name": request.form.get("dataset-name"),
+                "fname": request.form.get("dataset-fullname"),
+                "sname": request.form.get("dataset-shortname"),
+                "today": date.today().isoformat(),
+                "pub": public,
+                "isetid": population_id
+            }
+            cursor.execute(
+                "INSERT INTO GenoFreeze("
+                "Name, FullName, ShortName, CreateTime, public, InbredSetId"
+                ") "
+                "VALUES("
+                "%(name)s, %(fname)s, %(sname)s, %(today)s, %(pub)s, %(isetid)s"
+                ")",
+                new_dataset)
+            flash("Created dataset successfully.", "alert-success")
+            return render_template(
+                "rqtl2/create-geno-dataset-success.html",
+                species=species_by_id(conn, species_id),
+                population=population_by_species_and_id(
+                    conn, species_id, population_id),
+                rqtl2_bundle_file=request.form["rqtl2_bundle_file"],
+                geno_dataset={**new_dataset, "id": cursor.lastrowid})