add CheckPrinter

build_lib.sh

@@ -1,7 +1,7 @@
 #!/bin/bash
 
 APP_NAME="libgofunc"
-VERSION="${1:-v0.1.9}"
+VERSION="${1:-v0.1.12}"
 OUTPUT_DIR="../assets"
 BUILD_DIR="../build"
 

img.go

@@ -14,6 +14,7 @@ import (
 	"strings"
 
 	"embed"
+	_ "time/tzdata"
 
 	"github.com/fogleman/gg"
 	"golang.org/x/image/font"
@@ -21,8 +22,6 @@ import (
 	"golang.org/x/net/html"
 
 	"encoding/json"
-
-	"github.com/kenshaw/escpos"
 )
 import (
 	"log"
@@ -376,30 +375,25 @@ func findNode(n *html.Node, tag string) *html.Node {
 	return nil
 }
 
-func printImg(prt *escpos.Escpos, imgPath string) error {
+func imgData(imgPath string) ([]byte, error) {
 	imgFile, err := os.Open(imgPath)
 	if err != nil {
 		fmt.Println(err)
-		return err
+		return nil, err
 	}
 
 	img, _, err := image.Decode(imgFile)
 	defer imgFile.Close()
 	if err != nil {
 		fmt.Println(err)
-		return err
+		return nil, err
 	}
 	data := []byte{0x1D, 0x4C, 0x00, 0x00}
-	_, err = prt.WriteRaw(data)
-	if err != nil {
-		fmt.Println("error 0x1D, 0x4C:", err.Error())
-	}
 
 	gray := toMonochrome(img)
-	data = escposRaster(gray)
-
-	_, err = prt.WriteRaw(data)
-	return err
+	imgData := escposRaster(gray)
+	data = append(data, imgData...)
+	return data, err
 }
 
 func LoadFont(size float64) (*font.Face, error) {
@@ -561,5 +555,11 @@ func formatDateFromSec(input any, layout string) string {
 		return "[Error: unsupported time type]"
 	}
 	t := time.UnixMilli(sec * 1000)
+
+	loc, err := time.LoadLocation("Asia/Rangoon")
+	if err != nil {
+		return fmt.Sprintf("[Error: unable to load TZ  %v]", err)
+	}
+	t = t.In(loc)
 	return t.Format(layout)
 }

printer.go

@@ -15,92 +15,122 @@ import (
 
 	"time"
 
+	"errors"
+
 	"github.com/kenshaw/escpos"
 )
-import "errors"
+import "io"
 
 //export PrintImg
 func PrintImg(printer *C.char, imagePath *C.char) *C.char {
 	goPrinter := C.GoString(printer)
 	goImagePath := C.GoString(imagePath)
-	// printer := "tcp:192.168.100.151:9100"
-	// printer := "usb:/dev/usb/lp1"
-	var w *bufio.ReadWriter
-	if strings.HasPrefix(goPrinter, "tcp:") {
-		location := strings.TrimLeft(goPrinter, "tcp:")
-		conn, err := net.Dial("tcp", location)
+	err := Print(goPrinter, goImagePath)
 	if err != nil {
-			log.Println("error dialing:", err.Error())
 		return NewErr(err)
 	}
+	return NewOk(nil)
+}
+
+//export CheckPrinter
+func CheckPrinter(printer *C.char) *C.char {
+	goPrinter := C.GoString(printer)
+	err := Check(goPrinter)
+	if err != nil {
+		return NewErr(err)
+	}
+	return NewOk(nil)
+}
+
+func Print(printer, imagePath string) error {
+	conn, err := connect(printer)
+	if err != nil {
+		return err
+	}
 	defer conn.Close()
-		w = bufio.NewReadWriter(bufio.NewReader(conn), bufio.NewWriter(conn))
-	} else if strings.HasPrefix(goPrinter, "usb:") {
-		location := strings.TrimLeft(goPrinter, "usb:")
-		f, err := os.OpenFile(location, os.O_RDWR, os.ModeDevice)
-		if err != nil {
-			log.Println("error OpenFile usb:", err.Error())
-			return NewErr(err)
-		}
-		defer f.Close()
-		w = bufio.NewReadWriter(bufio.NewReader(f), bufio.NewWriter(f))
-		// } else if strings.HasPrefix(goPrinter, "int:") {
-		// 	ctx := gousb.NewContext()
-		// 	// location := strings.TrimLeft(goPrinter, "int:")
-		// 	targetBus := 1
-		// 	targetAddr := 5
-		// 	devs, err := ctx.OpenDevices(func(desc *gousb.DeviceDesc) bool {
-		// 		return int(desc.Bus) == targetBus && int(desc.Address) == targetAddr
-		// 	})
-		// 	if err != nil || len(devs) == 0 {
-		// 		log.Fatal("Could not find or open the device")
-		// 	}
-		// 	dev := devs[0]
-		// 	defer dev.Close()
-		// 	dev.SetAutoDetach(true)
+	w := bufio.NewReadWriter(bufio.NewReader(conn), bufio.NewWriter(conn))
 
-		// 	// 2. Claim the default interface (usually 0 for printers)
-		// 	// Note: This may require detaching the kernel driver on Linux
-		// 	intf, done, err := dev.DefaultInterface()
-		// 	if err != nil {
-		// 		log.Fatalf("Failed to claim interface: %v", err)
-		// 	}
-		// 	defer done()
-
-		// 	// 3. Open the Bulk Output Endpoint (usually endpoint #1 or #2)
-		// 	// You may need to inspect desc.Endpoints to find the correct Bulk Out ID
-		// 	out, err = intf.OutEndpoint(1)
-		// 	if err != nil {
-		// 		log.Fatalf("Failed to open OUT endpoint: %v", err)
-		// 	}
-		// 	// w = bufio.NewReadWriter(bufio.NewReader(outPort), bufio.NewWriter(f))
-		// 	rw := &USBReadWriter{out: out}
-		// 	reader := bufio.NewReader(rw)
-		// 	writer := bufio.NewWriter(rw)
-		// 	w = bufio.NewReadWriter(reader, writer)
-	} else {
-		return NewErr(errors.New("invalid printer"))
-	}
 	prt := escpos.New(w)
 
 	prt.Init()
 	prt.SetSmooth(1)
 	prt.SetAlign("left")
 
-	err := printImg(prt, goImagePath)
+	imgBytes, err := imgData(imagePath)
 	if err != nil {
-		return NewErr(err)
+		return err
 	}
+	err = writeChunk(w, prt, imgBytes)
+	if err != nil {
+		return err
+	}
+	time.Sleep(500 * time.Millisecond)
+	w.Flush()
+
 	prt.WriteRaw([]byte{0x1B, 0x64, 0x03})
 	prt.Cut()
 	prt.End()
 	w.Flush()
 	time.Sleep(1 * time.Second)
-	return NewOk(nil)
+	return nil
 }
 
-func Print(printer, imagePath string) string {
-	result := PrintImg(C.CString(printer), C.CString(imagePath))
-	r := C.GoString(result)
-	return r
+func Check(printer string) error {
+	conn, err := connect(printer)
+	if err != nil {
+		return err
+	}
+	defer conn.Close()
+
+	var w *bufio.ReadWriter
+	w = bufio.NewReadWriter(bufio.NewReader(conn), bufio.NewWriter(conn))
+	prt := escpos.New(w)
+
+	prt.Init()
+	prt.SetSmooth(1)
+	prt.SetAlign("left")
+	time.Sleep(100 * time.Millisecond)
+	return w.Flush()
+}
+
+func connect(printer string) (io.ReadWriteCloser, error) {
+	if strings.HasPrefix(printer, "tcp:") {
+		location := strings.TrimLeft(printer, "tcp:")
+		conn, err := net.Dial("tcp", location)
+		if err != nil {
+			log.Println("error net.Dial tcp:", err.Error())
+			return nil, err
+		}
+		return conn, nil
+	} else if strings.HasPrefix(printer, "usb:") {
+		location := strings.TrimLeft(printer, "usb:")
+		f, err := os.OpenFile(location, os.O_RDWR, os.ModeDevice)
+		if err != nil {
+			log.Println("error os.OpenFile usb:", err.Error())
+			return nil, err
+		}
+		return f, nil
+	}
+	return nil, errors.New("invalid printer")
+}
+
+// writeChunk breaks the large byte array into smaller chunks
+func writeChunk(w *bufio.ReadWriter, prt *escpos.Escpos, data []byte) error {
+	chunkSize := 1024 // 1 KB chunks work best for network printers
+	for i := 0; i < len(data); i += chunkSize {
+		end := min(i+chunkSize, len(data))
+
+		_, err := prt.WriteRaw(data[i:end])
+		if err != nil {
+			log.Println("Error writing image chunk:", err)
+			return err
+		}
+		if err := w.Flush(); err != nil {
+			log.Println("Error flushing buffer:", err)
+			return err
+		}
+		// Give the printer's network chip a microsecond to breathe
+		time.Sleep(5 * time.Millisecond)
+	}
+	return nil
 }