FCC/Devices/Terminals/GilbarcoDispenserIntegratedTerminal/MessageTemplateLookup.cs

using Edge.Core.Parser.BinaryParser;
using Edge.Core.Parser.BinaryParser.MessageEntity;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace Dfs.WayneChina.GilbarcoDispenserPayTerminal
{
    public class MessageTemplateLookup : IMessageTemplateLookup
    {
        /// <summary>
        /// Gets the default singleton instance of type MessageTemplateLookup.
        /// </summary>
        public static MessageTemplateLookup Default { get; } = new MessageTemplateLookup();

        /// <summary>
        /// Dictionary that holds the commands and types
        /// </summary>
        private static readonly Dictionary<string, string> messageCodeToTypeStrDict = new Dictionary<string, string>();

        static MessageTemplateLookup()
        {
            //Regular check - Info
            messageCodeToTypeStrDict.Add("0x31",
                "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.InfoCommand, Dfs.WayneChina.GilbarcoDispenserPayTerminal");

            //Transaction data
            messageCodeToTypeStrDict.Add("0x32",
                "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.TransactionData, Dfs.WayneChina.GilbarcoDispenserPayTerminal");

            //Data download
            messageCodeToTypeStrDict.Add("0x33",
                "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.DataDownload, Dfs.WayneChina.GilbarcoDispenserPayTerminal");
            
            //Content downnload
            messageCodeToTypeStrDict.Add("0x34",
                "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.ContentDownload, Dfs.WayneChina.GilbarcoDispenserPayTerminal");

            //Ungray
            messageCodeToTypeStrDict.Add("0x35",
                "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.Ungray, Dfs.WayneChina.GilbarcoDispenserPayTerminal");
            
            //messageCodeToTypeStrDict.Add("0x36",
            //    "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.ContentDownload, Dfs.WayneChina.GilbarcoDispenserPayTerminal");

            //Volume totalizer
            messageCodeToTypeStrDict.Add("0x38",
                "Dfs.WayneChina.GilbarcoDispenserPayTerminal.MessageEntities.Incoming.VolumeTotalizer, Dfs.WayneChina.GilbarcoDispenserPayTerminal");
        }

        public MessageTemplateBase GetMessageTemplateByRawBytes(byte[] bytes)
        {
            var msgHandleCode = bytes.Skip(6).First();

            var key = "0x" + msgHandleCode.ToString("X").PadLeft(2, '0');
            if (messageCodeToTypeStrDict.ContainsKey(key))
            {
                var found = messageCodeToTypeStrDict[key];
                var targetType = Type.GetType(found);
                var targetInstance = (MessageTemplateBase)Activator.CreateInstance(targetType);
                return targetInstance;
            }
            else
            {
                throw new ArgumentException("Can't find correlated message entity type for incoming raw message bytes: " +
                    bytes.Select(s => s.ToString("X").PadLeft(2, '0')).Aggregate((n, acc) => n + " " + acc));
            }
        }
    }
}