Skip to content

Commit

Permalink
chore: usecase interface and implementation (#132)
Browse files Browse the repository at this point in the history
  • Loading branch information
@Muchogoc
Muchogoc committed Sep 2, 2021
1 parent d760aaa commit 43cd11d
Show file tree
Hide file tree
Showing 25 changed files with 1,199 additions and 818 deletions.
6 changes: 4 additions & 2 deletions pkg/onboarding/application/extension/base.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -92,9 +92,11 @@ type BaseExtensionImpl struct {
}

// NewBaseExtensionImpl ...
func NewBaseExtensionImpl(fc firebasetools.IFirebaseClient) BaseExtension {
func NewBaseExtensionImpl() BaseExtension {
client := &firebasetools.FirebaseClient{}

return &BaseExtensionImpl{
fc: fc,
fc: client,
}
}

Expand Down
3 changes: 1 addition & 2 deletions pkg/onboarding/application/utils/login_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import (
"os"
"testing"

"github.com/savannahghi/firebasetools"
"github.com/savannahghi/onboarding/pkg/onboarding/application/extension"
"github.com/savannahghi/onboarding/pkg/onboarding/application/utils"
"github.com/stretchr/testify/assert"
Expand All @@ -14,7 +13,7 @@ import (

func TestLoginClientMissingEnvs(t *testing.T) {

baseExt := extension.NewBaseExtensionImpl(&firebasetools.FirebaseClient{})
baseExt := extension.NewBaseExtensionImpl()

username := "username"
password := "password"
Expand Down
122 changes: 41 additions & 81 deletions pkg/onboarding/infrastructure/database/fb/firebase_integration_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"testing"

"github.com/savannahghi/onboarding/pkg/onboarding/application/dto"
"github.com/savannahghi/onboarding/pkg/onboarding/application/utils"
"github.com/savannahghi/onboarding/pkg/onboarding/infrastructure"

"fmt"

Expand All @@ -22,27 +22,21 @@ import (
"github.com/savannahghi/interserviceclient"
"github.com/savannahghi/onboarding/pkg/onboarding/application/extension"
"github.com/savannahghi/onboarding/pkg/onboarding/domain"
"github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/database"
"github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/database/fb"
"github.com/savannahghi/profileutils"
"github.com/savannahghi/scalarutils"
"github.com/savannahghi/serverutils"
"github.com/stretchr/testify/assert"

"cloud.google.com/go/firestore"
"cloud.google.com/go/pubsub"
"firebase.google.com/go/auth"

"github.com/savannahghi/onboarding/pkg/onboarding/infrastructure/services/engagement"

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"
)

const (
engagementService = "engagement"
ediService = "edi"
var (
firestoreClient *firestore.Client
firebaseAuth *auth.Client
)

func TestMain(m *testing.M) {
Expand All @@ -69,6 +63,8 @@ func TestMain(m *testing.M) {
log.Printf("failed to initialize test FireBase client")
return
}
firestoreClient = fsc
firebaseAuth = fbc

purgeRecords := func() {
collections := []string{
Expand Down Expand Up @@ -96,7 +92,7 @@ func TestMain(m *testing.M) {
log.Printf("Tearing tests down ...")
purgeRecords()

// restore environment varibles to original values
// restore environment variables to original values
os.Setenv(envOriginalValue, "ENVIRONMENT")
os.Setenv("DEBUG", debugEnvValue)
os.Setenv("ROOT_COLLECTION_SUFFIX", collectionEnvValue)
Expand All @@ -105,72 +101,35 @@ func TestMain(m *testing.M) {
}

func InitializeTestService(ctx context.Context) (*interactor.Interactor, error) {
db := database.NewDbService()
fsc, fbc := InitializeTestFirebaseClient(ctx)
if fsc == nil {
return nil, fmt.Errorf("failed to initialize test FireStore client")

}
if fbc == nil {
return nil, fmt.Errorf("failed to initialize test FireBase client")

}
infrastructure, _ := infrastructure.NewInfrastructureInteractor()

projectID, err := serverutils.GetEnvVar(serverutils.GoogleCloudProjectIDEnvVarName)
if err != nil {
return nil, fmt.Errorf(
"can't get projectID from env var `%s`: %w",
serverutils.GoogleCloudProjectIDEnvVarName,
err,
)
}
pubSubClient, err := pubsub.NewClient(ctx, projectID)
if err != nil {
return nil, fmt.Errorf("unable to initialize pubsub client: %w", err)
}
ext := extension.NewBaseExtensionImpl()

ext := extension.NewBaseExtensionImpl(&firebasetools.FirebaseClient{})

// Initialize ISC clients
engagementClient := utils.NewInterServiceClient(engagementService, ext)

firestoreExtension := fb.NewFirestoreClientExtension(fsc)
fr := fb.NewFirebaseRepository(firestoreExtension, fbc)
engage := engagement.NewServiceEngagementImpl(engagementClient, ext)

ps, err := pubsubmessaging.NewServicePubSubMessaging(
pubSubClient,
ext,
*db,
)
if err != nil {
return nil, fmt.Errorf("unable to initialize new pubsub messaging service: %w", err)
}
pinExt := extension.NewPINExtensionImpl()
profile := usecases.NewProfileUseCase(fr, ext, engage, ps)
login := usecases.NewLoginUseCases(fr, profile, ext, pinExt)
survey := usecases.NewSurveyUseCases(fr, ext)
userpin := usecases.NewUserPinUseCase(fr, profile, ext, pinExt, engage)
su := usecases.NewSignUpUseCases(fr, profile, userpin, ext, engage, ps)
profile := usecases.NewProfileUseCase(infrastructure, ext)
login := usecases.NewLoginUseCases(infrastructure, profile, ext, pinExt)
survey := usecases.NewSurveyUseCases(infrastructure, ext)
userpin := usecases.NewUserPinUseCase(infrastructure, profile, ext, pinExt)
su := usecases.NewSignUpUseCases(infrastructure, profile, userpin, ext)

return &interactor.Interactor{
Onboarding: profile,
Signup: su,
Login: login,
Survey: survey,
UserPIN: userpin,
Engagement: engage,
PubSub: ps,
}, nil
}

func generateTestOTP(t *testing.T, phone string) (*profileutils.OtpResponse, error) {
ctx := context.Background()
s, err := InitializeTestService(ctx)
s, err := infrastructure.NewInfrastructureInteractor()
if err != nil {
return nil, fmt.Errorf("unable to initialize test service: %v", err)
}
testAppID := uuid.New().String()
return s.Engagement.GenerateAndSendOTP(ctx, phone, &testAppID)
return s.GenerateAndSendOTP(ctx, phone, &testAppID)
}

// CreateTestUserByPhone creates a user that is to be used in
Expand All @@ -192,7 +151,7 @@ func CreateOrLoginTestUserByPhone(t *testing.T) (*auth.Token, error) {
}
if !exists {
otp, err := generateTestOTP(t, phone)
log.Println("The otp is:", otp)
log.Println("The otp is:", otp.OTP)
if err != nil {
return nil, fmt.Errorf("failed to generate test OTP: %v", err)
}
Expand Down Expand Up @@ -278,7 +237,7 @@ func TestPurgeUserByPhoneNumber(t *testing.T) {
ctx, auth, err := GetTestAuthenticatedContext(t)
assert.Nil(t, err)
assert.NotNil(t, auth)
fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand All @@ -287,6 +246,7 @@ func TestPurgeUserByPhoneNumber(t *testing.T) {
t.Errorf("failed to initialize test FireBase client")
return
}

firestoreExtension := fb.NewFirestoreClientExtension(fsc)
fr := fb.NewFirebaseRepository(firestoreExtension, fbc)
profile, err := fr.GetUserProfileByUID(ctx, auth.UID, false)
Expand Down Expand Up @@ -360,7 +320,7 @@ func TestRepository_ExchangeRefreshTokenForIDToken(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -462,7 +422,7 @@ func TestRepository_GetUserProfileByPhoneNumber(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -526,7 +486,7 @@ func TestRepository_GetUserProfileByPrimaryPhoneNumber(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -602,7 +562,7 @@ func TestRepository_GetUserProfileByUID(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -671,7 +631,7 @@ func TestRepository_GetUserProfileByID(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -746,7 +706,7 @@ func TestRepository_CheckIfPhoneNumberExists(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -832,7 +792,7 @@ func TestRepository_CheckIfUsernameExists(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -918,7 +878,7 @@ func TestRepository_GetPINByProfileID(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1014,7 +974,7 @@ func TestRepository_SavePIN(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1094,7 +1054,7 @@ func TestRepository_UpdatePIN(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1178,7 +1138,7 @@ func TestRepository_RecordPostVisitSurvey(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1247,7 +1207,7 @@ func TestRepository_UpdateSuspended(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1319,7 +1279,7 @@ func TestRepository_UpdateVerifiedUIDS(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1388,7 +1348,7 @@ func TestRepository_UpdateVerifiedIdentifiers(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1495,7 +1455,7 @@ func TestRepository_UpdateCovers(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1574,7 +1534,7 @@ func TestRepository_UpdateSecondaryEmailAddresses(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1642,7 +1602,7 @@ func TestRepository_UpdatePrimaryEmailAddress(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1718,7 +1678,7 @@ func TestRepository_UpdatePrimaryPhoneNumber(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1793,7 +1753,7 @@ func TestRepository_UpdateSecondaryPhoneNumbers(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1869,7 +1829,7 @@ func TestRepository_UpdateBioData(t *testing.T) {
return
}

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down Expand Up @@ -1998,7 +1958,7 @@ func TestRepository_UpdateBioData(t *testing.T) {
func TestRepositoryGenerateAuthCredentialsForAnonymousUser(t *testing.T) {
ctx := context.Background()

fsc, fbc := InitializeTestFirebaseClient(ctx)
fsc, fbc := firestoreClient, firebaseAuth
if fsc == nil {
t.Errorf("failed to initialize test FireStore client")
return
Expand Down
Loading

0 comments on commit 43cd11d

Please sign in to comment.