using System; using System.Linq; using System.Threading.Tasks; using Microsoft.AspNetCore.Mvc; using Bit.Core.Repositories; using Microsoft.AspNetCore.Authorization; using Bit.Core.Models.Api; using Bit.Core.Exceptions; using Bit.Core.Services; namespace Bit.Api.Controllers { [Route("ciphers")] [Authorize("Application")] public class CiphersController : Controller { private readonly ICipherRepository _cipherRepository; private readonly ICipherService _cipherService; private readonly IUserService _userService; public CiphersController( ICipherRepository cipherRepository, ICipherService cipherService, IUserService userService) { _cipherRepository = cipherRepository; _cipherService = cipherService; _userService = userService; } [HttpGet("{id}")] public async Task Get(string id) { var userId = _userService.GetProperUserId(User).Value; var cipher = await _cipherRepository.GetByIdAsync(new Guid(id), userId); if(cipher == null) { throw new NotFoundException(); } return new CipherResponseModel(cipher); } [HttpGet("")] public async Task> Get() { var userId = _userService.GetProperUserId(User).Value; var ciphers = await _cipherRepository.GetManyByUserIdAsync(userId); var responses = ciphers.Select(c => new CipherResponseModel(c)); return new ListResponseModel(responses); } //[Obsolete] //[HttpGet("history")] //public async Task Get(DateTime since) //{ // var userId = _userService.GetProperUserId(User).Value; // var history = await _cipherRepository.GetManySinceRevisionDateAndUserIdWithDeleteHistoryAsync( // since, userId); // return new CipherHistoryResponseModel(history.Item1, history.Item2, userId); //} [HttpPost("import")] public async Task PostImport([FromBody]ImportRequestModel model) { var userId = _userService.GetProperUserId(User).Value; var folderCiphers = model.Folders.Select(f => f.ToFolder(userId)).ToList(); var otherCiphers = model.Logins.Select(s => s.ToCipherDetails(userId)).ToList(); await _cipherService.ImportCiphersAsync( folderCiphers, otherCiphers, model.FolderRelationships); } //[HttpPut("{id}/favorite")] //[HttpPost("{id}/favorite")] //public async Task Favorite(string id) //{ // var cipher = await _cipherRepository.GetByIdAsync(new Guid(id), _userService.GetProperUserId(User).Value); // if(cipher == null) // { // throw new NotFoundException(); // } // cipher.Favorite = !cipher.Favorite; // await _cipherService.SaveAsync(cipher); //} [HttpPut("{id}/move")] [HttpPost("{id}/move")] public async Task PostMove(string id, [FromBody]CipherMoveRequestModel model) { var userId = _userService.GetProperUserId(User).Value; var cipher = await _cipherRepository.GetByIdAsync(new Guid(id), userId); if(cipher == null) { throw new NotFoundException(); } await _cipherService.MoveSubvaultAsync(model.Cipher.ToCipher(cipher), model.SubvaultIds.Select(s => new Guid(s)), userId); } [HttpDelete("{id}")] [HttpPost("{id}/delete")] public async Task Delete(string id) { var userId = _userService.GetProperUserId(User).Value; var cipher = await _cipherRepository.GetByIdAsync(new Guid(id), userId); if(cipher == null) { throw new NotFoundException(); } await _cipherService.DeleteAsync(cipher); } } }