ChannelRepository.cs

using Perpetuum.Data;
using System.Collections.Generic;
using System.Linq;

namespace Perpetuum.Services.Channels
{
    public class ChannelRepository : IChannelRepository
    {
        private readonly ChannelLoggerFactory _channelLoggerFactory;

        public ChannelRepository(ChannelLoggerFactory channelLoggerFactory)
        {
            _channelLoggerFactory = channelLoggerFactory;
        }

        public Channel Insert(Channel channel)
        {
            const string cmd = "insert into channels (name,type) values (@name,@type);select id from channels where id = scope_identity()";

            int id = Db.Query().CommandText(cmd)
                .SetParameter("@name", channel.Name)
                .SetParameter("@type", (int)channel.Type)
                .ExecuteScalar<int>().ThrowIfEqual(0, ErrorCodes.SQLInsertError);

            return channel.SetId(id);
        }

        public void Delete(Channel channel)
        {
            Db.Query().CommandText("delete channels where id = @channelId")
                .SetParameter("@channelId", channel.Id)
                .ExecuteNonQuery().ThrowIfZero(ErrorCodes.SQLDeleteError);
        }

        public void Update(Channel channel)
        {
            Db.Query().CommandText("update channels set topic = @topic, password = @password, type=@type where id = @channelid")
                .SetParameter("@topic", channel.Topic)
                .SetParameter("@password", channel.Password)
                .SetParameter("@type", channel.Type)
                .SetParameter("@channelid", channel.Id)
                .ExecuteNonQuery().ThrowIfEqual(0, ErrorCodes.SQLUpdateError);
        }

        public IEnumerable<Channel> GetAll()
        {
            return Db.Query().CommandText("select * from channels").Execute().Select(record =>
            {
                int id = record.GetValue<int>("id");
                ChannelType type = (ChannelType)record.GetValue<int>("type");
                string name = record.GetValue<string>("name");
                string topic = record.GetValue<string>("topic");
                string password = record.GetValue<string>("password");
                bool isForcedJoin = record.GetValueOrDefault<bool>("isForcedJoin");
                string discordIdString = record.GetValueOrDefault<string>("DiscordId");
                ulong? discordId = ulong.TryParse(discordIdString, out ulong parsedId)
                    ? parsedId
                    : (ulong?)null;

                IChannelLogger logger = _channelLoggerFactory(name);

                return new Channel(id, type, name, topic, password, isForcedJoin, discordId, logger);
            }).ToArray();
        }
    }
}