♻️ Moved the site to the Zone project
This commit is contained in:
111
DysonNetwork.Shared/Registry/RemotePublisherService.cs
Normal file
111
DysonNetwork.Shared/Registry/RemotePublisherService.cs
Normal file
@@ -0,0 +1,111 @@
|
||||
using DysonNetwork.Shared.Models;
|
||||
using DysonNetwork.Shared.Proto;
|
||||
|
||||
namespace DysonNetwork.Shared.Registry;
|
||||
|
||||
public class RemotePublisherService(PublisherService.PublisherServiceClient publishers)
|
||||
{
|
||||
public async Task<SnPublisher> GetPublisher(string? name = null, string? id = null,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
if (string.IsNullOrEmpty(name) && string.IsNullOrEmpty(id))
|
||||
throw new ArgumentException("Either name or id must be provided.");
|
||||
if (!string.IsNullOrEmpty(name) && !string.IsNullOrEmpty(id))
|
||||
throw new ArgumentException("Only one of name or id can be provided.");
|
||||
|
||||
var request = new GetPublisherRequest();
|
||||
if (!string.IsNullOrEmpty(name))
|
||||
request.Name = name;
|
||||
else
|
||||
request.Id = id;
|
||||
|
||||
var response = await publishers.GetPublisherAsync(request, cancellationToken: cancellationToken);
|
||||
return SnPublisher.FromProtoValue(response.Publisher);
|
||||
}
|
||||
|
||||
public async Task<List<SnPublisher>> GetPublishersBatch(List<string> ids,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
var request = new GetPublisherBatchRequest();
|
||||
request.Ids.AddRange(ids);
|
||||
var response = await publishers.GetPublisherBatchAsync(request, cancellationToken: cancellationToken);
|
||||
return response.Publishers.Select(SnPublisher.FromProtoValue).ToList();
|
||||
}
|
||||
|
||||
public async Task<List<SnPublisher>> ListPublishers(string? accountId = null, string? realmId = null,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
var request = new ListPublishersRequest
|
||||
{
|
||||
AccountId = accountId ?? "",
|
||||
RealmId = realmId ?? ""
|
||||
};
|
||||
var response = await publishers.ListPublishersAsync(request, cancellationToken: cancellationToken);
|
||||
return response.Publishers.Select(SnPublisher.FromProtoValue).ToList();
|
||||
}
|
||||
|
||||
public async Task<List<SnPublisherMember>> ListPublisherMembers(string publisherId,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
var request = new ListPublisherMembersRequest { PublisherId = publisherId };
|
||||
var response = await publishers.ListPublisherMembersAsync(request, cancellationToken: cancellationToken);
|
||||
return response.Members.Select(SnPublisherMember.FromProtoValue).ToList();
|
||||
}
|
||||
|
||||
public async Task<string?> SetPublisherFeatureFlag(string publisherId, string flag,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
var request = new SetPublisherFeatureFlagRequest
|
||||
{
|
||||
PublisherId = publisherId,
|
||||
Flag = flag
|
||||
};
|
||||
var response = await publishers.SetPublisherFeatureFlagAsync(request, cancellationToken: cancellationToken);
|
||||
return response.Value;
|
||||
}
|
||||
|
||||
public async Task<bool> HasPublisherFeature(string publisherId, string flag,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
var request = new HasPublisherFeatureRequest
|
||||
{
|
||||
PublisherId = publisherId,
|
||||
Flag = flag
|
||||
};
|
||||
var response = await publishers.HasPublisherFeatureAsync(request, cancellationToken: cancellationToken);
|
||||
return response.Enabled;
|
||||
}
|
||||
|
||||
public async Task<bool> IsPublisherMember(string publisherId, string accountId,
|
||||
Proto.PublisherMemberRole? role = null, CancellationToken cancellationToken = default)
|
||||
{
|
||||
var request = new IsPublisherMemberRequest
|
||||
{
|
||||
PublisherId = publisherId,
|
||||
AccountId = accountId,
|
||||
};
|
||||
if (role.HasValue) request.Role = role.Value;
|
||||
var response = await publishers.IsPublisherMemberAsync(request, cancellationToken: cancellationToken);
|
||||
return response.Valid;
|
||||
}
|
||||
|
||||
public async Task<List<SnPublisher>> GetUserPublishers(Guid accountId,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
return await ListPublishers(accountId: accountId.ToString(), realmId: null, cancellationToken);
|
||||
}
|
||||
|
||||
public async Task<bool> IsMemberWithRole(Guid publisherId, Guid accountId, Models.PublisherMemberRole role,
|
||||
CancellationToken cancellationToken = default)
|
||||
{
|
||||
var protoRole = role switch
|
||||
{
|
||||
Models.PublisherMemberRole.Owner => Proto.PublisherMemberRole.Owner,
|
||||
Models.PublisherMemberRole.Manager => Proto.PublisherMemberRole.Manager,
|
||||
Models.PublisherMemberRole.Editor => Proto.PublisherMemberRole.Editor,
|
||||
Models.PublisherMemberRole.Viewer => Proto.PublisherMemberRole.Viewer,
|
||||
_ => Proto.PublisherMemberRole.Unspecified
|
||||
};
|
||||
return await IsPublisherMember(publisherId.ToString(), accountId.ToString(), protoRole, cancellationToken);
|
||||
}
|
||||
}
|
||||
@@ -116,6 +116,7 @@ public static class ServiceInjectionHelper
|
||||
.ConfigurePrimaryHttpMessageHandler(_ => new HttpClientHandler()
|
||||
{ ServerCertificateCustomValidationCallback = (_, _, _, _) => true }
|
||||
);
|
||||
services.AddSingleton<RemotePublisherService>();
|
||||
|
||||
return services;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user