mirror of
https://github.com/bitwarden/server.git
synced 2025-05-23 04:21:05 -05:00
remove old share solution code
This commit is contained in:
parent
321183c570
commit
acb1fc0be5
@ -31,25 +31,25 @@ namespace Bit.Api.Controllers
|
|||||||
}
|
}
|
||||||
|
|
||||||
[HttpGet("{id}")]
|
[HttpGet("{id}")]
|
||||||
public async Task<CipherShareResponseModel> Get(string id)
|
public async Task<CipherResponseModel> Get(string id)
|
||||||
{
|
{
|
||||||
var userId = _userService.GetProperUserId(User).Value;
|
var userId = _userService.GetProperUserId(User).Value;
|
||||||
var cipher = await _cipherRepository.GetShareByIdAsync(new Guid(id), userId);
|
var cipher = await _cipherRepository.GetByIdAsync(new Guid(id), userId);
|
||||||
if(cipher == null)
|
if(cipher == null)
|
||||||
{
|
{
|
||||||
throw new NotFoundException();
|
throw new NotFoundException();
|
||||||
}
|
}
|
||||||
|
|
||||||
return new CipherShareResponseModel(cipher, userId);
|
return new CipherResponseModel(cipher, userId);
|
||||||
}
|
}
|
||||||
|
|
||||||
[HttpGet("")]
|
[HttpGet("")]
|
||||||
public async Task<ListResponseModel<CipherShareResponseModel>> Get()
|
public async Task<ListResponseModel<CipherResponseModel>> Get()
|
||||||
{
|
{
|
||||||
var userId = _userService.GetProperUserId(User).Value;
|
var userId = _userService.GetProperUserId(User).Value;
|
||||||
var ciphers = await _cipherRepository.GetManyShareByUserIdAsync(userId);
|
var ciphers = await _cipherRepository.GetManyByUserIdAsync(userId);
|
||||||
var responses = ciphers.Select(c => new CipherShareResponseModel(c, userId));
|
var responses = ciphers.Select(c => new CipherResponseModel(c, userId));
|
||||||
return new ListResponseModel<CipherShareResponseModel>(responses);
|
return new ListResponseModel<CipherResponseModel>(responses);
|
||||||
}
|
}
|
||||||
|
|
||||||
[Obsolete]
|
[Obsolete]
|
||||||
|
@ -33,29 +33,29 @@ namespace Bit.Api.Controllers
|
|||||||
}
|
}
|
||||||
|
|
||||||
[HttpGet("{id}")]
|
[HttpGet("{id}")]
|
||||||
public async Task<LoginShareResponseModel> Get(string id, string[] expand = null)
|
public async Task<LoginResponseModel> Get(string id, string[] expand = null)
|
||||||
{
|
{
|
||||||
var userId = _userService.GetProperUserId(User).Value;
|
var userId = _userService.GetProperUserId(User).Value;
|
||||||
var login = await _cipherRepository.GetShareByIdAsync(new Guid(id), userId);
|
var login = await _cipherRepository.GetByIdAsync(new Guid(id), userId);
|
||||||
if(login == null || login.Type != Core.Enums.CipherType.Login)
|
if(login == null || login.Type != Core.Enums.CipherType.Login)
|
||||||
{
|
{
|
||||||
throw new NotFoundException();
|
throw new NotFoundException();
|
||||||
}
|
}
|
||||||
|
|
||||||
var response = new LoginShareResponseModel(login, userId);
|
var response = new LoginResponseModel(login, userId);
|
||||||
await ExpandAsync(login, response, expand, null, userId);
|
await ExpandAsync(login, response, expand, null, userId);
|
||||||
return response;
|
return response;
|
||||||
}
|
}
|
||||||
|
|
||||||
[HttpGet("")]
|
[HttpGet("")]
|
||||||
public async Task<ListResponseModel<LoginShareResponseModel>> Get(string[] expand = null)
|
public async Task<ListResponseModel<LoginResponseModel>> Get(string[] expand = null)
|
||||||
{
|
{
|
||||||
var userId = _userService.GetProperUserId(User).Value;
|
var userId = _userService.GetProperUserId(User).Value;
|
||||||
var logins = await _cipherRepository.GetManyShareByTypeAndUserIdAsync(Core.Enums.CipherType.Login,
|
var logins = await _cipherRepository.GetManyByTypeAndUserIdAsync(Core.Enums.CipherType.Login,
|
||||||
userId);
|
userId);
|
||||||
var responses = logins.Select(s => new LoginShareResponseModel(s, userId)).ToList();
|
var responses = logins.Select(s => new LoginResponseModel(s, userId)).ToList();
|
||||||
await ExpandManyAsync(logins, responses, expand, null, userId);
|
await ExpandManyAsync(logins, responses, expand, null, userId);
|
||||||
return new ListResponseModel<LoginShareResponseModel>(responses);
|
return new ListResponseModel<LoginResponseModel>(responses);
|
||||||
}
|
}
|
||||||
|
|
||||||
[HttpPost("")]
|
[HttpPost("")]
|
||||||
@ -119,8 +119,8 @@ namespace Bit.Api.Controllers
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task ExpandManyAsync<TResponseModel>(IEnumerable<Cipher> logins, ICollection<TResponseModel> responses,
|
private async Task ExpandManyAsync(IEnumerable<Cipher> logins, ICollection<LoginResponseModel> responses,
|
||||||
string[] expand, IEnumerable<Cipher> folders, Guid userId) where TResponseModel : LoginResponseModel
|
string[] expand, IEnumerable<Cipher> folders, Guid userId)
|
||||||
{
|
{
|
||||||
if(expand == null || expand.Count() == 0)
|
if(expand == null || expand.Count() == 0)
|
||||||
{
|
{
|
||||||
|
@ -1,83 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Linq;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using Microsoft.AspNetCore.Mvc;
|
|
||||||
using Bit.Core.Repositories;
|
|
||||||
using Microsoft.AspNetCore.Authorization;
|
|
||||||
using Bit.Api.Models;
|
|
||||||
using Bit.Core.Exceptions;
|
|
||||||
using Bit.Core.Services;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
|
|
||||||
namespace Bit.Api.Controllers
|
|
||||||
{
|
|
||||||
[Route("shares")]
|
|
||||||
[Authorize("Application")]
|
|
||||||
public class SharesController : Controller
|
|
||||||
{
|
|
||||||
private readonly IShareRepository _shareRepository;
|
|
||||||
private readonly IUserService _userService;
|
|
||||||
private readonly ICipherService _cipherService;
|
|
||||||
|
|
||||||
public SharesController(
|
|
||||||
IShareRepository shareRepository,
|
|
||||||
IUserService userService,
|
|
||||||
ICipherService cipherService)
|
|
||||||
{
|
|
||||||
_shareRepository = shareRepository;
|
|
||||||
_userService = userService;
|
|
||||||
_cipherService = cipherService;
|
|
||||||
}
|
|
||||||
|
|
||||||
[HttpGet("{id}")]
|
|
||||||
public async Task<ShareResponseModel> Get(string id)
|
|
||||||
{
|
|
||||||
var userId = _userService.GetProperUserId(User).Value;
|
|
||||||
var share = await _shareRepository.GetByIdAsync(new Guid(id), userId);
|
|
||||||
if(share == null)
|
|
||||||
{
|
|
||||||
throw new NotFoundException();
|
|
||||||
}
|
|
||||||
|
|
||||||
return new ShareResponseModel(share);
|
|
||||||
}
|
|
||||||
|
|
||||||
//[HttpGet("cipher/{cipherId}")]
|
|
||||||
//public async Task<IEnumerable<ShareResponseModel>> GetCipher(string cipherId)
|
|
||||||
//{
|
|
||||||
// var userId = _userService.GetProperUserId(User).Value;
|
|
||||||
// var share = await _shareRepository.GetByIdAsync(new Guid(cipherId), userId);
|
|
||||||
// if(share == null)
|
|
||||||
// {
|
|
||||||
// throw new NotFoundException();
|
|
||||||
// }
|
|
||||||
|
|
||||||
// return new ShareResponseModel(share);
|
|
||||||
//}
|
|
||||||
|
|
||||||
[HttpPost("")]
|
|
||||||
public async Task<ShareResponseModel> Post([FromBody]ShareRequestModel model)
|
|
||||||
{
|
|
||||||
var share = model.ToShare(_userService.GetProperUserId(User).Value);
|
|
||||||
await _cipherService.ShareAsync(share, model.Email);
|
|
||||||
|
|
||||||
var response = new ShareResponseModel(share);
|
|
||||||
return response;
|
|
||||||
}
|
|
||||||
|
|
||||||
[HttpDelete("{id}")]
|
|
||||||
[HttpPost("{id}/delete")]
|
|
||||||
public async Task Delete(string id)
|
|
||||||
{
|
|
||||||
var share = await _shareRepository.GetByIdAsync(new Guid(id), _userService.GetProperUserId(User).Value);
|
|
||||||
if(share == null)
|
|
||||||
{
|
|
||||||
throw new NotFoundException();
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: permission checks
|
|
||||||
|
|
||||||
await _shareRepository.DeleteAsync(share);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,33 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.ComponentModel.DataAnnotations;
|
|
||||||
using Bit.Core.Domains;
|
|
||||||
using Newtonsoft.Json;
|
|
||||||
|
|
||||||
namespace Bit.Api.Models
|
|
||||||
{
|
|
||||||
public class ShareRequestModel
|
|
||||||
{
|
|
||||||
[Required]
|
|
||||||
public string Email { get; set; }
|
|
||||||
[Required]
|
|
||||||
[StringLength(36)]
|
|
||||||
public string CipherId { get; set; }
|
|
||||||
public string Key { get; set; }
|
|
||||||
|
|
||||||
public Share ToShare(Guid sharerUserId)
|
|
||||||
{
|
|
||||||
return ToShare(new Share
|
|
||||||
{
|
|
||||||
SharerUserId = sharerUserId
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
public Share ToShare(Share existingShare)
|
|
||||||
{
|
|
||||||
existingShare.CipherId = new Guid(CipherId);
|
|
||||||
existingShare.Key = Key;
|
|
||||||
|
|
||||||
return existingShare;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,6 +1,5 @@
|
|||||||
using System;
|
using System;
|
||||||
using Bit.Core.Domains;
|
using Bit.Core.Domains;
|
||||||
using Bit.Core.Models.Data;
|
|
||||||
|
|
||||||
namespace Bit.Api.Models
|
namespace Bit.Api.Models
|
||||||
{
|
{
|
||||||
@ -19,7 +18,6 @@ namespace Bit.Api.Models
|
|||||||
Type = cipher.Type;
|
Type = cipher.Type;
|
||||||
Favorite = cipher.Favorite;
|
Favorite = cipher.Favorite;
|
||||||
RevisionDate = cipher.RevisionDate;
|
RevisionDate = cipher.RevisionDate;
|
||||||
Key = cipher.Key;
|
|
||||||
|
|
||||||
switch(cipher.Type)
|
switch(cipher.Type)
|
||||||
{
|
{
|
||||||
@ -38,21 +36,7 @@ namespace Bit.Api.Models
|
|||||||
public string FolderId { get; set; }
|
public string FolderId { get; set; }
|
||||||
public Core.Enums.CipherType Type { get; set; }
|
public Core.Enums.CipherType Type { get; set; }
|
||||||
public bool Favorite { get; set; }
|
public bool Favorite { get; set; }
|
||||||
public string Key { get; set; }
|
|
||||||
public dynamic Data { get; set; }
|
public dynamic Data { get; set; }
|
||||||
public DateTime RevisionDate { get; set; }
|
public DateTime RevisionDate { get; set; }
|
||||||
}
|
}
|
||||||
|
|
||||||
public class CipherShareResponseModel : CipherResponseModel
|
|
||||||
{
|
|
||||||
public CipherShareResponseModel(CipherShare cipherShare, Guid userId)
|
|
||||||
: base(cipherShare, userId, "cipherShare")
|
|
||||||
{
|
|
||||||
ReadOnly = cipherShare.ReadOnly;
|
|
||||||
Status = cipherShare.Status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public bool ReadOnly { get; set; }
|
|
||||||
public Core.Enums.ShareStatusType? Status { get; set; }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -1,13 +1,12 @@
|
|||||||
using System;
|
using System;
|
||||||
using Bit.Core.Domains;
|
using Bit.Core.Domains;
|
||||||
using Bit.Core.Models.Data;
|
|
||||||
|
|
||||||
namespace Bit.Api.Models
|
namespace Bit.Api.Models
|
||||||
{
|
{
|
||||||
public class LoginResponseModel : ResponseModel
|
public class LoginResponseModel : ResponseModel
|
||||||
{
|
{
|
||||||
public LoginResponseModel(Cipher cipher, Guid userId, string obj = "login")
|
public LoginResponseModel(Cipher cipher, Guid userId, string obj = "login")
|
||||||
: base("login")
|
: base(obj)
|
||||||
{
|
{
|
||||||
if(cipher == null)
|
if(cipher == null)
|
||||||
{
|
{
|
||||||
@ -30,7 +29,6 @@ namespace Bit.Api.Models
|
|||||||
Password = data.Password;
|
Password = data.Password;
|
||||||
Notes = data.Notes;
|
Notes = data.Notes;
|
||||||
RevisionDate = cipher.RevisionDate;
|
RevisionDate = cipher.RevisionDate;
|
||||||
Key = cipher.Key;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public string Id { get; set; }
|
public string Id { get; set; }
|
||||||
@ -42,22 +40,8 @@ namespace Bit.Api.Models
|
|||||||
public string Password { get; set; }
|
public string Password { get; set; }
|
||||||
public string Notes { get; set; }
|
public string Notes { get; set; }
|
||||||
public DateTime RevisionDate { get; set; }
|
public DateTime RevisionDate { get; set; }
|
||||||
public string Key { get; set; }
|
|
||||||
|
|
||||||
// Expandables
|
// Expandables
|
||||||
public FolderResponseModel Folder { get; set; }
|
public FolderResponseModel Folder { get; set; }
|
||||||
}
|
}
|
||||||
|
|
||||||
public class LoginShareResponseModel : LoginResponseModel
|
|
||||||
{
|
|
||||||
public LoginShareResponseModel(CipherShare cipherShare, Guid userId)
|
|
||||||
: base(cipherShare, userId, "loginShare")
|
|
||||||
{
|
|
||||||
ReadOnly = cipherShare.ReadOnly;
|
|
||||||
Status = cipherShare.Status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public bool ReadOnly { get; set; }
|
|
||||||
public Core.Enums.ShareStatusType? Status { get; set; }
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -1,33 +0,0 @@
|
|||||||
using System;
|
|
||||||
using Bit.Core.Domains;
|
|
||||||
|
|
||||||
namespace Bit.Api.Models
|
|
||||||
{
|
|
||||||
public class ShareResponseModel : ResponseModel
|
|
||||||
{
|
|
||||||
public ShareResponseModel(Share share)
|
|
||||||
: base("share")
|
|
||||||
{
|
|
||||||
if(share == null)
|
|
||||||
{
|
|
||||||
throw new ArgumentNullException(nameof(share));
|
|
||||||
}
|
|
||||||
|
|
||||||
Id = share.Id.ToString();
|
|
||||||
UserId = share.UserId.ToString();
|
|
||||||
SharerUserId = share.SharerUserId.ToString();
|
|
||||||
CipherId = share.CipherId.ToString();
|
|
||||||
Key = Key;
|
|
||||||
ReadOnly = share.ReadOnly;
|
|
||||||
Status = share.Status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public string Id { get; set; }
|
|
||||||
public string UserId { get; set; }
|
|
||||||
public string SharerUserId { get; set; }
|
|
||||||
public string CipherId { get; set; }
|
|
||||||
public string Key { get; set; }
|
|
||||||
public bool ReadOnly { get; set; }
|
|
||||||
public Core.Enums.ShareStatusType? Status { get; set; }
|
|
||||||
}
|
|
||||||
}
|
|
@ -79,7 +79,6 @@ namespace Bit.Api
|
|||||||
services.AddSingleton<ICipherRepository, SqlServerRepos.CipherRepository>();
|
services.AddSingleton<ICipherRepository, SqlServerRepos.CipherRepository>();
|
||||||
services.AddSingleton<IDeviceRepository, SqlServerRepos.DeviceRepository>();
|
services.AddSingleton<IDeviceRepository, SqlServerRepos.DeviceRepository>();
|
||||||
services.AddSingleton<IGrantRepository, SqlServerRepos.GrantRepository>();
|
services.AddSingleton<IGrantRepository, SqlServerRepos.GrantRepository>();
|
||||||
services.AddSingleton<IShareRepository, SqlServerRepos.ShareRepository>();
|
|
||||||
|
|
||||||
// Context
|
// Context
|
||||||
services.AddScoped<CurrentContext>();
|
services.AddScoped<CurrentContext>();
|
||||||
|
@ -10,7 +10,6 @@ namespace Bit.Core.Domains
|
|||||||
public Guid? FolderId { get; set; }
|
public Guid? FolderId { get; set; }
|
||||||
public Enums.CipherType Type { get; set; }
|
public Enums.CipherType Type { get; set; }
|
||||||
public bool Favorite { get; set; }
|
public bool Favorite { get; set; }
|
||||||
public string Key { get; set; }
|
|
||||||
public string Data { get; set; }
|
public string Data { get; set; }
|
||||||
public DateTime CreationDate { get; internal set; } = DateTime.UtcNow;
|
public DateTime CreationDate { get; internal set; } = DateTime.UtcNow;
|
||||||
public DateTime RevisionDate { get; internal set; } = DateTime.UtcNow;
|
public DateTime RevisionDate { get; internal set; } = DateTime.UtcNow;
|
||||||
|
@ -1,23 +0,0 @@
|
|||||||
using System;
|
|
||||||
using Bit.Core.Utilities;
|
|
||||||
|
|
||||||
namespace Bit.Core.Domains
|
|
||||||
{
|
|
||||||
public class Share : IDataObject<Guid>
|
|
||||||
{
|
|
||||||
public Guid Id { get; set; }
|
|
||||||
public Guid UserId { get; set; }
|
|
||||||
public Guid SharerUserId { get; set; }
|
|
||||||
public Guid CipherId { get; set; }
|
|
||||||
public string Key { get; set; }
|
|
||||||
public bool ReadOnly { get; set; }
|
|
||||||
public Enums.ShareStatusType Status { get; set; }
|
|
||||||
public DateTime CreationDate { get; internal set; } = DateTime.UtcNow;
|
|
||||||
public DateTime RevisionDate { get; internal set; } = DateTime.UtcNow;
|
|
||||||
|
|
||||||
public void SetNewId()
|
|
||||||
{
|
|
||||||
Id = CoreHelpers.GenerateComb();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,10 +0,0 @@
|
|||||||
using Bit.Core.Domains;
|
|
||||||
|
|
||||||
namespace Bit.Core.Models.Data
|
|
||||||
{
|
|
||||||
public class CipherShare : Cipher
|
|
||||||
{
|
|
||||||
public bool ReadOnly { get; internal set; }
|
|
||||||
public Enums.ShareStatusType? Status { get; internal set; }
|
|
||||||
}
|
|
||||||
}
|
|
@ -2,20 +2,16 @@
|
|||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.Threading.Tasks;
|
using System.Threading.Tasks;
|
||||||
using Bit.Core.Domains;
|
using Bit.Core.Domains;
|
||||||
using Bit.Core.Models.Data;
|
|
||||||
|
|
||||||
namespace Bit.Core.Repositories
|
namespace Bit.Core.Repositories
|
||||||
{
|
{
|
||||||
public interface ICipherRepository : IRepository<Cipher, Guid>
|
public interface ICipherRepository : IRepository<Cipher, Guid>
|
||||||
{
|
{
|
||||||
Task<Cipher> GetByIdAsync(Guid id, Guid userId);
|
Task<Cipher> GetByIdAsync(Guid id, Guid userId);
|
||||||
Task<CipherShare> GetShareByIdAsync(Guid id, Guid userId);
|
|
||||||
Task<ICollection<Cipher>> GetManyByUserIdAsync(Guid userId);
|
Task<ICollection<Cipher>> GetManyByUserIdAsync(Guid userId);
|
||||||
Task<ICollection<CipherShare>> GetManyShareByUserIdAsync(Guid userId);
|
|
||||||
Task<ICollection<Cipher>> GetManyByTypeAndUserIdAsync(Enums.CipherType type, Guid userId);
|
Task<ICollection<Cipher>> GetManyByTypeAndUserIdAsync(Enums.CipherType type, Guid userId);
|
||||||
Task<ICollection<CipherShare>> GetManyShareByTypeAndUserIdAsync(Enums.CipherType type, Guid userId);
|
Task<Tuple<ICollection<Cipher>, ICollection<Guid>>> GetManySinceRevisionDateAndUserIdWithDeleteHistoryAsync(
|
||||||
Task<Tuple<ICollection<Cipher>, ICollection<Guid>>>
|
DateTime sinceRevisionDate, Guid userId);
|
||||||
GetManySinceRevisionDateAndUserIdWithDeleteHistoryAsync(DateTime sinceRevisionDate, Guid userId);
|
|
||||||
Task UpdateUserEmailPasswordAndCiphersAsync(User user, IEnumerable<Cipher> ciphers);
|
Task UpdateUserEmailPasswordAndCiphersAsync(User user, IEnumerable<Cipher> ciphers);
|
||||||
Task CreateAsync(IEnumerable<Cipher> ciphers);
|
Task CreateAsync(IEnumerable<Cipher> ciphers);
|
||||||
}
|
}
|
||||||
|
@ -1,13 +0,0 @@
|
|||||||
using System;
|
|
||||||
using Bit.Core.Domains;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
|
|
||||||
namespace Bit.Core.Repositories
|
|
||||||
{
|
|
||||||
public interface IShareRepository : IRepository<Share, Guid>
|
|
||||||
{
|
|
||||||
Task<Share> GetByIdAsync(Guid id, Guid userId);
|
|
||||||
Task<ICollection<Share>> GetManyByCipherId(Guid id);
|
|
||||||
}
|
|
||||||
}
|
|
@ -7,7 +7,6 @@ using DataTableProxy;
|
|||||||
using Bit.Core.Domains;
|
using Bit.Core.Domains;
|
||||||
using System.Data;
|
using System.Data;
|
||||||
using Dapper;
|
using Dapper;
|
||||||
using Bit.Core.Models.Data;
|
|
||||||
|
|
||||||
namespace Bit.Core.Repositories.SqlServer
|
namespace Bit.Core.Repositories.SqlServer
|
||||||
{
|
{
|
||||||
@ -32,19 +31,6 @@ namespace Bit.Core.Repositories.SqlServer
|
|||||||
return cipher;
|
return cipher;
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<CipherShare> GetShareByIdAsync(Guid id, Guid userId)
|
|
||||||
{
|
|
||||||
using(var connection = new SqlConnection(ConnectionString))
|
|
||||||
{
|
|
||||||
var results = await connection.QueryAsync<CipherShare>(
|
|
||||||
$"[{Schema}].[CipherShare_ReadById]",
|
|
||||||
new { UserId = userId },
|
|
||||||
commandType: CommandType.StoredProcedure);
|
|
||||||
|
|
||||||
return results.FirstOrDefault(c => c.UserId == userId);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task<ICollection<Cipher>> GetManyByUserIdAsync(Guid userId)
|
public async Task<ICollection<Cipher>> GetManyByUserIdAsync(Guid userId)
|
||||||
{
|
{
|
||||||
using(var connection = new SqlConnection(ConnectionString))
|
using(var connection = new SqlConnection(ConnectionString))
|
||||||
@ -58,19 +44,6 @@ namespace Bit.Core.Repositories.SqlServer
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<ICollection<CipherShare>> GetManyShareByUserIdAsync(Guid userId)
|
|
||||||
{
|
|
||||||
using(var connection = new SqlConnection(ConnectionString))
|
|
||||||
{
|
|
||||||
var results = await connection.QueryAsync<CipherShare>(
|
|
||||||
$"[{Schema}].[CipherShare_ReadByUserId]",
|
|
||||||
new { UserId = userId },
|
|
||||||
commandType: CommandType.StoredProcedure);
|
|
||||||
|
|
||||||
return results.ToList();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task<ICollection<Cipher>> GetManyByTypeAndUserIdAsync(Enums.CipherType type, Guid userId)
|
public async Task<ICollection<Cipher>> GetManyByTypeAndUserIdAsync(Enums.CipherType type, Guid userId)
|
||||||
{
|
{
|
||||||
using(var connection = new SqlConnection(ConnectionString))
|
using(var connection = new SqlConnection(ConnectionString))
|
||||||
@ -88,23 +61,6 @@ namespace Bit.Core.Repositories.SqlServer
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<ICollection<CipherShare>> GetManyShareByTypeAndUserIdAsync(Enums.CipherType type, Guid userId)
|
|
||||||
{
|
|
||||||
using(var connection = new SqlConnection(ConnectionString))
|
|
||||||
{
|
|
||||||
var results = await connection.QueryAsync<CipherShare>(
|
|
||||||
$"[{Schema}].[CipherShare_ReadByTypeUserId]",
|
|
||||||
new
|
|
||||||
{
|
|
||||||
Type = type,
|
|
||||||
UserId = userId
|
|
||||||
},
|
|
||||||
commandType: CommandType.StoredProcedure);
|
|
||||||
|
|
||||||
return results.ToList();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task<Tuple<ICollection<Cipher>, ICollection<Guid>>>
|
public async Task<Tuple<ICollection<Cipher>, ICollection<Guid>>>
|
||||||
GetManySinceRevisionDateAndUserIdWithDeleteHistoryAsync(DateTime sinceRevisionDate, Guid userId)
|
GetManySinceRevisionDateAndUserIdWithDeleteHistoryAsync(DateTime sinceRevisionDate, Guid userId)
|
||||||
{
|
{
|
||||||
|
@ -1,46 +0,0 @@
|
|||||||
using System;
|
|
||||||
using Bit.Core.Domains;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.Data.SqlClient;
|
|
||||||
using Dapper;
|
|
||||||
using System.Data;
|
|
||||||
using System.Linq;
|
|
||||||
|
|
||||||
namespace Bit.Core.Repositories.SqlServer
|
|
||||||
{
|
|
||||||
public class ShareRepository : Repository<Share, Guid>, IShareRepository
|
|
||||||
{
|
|
||||||
public ShareRepository(GlobalSettings globalSettings)
|
|
||||||
: this(globalSettings.SqlServer.ConnectionString)
|
|
||||||
{ }
|
|
||||||
|
|
||||||
public ShareRepository(string connectionString)
|
|
||||||
: base(connectionString)
|
|
||||||
{ }
|
|
||||||
|
|
||||||
public async Task<Share> GetByIdAsync(Guid id, Guid userId)
|
|
||||||
{
|
|
||||||
var share = await GetByIdAsync(id);
|
|
||||||
if(share == null || (share.UserId != userId && share.SharerUserId != userId))
|
|
||||||
{
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return share;
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task<ICollection<Share>> GetManyByCipherId(Guid cipherId)
|
|
||||||
{
|
|
||||||
using(var connection = new SqlConnection(ConnectionString))
|
|
||||||
{
|
|
||||||
var results = await connection.QueryAsync<Share>(
|
|
||||||
$"[{Schema}].[Share_ReadByCipherId]",
|
|
||||||
new { CipherId = cipherId },
|
|
||||||
commandType: CommandType.StoredProcedure);
|
|
||||||
|
|
||||||
return results.ToList();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -10,6 +10,5 @@ namespace Bit.Core.Services
|
|||||||
Task DeleteAsync(Cipher cipher);
|
Task DeleteAsync(Cipher cipher);
|
||||||
Task ImportCiphersAsync(List<Cipher> folders, List<Cipher> ciphers,
|
Task ImportCiphersAsync(List<Cipher> folders, List<Cipher> ciphers,
|
||||||
IEnumerable<KeyValuePair<int, int>> folderRelationships);
|
IEnumerable<KeyValuePair<int, int>> folderRelationships);
|
||||||
Task ShareAsync(Share share, string email);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -10,18 +10,15 @@ namespace Bit.Core.Services
|
|||||||
public class CipherService : ICipherService
|
public class CipherService : ICipherService
|
||||||
{
|
{
|
||||||
private readonly ICipherRepository _cipherRepository;
|
private readonly ICipherRepository _cipherRepository;
|
||||||
private readonly IShareRepository _shareRepository;
|
|
||||||
private readonly IUserRepository _userRepository;
|
private readonly IUserRepository _userRepository;
|
||||||
private readonly IPushService _pushService;
|
private readonly IPushService _pushService;
|
||||||
|
|
||||||
public CipherService(
|
public CipherService(
|
||||||
ICipherRepository cipherRepository,
|
ICipherRepository cipherRepository,
|
||||||
IShareRepository shareRepository,
|
|
||||||
IUserRepository userRepository,
|
IUserRepository userRepository,
|
||||||
IPushService pushService)
|
IPushService pushService)
|
||||||
{
|
{
|
||||||
_cipherRepository = cipherRepository;
|
_cipherRepository = cipherRepository;
|
||||||
_shareRepository = shareRepository;
|
|
||||||
_userRepository = userRepository;
|
_userRepository = userRepository;
|
||||||
_pushService = pushService;
|
_pushService = pushService;
|
||||||
}
|
}
|
||||||
@ -90,24 +87,5 @@ namespace Bit.Core.Services
|
|||||||
await _pushService.PushSyncCiphersAsync(userId.Value);
|
await _pushService.PushSyncCiphersAsync(userId.Value);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task ShareAsync(Share share, string email)
|
|
||||||
{
|
|
||||||
// TODO: Make sure share does not already exist between these two users.
|
|
||||||
|
|
||||||
var user = await _userRepository.GetByEmailAsync(email);
|
|
||||||
if(user == null)
|
|
||||||
{
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
share.UserId = user.Id;
|
|
||||||
|
|
||||||
// TODO: Permissions and status
|
|
||||||
share.ReadOnly = false;
|
|
||||||
share.Status = Enums.ShareStatusType.Accepted;
|
|
||||||
|
|
||||||
await _shareRepository.CreateAsync(share);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user