Package ASTM

This package was forked from base package. I express my deep gratitude to the author. My goal is to complement the project for my own purposes, which may help you apply this in your work.

This is a basic implentation of an ASTM host interface, simplifying the creation of of bi-directional interfaces between ASTM-compliant analysers and a LIMS/LIS by abstracting the protocol behind familiar interfaces.

Because Listen() wraps any io.ReadWriteCloser, the library works with serial or TCP interfaces.

Description of commits

Name	Description
build	Building a project or changing external dependencies
sec	Security
docs	Update documentation
feat	Add a new features
fix	Fixing errors
perf	Changes aimed at improving performance
refactor	Code edits without correcting errors or adding new features
revert	Rollback to previous commits
style	Code style edits (tabs, indents, dots, commas, etc.)
test	Add the tests

Examples

Single-directional Serial communication

Full example (using go-serial package):

func main() {
	baud := 9600
	parity := 0
	stopBit := 2
	dataBit := 8

	mode := &serial.Mode{
		BaudRate: baud,
		StopBits: serial.StopBits(stopBit),
		Parity:   serial.Parity(parity),
		DataBits: dataBit,
	}

	p, err := serial.Open("/dev/ttyS0", mode)
	if err != nil {
		log.Fatal(err)
	}

	conn := astm.Listen(p)
	defer conn.Close()

	for {
		tx, err := conn.Acknowledge()
		if err != nil {
			fmt.Println(err)
			return
		}

		for {
			buf := make([]byte, 248)
			n, err := tx.Read(buf)
			if err == io.EOF {
				break
			}
			if err != nil {
				return
			}
			fmt.Println(string(buf[:n]))
		}
	}
}

// Example output:
// H|\^&||||||||||P||
// O|1|MySample|36^0044^2^^SAMPLE^NORMAL|ALL|R|20050705093416|||||X||||||||||||||O
// R|1|^^^245^^0|22.50|pmol/l|18.94^27.26|N||F|||20230602184928|20230602190748|
// R|3|^^^182^^0|8.71|uIU/ml|7.78^10.52|N||F|||20230602184804|20230602190624|
// L|1|

Bi-directional communication (template)

// ...
tx, err := conn.RequestControl()
if err != nil {
    // ...
}

myFrames := [][]byte{/* ... */}

for _, f := range myFrames {
    _, err := tx.Write(f)
    if err != nil {
        switch {
        case errors.Is(err, astm.ErrNotAcknowledged):
        //...
        default:
        //...
        }
    }
    //...
}

tx.Close()
// ...