RavenDB-16050 Exporting query result to JSON - updating node.js client

ravendb · Jun 19, 2024 · c853126 · c853126
1 parent 5122ac7
commit c853126
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/Documents/Commands/QueryStreamCommand.ts b/src/Documents/Commands/QueryStreamCommand.ts
@@ -30,11 +30,11 @@ export class QueryStreamCommand extends RavenCommand<StreamResultResponse> {
     }
 
     public createRequest(node: ServerNode): HttpRequestParameters {
-        const format = this._conventions.useJsonlStreaming ? 'jsonl' : 'json';
+        const format = this._conventions.useJsonlStreaming ? 'format=jsonl' : "";
 
         return {
             method: "POST",
-            uri: `${node.url}/databases/${node.database}/streams/queries?format=${format}`,
+            uri: `${node.url}/databases/${node.database}/streams/queries?${format}`,
             body: writeIndexQuery(this._conventions, this._indexQuery),
             headers: this._headers().typeAppJson().build()
         };

diff --git a/src/Documents/Session/Operations/StreamOperation.ts b/src/Documents/Session/Operations/StreamOperation.ts
@@ -49,9 +49,12 @@ export class StreamOperation {
     }
 
     private _createRequestForIdPrefix(idPrefix: string, opts: StartingWithOptions): StreamCommand {
-        const format = this._session.conventions.useJsonlStreaming ? 'jsonl' : 'json';
+        const sb = new StringBuilder(`streams/docs?`);
+
+        if (this._session.conventions.useJsonlStreaming) {
+            sb.append("format=jsonl&");
+        }
 
-        const sb = new StringBuilder(`streams/docs?format=${format}&`);
         if (idPrefix) {
             sb.append("startsWith=")
                 .append(encodeURIComponent(idPrefix)).append("&");