Function processPost

lib/nodejs/lib/thrift/web_server.js:378–429

(request, response)

  //Handle POST methods (TXHRTransport)
  ///////////////////////////////////////////////////
  function processPost(request, response) {
    //Lookup service
    var uri = url.parse(request.url).pathname;
    var svc = services[uri];
    if (!svc) {
      response.writeHead("403", "No Apache Thrift Service at " + uri, {});
      response.end();
      return;
    }

    //Verify CORS requirements
    if (!VerifyCORSAndSetHeaders(request, response)) {
      response.writeHead(
        "403",
        "Origin " + request.headers.origin + " not allowed",
        {},
      );
      response.end();
      return;
    }

    //Process XHR payload
    request.on(
      "data",
      svc.transport.receiver(function (transportWithData) {
        var input = new svc.protocol(transportWithData);
        var output = new svc.protocol(
          new svc.transport(undefined, function (buf) {
            try {
              response.writeHead(200);
              response.end(buf);
            } catch (err) {
              response.writeHead(500);
              response.end();
            }
          }),
        );

        try {
          svc.processor.process(input, output);
          transportWithData.commitPosition();
        } catch (err) {
          if (err instanceof InputBufferUnderrunError) {
            transportWithData.rollbackPosition();
          } else {
            response.writeHead(500);
            response.end();
          }
        }
      }),
    );
  }

  //Handle GET methods (Static Page Server)
  ///////////////////////////////////////////////////