events collect endpoint

src/Events/Controllers/EventsController.cs

@@ -1,6 +1,6 @@
-using System;
+using System.Threading.Tasks;
-using System.Threading.Tasks;
 using Bit.Core;
+using Bit.Core.Enums;
 using Bit.Core.Repositories;
 using Bit.Core.Services;
 using Bit.Events.Models;
@@ -26,20 +26,39 @@ namespace Events.Controllers
             _cipherRepository = cipherRepository;
         }
 
-        [HttpPost("~/cipher/{id}")]
+        [HttpGet("~/collect")]
-        public async Task PostCipher(Guid id, [FromBody]EventModel model)
+        public Task<IActionResult> GetCollect([FromQuery]EventModel model)
         {
-            var cipher = await _cipherRepository.GetByIdAsync(id, _currentContext.UserId.Value);
+            return PostCollect(model);
-            if(cipher != null)
-            {
-                await _eventService.LogCipherEventAsync(cipher, model.Type);
-            }
         }
 
-        [HttpPost("~/user")]
+        [HttpPost("~/collect")]
-        public async Task PostUser([FromBody]EventModel model)
+        public async Task<IActionResult> PostCollect([FromBody]EventModel model)
         {
-            await _eventService.LogUserEventAsync(_currentContext.UserId.Value, model.Type);
+            switch(model.Type)
+            {
+                // User events
+                case EventType.User_LoggedIn:
+                    await _eventService.LogUserEventAsync(_currentContext.UserId.Value, model.Type);
+                    break;
+                // Cipher events
+                case EventType.Cipher_Created:
+                    if(!model.CipherId.HasValue)
+                    {
+                        return new BadRequestResult();
+                    }
+                    var cipher = await _cipherRepository.GetByIdAsync(model.CipherId.Value,
+                        _currentContext.UserId.Value);
+                    if(cipher == null)
+                    {
+                        return new BadRequestResult();
+                    }
+                    await _eventService.LogCipherEventAsync(cipher, model.Type);
+                    break;
+                default:
+                    return new BadRequestResult();
+            }
+            return new OkResult();
         }
     }
 }

src/Events/Models/EventModel.cs

@@ -6,5 +6,6 @@ namespace Bit.Events.Models
     public class EventModel
     {
         public EventType Type { get; set; }
+        public Guid? CipherId { get; set; }
     }
 }