diff --git a/erpnext/hub_node/__init__.py b/erpnext/hub_node/__init__.py
index 76a7f6f..8eb1074 100644
--- a/erpnext/hub_node/__init__.py
+++ b/erpnext/hub_node/__init__.py
@@ -16,7 +16,7 @@
 
 @frappe.whitelist()
 def get_items(start=0, limit=20, category=None, order_by=None, company=None, text=None):
-	connection = get_connection()
+	connection = get_client_connection()
 	filters = {
 		'hub_category': category,
 	}
@@ -32,7 +32,7 @@
 
 @frappe.whitelist()
 def get_categories():
-	connection = get_connection()
+	connection = get_client_connection()
 	response = connection.get_list('Hub Category')
 	return response
 
@@ -40,20 +40,24 @@
 def get_item_details(hub_sync_id=None):
 	if not hub_sync_id:
 		return
-	connection = get_connection()
+	connection = get_client_connection()
 	return connection.get_doc('Hub Item', hub_sync_id)
 
 @frappe.whitelist()
 def get_company_details(hub_sync_id):
-	connection = get_connection()
+	connection = get_client_connection()
 	return connection.get_doc('Hub Company', hub_sync_id)
 
-def get_connection():
+def get_client_connection():
+	# frappeclient connection
+	hub_connection = get_hub_connection()
+	return hub_connection.connection
+
+def get_hub_connection():
 	hub_connector = frappe.get_doc(
 		'Data Migration Connector', 'Hub Connector')
 	hub_connection = hub_connector.get_connection()
-	# frappeclient connection
-	return hub_connection.connection
+	return hub_connection
 
 def make_opportunity(buyer_name, email_id):
 	buyer_name = "HUB-" + buyer_name
@@ -174,7 +178,7 @@
 		user=contact.email_id
 	))
 
-	connection = get_connection()
+	connection = get_hub_connection()
 	response = connection.insert('Hub Message', args)
 
 	return response.ok