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

feat : use csredis async api

Browse source
This commit is contained in:
geffzhang 2018-11-01 11:09:52 +08:00
parent 24ed5179e5
commit 7c42c6462a
2 changed files with 7 additions and 8 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

12
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
{
@ -51,7 +51,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);
if(agent.Name == agentName)
@ -76,7 +76,7 @@ namespace BotSharp.Core.AgentStorage
Formatting = Formatting.Indented,
});
csredis.Set(agent.Id, json);
await csredis.SetAsync(agent.Id, json);
return true;
}
@ -85,7 +85,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 +97,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);
}