raspi_nrf_python/client_radio.tac at master · rishenko/raspi_nrf_python · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
import threading, queue
from sb import util, processor
from sb.network.receiving import ReceivingProtocolFactory, ReceivingProtocol
from sb.network.websocket import SensorDataClientFactory, SensorDataClientProtocol
from twisted.application import service, internet

from twisted.internet import reactor, task
from twisted.application import internet
from twisted.internet.endpoints import clientFromString
from sb.util import Log

from autobahn.twisted.websocket import connectWS

globalLog = Log().buildLogger()

globalLog.info("Building Processor")
dataProcessor = processor.SensorDataProcessor()
dataProcessor.addConsumer(processor.DatabaseProcessor(queue.Queue()))
dataProcessor.addConsumer(processor.WebServiceProcessor())

globalLog.info("Building Protocols and Factories")
recFactory = ReceivingProtocolFactory()
recFactory.addConsumer(dataProcessor) # processor consumes incoming socket data

wsFactory = SensorDataClientFactory("ws://echo.websocket.org")
dataProcessor.addConsumer(wsFactory) # WS consumes processed reading objs

globalLog.info("About to start the application server")
application = service.Application("radio server")
#internet.TCPClient('104.59.236.94', 1025, recFactory).setServiceParent(application)
internet.TCPClient('192.168.1.68', 1025, recFactory).setServiceParent(application)
#internet.TCPClient('192.168.1.148', 1025, recFactory).setServiceParent(application)
connectWS(wsFactory)

#Run with: twistd -noy client_radio.tac