/
AsyncAdminServerClient.cs
88 lines (72 loc) · 3.33 KB
/
AsyncAdminServerClient.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
// -----------------------------------------------------------------------
// <copyright file="AdminAsyncServerClient.cs" company="Hibernating Rhinos LTD">
// Copyright (c) Hibernating Rhinos LTD. All rights reserved.
// </copyright>
// -----------------------------------------------------------------------
using System.Threading.Tasks;
using Raven.Abstractions.Data;
using Raven.Imports.Newtonsoft.Json;
using Raven.Json.Linq;
namespace Raven.Client.Connection.Async
{
public class AsyncAdminServerClient : IAsyncAdminDatabaseCommands, IAsyncGlobalAdminDatabaseCommands
{
internal readonly AsyncServerClient innerAsyncServerClient;
private readonly AdminRequestCreator adminRequest;
public AsyncAdminServerClient(AsyncServerClient asyncServerClient)
{
innerAsyncServerClient = asyncServerClient;
adminRequest =
new AdminRequestCreator((url, method) => innerAsyncServerClient.ForSystemDatabase().CreateRequest(url, method),
(url, method) => innerAsyncServerClient.CreateRequest(url, method),
(currentServerUrl, requestUrl, method) => innerAsyncServerClient.CreateReplicationAwareRequest(currentServerUrl, requestUrl, method));
}
public Task CreateDatabaseAsync(DatabaseDocument databaseDocument)
{
RavenJObject doc;
var req = adminRequest.CreateDatabase(databaseDocument, out doc);
return req.WriteAsync(doc.ToString(Formatting.Indented));
}
public Task DeleteDatabaseAsync(string databaseName, bool hardDelete = false)
{
return adminRequest.DeleteDatabase(databaseName, hardDelete).ExecuteRequestAsync();
}
public Task CompactDatabaseAsync(string databaseName)
{
return adminRequest.CompactDatabase(databaseName).ExecuteRequestAsync();
}
public Task StopIndexingAsync()
{
return innerAsyncServerClient.ExecuteWithReplication("POST", operationMetadata => adminRequest.StopIndexing(operationMetadata.Url).ExecuteRequestAsync());
}
public Task StartIndexingAsync()
{
return innerAsyncServerClient.ExecuteWithReplication("POST", operationMetadata => adminRequest.StartIndexing(operationMetadata.Url).ExecuteRequestAsync());
}
public async Task<AdminStatistics> GetStatisticsAsync()
{
var json = (RavenJObject) await adminRequest.AdminStats().ReadResponseJsonAsync();
return json.Deserialize<AdminStatistics>(innerAsyncServerClient.convention);
}
public Task StartBackupAsync(string backupLocation, DatabaseDocument databaseDocument, string databaseName)
{
RavenJObject backupSettings;
var request = adminRequest.StartBackup(backupLocation, databaseDocument, databaseName, out backupSettings);
return request.WriteAsync(backupSettings.ToString(Formatting.None));
}
public Task StartRestoreAsync(string restoreLocation, string databaseLocation, string databaseName = null, bool defrag = false)
{
RavenJObject restoreSettings;
var request = adminRequest.StartRestore(restoreLocation, databaseLocation, databaseName, defrag, out restoreSettings);
return request.WriteAsync(restoreSettings.ToString(Formatting.None));
}
public Task<string> GetIndexingStatusAsync()
{
return innerAsyncServerClient.ExecuteWithReplication("GET", async operationMetadata =>
{
var result = await adminRequest.IndexingStatus(operationMetadata.Url).ReadResponseJsonAsync();
return result.Value<string>("IndexingStatus");
});
}
}
}