Encoder of HTTP request parameters

Encoder of HTTP request parameters

Encoder of HTTP request parameters

Author: BoykoAlex

ui/src/app/shared/support/http.utils.spec.ts

@@ -0,0 +1,13 @@
+import { URL_QUERY_ENCODER } from './http.utils';
+
+describe('HTTP Utils', () => {
+
+  it('Encode + in key', () => {
+    expect(URL_QUERY_ENCODER.encodeKey('2 + 2 = 4')).toEqual('2%20%2B%202%20=%204');
+  });
+
+  it('Encode + in value', () => {
+    expect(URL_QUERY_ENCODER.encodeValue('2 + 2 = 4')).toEqual('2%20%2B%202%20=%204');
+  });
+
+});

ui/src/app/shared/support/http.utils.ts

@@ -1,4 +1,4 @@
-import { Headers, RequestOptions, URLSearchParams } from '@angular/http';
+import { Headers, RequestOptions, URLSearchParams, QueryEncoder } from '@angular/http';
 
 /**
  * Contains common HTTP-related helper methods.
@@ -25,3 +25,17 @@ export class HttpUtils {
     return params;
   }
 }
+
+class UrlQueryEncoder extends QueryEncoder {
+
+  encodeKey(k: string): string {
+    return super.encodeKey(k).replace(/\+/gi, '%2B');
+  }
+
+  encodeValue(v: string): string {
+    return super.encodeValue(v).replace(/\+/gi, '%2B');
+  }
+
+}
+
+export const URL_QUERY_ENCODER = new UrlQueryEncoder();

ui/src/app/streams/streams.service.ts

@@ -8,7 +8,7 @@ import 'rxjs/add/operator/map';
 import { StreamDefinition } from './model/stream-definition';
 import { Page } from '../shared/model/page';
 import { ErrorHandler } from '../shared/model/error-handler';
-import { HttpUtils } from '../shared/support/http.utils';
+import { HttpUtils, URL_QUERY_ENCODER } from '../shared/support/http.utils';
 
 /**
  * Provides {@link StreamDefinition} related services.
@@ -85,7 +85,7 @@ export class StreamsService {
   }
 
   createDefinition(name: string, dsl: string, deploy?: boolean): Observable<Response> {
-    const params =  new URLSearchParams();
+    const params =  new URLSearchParams('', URL_QUERY_ENCODER);
     params.append('name', name);
     params.append('definition', dsl);
     if (deploy) {