Shiloh/brotherton-erpnext
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[fix] hub connection, fixes #11357

Browse Source
This commit is contained in:
Prateeksha Singh 2017-12-11 23:22:30 +05:30
parent 3ca00c7143
commit 1126a43979
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
erpnext/hub_node/__init__.py
View File

@ -16,7 +16,7 @@ def enable_hub():
@frappe.whitelist() @frappe.whitelist()
def get_items(start=0, limit=20, category=None, order_by=None, company=None, text=None): def get_items(start=0, limit=20, category=None, order_by=None, company=None, text=None):
connection = get_connection() connection = get_client_connection()
filters = { filters = {
'hub_category': category, 'hub_category': category,
} }
@ -32,7 +32,7 @@ def get_items(start=0, limit=20, category=None, order_by=None, company=None, tex
@frappe.whitelist() @frappe.whitelist()
def get_categories(): def get_categories():
connection = get_connection() connection = get_client_connection()
response = connection.get_list('Hub Category') response = connection.get_list('Hub Category')
return response return response
@ -40,20 +40,24 @@ def get_categories():
def get_item_details(hub_sync_id=None): def get_item_details(hub_sync_id=None):
if not hub_sync_id: if not hub_sync_id:
return return
connection = get_connection() connection = get_client_connection()
return connection.get_doc('Hub Item', hub_sync_id) return connection.get_doc('Hub Item', hub_sync_id)
@frappe.whitelist() @frappe.whitelist()
def get_company_details(hub_sync_id): def get_company_details(hub_sync_id):
connection = get_connection() connection = get_client_connection()
return connection.get_doc('Hub Company', hub_sync_id) 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( hub_connector = frappe.get_doc(
'Data Migration Connector', 'Hub Connector') 'Data Migration Connector', 'Hub Connector')
hub_connection = hub_connector.get_connection() hub_connection = hub_connector.get_connection()
# frappeclient connection return hub_connection
return hub_connection.connection
def make_opportunity(buyer_name, email_id): def make_opportunity(buyer_name, email_id):
buyer_name = "HUB-" + buyer_name buyer_name = "HUB-" + buyer_name
@ -174,7 +178,7 @@ def send_opportunity(contact):
user=contact.email_id user=contact.email_id
)) ))
connection = get_connection() connection = get_hub_connection()
response = connection.insert('Hub Message', args) response = connection.insert('Hub Message', args)
return response.ok return response.ok