summaryrefslogtreecommitdiff
path: root/FireBase/Query/FirebaseQuery.cs
diff options
context:
space:
mode:
Diffstat (limited to 'FireBase/Query/FirebaseQuery.cs')
-rw-r--r--FireBase/Query/FirebaseQuery.cs314
1 files changed, 0 insertions, 314 deletions
diff --git a/FireBase/Query/FirebaseQuery.cs b/FireBase/Query/FirebaseQuery.cs
deleted file mode 100644
index 60d0289..0000000
--- a/FireBase/Query/FirebaseQuery.cs
+++ /dev/null
@@ -1,314 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Net;
-using System.Net.Http;
-using System.Reactive.Linq;
-using System.Threading.Tasks;
-using Firebase.Database.Http;
-using Firebase.Database.Streaming;
-using Newtonsoft.Json;
-
-namespace Firebase.Database.Query
-{
- /// <summary>
- /// Represents a firebase query.
- /// </summary>
- public abstract class FirebaseQuery : IFirebaseQuery, IDisposable
- {
- protected readonly FirebaseQuery Parent;
-
- private HttpClient client;
- protected TimeSpan DEFAULT_HTTP_CLIENT_TIMEOUT = new TimeSpan(0, 0, 180);
-
- /// <summary>
- /// Initializes a new instance of the <see cref="FirebaseQuery" /> class.
- /// </summary>
- /// <param name="parent"> The parent of this query. </param>
- /// <param name="client"> The owning client. </param>
- protected FirebaseQuery(FirebaseQuery parent, FirebaseClient client)
- {
- Client = client;
- Parent = parent;
- }
-
- /// <summary>
- /// Disposes this instance.
- /// </summary>
- public void Dispose()
- {
- client?.Dispose();
- }
-
- /// <summary>
- /// Gets the client.
- /// </summary>
- public FirebaseClient Client { get; }
-
- /// <summary>
- /// Queries the firebase server once returning collection of items.
- /// </summary>
- /// <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)
- {
- var url = string.Empty;
-
- try
- {
- url = await BuildUrlAsync().ConfigureAwait(false);
- }
- catch (Exception ex)
- {
- throw new FirebaseException("Couldn't build the url", string.Empty, string.Empty, HttpStatusCode.OK,
- ex);
- }
-
- return await GetClient(timeout).GetObjectCollectionAsync<T>(url, Client.Options.JsonSerializerSettings)
- .ConfigureAwait(false);
- }
-
- /// <summary>
- /// Starts observing this query watching for changes real time sent by the server.
- /// </summary>
- /// <typeparam name="T"> Type of elements. </typeparam>
- /// <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 =>
- {
- var sub = new FirebaseSubscription<T>(observer, this, elementRoot, new FirebaseCache<T>());
- sub.ExceptionThrown += exceptionHandler;
- return sub.Run();
- });
- }
-
- /// <summary>
- /// Builds the actual URL of this query.
- /// </summary>
- /// <returns> The <see cref="string" />. </returns>
- 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)
- {
- var token = await Client.Options.AuthTokenAsyncFactory().ConfigureAwait(false);
- return this.WithAuth(token).BuildUrl(null);
- }
-
- return BuildUrl(null);
- }
-
- /*public async Task<IReadOnlyCollection<FirebaseObject<Object>>> OnceAsync(Type dataType, TimeSpan? timeout = null)
- {
- var url = string.Empty;
-
- try
- {
- url = await this.BuildUrlAsync().ConfigureAwait(false);
- }
- catch (Exception ex)
- {
- throw new FirebaseException("Couldn't build the url", string.Empty, string.Empty, HttpStatusCode.OK, ex);
- }
-
- return await this.GetClient(timeout).GetObjectCollectionAsync(url, Client.Options.JsonSerializerSettings, dataType)
- .ConfigureAwait(false);
- }*/
-
- /// <summary>
- /// Assumes given query is pointing to a single object of type <typeparamref name="T" /> and retrieves it.
- /// </summary>
- /// <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)
- {
- var responseData = string.Empty;
- var statusCode = HttpStatusCode.OK;
- var url = string.Empty;
-
- try
- {
- url = await BuildUrlAsync().ConfigureAwait(false);
- }
- catch (Exception ex)
- {
- throw new FirebaseException("Couldn't build the url", string.Empty, responseData, statusCode, ex);
- }
-
- try
- {
- var response = await GetClient(timeout).GetAsync(url).ConfigureAwait(false);
- statusCode = response.StatusCode;
- responseData = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
-
- response.EnsureSuccessStatusCode();
- response.Dispose();
-
- return JsonConvert.DeserializeObject<T>(responseData, Client.Options.JsonSerializerSettings);
- }
- catch (Exception ex)
- {
- throw new FirebaseException(url, string.Empty, responseData, statusCode, ex);
- }
- }
-
- /// <summary>
- /// Posts given object to repository.
- /// </summary>
- /// <param name="obj"> The object. </param>
- /// <param name="generateKeyOffline"> Specifies whether the key should be generated offline instead of online. </param>
- /// <param name="timeout"> Optional timeout value. </param>
- /// <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)
- {
- // post generates a new key server-side, while put can be used with an already generated local key
- if (generateKeyOffline)
- {
- var key = FirebaseKeyGenerator.Next();
- await new ChildQuery(this, () => key, Client).PutAsync(data).ConfigureAwait(false);
-
- return new FirebaseObject<string>(key, data);
- }
-
- var c = GetClient(timeout);
- var sendData = await SendAsync(c, data, HttpMethod.Post).ConfigureAwait(false);
- var result = JsonConvert.DeserializeObject<PostResult>(sendData, Client.Options.JsonSerializerSettings);
-
- return new FirebaseObject<string>(result.Name, data);
- }
-
- /// <summary>
- /// Patches data at given location instead of overwriting them.
- /// </summary>
- /// <param name="obj"> The object. </param>
- /// <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)
- {
- var c = GetClient(timeout);
-
- await this.Silent().SendAsync(c, data, new HttpMethod("PATCH")).ConfigureAwait(false);
- }
-
- /// <summary>
- /// Sets or overwrites data at given location.
- /// </summary>
- /// <param name="obj"> The object. </param>
- /// <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)
- {
- var c = GetClient(timeout);
-
- await this.Silent().SendAsync(c, data, HttpMethod.Put).ConfigureAwait(false);
- }
-
- /// <summary>
- /// Deletes data from given location.
- /// </summary>
- /// <param name="timeout"> Optional timeout value. </param>
- /// <returns> The <see cref="Task" />. </returns>
- public async Task DeleteAsync(TimeSpan? timeout = null)
- {
- var c = GetClient(timeout);
- var url = string.Empty;
- var responseData = string.Empty;
- var statusCode = HttpStatusCode.OK;
-
- try
- {
- url = await BuildUrlAsync().ConfigureAwait(false);
- }
- catch (Exception ex)
- {
- throw new FirebaseException("Couldn't build the url", string.Empty, responseData, statusCode, ex);
- }
-
- try
- {
- var result = await c.DeleteAsync(url).ConfigureAwait(false);
- statusCode = result.StatusCode;
- responseData = await result.Content.ReadAsStringAsync().ConfigureAwait(false);
-
- result.EnsureSuccessStatusCode();
- }
- catch (Exception ex)
- {
- throw new FirebaseException(url, string.Empty, responseData, statusCode, ex);
- }
- }
-
- /// <summary>
- /// Build the url segment of this child.
- /// </summary>
- /// <param name="child"> The child of this query. </param>
- /// <returns> The <see cref="string" />. </returns>
- protected abstract string BuildUrlSegment(FirebaseQuery child);
-
- private string BuildUrl(FirebaseQuery child)
- {
- var url = BuildUrlSegment(child);
-
- if (Parent != null) url = Parent.BuildUrl(this) + url;
-
- return url;
- }
-
- private HttpClient GetClient(TimeSpan? timeout = null)
- {
- if (client == null) client = new HttpClient();
-
- if (!timeout.HasValue)
- client.Timeout = DEFAULT_HTTP_CLIENT_TIMEOUT;
- else
- client.Timeout = timeout.Value;
-
- return client;
- }
-
- 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
- {
- url = await BuildUrlAsync().ConfigureAwait(false);
- }
- catch (Exception ex)
- {
- throw new FirebaseException("Couldn't build the url", requestData, responseData, statusCode, ex);
- }
-
- var message = new HttpRequestMessage(method, url)
- {
- Content = new StringContent(requestData)
- };
-
- try
- {
- var result = await client.SendAsync(message).ConfigureAwait(false);
- statusCode = result.StatusCode;
- responseData = await result.Content.ReadAsStringAsync().ConfigureAwait(false);
-
- result.EnsureSuccessStatusCode();
-
- return responseData;
- }
- catch (Exception ex)
- {
- throw new FirebaseException(url, requestData, responseData, statusCode, ex);
- }
- }
- }
-} \ No newline at end of file
generated by cgit v1.2.3-70-g09d2 (git 2.47.0) at 2024-11-19 00:20:46 +0000