nodejs-javascript-invoke-params.js

/*
* Copyright (c) 2015-2025 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
*/
var should = require('should');

var testconfig = require('../etc/test-config-qa.js');
var fs = require('fs');

var marklogic = require('../');

var db = marklogic.createDatabaseClient(testconfig.restReaderConnection);
var dbWriter = marklogic.createDatabaseClient(testconfig.restWriterConnection);
var dbEval = marklogic.createDatabaseClient(testconfig.restEvaluatorConnection);
var dbAdmin = marklogic.createDatabaseClient(testconfig.restAdminConnection);

describe('Javascript invoke test', function () {

    var fsPath = __dirname + '/data/sourceParams.js';
    var invokePath = '/ext/invokeTest/sourceParams.sjs';

    before(function (done) {
        this.timeout(10000);
        dbAdmin.config.extlibs.write({
            path: invokePath, contentType: 'application/javascript', source: fs.createReadStream(fsPath)
        }).
            result(function (response) {
                done();
            }, done);
    });

    after(function (done) {
        dbAdmin.config.extlibs.remove(invokePath).
            result(function (response) {
                done();
            }, done);
    });

    it('should do javascript invoke with params', function (done) {
        dbEval.invoke(invokePath, { num1: 2, num2: 3 }).result(function (values) {
            //console.log(values);
            values[0].value.should.equal(5);
            done();
        }, done);
    });

    it('should do javascript invoke with params on stream', function (done) {
        dbEval.invoke(invokePath, { num1: 2, num2: 3 }).
            stream().
            on('data', function (data) {
                //console.log(data);
                data.value.should.equal(5);
            }).
            on('end', function () {
                done();
            }, done);
    });

    it('should do javascript invoke with params and transaction', function (done) {
        var tid = 0;

        dbEval.transactions.open({ transactionName: 'invokeTransaction', timeLimit: 60 })
            .result(function (response) {
                tid = response.txid;
                return dbEval.invoke({
                    path: invokePath,
                    variables: { num1: 2, num2: 3 },
                    txid: tid
                }).result();
            })
            .then(function (response) {
                //console.log(response);
                response[0].value.should.equal(5);
                return dbEval.transactions.commit(tid).result();
            })
            .then(function (response) {
                //console.log(response);
                done();
            }, done);
    });

    it('should do javascript invoke with wrong params', function (done) {
        dbEval.invoke(invokePath, { numa: 2, num2: 3 }).result(function (values) {
            //console.log(values);
            values[0].value.should.equal('NaN');
            done();
        }, function (error) {
            console.log(error);
            done();
        });
    });

    it('should do javascript invoke with wrong numbers of params', function (done) {
        dbEval.invoke(invokePath, { num1: 2, num2: 3, num3: 5 }).result(function (values) {
            //console.log(values);
            values[0].value.should.equal(5);
            done();
        }, function (error) {
            console.log(error);
            done();
        });
    });

});