adding endpoint to get AETitles by AeTitle

Signed-off-by: Neil South <[email protected]>

Author: neildsouth

src/Common/packages.lock.json

@@ -34,12 +34,6 @@
         "resolved": "17.2.3",
         "contentHash": "VcozGeE4SxIo0cnXrDHhbrh/Gb8KQnZ3BvMelvh+iw0PrIKtuuA46U2Xm4e4pgnaWFgT4RdZfTpWl/WPRdw0WQ=="
       },
-      "System.IO.Abstractions": {
-        "type": "Direct",
-        "requested": "[17.2.3, )",
-        "resolved": "17.2.3",
-        "contentHash": "VcozGeE4SxIo0cnXrDHhbrh/Gb8KQnZ3BvMelvh+iw0PrIKtuuA46U2Xm4e4pgnaWFgT4RdZfTpWl/WPRdw0WQ=="
-      },
       "System.Threading.Tasks.Dataflow": {
         "type": "Direct",
         "requested": "[6.0.0, )",

src/Database/Api/Repositories/ISourceApplicationEntityRepository.cs

@@ -25,6 +25,8 @@ public interface ISourceApplicationEntityRepository
 
         Task<SourceApplicationEntity?> FindByNameAsync(string name, CancellationToken cancellationToken = default);
 
+        Task<SourceApplicationEntity[]?> FindByAETAsync(string name, CancellationToken cancellationToken = default);
+
         Task<SourceApplicationEntity> AddAsync(SourceApplicationEntity item, CancellationToken cancellationToken = default);
 
         Task<SourceApplicationEntity> UpdateAsync(SourceApplicationEntity entity, CancellationToken cancellationToken = default);

src/Database/EntityFramework/Repositories/SourceApplicationEntityRepository.cs

@@ -87,6 +87,16 @@ public async Task<bool> ContainsAsync(Expression<Func<SourceApplicationEntity, b
             }).ConfigureAwait(false);
         }
 
+        public async Task<SourceApplicationEntity[]?> FindByAETAsync(string aeTitle, CancellationToken cancellationToken = default)
+        {
+            Guard.Against.NullOrWhiteSpace(aeTitle);
+
+            return await _retryPolicy.ExecuteAsync(async () =>
+            {
+                return await _dataset.Where(p => p.AeTitle.Equals(aeTitle)).ToArrayAsync(cancellationToken).ConfigureAwait(false);
+            }).ConfigureAwait(false);
+        }
+
         public async Task<SourceApplicationEntity> RemoveAsync(SourceApplicationEntity entity, CancellationToken cancellationToken = default)
         {
             Guard.Against.Null(entity);

src/Database/MongoDB/Repositories/SourceApplicationEntityRepository.cs

@@ -97,6 +97,16 @@ public async Task<List<SourceApplicationEntity>> ToListAsync(CancellationToken c
             }).ConfigureAwait(false);
         }
 
+        public async Task<SourceApplicationEntity[]?> FindByAETAsync(string aeTitle, CancellationToken cancellationToken = default)
+        {
+            return await _retryPolicy.ExecuteAsync(async () =>
+            {
+                return (await _collection
+                    .Find(x => x.AeTitle == aeTitle)
+                    .ToListAsync(cancellationToken).ConfigureAwait(false)).ToArray();
+            }).ConfigureAwait(false);
+        }
+
         public async Task<SourceApplicationEntity> AddAsync(SourceApplicationEntity item, CancellationToken cancellationToken = default)
         {
             Guard.Against.Null(item);

src/DicomWebClient/packages.lock.json

@@ -1248,8 +1248,8 @@
       "monai.deploy.informaticsgateway.client.common": {
         "type": "Project",
         "dependencies": {
-          "Ardalis.GuardClauses": "4.0.1",
-          "System.Text.Json": "6.0.7"
+          "Ardalis.GuardClauses": "[4.0.1, )",
+          "System.Text.Json": "[6.0.7, )"
         }
       }
     }

src/InformaticsGateway/Services/Http/SourceAeTitleController.cs

@@ -88,6 +88,32 @@ public async Task<ActionResult<SourceApplicationEntity>> GetAeTitle(string name)
             }
         }
 
+        [HttpGet("/getbyaetitle/{aeTitle}")]
+        [Produces("application/json")]
+        [ProducesResponseType(StatusCodes.Status200OK)]
+        [ProducesResponseType(StatusCodes.Status404NotFound)]
+        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
+        [ActionName(nameof(GetAeTitleByAET))]
+        public async Task<ActionResult<SourceApplicationEntity>> GetAeTitleByAET(string aeTitle)
+        {
+            try
+            {
+                var sourceApplicationEntity = await _repository.FindByAETAsync(aeTitle, HttpContext.RequestAborted).ConfigureAwait(false);
+
+                if (sourceApplicationEntity is null)
+                {
+                    return NotFound();
+                }
+
+                return Ok(sourceApplicationEntity);
+            }
+            catch (Exception ex)
+            {
+                _logger.ErrorListingSourceApplicationEntities(ex);
+                return Problem(title: "Error querying DICOM sources.", statusCode: (int)System.Net.HttpStatusCode.InternalServerError, detail: ex.Message);
+            }
+        }
+
         [HttpPost]
         [Consumes(MediaTypeNames.Application.Json)]
         [ProducesResponseType(StatusCodes.Status201Created)]

src/InformaticsGateway/appsettings.Development.json

@@ -17,15 +17,15 @@
     "messaging": {
       "publisherSettings": {
         "endpoint": "localhost",
-        "username": "rabbitmq",
-        "password": "rabbitmq",
+        "username": "admin",
+        "password": "admin",
         "virtualHost": "monaideploy",
         "exchange": "monaideploy"
       },
       "subscriberSettings": {
         "endpoint": "localhost",
-        "username": "rabbitmq",
-        "password": "rabbitmq",
+        "username": "admin",
+        "password": "admin",
         "virtualHost": "monaideploy",
         "exchange": "monaideploy",
         "exportRequestQueue": "export_tasks"