SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Merge pull request #29 from geffzhang/master

Browse source 
use csredis async api
This commit is contained in:
geffzhang 2018-11-02 15:42:05 +08:00 committed by GitHub
parent dc6db83e57 180bdf07b4
commit 221f8134b8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
BotSharp.Core/AgentStorage/AgentStorageInMemory.cs
View file

@ -2,8 +2,7 @@
using BotSharp.Platform.Models;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Linq;
using System.Threading.Tasks;
namespace BotSharp.Core.AgentStorage

14
BotSharp.Core/AgentStorage/AgentStorageInRedis.cs
View file

@ -34,9 +34,9 @@ namespace BotSharp.Core.AgentStorage
public async Task<TAgent> FetchById(string agentId)
{
var key = agentId;
if (csredis.Exists(key))
if (await csredis.ExistsAsync(key))
{
return JsonConvert.DeserializeObject<TAgent>(csredis.Get(key));
return JsonConvert.DeserializeObject<TAgent>(await csredis.GetAsync(key));
}
else
{
@ -46,12 +46,10 @@ namespace BotSharp.Core.AgentStorage
public async Task<TAgent> FetchByName(string agentName)
{
var agents = new List<TAgent>();
var keys = csredis.Keys($"{prefix}*");
foreach (string key in keys)
{
var data = csredis.Get(key.Substring(prefix.Length));
var data = await csredis.GetAsync(key.Substring(prefix.Length));
var agent = JsonConvert.DeserializeObject<TAgent>(data);
if(agent.Name == agentName)
@ -76,7 +74,7 @@ namespace BotSharp.Core.AgentStorage
Formatting = Formatting.Indented,
});
csredis.Set(agent.Id, json);
await csredis.SetAsync(agent.Id, json);
return true;
}
@ -85,7 +83,7 @@ namespace BotSharp.Core.AgentStorage
{
var keys = csredis.Keys($"{prefix}*");
csredis.Del(keys.Select(x => x.Substring(prefix.Length)).ToArray());
await csredis.DelAsync(keys.Select(x => x.Substring(prefix.Length)).ToArray());
return keys.Count();
}
@ -97,7 +95,7 @@ namespace BotSharp.Core.AgentStorage
var keys = csredis.Keys($"{prefix}*");
foreach (string key in keys)
{
var data = csredis.Get(key.Substring(prefix.Length));
var data = await csredis.GetAsync(key.Substring(prefix.Length));
var agent = JsonConvert.DeserializeObject<TAgent>(data);
agents.Add(agent);
}