Add new grpc endpoint to get genome id from accession id

app/api/models/genome.py

@@ -156,3 +156,8 @@ class DatasetAttribute(BaseModel):
 class DatasetAttributes(BaseModel):
     attributes: list[DatasetAttribute]
     release_version: float = Field(alias="releaseVersion")
+
+class GenomeByKeyword(BaseModel):
+    genome_uuid: str = Field(alias="genomeUuid", default="")
+    release_version: float = Field(alias=AliasPath("release", "releaseVersion"), default=0)
+    genome_tag: str = Field(alias=AliasPath("assembly", "urlName"), default="")

app/api/resources/grpc_client.py

@@ -12,6 +12,7 @@
    limitations under the License.
 """
 
+import logging
 import grpc
 from google.protobuf.json_format import MessageToDict
 from yagrc import reflector as yagrc_reflector
@@ -148,3 +149,11 @@ def get_dataset_attributes(
                 genome_uuid=genome_uuid, dataset_type=dataset_type
             )
         return self.stub.GetAttributesValuesByUUID(dataset_attributes)
+
+    def get_genome_by_specific_keyword(self, **kwargs):
+        request_class = self.reflector.message_class(
+            "ensembl_metadata.GenomeBySpecificKeywordRequest"
+        )
+        request = request_class(**kwargs)
+        response = self.stub.GetGenomesBySpecificKeyword(request)
+        return response

app/api/resources/metadata.py

@@ -14,6 +14,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 """
+import json
 import logging
 from typing import Annotated
 
@@ -25,7 +26,7 @@
 from api.models.statistics import GenomeStatistics, ExampleObjectList
 from api.models.popular_species import PopularSpeciesGroup
 from api.models.karyotype import Karyotype
-from api.models.genome import BriefGenomeDetails, GenomeDetails, DatasetAttributes
+from api.models.genome import BriefGenomeDetails, GenomeDetails, DatasetAttributes, GenomeByKeyword
 from api.models.ftplinks import FTPLinks
 
 from core.config import GRPC_HOST, GRPC_PORT
@@ -238,3 +239,21 @@ async def get_genome_dataset_attributes(
     except Exception as ex:
         logging.error(ex)
         return response_error_handler({"status": 500})
+
+@router.get("/genome")
+async def get_genome_by_keyword(request: Request, assembly_accession_id: str):
+    if (assembly_accession_id == ""):
+        not_found_response = {"message": "missing assembly_accession_id"}
+        return responses.JSONResponse(not_found_response, status_code=404)
+    try:
+        genome_response = grpc_client.get_genome_by_specific_keyword(assembly_accession_id=assembly_accession_id)
+        latest_genome_by_keyword_object = GenomeByKeyword()
+        for arr in genome_response:
+            arr = MessageToDict(arr)
+            genome_by_keyword_object = GenomeByKeyword(**arr)
+            if (genome_by_keyword_object.release_version > latest_genome_by_keyword_object.release_version):
+                latest_genome_by_keyword_object = genome_by_keyword_object
+        return latest_genome_by_keyword_object
+    except Exception as ex:
+        logging.error(ex)
+        return response_error_handler({"status": 500})