sharee.bike-App/TINKLib/Model/Connector/Query/CachedQuery.cs

using Serilog;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using TINK.Model.Bike;
using TINK.Model.Services.CopriApi;
using TINK.Model.Repository;
using BikeInfo = TINK.Model.Bike.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="p_oCopriServer">Server which implements communication.</param>
        public CachedQuery(
            ICopriServerBase p_oCopriServer) : base(p_oCopriServer)
        {
            server = p_oCopriServer as ICachedCopriServer;
            if (server == null)
            {
                throw new ArgumentException($"Copri server is not of expected typ. Type detected is {p_oCopriServer.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.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.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()));
        }

        /// <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.Run(() => new BikeCollection(new Dictionary<int, BikeInfo>())),
                new System.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.Exception);
        }
    }
}