summaryrefslogtreecommitdiff
path: root/dsa/FireBase/Query/FirebaseQuery.cs
diff options
context:
space:
mode:
Diffstat (limited to 'dsa/FireBase/Query/FirebaseQuery.cs')
-rw-r--r--dsa/FireBase/Query/FirebaseQuery.cs99
1 files changed, 33 insertions, 66 deletions
diff --git a/dsa/FireBase/Query/FirebaseQuery.cs b/dsa/FireBase/Query/FirebaseQuery.cs
index 60d0289..91e7afa 100644
--- a/dsa/FireBase/Query/FirebaseQuery.cs
+++ b/dsa/FireBase/Query/FirebaseQuery.cs
@@ -8,13 +8,11 @@ using Firebase.Database.Http;
using Firebase.Database.Streaming;
using Newtonsoft.Json;
-namespace Firebase.Database.Query
-{
+namespace Firebase.Database.Query {
/// <summary>
/// Represents a firebase query.
/// </summary>
- public abstract class FirebaseQuery : IFirebaseQuery, IDisposable
- {
+ public abstract class FirebaseQuery : IFirebaseQuery, IDisposable {
protected readonly FirebaseQuery Parent;
private HttpClient client;
@@ -25,8 +23,7 @@ namespace Firebase.Database.Query
/// </summary>
/// <param name="parent"> The parent of this query. </param>
/// <param name="client"> The owning client. </param>
- protected FirebaseQuery(FirebaseQuery parent, FirebaseClient client)
- {
+ protected FirebaseQuery(FirebaseQuery parent, FirebaseClient client) {
Client = client;
Parent = parent;
}
@@ -34,8 +31,7 @@ namespace Firebase.Database.Query
/// <summary>
/// Disposes this instance.
/// </summary>
- public void Dispose()
- {
+ public void Dispose() {
client?.Dispose();
}
@@ -50,16 +46,13 @@ namespace Firebase.Database.Query
/// <param name="timeout"> Optional timeout value. </param>
/// <typeparam name="T"> Type of elements. </typeparam>
/// <returns> Collection of <see cref="FirebaseObject{T}" /> holding the entities returned by server. </returns>
- public async Task<IReadOnlyCollection<FirebaseObject<T>>> OnceAsync<T>(TimeSpan? timeout = null)
- {
+ public async Task<IReadOnlyCollection<FirebaseObject<T>>> OnceAsync<T>(TimeSpan? timeout = null) {
var url = string.Empty;
- try
- {
+ try {
url = await BuildUrlAsync().ConfigureAwait(false);
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException("Couldn't build the url", string.Empty, string.Empty, HttpStatusCode.OK,
ex);
}
@@ -75,10 +68,8 @@ namespace Firebase.Database.Query
/// <param name="elementRoot"> Optional custom root element of received json items. </param>
/// <returns> Observable stream of <see cref="FirebaseEvent{T}" />. </returns>
public IObservable<FirebaseEvent<T>> AsObservable<T>(
- EventHandler<ExceptionEventArgs<FirebaseException>> exceptionHandler = null, string elementRoot = "")
- {
- return Observable.Create<FirebaseEvent<T>>(observer =>
- {
+ EventHandler<ExceptionEventArgs<FirebaseException>> exceptionHandler = null, string elementRoot = "") {
+ return Observable.Create<FirebaseEvent<T>>(observer => {
var sub = new FirebaseSubscription<T>(observer, this, elementRoot, new FirebaseCache<T>());
sub.ExceptionThrown += exceptionHandler;
return sub.Run();
@@ -89,11 +80,9 @@ namespace Firebase.Database.Query
/// Builds the actual URL of this query.
/// </summary>
/// <returns> The <see cref="string" />. </returns>
- public async Task<string> BuildUrlAsync()
- {
+ public async Task<string> BuildUrlAsync() {
// if token factory is present on the parent then use it to generate auth token
- if (Client.Options.AuthTokenAsyncFactory != null)
- {
+ if (Client.Options.AuthTokenAsyncFactory != null) {
var token = await Client.Options.AuthTokenAsyncFactory().ConfigureAwait(false);
return this.WithAuth(token).BuildUrl(null);
}
@@ -124,23 +113,19 @@ namespace Firebase.Database.Query
/// <param name="timeout"> Optional timeout value. </param>
/// <typeparam name="T"> Type of elements. </typeparam>
/// <returns> Single object of type <typeparamref name="T" />. </returns>
- public async Task<T> OnceSingleAsync<T>(TimeSpan? timeout = null)
- {
+ public async Task<T> OnceSingleAsync<T>(TimeSpan? timeout = null) {
var responseData = string.Empty;
var statusCode = HttpStatusCode.OK;
var url = string.Empty;
- try
- {
+ try {
url = await BuildUrlAsync().ConfigureAwait(false);
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException("Couldn't build the url", string.Empty, responseData, statusCode, ex);
}
- try
- {
+ try {
var response = await GetClient(timeout).GetAsync(url).ConfigureAwait(false);
statusCode = response.StatusCode;
responseData = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
@@ -150,8 +135,7 @@ namespace Firebase.Database.Query
return JsonConvert.DeserializeObject<T>(responseData, Client.Options.JsonSerializerSettings);
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException(url, string.Empty, responseData, statusCode, ex);
}
}
@@ -165,11 +149,9 @@ namespace Firebase.Database.Query
/// <typeparam name="T"> Type of <see cref="obj" /> </typeparam>
/// <returns> Resulting firebase object with populated key. </returns>
public async Task<FirebaseObject<string>> PostAsync(string data, bool generateKeyOffline = true,
- TimeSpan? timeout = null)
- {
+ TimeSpan? timeout = null) {
// post generates a new key server-side, while put can be used with an already generated local key
- if (generateKeyOffline)
- {
+ if (generateKeyOffline) {
var key = FirebaseKeyGenerator.Next();
await new ChildQuery(this, () => key, Client).PutAsync(data).ConfigureAwait(false);
@@ -190,8 +172,7 @@ namespace Firebase.Database.Query
/// <param name="timeout"> Optional timeout value. </param>
/// <typeparam name="T"> Type of <see cref="obj" /> </typeparam>
/// <returns> The <see cref="Task" />. </returns>
- public async Task PatchAsync(string data, TimeSpan? timeout = null)
- {
+ public async Task PatchAsync(string data, TimeSpan? timeout = null) {
var c = GetClient(timeout);
await this.Silent().SendAsync(c, data, new HttpMethod("PATCH")).ConfigureAwait(false);
@@ -204,8 +185,7 @@ namespace Firebase.Database.Query
/// <param name="timeout"> Optional timeout value. </param>
/// <typeparam name="T"> Type of <see cref="obj" /> </typeparam>
/// <returns> The <see cref="Task" />. </returns>
- public async Task PutAsync(string data, TimeSpan? timeout = null)
- {
+ public async Task PutAsync(string data, TimeSpan? timeout = null) {
var c = GetClient(timeout);
await this.Silent().SendAsync(c, data, HttpMethod.Put).ConfigureAwait(false);
@@ -216,32 +196,27 @@ namespace Firebase.Database.Query
/// </summary>
/// <param name="timeout"> Optional timeout value. </param>
/// <returns> The <see cref="Task" />. </returns>
- public async Task DeleteAsync(TimeSpan? timeout = null)
- {
+ public async Task DeleteAsync(TimeSpan? timeout = null) {
var c = GetClient(timeout);
var url = string.Empty;
var responseData = string.Empty;
var statusCode = HttpStatusCode.OK;
- try
- {
+ try {
url = await BuildUrlAsync().ConfigureAwait(false);
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException("Couldn't build the url", string.Empty, responseData, statusCode, ex);
}
- try
- {
+ try {
var result = await c.DeleteAsync(url).ConfigureAwait(false);
statusCode = result.StatusCode;
responseData = await result.Content.ReadAsStringAsync().ConfigureAwait(false);
result.EnsureSuccessStatusCode();
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException(url, string.Empty, responseData, statusCode, ex);
}
}
@@ -253,8 +228,7 @@ namespace Firebase.Database.Query
/// <returns> The <see cref="string" />. </returns>
protected abstract string BuildUrlSegment(FirebaseQuery child);
- private string BuildUrl(FirebaseQuery child)
- {
+ private string BuildUrl(FirebaseQuery child) {
var url = BuildUrlSegment(child);
if (Parent != null) url = Parent.BuildUrl(this) + url;
@@ -262,8 +236,7 @@ namespace Firebase.Database.Query
return url;
}
- private HttpClient GetClient(TimeSpan? timeout = null)
- {
+ private HttpClient GetClient(TimeSpan? timeout = null) {
if (client == null) client = new HttpClient();
if (!timeout.HasValue)
@@ -274,29 +247,24 @@ namespace Firebase.Database.Query
return client;
}
- private async Task<string> SendAsync(HttpClient client, string data, HttpMethod method)
- {
+ private async Task<string> SendAsync(HttpClient client, string data, HttpMethod method) {
var responseData = string.Empty;
var statusCode = HttpStatusCode.OK;
var requestData = data;
var url = string.Empty;
- try
- {
+ try {
url = await BuildUrlAsync().ConfigureAwait(false);
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException("Couldn't build the url", requestData, responseData, statusCode, ex);
}
- var message = new HttpRequestMessage(method, url)
- {
+ var message = new HttpRequestMessage(method, url) {
Content = new StringContent(requestData)
};
- try
- {
+ try {
var result = await client.SendAsync(message).ConfigureAwait(false);
statusCode = result.StatusCode;
responseData = await result.Content.ReadAsStringAsync().ConfigureAwait(false);
@@ -305,8 +273,7 @@ namespace Firebase.Database.Query
return responseData;
}
- catch (Exception ex)
- {
+ catch (Exception ex) {
throw new FirebaseException(url, requestData, responseData, statusCode, ex);
}
}
generated by cgit v1.2.3-54-g00ecf (git 2.45.0) at 2024-05-13 17:10:57 +0000