Added heartbeat parser and definitions

Author: Rentacookie

lib/binlog_event.js

@@ -28,6 +28,20 @@ BinlogEvent.prototype._readTableId = function (parser) {
   this.tableId = Common.parseUInt48(parser);
 };
 
+function Heartbeat(parser) {
+  BinlogEvent.apply(this, arguments);
+  this.binlogName = parser.parseString(this.size - 8);
+  this.position = Common.parseUInt64(parser);
+}
+util.inherits(Heartbeat, BinlogEvent);
+
+Heartbeat.prototype.dump = function () {
+  console.log('=== %s ===', this.getTypeName());
+  console.log('Event size: %d', this.size);
+  console.log('Position: %d', this.position);
+  console.log('Current binlog file: %s', this.binlogName);
+};
+
 /* Change MySQL bin log file
  * Attributes:
  *   position: Position inside next binlog
@@ -303,6 +317,7 @@ function Unknown() {
 util.inherits(Unknown, BinlogEvent);
 
 exports.BinlogEvent = BinlogEvent;
+exports.Heartbeat = Heartbeat;
 exports.Rotate = Rotate;
 exports.Format = Format;
 exports.Query = Query;

lib/code_map.js

@@ -48,6 +48,7 @@ const EventClass = {
   FORMAT_DESCRIPTION_EVENT: events.Format,
   XID_EVENT: events.Xid,
   GTID_LOG_EVENT: events.GtidLog,
+  HEARTBEAT_LOG_EVENT: events.Heartbeat,
 
   TABLE_MAP_EVENT: events.TableMap,
   DELETE_ROWS_EVENT_V1: rowsEvents.DeleteRows,

types/index.d.ts

@@ -106,6 +106,11 @@ export type BaseBinLogEvent = {
   useChecksum: boolean;
 };
 
+export type BinLogHeartbeatEvent = {
+  binlogName: string;
+  position: number;
+};
+
 export type BinLogRotationEvent = BaseBinLogEvent & {
   binlogName: string;
   position: number;
@@ -165,6 +170,7 @@ export type BinLogQueryEvent = BaseBinLogEvent & {
 
 export type BinLogEvent =
   | BinLogRotationEvent
+  | BinLogHeartbeatEvent
   | BinLogGTIDLogEvent
   | BinLogXidEvent
   | BinLogRowEvent