In this article you will learn how to:<\/h2>\n\n- Create webhook to CPI<\/li>\n
- Consume OData service basing on S\/4HANA event
\n<\/div>
\n<\/div><\/span><\/span><\/strong><\/li>\n<\/ul>\nOur journey continues<\/h3>\n
In the previous part of this blog<\/a><\/strong> I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app. Don’t worry, I will show you the app in the third part of this blog. Let’s go!<\/p>\n <\/p>\n
What is a webhook?<\/h3>\n
Let’s say in app A we want to fetch actual data from app B and display it. The most traditional way of achieving this goal would be to query some API in app B. The much better way would be when app B could inform app A when some changes occur (for example new order or change in business partner profile). Then app A would get the changed data only from app B.<\/p>\n
Hm, it sounds exactly like our scenario. But how a webhook fits into it?<\/p>\n
We have a message in our queue and want to notify CPI that it needs to fetch data of newly created sales order. We will simply create a webhook to CPI, I will show how to do that in a minute.<\/p>\n
<\/p>\n
CPI<\/h3>\n
First let’s take a look at CPI flow:<\/p>\n
![\"SAP](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/SAP-CPI-flow.png\")
<\/a><\/p>\n <\/p>\n
Get sales order number<\/h4>\n
In get sales order number step I used a simple Groovy script:<\/p>\n
def Message processData(Message message) {\r\n\r\n def body = message.getBody(String.class);\r\n\r\n def jsonSlurper = new JsonSlurper();\r\n\r\n def result = jsonSlurper.parseText(body);\r\n\r\n def val = result.EVENT_PAYLOAD.KEY[0].SALESORDER.toString();\r\n\r\n message.setProperty(\"SalesOrderNumber\",val);\r\n\r\n return message;\r\n\r\n}<\/pre>\n <\/p>\n
In order to understand the code we need to take a look at event payload itself:<\/p>\n
{\r\n\r\n \"EVENT_PAYLOAD\":{\r\n\r\n \"BUSINESSEVENT\":\"ErF9donAHtqm1WON+3ADaw==\",\r\n\r\n \"TIMESTAMP\":20200520150350,\r\n\r\n \"KEY\":[{\r\n\r\n \"SALESORDER\":\"0000005734\"\r\n\r\n }]\r\n\r\n }\r\n\r\n}<\/pre>\n <\/p>\n
This is what our S\/4 generated after creation of sales order 5734. Now you can easily understand the above Groovy script which uses JSONslurper to traverse event payload.At the end sales order number is saved in propert ‘SalesOrderNumber’.<\/p>\n
<\/h4>\nAdd header step<\/h4>\n
Content-type is set to application\/json;IEEE754Compatible=true. It is a necessary header for Node.js app to properly encode JSON payload.<\/p>\n
<\/p>\n
![\"\"](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Content-Modifier-SAP-CPI.png\")
<\/a><\/p>\n <\/p>\n
Get sales order details<\/h4>\n
This is the proper call to S\/4HANA system in order to get all details of processed sales order. In order to make it simple I use a custom CDS with OData service. Metadata looks like this:<\/p>\n
<\/p>\n
![\"Sales](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Sales-Order-Details.png\" "\\"Sales")
<\/a><\/p>\n <\/p>\n
As you can see there are only a few fields and it is ok for the purpose of our demo.<\/p>\n
OData adapter configuration:<\/p>\n
<\/p>\n
![\"OData](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/OData-Connection.png\" "\\"OData")
<\/a><\/p>\n <\/p>\n
![\"OData](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/OData-Connection-1.png\")
<\/a><\/p>\n <\/p>\n
Just remember to configure your Cloud Connector in S\/4. Reading OData also requires such configuration.<\/p>\n
XML to JSON converter<\/h4>\n
Will convert XML OData response to JSON (wow).<\/p>\n
<\/p>\n
Remove parent<\/h4>\n
Payload coming from OData service looks like this:<\/p>\n
{\r\n\r\n \"ZC_SALES_ORDER\":{\r\n\r\n \"ZC_SALES_ORDERType\":{\r\n\r\n \"netwr\":\"255453.00\",\r\n\r\n \"vbeln\":\"5734\",\r\n\r\n \"matnr\":\"MZ-FG-R300\",\r\n\r\n \"audat\":\"2016-06-16T00:00:00.000\",\r\n\r\n \"waerk\":\"USD\"\r\n\r\n }\r\n\r\n }\r\n\r\n}<\/pre>\n <\/p>\n
I want to achieve two things here: remove waerk field\u00a0 (app does not accept it) and send a flat JSON structure. I want the final payload to look like this:<\/p>\n
<\/p>\n
{\r\n\r\n \"netwr\":\"255453.00\",\r\n\r\n \"vbeln\":\"5734\",\r\n\r\n \"matnr\":\"MZ-FG-R300\",\r\n\r\n \"audat\":\"2016-06-16T00:00:00.000\",\r\n\r\n}\r\n<\/pre>\nSo let’s take a look at Groovy script:<\/p>\n
def Message processData(Message message) { \r\n\r\n def body = message.getBody(String.class);\r\n \r\n def jsonSlurper = new JsonSlurper();\r\n \r\n def result = jsonSlurper.parseText(body);\r\n \r\n result.ZC_SALES_ORDER.ZC_SALES_ORDERType.remove(\"waerk\");\r\n \r\n body = JsonOutput.toJson(result.ZC_SALES_ORDER.ZC_SALES_ORDERType);\r\n \r\n message.setBody(body);\r\n \r\n return message;\r\n\r\n}<\/pre>\n <\/p>\n
And voila! Now the only thing left is to send this message to my app. We will do it in part 3.<\/p>\n
<\/p>\n
Let’s create a webhook<\/h3>\n
As discussed in the second paragraph – we want Enterprise Messaging to automatically propagate event from S\/4 to our CPI flow. In webhook subscriptions click create:<\/p>\n
![\"Webhook](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Webhook-CPI.png\" "\\"Webhook")
<\/a><\/p>\nAnd let’s add connection to CPI:<\/p>\n
![\"\"](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Webhook-Subscription-Creation.png\")
<\/a><\/p>\n <\/p>\n
The final result should look like this:<\/p>\n
<\/p>\n
![\"Webhook](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Webhook-Subscription-Final-Result.png\")
<\/a><\/p>\nNow all messages from queue S42_SalesOrder will be propagated to CPI. From technical point of view it’s a simple HTTP POST call.<\/p>\n
<\/p>\n
Quick paragraph about queues and topics<\/h3>\n
If you want to learn more on this topic (hehe) take a look at this documentation:
\n- https:\/\/help.sap.com\/viewer\/bf82e6b26456494cbdd197057c09979f\/Cloud\/en-US\/e87534178ff448139efa93d639f13299.html.<\/a>
\n<\/div><\/li>\n<\/ul>\nLong story short – relations between a queue and a subscription app is 1:1. If we wanted to handle multiple subscription apps we would create two queues assigned to one topic and each queue would be consumed by one app. Documentation states that it is possible to have multiple apps consuming one topic but it’s possible only programmatically. I copied the CPI flow and named it SalesOrderOData2. I created another queue and assigned it to the same topic:<\/p>\n
![\"Queue](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Queue-Subscriptions-Webhook.png\" "\\"Queue")
<\/a><\/p>\nAnd a new webhook subscription:<\/p>\n
![\"New](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/New-Webhook-Subscriptions.png\" "\\"New")
<\/a><\/p>\n <\/p>\n
Now let’s emit an event from S\/4. The result in CPI looks like this:<\/p>\n
<\/p>\n
![\"Result](\"https:\/\/int4.com\/wp-content\/uploads\/2020\/05\/Result-in-CPI.png\" "\\"Result")
<\/a><\/p>\nAs you can see we’ve just sent one event to two separate receivers. This way we can notify all the apps that need to be notified about a change in our master system.<\/p>\n
Summary<\/h2>\n
In this article, I showed you how to consume OData service basing on event emmited from S\/4HANA system, how to create a webhook and how to propagate one event to multiple systems. In part 3, I will show you a consuming Node.js app in Cloud Platform. I will also send an event directly there and consume OData from the app. See you there!<\/p>\n
<\/p>\n
Read also:<\/h4>\n\n- SAP CPI Value Mapping Maintenance<\/a><\/li>\n
- SAP CPI: Technical guide to build a single XSLT mapping for multiple input types<\/a><\/li>\n<\/ol>\n
<\/p>\n","protected":false},"excerpt":{"rendered":"
Our journey continues In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data […]<\/p>\n","protected":false},"author":17,"featured_media":6018,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"content-type":""},"categories":[1],"tags":[203,74],"acf":[],"yoast_head":"\n
Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4<\/title>\n<meta name=\"description\" content=\"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.\" \/>\n<meta name=\"robots\" content=\"noindex, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<meta property=\"og:locale\" content=\"en_GB\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4\" \/>\n<meta property=\"og:description\" content=\"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.\" \/>\n<meta property=\"og:url\" content=\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\" \/>\n<meta property=\"og:site_name\" content=\"INT4\" \/>\n<meta property=\"article:published_time\" content=\"2020-05-27T14:43:32+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2020-12-10T07:43:33+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/test11988.futurehost.pl\/wp-content\/uploads\/2020\/06\/CPI_webhooks_Halicki.png\" \/>\n\t<meta property=\"og:image:width\" content=\"1200\" \/>\n\t<meta property=\"og:image:height\" content=\"627\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/png\" \/>\n<meta name=\"author\" content=\"Andrzej Halicki\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"Andrzej Halicki\" \/>\n\t<meta name=\"twitter:label2\" content=\"Estimated reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"5 minutes\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\",\"url\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\",\"name\":\"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4\",\"isPartOf\":{\"@id\":\"https:\/\/test11988.futurehost.pl\/#website\"},\"datePublished\":\"2020-05-27T14:43:32+00:00\",\"dateModified\":\"2020-12-10T07:43:33+00:00\",\"author\":{\"@id\":\"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd\"},\"description\":\"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.\",\"breadcrumb\":{\"@id\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb\"},\"inLanguage\":\"en-GB\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\/\/test11988.futurehost.pl\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Events with CPI, Enterprise Messaging and Node.js app part 2 – Webhooks and CPI OData\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/test11988.futurehost.pl\/#website\",\"url\":\"https:\/\/test11988.futurehost.pl\/\",\"name\":\"INT4\",\"description\":\"Your soft landing in SAP API testing\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/test11988.futurehost.pl\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"en-GB\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd\",\"name\":\"Andrzej Halicki\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-GB\",\"@id\":\"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g\",\"caption\":\"Andrzej Halicki\"},\"description\":\"Andrzej Halicki is an SAP integration consultant and developer. He has strong experience in ABAP development across local and international projects. Andrzej works with the latest solutions like ABAP for HANA and Cloud Platform Integration. Author of many technical articles that are available online in the SAP Community and Int4 website.\",\"url\":\"https:\/\/test11988.futurehost.pl\/author\/ahal\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4","description":"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.","robots":{"index":"noindex","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"og_locale":"en_GB","og_type":"article","og_title":"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4","og_description":"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.","og_url":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata","og_site_name":"INT4","article_published_time":"2020-05-27T14:43:32+00:00","article_modified_time":"2020-12-10T07:43:33+00:00","og_image":[{"width":"1200","height":"627","url":"https:\/\/test11988.futurehost.pl\/wp-content\/uploads\/2020\/06\/CPI_webhooks_Halicki.png","type":"image\/png"}],"author":"Andrzej Halicki","twitter_card":"summary_large_image","twitter_misc":{"Written by":"Andrzej Halicki","Estimated reading time":"5 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata","url":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata","name":"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4","isPartOf":{"@id":"https:\/\/test11988.futurehost.pl\/#website"},"datePublished":"2020-05-27T14:43:32+00:00","dateModified":"2020-12-10T07:43:33+00:00","author":{"@id":"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd"},"description":"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.","breadcrumb":{"@id":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb"},"inLanguage":"en-GB","potentialAction":[{"@type":"ReadAction","target":["https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/test11988.futurehost.pl\/"},{"@type":"ListItem","position":2,"name":"Events with CPI, Enterprise Messaging and Node.js app part 2 – Webhooks and CPI OData"}]},{"@type":"WebSite","@id":"https:\/\/test11988.futurehost.pl\/#website","url":"https:\/\/test11988.futurehost.pl\/","name":"INT4","description":"Your soft landing in SAP API testing","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/test11988.futurehost.pl\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"en-GB"},{"@type":"Person","@id":"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd","name":"Andrzej Halicki","image":{"@type":"ImageObject","inLanguage":"en-GB","@id":"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g","caption":"Andrzej Halicki"},"description":"Andrzej Halicki is an SAP integration consultant and developer. He has strong experience in ABAP development across local and international projects. Andrzej works with the latest solutions like ABAP for HANA and Cloud Platform Integration. Author of many technical articles that are available online in the SAP Community and Int4 website.","url":"https:\/\/test11988.futurehost.pl\/author\/ahal"}]}},"_links":{"self":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/posts\/5799"}],"collection":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/users\/17"}],"replies":[{"embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/comments?post=5799"}],"version-history":[{"count":0,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/posts\/5799\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/media\/6018"}],"wp:attachment":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/media?parent=5799"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/categories?post=5799"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/tags?post=5799"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
- \n
- Create webhook to CPI<\/li>\n
- Consume OData service basing on S\/4HANA event
\n<\/div>
\n<\/div><\/span><\/span><\/strong><\/li>\n<\/ul>\nOur journey continues<\/h3>\n
In the previous part of this blog<\/a><\/strong> I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app. Don’t worry, I will show you the app in the third part of this blog. Let’s go!<\/p>\n
<\/p>\n
What is a webhook?<\/h3>\n
Let’s say in app A we want to fetch actual data from app B and display it. The most traditional way of achieving this goal would be to query some API in app B. The much better way would be when app B could inform app A when some changes occur (for example new order or change in business partner profile). Then app A would get the changed data only from app B.<\/p>\n
Hm, it sounds exactly like our scenario. But how a webhook fits into it?<\/p>\n
We have a message in our queue and want to notify CPI that it needs to fetch data of newly created sales order. We will simply create a webhook to CPI, I will show how to do that in a minute.<\/p>\n
<\/p>\n
CPI<\/h3>\n
First let’s take a look at CPI flow:<\/p>\n
<\/a><\/p>\n<\/p>\n
Get sales order number<\/h4>\n
In get sales order number step I used a simple Groovy script:<\/p>\n
def Message processData(Message message) {\r\n\r\n def body = message.getBody(String.class);\r\n\r\n def jsonSlurper = new JsonSlurper();\r\n\r\n def result = jsonSlurper.parseText(body);\r\n\r\n def val = result.EVENT_PAYLOAD.KEY[0].SALESORDER.toString();\r\n\r\n message.setProperty(\"SalesOrderNumber\",val);\r\n\r\n return message;\r\n\r\n}<\/pre>\n<\/p>\n
In order to understand the code we need to take a look at event payload itself:<\/p>\n
{\r\n\r\n \"EVENT_PAYLOAD\":{\r\n\r\n \"BUSINESSEVENT\":\"ErF9donAHtqm1WON+3ADaw==\",\r\n\r\n \"TIMESTAMP\":20200520150350,\r\n\r\n \"KEY\":[{\r\n\r\n \"SALESORDER\":\"0000005734\"\r\n\r\n }]\r\n\r\n }\r\n\r\n}<\/pre>\n<\/p>\n
This is what our S\/4 generated after creation of sales order 5734. Now you can easily understand the above Groovy script which uses JSONslurper to traverse event payload.At the end sales order number is saved in propert ‘SalesOrderNumber’.<\/p>\n
<\/h4>\n
Add header step<\/h4>\n
Content-type is set to application\/json;IEEE754Compatible=true. It is a necessary header for Node.js app to properly encode JSON payload.<\/p>\n
<\/p>\n
<\/a><\/p>\n<\/p>\n
Get sales order details<\/h4>\n
This is the proper call to S\/4HANA system in order to get all details of processed sales order. In order to make it simple I use a custom CDS with OData service. Metadata looks like this:<\/p>\n
<\/p>\n
<\/a><\/p>\n<\/p>\n
As you can see there are only a few fields and it is ok for the purpose of our demo.<\/p>\n
OData adapter configuration:<\/p>\n
<\/p>\n
<\/a><\/p>\n<\/p>\n
<\/a><\/p>\n<\/p>\n
Just remember to configure your Cloud Connector in S\/4. Reading OData also requires such configuration.<\/p>\n
XML to JSON converter<\/h4>\n
Will convert XML OData response to JSON (wow).<\/p>\n
<\/p>\n
Remove parent<\/h4>\n
Payload coming from OData service looks like this:<\/p>\n
{\r\n\r\n \"ZC_SALES_ORDER\":{\r\n\r\n \"ZC_SALES_ORDERType\":{\r\n\r\n \"netwr\":\"255453.00\",\r\n\r\n \"vbeln\":\"5734\",\r\n\r\n \"matnr\":\"MZ-FG-R300\",\r\n\r\n \"audat\":\"2016-06-16T00:00:00.000\",\r\n\r\n \"waerk\":\"USD\"\r\n\r\n }\r\n\r\n }\r\n\r\n}<\/pre>\n<\/p>\n
I want to achieve two things here: remove waerk field\u00a0 (app does not accept it) and send a flat JSON structure. I want the final payload to look like this:<\/p>\n
<\/p>\n
{\r\n\r\n \"netwr\":\"255453.00\",\r\n\r\n \"vbeln\":\"5734\",\r\n\r\n \"matnr\":\"MZ-FG-R300\",\r\n\r\n \"audat\":\"2016-06-16T00:00:00.000\",\r\n\r\n}\r\n<\/pre>\nSo let’s take a look at Groovy script:<\/p>\n
def Message processData(Message message) { \r\n\r\n def body = message.getBody(String.class);\r\n \r\n def jsonSlurper = new JsonSlurper();\r\n \r\n def result = jsonSlurper.parseText(body);\r\n \r\n result.ZC_SALES_ORDER.ZC_SALES_ORDERType.remove(\"waerk\");\r\n \r\n body = JsonOutput.toJson(result.ZC_SALES_ORDER.ZC_SALES_ORDERType);\r\n \r\n message.setBody(body);\r\n \r\n return message;\r\n\r\n}<\/pre>\n<\/p>\n
And voila! Now the only thing left is to send this message to my app. We will do it in part 3.<\/p>\n
<\/p>\n
Let’s create a webhook<\/h3>\n
As discussed in the second paragraph – we want Enterprise Messaging to automatically propagate event from S\/4 to our CPI flow. In webhook subscriptions click create:<\/p>\n
<\/a><\/p>\nAnd let’s add connection to CPI:<\/p>\n
<\/a><\/p>\n<\/p>\n
The final result should look like this:<\/p>\n
<\/p>\n
<\/a><\/p>\nNow all messages from queue S42_SalesOrder will be propagated to CPI. From technical point of view it’s a simple HTTP POST call.<\/p>\n
<\/p>\n
Quick paragraph about queues and topics<\/h3>\n
If you want to learn more on this topic (hehe) take a look at this documentation:
- \n
- https:\/\/help.sap.com\/viewer\/bf82e6b26456494cbdd197057c09979f\/Cloud\/en-US\/e87534178ff448139efa93d639f13299.html.<\/a>
\n<\/div><\/li>\n<\/ul>\nLong story short – relations between a queue and a subscription app is 1:1. If we wanted to handle multiple subscription apps we would create two queues assigned to one topic and each queue would be consumed by one app. Documentation states that it is possible to have multiple apps consuming one topic but it’s possible only programmatically. I copied the CPI flow and named it SalesOrderOData2. I created another queue and assigned it to the same topic:<\/p>\n
<\/a><\/p>\nAnd a new webhook subscription:<\/p>\n
<\/a><\/p>\n<\/p>\n
Now let’s emit an event from S\/4. The result in CPI looks like this:<\/p>\n
<\/p>\n
<\/a><\/p>\nAs you can see we’ve just sent one event to two separate receivers. This way we can notify all the apps that need to be notified about a change in our master system.<\/p>\n
Summary<\/h2>\n
In this article, I showed you how to consume OData service basing on event emmited from S\/4HANA system, how to create a webhook and how to propagate one event to multiple systems. In part 3, I will show you a consuming Node.js app in Cloud Platform. I will also send an event directly there and consume OData from the app. See you there!<\/p>\n
<\/p>\n
Read also:<\/h4>\n
- \n
- SAP CPI Value Mapping Maintenance<\/a><\/li>\n
- SAP CPI: Technical guide to build a single XSLT mapping for multiple input types<\/a><\/li>\n<\/ol>\n
<\/p>\n","protected":false},"excerpt":{"rendered":"
Our journey continues In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data […]<\/p>\n","protected":false},"author":17,"featured_media":6018,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"content-type":""},"categories":[1],"tags":[203,74],"acf":[],"yoast_head":"\n
Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4<\/title>\n<meta name=\"description\" content=\"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.\" \/>\n<meta name=\"robots\" content=\"noindex, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<meta property=\"og:locale\" content=\"en_GB\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4\" \/>\n<meta property=\"og:description\" content=\"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.\" \/>\n<meta property=\"og:url\" content=\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\" \/>\n<meta property=\"og:site_name\" content=\"INT4\" \/>\n<meta property=\"article:published_time\" content=\"2020-05-27T14:43:32+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2020-12-10T07:43:33+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/test11988.futurehost.pl\/wp-content\/uploads\/2020\/06\/CPI_webhooks_Halicki.png\" \/>\n\t<meta property=\"og:image:width\" content=\"1200\" \/>\n\t<meta property=\"og:image:height\" content=\"627\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/png\" \/>\n<meta name=\"author\" content=\"Andrzej Halicki\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"Andrzej Halicki\" \/>\n\t<meta name=\"twitter:label2\" content=\"Estimated reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"5 minutes\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\",\"url\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\",\"name\":\"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4\",\"isPartOf\":{\"@id\":\"https:\/\/test11988.futurehost.pl\/#website\"},\"datePublished\":\"2020-05-27T14:43:32+00:00\",\"dateModified\":\"2020-12-10T07:43:33+00:00\",\"author\":{\"@id\":\"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd\"},\"description\":\"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.\",\"breadcrumb\":{\"@id\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb\"},\"inLanguage\":\"en-GB\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\/\/test11988.futurehost.pl\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Events with CPI, Enterprise Messaging and Node.js app part 2 – Webhooks and CPI OData\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/test11988.futurehost.pl\/#website\",\"url\":\"https:\/\/test11988.futurehost.pl\/\",\"name\":\"INT4\",\"description\":\"Your soft landing in SAP API testing\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/test11988.futurehost.pl\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"en-GB\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd\",\"name\":\"Andrzej Halicki\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-GB\",\"@id\":\"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g\",\"caption\":\"Andrzej Halicki\"},\"description\":\"Andrzej Halicki is an SAP integration consultant and developer. He has strong experience in ABAP development across local and international projects. Andrzej works with the latest solutions like ABAP for HANA and Cloud Platform Integration. Author of many technical articles that are available online in the SAP Community and Int4 website.\",\"url\":\"https:\/\/test11988.futurehost.pl\/author\/ahal\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4","description":"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.","robots":{"index":"noindex","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"og_locale":"en_GB","og_type":"article","og_title":"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4","og_description":"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.","og_url":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata","og_site_name":"INT4","article_published_time":"2020-05-27T14:43:32+00:00","article_modified_time":"2020-12-10T07:43:33+00:00","og_image":[{"width":"1200","height":"627","url":"https:\/\/test11988.futurehost.pl\/wp-content\/uploads\/2020\/06\/CPI_webhooks_Halicki.png","type":"image\/png"}],"author":"Andrzej Halicki","twitter_card":"summary_large_image","twitter_misc":{"Written by":"Andrzej Halicki","Estimated reading time":"5 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata","url":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata","name":"Events with CPI, Enterprise Messaging and Node.js app part 2 - Webhooks and CPI OData - INT4","isPartOf":{"@id":"https:\/\/test11988.futurehost.pl\/#website"},"datePublished":"2020-05-27T14:43:32+00:00","dateModified":"2020-12-10T07:43:33+00:00","author":{"@id":"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd"},"description":"In the previous part of this blog I showed you how to configure events raised from S\/4HANA system and send them to Enterprise Messaging service. In this part we will take a look at event itself. We will create a webhook to our CPI flow where we will fetch Sales Order data from OData service and move it to Node.js app.","breadcrumb":{"@id":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb"},"inLanguage":"en-GB","potentialAction":[{"@type":"ReadAction","target":["https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/test11988.futurehost.pl\/events-with-cpi-enterprise-messaging-and-node-js-app-part-2-webhooks-and-cpi-odata#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/test11988.futurehost.pl\/"},{"@type":"ListItem","position":2,"name":"Events with CPI, Enterprise Messaging and Node.js app part 2 – Webhooks and CPI OData"}]},{"@type":"WebSite","@id":"https:\/\/test11988.futurehost.pl\/#website","url":"https:\/\/test11988.futurehost.pl\/","name":"INT4","description":"Your soft landing in SAP API testing","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/test11988.futurehost.pl\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"en-GB"},{"@type":"Person","@id":"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/4b9dd6ed1d0ca8054d444b47bb2393fd","name":"Andrzej Halicki","image":{"@type":"ImageObject","inLanguage":"en-GB","@id":"https:\/\/test11988.futurehost.pl\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/39edd33be18263d68f44ff45057e7227?s=96&d=mm&r=g","caption":"Andrzej Halicki"},"description":"Andrzej Halicki is an SAP integration consultant and developer. He has strong experience in ABAP development across local and international projects. Andrzej works with the latest solutions like ABAP for HANA and Cloud Platform Integration. Author of many technical articles that are available online in the SAP Community and Int4 website.","url":"https:\/\/test11988.futurehost.pl\/author\/ahal"}]}},"_links":{"self":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/posts\/5799"}],"collection":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/users\/17"}],"replies":[{"embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/comments?post=5799"}],"version-history":[{"count":0,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/posts\/5799\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/media\/6018"}],"wp:attachment":[{"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/media?parent=5799"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/categories?post=5799"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/test11988.futurehost.pl\/wp-json\/wp\/v2\/tags?post=5799"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} - SAP CPI: Technical guide to build a single XSLT mapping for multiple input types<\/a><\/li>\n<\/ol>\n
- SAP CPI Value Mapping Maintenance<\/a><\/li>\n
- https:\/\/help.sap.com\/viewer\/bf82e6b26456494cbdd197057c09979f\/Cloud\/en-US\/e87534178ff448139efa93d639f13299.html.<\/a>