From 46f3b577512a4a1602dbf6e8edbbaf34314873aa Mon Sep 17 00:00:00 2001
From: AJ ONeal <awesome@coolaj86.com>
Date: Thu, 29 Sep 2016 23:41:42 -0400
Subject: [PATCH] add type info

---
 index.js | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/index.js b/index.js
index c834e5b..793ed40 100644
--- a/index.js
+++ b/index.js
@@ -157,11 +157,22 @@ module.exports.create = function (opts) {
 
 };
 
-module.exports.pack = function (address, data) {
+module.exports.pack = function (address, data, type) {
+  if (type || (data.byteLength <= '|__ERROR__|'.length)) {
+    if ('error' === type || '|__ERROR__|' === data.toString()) {
+      address.type = 'error';
+      address.service = 'error';
+    }
+    else if ('end' === type || '|__END__|' === data.toString()) {
+      address.type = 'end';
+      address.service = 'end';
+    }
+  }
+
   var version = 1;
   var header = Buffer.from([
     /*servername,*/ address.family, address.address, address.port, data.byteLength
-  , (address.service || '')
+  , (address.type || address.service || '')
   ].join(','));
   var meta = Buffer.from([ 255 - version, header.length ]);
   var buf = Buffer.alloc(meta.byteLength + header.byteLength + data.byteLength);