Shopware 6 HTTP Request

Shopware Request Sub-Flow

Features

• Sends a HTTP request to a Shopware 6 shop
• Automatically authenticates based on environment variables
• Dynamic request url generation based on message

Requirements

• Node Red ^1.2

How to use

Basic Usage

This subflow requires environment variables. These can be set by starting Node Red with them, or by configurating the sub flow.

• SHOPWARE_URL : The Shopware 6 base url, e.g. "https://example.com"
• SHOPWARE_CLIENT : The Application client id. Can be created in Shopware Settings / Integrations
• SHOPWARE_SECRET : The Application secret key. Can be created in Shopware Settings / Integrations

With that you're ready to create your first request:

[ Inject ] -> [ Shopware request ] -> [ Debug ]

Request method and uri can be set either as part of the message object, e.g.

msg.method = "POST";
msg.uri = "/api/v3/search/product";

Or as environment variable as part of the Shopware Request sub flow, e.g.

METHOD = "POST";
URI = "/api/v3/search/product";

Now, set the request body in msg.payload:

msg.payload = {
  "filter": [
    {
      "type":"equals",
      "field":"productNumber",
      "value":"123456"
    }
  ]
}

This will create a HTTP request to

POST https://example.com/api/v3/search/product
{
  "filter": [
    {
      "type":"equals",
      "field":"productNumber",
      "value":"123456"
    }
  ]
}

Usage with dynamic url

If needed, you can set request url based on message parts:

msg.method = "GET";
msg.uri = "/api/v3/product/{productId}";
msg.productId = '123456'

This will create the uri "/api/v3/product/123456".

Response

Response code and body are set similar to Node-Reds http-request node. See documentation of http-request.

Flow.json

Copy[{"id":"64d3d6c7.500ee8","type":"subflow","name":"Shopware Request","info":"# Shopware Request Sub-Flow\n\n## Features\n\n - Sends a HTTP request to a Shopware 6 shop\n - Automatically authenticates\n - Dynamic request url generation based on message\n\n\n## Requirements\n\n- Node Red ^1.2\n\n\n## How to use\n\n### Basic Usage\n\nThis subflow requires environment variables. These can be set by starting Node Red with them, or by configurating the sub flow.\n\n - SHOPWARE_URL : The Shopware 6 base url, e.g. \"https://example.com\"\n - SHOPWARE_CLIENT : The Application client id. Can be created in Shopware Settings / Integrations\n - SHOPWARE_SECRET : The Application secret key. Can be created in Shopware Settings / Integrations\n\n\nWith that you're ready to create your first request:\n\n[ Inject ] -> [ Shopware request ] -> [ Debug ]\n\nRequest method and uri can be set either as part of the message object, e.g.\n```\nmsg.method = \"POST\";\nmsg.uri = \"/api/v3/search/product\";\n```\nOr as environment variable for the Shopware Request sub flow, e.g.\n```\nMETHOD = \"POST\";\nURI = \"/api/v3/search/product\";\n```\n\nNow, set the request body in msg.payload:\n```\nmsg.payload = {\n  \"filter\": [\n    {\n      \"type\":\"equals\",\n      \"field\":\"productNumber\",\n      \"value\":\"123456\"\n    }\n  ]\n}\n```\n\n### Usage with dynamic url\n\nIf needed, you can set request url based on message parts:\n\n```\nmsg.method = \"GET\";\nmsg.uri = \"/api/v3/product/{productId}\";\nmsg.productId = '123456'\n```\n","category":"","in":[{"x":20,"y":280,"wires":[{"id":"f75b96c.e6af168"}]}],"out":[{"x":1900,"y":260,"wires":[{"id":"1b3aec7.ccaad14","port":0},{"id":"116428e7.8a9df7","port":0},{"id":"f75b96c.e6af168","port":1}]}],"env":[],"color":"#51b6ff","icon":"node-red/white-globe.svg"},{"id":"673b2b02.cfa3e4","type":"switch","z":"64d3d6c7.500ee8","name":"Check token","property":"shopware_token","propertyType":"global","rules":[{"t":"istype","v":"string","vt":"string"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":570,"y":260,"wires":[["d4483c4a.6c46f"],["1e525de3.1ace52"]]},{"id":"f7834de8.dfe03","type":"http request","z":"64d3d6c7.500ee8","name":"Send request","method":"use","ret":"bin","paytoqs":"ignore","url":"","tls":"","persist":false,"proxy":"","authType":"","x":1040,"y":160,"wires":[["4d0dbbbc.1e1ca4"]]},{"id":"4d0dbbbc.1e1ca4","type":"switch","z":"64d3d6c7.500ee8","name":"statusCode!=401","property":"statusCode","propertyType":"msg","rules":[{"t":"neq","v":"401","vt":"num"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":1050,"y":200,"wires":[["f8dbf065.8b0d9"],["1e525de3.1ace52"]]},{"id":"f75b96c.e6af168","type":"function","z":"64d3d6c7.500ee8","name":"Validate uri/method","func":"const url = env.get(\"SHOPWARE_URL\");\nconst client = env.get(\"SHOPWARE_CLIENT\");\nconst secret = env.get(\"SHOPWARE_SECRET\");\n\nif (!msg.uri) {\n    msg.uri = env.get(\"URI\");\n}\nif (!msg.method) {\n    msg.method = env.get(\"METHOD\");\n}\n\nif (msg.uri && msg.method && url && client && secret) {\n    // If uri contains variables, parse uri with msg object\n    // e.g. msg.uri=\"/family/{code}/variants\" and msg.code=\"abc\"\n    // => msg.uri=\"/family/abc/variants\"\n    msg.uri = msg.uri.replace(/\\{/g, '${this.');\n    msg.uri = new Function(\"return `\" + msg.uri + \"`;\").call(msg);\n    msg.url = url.replace(/\\/$/, '') + \"/\" + msg.uri.replace(/^\\//, '');\n    return [msg, null];\n} else {\n    msg.error = 'Missing environment variable';\n    return [null, msg];\n}\n","outputs":2,"noerr":0,"initialize":"","finalize":"","libs":[],"x":150,"y":280,"wires":[["8f40c73f.9f5218"],[]]},{"id":"674da84b.03c998","type":"http request","z":"64d3d6c7.500ee8","name":"Get Shopware token","method":"use","ret":"obj","paytoqs":"ignore","url":"","tls":"","persist":false,"proxy":"","authType":"","x":1060,"y":320,"wires":[["116428e7.8a9df7"]]},{"id":"119a80f4.33b11f","type":"change","z":"64d3d6c7.500ee8","name":"Extract Token","rules":[{"t":"set","p":"shopware_token","pt":"global","to":"payload.access_token","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":1480,"y":340,"wires":[["73b0980b.5b6718"]]},{"id":"73b0980b.5b6718","type":"change","z":"64d3d6c7.500ee8","name":"Set orig payload","rules":[{"t":"set","p":"payload","pt":"msg","to":"orig_payload","tot":"msg"},{"t":"set","p":"method","pt":"msg","to":"orig_method","tot":"msg"},{"t":"set","p":"url","pt":"msg","to":"orig_url","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":1660,"y":340,"wires":[["d4483c4a.6c46f"]]},{"id":"116428e7.8a9df7","type":"switch","z":"64d3d6c7.500ee8","name":"statusCode!=200","property":"statusCode","propertyType":"msg","rules":[{"t":"neq","v":"200","vt":"num"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":1270,"y":320,"wires":[[],["119a80f4.33b11f"]]},{"id":"1b3aec7.ccaad14","type":"change","z":"64d3d6c7.500ee8","name":"Remove superfluous parts","rules":[{"t":"delete","p":"headers","pt":"msg"},{"t":"delete","p":"method","pt":"msg"},{"t":"delete","p":"uri","pt":"msg"},{"t":"delete","p":"url","pt":"msg"},{"t":"delete","p":"responseUrl","pt":"msg"},{"t":"delete","p":"redirectList","pt":"msg"},{"t":"delete","p":"responseCookies","pt":"msg"},{"t":"delete","p":"orig_payload","pt":"msg"},{"t":"delete","p":"orig_method","pt":"msg"},{"t":"delete","p":"orig_url","pt":"msg"},{"t":"delete","p":"orig_header","pt":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":1640,"y":180,"wires":[[]]},{"id":"8f40c73f.9f5218","type":"change","z":"64d3d6c7.500ee8","name":"Remember request","rules":[{"t":"set","p":"orig_payload","pt":"msg","to":"payload","tot":"msg"},{"t":"set","p":"orig_url","pt":"msg","to":"url","tot":"msg"},{"t":"set","p":"orig_method","pt":"msg","to":"method","tot":"msg"},{"t":"set","p":"orig_headers","pt":"msg","to":"headers","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":370,"y":260,"wires":[["673b2b02.cfa3e4"]]},{"id":"c00e789e.3a9df8","type":"comment","z":"64d3d6c7.500ee8","name":"Authentication","info":"","x":810,"y":360,"wires":[]},{"id":"ca6e850a.75cbe8","type":"comment","z":"64d3d6c7.500ee8","name":"Request execution","info":"","x":830,"y":160,"wires":[]},{"id":"3b068663.91f75a","type":"comment","z":"64d3d6c7.500ee8","name":"Cleanup","info":"","x":1580,"y":140,"wires":[]},{"id":"d4483c4a.6c46f","type":"function","z":"64d3d6c7.500ee8","name":"Prepare headers","func":"msg.headers = msg.orig_headers || {};\nmsg.headers['Accept'] = msg.headers['Accept'] || env.get(\"ACCEPT\") || '*/*';\nmsg.headers['Authorization'] = 'Bearer ' + global.get('shopware_token');\nif (!msg.headers['Content-Type']) {\n    msg.headers['Content-Type'] = 'application/json';\n}\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":820,"y":200,"wires":[["f7834de8.dfe03"]]},{"id":"1e525de3.1ace52","type":"function","z":"64d3d6c7.500ee8","name":"Prepare Auth request","func":"msg.payload = {\n    \"grant_type\": \"client_credentials\",\n    \"client_id\": env.get(\"SHOPWARE_CLIENT\"),\n    \"client_secret\": env.get(\"SHOPWARE_SECRET\")\n};\nmsg.url = env.get(\"SHOPWARE_URL\").replace(/\\/$/, '') + \"/api/oauth/token\";\nmsg.method = \"POST\";\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","x":840,"y":320,"wires":[["674da84b.03c998"]]},{"id":"f8dbf065.8b0d9","type":"switch","z":"64d3d6c7.500ee8","name":"Check Content-Type","property":"headers['content-type']","propertyType":"msg","rules":[{"t":"eq","v":"application/json","vt":"str"},{"t":"eq","v":"application/vnd.api+json","vt":"str"},{"t":"else"}],"checkall":"false","repair":false,"outputs":3,"x":1280,"y":180,"wires":[["7ddfbb37.2eebd4"],["7ddfbb37.2eebd4"],["9c941c33.8397d"]]},{"id":"7ddfbb37.2eebd4","type":"function","z":"64d3d6c7.500ee8","name":"toJson","func":"msg.payload = msg.payload.toString('utf8'); // txt\ntry {\n    msg.payload = JSON.parse(msg.payload);\n} catch(e) {}\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","x":1450,"y":160,"wires":[["1b3aec7.ccaad14"]]},{"id":"9c941c33.8397d","type":"function","z":"64d3d6c7.500ee8","name":"toTxt","func":"msg.payload = msg.payload.toString('utf8'); // txt\n\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","x":1450,"y":200,"wires":[["1b3aec7.ccaad14"]]}]