athos & foil. create command to send expiration mails (#28)

* athos & foil. create command to send expiration mails

Co-authored-by: Giacomo Sanchietti <giacomo.sanchietti@nethesis.it>

Author: edospadoni

athos/configuration/configuration.go

@@ -31,11 +31,12 @@ import (
 )
 
 type Notifications struct {
-	PortalUrl   string `json:"portal_url"`
-	HelpUrl     string `json:"help_url"`
-	DocsUrl     string `json:"docs_url"`
-	PortalTitle string `json:"portal_title"`
-	Email       struct {
+	PortalUrl    string `json:"portal_url"`
+	HelpUrl      string `json:"help_url"`
+	DocsUrl      string `json:"docs_url"`
+	CommunityUrl string `json:"community_url"`
+	PortalTitle  string `json:"portal_title"`
+	Email        struct {
 		From         string `json:"from"`
 		SMTPHost     string `json:"smtp_host"`
 		SMTPPort     int    `json:"smtp_port"`
@@ -53,25 +54,25 @@ type Configuration struct {
 		Password string `json:"password"`
 	} `json:"database"`
 	Redis struct {
-		Host  string `json:"host"`
-		Port  string `json:"port"`
+		Host string `json:"host"`
+		Port string `json:"port"`
 	} `json:"redis"`
-	Cors       struct {
+	Cors struct {
 		Headers []string `json:"headers"`
 		Origins []string `json:"origins"`
 		Methods []string `json:"methods"`
 	} `json:"cors"`
 	Auth0 struct {
-		Domain        string `json:"domain"`
-		Audience      string `json:"audience"`
+		Domain   string `json:"domain"`
+		Audience string `json:"audience"`
 	} `json:"auth0"`
 	PayPal struct {
 		ClientID     string `json:"client_id"`
 		ClientSecret string `json:"client_secret"`
 		Sandbox      bool   `json:"sandbox"`
 	} `json:"paypal"`
 	Log struct {
-		Level        string `json:"level"`
+		Level string `json:"level"`
 	} `json:"log"`
 	Billing struct {
 		Country string `json:"country"`

athos/notifications/alert.go

@@ -34,7 +34,7 @@ func AlertNotification(alert models.Alert, isNew bool) {
 		switch x := alert.System.Notification["emails"].(type) {
 		case []interface{}:
 			for _, e := range x {
-				MailNotification(e.(string), alert, isNew)
+				MailNotificationAlert(e.(string), alert, isNew)
 			}
 		default:
 		}

athos/notifications/mail.go

@@ -23,13 +23,16 @@ package notifications
 
 import (
 	"fmt"
+	"strconv"
+	"strings"
 	"time"
 
 	gomail "gopkg.in/gomail.v2"
 
 	"github.com/cbroglie/mustache"
 	"github.com/nethesis/dartagnan/athos/configuration"
 	"github.com/nethesis/dartagnan/athos/models"
+	"github.com/nethesis/dartagnan/athos/utils"
 	"github.com/nicksnyder/go-i18n/i18n"
 )
 
@@ -94,7 +97,76 @@ func alertTextBody(alert models.Alert) string {
 	return text
 }
 
-func MailNotification(address string, alert models.Alert, isNew bool) bool {
+func expireHtmlBody(system models.System, period string) string {
+	values := make(map[string]string)
+	T, _ := i18n.Tfunc("en-US", "en-US", "en-US")
+
+	values["hello"] = T("hello")
+	values["year"] = strconv.Itoa(time.Now().Year())
+
+	values["title"] = configuration.Config.Notifications.PortalTitle
+	values["urlComm"] = configuration.Config.Notifications.CommunityUrl
+	values["urlDocs"] = configuration.Config.Notifications.DocsUrl
+	values["urlHelp"] = configuration.Config.Notifications.HelpUrl
+
+	values["systemUUID"] = T("server_uuid")
+	values["serverName"] = system.UUID
+	values["serverDetails"] = fmt.Sprintf(fmt.Sprintf("%s/servers/%d", configuration.Config.Notifications.PortalUrl, system.ID))
+
+	values["footerMessage"] = T("footer_message")
+
+	renderFile := ""
+	if system.Subscription.SubscriptionPlan.Code == "trial" {
+		values["message"] = T(period + "_trial")
+		values["serverDetailsMessage"] = T("server_link")
+
+		renderFile = "templates/expiration-template-trial.mustache"
+	} else {
+		values["message"] = T(period+"_others", map[string]interface{}{
+			"Subscription": system.Subscription.SubscriptionPlan.Name,
+		})
+		values["serverDetailsMessage"] = T("server_link_renew")
+		values["ownerName"] = utils.GetBillingInfo(system.CreatorID).Name
+
+		renderFile = "templates/expiration-template-others.mustache"
+	}
+
+	output, err := mustache.RenderFile(renderFile, values)
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	return output
+}
+
+func expireTextBody(system models.System, period string) string {
+	T, _ := i18n.Tfunc("en-US", "en-US", "en-US")
+
+	text := fmt.Sprintf("***** %s ***** \n\n", configuration.Config.Notifications.PortalTitle)
+	text += fmt.Sprintf("%s: %s\n", T("server_uuid"), system.UUID)
+	text += fmt.Sprintf("%s: %s\n", T("subscription"), system.Subscription.SubscriptionPlan.Name)
+
+	message := ""
+	if system.Subscription.SubscriptionPlan.Code == "trial" {
+		message = T(period + "_trial_plain")
+
+	} else {
+		message = T(period+"_others_plain", map[string]interface{}{
+			"Subscription": system.Subscription.SubscriptionPlan.Name,
+			"Name":         utils.GetBillingInfo(system.CreatorID).Name,
+		})
+	}
+
+	text += "\n" + message
+	text += fmt.Sprintf("\n%s\n", fmt.Sprintf(fmt.Sprintf("%s/servers/%d", configuration.Config.Notifications.PortalUrl, system.ID)))
+
+	text += fmt.Sprintf("\n%s: %s\n", "Blog", configuration.Config.Notifications.CommunityUrl)
+	text += fmt.Sprintf("%s: %s\n", "Support", strings.Split(configuration.Config.Notifications.HelpUrl, ":")[1])
+	text += fmt.Sprintf("%s: %s\n", "Docs", configuration.Config.Notifications.DocsUrl)
+	return text
+}
+
+func MailNotificationAlert(address string, alert models.Alert, isNew bool) bool {
 	i18n.MustLoadTranslationFile("templates/en-US-alert.json")
 	T, _ := i18n.Tfunc("en-US", "en-US", "en-US")
 	status := true
@@ -127,3 +199,32 @@ func MailNotification(address string, alert models.Alert, isNew bool) bool {
 
 	return status
 }
+
+func MailNotificationExpire(address string, system models.System, period string) bool {
+	i18n.MustLoadTranslationFile("templates/en-US-alert.json")
+	T, _ := i18n.Tfunc("en-US", "en-US", "en-US")
+	status := true
+	m := gomail.NewMessage()
+	m.SetHeader("From", configuration.Config.Notifications.Email.From)
+	m.SetHeader("To", address)
+	subject := fmt.Sprintf("[%s][%s] %s", T("expiration"), system.Subscription.SubscriptionPlan.Name, T(system.UUID))
+	m.SetHeader("Subject", subject)
+	m.SetBody("text/plain", expireTextBody(system, period))
+	m.SetHeader("Message-Id", fmt.Sprintf("%d@dartagnan.project", time.Now().UnixNano()))
+
+	m.AddAlternative("text/html", expireHtmlBody(system, period))
+
+	d := gomail.NewDialer(
+		configuration.Config.Notifications.Email.SMTPHost,
+		configuration.Config.Notifications.Email.SMTPPort,
+		configuration.Config.Notifications.Email.SMTPUser,
+		configuration.Config.Notifications.Email.SMTPPassword,
+	)
+
+	// send the email
+	if err := d.DialAndSend(m); err != nil {
+		status = false
+	}
+
+	return status
+}

athos/templates/en-US-alert.json

@@ -1,4 +1,5 @@
-[{
+[
+  {
     "id": "Alert report",
     "translation": "Alert report"
   },
@@ -93,5 +94,73 @@
   {
     "id": "alert_nut",
     "translation": "UPS on battery"
+  },
+  {
+    "id": "hello",
+    "translation": "Hello"
+  },
+  {
+    "id": "expiration",
+    "translation": "EXPIRATION"
+  },
+  {
+    "id": "subscription",
+    "translation": "Subscription"
+  },
+  {
+    "id": "2w_trial",
+    "translation": "<br>thank you for joining our Subscription trial program.<br><br>Your trial subscription will expire in <b>2 weeks</b>, we hope that everything is still up and running!<br><br>If you need help, remember to join our vibrant <a target=\"blank\" href=\"https://community.nethserver.org\">Community</a><br><br>· Would you like to secure your installation thanks to stable repositories?<br>· Do you want to sponsor the NethServer project?<br><br>Click on the button below and buy a subscription:"
+  },
+  {
+    "id": "1w_trial",
+    "translation": "<br>your trial subscription will expire in <b>1 week</b>.<br><br>If you are enjoining it and you want to still have access to stable repositories, buy a subscription by clicking the button below:"
+  },
+  {
+    "id": "1d_trial",
+    "translation": "<br>your trial subscription will expire <b>tomorrow</b>!<br><br>After subscription expiration, the server <b>will not be able</b> to download updates.<br><br>If you want to leave the subscription program, remember to unregister your machine following the <a href=\"https://docs.nethserver.org/en/v7/subscription.html#removing-a-subscription\">documentation</a>.<br><br>Otherwise, if you are still interested in accessing the stable repositories, buy a subscription now by clicking the button below:"
+  },
+  {
+    "id": "1w_others",
+    "translation": "<br>your <b>{{.Subscription}}</b> subscription will expire in <b>1 week</b>.<br><br>If you are enjoying it and you want to still have access to stable repositories, renew your subscription clicking the button below:"
+  },
+  {
+    "id": "1d_others",
+    "translation": "<br>your <b>{{.Subscription}}</b> subscription will expire <b>tomorrow</b>!<br><br>After subscription expiration, the server <b>will not be able</b> to download updates.<br><br>If you want to leave the subscription program, remember to unregister your machine following the <a href=\"https://docs.nethserver.org/en/v7/subscription.html#removing-a-subscription\">documentation</a>.<br><br>Otherwise, if you are still interested in accessing the stable repositories, renew your subscription now by clicking the button below:"
+  },
+  {
+    "id": "2w_trial_plain",
+    "translation": "Hi,\nthank you for joining our Subscription trial program.\n\nYour trial subscription will expire in 2 weeks, we hope that everything is still up and running!\n\nIf you need help, remember to join our vibrant community at: https://community.nethserver.org\n\n· Would you like to secure your installation thanks to stable repositories?\n· Do you want to sponsor the NethServer project?\n\nClick on the link below and buy a subscription:"
+  },
+  {
+    "id": "1w_trial_plain",
+    "translation": "Hi,\nyour trial subscription will expire in 1 week.\n\nIf you are enjoining it and you want to still have access to stable repositories, buy a subscription by clicking the link below:"
+  },
+  {
+    "id": "1d_trial_plain",
+    "translation": "Hi,\nyour trial subscription will expire tomorrow!\n\nAfter subscription expiration, the server will not be able to download updates.\n\nIf you want to leave the subscription program, remember to unregister your machine following the documentation at: https://docs.nethserver.org/en/v7/subscription.html#removing-a-subscription.\n\nOtherwise, if you are still interested in accessing the stable repositories, buy a subscription now by clicking the link below:"
+  },
+  {
+    "id": "1w_others_plain",
+    "translation": "Hi {{.Name}},\nyour {{.Subscription}} subscription will expire in 1 week.\n\nIf you are enjoining it and you want to still have access to stable repositories, renew your subscription by clicking the link below:"
+  },
+  {
+    "id": "1d_others_plain",
+    "translation": "Hi {{.Name}},\nyour {{.Subscription}} subscription will expire tomorrow!\n\nAfter subscription expiration, the server will not be able to download updates.\n\nIf you want to leave the subscription program, remember to unregister your machine following the documentation at: https://docs.nethserver.org/en/v7/subscription.html#removing-a-subscription.\n\nOtherwise, if you are still interested in accessing the stable repositories, renew your subscription now by clicking the link below:"
+  },
+  {
+    "id": "server_link",
+    "translation": "Upgrade your plan"
+  },
+  {
+    "id": "server_link_renew",
+    "translation": "Renew your plan"
+  },
+  {
+    "id": "server_uuid",
+    "translation": "System"
+  },
+  {
+    "id": "footer_message",
+    "translation": "Still convinced to not buy a subscription? <a href=\"mailto:support@nethserver.com\">Tell us</a> why and how can we improve our offer!<br><br>Thank you,<br>NethServer Subscription team"
   }
-]
+]