Merge pull request #10 from stape-io/x-www-form-urlencoded-support

x-www-form-urlencoded support
stape-io · Jan 30, 2024 · f4d40e4 · f4d40e4
2 parents 285aedf + 1fc551b
commit f4d40e4
Show file tree

Hide file tree

Showing 3 changed files with 102 additions and 3 deletions.
diff --git a/metadata.yaml b/metadata.yaml
@@ -1,5 +1,7 @@
 homepage: "https://stape.io/"
 versions:
+  - sha: e31d2f39c10285cbc5169e349c473f73e4668692
+    changeNotes: Added support for x-www-form-urlencoded.
   - sha: 4d9f4d4fbded5414cb091efac70224d31c522e5c
     changeNotes: Fix user address data.
   - sha: 905af50fe8eb5f61e58a6d04c33fd6faf01e7f98

diff --git a/template.js b/template.js
@@ -21,6 +21,9 @@ const computeEffectiveTldPlusOne = require('computeEffectiveTldPlusOne');
 const getRequestQueryParameter = require('getRequestQueryParameter');
 const getType = require('getType');
 const Promise = require('Promise');
+const decodeUriComponent = require('decodeUriComponent');
+const createRegex = require('createRegex');
+const makeString = require('makeString');
 
 const requestMethod = getRequestMethod();
 const path = getRequestPath();
@@ -522,7 +525,11 @@ function getEventModels(baseEventModel) {
   const body = getRequestBody();
 
   if (body) {
-    let bodyJson = JSON.parse(body);
+    const contentType = getRequestHeader('content-type');
+    const isFormUrlEncoded =
+      !!contentType &&
+      contentType.indexOf('application/x-www-form-urlencoded') !== -1;
+    let bodyJson = isFormUrlEncoded ? parseUrlEncoded(body) : JSON.parse(body);
     if (bodyJson) {
       const bodyType = getType(bodyJson);
       const shouldUseOriginalBody =
@@ -586,3 +593,43 @@ function assign() {
   }
   return target;
 }
+
+function parseUrlEncoded(data) {
+  const pairs = data.split('&');
+  const parsedData = {};
+  const regex = createRegex('\\+', 'g');
+  for (const pair of pairs) {
+    const pairValue = pair.split('=');
+    const key = pairValue[0];
+    const value = pairValue[1];
+    const keys = key
+      .split('.')
+      .map((k) => decodeUriComponent(k.replace(regex, ' ')));
+
+    let currentObject = parsedData;
+
+    for (let i = 0; i < keys.length - 1; i++) {
+      const currentKey = keys[i];
+
+      if (!currentObject[currentKey]) {
+        const nextKey = keys[i + 1];
+        const nextKeyIsNumber = makeString(makeInteger(nextKey)) === nextKey;
+        currentObject[currentKey] = nextKeyIsNumber ? [] : {};
+      }
+
+      currentObject = currentObject[currentKey];
+    }
+
+    const lastKey = keys[keys.length - 1];
+    const decodedValue = decodeUriComponent(value.replace(regex, ' '));
+    const parsedValue = JSON.parse(decodedValue) || decodedValue;
+
+    if (getType(currentObject) === 'array') {
+      currentObject.push(parsedValue);
+    } else {
+      currentObject[lastKey] = parsedValue;
+    }
+  }
+
+  return parsedData;
+}
diff --git a/template.tpl b/template.tpl
@@ -297,6 +297,9 @@ const computeEffectiveTldPlusOne = require('computeEffectiveTldPlusOne');
 const getRequestQueryParameter = require('getRequestQueryParameter');
 const getType = require('getType');
 const Promise = require('Promise');
+const decodeUriComponent = require('decodeUriComponent');
+const createRegex = require('createRegex');
+const makeString = require('makeString');
 
 const requestMethod = getRequestMethod();
 const path = getRequestPath();
@@ -798,7 +801,11 @@ function getEventModels(baseEventModel) {
   const body = getRequestBody();
 
   if (body) {
-    let bodyJson = JSON.parse(body);
+    const contentType = getRequestHeader('content-type');
+    const isFormUrlEncoded =
+      !!contentType &&
+      contentType.indexOf('application/x-www-form-urlencoded') !== -1;
+    let bodyJson = isFormUrlEncoded ? parseUrlEncoded(body) : JSON.parse(body);
     if (bodyJson) {
       const bodyType = getType(bodyJson);
       const shouldUseOriginalBody =
@@ -863,6 +870,46 @@ function assign() {
   return target;
 }
 
+function parseUrlEncoded(data) {
+  const pairs = data.split('&');
+  const parsedData = {};
+  const regex = createRegex('\\+', 'g');
+  for (const pair of pairs) {
+    const pairValue = pair.split('=');
+    const key = pairValue[0];
+    const value = pairValue[1];
+    const keys = key
+      .split('.')
+      .map((k) => decodeUriComponent(k.replace(regex, ' ')));
+
+    let currentObject = parsedData;
+
+    for (let i = 0; i < keys.length - 1; i++) {
+      const currentKey = keys[i];
+
+      if (!currentObject[currentKey]) {
+        const nextKey = keys[i + 1];
+        const nextKeyIsNumber = makeString(makeInteger(nextKey)) === nextKey;
+        currentObject[currentKey] = nextKeyIsNumber ? [] : {};
+      }
+
+      currentObject = currentObject[currentKey];
+    }
+
+    const lastKey = keys[keys.length - 1];
+    const decodedValue = decodeUriComponent(value.replace(regex, ' '));
+    const parsedValue = JSON.parse(decodedValue) || decodedValue;
+
+    if (getType(currentObject) === 'array') {
+      currentObject.push(parsedValue);
+    } else {
+      currentObject[lastKey] = parsedValue;
+    }
+  }
+
+  return parsedData;
+}
+
 
 ___SERVER_PERMISSIONS___
 
@@ -1163,7 +1210,10 @@ ___SERVER_PERMISSIONS___
 
 ___TESTS___
 
-scenarios: []
+scenarios:
+- name: Quick Test
+  code: runCode();
+setup: ''
 
 
 ___NOTES___