local urllib = require "http.url"
  require "shared.init"
  require "utils.init"

  local sockethelper = require "http.sockethelper"
  local httpd = require "http.httpd"
  skynet = require "skynet"
  redisproxy = require "shared.redisproxy"
  netpack = require "skynet.netpack"
  datacenter = require "skynet.datacenter"

  mcast_util = require "services/mcast_util"

  csvdb = require "shared.csvdata"

  
  local socket = require "skynet.socket"

  
  require "shared.init"
  require "utils.init"
  require "ProtocolCode"
  require "skynet.manager"
  require "RedisKeys"
  require "GlobalVar"
  
  SendPacket = function(...) end
  rpcAgent = function(...) end
  rpcParter = function(...) end
  rpcRole = function(...) end
  rpcUnion = function(...) end
  rpcOtherUnion = function(...) end

  
  local table = table
  local string = string
  

  skynet.register_protocol {
  	name = "role",

  	id = 101,

  	pack = skynet.pack,
  	unpack = skynet.unpack,
  }
  

  local port = ...

  port = tonumber(port)
  
  local key = "zhaolu1234dangge"

  local function response(id, code, body)
  	local ok, err = httpd.write_response(sockethelper.writefunc(id), code, body, {
  		["Connection"] = "Close",
  	})

  	if not ok then
  		-- if err == sockethelper.socket_error , that means socket closed.
  		skynet.error(string.format("fd = %d, %s", id, err))
  	end
  end
  
  
  local CMD = require "actions.HttpAction"
  
  local function start()

  	globalCsv = csvdb["GlobalDefineCsv"]

  	local listen_socket = socket.listen("0.0.0.0", port)
  	print("Listen web port " .. port)
  	socket.start(listen_socket , function(id, addr)
  		socket.start(id)
  		local code, url, method, header, body = httpd.read_request(sockethelper.readfunc(id), 8192)
  		if code then
  			if code ~= 200 then
  				response(id, code)
  			else
  				local path, query = urllib.parse(url)
  				local cmd = path:match("([^/]+)")
  				if not CMD[cmd] or not query then
  					response(id, 404)
  					socket.close(id) 
  					return 
  				end
  				local query = urllib.parse_query(query)

  				-- if query.key ~= key then
  				-- 	response(id, 404)
  				-- 	socket.close(id) 
  				-- 	return 
  				-- end

  				local content = CMD[cmd](query, body)
  				if not content then
  					code = 404
  				end

  				response(id, code, tostring(content))

  			end
  		else
  			if url == sockethelper.socket_error then
  				skynet.error("socket closed")
  			else
  				skynet.error(url)
  			end
  		end
  		socket.close(id)
  	end)

  
  	-- 注册全服广播
  	local channels = {}
  	for i = 1, 10 do
  		local channel = datacenter.get("MC_W_CHANNEL" .. i)
  		if channel then
  			table.insert(channels, channel)
  		end
  	end
  	if #channels > 0 then
  		mcast_util.sub_worlds(channels)
  	end

  end
  
  local function __init__()
  	skynet.dispatch("lua", function(_,_, command, ...)
  		if command == "start" then
  			skynet.ret(skynet.pack(start(...)))
  		end
  	end)
  end
  
  skynet.start(__init__)