add basic redis

AuctionTracker/AuctionTracker.csproj

@@ -15,6 +15,7 @@
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="2.1.1" />
     <PackageReference Include="Microsoft.Extensions.Configuration.FileExtensions" Version="2.1.1" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="2.1.1" />
+    <PackageReference Include="ServiceStack.Redis.Core" Version="5.1.0" />
   </ItemGroup>
 
 </Project>

AuctionTracker/Program.cs

@@ -13,6 +13,8 @@ using log4net.Config;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Configuration.FileExtensions;
 using Microsoft.Extensions.Configuration.Json;
+using ServiceStack.Redis;
+using ServiceStack.Redis.Generic;
 
 namespace AuctionTracker
 {
@@ -25,6 +27,7 @@ namespace AuctionTracker
         private static IConfiguration _configuration;
         private static ILog _logger;
 
+        private static RedisManagerPool _redisPool;
         private static string _character;
         private static string _locale;
         private static string _realm;
@@ -80,6 +83,26 @@ namespace AuctionTracker
                 }
             }
             lastAuctions = auctions;
+            //update redis database
+            using (IRedisClient client = _redisPool.GetClient())
+            {
+                var auctionClient = client.As<RedisAuctionSnapshot>();
+                foreach(Auction auction in auctions)
+                {
+                    RedisAuctionSnapshot snapshot = await RedisAuctionSnapshot.FromAuctionClientAsync(auction, _client, _locale);
+                    auctionClient.Store(snapshot, TimeSpan.FromMinutes(20d));
+                }
+            }
+            //retrieving stuff
+            _logger.Info("Retrieving stored values");
+            using (IRedisClient client = _redisPool.GetClient())
+            {
+                var auctionClient = client.As<RedisAuctionSnapshot>();
+                foreach(RedisAuctionSnapshot item in auctionClient.GetAll())
+                {
+                    _logger.Info(item.Name);
+                }
+            }
         }
         static async Task Main(string[] args)
         {
@@ -99,6 +122,8 @@ namespace AuctionTracker
             _logger.Info("Creating Clients");
             _client = new BlizzSharpClient($"{_configuration["blizzardApiKey"]}");
             _pushClient = new PushClient($"{_configuration["pushoverSecretKey"]}", $"{_configuration["pushoverUserKey"]}");
+            _logger.Info("Initializing redis pool");
+            _redisPool = new RedisManagerPool("localhost:6379");
             _logger.Info("AuctionTracker started, entering loop");
 
             while(true)

AuctionTracker/RedisAuctionSnapshot.cs

@@ -0,0 +1,29 @@
+using System;
+using System.Threading.Tasks;
+
+namespace AuctionTracker
+{
+    public class RedisAuctionSnapshot
+    {
+        public long Gold {get;set;}
+        public long Silver {get;set;}
+        public long Copper {get;set;}
+        public string Name {get;set;}
+
+        public long Id {get;set;}
+        private RedisAuctionSnapshot(BlizzSharp.Data.Auction auction, BlizzSharp.Data.Item item)
+        {
+            Gold = auction.Buyout / 10000;
+            Silver = (auction.Buyout - (Gold*10000)) / 100;
+            Copper = (auction.Buyout - (Gold*10000) - (Silver * 100));
+            Name = item.Name;
+            Id = auction.Id;
+        }
+
+        public static async Task<RedisAuctionSnapshot> FromAuctionClientAsync(BlizzSharp.Data.Auction auction, BlizzSharp.BlizzSharpClient client, string locale)
+        {
+            return new RedisAuctionSnapshot(auction, await client.GetItemInfoAsync(auction.Item, locale));
+        }
+    }
+
+}