Function TestTokenizeAllPII

identity_test.go:458–494

(t *testing.T)

}

func TestTokenizeAllPII(t *testing.T) {
	datasource, mock, err := newTestDataSource()
	if err != nil {
		t.Fatalf("Error creating test data source: %s", err)
	}

	d, err := NewLedgerForge(datasource)
	if err != nil {
		t.Fatalf("Error creating LedgerForge instance: %s", err)
	}

	testID := "idt_123"

	for i := 0; i < 10; i++ {
		mock.ExpectBegin()
		row := sqlmock.NewRows([]string{
			"identity_id", "identity_type", "first_name", "last_name", "other_names", "gender", "dob",
			"email_address", "phone_number", "nationality", "organization_name", "category",
			"street", "country", "state", "post_code", "city", "created_at", "meta_data",
		}).AddRow(
			testID, "Individual", "John", "Doe", "Other", "Male", time.Now(),
			"john@example.com", "1234567890", "US", "Org", "Cat",
			"Street", "Country", "State", "12345", "City", time.Now(), `{}`,
		)
		mock.ExpectQuery("SELECT .* FROM ledgerforge.identity WHERE identity_id =").
			WithArgs(testID).
			WillReturnRows(row)
		mock.ExpectCommit()

		mock.ExpectExec("UPDATE ledgerforge.identity SET").
			WithArgs(sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), testID).
			WillReturnResult(sqlmock.NewResult(1, 1))
	}

	err = d.TokenizeAllPII(testID)
	assert.NoError(t, err)
}

func TestConvertToStructFieldName(t *testing.T) {
	tests := []struct {