Skip to content

W
wendelin
Commit cea8f5ca authored by Klaus Wölfel's avatar Klaus Wölfel Committed by Ivan Tyagov
Browse files
Options

add erp5_wendelin_relay bt 

@Tyagov @kirr Configuration is currently done through python script, this could be improved. In current design, if messages cannot be forwarded as fast as new messages come in, some messages will be skipped.

/reviewed-on nexedi/wendelin!22
parent c4664c9a
Pipeline #1480 skipped
Hide whitespace changes
Inline Side-by-side
Showing with 598 additions and 0 deletions
erp5_wendelin_relay/ExtensionTemplateItem/portal_components/erp5.extension.WendelinRelay.py 0 → 100644
View file @ cea8f5ca
# -*- coding: utf-8 -*-
"""
Wendelin extension code to forward data to another wendelin instance.
"""
import base64
import urllib
import urllib2
def IngestionPolicy_forward(self, reference, data_chunk):
configuration_dict = self.IngestionPolicy_getWendelinRelayConfigurationDict()
if not configuration_dict["wendelin_url"]:
return
data = urllib.urlencode({'data_chunk': data_chunk})
url = "%s/%s/ingest?reference=%s" %(configuration_dict["wendelin_url"],
self.getRelativeUrl(),
reference)
request = urllib2.Request(url, data)
base64string = base64.encodestring('%s:%s' % (
configuration_dict["username"],
configuration_dict["password"])).replace('\n', '')
request.add_header("Authorization", "Basic %s" % base64string)
urllib2.urlopen(request, timeout=configuration_dict["timeout"])
\ No newline at end of file
erp5_wendelin_relay/ExtensionTemplateItem/portal_components/erp5.extension.WendelinRelay.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="Extension Component" module="erp5.portal_type"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_recorded_property_dict</string> </key>
<value>
<persistent> <string encoding="base64">AAAAAAAAAAI=</string> </persistent>
</value>
</item>
<item>
<key> <string>default_reference</string> </key>
<value> <string>WendelinRelay</string> </value>
</item>
<item>
<key> <string>description</string> </key>
<value>
<none/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>erp5.extension.WendelinRelay</string> </value>
</item>
<item>
<key> <string>portal_type</string> </key>
<value> <string>Extension Component</string> </value>
</item>
<item>
<key> <string>sid</string> </key>
<value>
<none/>
</value>
</item>
<item>
<key> <string>text_content_error_message</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>text_content_warning_message</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>version</string> </key>
<value> <string>erp5</string> </value>
</item>
<item>
<key> <string>workflow_history</string> </key>
<value>
<persistent> <string encoding="base64">AAAAAAAAAAM=</string> </persistent>
</value>
</item>
</dictionary>
</pickle>
</record>
<record id="2" aka="AAAAAAAAAAI=">
<pickle>
<global name="PersistentMapping" module="Persistence.mapping"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>data</string> </key>
<value>
<dictionary/>
</value>
</item>
</dictionary>
</pickle>
</record>
<record id="3" aka="AAAAAAAAAAM=">
<pickle>
<global name="PersistentMapping" module="Persistence.mapping"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>data</string> </key>
<value>
<dictionary>
<item>
<key> <string>component_validation_workflow</string> </key>
<value>
<persistent> <string encoding="base64">AAAAAAAAAAQ=</string> </persistent>
</value>
</item>
</dictionary>
</value>
</item>
</dictionary>
</pickle>
</record>
<record id="4" aka="AAAAAAAAAAQ=">
<pickle>
<global name="WorkflowHistoryList" module="Products.ERP5Type.patches.WorkflowTool"/>
</pickle>
<pickle>
<tuple>
<none/>
<list>
<dictionary>
<item>
<key> <string>action</string> </key>
<value> <string>validate</string> </value>
</item>
<item>
<key> <string>validation_state</string> </key>
<value> <string>validated</string> </value>
</item>
</dictionary>
</list>
</tuple>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/PortalTypeWorkflowChainTemplateItem/workflow_chain_type.xml 0 → 100644
View file @ cea8f5ca
<workflow_chain>
<chain>
<type>Ingestion Policy</type>
<workflow>ingestion_policy_interaction_workflow</workflow>
</chain>
</workflow_chain>
\ No newline at end of file
erp5_wendelin_relay/SkinTemplateItem/portal_skins/erp5_wendelin_relay.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="Folder" module="OFS.Folder"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_objects</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>erp5_wendelin_relay</string> </value>
</item>
<item>
<key> <string>title</string> </key>
<value> <string></string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/SkinTemplateItem/portal_skins/erp5_wendelin_relay/IngestionPolicy_forward.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="ExternalMethod" module="Products.ExternalMethod.ExternalMethod"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_function</string> </key>
<value> <string>IngestionPolicy_forward</string> </value>
</item>
<item>
<key> <string>_module</string> </key>
<value> <string>WendelinRelay</string> </value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>IngestionPolicy_forward</string> </value>
</item>
<item>
<key> <string>title</string> </key>
<value> <string></string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/SkinTemplateItem/portal_skins/erp5_wendelin_relay/IngestionPolicy_getWendelinRelayConfigurationDict.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="PythonScript" module="Products.PythonScripts.PythonScript"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>Script_magic</string> </key>
<value> <int>3</int> </value>
</item>
<item>
<key> <string>_bind_names</string> </key>
<value>
<object>
<klass>
<global name="NameAssignments" module="Shared.DC.Scripts.Bindings"/>
</klass>
<tuple/>
<state>
<dictionary>
<item>
<key> <string>_asgns</string> </key>
<value>
<dictionary>
<item>
<key> <string>name_container</string> </key>
<value> <string>container</string> </value>
</item>
<item>
<key> <string>name_context</string> </key>
<value> <string>context</string> </value>
</item>
<item>
<key> <string>name_m_self</string> </key>
<value> <string>script</string> </value>
</item>
<item>
<key> <string>name_subpath</string> </key>
<value> <string>traverse_subpath</string> </value>
</item>
</dictionary>
</value>
</item>
</dictionary>
</state>
</object>
</value>
</item>
<item>
<key> <string>_params</string> </key>
<value> <string></string> </value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>IngestionPolicy_getWendelinRelayConfigurationDict</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="InteractionWorkflowDefinition" module="Products.ERP5.InteractionWorkflow"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_objects</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>creation_guard</string> </key>
<value>
<none/>
</value>
</item>
<item>
<key> <string>description</string> </key>
<value> <string>Ingestion Policy interaction workflow</string> </value>
</item>
<item>
<key> <string>groups</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>ingestion_policy_interaction_workflow</string> </value>
</item>
<item>
<key> <string>manager_bypass</string> </key>
<value> <int>0</int> </value>
</item>
<item>
<key> <string>title</string> </key>
<value> <string>Ingestion Policy interaction workflow</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/interactions.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="Interaction" module="Products.ERP5.Interaction"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_mapping</string> </key>
<value>
<dictionary/>
</value>
</item>
<item>
<key> <string>_objects</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>interactions</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/interactions/IngestionPolicy_forward.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="InteractionDefinition" module="Products.ERP5.Interaction"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>actbox_category</string> </key>
<value> <string>workflow</string> </value>
</item>
<item>
<key> <string>actbox_name</string> </key>
<value> <string></string> </value>
</item>
<item>
<key> <string>actbox_url</string> </key>
<value> <string></string> </value>
</item>
<item>
<key> <string>activate_script_name</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>after_script_name</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>before_commit_script_name</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>description</string> </key>
<value> <string></string> </value>
</item>
<item>
<key> <string>guard</string> </key>
<value>
<none/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>IngestionPolicy_forward</string> </value>
</item>
<item>
<key> <string>method_id</string> </key>
<value>
<list>
<string>ingest</string>
</list>
</value>
</item>
<item>
<key> <string>once_per_transaction</string> </key>
<value> <int>0</int> </value>
</item>
<item>
<key> <string>portal_type_filter</string> </key>
<value>
<none/>
</value>
</item>
<item>
<key> <string>portal_type_group_filter</string> </key>
<value>
<none/>
</value>
</item>
<item>
<key> <string>script_name</string> </key>
<value>
<list>
<string>IngestionPolicy_activateForward</string>
</list>
</value>
</item>
<item>
<key> <string>temporary_document_disallowed</string> </key>
<value> <int>1</int> </value>
</item>
<item>
<key> <string>title</string> </key>
<value> <string></string> </value>
</item>
<item>
<key> <string>trigger_type</string> </key>
<value> <int>2</int> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/scripts.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="Scripts" module="Products.DCWorkflow.Scripts"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_mapping</string> </key>
<value>
<dictionary/>
</value>
</item>
<item>
<key> <string>_objects</string> </key>
<value>
<tuple/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>scripts</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/scripts/IngestionPolicy_activateForward.py 0 → 100644
View file @ cea8f5ca
ingestion_policy = state_change['object']
reference = context.REQUEST.get('reference')
data_chunk = context.REQUEST.get('data_chunk')
ingestion_policy.activate(
serialization_tag="IngestionPolicy_forward_%s" %ingestion_policy.getUid()
).IngestionPolicy_forward(reference, data_chunk)
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/scripts/IngestionPolicy_activateForward.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="PythonScript" module="Products.PythonScripts.PythonScript"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>Script_magic</string> </key>
<value> <int>3</int> </value>
</item>
<item>
<key> <string>_bind_names</string> </key>
<value>
<object>
<klass>
<global name="NameAssignments" module="Shared.DC.Scripts.Bindings"/>
</klass>
<tuple/>
<state>
<dictionary>
<item>
<key> <string>_asgns</string> </key>
<value>
<dictionary>
<item>
<key> <string>name_container</string> </key>
<value> <string>container</string> </value>
</item>
<item>
<key> <string>name_context</string> </key>
<value> <string>context</string> </value>
</item>
<item>
<key> <string>name_m_self</string> </key>
<value> <string>script</string> </value>
</item>
<item>
<key> <string>name_subpath</string> </key>
<value> <string>traverse_subpath</string> </value>
</item>
</dictionary>
</value>
</item>
</dictionary>
</state>
</object>
</value>
</item>
<item>
<key> <string>_params</string> </key>
<value> <string>state_change</string> </value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>IngestionPolicy_activateForward</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/variables.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="Variables" module="Products.DCWorkflow.Variables"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_mapping</string> </key>
<value>
<dictionary/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>variables</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/WorkflowTemplateItem/portal_workflow/ingestion_policy_interaction_workflow/worklists.xml 0 → 100644
View file @ cea8f5ca
<?xml version="1.0"?>
<ZopeData>
<record id="1" aka="AAAAAAAAAAE=">
<pickle>
<global name="Worklists" module="Products.DCWorkflow.Worklists"/>
</pickle>
<pickle>
<dictionary>
<item>
<key> <string>_mapping</string> </key>
<value>
<dictionary/>
</value>
</item>
<item>
<key> <string>id</string> </key>
<value> <string>worklists</string> </value>
</item>
</dictionary>
</pickle>
</record>
</ZopeData>
erp5_wendelin_relay/bt/change_log 0 → 100644
View file @ cea8f5ca
08-16-2016 klaus
* First version of bt5 released
\ No newline at end of file
erp5_wendelin_relay/bt/dependency_list 0 → 100644
View file @ cea8f5ca
erp5_wendelin
\ No newline at end of file
erp5_wendelin_relay/bt/description 0 → 100644
View file @ cea8f5ca
Forwards incoming data to another wendelin instance
\ No newline at end of file
erp5_wendelin_relay/bt/maintainer_list 0 → 100644
View file @ cea8f5ca
klaus
\ No newline at end of file
erp5_wendelin_relay/bt/template_extension_id_list 0 → 100644
View file @ cea8f5ca
erp5.extension.WendelinRelay
\ No newline at end of file
erp5_wendelin_relay/bt/template_portal_type_workflow_chain_list 0 → 100644
View file @ cea8f5ca
Ingestion Policy | ingestion_policy_interaction_workflow
\ No newline at end of file
erp5_wendelin_relay/bt/template_skin_id_list 0 → 100644
View file @ cea8f5ca
erp5_wendelin_relay
\ No newline at end of file
erp5_wendelin_relay/bt/template_workflow_id_list 0 → 100644
View file @ cea8f5ca
ingestion_policy_interaction_workflow
\ No newline at end of file
erp5_wendelin_relay/bt/title 0 → 100644
View file @ cea8f5ca
erp5_wendelin_relay
\ No newline at end of file
erp5_wendelin_relay/bt/version 0 → 100644
View file @ cea8f5ca
0.01
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7