support more events

Author: kerryjiang

src/SciSharp.MySQL.Replication/Events/DefaultEventFactory.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Buffers;
+
+namespace SciSharp.MySQL.Replication
+{
+
+    class DefaultEventFactory<TEventType> : ILogEventFactory
+        where TEventType : LogEvent, new()
+    {
+        public LogEvent Create()
+        {
+            return new TEventType();
+        }
+    }
+}

src/SciSharp.MySQL.Replication/Events/EmptyPayloadEvent.cs

@@ -5,29 +5,9 @@ namespace SciSharp.MySQL.Replication
 {
     public sealed class EmptyPayloadEvent : LogEvent
     {
-        public EmptyPayloadEvent(LogEventType eventType)
-        {
-            EventType = eventType;
-        }
-
         protected internal override void DecodeBody(ref SequenceReader<byte> reader)
         {
-
-        }
-    }
-
-    class EmptyPayloadEventFactory : ILogEventFactory
-    {
-        public LogEventType EventType { get; private set; }
-
-        public EmptyPayloadEventFactory(LogEventType eventType)
-        {
-            EventType = eventType;
-        }
-
-        public LogEvent Create()
-        {
-            return new EmptyPayloadEvent(EventType);
+            
         }
     }
 }

src/SciSharp.MySQL.Replication/Events/NotImplementedEvent.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Buffers;
+
+namespace SciSharp.MySQL.Replication
+{
+    public sealed class NotImplementedEvent : LogEvent
+    {
+        protected internal override void DecodeBody(ref SequenceReader<byte> reader)
+        {
+
+        }
+    }
+}

src/SciSharp.MySQL.Replication/Events/XIDEvent.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Buffers;
+using System.Text;
+using SuperSocket.ProtoBase;
+
+namespace SciSharp.MySQL.Replication
+{
+    public sealed class XIDEvent : LogEvent
+    {
+        public long TransactionID { get; set; }
+        
+        protected internal override void DecodeBody(ref SequenceReader<byte> reader)
+        {
+            reader.TryReadLittleEndian(out long tarnsID);
+            TransactionID = tarnsID;
+        }
+    }
+}

src/SciSharp.MySQL.Replication/LogEvent.cs

@@ -7,7 +7,7 @@ public abstract class LogEvent
     {
         public static ChecksumType ChecksumType { get; internal set; }        
         public DateTime Timestamp { get; set; }
-        public LogEventType EventType { get; set; }
+        public LogEventType EventType { get; internal set; }
         public int ServerID { get; set; }
         public int EventSize { get; set; }
         public int Position { get; set; }

src/SciSharp.MySQL.Replication/LogEventPackageDecoder.cs

@@ -11,14 +11,6 @@ namespace SciSharp.MySQL.Replication
     */
     class LogEventPackageDecoder : IPackageDecoder<LogEvent>
     {
-        class DefaultLogEventFactory<TLogEvent> : ILogEventFactory
-            where TLogEvent : LogEvent, new()
-        {
-            public LogEvent Create()
-            {
-                return new TLogEvent();
-            }
-        }
 
         private static readonly DateTime _unixEpoch = new DateTime(1970, 1, 1);
 
@@ -28,11 +20,11 @@ internal static DateTime GetTimestapmFromUnixEpoch(int seconds)
         }
 
         private static Dictionary<LogEventType, ILogEventFactory> _logEventFactories = new Dictionary<LogEventType, ILogEventFactory>();
-
+        private static ILogEventFactory _notImplementedEventFactory = new DefaultEventFactory<NotImplementedEvent>();
         internal static void RegisterLogEventType<TLogEvent>(LogEventType eventType)
             where TLogEvent : LogEvent, new()
         {
-            RegisterLogEventType(eventType, new DefaultLogEventFactory<TLogEvent>());
+            RegisterLogEventType(eventType, new DefaultEventFactory<TLogEvent>());
         }
 
         internal static void RegisterLogEventType(LogEventType eventType, ILogEventFactory factory)
@@ -44,16 +36,18 @@ internal static void RegisterEmptyPayloadEventTypes(params LogEventType[] eventT
         {
             foreach (var eventType in eventTypes)
             {
-                _logEventFactories.Add(eventType, new EmptyPayloadEventFactory(eventType));
+                _logEventFactories.Add(eventType, new DefaultEventFactory<EmptyPayloadEvent>());
             }
         }
 
         protected virtual LogEvent CreateLogEvent(LogEventType eventType)
         {
             if (!_logEventFactories.TryGetValue(eventType, out var factory))
-                throw new Exception("Unexpected eventType: " + eventType);
+                factory = _notImplementedEventFactory;
 
-            return factory.Create();
+            var log = factory.Create();
+            log.EventType = eventType;
+            return log;
         }
 
         public LogEvent Decode(ReadOnlySequence<byte> buffer)