1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
"""The views/routes for the resources package"""
import uuid
from functools import partial
from flask import request, jsonify, Response, Blueprint, current_app as app
from gn3 import db_utils as gn3dbutils
from gn3.auth.db_utils import with_db_connection
from .data import retrieve_ungrouped_data
from .models import (
resource_by_id, resource_categories, resource_category_by_id,
create_resource as _create_resource)
from ..errors import AuthorisationError
from ..groups.models import user_group, DUMMY_GROUP
from ... import db
from ...dictify import dictify
from ...authentication.oauth2.resource_server import require_oauth
resources = Blueprint("resources", __name__)
@resources.route("/categories", methods=["GET"])
@require_oauth("profile group resource")
def list_resource_categories() -> Response:
"""Retrieve all resource categories"""
db_uri = app.config["AUTH_DB"]
with db.connection(db_uri) as conn:
return jsonify(tuple(
dictify(category) for category in resource_categories(conn)))
@resources.route("/create", methods=["POST"])
@require_oauth("profile group resource")
def create_resource() -> Response:
"""Create a new resource"""
with require_oauth.acquire("profile group resource") as the_token:
form = request.form
resource_name = form.get("resource_name")
resource_category_id = uuid.UUID(form.get("resource_category"))
db_uri = app.config["AUTH_DB"]
with db.connection(db_uri) as conn:
resource = _create_resource(
conn, resource_name, resource_category_by_id(
conn, resource_category_id),
the_token.user)
return jsonify(dictify(resource))
@resources.route("/view/<uuid:resource_id>")
@require_oauth("profile group resource")
def view_resource(resource_id: uuid.UUID) -> Response:
"""View a particular resource's details."""
with require_oauth.acquire("profile group resource") as the_token:
db_uri = app.config["AUTH_DB"]
with db.connection(db_uri) as conn:
return jsonify(dictify(resource_by_id(
conn, the_token.user, resource_id)))
@resources.route("/<string:resource_type>/unlinked-data")
@require_oauth("profile group resource")
def unlinked_data(resource_type: str) -> Response:
"""View data linked to the group but not linked to any resource."""
if resource_type not in ("all", "mrna", "genotype", "phenotype"):
raise AuthorisationError(f"Invalid resource type {resource_type}")
with require_oauth.acquire("profile group resource") as the_token:
db_uri = app.config["AUTH_DB"]
with db.connection(db_uri) as conn, db.cursor(conn) as cursor:
ugroup = user_group(cursor, the_token.user).maybe(# type: ignore[misc]
DUMMY_GROUP, lambda grp: grp)
if ugroup == DUMMY_GROUP:
return jsonify(tuple())
type_filter = {
"all": "",
"mrna": 'WHERE dataset_type="mRNA"',
"genotype": 'WHERE dataset_type="Genotype"',
"phenotype": 'WHERE dataset_type="Phenotype"'
}[resource_type]
except_filter = (
"SELECT group_id, dataset_type, "
"dataset_id AS dataset_or_trait_id FROM mrna_resources "
"UNION "
"SELECT group_id, dataset_type, "
"trait_id AS dataset_or_trait_id FROM genotype_resources "
"UNION "
"SELECT group_id, dataset_type, "
"trait_id AS dataset_or_trait_id FROM phenotype_resources")
ids_query = ("SELECT group_id, dataset_type, dataset_or_trait_id "
"FROM linked_group_data "
f"{type_filter} "
f"EXCEPT {except_filter} ")
cursor.execute(ids_query)
ids = cursor.fetchall()
if ids:
clause = ", ".join(["(?, ?, ?)"] * len(ids))
data_query = (
"SELECT * FROM linked_group_data "
"WHERE (group_id, dataset_type, dataset_or_trait_id) "
f"IN (VALUES {clause})")
params = tuple(item for sublist in
((row[0], row[1], row[2]) for row in ids)
for item in sublist)
cursor.execute(data_query, params)
return jsonify(tuple(dict(row) for row in cursor.fetchall()))
return jsonify(tuple())
@resources.route("/<string:dataset_type>/ungrouped-data", methods=["GET"])
@require_oauth("profile group resource")
def ungrouped_data(dataset_type: str) -> Response:
"""View data not linked to any group."""
if dataset_type not in ("all", "mrna", "genotype", "phenotype"):
raise AuthorisationError(f"Invalid dataset type {dataset_type}")
with gn3dbutils.database_connection() as gn3conn:
return jsonify(with_db_connection(partial(
retrieve_ungrouped_data, gn3conn=gn3conn,
dataset_type=dataset_type)))
|
