MLE-21460 : ResultProvider.result() sometimes returns a text node as a Buffer

Author: anu3990

lib/responder.js

@@ -1121,6 +1121,14 @@ function resolvedPromise(operation, resolve) {
   var data    = operation.data;
   var hasData = (data != null);
   var dataLen = hasData ? data.length : null;
+  if(hasData && dataLen) {
+    for(let i=0; i<data.length; i++){
+      if(data[i] && data[i].value &&
+          data[i].format === 'text' && Buffer.isBuffer(data[i].value)){
+        data[i].value = data[i].value.toString();
+      }
+    }
+  }
 
   operation.logger.debug('promise resolving with '+(
       hasData ? (dataLen+' chunks of') : 'null'

test-basic/documents-read-xqy-docs.js

@@ -0,0 +1,97 @@
+/*
+ * Copyright (c) 2025 MarkLogic Corporation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+let testconfig = require('../etc/test-config.js');
+let should = require('should');
+let marklogic = require('../');
+let db = marklogic.createDatabaseClient(testconfig.restWriterConnection);
+let uris = ['/hello.xqy', '/hello-2.xqy', '/test-doc.txt', '/test-doc.json'];
+
+describe('document-read-xqy-documents', function() {
+    this.timeout(5000);
+    before(function(done){
+        db.documents.write({
+            uri: uris[0],
+            contentType: 'application/vnd.marklogic-xdmp',
+            content: 'Hello, world! in hello.xqy'
+        })
+            .result(()=>{
+                db.documents.write({
+                    uri: uris[1],
+                    contentType: 'application/vnd.marklogic-xdmp',
+                    content: 'Hello, world! in hello-2.xqy'
+                }).result(()=>{
+                    db.documents.write({
+                        uri: uris[2],
+                        contentType: 'text/plain',
+                        content: 'Hello, world! in test-doc.txt'
+                    }).result(()=> {
+                        db.documents.write({
+                            uri: uris[3],
+                            contentType: 'application/json',
+                            content: '{"key":"value"}'
+                        }).result(()=> done())
+                    })
+                })
+            })
+            .catch(error=> done(error));
+    });
+
+    after(function(done){
+        db.documents.remove(uris)
+            .result(function(response){
+                done();
+            })
+            .catch(err=> done(err));
+    });
+
+    it('should read single xqy document and return content in string',  done => {
+
+        db.eval(`cts.doc('/hello.xqy')`).result(res=>{
+            res[0].value.should.equal('Hello, world! in hello.xqy')
+        }).then(()=> done())
+            .catch(error=> done(error))
+    });
+
+    it('should read multiple xqy documents and return content in string',  done => {
+
+        db.eval(`Sequence.from([cts.doc('/hello.xqy'), cts.doc('/hello-2.xqy')])`).result(res=>{
+            res[0].value.should.equal('Hello, world! in hello.xqy');
+            res[1].value.should.equal('Hello, world! in hello-2.xqy');
+        }).then(()=> done())
+            .catch(error=> done(error))
+    });
+
+    it('should read xqy document along with text document and return content in string',  done => {
+
+        db.eval(`Sequence.from([cts.doc('/hello.xqy'), cts.doc('/test-doc.txt')])`).result(res=>{
+            res[0].value.should.equal('Hello, world! in hello.xqy');
+            res[1].value.should.equal('Hello, world! in test-doc.txt');
+        }).then(()=> done())
+            .catch(error=> done(error))
+    });
+
+    it('should read multiple xqy documents along with json document and return content in string',  done => {
+
+        db.eval(`Sequence.from([cts.doc('/hello.xqy'), cts.doc('/hello-2.xqy'), cts.doc('/test-doc.json')])`).result(res=>{
+            res[0].value.should.equal('Hello, world! in hello.xqy');
+            res[1].value.should.equal('Hello, world! in hello-2.xqy');
+            res[2].value.should.have.property('key');
+            res[2].value.key.should.equal('value');
+        }).then(()=> done())
+            .catch(error=> done(error))
+    });
+});