Line 50: |
Line 50: |
| | | |
| context = zmq.Context.instance() | | context = zmq.Context.instance() |
− | | + | |
| # Create a zmq socket that will SUBscribe to door nodes. | | # Create a zmq socket that will SUBscribe to door nodes. |
| door_socket = context.socket(zmq.SUB) | | door_socket = context.socket(zmq.SUB) |
Line 56: |
Line 56: |
| door_socket.connect("tcp://backdoor.pumpingstationone.org:5556") | | door_socket.connect("tcp://backdoor.pumpingstationone.org:5556") |
| door_socket.setsockopt(zmq.SUBSCRIBE, b"door.state.unlock") | | door_socket.setsockopt(zmq.SUBSCRIBE, b"door.state.unlock") |
− |
| + | |
| # create a zmq socket that will PUSH data to our IRC actuator node. | | # create a zmq socket that will PUSH data to our IRC actuator node. |
| zirc_socket = context.socket(zmq.PUSH) | | zirc_socket = context.socket(zmq.PUSH) |
| zirc_socket.connect('tcp://sally.ad.pumpingstationone.org:5558') | | zirc_socket.connect('tcp://sally.ad.pumpingstationone.org:5558') |
− | | + | |
| # Loop forever | | # Loop forever |
| while True: | | while True: |
− | | + | |
| # Read messages from the doors | | # Read messages from the doors |
| topic, message = door_socket.recv_multipart() | | topic, message = door_socket.recv_multipart() |
− | | + | |
| # Send the message to the irc channel | | # Send the message to the irc channel |
| zirc.send(message) | | zirc.send(message) |