mirror of
https://dev.azure.com/TeilRad/sharee.bike%20App/_git/Code
synced 2024-10-06 13:26:28 +02:00
92 lines
3.3 KiB
C#
92 lines
3.3 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Threading.Tasks;
|
|
using Serilog;
|
|
using TINK.Model.Bikes;
|
|
using TINK.Model.Connector.Updater;
|
|
using TINK.Model.Services.CopriApi;
|
|
using TINK.Repository;
|
|
using TINK.Services.CopriApi;
|
|
using BikeInfo = TINK.Model.Bikes.BikeInfoNS.BC.BikeInfo;
|
|
|
|
namespace TINK.Model.Connector
|
|
{
|
|
public class CachedQuery : Base, IQuery
|
|
{
|
|
/// <summary> Cached copri server. </summary>
|
|
private readonly ICachedCopriServer server;
|
|
|
|
/// <summary>Constructs a copri query object.</summary>
|
|
/// <param name="copriServer">Server which implements communication.</param>
|
|
public CachedQuery(
|
|
ICopriServerBase copriServer) : base(copriServer)
|
|
{
|
|
server = copriServer as ICachedCopriServer;
|
|
if (server == null)
|
|
{
|
|
throw new ArgumentException($"Copri server is not of expected typ. Type detected is {copriServer.GetType()}.");
|
|
}
|
|
}
|
|
|
|
/// <summary> Gets all stations including postions and bikes.</summary>
|
|
public async Task<Result<StationsAndBikesContainer>> GetBikesAndStationsAsync()
|
|
{
|
|
var resultStations = await server.GetStations();
|
|
|
|
if (resultStations.Source == typeof(CopriCallsMonkeyStore))
|
|
{
|
|
// Communication with copri in order to get stations failed.
|
|
return new Result<StationsAndBikesContainer>(
|
|
resultStations.Source,
|
|
new StationsAndBikesContainer(
|
|
resultStations.Response.GetStationsAllMutable(),
|
|
(await server.GetBikesAvailable(true)).Response.GetBikesAvailable()),
|
|
resultStations.GeneralData,
|
|
resultStations.Exception);
|
|
}
|
|
|
|
var resultBikes = await server.GetBikesAvailable();
|
|
if (resultBikes.Source == typeof(CopriCallsMonkeyStore))
|
|
{
|
|
// Communication with copri in order to get bikes failed.
|
|
return new Result<StationsAndBikesContainer>(
|
|
resultBikes.Source,
|
|
new StationsAndBikesContainer(
|
|
(await server.GetStations(true)).Response.GetStationsAllMutable(),
|
|
resultBikes.Response.GetBikesAvailable()),
|
|
resultBikes.GeneralData,
|
|
resultBikes.Exception);
|
|
}
|
|
|
|
// Communicatin with copri succeeded.
|
|
server.AddToCache(resultStations);
|
|
server.AddToCache(resultBikes);
|
|
|
|
return new Result<StationsAndBikesContainer>(
|
|
resultStations.Source,
|
|
new StationsAndBikesContainer(resultStations.Response.GetStationsAllMutable(), resultBikes.Response.GetBikesAvailable()),
|
|
resultStations.GeneralData);
|
|
}
|
|
|
|
/// <summary> Gets bikes occupied. </summary>
|
|
/// <returns>Collection of bikes.</returns>
|
|
public async Task<Result<BikeCollection>> GetBikesOccupiedAsync()
|
|
{
|
|
Log.ForContext<CachedQuery>().Error("Unexpected call to get be bikes occpied detected. No user is logged in.");
|
|
return new Result<BikeCollection>(
|
|
typeof(CopriCallsMonkeyStore),
|
|
await Task.FromResult(new BikeCollection(new Dictionary<string, BikeInfo>())),
|
|
new GeneralData(),
|
|
new Exception("Abfrage der reservierten/ gebuchten Räder nicht möglich. Kein Benutzer angemeldet."));
|
|
}
|
|
|
|
/// <summary> Gets bikes available. </summary>
|
|
/// <returns>Collection of bikes.</returns>
|
|
public async Task<Result<BikeCollection>> GetBikesAsync()
|
|
{
|
|
var result = await server.GetBikesAvailable();
|
|
server.AddToCache(result);
|
|
return new Result<BikeCollection>(result.Source, result.Response.GetBikesAvailable(), result.GeneralData, result.Exception);
|
|
}
|
|
}
|
|
}
|