Add buttons to actually send emails either the test address or mailing list
parent
45d25d8990
commit
ed872ddfa3
107
main.go
107
main.go
|
@ -45,11 +45,6 @@ type ApiConfig struct {
|
||||||
Postmark PostmarkConfig
|
Postmark PostmarkConfig
|
||||||
}
|
}
|
||||||
|
|
||||||
// ------------- HMC Api Responses -------------
|
|
||||||
type EmailsResonse struct {
|
|
||||||
Emails []string `json:"emails"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load the HMCsend-email app.ini and store the values in a structure, some of the keys in here
|
// Load the HMCsend-email app.ini and store the values in a structure, some of the keys in here
|
||||||
// we probably don't actualy care about for this usage.
|
// we probably don't actualy care about for this usage.
|
||||||
func loadConfig() ApiConfig {
|
func loadConfig() ApiConfig {
|
||||||
|
@ -89,6 +84,47 @@ func loadConfig() ApiConfig {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ParseArguments(rawArgs string) map[string]string {
|
||||||
|
pairs := strings.Split(rawArgs, "&")
|
||||||
|
result := make(map[string]string)
|
||||||
|
for _, pair := range pairs {
|
||||||
|
key_val := strings.Split(pair, "=")
|
||||||
|
if len(key_val) != 2 {
|
||||||
|
log.Fatalf("Cannot parse argument %v\n", pair)
|
||||||
|
}
|
||||||
|
result[key_val[0]] = key_val[1]
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
func GetMailingList(cfg ApiConfig) []string {
|
||||||
|
type EmailsResonse struct {
|
||||||
|
Emails []string `json:"emails"`
|
||||||
|
}
|
||||||
|
body := []byte(fmt.Sprintf("{\"city\": \"%s\"}", cfg.Hmc.City))
|
||||||
|
req, err := http.NewRequest("POST", cfg.Hmc.ApiUrl, bytes.NewBuffer(body))
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
req.Header.Add("Content-Type", "application/json")
|
||||||
|
req.Header.Add("Authorization", cfg.Hmc.ApiSecret)
|
||||||
|
|
||||||
|
client := &http.Client{}
|
||||||
|
res, err := client.Do(req)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
defer res.Body.Close()
|
||||||
|
|
||||||
|
response := &EmailsResonse{}
|
||||||
|
decode_error := json.NewDecoder(res.Body).Decode(&response)
|
||||||
|
if decode_error != nil {
|
||||||
|
panic(decode_error)
|
||||||
|
}
|
||||||
|
return response.Emails
|
||||||
|
}
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
apiConfig := loadConfig()
|
apiConfig := loadConfig()
|
||||||
postmarkTemplate := getPostmarkTemplate(apiConfig.Postmark)
|
postmarkTemplate := getPostmarkTemplate(apiConfig.Postmark)
|
||||||
|
@ -102,25 +138,25 @@ func main() {
|
||||||
|
|
||||||
// The base endpoint for the web-app simply renders the index tempalte
|
// The base endpoint for the web-app simply renders the index tempalte
|
||||||
mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
|
mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
|
||||||
log.Printf("Hello '%v %v' handler", r.Method, r.URL)
|
log.Printf("%v %v", r.Method, r.URL)
|
||||||
templates.ExecuteTemplate(w, "index", nil)
|
templates.ExecuteTemplate(w, "index", nil)
|
||||||
})
|
})
|
||||||
|
|
||||||
// Endpoint called when editing the text area and posts to the postmark api to generate the email preview
|
// Endpoint called when editing the text area and posts to the postmark api to generate the email preview
|
||||||
mux.HandleFunc("/mail-content", func(w http.ResponseWriter, r *http.Request) {
|
mux.HandleFunc("/mail-content", func(w http.ResponseWriter, r *http.Request) {
|
||||||
log.Printf("Hello '%v %v' handler", r.Method, r.URL)
|
log.Printf("%v %v", r.Method, r.URL)
|
||||||
body, err := io.ReadAll(r.Body)
|
body, err := io.ReadAll(r.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer r.Body.Close()
|
defer r.Body.Close()
|
||||||
textarea_content := string(body)
|
arguments := ParseArguments(string(body))
|
||||||
decoded_textarea, err := url.QueryUnescape(textarea_content)
|
// textarea_content := string(body)
|
||||||
|
email_content, err := url.QueryUnescape(arguments["email_input"])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
email_content, _ := strings.CutPrefix(decoded_textarea, "email_input=")
|
|
||||||
|
|
||||||
// Return a response to HTMX
|
// Return a response to HTMX
|
||||||
model := PostmarkTemplateModel{
|
model := PostmarkTemplateModel{
|
||||||
|
@ -135,17 +171,16 @@ func main() {
|
||||||
})
|
})
|
||||||
|
|
||||||
mux.HandleFunc("/subject_preview", func(w http.ResponseWriter, r *http.Request) {
|
mux.HandleFunc("/subject_preview", func(w http.ResponseWriter, r *http.Request) {
|
||||||
log.Printf("Hello '%v %v' handler", r.Method, r.URL)
|
log.Printf("%v %v", r.Method, r.URL)
|
||||||
body, err := io.ReadAll(r.Body)
|
body, err := io.ReadAll(r.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer r.Body.Close()
|
defer r.Body.Close()
|
||||||
|
arguments := ParseArguments(string(body))
|
||||||
|
|
||||||
text_field_body := string(body)
|
decoded_subject, err := url.QueryUnescape(arguments["subject"])
|
||||||
text_field_body, _ = strings.CutPrefix(text_field_body, "subject=")
|
|
||||||
decoded_subject, err := url.QueryUnescape(text_field_body)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
@ -162,30 +197,44 @@ func main() {
|
||||||
|
|
||||||
// Endpoint called on load or button press by htmx to retrieve and populate the mailing list
|
// Endpoint called on load or button press by htmx to retrieve and populate the mailing list
|
||||||
mux.HandleFunc("/mailing_list", func(w http.ResponseWriter, r *http.Request) {
|
mux.HandleFunc("/mailing_list", func(w http.ResponseWriter, r *http.Request) {
|
||||||
body := []byte(fmt.Sprintf("{\"city\": \"%s\"}", apiConfig.Hmc.City))
|
log.Printf("%v %v", r.Method, r.URL)
|
||||||
|
mailing_list := GetMailingList(apiConfig)
|
||||||
|
templates.ExecuteTemplate(w, "mailing_list", mailing_list)
|
||||||
|
})
|
||||||
|
|
||||||
req, err := http.NewRequest("POST", apiConfig.Hmc.ApiUrl, bytes.NewBuffer(body))
|
mux.HandleFunc("/send_email", func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
log.Printf("%v %v", r.Method, r.URL)
|
||||||
|
|
||||||
|
body, err := io.ReadAll(r.Body)
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
defer r.Body.Close()
|
||||||
|
|
||||||
|
body_string := string(body)
|
||||||
|
arguments := ParseArguments(body_string)
|
||||||
|
fmt.Printf("%v\n", arguments)
|
||||||
|
var recipients []string
|
||||||
|
if arguments["destination"] == "test" {
|
||||||
|
recipients = []string{apiConfig.Default.TestEmail}
|
||||||
|
} else if arguments["destination"] == "mailing_list" {
|
||||||
|
recipients = GetMailingList(apiConfig)
|
||||||
|
} else {
|
||||||
|
panic("unknown destination in arguments")
|
||||||
|
}
|
||||||
|
|
||||||
|
decoded_email, err := url.QueryUnescape(arguments["email_input"])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
req.Header.Add("Content-Type", "application/json")
|
decoded_subject, err := url.QueryUnescape(arguments["subject"])
|
||||||
req.Header.Add("Authorization", apiConfig.Hmc.ApiSecret)
|
|
||||||
|
|
||||||
client := &http.Client{}
|
|
||||||
res, err := client.Do(req)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
defer res.Body.Close()
|
|
||||||
|
|
||||||
response := &EmailsResonse{}
|
sendBatchWithTemplate(apiConfig, decoded_email, decoded_subject, recipients)
|
||||||
decode_error := json.NewDecoder(res.Body).Decode(&response)
|
|
||||||
if decode_error != nil {
|
|
||||||
panic(decode_error)
|
|
||||||
}
|
|
||||||
|
|
||||||
templates.ExecuteTemplate(w, "mailing_list", response)
|
|
||||||
})
|
})
|
||||||
|
|
||||||
srv := &http.Server{
|
srv := &http.Server{
|
||||||
|
|
60
postmark.go
60
postmark.go
|
@ -5,6 +5,7 @@ import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -141,3 +142,62 @@ func renderPostmarkTemplate(cfg PostmarkConfig, template PostmarkTemplate, model
|
||||||
Subject: response.Subject.RenderedContent,
|
Subject: response.Subject.RenderedContent,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type PostmarkBatchArguments struct {
|
||||||
|
From string
|
||||||
|
To string
|
||||||
|
TemplateId int
|
||||||
|
TemplateModel PostmarkTemplateModel
|
||||||
|
MessageStream string
|
||||||
|
}
|
||||||
|
|
||||||
|
func sendBatchWithTemplate(cfg ApiConfig, email, subject string, recipients []string) {
|
||||||
|
type BatchAPIArgs struct {
|
||||||
|
Messages []PostmarkBatchArguments
|
||||||
|
}
|
||||||
|
bodyObj := &BatchAPIArgs{}
|
||||||
|
|
||||||
|
for _, recipient := range recipients {
|
||||||
|
args := PostmarkBatchArguments{
|
||||||
|
From: cfg.Postmark.SenderEmail,
|
||||||
|
To: recipient,
|
||||||
|
TemplateId: cfg.Postmark.TemplateId,
|
||||||
|
TemplateModel: PostmarkTemplateModel{
|
||||||
|
Name: cfg.Default.SenderName,
|
||||||
|
Email: cfg.Postmark.SenderEmail,
|
||||||
|
Body: email,
|
||||||
|
Subject: subject,
|
||||||
|
},
|
||||||
|
MessageStream: cfg.Postmark.MessageStream,
|
||||||
|
}
|
||||||
|
bodyObj.Messages = append(bodyObj.Messages, args)
|
||||||
|
}
|
||||||
|
|
||||||
|
body, err := json.Marshal(bodyObj)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
req, err := http.NewRequest("POST", "https://api.postmarkapp.com/email/batchWithTemplates", bytes.NewBuffer(body))
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
req.Header.Add("Accept", "application/json")
|
||||||
|
req.Header.Add("Content-Type", "application/json")
|
||||||
|
req.Header.Add("X-Postmark-Server-Token", cfg.Postmark.ServerToken)
|
||||||
|
|
||||||
|
client := &http.Client{}
|
||||||
|
resp, err := client.Do(req)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
defer resp.Body.Close()
|
||||||
|
|
||||||
|
rawBodyContent, err := io.ReadAll(resp.Body)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Printf("batchWithTemplates responded with: %s\n", string(rawBodyContent))
|
||||||
|
}
|
||||||
|
|
|
@ -87,9 +87,14 @@ ul {
|
||||||
|
|
||||||
.row {
|
.row {
|
||||||
display: flex;
|
display: flex;
|
||||||
|
flex-direction: row;
|
||||||
|
flex-wrap: nowrap;
|
||||||
}
|
}
|
||||||
|
|
||||||
.column {
|
.column {
|
||||||
padding: 0.5em;
|
padding: 0.5em;
|
||||||
border-color: #E8B;
|
border-color: #E8B;
|
||||||
|
display: flex;
|
||||||
|
flex-direction: column;
|
||||||
|
flex-wrap: nowrap;
|
||||||
}
|
}
|
|
@ -19,15 +19,28 @@
|
||||||
<div class="content">
|
<div class="content">
|
||||||
<h1> This is an input </h1>
|
<h1> This is an input </h1>
|
||||||
<div class="row">
|
<div class="row">
|
||||||
<div class="column">
|
<div class="column" stye="align-items: center">
|
||||||
<div style="display: flex; justify-content: space-between;">
|
<div style="display: flex; justify-content: space-between;">
|
||||||
<span class="input_label">Subject:</span>
|
<span class="input_label">Subject:</span>
|
||||||
<input name="subject" type="text" id="subject" hx-post="/subject_preview"
|
<input name="subject" type="text" id="subject" hx-post="/subject_preview"
|
||||||
hx-trigger="keyup changed delay:1000ms" hx-target="#subject-preview">
|
hx-trigger="keyup changed delay:1000ms" hx-target="#subject-preview">
|
||||||
</div><br>
|
</div><br>
|
||||||
<textarea name="email_input" id="typebox" rows="32" cols="64" style="resize: none;"
|
<textarea name="email_input" id="email_input" rows="32" cols="64" style="resize: none;"
|
||||||
hx-trigger="keyup changed delay:1000ms" hx-post="/mail-content" hx-target="#email-preview"
|
hx-trigger="keyup changed delay:1000ms" hx-post="/mail-content" hx-target="#email-preview"
|
||||||
placeholder="Type out your email here..."></textarea>
|
placeholder="Type out your email here..."></textarea>
|
||||||
|
<br>
|
||||||
|
<div class="row" style="justify-content: space-around;">
|
||||||
|
<button hx-post="/send_email" hx-include="[id='email_input'], [id='subject']"
|
||||||
|
hx-vals='{"destination": "test"}' hx-swap="none">
|
||||||
|
Send Test Email
|
||||||
|
</button>
|
||||||
|
<button hx-post="/send_email" hx-include="[id='email_input'], [id='subject']"
|
||||||
|
hx-vals='{"destination": "mailing_list"}'
|
||||||
|
hx-confirm="You are about to send an email to your entire mailing list. Are you sure?"
|
||||||
|
hx-swap="none">
|
||||||
|
Send Email
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="column">
|
<div class="column">
|
||||||
|
@ -54,7 +67,7 @@
|
||||||
|
|
||||||
{{ block "mailing_list" . }}
|
{{ block "mailing_list" . }}
|
||||||
<ul style="columns: 2;">
|
<ul style="columns: 2;">
|
||||||
{{ range .Emails }}
|
{{ range . }}
|
||||||
<li><a href="mailto:{{ . }}"> {{ . }} </a></li>
|
<li><a href="mailto:{{ . }}"> {{ . }} </a></li>
|
||||||
{{end}}
|
{{end}}
|
||||||
</ul>
|
</ul>
|
||||||
|
|
Loading…
Reference in New Issue