http_request_eval

require("msys.core")
require("msys.delivery")
require("msys.httpclnt")
require("msys.gcm")
require("json")

function mod:http_request_eval(sess)
  -- get message associated with this request
  local msg = msys.delivery.ob_get_current_message(sess.connh)
  if msg == nil then
    print ("http_request_eval_hook: Associated message missing")
    return msys.delivery.DELIVERY_FAIL
  end

  -- print http request built by gcm
  print ("http request = ", sess.request.data)

  local reg_id = "APA91bHAUcDAJP-cQJuwQaHYGK6hGU4G4NTUPJT4zI6f2o4sl1S0-zOlPlq »
    JUFTSvHBmudvhMLrkGR1sQMc5qYBVjcNIpzyXoC2CIEj_1FeFKmNBDYX2LBp_zG-rj2hVA2-t7Fm40tQY2 »
    DzyjAI8maYIogujSPtq-jSUG0WybCQ0mT1eGOZsgy0"
  local request = "{ \"registration_ids\": [ \"" .. reg_id .. "\" ], \"dry_run\": true, »
    \"data\": { \"message\": \"Push message to send over GCM\" } }"
  local auth_key = "AIzaSyA09R1jflwVV4T79OIuLtTxQyXKFlOVQfs"

  -- print new json request to paniclog.ec for ref
  print ("new json request = ", request)

  sess:request_add_header("Accept", "text/plain", 1)
  sess:request_add_header("Accept", "application/json", 0)
  sess:request_add_header("Connection", "Keep-Alive", 1)
  sess:request_add_header("Authorization", "key=" .. auth_key, 1)
  sess:request_add_header("Content-Length", #request, 1)
  sess:request_set_body(request)

  -- have http client build (update) the request
  sess:request_finalize(1);
  -- print new request to paniclog.ec for ref
  print ("new http request = ", sess.request.data)

  -- update context variables
  msg:context_set(msys.core.ECMESS_CTX_MESS, "DLV_Dest_ID", reg_id)
  msg:context_set(msys.core.ECMESS_CTX_MESS, "DLV_Msg_Length", #sess.request.data)
  print ("new HTTP notification length = ", #sess.request.data)
  return msys.delivery.DELIVERY_CONTINUE;
end

msys.registerModule("gcm_hooks", mod);