bloodlabnet

Go BloodLab Net

A libarary to simplify communication with laboratory instruments.

go get github.com/DRK-Blutspende-BaWueHe/go-bloodlab-net

• TCP/IP Server implementation
• TCP/IP Client implementation
• FTP Client implementation
• Low-level protocols :
  • RAW protocol.Raw()
  • STX-ETX protocol.STXETX()
  • MLLP (for HL7) protocol.MLLP()
  • Lis1A1 protocol.Lis1A1()

TCP/IP Client

Create a client to send data.

 tcpClient := CreateNewTCPClient("127.0.0.1", 4001, protocol.Raw(), NoLoadBalancer)

 if err := tcpClient.Connect(); err != nil {  
   log.Panic(err)
 }

 n, err := tcpClient.Send([]byte("Hello TCP/IP"))

 receivedMsg, err := tcpClient.Receive()

TCP/IP Server

package main

import (
	"fmt"
	"time"

	bloodlabnet "github.com/DRK-Blutspende-BaWueHe/go-bloodlab-net"
	"github.com/DRK-Blutspende-BaWueHe/go-bloodlab-net/protocol"
)

type MySessionHandler struct {
}

func (s *MySessionHandler) Connected(session bloodlabnet.Session) {
	fmt.Println("Disconnected Event")
}

func (s *MySessionHandler) Disconnected(session bloodlabnet.Session) {
	fmt.Println("Disconnected Event")
}

func (s *MySessionHandler) Error(session bloodlabnet.Session, errorType bloodlabnet.ErrorType, err error) {
	fmt.Println(err)
}

func (s *MySessionHandler) DataReceived(session bloodlabnet.Session, data []byte, receiveTimestamp time.Time) {
	
  rad, _ := session.RemoteAddress()
	fmt.Println("From %s received : ", rad, string(data))
	
  session.Send([]byte(fmt.Sprintf("You are sending from %s", rad)))
}

func main() {

	server := bloodlabnet.CreateNewTCPServerInstance(4009,
		protocol.STXETX(),
		bloodlabnet.HAProxySendProxyV2,
		100) // Max Connections

	server.Run(&MySessionHandler{})
}

SFTP Client

Connect as a client to an existing sftp server and keep polling.

CreateFTP(ftptype, host, port, directory, filemask, config)

ftptype

• FTP for ftp server
• SFTP for sftp server

Example

 
 func (h *myhandler)DataReceived(session Session, data []byte) {

 }

func main() {
 
 var hander myhandler

   server := CreateSFTPClient(SFTP, "localhost", 25, "/sourcefolder", "*.dat",
     DefaultFTPConfig()
     .UserPass("Istvan", "Pass")
     .HostKey("ajsdflkasjflksajklfjaslfjlksadfj")
	 .PollInterval(60 * Duration.Seconds)
	 .DialTimeout(10 * Duration.Seconds)
	 .DontDeleteAfterRead()
   )

	server, err := bnet.CreateSFTPClient(bnet.SFTP, "172.23.114.30", 22, "/tests", "*.dat",
		bnet.DefaultFTPConfig().UserPass("test", "testpaul").PollInterval(5*time.Second),
	)

    server.Run(handler)

	data := [][]byte{[]byte("Dolor sit amed"), []byte("This is the 2nd line")}

    // sending the file to ftp server with autogenerated names
	server.Send(data)

  server.Close()
}

Configruation

Start with DefaultFTPConfig() and continue with fluentapi

• PollInterval(pollInterval time.Duration)
• DeleteAfterRead()
• DontDeleteAfterRead()
• LineBreakCR()
• LineBreakCRLF()
• LineBreakLF()
• DialTimeout(dialTimeout time.Duration)
• FilenameGeneratorPattern(pattern string)
• FilenameGeneratorPrefix(prefix string)
• NoFilenamePrefix()
• FilenameGeneratorSuffix(suffix string)
• NoFilenameSuffix()

Protocols

Raw Protocol (TCP/Client + TCP/Server)

Raw communication for tcp-ip.

STX-ETX Protocol (TCP/Client + TCP/Server)

Mesasge are embedded in (Ascii 0x02) and (Ascii 0x03) to indicate start and end. At the end of each transmission the transmissions contents are passed further for higher level protocols.

 .... <STX>Some data<ETX> This data here is ignored <STX>More data<ETX> ....

MLLP Protocol (TCP/Client + TCP/Server)

Mesasge are embedded in (Ascii 11) and (Ascii 28) terminated with (Ascii 13) to indicate start and end. At the end of each transmission the transmissions contents are passed further for higher level protocols.

 .... <VT>Some data<FS><CR> This data here is ignored <VT>More data<FS><CR> ....

For some vendors start/stop - bytes might be altered. In that case you can use DefaultMLLPProtocolSettings and use SetStartByte and SetStopByte to change them.

tcpServer := bloodlabnet.CreateNewTCPServerInstance(config.TCPListenerPort,
  bloodlabnetProtocol.MLLP(bloodlabnetProtocol.DefaultMLLPProtocolSettings().SetStartByte(0)),
  bloodlabnet.HAProxySendProxyV2, config.TCPServerMaxConnections)

Lis1A1 Protocol (TCP/Client + TCP/Server)

Lis1A1 is a low level protocol for submitting data to laboratory instruments, typically via serial line.

au6xx Protocol (TCP/Client + TCP/Server)

The au6xx is the low-level protocol required for connecting to Beckman&Coulter AU6xx systems.

TCP/IP Server Configuration

Connection timeout

Portscanners or Loadbalancers do connect just to disconnect a second later. By default the session initiation happens not on connect, rather when the first byte is sent.

Notice that certain instruments require the connection to remain opened, even if there is no data.

Disable the connection-timeout

config := DefaultTCPServerSettings
config.SessionAfterFirstByte = false // Default: true

Require the first Byte to be sent within a timelimit

config := DefaultTCPServerSettings
config.SessionInitationTimeout = time.Second * 3  // Default: 0

Add low-level Logging : Protcol-Logger

Logging can be added to any protocol by wrapping the Protocol into the logger. This does not affect the functionality. In addition set the environment-variable PROTOLOG_ENABLE to true.

PROTOLOG_ENABLE = (traffic|extended)

1. traffic = logs only the
2. extended = would log the traffic plus the states of the FSM

set PROTOLOG_ENABLE=extended

tcpServer := bloodlabnet.CreateNewTCPServerInstance(config.TCPListenerPort,
  bloodlabnetProtocol.Logger(
    bloodlabnetProtocol.MLLP(bloodlabnetProtocol.DefaultMLLPProtocolSettings().SetStartByte(0))
  ),
  bloodlabnet.HAProxySendProxyV2, config.TCPServerMaxConnections)