enhancement: non blocking telegram api calls

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
 }