ClearQueueCommand.cs

using System;
using System.Threading.Tasks;
using Waher.Persistence;
using Waher.Runtime.Language;
using Waher.Things;
using Waher.Things.Queries;
 
namespace Waher.Service.IoTBroker.Sources.GatewayConfig.EventSinkNodes.Commands
{
    public class ClearQueueCommand : ICommand
    {
        private readonly string queueName;
 
        public ClearQueueCommand(string QueueName)
        {
            this.queueName = QueueName;
        }
 
        public string CommandID => "Clear";
 
        public CommandType Type => CommandType.Simple;
 
        public string SortCategory => "Queue";
 
        public string SortKey => "Clear";
 
        public Task<string> GetNameAsync(Language Language) =>
            Language.GetStringAsync(typeof(GatewayConfigSource), 254, "Clear Queue");
 
        public Task<string> GetConfirmationStringAsync(Language Language) =>
            Language.GetStringAsync(typeof(GatewayConfigSource), 255,
                "Are you sure you want to clear all messages in the queue?");
 
        public Task<string> GetFailureStringAsync(Language Language) =>
            Language.GetStringAsync(typeof(GatewayConfigSource), 256,
                "Unable to clear messages in queue.");
 
        public Task<string> GetSuccessStringAsync(Language Language) =>
            Language.GetStringAsync(typeof(GatewayConfigSource), 257,
                "Queue successfully cleared.");
 
        public Task<bool> CanExecuteAsync(RequestOrigin Caller)
        {
            return Task.FromResult(Caller.HasPrivilege("Admin.Queues." + this.queueName + ".Clear"));
        }
 
        public async Task ExecuteCommandAsync()
        {
            IPersistedQueue Queue = await Database.GetQueue(this.queueName);
            await Queue.Clear();
        }
 
        public Task StartQueryExecutionAsync(Query Query, Language Language) =>
            throw new InvalidOperationException();
 
        public ICommand Copy() => new ClearQueueCommand(this.queueName);
    }
}