Merge pull request #16 from palavrapasse/15-enhancement-non-blocking-…

…telegram-api-calls enhancement: non blocking telegram api calls
palavrapasse · Feb 11, 2023 · c1778dc · c1778dc
2 parents ef0808f + 1984bd5
commit c1778dc
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 4 deletions.
diff --git a/go.sum b/go.sum
diff --git a/pkg/telegramwriter.go b/pkg/telegramwriter.go
@@ -12,6 +12,8 @@ type TelegramWriter struct {
 	chatId   string
 }
 
+var resultChan = make(chan *http.Response)
+
 func (tw TelegramWriter) Write(p []byte) (n int, err error) {
 
 	body, err := json.Marshal(map[string]string{
@@ -25,13 +27,25 @@ func (tw TelegramWriter) Write(p []byte) (n int, err error) {
 
 	url := fmt.Sprintf("https://api.telegram.org/bot%s/sendMessage", tw.botToken)
 
+	go asyncPost(url, body, resultChan)
+
+	response := <-resultChan
+	defer func() {
+		if response != nil && response.Body != nil {
+			response.Body.Close()
+		}
+	}()
+
+	return len(p), nil
+}
+
+func asyncPost(url string, body []byte, rc chan *http.Response) {
 	response, err := http.Post(url, messageType, bytes.NewBuffer(body))
 
 	if err != nil {
-		return 0, err
+		rc <- response
+		return
 	}
 
-	defer response.Body.Close()
-
-	return len(p), nil
+	rc <- response
 }