Added extra logging to event submission

Author: niemyjski

Source/Api/Controllers/EventController.cs

@@ -92,7 +92,7 @@ public async Task<IHttpActionResult> GetByIdAsync(string id, string filter = nul
             var organization = await GetOrganizationAsync(model.OrganizationId);
             if (organization == null)
                 return NotFound();
-            
+
             if (organization.IsSuspended || organization.RetentionDays > 0 && model.Date.UtcDateTime < SystemClock.UtcNow.SubtractDays(organization.RetentionDays))
                 return PlanLimitReached("Unable to view event occurrence due to plan limits.");
 
@@ -318,7 +318,7 @@ public async Task<IHttpActionResult> GetByReferenceIdAsync(string referenceId, s
             var project = await GetProjectAsync(projectId);
             if (project == null)
                 return NotFound();
-            
+
             var organization = await GetOrganizationAsync(project.OrganizationId);
             if (organization == null)
                 return NotFound();
@@ -378,7 +378,7 @@ public async Task<IHttpActionResult> GetBySessionIdAsync(string sessionId, strin
             var project = await GetProjectAsync(projectId);
             if (project == null)
                 return NotFound();
-            
+
             var organization = await GetOrganizationAsync(project.OrganizationId);
             if (organization == null)
                 return NotFound();
@@ -448,7 +448,7 @@ public async Task<IHttpActionResult> GetBySessionAsync(string projectId, string
             var sf = new ExceptionlessSystemFilterQuery(project, organization);
             return await GetInternalAsync(sf, ti, $"type:{Event.KnownTypes.Session} {filter}", sort, mode, page, limit, true);
         }
-        
+
         /// <summary>
         /// Set user description
         /// </summary>
@@ -566,12 +566,12 @@ public async Task<IHttpActionResult> RecordHeartbeatAsync(string projectId = nul
         /// </summary>
         /// <remarks>
         /// You can create an event using query string parameters.
-        /// 
+        ///
         /// Feature usage named build with a duration of 10:
         /// <code><![CDATA[/events/submit?access_token=YOUR_API_KEY&type=usage&source=build&value=10]]></code>
         /// OR
         /// <code><![CDATA[/events/submit/usage?access_token=YOUR_API_KEY&source=build&value=10]]></code>
-        /// 
+        ///
         /// Log with message, geo and extended data
         /// <code><![CDATA[/events/submit?access_token=YOUR_API_KEY&type=log&message=Hello World&source=server01&geo=32.85,-96.9613&randomproperty=true]]></code>
         /// OR
@@ -769,6 +769,18 @@ await _eventPostQueue.EnqueueAsync(new EventPostInfo {
             // Set the project for the configuration response filter.
             Request.SetProject(project);
 
+            if (data.LongLength > Settings.Current.MaximumEventPostSize) {
+                _logger.Error().Critical()
+                    .Message("Attempting to enqueue events greater than the maxiumum queue size")
+                    .Project(projectId)
+                    .Identity(ExceptionlessUser?.EmailAddress)
+                    .Property("User", ExceptionlessUser)
+                    .Property("Headers", Request.Content.Headers)
+                    .Property("Size", data.LongLength)
+                    .Property("MaximumEventPostSize", Settings.Current.MaximumEventPostSize)
+                    .SetActionContext(ActionContext);
+            }
+
             string contentEncoding = Request.Content.Headers.ContentEncoding.ToString();
             bool isCompressed = contentEncoding == "gzip" || contentEncoding == "deflate";
             if (!isCompressed && data.Length > 1000) {
@@ -819,7 +831,7 @@ public Task<IHttpActionResult> DeleteAsync(string ids) {
         private Task<Organization> GetOrganizationAsync(string organizationId, bool useCache = true) {
             if (String.IsNullOrEmpty(organizationId) || !CanAccessOrganization(organizationId))
                 return null;
-            
+
             return _organizationRepository.GetByIdAsync(organizationId, useCache);
         }
 
@@ -833,7 +845,7 @@ private async Task<Project> GetProjectAsync(string projectId, bool useCache = tr
 
             return project;
         }
-        
+
         private async Task<Stack> GetStackAsync(string stackId, bool useCache = true) {
             if (String.IsNullOrEmpty(stackId))
                 return null;

Source/Api/Utility/Handlers/OverageHandler.cs

@@ -29,7 +29,7 @@ private bool IsEventPost(HttpRequestMessage request) {
             if (request.Method != HttpMethod.Post)
                 return false;
 
-            return request.RequestUri.AbsolutePath.EndsWith("/events", StringComparison.OrdinalIgnoreCase) 
+            return request.RequestUri.AbsolutePath.EndsWith("/events", StringComparison.OrdinalIgnoreCase)
                 || String.Equals(request.RequestUri.AbsolutePath, "/api/v1/error", StringComparison.OrdinalIgnoreCase);
         }
 
@@ -41,7 +41,7 @@ protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage
                 return CreateResponse(request, HttpStatusCode.ServiceUnavailable, "Service Unavailable");
 
             bool tooBig = false;
-            if (request.Content?.Headers != null) {
+            if (request.Method == HttpMethod.Post && request.Content?.Headers != null) {
                 long size = request.Content.Headers.ContentLength.GetValueOrDefault();
                 await _metricsClient.GaugeAsync(MetricNames.PostsSize, size);
                 if (size > Settings.Current.MaximumEventPostSize) {
@@ -64,7 +64,7 @@ protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage
 
             return await base.SendAsync(request, cancellationToken);
         }
-        
+
         private HttpResponseMessage CreateResponse(HttpRequestMessage request, HttpStatusCode statusCode, string message) {
             HttpResponseMessage response = request.CreateResponse(statusCode);
             response.ReasonPhrase = message;