initial commit

Author: kardianos

coder.go

@@ -0,0 +1,114 @@
+package hl7
+
+import (
+	"fmt"
+	"reflect"
+	"strconv"
+	"strings"
+)
+
+type Registry map[string]any
+
+const tagName = "hl7"
+
+var empty []any
+var anyType = reflect.TypeOf(empty).Elem()
+
+type structType byte
+
+const (
+	structUnknown structType = iota
+	structTrigger
+	structTriggerGroup // Trigger Sub-Type
+	structSegment
+	structDataType
+)
+
+type tag struct {
+	Order      int32
+	Name       string
+	Format     string
+	Type       structType
+	Meta       bool
+	Child      bool
+	Omit       bool
+	NoEscape   bool
+	Sequence   bool
+	FieldSep   bool
+	FieldChars bool
+	Present    bool
+}
+
+const hl7MetaName = "HL7"
+
+func parseTag(fieldName, v string) (tag, error) {
+	t := tag{}
+	if len(v) == 0 {
+		return t, nil
+	}
+	t.Present = true
+	ss := strings.Split(v, ",")
+	s0 := ss[0]
+	sN := ss[1:]
+	if len(s0) > 0 {
+		i, err := strconv.ParseInt(s0, 10, 32)
+		if err != nil {
+			return t, fmt.Errorf("field %q: unable to parse tag position: %w", fieldName, err)
+		}
+		t.Order = int32(i)
+	}
+	switch fieldName {
+	case hl7MetaName:
+		t.Meta = true
+	}
+	for _, vv := range sN {
+		k, v, _ := strings.Cut(vv, "=")
+
+		switch k {
+		default:
+			return t, fmt.Errorf("field %q: unknown tag value %q", fieldName, vv)
+		case "name":
+			t.Name = v
+		case "type":
+			switch v {
+			default:
+				return t, fmt.Errorf("field %q: unknown type tag value %q", fieldName, vv)
+			case "t":
+				t.Type = structTrigger
+			case "tg":
+				t.Type = structTriggerGroup
+			case "s":
+				t.Type = structSegment
+			case "d":
+				t.Type = structDataType
+			}
+		case "format":
+			t.Format = v
+		case "child":
+			t.Child = true
+		case "noescape":
+			t.NoEscape = true
+		case "omit":
+			t.Omit = true
+		case "seq":
+			t.Sequence = true
+		case "required":
+			// TODO.
+		case "conditional":
+			// TODO.
+		case "len":
+			// TODO.
+		case "max":
+			// TODO.
+		case "display":
+			// TODO.
+		case "table":
+			// TODO.
+		case "fieldsep":
+			t.FieldSep = true
+		case "fieldchars":
+			t.FieldChars = true
+		}
+	}
+	return t, nil
+}

coder_test.go

@@ -0,0 +1,135 @@
+package hl7
+
+import (
+	"bytes"
+	"encoding/json"
+	"flag"
+	"os"
+	"path/filepath"
+	"testing"
+
+	v25 "github.com/kardianos/hl7/v25"
+	"github.com/sanity-io/litter"
+)
+
+var overwrite = flag.Bool("overwrite", false, "overwrite testing values with got values")
+
+func TestEncode(t *testing.T) {
+	msg := v25.MSH{
+		FieldSeparator:     `|`,
+		EncodingCharacters: `^~\&`,
+		VersionID: v25.VID{
+			VersionID: "2.5",
+		},
+	}
+
+	bb, err := Marshal(msg)
+	if err != nil {
+		t.Fatal(err)
+	}
+	bb = bytes.ReplaceAll(bb, []byte{'\r'}, []byte{'\n'})
+	t.Log(string(bb))
+}
+
+func TestDecode(t *testing.T) {
+	var raw = []byte(`MSH|^~\&||||||||||2.5^^|||||||||
+PID|1||||^Bob||||||||||||||||||||||||||||||||||
+NTE|1||testing the system comments here|||
+NTE|2||more comments here|||
+OBR|1|ABC||||||||||||||1234^Acron^Smith~5678^Beta^Zeta|||||||||||||||||||||||||||||||||||||||||||
+OBR|2|XYZ||||||||||||||903^Blacky|||||||||||||||||||||||||||||||||||||||||||`)
+
+	v, err := Unmarshal(raw, v25.SegmentRegistry)
+	if err != nil {
+		t.Fatal(err)
+	}
+	data, err := json.MarshalIndent(v, "", "\t")
+	if err != nil {
+		t.Fatal(err)
+	}
+	_ = data
+}
+func TestGroup(t *testing.T) {
+	flag.Parse()
+	var raw = []byte(`MSH|^~\&|DX_LAB|Hematology|WPX||20070305170957||ORL^O34^ORL_O34|2|P|2.5||||||8859/1|||
+MSA|AA|161||||
+`)
+
+	v, err := Unmarshal(raw, v25.SegmentRegistry)
+	if err != nil {
+		t.Fatal(err)
+	}
+	root, err := Group(v, v25.TriggerRegistry)
+	if err != nil {
+		t.Fatal(err)
+	}
+	rt, err := Marshal(root)
+	if err != nil {
+		t.Fatal(err)
+	}
+	rt = bytes.ReplaceAll(rt, []byte{'\r'}, []byte{'\n'})
+	if bytes.Equal(rt, raw) {
+		t.Fatal("mismatch")
+	}
+}
+
+func printTypes(t *testing.T, list []any) {
+	for _, item := range list {
+		t.Logf("type %T", item)
+	}
+}
+
+func (w *walker) printLinear(t *testing.T) {
+	for index, item := range w.list {
+		t.Logf("linear[%d] %s leaf=%t inArray=%t", index, item.Type.String(), item.Leaf, item.InArray)
+	}
+}
+
+func TestRoundTrip(t *testing.T) {
+	fsDir := filepath.Join("testdata", "roundtrip")
+	dirList, err := os.ReadDir(fsDir)
+	if err != nil {
+		t.Fatal(err)
+	}
+	c := &litter.Options{
+		HideZeroValues:    true,
+		HidePrivateFields: true,
+		Separator:         " ",
+	}
+	_ = c
+	for _, f := range dirList {
+		if f.IsDir() {
+			continue
+		}
+		t.Run(f.Name(), func(t *testing.T) {
+			fn := filepath.Join(fsDir, f.Name())
+			bb, err := os.ReadFile(fn)
+			if err != nil {
+				t.Fatal(err)
+			}
+
+			v, err := Unmarshal(bb, v25.SegmentRegistry)
+			if err != nil {
+				t.Fatal("unmarshal", err)
+			}
+
+			root, err := Group(v, v25.TriggerRegistry)
+			if err != nil {
+				t.Fatal("group", err)
+			}
+
+			rt, err := Marshal(root)
+			if err != nil {
+				t.Fatal("marshal", err)
+			}
+			rt = bytes.ReplaceAll(rt, []byte{'\r'}, []byte{'\n'})
+			if *overwrite {
+				os.WriteFile(fn, rt, 0600)
+			}
+			d := lineDiff(bb, rt)
+			if len(d) > 0 {
+				t.Fatalf("mismatch\n%s", d)
+			}
+		})
+	}
+}