http_router.zsh

rpc(){
	ztcp localhost 7000
	# TODO read the banner to make sure we connected ok
	echo "$1" >&$REPLY
	# TODO read a response and print
	ztcp -c $REPLY
}

http_reload(){
	until git pull -f; do
		sleep 1
	done
	source http_router.zsh
	rpc "source"
}

http_router(){
	client=$1
	url=$2
	body=$3
	shift 3
	local -A headers
	set -A headers "$@"
	echo "Got a route request for $url"
	for h in "${(k)headers[@]}"; do
		echo "$h: ${headers[$h]}"
	done
	[[ "$url" == "/quit" ]] && ztcp -c && exit 2

	if [[ "$url" == "/pull" ]]; then
		http_reload
	elif [[ "$url" == "/github" ]]; then
		if [ -z "$body" ]; then
			echo "No body!"
			return
		fi
		if [ -z "${headers[X-Github-Event]:-}" ]; then
			echo "No X-Github-Event header!"
			return
		fi
		event="${headers[X-Github-Event]}"

		echo "parsing body"
		echo "Event type: $event"
		JSON.load "$body" jason
		mkdir hooks 2>/dev/null || true
		#echo "$body" > hooks/${headers[X-Github-Delivery]}.json

# [{purple}myzsh-docker{reset}] dan9186 created {purple}change-dev-mapped-dir{reset} (+1 new commit): {blue}https://github.com/myzsh/myzsh-docker/commit/b0614575bde3
# {purple}myzsh-docker{reset}/{purple}change-dev-mapped-dir{reset} b061457 Daniel Hess: changing to /docker per issue #4
# [{purple}myzsh-docker{reset}] dan9186 opened pull request #9: changing to /docker per issue #4 ({purple}master{reset}...{purple}change-dev-mapped-dir{reset}) {blue}https://github.com/myzsh/myzsh-docker/pull/9

		if [[ "$event" == "push" ]]; then
			deleted="$(JSON.get /deleted jason)"
			whom="$(JSON.get -s /pusher/name jason)"
			repo="$(JSON.get -s /repository/name jason)"
			branch="$(basename "$(JSON.get -s /ref jason)")"
			if [[ "$deleted" != "true" ]]; then
				commits="commit"
				number=$(echo "$jason" | grep -cE "^/commits/[0-9]*/id" || true)
				force="$(JSON.get /forced jason)"
				[[ "$force" == "false" ]] && force="" || force="forced "
				url="$(JSON.get -s /compare jason)"
				msg=""
				if [[ "$number" -gt 1 ]]; then
					commits="commits"
				fi
				msg="\"$(JSON.get -s /head_commit/message jason || JSON.get /head_commit/message jason | sed -e 's/^"//g')\" "
				if [[ "$number" == 0 ]]; then
					number=1
				fi
				rpc "msg #myzsh [{purple}$repo{reset}/{purple}$branch{reset}] $whom ${force}pushed $number $commits ${msg}{blue}$url"
				if [[ "$repo" == "myzshbot" ]] && [[ "$branch" == "master" ]]; then
					rpc "msg #myzsh reloading modules"
					echo "HTTP/1.1 200 OK" >&$client
					echo "Content-type: text/plain" >&$client
					echo "Connection: close" >&$client
					echo "" >&$client
					echo "Reloading modules" >&$client
					ztcp -c $client
					http_reload
					return
				fi
			fi
		elif [[ "$event" == "pull_request" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			who="$(JSON.get -s /pull_request/user/login jason)"
			title="$(JSON.get /pull_request/title jason)"
			url="$(JSON.get -s /pull_request/html_url jason)"
			if [[ "$(JSON.get -s /action jason)" == "opened" ]]; then
				rpc "msg #myzsh [{purple}$repo{reset}] $who opened pull request $title {blue}$url"
			elif [[ "$(JSON.get -s /action jason)" == "labeled" ]]; then
				label="$(JSON.get /label/name jason)"
				rpc "msg #myzsh [{purple}$repo{reset}] $who labeled pull request $title as $label {blue}$url"
			fi
		elif [[ "$event" == "issue_comment" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			who="$(JSON.get -s /comment/user/login jason)"
			title="$(JSON.get /issue/title jason)"
			url="$(JSON.get -s /issue/html_url jason)"
			rpc "msg #myzsh [{purple}$repo{reset}] $who commented on issue $title {blue}$url"
		elif [[ "$event" == "pull_request_review_comment" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			who="$(JSON.get -s /comment/user/login jason)"
			title="$(JSON.get /pull_request/title jason)"
			url="$(JSON.get -s /comment/url jason)"
			rpc "msg #myzsh [{purple}$repo{reset}] $who commented on pull request $title {blue}$url"
		elif [[ "$event" == "page_build" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			buildstatus="$(JSON.get -s /build/status jason)"
			url="http://$(JSON.get -s /repository/name jason)"
			if [[ "$buildstatus" == "built" ]]; then
				rpc "msg #myzsh [{purple}$repo{reset}] {blue}$url{reset} rebuilt successfully."
			else
				rpc "msg #myzsh [{purple}$repo{reset}] {blue}$url{reset} page_build status $buildstatus."
			fi
		elif [[ "$event" == "create" ]]; then
			echo "ignoring $event"
		elif [[ "$event" == "delete" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			ref_type="$(JSON.get -s /ref_type jason)"
			ref="$(JSON.get -s /ref jason)"
			whom="$(JSON.get -s /sender/login jason)"
			rpc "msg #myzsh [{purple}$repo{reset}] $whom deleted $ref_type {purple}$ref{reset}."
		elif [[ "$event" == "repository" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			whom="$(JSON.get -s /sender/login jason)"
			action="$(JSON.get -s /action jason)"
			if [[ "$action" == "created" ]]; then
				rpc "msg #myzsh [{purple}$repo{reset}] $whom created repository."
			else
				rpc "msg #myzsh [{purple}$repo{reset}] $whom $action repository. TBD"
			fi
		elif [[ "$event" == "issues" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			action="$(JSON.get -s /action jason)"
			if [[ "$action" == "opened" ]]; then
				title="$(JSON.get -s /issue/title jason)"
				whom="$(JSON.get -s /sender/login jason)"
				number="$(JSON.get /issue/number jason)"
				url="$(JSON.get /issue/html_url jason)"
				rpc "msg #myzsh [{purple}$repo{reset}] $whom $action issue #$number \"$title\" $url"
			else
				rpc "msg #myzsh Event of type $event/$action: ${headers[X-Github-Delivery]}"
			fi
		elif [[ "$event" == "watch" ]]; then
			repo="$(JSON.get -s /repository/name jason)"
			whom="$(JSON.get -s /sender/login jason)"
			rpc "msg #myzsh [{purple}$repo{reset}] is now being watched by $whom"
		else
			rpc "msg #myzsh Event of type $event: ${headers[X-Github-Delivery]}"
		fi

	fi

	echo "HTTP/1.1 200 OK" >&$client
	echo "Content-type: text/plain" >&$client
	echo "Content-Length: 0" >&$client
	echo "Connection: close" >&$client
}