ipc-examples/crystal/src/pongd.cr

require "option_parser"
require "ipc"
require "./colors"

verbosity = 1
service_name = "pong"
no_response = false

OptionParser.parse do |parser|
	parser.on "-s service_name", "--service-name service_name", "URI" do |optsn|
		service_name = optsn
	end

	parser.on "-n", "--no-response", "Do not provide any response back." do
		no_response = true
	end

	parser.on "-v verbosity", "--verbosity verbosity", "Verbosity (0 = nothing is printed, 1 = only events, 2 = events and messages). Default: 1" do |optsn|
		verbosity = optsn.to_i
	end

	parser.on "-h", "--help", "Show this help" do
		puts parser
		exit 0
	end
end

service = IPC::Server.new (service_name)
service.base_timer = 5000 # 5 seconds
service.timer      = 5000 # 5 seconds

service.loop do |event|
	case event
	when IPC::Event::Timer
		if verbosity >= 1
			puts "#{CORANGE}IPC::Event::Timer#{CRESET}"
		end
	when IPC::Event::Connection
		if verbosity >= 1
			puts "#{CBLUE}IPC::Event::Connection#{CRESET}, client: #{event.fd}"
		end
	when IPC::Event::Disconnection
		if verbosity >= 1
			puts "#{CBLUE}IPC::Event::Disconnection#{CRESET}, client: #{event.fd}"
		end
	when IPC::Event::MessageSent
		begin
			if verbosity >= 1
				puts "#{CGREEN}IPC::Event::MessageSent#{CRESET}, client: #{event.fd}"
			end
		rescue e
			puts "#{CRED}#{e.message}#{CRESET}"
			service.remove_fd event.fd
		end
	when IPC::Event::MessageReceived
		begin
			if verbosity >= 1
				puts "#{CGREEN}IPC::Event::MessageReceived#{CRESET}, client: #{event.fd}"
				if verbosity >= 2
					m = String.new event.message.payload
					puts "#{CBLUE}message type #{event.message.utype}: #{m} #{CRESET}"
				end
			end
			service.send event.message unless no_response
			if verbosity >= 2 && ! no_response
				puts "#{CBLUE}sending message...#{CRESET}"
			end

		rescue e
			puts "#{CRED}#{e.message}#{CRESET}"
			service.remove_fd event.fd
		end
	else
		if verbosity >= 1
			puts "#{CRED}Exception: message #{event} #{CRESET}"
		end
	end
end