Method sendRequest

src/runtime/databases/node/http.ts:13–51

(evaluation, requestId, request)

export class HttpDatabase extends Database {

  sendRequest(evaluation, requestId, request) {
    let options: any = {url: request.url[0], headers: {}};
    if(request.headers) {
      let headers = this.index.asObject(request.headers[0]);
      for(let header in headers) {
        options.headers[header] = headers[header];
      }
    }
    if(request.method) {
      options.method = request.method[0];
    }
    if(request.json) {
      let object = this.index.asObject(request.json[0], true, true);
      options.headers["Content-Type"] = "application/json";
      options.body = JSON.stringify(object);
    }
    if(request.body) {
      options.body = request.body[0];
    }
    httpRequest(options, (error, response, body) => {
      if(error || !response) {
        // @TODO: expose errors and other weirdness into Eve instead of just bailing here.
        console.error(error || "ERROR: No response received from HTTP request");
        return;
      }
      let scope = "http";
      let responseId = `${requestId}|response`;
      let changes = evaluation.createChanges();
      changes.store(scope, requestId, "response", responseId, this.id);
      changes.store(scope, responseId, "tag", "response", this.id);
      let contentType = response.headers["content-type"];
      if(contentType && contentType.indexOf("application/json") > -1) {
        let id = eavs.fromJS(changes, JSON.parse(body), this.id, scope, `${responseId}|json`);
        changes.store(scope, responseId, "json", id, this.id);
      }
      changes.store(scope, responseId, "body", body, this.id);
      evaluation.executeActions([], changes);
    })
  }

  onFixpoint(evaluation: Evaluation, changes: Changes) {
    let name = evaluation.databaseToName(this);