chore: remove hubspot crm implementations

go.mod

@@ -35,7 +35,7 @@ require (
 	github.com/vektah/gqlparser/v2 v2.1.0
 	gitlab.slade360emr.com/go/apiclient v0.0.14
 	gitlab.slade360emr.com/go/commontools/accounting v0.0.0-20210726041609-f5e1334c2640
-	gitlab.slade360emr.com/go/commontools/crm v0.0.0-20210726041609-f5e1334c2640
+	gitlab.slade360emr.com/go/commontools/crm v0.0.0-20210726041609-f5e1334c2640 // indirect
 	go.opencensus.io v0.23.0
 	go.opentelemetry.io/contrib/instrumentation/github.com/gorilla/mux/otelmux v0.21.0
 	go.opentelemetry.io/otel v1.0.0-RC1

go.sum

@@ -97,7 +97,6 @@ github.com/brianvoe/gofakeit v3.18.0+incompatible h1:wDOmHc9DLG4nRjUVVaxA+CEglKO
 github.com/brianvoe/gofakeit v3.18.0+incompatible/go.mod h1:kfwdRA90vvNhPutZWfH7WPaDzUjz+CZFqG+rPkOjGOc=
 github.com/brianvoe/gofakeit/v5 v5.11.2 h1:Ny5Nsf4z2023ZvYP8ujW8p5B1t5sxhdFaQ/0IYXbeSA=
 github.com/brianvoe/gofakeit/v5 v5.11.2/go.mod h1:/ZENnKqX+XrN8SORLe/fu5lZDIo1tuPncWuRD+eyhSI=
-github.com/brianvoe/gofakeit/v6 v6.5.0 h1:zoWqGsuB8TB4MSwUZXtV3OwUSdzi8EHeXO8JfReRIHg=
 github.com/brianvoe/gofakeit/v6 v6.5.0/go.mod h1:palrJUk4Fyw38zIFB/uBZqsgzW5VsNllhHKKwAebzew=
 github.com/casbin/casbin/v2 v2.31.3 h1:NaPzGmLYWAtEgItUjqH8aGP6cvIYOY2X4HNMusCuuzY=
 github.com/casbin/casbin/v2 v2.31.3/go.mod h1:vByNa/Fchek0KZUgG5wEsl7iFsiviAYKRtgrQfcJqHg=

pkg/onboarding/application/common/common.go

@@ -79,12 +79,3 @@ const (
 	PartnerNavActionTitle       = "Partners"
 	PartnerNavActionDescription = "Partner Navigation action"
 )
-
-// PubSub topic names
-const (
-	// CreateCRMContact is the TopicID for CRM contact creation
-	CreateCRMContact = "crm.contact.create"
-
-	// UpdateCRMContact is the topicID for CRM contact updates
-	UpdateCRMContact = "crm.contact.update"
-)

pkg/onboarding/application/dto/input.go

@@ -11,7 +11,6 @@ import (
 	"github.com/savannahghi/profileutils"
 	"github.com/savannahghi/scalarutils"
 	dm "gitlab.slade360emr.com/go/commontools/accounting/pkg/domain"
-	CRMDomain "gitlab.slade360emr.com/go/commontools/crm/pkg/domain"
 )
 
 // UserProfileInput is used to create or update a user's profile.
@@ -303,21 +302,6 @@ type RegisterAdminInput struct {
 	RoleIDs []string `json:"roleIDs"`
 }
 
-// ContactLeadInput ...
-type ContactLeadInput struct {
-	ContactType    string                      `json:"contact_type,omitempty"`
-	ContactValue   string                      `json:"contact_value,omitempty"`
-	FirstName      string                      `json:"first_name,omitempty"`
-	LastName       string                      `json:"last_name,omitempty"`
-	DateOfBirth    scalarutils.Date            `json:"date_of_birth,omitempty"`
-	IsSync         bool                        `json:"isSync"                    firestore:"IsSync"`
-	TimeSync       *time.Time                  `json:"timeSync"                  firestore:"TimeSync"`
-	OptOut         CRMDomain.GeneralOptionType `json:"opt_out,omitempty"`
-	WantCover      bool                        `json:"wantCover"                 firestore:"wantCover"`
-	ContactChannel string                      `json:"contact_channel,omitempty"`
-	IsRegistered   bool                        `json:"is_registered,omitempty"`
-}
-
 // AgentFilterInput is used to supply filter parameters for agent filter inputs
 type AgentFilterInput struct {
 	PhoneNumber string `json:"phoneNumber"`

pkg/onboarding/application/dto/output.go

@@ -4,7 +4,6 @@ import (
 	"github.com/savannahghi/firebasetools"
 	"github.com/savannahghi/onboarding/pkg/onboarding/domain"
 	"github.com/savannahghi/profileutils"
-	crmDomain "gitlab.slade360emr.com/go/commontools/crm/pkg/domain"
 )
 
 // BusinessPartnerEdge is used to serialize GraphQL Relay edges for organization
@@ -134,17 +133,6 @@ type UserInfo struct {
 	UID        string `json:"rawId,omitempty"`
 }
 
-// Segment represents the Segments data
-type Segment struct {
-	Properties     crmDomain.ContactProperties `json:"properties"       firestore:"properties"`
-	Wing           string                      `json:"wing"             firestore:"wing"`
-	MessageSent    string                      `json:"message_sent"     firestore:"message_sent"`
-	IsSynced       string                      `json:"is_synced"        firestore:"is_synced"`
-	TimeSynced     string                      `json:"time_synced"      firestore:"time_synced"`
-	PayerSladeCode string                      `json:"payer_slade_code" firestore:"payersladecode"`
-	MemberNumber   string                      `json:"member_number"    firestore:"membernumber"`
-}
-
 // RoleOutput is the formatted output with scopes and permissions
 type RoleOutput struct {
 	ID          string                      `json:"id"`

pkg/onboarding/domain/models.go

@@ -100,17 +100,6 @@ type NHIFDetails struct {
 	NHIFCardPhotoID           string                          `json:"nhifCardPhotoID"           firestore:"nhifCardPhotoID"`
 }
 
-// CRMContact represents a stored CRM contact
-type CRMContact struct {
-	FirstName   string `json:"first_name,omitempty"`
-	LastName    string `json:"last_name,omitempty"`
-	DOB         string `json:"dob,omitempty"`
-	PhoneNumber string `json:"phone_number,omitempty"`
-	OptOut      string `json:"opt_out,omitempty"`
-	TimeStamp   string `json:"time_stamp,omitempty"`
-	IsSynced    string `json:"is_synced,omitempty"`
-}
-
 // Microservice identifies a micro-service that conforms to the Apollo Graphqql
 // federation specification. These microservices are composed by an Apollo
 // Gateway into a single data graph.

pkg/onboarding/infrastructure/database/fb/firebase.go

@@ -47,7 +47,6 @@ const (
 	communicationsSettingsCollectionName = "communications_settings"
 	smsCollectionName                    = "incoming_sms"
 	firebaseExchangeRefreshTokenURL      = "https://securetoken.googleapis.com/v1/token?key="
-	marketingDataCollectionName          = "marketing_data"
 	rolesRevocationCollectionName        = "role_revocations"
 	rolesCollectionName                  = "user_roles"
 )
@@ -135,12 +134,6 @@ func (fr Repository) GetSMSCollectionName() string {
 	return suffixed
 }
 
-// GetMarketingDataCollectionName ...
-func (fr Repository) GetMarketingDataCollectionName() string {
-	suffixed := firebasetools.SuffixCollection(marketingDataCollectionName)
-	return suffixed
-}
-
 // GetRolesCollectionName ...
 func (fr Repository) GetRolesCollectionName() string {
 	suffixed := firebasetools.SuffixCollection(rolesCollectionName)

pkg/onboarding/infrastructure/database/fb/firebase_integration_test.go

@@ -8,7 +8,6 @@ import (
 
 	"github.com/savannahghi/onboarding/pkg/onboarding/application/dto"
 	"github.com/savannahghi/onboarding/pkg/onboarding/application/utils"
-	"gitlab.slade360emr.com/go/commontools/crm/pkg/infrastructure/services/hubspot"
 
 	"fmt"
 
@@ -36,13 +35,10 @@ import (
 
 	"github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/services/engagement"
 
-	crmExt "github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/services/crm"
 	"github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/services/messaging"
 	pubsubmessaging "github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/services/pubsub"
 	"github.com/savannahghi/onboarding/pkg/onboarding/presentation/interactor"
 	"github.com/savannahghi/onboarding/pkg/onboarding/usecases"
-	hubspotRepo "gitlab.slade360emr.com/go/commontools/crm/pkg/infrastructure/database/fs"
-	hubspotUsecases "gitlab.slade360emr.com/go/commontools/crm/pkg/usecases"
 )
 
 const (
@@ -86,7 +82,6 @@ func TestMain(m *testing.M) {
 			r.GetCustomerProfileCollectionName(),
 			r.GetExperimentParticipantCollectionName(),
 			r.GetKCYProcessCollectionName(),
-			r.GetMarketingDataCollectionName(),
 			r.GetNHIFDetailsCollectionName(),
 			r.GetProfileNudgesCollectionName(),
 			r.GetSMSCollectionName(),
@@ -148,26 +143,18 @@ func InitializeTestService(ctx context.Context) (*interactor.Interactor, error)
 	firestoreExtension := fb.NewFirestoreClientExtension(fsc)
 	fr := fb.NewFirebaseRepository(firestoreExtension, fbc)
 	engage := engagement.NewServiceEngagementImpl(engagementClient, ext)
-	// hubspot usecases
-	hubspotService := hubspot.NewHubSpotService()
-	hubspotfr, err := hubspotRepo.NewHubSpotFirebaseRepository(ctx, hubspotService)
-	if err != nil {
-		return nil, fmt.Errorf("failed to initialize hubspot crm repository: %w", err)
-	}
-	hubspotUsecases := hubspotUsecases.NewHubSpotUsecases(hubspotfr)
-	crmExt := crmExt.NewCrmService(hubspotUsecases)
+
 	ps, err := pubsubmessaging.NewServicePubSubMessaging(
 		pubSubClient,
 		ext,
-		crmExt,
 		fr,
 	)
 	if err != nil {
 		return nil, fmt.Errorf("unable to initialize new pubsub messaging service: %w", err)
 	}
 	mes := messaging.NewServiceMessagingImpl(ext)
 	pinExt := extension.NewPINExtensionImpl()
-	profile := usecases.NewProfileUseCase(fr, ext, engage, ps, crmExt)
+	profile := usecases.NewProfileUseCase(fr, ext, engage, ps)
 	supplier := usecases.NewSupplierUseCases(fr, profile, engage, mes, ext, ps)
 	login := usecases.NewLoginUseCases(fr, profile, ext, pinExt)
 	survey := usecases.NewSurveyUseCases(fr, ext)
@@ -183,7 +170,6 @@ func InitializeTestService(ctx context.Context) (*interactor.Interactor, error)
 		UserPIN:    userpin,
 		Engagement: engage,
 		PubSub:     ps,
-		CrmExt:     crmExt,
 	}, nil
 }
 

pkg/onboarding/infrastructure/services/pubsub/mock/service_mock.go

@@ -3,8 +3,6 @@ package mock
 import (
 	"context"
 	"net/http"
-
-	"gitlab.slade360emr.com/go/commontools/crm/pkg/domain"
 )
 
 // FakeServicePubSub ...
@@ -29,8 +27,6 @@ type FakeServicePubSub struct {
 		r *http.Request,
 	)
 	AddEngagementPubsubNameSpaceFn func(topic string) string
-	NotifyCreateContactFn          func(ctx context.Context, contact domain.CRMContact) error
-	NotifyUpdateContactFn          func(ctx context.Context, contact domain.CRMContact) error
 }
 
 // AddPubSubNamespace ...
@@ -88,13 +84,3 @@ func (m *FakeServicePubSub) ReceivePubSubPushMessages(
 func (m *FakeServicePubSub) AddEngagementPubsubNameSpace(topic string) string {
 	return m.AddEngagementPubsubNameSpaceFn(topic)
 }
-
-// NotifyCreateContact ..
-func (m *FakeServicePubSub) NotifyCreateContact(ctx context.Context, contact domain.CRMContact) error {
-	return m.NotifyCreateContactFn(ctx, contact)
-}
-
-// NotifyUpdateContact ..
-func (m *FakeServicePubSub) NotifyUpdateContact(ctx context.Context, contact domain.CRMContact) error {
-	return m.NotifyUpdateContactFn(ctx, contact)
-}