Scanner with LF thing to prevent partial scanning
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"bufio"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"flag"
|
"flag"
|
||||||
"fmt"
|
"fmt"
|
||||||
@@ -49,7 +50,7 @@ func main() {
|
|||||||
serialConfig := &serial.Config{
|
serialConfig := &serial.Config{
|
||||||
Name: cfg.Port,
|
Name: cfg.Port,
|
||||||
Baud: cfg.BaudRate,
|
Baud: cfg.BaudRate,
|
||||||
ReadTimeout: time.Second * 2,
|
ReadTimeout: 0,
|
||||||
}
|
}
|
||||||
|
|
||||||
port, err := serial.OpenPort(serialConfig)
|
port, err := serial.OpenPort(serialConfig)
|
||||||
@@ -62,22 +63,16 @@ func main() {
|
|||||||
fmt.Printf("Listening on %s (Baud: %d)...\n", cfg.Port, cfg.BaudRate)
|
fmt.Printf("Listening on %s (Baud: %d)...\n", cfg.Port, cfg.BaudRate)
|
||||||
fmt.Printf("Sending data to: %s\n", cfg.URL)
|
fmt.Printf("Sending data to: %s\n", cfg.URL)
|
||||||
|
|
||||||
buf := make([]byte, 128)
|
scanner := bufio.NewScanner(port)
|
||||||
for {
|
for scanner.Scan() {
|
||||||
n, err := port.Read(buf)
|
content := strings.TrimSpace(scanner.Text())
|
||||||
if err != nil {
|
if content != "" {
|
||||||
if err != io.EOF {
|
sendToEndpoint(cfg.URL, content)
|
||||||
fmt.Printf("Read error: %v\n", err)
|
|
||||||
}
|
|
||||||
continue
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if n > 0 {
|
if err := scanner.Err(); err != nil {
|
||||||
content := strings.TrimSpace(string(buf[:n]))
|
fmt.Printf("Scanner error: %v\n", err)
|
||||||
if content != "" {
|
|
||||||
sendToEndpoint(cfg.URL, content)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -127,7 +122,6 @@ func sendToEndpoint(baseURL, content string) {
|
|||||||
}
|
}
|
||||||
defer resp.Body.Close()
|
defer resp.Body.Close()
|
||||||
|
|
||||||
// Read the response body
|
|
||||||
body, err := io.ReadAll(resp.Body)
|
body, err := io.ReadAll(resp.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("Error reading response: %v\n", err)
|
fmt.Printf("Error reading response: %v\n", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user