Serial Server and Serial Client

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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
-- Aliases
TxData = Controls.TxData  -- alias for the TxData control
RxData = Controls.RxData  -- alias for the RxData control


-- Constants
Serial = SerialServerPorts[1]  -- Create new Serial Server object
Server = TcpSocket.New()  -- Create a TCP socket
IPAddress = "127.0.0.1"  -- variable that will be used for the TCP IP address
Port = 4888  -- variable that will be used for the TCP port


-- Functions
function IncData(data)  -- function that reads data passed through and increments by one or sets to one if > 9
  print("Incomming Data: "..data)
  RxData.Value = data  -- set the RxData control to the incoming value
  if data > 9 then data = 1.0 else data = data + 1 end  -- evaluates data and gives it a new value
  print("Sent Data: "..data)
  TxData.Value = data  -- set the TxData control to the new value of data
  return data  -- returns the new value of data
end

function ParseResponse()  -- function that reads the SerialServer port and writes it to the TCP socket
  local data = tonumber(Serial:Read(Serial.BufferLength))  -- read the SerialServer port
  if Server.IsConnected then Server:Write(IncData(data)) end  -- write to the TCP socket if it's connected
end

function Initialization()  -- function called at the start of runtime
  Server:Connect(IPAddress,Port)  -- connect the TCP socket
  print("TCP Socket Connecting to: "..IPAddress..":"..Port)
end


-- Serial Server Callbacks
Serial.OnOpen = function(baud,databits,parity)  -- function called when the SerialServer is opened
  print("Virtual Serial Port Connected | Baud: "..baud.." Data Bits: "..databits.." Parity: "..parity)
  Serial:Event(SerialPorts.Events.Connected)  -- connected event sent to serial client
end

Serial.OnClose = function()  -- function called when the SerialServer port closes
  print("Virtual Serial Port Closed")
  Serial:Event(SerialPorts.Events.Closed)  -- closed event sent to serial client
end

Serial.Data = ParseResponse  -- ParseResponse is called when Serial has data


-- TCP Socket Callbacks
Server.Connected=function()  -- function called when the TCP socket is connected
  print("TCP Socket Connected to: "..IPAddress..":"..Port)
end

Server.Reconnect=function()  -- function called when the TCP socket is reconnected
  print("TCP Socket Reconnecting to: "..IPAddress..":"..Port)
end

Server.Data=function()  -- function called when the TCP socket has data
  print("TCP Socket has data")
end

Server.Closed=function()  -- function called when the TCP socket is closed
  print("TCP Socket Closed")
end

Server.Error=function(server,err)  -- function called when the TCP socket has an error
  print("TCP Socket has an Error: "..err)
end

Server.Timeout=function()  -- function called when the TCP socket times out
  print("TCP Socket has Timedout")
end


-- Start at runtime
Initialization()  -- calls the Initialization function at the start of runtime

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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
-- Aliases
Send = Controls.Send
Count = Controls.Count
AutoSend = Controls.AutoSend


-- Constants
Poll = Timer.New()  -- create new timer object
PollTime = 1  -- variable that will be used when starting a timer and setting the timer 
Server = TcpSocketServer.New()  -- create new TCP server object
Port = 4888  -- variable that will be used when defining the TCP port
Serial = SerialPorts[1]  -- create new SerialPort object
Baud = 9600  -- variable that will be used for the baud rate
DataBits = 8  -- variable that will be used for the data bits
Parity = "N"  -- variable that will be used for parity


-- Functions
function SendData()  -- function to write to the serial port if it is open
  print("Sending: "..Count.Value)
  if Serial.IsOpen then Serial:Write(Count.Value) end
end

function ParseResponse(TcpSocket)  -- function to read the TCP socket
  local data = tonumber(TcpSocket:Read(TcpSocket.BufferLength))
  if data then print("Recieved Data: "..data) Count.Value = data end
end

function SetPollTimer()  -- function to start/stop the poll timer
  if AutoSend.Boolean == true then SendData() Poll:Start(PollTime) else Poll:Stop() end
end

function SocketHandler(TcpSocket,event) -- function that sets the TCP socket instance data callback to the ParseResponse function 
  TcpSocket.Data = ParseResponse
  print("Sock "..event)
end

function Initialization()  -- function that is called at the start of runtime
  print("Initializing plugin")
  Serial:Open(Baud,DataBits,Pairty)  -- Open the serial port
  print("Opening Serial Port | Baud: "..Baud.." Data Bits: "..DataBits.." Parity: "..Parity)
  Server:Listen(Port) -- This listen port is opened on all network interfaces
  print("TCP Socket Server listening on port: "..Port)
end


-- Serial Port Callbacks
Serial.Connected=function()  -- functin called when the serial port is connected
  print("Serial Port Open")
  SetPollTimer()  -- calls SetPollTimer when the serial port is connected
end

Serial.Reconnect=function()
  print("Serial Port Reconnecting")
end

Serial.Data=function(serial,data)
  print("Serial Port has data: "..data)
end

Serial.Closed=function()
  print("Serial Port Closed")
end

Serial.Error=function(serial,err)
  print("Serial Port Error: "..err)
end

Serial.Timeout=function(serial,err)
  print("Serial Port Timeout: "..err)
end


-- EventHandlers
Server.EventHandler = function(TcpSocket) -- the properties of this socket instance are those of the TcpSocket library
  print("TCP Server connected on port: "..Port)
  TcpSocket.EventHandler = SocketHandler  -- sets TCP socket instance EventHandler to call the SocketHandler function
end

AutoSend.EventHandler = SetPollTimer
Send.EventHandler = SendData
Poll.EventHandler = SendData


-- Start at Runtime
Initialization()