DSInternals/Src/DSInternals.Replication.Model/ReplicatedLinkedValueCollection.cs

using System;
using System.Collections.Generic;
using System.Linq;

namespace DSInternals.Replication.Model
{
    public class ReplicatedLinkedValueCollection : Dictionary<Guid, List<ReplicaAttribute>>
    {
        // TODO: Move parent as member.
        public ReplicatedLinkedValueCollection() : base()
        {
        }

        public void Add(Guid objectId, ReplicaAttribute attribute)
        {
            if (this.ContainsKey(objectId))
            {
                this[objectId].Add(attribute);
            }
            else
            {
                var attributeList = new List<ReplicaAttribute>();
                attributeList.Add(attribute);
                this.Add(objectId, attributeList);
            }
        }

        public IEnumerable<ReplicaAttribute> Get(Guid objectId)
        {
            List<ReplicaAttribute> attributes;
            bool objectFound = this.TryGetValue(objectId, out attributes);
            if(!objectFound)
            {
                // The linked value collection does not contain any attributes of object objectId.
                return null;
            }

            // Combine multiple Id => byte[] into single Id => byte[][] 
            var consolidatedAttributes = attributes.
                GroupBy(attribute => attribute.Id).
                Select(grouppedAttribute =>
                {
                    byte[][] consolidatedValue = grouppedAttribute.SelectMany(attribute => attribute.Values).ToArray();
                    return new ReplicaAttribute(grouppedAttribute.Key, consolidatedValue);
                });

            return consolidatedAttributes;
        }
    }
}