[fix] hub connection, fixes #11357
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