From 3f25aa0f1b4dec36aa77aa8027ff83f175e96f98 Mon Sep 17 00:00:00 2001
From: Casper Warden <216465704+casperwardensl@users.noreply.github.com>
Date: Sun, 26 Nov 2017 03:10:54 +0000
Subject: [PATCH] InstantMessage helper function, fix issue with failing to use
 the returned buffer

---
 example/testBot.js     |  5 ++++-
 lib/classes/Circuit.ts | 42 ++++++++++++++++++++++++++++++++++++++++--
 2 files changed, 44 insertions(+), 3 deletions(-)

diff --git a/example/testBot.js b/example/testBot.js
index 7d8c733..0ab983d 100644
--- a/example/testBot.js
+++ b/example/testBot.js
@@ -10,13 +10,16 @@ loginParameters.start = "last";
 
 const bot = new nmv.Bot(loginParameters);
 
+let resp = null;
+
 bot.Login().then((response) =>
 {
     //Establish circuit wit region
+    resp = response;
     return response.region.circuit.establish(response.agent.agentID);
 }).then(() =>
 {
-    console.log("Region circuit established");
+    resp.region.circuit.sendInstantMessage(resp.agent.agentID, "dbcd7dfe-a5db-4736-91bc-2af1e69902e6", "FUCK YOU");
 }).catch((error) =>
 {
     console.log("Error:");
diff --git a/lib/classes/Circuit.ts b/lib/classes/Circuit.ts
index 0816384..23b3cbc 100644
--- a/lib/classes/Circuit.ts
+++ b/lib/classes/Circuit.ts
@@ -13,6 +13,8 @@ import {CompleteAgentMovementMessage} from './messages/CompleteAgentMovement';
 import {Subscription} from 'rxjs/Subscription';
 import {Subject} from 'rxjs/Subject';
 import Timer = NodeJS.Timer;
+import {ImprovedInstantMessageMessage} from './messages/ImprovedInstantMessage';
+import {Vector3} from './Vector3';
 
 export class Circuit
 {
@@ -118,8 +120,8 @@ export class Circuit
                 };
         }
         let size = packet.getSize();
-        const dataToSend: Buffer = Buffer.allocUnsafe(size);
-        packet.writeToBuffer(dataToSend, 0);
+        let dataToSend: Buffer = Buffer.allocUnsafe(size);
+        dataToSend = packet.writeToBuffer(dataToSend, 0);
         if (this.client !== null)
         {
             this.client.send(dataToSend, 0, dataToSend.length, this.port, this.ipAddress, (err, bytes) =>
@@ -147,6 +149,42 @@ export class Circuit
         }
     }
 
+    sendInstantMessage(from: UUID | string, to: UUID | string, message: string)
+    {
+        if (typeof from === 'string')
+        {
+            from = new UUID(from);
+        }
+        if (typeof to === 'string')
+        {
+            to = new UUID(to);
+        }
+        message += '\0';
+        const im: ImprovedInstantMessageMessage = new ImprovedInstantMessageMessage();
+        im.AgentData = {
+            AgentID: from,
+            SessionID: this.sessionID
+        };
+        im.MessageBlock = {
+            FromGroup: false,
+            ToAgentID: to,
+            ParentEstateID: 0,
+            RegionID: UUID.zero(),
+            Position: Vector3.getZero(),
+            Offline: 0,
+            Dialog: 0,
+            ID: UUID.zero(),
+            Timestamp: 0,
+            FromAgentName: 'Yo Momma',
+            Message: message,
+            BinaryBucket: ''
+        };
+        im.EstateBlock = {
+            EstateID: 0
+        };
+        this.sendMessage(im, PacketFlags.Reliable);
+    }
+
     sendAck(sequenceID: number)
     {
         const msg: PacketAckMessage = new PacketAckMessage();