private _executeQueryFunc()

in src/registry.ts [1524:1559]

• 18 lines of code
• 3 McCabe index (conditional complexity)

  private _executeQueryFunc(sqlQuery: string, pageSize: number): (continuationToken: string, done: IncomingMessageCallback<any>) => void {
    return (continuationToken, done) => {
      /*Codes_SRS_NODE_IOTHUB_REGISTRY_16_057: [The `_executeQueryFunc` method shall construct an HTTP request as follows:
      ```
      POST /devices/query?api-version=<version> HTTP/1.1
      Authorization: <config.sharedAccessSignature>
      Content-Type: application/json; charset=utf-8
      x-ms-continuation: continuationToken
      x-ms-max-item-count: pageSize
      Request-Id: <guid>

      {
        query: <sqlQuery>
      }
      ```]*/
      const path = '/devices/query' + versionQueryString();
      const headers = {
        'Content-Type': 'application/json; charset=utf-8'
      };

      if (continuationToken) {
        headers['x-ms-continuation'] = continuationToken;
      }

      if (pageSize) {
        headers['x-ms-max-item-count'] = pageSize;
      }

      const query = {
        query: sqlQuery
      };

      this._restApiClient.executeApiCall('POST', path, headers, query, done);
    };

  }