aurora/aurora-sharp-desktop/Aurora/Services/Controllers/MemberController.cs

using System;
using System.Threading.Tasks;
using System.Collections.Generic;
using Aurora.Proto.Party;
using Aurora.Proto.General;
using Aurora.Utils;
using Grpc.Core;
using Google.Protobuf.WellKnownTypes;
using Aurora.Cursor;

namespace Aurora.Services.Controllers
{
    public partial class RemotePartyController : RemotePartyService.RemotePartyServiceBase
    {
        private CursorList<Member> _memberList;

        public CursorList<Member> MemberList
        {
            get 
            {
                return this._memberList;
            }
            set 
            {
                if(this._memberList != value)
                {
                    _memberList = value;
                }
            }
        }

        public override Task<ListMembersResponse> ListMembers(ListMembersRequest request, Grpc.Core.ServerCallContext context)
        {
            Cursor<Member> cursor = new Cursor<Member>(ref this._memberList);

            Aurora.Cursor.SortDirection direction = Aurora.Cursor.SortDirection.Asc;

            CursorResult<Member> res = cursor
                .WithNextPageToken(request.PageToken)
                .WithSize(request.PageSize)
                .GetNextPage();

            //Ignoring parent field because there is only one instance of the party
            ListMembersResponse resp = new ListMembersResponse();

            resp.Members.AddRange(res.Result.ConvertAll(member => new Member()
            {
                Name = member.Name,
                UserName = member.UserName,
                IpAddress = member.IpAddress,
                AddedOn = member.AddedOn
            }));

            return Task.FromResult(resp);
        }

        public override Task<Member> GetMember(GetMemberRequest request, Grpc.Core.ServerCallContext context)
        {
            _memberList.TryGetValue(request.Name, out Member member);

            if (member == null)
            {
                throw new KeyNotFoundException();
            }

            return Task.FromResult(member);
        }

        public override Task<Member> UpdateMember(UpdateMemberRequest request, Grpc.Core.ServerCallContext context)
        {
            throw new NotImplementedException();
        }

        public override Task<Member> CreateMember(CreateMemberRequest request, Grpc.Core.ServerCallContext context)
        {
            //Generate Guid
            string resourceName = GetNewMemberResourceName(request.Parent, context.Peer, request.Member.UserName);

            //Check if already added
            if (_memberList.ContainsKey(resourceName))
            {
                throw new RpcException(new Status(StatusCode.AlreadyExists, "Member already exists"));
            }

            request.Member.Name = resourceName;
            request.Member.AddedOn = Timestamp.FromDateTime(DateTime.UtcNow);
            request.Member.IpAddress = context.Host;

            _memberList.Add(request.Member);

            BaseEvent @event = new BaseEvent
            {
                EventType = EventType.MemberCreated,
                MemberCreatedEvent = new MemberCreatedEvent
                {
                    Member = request.Member,
                }
            };

            //Fire event manager event
            this._eventManager.FireEvent(@event);

            return Task.FromResult(request.Member);
        }

        public override Task<Aurora.Proto.General.Empty> DeleteMember(DeleteMemberRequest request, Grpc.Core.ServerCallContext context)
        {
            string memberResourceName = request.Name;
            //Check if member exists
            if (!_memberList.ContainsKey(request.Name))
            {
                throw new RpcException(new Status(StatusCode.NotFound, "Member not found"));
            }

            _memberList.Remove(memberResourceName);

            BaseEvent @event = new BaseEvent
            {
                EventType = EventType.MemberDeleted,
                MemberDeletedEvent = new MemberDeletedEvent
                {
                    MemberName = memberResourceName,
                }
            };

            _eventManager.FireEvent(@event);
            _eventManager.RemoveAllSubscriptions(memberResourceName);
            _eventManager.CancelEventStream(memberResourceName);

            return Task.FromResult(new Aurora.Proto.General.Empty());
        }

        private string GetNewMemberResourceName(string parent, string contextPeer, string userName)
        {
            string memberNameGuid = HashUtil.GetHash(new string[] { contextPeer, userName }).ToString();
            return string.Format("{0}/members/{1}", parent, memberNameGuid);
        }
    }
}