TEAMModelOS/TEAMModelOS.Service/Services/ChangeFeed/KnowledgeChangeFeed.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using TEAMModelOS.SDK.Helper.Common.JsonHelper;
using TEAMModelOS.SDK.Module.AzureCosmosDBV3;
using TEAMModelOS.Service.Models.Syllabus;

namespace TEAMModelOS.Service.Services.ChangeFeed
{
    public class KnowledgeChangeFeed : IChangeFeedService<Knowledge>, IChangeService
    {
        private IAzureCosmosDBV3Repository cosmosDBV3Repository;
        public KnowledgeChangeFeed(IAzureCosmosDBV3Repository azureCosmos) {
            cosmosDBV3Repository = azureCosmos;
        }
        public async  Task Processor(IReadOnlyCollection<Knowledge> changes)
        {
            //List<Knowledge> s = await cosmosDBV3Repository.FindAll<Knowledge>();
            Console.WriteLine(changes.ToApiJson());
        }
    }
}