miralemd / qlik-sse Goto Github PK

View Code? Open in Web Editor NEW

13.0 5.0 7.0 495 KB

Qlik Server Side Extension in nodejs

License: MIT License

JavaScript 100.00%

qlik-sse's Introduction

qlik-sse's People

Contributors

Stargazers

Watchers

Forkers

ralfbecher izlotnik 552847957 ssrisunt treska nexys-consulting alner

qlik-sse's Issues

Not able to write to request.write

For some reason I am unable to write information back within one of my functions. If I log the request before writing the data back I see the following which I suspect is my reason writable: false

Here is the function:

function GetAppMasterItems(request) {
  request.on('data', async function (bundle) {
    console.log(1);
    let tmpItems = []
    let finalItems = []
    async function getData(row) {
      return new Promise(async function (resolve, reject) {
        let masterItems = [];
        let appId = row.duals[0].strData;
        let onlyQwikMaster = row.duals[1].strData;
        let app = await global.openDoc(appId);
        let allInfos = await app.getAllInfos();
        for (var i = 0; i < allInfos.length; i++) {
          if (allInfos[i].qType == 'measure') {
            let measure = await app.getMeasure(allInfos[i].qId);
            let measureLayout = await measure.getProperties();
            if (onlyQwikMaster == 'true') {
              if (typeof measureLayout.qMetaDef.masterId != 'undefined') {
                masterItems.push(
                  [
                    measureLayout.qMetaDef.masterId,
                    "measure",
                    measureLayout.qMeasure.qDef,
                    measureLayout.qMeasure.qLabel,
                    measureLayout.qMetaDef.title,
                    measureLayout.qMetaDef.description,
                    measureLayout.qMeasure.coloring.baseColor.color,
                    appId
                  ]
                )
              }
            }
            else {
              masterItems.push(
                [
                  measureLayout.qMetaDef.masterId,
                  "measure",
                  measureLayout.qMeasure.qDef,
                  measureLayout.qMeasure.qLabel,
                  measureLayout.qMetaDef.title,
                  measureLayout.qMetaDef.description,
                  measureLayout.qMeasure.coloring.baseColor.color,
                  appId
                ]
              )
            }
          }
          if (allInfos[i].qType == 'dimension') {
            let dimension = await app.getDimension(allInfos[i].qId);
            let dimensionLayout = await dimension.getProperties();

            if (onlyQwikMaster == 'true') {
              if (typeof dimensionLayout.qMetaDef.masterId != 'undefined') {
                masterItems.push(
                  [
                    dimensionLayout.qMetaDef.masterId,
                    "dimension",
                    dimensionLayout.qDim.qFieldDefs[0],
                    dimensionLayout.qDim.qLabelExpression,
                    dimensionLayout.qDim.title,
                    dimensionLayout.qDim.descriptionExpression.qStringExpression.qExpr,
                    dimensionLayout.qDim.coloring.baseColor.color,
                    appId
                  ]
                )
              }
            }
            else {
              masterItems.push(
                [
                  dimensionLayout.qMetaDef.masterId,
                  "dimension",
                  dimensionLayout.qDim.qFieldDefs[0],
                  dimensionLayout.qDim.qLabelExpression,
                  dimensionLayout.qDim.title,
                  dimensionLayout.qDim.descriptionExpression.qStringExpression.qExpr,
                  dimensionLayout.qDim.coloring.baseColor.color,
                  appId
                ]
              )
            }
          }
        }
        resolve(masterItems)
      })
    }

    for(var r = 0; r<bundle.rows.length;r++) {
      let data = await getData(bundle.rows[r]);
      tmpItems.push(data);
      console.log(2);
    }
    var test = [];
    for(var one = 0; one< tmpItems.length; one++) {
      for(var two = 0; two < tmpItems[one].length;two++) {
        for(var three = 0; three < tmpItems[one][two].length; three++) {
          test.push({strDate: tmpItems[one][two][three]})
        }
      }
    }
    console.log(3, test);
    console.log(4);
    console.log(request);
    request.write({ "rows": [{ "duals": [{ "strData": "Sucess!" }] }] });
  })
}

Errors in evaluated script can crash server

Error in the code evaluated by ScriptEval() will cause the server instance to terminate with the uncaught error. For example:
x.find()
where x is undefined of find() is not a method.

I've fixed this by adding try/catch here: https://github.com/RobWunderlich/qlik-sse/commit/91408d478ce4a153c7cdca3ba07dd96d32a7c1a8

Ideally, the value returned to Qlik would be a Qlik null, not the string "null" or "undefined". Is there some sse.DataType for null?

migrate to @grpc/proto-loader

The current npm package grpc is logging deprecation warnings, might be time to migrate to @grpc/proto-loader

AGGREGATION examples return 1 row per bundle versus per request.

Description

In https://github.com/miralemd/qlik-sse/blob/master/examples/functions.md the aggregation example returns a result per bundle. If you have a large enough payload the SSE will return more than one row.

*Note I am using the qcb-qlik-sse which is built using your library and contains your example script.

Example

Qlik Example

Result

Expected

Expectation

I'm don't have much experience in Node.js so I'm sure there is a much better way to fix this. However, this is what I used to sum up the bundles before returning the result to Qlik.

  const functionDefinition = function ProcessAllRows(request) {
    let bundleNum = 0;
    const bundleResult = [];
    const rows = [];

    request.on('data', (bundle) => {
      
      console.log('ProcessAllRows: Bundle number ', ++bundleNum) 

      try {

        let v = 0;
        bundle.rows.forEach((row, index) => {
        //   console.log('ProcessAllRows: Row number ', index, row)
          row.duals.forEach((dual) => {
            if (!Number.isNaN(dual.numData)) {
              v += dual.numData;
            }
          });
        });

        bundleResult.push(v)

      }
      catch (error) {
        console.log(error)
      }
      
    });
    
    request.on('end',() => {

        let i = 0;

        bundleResult.forEach((x, index) => {

            i += x;

        })

        rows.push({
            duals: [{ numData: i }],
          });

        console.log('ProcessAllRows: Bundles: ', bundleNum);
        console.log('ProcessAllRows: Write rows: ', JSON.stringify(rows))
        request.write({
            bundleResult
          });
    });

  }

miralemd / qlik-sse Goto Github PK

qlik-sse's Introduction

qlik-sse

Getting started

Prerequisites

Usage

TODO