From 78717642b076e341da1ba9c373c723d0a2b8ae0e Mon Sep 17 00:00:00 2001 From: Munyoki Kilyungi Date: Tue, 24 Oct 2023 10:38:29 +0300 Subject: Implement "GET /genewikis/ncbi/:symbol". * gn3/api/metadata.py (get_ncbi_genewiki_entries): New end-point. --- gn3/api/metadata.py | 88 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 88 insertions(+) (limited to 'gn3/api') diff --git a/gn3/api/metadata.py b/gn3/api/metadata.py index 84c1e72..1f99c57 100644 --- a/gn3/api/metadata.py +++ b/gn3/api/metadata.py @@ -532,3 +532,91 @@ CONSTRUCT { context) except (RemoteDisconnected, URLError): return jsonify({}) + +@metadata.route("/genewikis/ncbi/", methods=["GET"]) +def get_ncbi_genewiki_entries(symbol): + """Fetch the NCBI GeneRIF entries""" + try: + args = request.args + page = args.get("page", 0) + page_size = args.get("limit", 10) + sparql = SPARQLWrapper(current_app.config.get("SPARQL_ENDPOINT")) + sparql.setQuery(Template(""" +$prefix + +CONSTRUCT { + ?symbol ex:entries [ + rdfs:comment ?comment ; + gnt:hasGeneId ?geneId ; + ex:species ?species_ ; + dct:created ?createTime ; + dct:references ?pmids ; + dct:creator ?creator ; + ] . + ?symbol rdf:type gnc:GNWikiEntry ; + ex:totalCount ?totalCount ; + ex:currentPage $offset . +} WHERE { +{ + SELECT ?symbol ?comment ?geneId (GROUP_CONCAT(DISTINCT ?speciesName; SEPARATOR='; ') AS ?species_) + ?createTime ?creator + (GROUP_CONCAT(DISTINCT ?pubmed; SEPARATOR='; ') AS ?pmids) + WHERE { + ?symbol rdfs:label ?label ; + rdfs:comment _:entry . + ?label bif:contains "'$symbol'" . + _:entry rdf:type gnc:NCBIWikiEntry ; + rdfs:comment ?comment . + OPTIONAL { + ?species ^xkos:classifiedUnder _:entry ; + ^skos:member gnc:Species ; + skos:prefLabel ?speciesName . + } . + OPTIONAL { _:entry gnt:hasGeneId ?geneId . } . + OPTIONAL { _:entry dct:created ?createTime . } . + OPTIONAL { _:entry dct:references ?pubmed . } . + OPTIONAL { + ?investigator foaf:name ?creator ; + ^dct:creator _:entry . + } . + } GROUP BY ?comment ?symbol ?createTime ?creator ?geneId ORDER BY ?createTime LIMIT $limit OFFSET $offset +} + +{ + SELECT (COUNT(DISTINCT ?comment)/$limit+1 AS ?totalCount) WHERE { + ?symbol rdfs:comment _:entry ; + rdfs:label ?label . + _:entry rdfs:comment ?comment ; + rdf:type gnc:NCBIWikiEntry . + ?label bif:contains "'$symbol'" . + } +} +} +""").substitute(prefix=RDF_PREFIXES, symbol=symbol, + limit=page_size, offset=page)) + results = sparql.queryAndConvert() + results = json.loads(results.serialize(format="json-ld")) + context = { + "@context": PREFIXES | { + "data": "@graph", + "type": "@type", + "id": "@id", + "entries": "ex:entries", + "comment": "rdfs:comment", + "category": 'gnt:belongsToCategory', + "author": "dct:creator", + "pubmed": "dct:references", + "currentPage": "ex:currentPage", + "pages": "ex:totalCount", + "created": { + "@id": "dct:created", + "@type": "xsd:datetime" + }, + }, + "type": "gnc:GNWikiEntry" + } + return jsonld.compact( + jsonld.frame(results, context), + context) + except (RemoteDisconnected, URLError): + return jsonify({}) -- cgit v1.2.3