Added the ability to find specific incidents using tags

Author: jgauffin

src/Server/Coderr.Server.Api/Core/Incidents/Queries/FindIncidents.cs

@@ -95,5 +95,7 @@ public FindIncidents()
         ///     Version (in the form of a version string i.e. "1.2.1")
         /// </summary>
         public string Version { get; set; }
+
+        public string[] Tags { get; set; }
     }
 }

src/Server/Coderr.Server.Api/Modules/Tagging/Queries/GetTagsForApplication.cs

@@ -0,0 +1,28 @@
+using System;
+using DotNetCqs;
+
+namespace codeRR.Server.Api.Modules.Tagging.Queries
+{
+    /// <summary>
+    ///     Get all tags that the system have identified for an incident.
+    /// </summary>
+    [Message]
+    public class GetTagsForApplication : Query<TagDTO[]>
+    {
+        /// <summary>
+        ///     Creates a new instance of <see cref="GetTagsForIncident" />.
+        /// </summary>
+        /// <param name="applicationId">Incident to get tags for</param>
+        /// <exception cref="ArgumentOutOfRangeException">incidentId</exception>
+        public GetTagsForApplication(int applicationId)
+        {
+            if (applicationId <= 0) throw new ArgumentOutOfRangeException("applicationId");
+            ApplicationId = applicationId;
+        }
+
+        /// <summary>
+        ///     Incident to get tags for
+        /// </summary>
+        public int ApplicationId { get; private set; }
+    }
+}

src/Server/Coderr.Server.App/GlobalSuppressions.cs

@@ -6,7 +6,7 @@
 [assembly:
     SuppressMessage("Microsoft.Performance", "CA1811:AvoidUncalledPrivateCode", Scope = "member",
         Target =
-            "codeRR.App.Modules.Tagging.Handlers.GetTagsForIncidentHandler.#.ctor(codeRR.App.Modules.Tagging.ITagsRepository)"
+            "codeRR.App.Modules.Tagging.Handlers.GetTagsForApplicationHandler.#.ctor(codeRR.App.Modules.Tagging.ITagsRepository)"
         )]
 [assembly:
     SuppressMessage("Microsoft.Performance", "CA1811:AvoidUncalledPrivateCode", Scope = "member",

src/Server/Coderr.Server.App/Modules/Tagging/Handlers/GetTagsForApplicationHandler.cs

@@ -0,0 +1,31 @@
+using System.Linq;
+using System.Threading.Tasks;
+using codeRR.Server.Api.Modules.Tagging;
+using codeRR.Server.Api.Modules.Tagging.Queries;
+using codeRR.Server.App.Modules.Tagging.Domain;
+using DotNetCqs;
+using Griffin.Container;
+
+namespace codeRR.Server.App.Modules.Tagging.Handlers
+{
+    [Component]
+    internal class GetTagsForApplicationHandler : IQueryHandler<GetTagsForApplication, TagDTO[]>
+    {
+        private readonly ITagsRepository _repository;
+
+        public GetTagsForApplicationHandler(ITagsRepository repository)
+        {
+            _repository = repository;
+        }
+
+        public async Task<TagDTO[]> HandleAsync(IMessageContext context, GetTagsForApplication query)
+        {
+            return (await _repository.GetApplicationTagsAsync(query.ApplicationId)).Select(ConvertTag).ToArray();
+        }
+
+        private TagDTO ConvertTag(Tag arg)
+        {
+            return new TagDTO {Name = arg.Name, OrderNumber = arg.OrderNumber};
+        }
+    }
+}

src/Server/Coderr.Server.App/Modules/Tagging/Handlers/GetTagsForIncidentHandler.cs

@@ -20,7 +20,7 @@ public GetTagsForIncidentHandler(ITagsRepository repository)
 
         public async Task<TagDTO[]> HandleAsync(IMessageContext context, GetTagsForIncident query)
         {
-            return (await _repository.GetTagsAsync(query.IncidentId)).Select(ConvertTag).ToArray();
+            return (await _repository.GetIncidentTagsAsync(query.IncidentId)).Select(ConvertTag).ToArray();
         }
 
         private TagDTO ConvertTag(Tag arg)

src/Server/Coderr.Server.App/Modules/Tagging/Handlers/IdentifyTagsFromIncident.cs

@@ -40,7 +40,7 @@ public IdentifyTagsFromIncident(ITagsRepository repository, ITagIdentifierProvid
         public async Task HandleAsync(IMessageContext context, ReportAddedToIncident e)
         {
             _logger.Debug("Checking tags..");
-            var tags = await _repository.GetTagsAsync(e.Incident.Id);
+            var tags = await _repository.GetIncidentTagsAsync(e.Incident.Id);
             var ctx = new TagIdentifierContext(e.Report, tags);
             var identifiers = _tagIdentifierProvider.GetIdentifiers(ctx);
             foreach (var identifier in identifiers)

src/Server/Coderr.Server.App/Modules/Tagging/Handlers/IncidentReopenedHandler.cs

@@ -30,7 +30,7 @@ public IncidentReopenedHandler(ITagsRepository repository)
         /// <inheritdoc />
         public async Task HandleAsync(IMessageContext context, IncidentReOpened e)
         {
-            var tags = await _repository.GetTagsAsync(e.IncidentId);
+            var tags = await _repository.GetIncidentTagsAsync(e.IncidentId);
             if (tags.Any(x => x.Name == "incident-reopened"))
                 return;
 

src/Server/Coderr.Server.App/Modules/Tagging/ITagsRepository.cs

@@ -19,11 +19,19 @@ public interface ITagsRepository
         Task AddAsync(int incidentId, Tag[] tags);
 
         /// <summary>
-        ///     Get a list of tag
+        ///     Get a list of tags for a specific incident
         /// </summary>
         /// <param name="incidentId">incident to get tags for</param>
         /// <returns>List of tags (or an empty list)</returns>
         [SuppressMessage("Microsoft.Design", "CA1006:DoNotNestGenericTypesInMemberSignatures")]
-        Task<IReadOnlyList<Tag>> GetTagsAsync(int incidentId);
+        Task<IReadOnlyList<Tag>> GetIncidentTagsAsync(int incidentId);
+
+        /// <summary>
+        ///     Get a list of tags for an application
+        /// </summary>
+        /// <param name="applicationId">application to get tags for</param>
+        /// <returns>List of tags (or an empty list)</returns>
+        [SuppressMessage("Microsoft.Design", "CA1006:DoNotNestGenericTypesInMemberSignatures")]
+        Task<IReadOnlyList<Tag>> GetApplicationTagsAsync(int applicationId);
     }
 }

src/Server/Coderr.Server.SqlServer/Core/Incidents/Queries/FindIncidentsHandler.cs

@@ -43,6 +43,26 @@ FROM Incidents
                     cmd.AddParameter("versionId", versionId);
                     startWord = " AND ";
                 }
+                if (query.Tags != null && query.Tags.Length > 0 && query.ApplicationId > 0)
+                {
+                    var ourSql= @" join IncidentTags on (Incidents.Id=IncidentTags.IncidentId AND IncidentTags.Id IN (
+                                    SELECT MAX(IncidentTags.Id)
+                                    FROM IncidentTags 
+                                    WHERE TagName IN ({0}) 
+                                    AND IncidentTags.IncidentId=Incidents.Id
+                                    GROUP BY IncidentId 
+                                    HAVING Count(IncidentTags.Id) = {1}
+                                    ))
+";
+                    var ps = "";
+                    for (int i = 0; i < query.Tags.Length; i++)
+                    {
+                        ps += $"@tag{i}, ";
+                        cmd.AddParameter($"@tag{i}", query.Tags[i]);
+                    }
+
+                    sqlQuery += string.Format(ourSql, ps.Remove(ps.Length - 2, 2), query.Tags.Length);
+                }
 
                 if (query.ApplicationId > 0)
                 {

src/Server/Coderr.Server.SqlServer/Modules/Tagging/TagsRepository.cs

@@ -33,7 +33,7 @@ public async Task AddAsync(int incidentId, Tag[] tags)
             }
         }
 
-        public async Task<IReadOnlyList<Tag>> GetTagsAsync(int incidentId)
+        public async Task<IReadOnlyList<Tag>> GetIncidentTagsAsync(int incidentId)
         {
             using (var cmd = _adoNetUnitOfWork.CreateDbCommand())
             {
@@ -51,5 +51,28 @@ public async Task<IReadOnlyList<Tag>> GetTagsAsync(int incidentId)
                 }
             }
         }
+
+        public async Task<IReadOnlyList<Tag>> GetApplicationTagsAsync(int applicationId)
+        {
+            using (var cmd = _adoNetUnitOfWork.CreateDbCommand())
+            {
+                cmd.CommandText = @"select TagName, min(OrderNumber)
+                                    FROM IncidentTags
+                                    INNER JOIN Incidents ON (IncidentTags.IncidentId=Incidents.Id)
+                                    WHERE Incidents.ApplicationId = @id
+                                    GROUP BY TagName";
+                cmd.AddParameter("id", applicationId);
+                using (var reader = await cmd.ExecuteReaderAsync())
+                {
+                    var tags = new List<Tag>();
+                    while (await reader.ReadAsync())
+                    {
+                        var tag = new Tag((string) reader[0], (int) reader[1]);
+                        tags.Add(tag);
+                    }
+                    return tags;
+                }
+            }
+        }
     }
 }