class Zurl < Formula desc "HTTP and WebSocket client worker with ZeroMQ interface" homepage "https://github.com/fanout/zurl" url "https://dl.bintray.com/fanout/source/zurl-1.9.0.tar.bz2" sha256 "c97f430f9f815c3a8d9758e7611054224908727af938a28e0eef700add02e1dc" revision 1 bottle do cellar :any sha256 "eaac2e5b2f52a95cce831b6a96c6ec28dfb5f85fc599aef901d7436b3eb86154" => :high_sierra sha256 "4e54b0684783343bd3ded9ff5f116e3bbeacdc5f6cc8edf06208a0541715df26" => :sierra sha256 "d3daa46721f6b1c2e624e6704716085706e55e47a0125dac4ba3449a60fa4d42" => :el_capitan end depends_on "pkg-config" => :build depends_on "curl" if MacOS.version < :lion depends_on "qt" depends_on "zeromq" resource "pyzmq" do url "https://files.pythonhosted.org/packages/1e/f9/d0675409c11d11e549e3da000901cfaabd848da117390ee00030e14bfdb6/pyzmq-16.0.3.tar.gz" sha256 "8a883824147523c0fe76d247dd58994c1c28ef07f1cc5dde595a4fd1c28f2580" end def install system "./configure", "--prefix=#{prefix}", "--extraconf=QMAKE_MACOSX_DEPLOYMENT_TARGET=#{MacOS.version}" system "make" system "make", "check" system "make", "install" end test do conffile = testpath/"zurl.conf" ipcfile = testpath/"zurl-req" runfile = testpath/"test.py" resource("pyzmq").stage { system "python", *Language::Python.setup_install_args(testpath/"vendor") } conffile.write(<<~EOS [General] in_req_spec=ipc://#{ipcfile} defpolicy=allow timeout=10 EOS ) runfile.write(<<~EOS import json import threading from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer import zmq class TestHandler(BaseHTTPRequestHandler): def do_GET(self): self.send_response(200) self.end_headers() self.wfile.write('test response\\n') port = None def server_worker(c): global port server = HTTPServer(('', 0), TestHandler) port = server.server_address[1] c.acquire() c.notify() c.release() try: server.serve_forever() except: server.server_close() c = threading.Condition() c.acquire() server_thread = threading.Thread(target=server_worker, args=(c,)) server_thread.daemon = True server_thread.start() c.wait() c.release() ctx = zmq.Context() sock = ctx.socket(zmq.REQ) sock.connect('ipc://#{ipcfile}') req = {'id': '1', 'method': 'GET', 'uri': 'http://localhost:%d/test' % port} sock.send('J' + json.dumps(req)) poller = zmq.Poller() poller.register(sock, zmq.POLLIN) socks = dict(poller.poll(15000)) assert(socks.get(sock) == zmq.POLLIN) resp = json.loads(sock.recv()[1:]) assert('type' not in resp) assert(resp['body'] == 'test response\\n') EOS ) pid = fork do exec "#{bin}/zurl", "--config=#{conffile}" end begin ENV["PYTHONPATH"] = testpath/"vendor/lib/python2.7/site-packages" system "python", runfile ensure Process.kill("TERM", pid) Process.wait(pid) end end end