Function TestCreateIdentity_Success

database/identity_test.go:32–72

(t *testing.T)

)

func TestCreateIdentity_Success(t *testing.T) {
	db, mock, err := sqlmock.New()
	assert.NoError(t, err)
	defer func() { _ = db.Close() }()

	ds := Datasource{Conn: db}

	identity := model.Identity{
		IdentityType:     "individual",
		FirstName:        "John",
		LastName:         "Doe",
		OtherNames:       "JD",
		Gender:           "Male",
		DOB:              time.Now(),
		EmailAddress:     "john.doe@example.com",
		PhoneNumber:      "123456789",
		Nationality:      "US",
		OrganizationName: "Acme Corp",
		Category:         "Customer",
		Street:           "123 Main St",
		Country:          "USA",
		State:            "CA",
		PostCode:         "90210",
		City:             "Los Angeles",
		MetaData: map[string]interface{}{
			"key": "value",
		},
	}

	metaDataJSON, err := json.Marshal(identity.MetaData)
	assert.NoError(t, err)

	mock.ExpectExec("INSERT INTO ledgerforge.identity").
		WithArgs(sqlmock.AnyArg(), identity.IdentityType, identity.FirstName, identity.LastName, identity.OtherNames, identity.Gender, identity.DOB, identity.EmailAddress, identity.PhoneNumber, identity.Nationality, identity.OrganizationName, identity.Category, identity.Street, identity.Country, identity.State, identity.PostCode, identity.City, sqlmock.AnyArg(), metaDataJSON).
		WillReturnResult(sqlmock.NewResult(1, 1))

	createdIdentity, err := ds.CreateIdentity(identity)
	assert.NoError(t, err)
	assert.NotEmpty(t, createdIdentity.IdentityID)
	assert.WithinDuration(t, time.Now(), createdIdentity.CreatedAt, time.Second)
}

func TestCreateIdentity_Fail(t *testing.T) {
	db, mock, err := sqlmock.New()