76 lines
2 KiB
Go
76 lines
2 KiB
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, error) {
|
||
|
|
var domains []MailcowAlias
|
||
|
|
|
||
|
|
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{}, 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{}, 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{}, fmt.Errorf("failed to read alias request body: %w", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
err = json.Unmarshal(body, &domains)
|
||
|
|
if err != nil {
|
||
|
|
return []MailcowAlias{}, fmt.Errorf("failed to unmarshal alias request body: %w", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
return domains, nil
|
||
|
|
}
|