crgcode / neviles Goto Github PK

    public class ProjectionStoreInformation
    {
        public ProjectionStoreInformation(string name, IEnumerable<Type> eventsProjected)
        {
            Name = name;
            EventsProjected = eventsProjected;
        }

        public string Name { get; }
        public IEnumerable<Type> EventsProjected { get; }
    }


    public interface IProjectionEngine
    {
        Task<bool> Setup();
        Task Catchup();
    }

    public interface IReadEventStore
    {
        IEnumerable<IEventRow> Read(long from = 0, long to = 0);
        IEnumerable<IEventRow> Read(Guid streamId);
        IEnumerable<IEventRow> ReadNewestLimit(Guid streamId, int limit = 50);
    }

    public interface IProjectorLookupStrategy
    {
        IEnumerable<Type> GetRegisteredProjectors();
    }


    public class ProjectionEngine : IProjectionEngine
    {
        // db connection
        // info about projection store
        // eventstream replayer
        // IProjectorLookupStrategy



        private readonly ProjectionStoreInformation _storeInformation;

        public ProjectionEngine(
            ProjectionStoreInformation storeInformation,
            IDbTransaction transaction,
            IReadEventStore eventStoreReader,
            IProjectorLookupStrategy projectorLookupStrategy,
            IFactory factory
            )
        {
            this._storeInformation = storeInformation;
        }

        public Task<bool> Setup()
        {
            // Create Schema
            // cmd.Command = $"CREATE SCHEMA IF NOT EXISTS '{_storeInformation.Name}';
            // Create position table
            //cmd.Command = "CREATE TABLE IF NOT EXISTS \"_position\" (id TEXT PRIMARY KEY, position BIGINT)"
            // Create table for handled/projected events not sure if we really need this
            //cmd.Command = "CREATE TABLE IF NOT EXISTS \"_handled_events\" (event_type TEXT))"
            // insert only only row to position
            //cmd.Command = $"INSERT INTO \"_position\" VALUES ('{_storeInformation.Name}', 0) ON CONFLICT DO NOTHING"

            throw new System.NotImplementedException();
        }


        public Task Catchup()
        {

            // get position

            // read from position next 1000 using eventStoreReader using only events we care about _storeInformation.EventsProjected

            // project loop with commit per position 

            // commit

            throw new System.NotImplementedException();
        }
    }