diff --git a/APIConnection.js b/APIConnection.js
new file mode 100644
index 0000000..371bc49
--- /dev/null
+++ b/APIConnection.js
@@ -0,0 +1,153 @@
+'use strict';
+const events = require('events');
+const Parser = require('../utils/line-parser');
+const Peer = require('./Peer');
+
+class APIConnection extends events.EventEmitter {
+	constructor(socket) {
+		super();
+		this.socket = socket;
+		this.lineParser = new Parser(this);
+		this._registerEvents();
+		this.open = true;
+		this._cb_receiver = null;
+	}
+	
+	sendTyping(peer_id) {
+		this._executeCommand('send_typing', peer_id);
+	}
+	
+	userInfo(peer_id) {
+		return new Promise((resolve, reject) => {
+			this._executeCommand('user_info', peer_id);
+			this._cb_receiver = data => {
+				resolve(new Peer(this, data));
+			};
+		});
+	}
+	
+	forward(peer, msg_id) {
+		this._executeCommand('fwd', peer, msg_id);
+	}
+	
+	add_contact(phnom,fname,lname) {
+		return new Promise((resolve, reject) => {
+			this._executeCommand('add_contact',phnom,fname,lname);
+			this._cb_receiver = data => {
+				if (data.hasOwnProperty("result") | !data ) if(data.result == "FALSE") reject(data) ;
+				else resolve(data);
+			};
+		});
+	}
+
+	del_contact(username) {
+		return new Promise((resolve, reject) => {
+			this._executeCommand('del_contact',username);
+			this._cb_receiver = data => {
+				if(data.result == "SUCCESS") resolve(data); 
+				else reject(data);
+			};
+		});
+	}
+
+	contact_search(user) {
+		return new Promise((resolve, reject) => {
+			this._executeCommand('contact_search',user);
+			this._cb_receiver = data => {
+				if(data.result == "SUCCESS") resolve(data); 
+				else reject(data);
+			};
+		});
+	}
+
+
+
+	contactList() {
+		return new Promise((resolve, reject) => {
+			this._executeCommand('contact_list');
+			this._cb_receiver = data => {
+				const contactArr = [];
+				for (let i = 0; i < data.length; ++i) {
+					contactArr.push(new Peer(this, data[i]));
+				}
+				resolve(contactArr);
+			};
+		});
+	}
+	
+	dialogList() {
+		return new Promise((resolve, reject) => {
+			this._executeCommand('dialog_list');
+			this._cb_receiver = data => {
+				const dialogArr = [];
+				for (let i = 0; i < data.length; ++i) {
+					dialogArr.push(new Peer(this, data[i]));
+				}
+				resolve(dialogArr);
+			};
+		});
+	}
+	
+	send(peer, message) {
+		this._executeCommand('msg', peer, `"${message}"`);
+	}
+	
+	reply(id, message) {
+		this._executeCommand('reply', id, `"${message}"`);
+	}
+	
+	deleteMsg(id) {
+		this._executeCommand('delete_msg', id);
+	}
+	
+	sendImage(peer, path) {
+		this._executeCommand('send_photo', peer, '"' + path + '"');
+	}
+	
+	sendDocument(peer, path) {
+		this._executeCommand('send_document', peer, '"' + path + '"');
+	}
+	
+	_executeCommand() {
+    if(this.open){
+      var args = Array.prototype.slice.call(arguments);
+      var cmd = args.join(' ');
+      console.log('executing command:', cmd);
+      this.socket.writeLine(cmd);
+    }else{
+      throw new Error('Api connection closed');
+    }
+	}
+	
+	close() {
+		if(this.open){
+      this.open = false;
+      this.socket.end();
+    }
+	}
+	
+	_registerEvents() {
+		this.socket.on('line', line => {
+			const parsedLine = this.lineParser.parse(line);
+			if (parsedLine) {
+				if (parsedLine.type === 'callback' && this._cb_receiver !== null) {
+					this._cb_receiver(parsedLine.data);
+					this._cb_receiver = null;
+				} else {
+					this.emit(parsedLine.type, parsedLine.data);
+				}
+			}
+		});
+
+		this.socket.on('error', e => {
+			this.emit('error', e);
+		});
+
+		this.socket.on('close', () => {
+			this.emit('disconnect');
+		});
+	};
+}
+
+
+module.exports = APIConnection;
\ No newline at end of file
diff --git a/example.js b/example.js
index 61e337f..c7362ba 100644
--- a/example.js
+++ b/example.js
@@ -1,18 +1,21 @@
-const TelegramAPI = require('./lib/telegram-api.js');
-const config = require('./config');
-
-const Client = new TelegramAPI(config);
-
-Client.connect(connection => {
-    connection.on('message', message => {
-        console.log('message:', message);
-    });
-
-    connection.on('error', e => {
-        console.log('Error from Telegram API:', e);
-    });
-
-    connection.on('disconnect', () => {
-        console.log('Disconnected from Telegram API');
-    });
-});
\ No newline at end of file
+const TelegramAPI = require('./lib/telegram-api.js');
+const config = require('./config.js');
+
+const Client = new TelegramAPI(config);
+// console.log('conf',config);
+Client.connect(connection => {
+    connection.on('message', message => {
+        console.log('message:', message);
+    });
+
+    connection.on('error', e => {
+        console.log('Error from Telegram API:', e);
+    });
+
+    connection.on('disconnect', () => {
+        console.log('Disconnected from Telegram API');
+    });
+    connection.add_contact('+989123456789','sad',' ').then((xx)=>{
+        console.log('xxxxxxxx',xx);
+    });
+});