fix validation

cmd/tg/main.go

@@ -50,22 +50,8 @@ func main() {
 		*token = os.Getenv("TG_TOKEN")
 	}
 
-	if *token == "" {
-		logFatal("empty token")
-	}
-
-	if *chatID < 1 {
-		logFatal("invalid chat id")
-	}
-
-	if *text == "" {
-		logFatal("empty text")
-	}
-
 	if *text == "-" {
-		const maxTextSize int64 = 4096
-
-		stdin, err := io.ReadAll(io.LimitReader(os.Stdin, maxTextSize))
+		stdin, err := io.ReadAll(io.LimitReader(os.Stdin, int64(tg.MaxTextSize)))
 		if err != nil {
 			if !errors.Is(err, io.EOF) {
 				logFatal(err.Error())
@@ -92,9 +78,9 @@ func main() {
 	msg, err := tgb.SendMessage(ctx, *chatID, *text,
 		tg.ChatParseMode(tg.ParseMode(*parseMode)),
 		tg.ChatMessageThreadID(*messageThreadID),
-		tg.ChathDisableWebPagePreview(*disableWebPagePreview),
-		tg.ChathDisableNotification(*disableNotification),
-		tg.ChathProtectContent(*protectContent),
+		tg.ChatDisableWebPagePreview(*disableWebPagePreview),
+		tg.ChatDisableNotification(*disableNotification),
+		tg.ChatProtectContent(*protectContent),
 	)
 	if err != nil {
 		logFatal(err.Error())

tg.go

@@ -37,10 +37,15 @@ var parseModeList = []ParseMode{ //nolint:gochecknoglobals
 }
 
 var (
-	ErrInvalidScheme = errors.New("invalid scheme")
-	ErrEmptyHost     = errors.New("empty host")
-	ErrClientNil     = errors.New("client is nil")
-	ErrModeUnknown   = errors.New("unknown mode")
+	ErrInvalidScheme   = errors.New("invalid scheme")
+	ErrEmptyHost       = errors.New("empty host")
+	ErrClientNil       = errors.New("client is nil")
+	ErrModeUnknown     = errors.New("unknown mode")
+	ErrInvalidToken    = errors.New("invalid token")
+	ErrInvalidThreadID = errors.New("invalid thread id")
+	ErrInvalidChatID   = errors.New("invalid chat id")
+	ErrEmptyText       = errors.New("empty text")
+	ErrExceedsMaxText  = errors.New("exeeds max text")
 )
 
 // User .
@@ -79,29 +84,33 @@ func ChatParseMode(mode ParseMode) ChatOption {
 
 func ChatMessageThreadID(threadID int64) ChatOption {
 	return func(ch *Chat) error {
+		if threadID < 0 {
+			return ErrInvalidThreadID
+		}
+
 		ch.MessageThreadID = threadID
 
 		return nil
 	}
 }
 
-func ChathDisableWebPagePreview(disable bool) ChatOption {
+func ChatDisableWebPagePreview(disable bool) ChatOption {
 	return func(ch *Chat) error {
 		ch.DisableWebPagePreview = disable
 
 		return nil
 	}
 }
 
-func ChathDisableNotification(disable bool) ChatOption {
+func ChatDisableNotification(disable bool) ChatOption {
 	return func(ch *Chat) error {
 		ch.DisableNotification = disable
 
 		return nil
 	}
 }
 
-func ChathProtectContent(protect bool) ChatOption {
+func ChatProtectContent(protect bool) ChatOption {
 	return func(ch *Chat) error {
 		ch.ProtectContent = protect
 
@@ -135,7 +144,10 @@ func (r APIResponseError) Error() string {
 	return r.Description
 }
 
-var regexpBotToken = regexp.MustCompile(`/bot([\d]+):([\d\w]+)/`)
+var (
+	regexpBotToken = regexp.MustCompile(`/bot([\d]+):([\d\w]+)/`)
+	regexpToken    = regexp.MustCompile(`^([\d]+):([\d\w]+)$`)
+)
 
 type redactError struct {
 	err error
@@ -218,6 +230,10 @@ var defaultHTTPClient = &http.Client{
 
 // NewTG .
 func NewTG(token string, options ...Option) (*TG, error) {
+	if !regexpToken.MatchString(token) {
+		return nil, fmt.Errorf("TG: %w", ErrInvalidToken)
+	}
+
 	tg := &TG{
 		http:     nil,
 		endpoint: apiServer,
@@ -309,8 +325,22 @@ func (t *TG) GetMe(ctx context.Context) (*User, error) {
 	return user, nil
 }
 
+const MaxTextSize int = 4096
+
 // SendMessage .
 func (t *TG) SendMessage(ctx context.Context, chatID int64, text string, opts ...ChatOption) (*Message, error) {
+	if chatID < 1 {
+		return nil, fmt.Errorf("SendMessage: %w", ErrInvalidChatID)
+	}
+
+	if text == "" {
+		return nil, fmt.Errorf("SendMessage: %w", ErrEmptyText)
+	}
+
+	if len(text) > MaxTextSize {
+		return nil, fmt.Errorf("SendMessage: %w", ErrExceedsMaxText)
+	}
+
 	reader, err := t.makeMessage(chatID, text, opts...)
 	if err != nil {
 		return nil, fmt.Errorf("SendMessage: %w", err)