net/httpclient_listener.lua

   1 local log = require "util.logger".init("httpclient_listener");
   2
   3 local connlisteners_register = require "net.connlisteners".register;
   4
   5 local requests = {}; -- Open requests
   6 local buffers = {}; -- Buffers of partial lines
   7
   8 local httpclient = { default_port = 80, default_mode = "*a" };
   9
  10 function httpclient.listener(conn, data)
  11         local request = requests[conn];
  12
  13         if not request then
  14                 log("warn", "Received response from connection %s with no request attached!", tostring(conn));
  15                 return;
  16         end
  17
  18         if data and request.reader then
  19                 request:reader(data);
  20         end
  21 end
  22
  23 function httpclient.disconnect(conn, err)
  24         local request = requests[conn];
  25         if request then
  26                 request:reader(nil);
  27         end
  28         requests[conn] = nil;
  29 end
  30
  31 function httpclient.register_request(conn, req)
  32         log("debug", "Attaching request %s to connection %s", tostring(req.id or req), tostring(conn));
  33         requests[conn] = req;
  34 end
  35
  36 connlisteners_register("httpclient", httpclient);