maildb.go

package main

import (
	"fmt"
	"io/ioutil"
	"net/http"
	"strings"
	"time"

	config "github.com/mailway-app/config"

	"github.com/pkg/errors"
)

const (
	MAIL_STATUS_DELIVERED      = 2
	MAIL_STATUS_DELIVERY_ERROR = 4
)

func updateMailStatus(jwt string, domain string, uuid string, status int) error {
	client := &http.Client{
		Timeout: 5 * time.Second,
	}
	url := fmt.Sprintf("http://127.0.0.1:%d/db/domain/%s/update/%s", config.CurrConfig.PortMaildb, domain, uuid)
	body := fmt.Sprintf("{\"status\":%d}", status)
	req, err := http.NewRequest(http.MethodPut, url, strings.NewReader(body))
	if err != nil {
		return err
	}

	req.Header.Set("Authorization", "Bearer "+jwt)
	res, err := client.Do(req)
	if err != nil {
		return err
	}

	defer res.Body.Close()

	if res.StatusCode != 200 {
		bodyBytes, err := ioutil.ReadAll(res.Body)
		if err != nil {
			return errors.Wrap(err, "could not read response body")
		}
		return errors.Errorf("maildb returned code %d: %s", res.StatusCode, bodyBytes)
	}
	return nil
}