using DataStoring.Contract;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;

namespace DataStoring.EfCore
{
    public class Repository<TEntity> : IRepository<TEntity> where TEntity : class
    {
        private readonly DPContext _db;

        public IQueryable<TEntity> Query => _db.Set<TEntity>();

        public Repository(DPContext db)
        {
            _db = db;
        }

        public void Delete(int id)
        {
            try
            {
                var entity = _db.Set<TEntity>().Find(id);
                if(entity == null)
                {
                    throw new Exception("Id not found");
                }
            }
            catch(Exception e)
            {
                throw new Exception(string.Format("Cant delete entity with id {0} # {1} " ,id,e.Message));
            }
        }

        public void Insert(TEntity entity)
        {
            _db.Set<TEntity>().Add(entity);
            _db.SaveChanges();
        }

        public void Update(TEntity entity)
        {
            _db.Entry(entity).State = EntityState.Modified;
            _db.SaveChanges();
        }

        public IQueryable<TEntity> Get(Expression<Func<TEntity, bool>> filter = null, Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBy = null, string includeProperties = "")
        {
            IQueryable<TEntity> query = _db.Set<TEntity>();
            if(filter != null)
                query = query.Where(filter);
            if(includeProperties != null) {
                foreach(var includeProperty in includeProperties.Split(
                    new char[] {','}, StringSplitOptions.RemoveEmptyEntries
                ))
                    query = query.Include(includeProperty);
            }

            if(orderBy != null) {
                return orderBy(query);
            }
            else {
                return query;
            }
        }
    }
}