add custom email agent

Signed-off-by: WashingtonKK <washingtonkigan@gmail.com>

Author: WashingtonKK

api/grpc/users/v1/users.pb.go

@@ -15,6 +15,7 @@ import (
 	chclient "github.com/absmach/callhome/pkg/client"
 	"github.com/absmach/supermq"
 	grpcDomainsV1 "github.com/absmach/supermq/api/grpc/domains/v1"
+	grpcUsersV1 "github.com/absmach/supermq/api/grpc/users/v1"
 	"github.com/absmach/supermq/domains"
 	domainsSvc "github.com/absmach/supermq/domains"
 	domainsgrpcapi "github.com/absmach/supermq/domains/api/grpc"
@@ -169,7 +170,7 @@ func main() {
 		return
 	}
 
-	_, usersHandler, err := grpcclient.SetupUsersClient(ctx, usersClientConfig)
+	usersClient, usersHandler, err := grpcclient.SetupUsersClient(ctx, usersClientConfig)
 	if err != nil {
 		logger.Error(fmt.Sprintf("failed to connect to users gRPC server : %s", err.Error()))
 		exitCode = 1
@@ -225,7 +226,7 @@ func main() {
 		return
 	}
 
-	svc, err := newDomainService(ctx, domainsRepo, cache, tracer, cfg, authz, policyService, logger, call)
+	svc, err := newDomainService(ctx, domainsRepo, cache, tracer, cfg, authz, policyService, logger, call, usersClient)
 	if err != nil {
 		logger.Error(fmt.Sprintf("failed to create %s service: %s", svcName, err.Error()))
 		exitCode = 1
@@ -277,7 +278,7 @@ func main() {
 	}
 }
 
-func newDomainService(ctx context.Context, domainsRepo domainsSvc.Repository, cache domainsSvc.Cache, tracer trace.Tracer, cfg config, authz authz.Authorization, policiessvc policies.Service, logger *slog.Logger, callout callout.Callout) (domains.Service, error) {
+func newDomainService(ctx context.Context, domainsRepo domainsSvc.Repository, cache domainsSvc.Cache, tracer trace.Tracer, cfg config, authz authz.Authorization, policiessvc policies.Service, logger *slog.Logger, callout callout.Callout, usersClient grpcUsersV1.UsersServiceClient) (domains.Service, error) {
 	idProvider := uuid.New()
 	sidProvider, err := sid.New()
 	if err != nil {
@@ -289,7 +290,7 @@ func newDomainService(ctx context.Context, domainsRepo domainsSvc.Repository, ca
 		return nil, err
 	}
 
-	svc, err := domainsSvc.New(domainsRepo, cache, policiessvc, idProvider, sidProvider, availableActions, builtInRoles)
+	svc, err := domainsSvc.New(domainsRepo, cache, policiessvc, idProvider, sidProvider, availableActions, builtInRoles, usersClient)
 	if err != nil {
 		return nil, fmt.Errorf("failed to init domain service: %w", err)
 	}

api/grpc/users/v1/users_grpc.pb.go

@@ -95,6 +95,7 @@ type config struct {
 	SpicedbPreSharedKey        string        `env:"SMQ_SPICEDB_PRE_SHARED_KEY"            envDefault:"12345678"`
 	PasswordResetURLPrefix     string        `env:"SMQ_PASSWORD_RESET_URL_PREFIX"         envDefault:"http://localhost/password/reset"`
 	PasswordResetEmailTemplate string        `env:"SMQ_PASSWORD_RESET_EMAIL_TEMPLATE"     envDefault:"reset-password-email.tmpl"`
+	EmailTemplate              string        `env:"SM_EMAIL_TEMPLATE"                     envDefault:"email.tmpl"`
 	VerificationURLPrefix      string        `env:"SMQ_VERIFICATION_URL_PREFIX"           envDefault:"http://localhost/verify-email"`
 	VerificationEmailTemplate  string        `env:"SMQ_VERIFICATION_EMAIL_TEMPLATE"       envDefault:"verification-email.tmpl"`
 	PassRegex                  *regexp.Regexp
@@ -146,6 +147,14 @@ func main() {
 	}
 	verificationEmailConfig.Template = cfg.VerificationEmailTemplate
 
+	customEmailConfig := email.Config{}
+	if err := env.Parse(&customEmailConfig); err != nil {
+		logger.Error(fmt.Sprintf("failed to load custom email configuration : %s", err.Error()))
+		exitCode = 1
+		return
+	}
+	customEmailConfig.Template = cfg.EmailTemplate
+
 	dbConfig := pgclient.Config{Name: defDB}
 	if err := env.ParseWithOptions(&dbConfig, env.Options{Prefix: envPrefixDB}); err != nil {
 		logger.Error(err.Error())
@@ -233,7 +242,7 @@ func main() {
 	}
 	logger.Info("Policy client successfully connected to spicedb gRPC server")
 
-	csvc, err := newService(ctx, authz, tokenClient, policyService, domainsClient, db, dbConfig, tracer, cfg, resetPasswordEmailConfig, verificationEmailConfig, logger)
+	csvc, err := newService(ctx, authz, tokenClient, policyService, domainsClient, db, dbConfig, tracer, cfg, resetPasswordEmailConfig, verificationEmailConfig, customEmailConfig, logger)
 	if err != nil {
 		logger.Error(fmt.Sprintf("failed to setup service: %s", err))
 		exitCode = 1
@@ -294,7 +303,7 @@ func main() {
 	}
 }
 
-func newService(ctx context.Context, authz smqauthz.Authorization, token grpcTokenV1.TokenServiceClient, policyService policies.Service, domainsClient grpcDomainsV1.DomainsServiceClient, db *sqlx.DB, dbConfig pgclient.Config, tracer trace.Tracer, c config, resetPasswordEmailConfig, verificationEmailConfig email.Config, logger *slog.Logger) (users.Service, error) {
+func newService(ctx context.Context, authz smqauthz.Authorization, token grpcTokenV1.TokenServiceClient, policyService policies.Service, domainsClient grpcDomainsV1.DomainsServiceClient, db *sqlx.DB, dbConfig pgclient.Config, tracer trace.Tracer, c config, resetPasswordEmailConfig, verificationEmailConfig, customEmailConfig email.Config, logger *slog.Logger) (users.Service, error) {
 	database := pg.NewDatabase(db, dbConfig, tracer)
 	idp := uuid.New()
 	hsr := hasher.New()
@@ -307,6 +316,7 @@ func newService(ctx context.Context, authz smqauthz.Authorization, token grpcTok
 		c.VerificationURLPrefix,
 		&resetPasswordEmailConfig,
 		&verificationEmailConfig,
+		&customEmailConfig,
 	)
 	if err != nil {
 		logger.Error(fmt.Sprintf("failed to configure e-mailing util: %s", err.Error()))

cmd/domains/main.go

@@ -277,6 +277,7 @@ SMQ_PASSWORD_RESET_URL_PREFIX=http://localhost/password-reset
 SMQ_PASSWORD_RESET_EMAIL_TEMPLATE=reset-password-email.tmpl
 SMQ_VERIFICATION_URL_PREFIX=http://localhost/verify-email
 SMQ_VERIFICATION_EMAIL_TEMPLATE=verification-email.tmpl
+SM_EMAIL_TEMPLATE=invitation.tmpl
 
 #### Users Client Config
 SMQ_USERS_URL=users:9002

cmd/users/main.go

@@ -912,6 +912,7 @@ services:
     volumes:
       - ./templates/${SMQ_PASSWORD_RESET_EMAIL_TEMPLATE}:/${SMQ_PASSWORD_RESET_EMAIL_TEMPLATE}
       - ./templates/${SMQ_VERIFICATION_EMAIL_TEMPLATE}:/${SMQ_VERIFICATION_EMAIL_TEMPLATE}
+      - ./templates/${SMQ_EMAIL_TEMPLATE}:/${SMQ_EMAIL_TEMPLATE}
       # Auth gRPC client certificates
       - type: bind
         source: ${SMQ_AUTH_GRPC_CLIENT_CERT:-ssl/certs/dummy/client_cert}