|
|
@ -7,6 +7,7 @@ package main
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"bufio"
|
|
|
|
"bufio"
|
|
|
|
"crypto/tls"
|
|
|
|
"crypto/tls"
|
|
|
|
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"io"
|
|
|
|
"io"
|
|
|
|
"log"
|
|
|
|
"log"
|
|
|
@ -38,13 +39,13 @@ func readMessage(messageFilePath string) (string, error) {
|
|
|
|
// Check that message file is existing.
|
|
|
|
// Check that message file is existing.
|
|
|
|
_, err = os.Stat(messageFilePath)
|
|
|
|
_, err = os.Stat(messageFilePath)
|
|
|
|
if os.IsNotExist(err) {
|
|
|
|
if os.IsNotExist(err) {
|
|
|
|
return output, err
|
|
|
|
return output, fmt.Errorf("readMessage: %w", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Open message file.
|
|
|
|
// Open message file.
|
|
|
|
file, err := os.Open(messageFilePath)
|
|
|
|
file, err := os.Open(messageFilePath)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return output, err
|
|
|
|
return output, fmt.Errorf("readMessage: %w", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
scanner := bufio.NewScanner(file)
|
|
|
|
scanner := bufio.NewScanner(file)
|
|
|
|
scanner.Split(bufio.ScanLines)
|
|
|
|
scanner.Split(bufio.ScanLines)
|
|
|
@ -56,9 +57,9 @@ func readMessage(messageFilePath string) (string, error) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if err := scanner.Err(); err != nil {
|
|
|
|
if err := scanner.Err(); errors.Unwrap(err) != nil {
|
|
|
|
if err != io.EOF {
|
|
|
|
if err != io.EOF {
|
|
|
|
return "", err
|
|
|
|
return "", fmt.Errorf("readMessage: %w", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -67,7 +68,7 @@ func readMessage(messageFilePath string) (string, error) {
|
|
|
|
fmt.Println("error while closing file:", err)
|
|
|
|
fmt.Println("error while closing file:", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return output, err
|
|
|
|
return output, fmt.Errorf("readMessage: %w", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func main() {
|
|
|
|
func main() {
|
|
|
|