Add new grpc endpoint to get genome id from accession id

app/api/models/genome.py

@@ -156,3 +156,7 @@ 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)

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,12 @@ 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, assembly_accession_id: str):
+        # Create request
+        request_class = self.reflector.message_class(
+            "ensembl_metadata.GenomeBySpecificKeywordRequest"
+        )
+        request = request_class(assembly_accession_id=assembly_accession_id)
+        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,19 @@ async def get_genome_dataset_attributes(
     except Exception as ex:
         logging.error(ex)
         return response_error_handler({"status": 500})
+
+@router.get("/genomeid/{assembly_accession_id}", name="genome_id")
+async def get_uuid(request: Request, assembly_accession_id: str):
+    try:
+        genome_array = grpc_client.get_genome_by_specific_keyword(assembly_accession_id)
+        latest_genome_by_keyword_object = GenomeByKeyword()
+        for arr in genome_array:
+            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})
+    return response_data