SelectReviewService.cs

using Paiwise;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.Networking.HTTP;
using Waher.Persistence;
using Waher.Persistence.Filters;
using Waher.Runtime.Inventory;
using Waher.Script;
using Waher.Script.Abstraction.Elements;
using Waher.Service.IoTBroker.DataStorage;
using Waher.Service.IoTBroker.Legal.Identity;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Legal
{
    public class SelectReviewService : AgentPostResource
    {
        public SelectReviewService()
            : base("Legal/SelectReviewService",
                new KeyValuePair<Type, Expression>(typeof(Dictionary<string, object>), new Expression(jsonPattern)),
                new KeyValuePair<Type, Expression>(typeof(XmlDocument), new Expression(xmlPattern)))
        {
        }
 
        private static readonly string jsonPattern = Resources.LoadResourceAsText(typeof(SelectReviewService).Namespace + ".JSON.SelectReviewService.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(SelectReviewService).Namespace + ".XML.SelectReviewService.req");
 
        public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
 
            string ServiceId = (string)Parameters["PServiceId"].AssociatedObjectValue;
            string ServiceProvider = (string)Parameters["PServiceProvider"].AssociatedObjectValue;
 
            Type T = Types.GetType(ServiceProvider)
                ?? throw new NotFoundException("Service provider not found.");
 
            if (!typeof(IPeerReviewServiceProvider).IsAssignableFrom(T))
                throw new BadRequestException("Invalid service provider.");
 
            LegalIdentity IdentityApplication = await Database.FindFirstIgnoreRest<LegalIdentity>(new FilterAnd(
                new FilterFieldEqualTo("Account", User.UserName),
                new FilterFieldEqualTo("State", IdentityState.Created)), "-Created")
                ?? throw new ForbiddenException("No Identity Application found.");
 
            KeyValuePair<string, object>[] Tags = IdentityApplication.GetTags();
            IPeerReviewServiceProvider Provider = (IPeerReviewServiceProvider)Types.Instantiate(T);
            IPeerReviewService Service = await Provider.GetServiceForPeerReview(ServiceId, Tags)
                ?? throw new NotFoundException("Peer-review service not found.");
 
            XmppServerModule.Legal?.SelectServiceProvider(User.UserName, Service);
 
            await Response.Return(new NamedDictionary<string, object>("AckResponse", AgentNamespace));
        }
    }
}