mailcow-admin-aliases/internal/mailcow/aliases.go

package mailcow

import (
	"encoding/json"
	"fmt"
	"io"
	"log/slog"
	"net/http"
	"time"

	"code.lila.network/adoralaura/mailcow-admin-aliases/internal/configuration"
)

type MailcowAlias struct {
	ID             int    `json:"id"`
	Domain         string `json:"domain"`
	PublicComment  string `json:"public_comment"`
	PrivateComment string `json:"private_comment"`
	Goto           string `json:"goto"`
	Address        string `json:"address"`
	IsCatchAll     int    `json:"is_catch_all"` // skip if 1
	Active         int    `json:"active"`
	ActiveInt      int    `json:"active_int"`
	SogoVisible    int    `json:"sogo_visible"`
	SogoVisibleInt int    `json:"sogo_visible_int"`
}

func NewAlias(alias string, destination string) MailcowAlias {
	var a MailcowAlias
	a.Active = 1
	a.PublicComment = "automatically generated by the mail server admin"
	a.PrivateComment = "automatically generated by the mail server admin"
	a.Address = alias
	a.Goto = destination

	return a
}

func LoadAliases(cfg configuration.Config) ([]MailcowAlias, []string, error) {
	var aliases []MailcowAlias
	var aliasSlice []string

	url := cfg.ApiEndpoint + configuration.AllAliasesApiEndpoint
	method := "GET"

	client := &http.Client{Timeout: 10 * time.Second}
	req, err := http.NewRequest(method, url, nil)

	slog.Debug("alias request", "method", method, "url", url)

	if err != nil {
		return []MailcowAlias{}, []string{}, fmt.Errorf("failed to create alias http request: %w", err)
	}
	req.Header.Add("accept", "application/json")
	req.Header.Add("X-API-Key", cfg.ApiKey)

	res, err := client.Do(req)
	if err != nil {
		return []MailcowAlias{}, []string{}, fmt.Errorf("failed to request aliases from server: %w", err)
	}
	defer res.Body.Close()

	slog.Debug("alias response received", "status", res.Status, "status-code", res.StatusCode)

	body, err := io.ReadAll(res.Body)
	if err != nil {
		return []MailcowAlias{}, []string{}, fmt.Errorf("failed to read alias request body: %w", err)
	}

	err = json.Unmarshal(body, &aliases)
	if err != nil {
		return []MailcowAlias{}, []string{}, fmt.Errorf("failed to unmarshal alias request body: %w", err)
	}

	for _, alias := range aliases {
		aliasSlice = append(aliasSlice, alias.Address)
	}

	return aliases, aliasSlice, nil
}