BlobResource.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Content.Binary;
using Waher.Networking.HTTP.Mcp.Model.Server;
 
namespace Waher.Networking.HTTP.Mcp.Model.Resources
{
    public class BlobResource : Resource
    {
        private readonly Func<Task<CustomEncoding>>? readCustom;
        private readonly Func<Task<byte[]>>? readBinary;
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<CustomEncoding>> Read, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, MetaData)
        {
            this.readCustom = Read;
            this.readBinary = null;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<CustomEncoding>> Read, string? RequiredPrivilege,
            params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, MetaData)
        {
            this.readCustom = Read;
            this.readBinary = null;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<CustomEncoding>> Read, string? RequiredPrivilege, long? Size, 
            params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, null, Size,
                  MetaData)
        {
            this.readCustom = Read;
            this.readBinary = null;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<CustomEncoding>> Read, string? RequiredPrivilege, long? Size, 
            Icon Icon, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, null, Size,
                  Icon, MetaData)
        {
            this.readCustom = Read;
            this.readBinary = null;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<CustomEncoding>> Read, string? RequiredPrivilege, long? Size, 
            Icons? Icons, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, null, Size,
                  Icons, MetaData)
        {
            this.readCustom = Read;
            this.readBinary = null;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<CustomEncoding>> Read, string? RequiredPrivilege, long? Size, 
            Icons? Icons, McpRole[]? Audience, double? Priority, DateTime? LastModified, 
            params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, null, Size,
                  Icons, Audience, Priority, LastModified, MetaData)
        {
            this.readCustom = Read;
            this.readBinary = null;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, string? RequiredPrivilege,
            params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, string? RequiredPrivilege, string? ContentType,
            params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, ContentType, MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, string? RequiredPrivilege, string? ContentType,
            long? Size, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, ContentType, Size,
                  MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, string? RequiredPrivilege, string? ContentType,
            long? Size, Icon Icon, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, ContentType, Size,
                  Icon, MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, string? RequiredPrivilege, string? ContentType,
            long? Size, Icons? Icons, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, ContentType, Size,
                  Icons, MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public BlobResource(string Name, string Title, string Description, Uri Uri,
            Func<Task<byte[]>> Read, string? RequiredPrivilege, string? ContentType,
            long? Size, Icons? Icons, McpRole[]? Audience, double? Priority,
            DateTime? LastModified, params KeyValuePair<string, object>[] MetaData)
            : base(Name, Title, Description, Uri, RequiredPrivilege, ContentType, Size,
                  Icons, Audience, Priority, LastModified, MetaData)
        {
            this.readCustom = null;
            this.readBinary = Read;
        }
 
        public override async Task<IResourceContent[]> Read(
            Dictionary<string, object>? MetaData)
        {
            BlobContent Content;
 
            if (this.readBinary is null)
            {
                CustomEncoding Encoded = await this.readCustom!();
                Content = new BlobContent(this.Uri, Encoded.Encoded, Encoded.ContentType, 
                    MetaData);
            }
            else
            {
                byte[] Encoded = await this.readBinary();
                Content = new BlobContent(this.Uri, Encoded, 
                    this.ContentType ?? BinaryCodec.DefaultContentType, MetaData);
            }
 
            return new IResourceContent[]
            {
                Content
            };
        }
    }
}