nhyatt/bitwarden
1
0
Fork 0
mirror of https://github.com/bitwarden/server.git synced 2025-04-18 03:28:15 -05:00
Code

private member _table

Browse Source
This commit is contained in:
Kyle Spearrin 2017-12-08 23:14:02 -05:00
parent 89d488739d
commit 59fc1df754
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Core/Repositories/TableStorage/EventRepository.cs
View File

@ -11,6 +11,8 @@ namespace Bit.Core.Repositories.TableStorage
{ {
public class EventRepository : IEventRepository public class EventRepository : IEventRepository
{ {
private readonly CloudTable _table;
public EventRepository(GlobalSettings globalSettings) public EventRepository(GlobalSettings globalSettings)
: this(globalSettings.Storage.ConnectionString) : this(globalSettings.Storage.ConnectionString)
{ } { }
@ -19,11 +21,9 @@ namespace Bit.Core.Repositories.TableStorage
{ {
var storageAccount = CloudStorageAccount.Parse(storageConnectionString); var storageAccount = CloudStorageAccount.Parse(storageConnectionString);
var tableClient = storageAccount.CreateCloudTableClient(); var tableClient = storageAccount.CreateCloudTableClient();
Table = tableClient.GetTableReference("event"); _table = tableClient.GetTableReference("event");
} }
protected CloudTable Table { get; set; }
public async Task<ICollection<IEvent>> GetManyByUserAsync(Guid userId, public async Task<ICollection<IEvent>> GetManyByUserAsync(Guid userId,
DateTime startDate, DateTime endDate) DateTime startDate, DateTime endDate)
{ {
@ -45,7 +45,7 @@ namespace Bit.Core.Repositories.TableStorage
TableContinuationToken continuationToken = null; TableContinuationToken continuationToken = null;
do do
{ {
var queryResults = await Table.ExecuteQuerySegmentedAsync(query, continuationToken); var queryResults = await _table.ExecuteQuerySegmentedAsync(query, continuationToken);
continuationToken = queryResults.ContinuationToken; continuationToken = queryResults.ContinuationToken;
results.AddRange(queryResults.Results); results.AddRange(queryResults.Results);
} while(continuationToken != null); } while(continuationToken != null);
@ -103,14 +103,14 @@ namespace Bit.Core.Repositories.TableStorage
batch.InsertOrReplace(entity); batch.InsertOrReplace(entity);
} }
await Table.ExecuteBatchAsync(batch); await _table.ExecuteBatchAsync(batch);
} }
} }
} }
public async Task CreateEntityAsync(ITableEntity entity) public async Task CreateEntityAsync(ITableEntity entity)
{ {
await Table.ExecuteAsync(TableOperation.Insert(entity)); await _table.ExecuteAsync(TableOperation.Insert(entity));
} }
} }
} }