httpsms/api/pkg/services/marketting_service.go at main · pacoDevelop/httpsms · GitHub

History

110 lines (92 loc) · 3.45 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

package services

import (

"context"

"fmt"

"strings"

semconv "go.opentelemetry.io/otel/semconv/v1.10.0"

"firebase.google.com/go/auth"

"github.com/NdoleStudio/httpsms/pkg/entities"

"github.com/NdoleStudio/httpsms/pkg/telemetry"

plunk "github.com/NdoleStudio/plunk-go"

"github.com/NdoleStudio/stacktrace"

"github.com/gofiber/fiber/v3"

)

// MarketingService is handles marketing requests

type MarketingService struct {

logger telemetry.Logger

tracer telemetry.Tracer

authClient *auth.Client

plunkClient *plunk.Client

}

// NewMarketingService creates a new instance of the MarketingService

func NewMarketingService(

logger telemetry.Logger,

tracer telemetry.Tracer,

authClient *auth.Client,

plunkClient *plunk.Client,

) *MarketingService {

return &MarketingService{

logger: logger.WithService(fmt.Sprintf("%T", &MarketingService{})),

tracer: tracer,

authClient: authClient,

plunkClient: plunkClient,

}

// DeleteContact a user if exists as a contact

func (service *MarketingService) DeleteContact(ctx context.Context, email string) error {

ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)

defer span.End()

response, _, err := service.plunkClient.Contacts.List(ctx, map[string]string{"search": email})

if err != nil {

return service.tracer.WrapErrorSpan(span, stacktrace.Propagatef(err, "cannot search for contact with email [%s]", email))

}

if len(response.Data) == 0 {

ctxLogger.Info(fmt.Sprintf("no contact found with email [%s], skipping deletion", email))

return nil

}

contact := response.Data[0]

if _, err = service.plunkClient.Contacts.Delete(ctx, contact.ID); err != nil {

return service.tracer.WrapErrorSpan(span, stacktrace.Propagatef(err, "cannot delete user with ID [%s] from contacts", contact.Data[string(semconv.EnduserIDKey)]))

}

ctxLogger.Info(fmt.Sprintf("deleted user with ID [%s] from as marketting contact with ID [%s]", contact.Data[string(semconv.EnduserIDKey)], contact.ID))

return nil

}

// CreateContact adds a new user on the onboarding automation.

func (service *MarketingService) CreateContact(ctx context.Context, userID entities.UserID) error {

ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)

defer span.End()

userRecord, err := service.authClient.GetUser(ctx, userID.String())

if err != nil {

return service.tracer.WrapErrorSpan(span, stacktrace.Propagatef(err, "cannot get auth user with id [%s]", userID))

}

data := service.attributes(userRecord)

data[string(semconv.ServiceNameKey)] = "httpsms.com"

data[string(semconv.EnduserIDKey)] = userRecord.UID

event, _, err := service.plunkClient.Tracker.TrackEvent(ctx, &plunk.TrackEventRequest{

Email: userRecord.Email,

Event: "contact.created",

Subscribed: true,

Data: data,

})

if err != nil {

return service.tracer.WrapErrorSpan(span, stacktrace.Propagatef(err, "cannot create contact for user with id [%s]", userID))

}

ctxLogger.Info(fmt.Sprintf("user [%s] added to marketting list with contact ID [%s] and event ID [%s]", userID, event.Data.Contact, event.Data.Event))

return nil

}

func (service *MarketingService) attributes(user *auth.UserRecord) map[string]any {

name := strings.TrimSpace(user.DisplayName)

if name == "" {

return fiber.Map{}

}

parts := strings.Split(name, " ")

if len(parts) == 1 {

return fiber.Map{

"firstName": name,

}

return fiber.Map{

"firstName": strings.Join(parts[0:len(parts)-1], " "),

"lastName": parts[len(parts)-1],

}

httpsms/api/pkg/services/marketting_service.go at main · pacoDevelop/httpsms · GitHub

Expand file tree

Breadcrumbs

marketting_service.go

Latest commit

History

Breadcrumbs

marketting_service.go

File metadata and controls