BCDA-9876: enable pac data v3 ssp (#1327)

## 🎫 Ticket

https://jira.cms.gov/browse/BCDA-9876

## 🛠 Changes

New Behavior:
- SSP model entities can access both partially adjudicated and
adjudicated claims data via BCDA v3
- KCC model entities can access only adjudicated claims data 

## ℹ️ Context

We don't plan to add any new model types for v1/v2 access. Like IOTA,
any new models should be limited to v3. Going forward, the default will
be access to both adjudicated and partially adjudicated claims data via
v3.

## 🧪 Validation

Unit test suite

Author: bhagatparwinder

bcda/service/config.go

@@ -34,6 +34,7 @@ type Config struct {
 	CutoffDuration          time.Duration
 	RateLimitConfig         RateLimitConfig `conf:"rate_limit_config"`
 	V1V2DenyRegexes         []string        `conf:"v1_v2_deny_regexes"`
+	V3NoPartialClaimsModels []string        `conf:"v3_no_partial_claims_models"`
 	// Use the squash tag to allow the RunoutConfigs to avoid requiring the parameters
 	// to be defined as a child of RunoutConfig.
 	// Ex: Without the ,squash, we would have to have RunoutConfig.RUNOUT_CUTOFF_DATE_DAYS

bcda/service/service.go

@@ -5,6 +5,7 @@ import (
 	goerrors "errors"
 	"fmt"
 	"regexp"
+	"slices"
 	"strings"
 	"time"
 
@@ -51,7 +52,8 @@ type service struct {
 	bbBasePath        string
 
 	// These are always searched in order and first matching config is used for any given ACO.
-	acoConfigs []ACOConfig
+	acoConfigs              []ACOConfig
+	v3NoPartialClaimsModels []string
 }
 
 func NewService(r models.Repository, cfg *Config, basePath string) Service {
@@ -68,8 +70,9 @@ func NewService(r models.Repository, cfg *Config, basePath string) Service {
 			claimThruDate:  cfg.RunoutConfig.claimThru,
 			CutoffDuration: cfg.RunoutConfig.CutoffDuration,
 		},
-		bbBasePath: basePath,
-		acoConfigs: cfg.ACOConfigs,
+		bbBasePath:              basePath,
+		acoConfigs:              cfg.ACOConfigs,
+		v3NoPartialClaimsModels: cfg.V3NoPartialClaimsModels,
 	}
 }
 
@@ -277,6 +280,15 @@ func (s *service) createQueueJobs(ctx context.Context, args worker_types.Prepare
 		return nil, fmt.Errorf("failed to load or match ACO config (or potentially no ACO Configs set), CMS ID: %+v", args.CMSID)
 	}
 
+	effectiveDataTypes := acoCfg.Data
+	if args.BFDPath == constants.BFDV3Path {
+		excluded := slices.Contains(s.v3NoPartialClaimsModels, acoCfg.Model)
+		if !excluded && !slices.Contains(acoCfg.Data, constants.PartiallyAdjudicated) {
+			effectiveDataTypes = append([]string(nil), acoCfg.Data...)
+			effectiveDataTypes = append(effectiveDataTypes, constants.PartiallyAdjudicated)
+		}
+	}
+
 	for _, rt := range args.ResourceTypes {
 		maxBeneficiaries, err := getMaxBeneCount(rt)
 		if err != nil {
@@ -290,7 +302,7 @@ func (s *service) createQueueJobs(ctx context.Context, args worker_types.Prepare
 			jobIDs = append(jobIDs, fmt.Sprint(b.ID))
 			if len(jobIDs) >= maxBeneficiaries || rowCount >= len(beneficiaries) {
 				// Create separate jobs for each data type if needed
-				for _, dataType := range acoCfg.Data {
+				for _, dataType := range effectiveDataTypes {
 					// conditions.TransactionTime references the last time adjudicated data
 					// was updated in the BB client. If we are queuing up a partially-adjudicated
 					// data job, we need to assume that the adjudicated and partially-adjudicated

bcda/service/service_test.go

@@ -1844,6 +1844,76 @@ func TestCreateQueueJobs_Fail_ACOConfigMismatch(t *testing.T) {
 	assert.ErrorContains(t, err, "failed to load or match ACO config (or potentially no ACO Configs set), CMS ID:")
 }
 
+func TestCreateQueueJobs_V3_SSP_GetsPartiallyAdjudicated(t *testing.T) {
+	// SSP with only adjudicated in config gets both adjudicated and partially-adjudicated jobs when using v3.
+	sspACO := ACOConfig{
+		Model:      "SSP",
+		patternExp: regexp.MustCompile(`^A\d{4}`),
+		Data:       []string{constants.Adjudicated},
+	}
+	cfg := &Config{
+		CutoffDuration:          -50 * time.Hour,
+		SuppressionLookbackDays: int(30),
+		RunoutConfig:            RunoutConfig{CutoffDuration: defaultRunoutCutoff, claimThru: defaultRunoutClaimThru},
+		ACOConfigs:              []ACOConfig{sspACO},
+		V3NoPartialClaimsModels: []string{"CKCC"},
+	}
+	repository := models.NewMockRepository(t)
+	svc := NewService(repository, cfg, "").(*service)
+	ctx := context.WithValue(context.Background(), middleware.CtxTransactionKey, "test-txn")
+	args := worker_types.PrepareJobArgs{
+		Job:           models.Job{ID: 1, TransactionTime: time.Now()},
+		CMSID:         "A1234",
+		ACOID:         uuid.NewUUID(),
+		BFDPath:       constants.BFDV3Path,
+		ResourceTypes: []string{"ExplanationOfBenefit", "Claim"},
+		CreationTime:  time.Now(),
+	}
+	benes := []*models.CCLFBeneficiary{getCCLFBeneficiary(1, "MBI1")}
+	jobs, err := svc.createQueueJobs(ctx, args, time.Time{}, benes)
+	assert.NoError(t, err)
+	// EOB supports only adjudicated; Claim supports only partially-adjudicated. So we get 2 jobs (one of each data type).
+	assert.Len(t, jobs, 2)
+	dataTypes := make([]string, len(jobs))
+	for i, j := range jobs {
+		dataTypes[i] = j.DataType
+	}
+	assert.Contains(t, dataTypes, constants.Adjudicated)
+	assert.Contains(t, dataTypes, constants.PartiallyAdjudicated)
+}
+
+func TestCreateQueueJobs_V3_KCC_AdjudicatedOnly(t *testing.T) {
+	// KCC (CKCC) with only adjudicated in config gets only adjudicated jobs in v3 (no PAC).
+	kccACO := ACOConfig{
+		Model:      "CKCC",
+		patternExp: regexp.MustCompile(`C\d{4}`),
+		Data:       []string{constants.Adjudicated},
+	}
+	cfg := &Config{
+		CutoffDuration:          -50 * time.Hour,
+		SuppressionLookbackDays: int(30),
+		RunoutConfig:            RunoutConfig{CutoffDuration: defaultRunoutCutoff, claimThru: defaultRunoutClaimThru},
+		ACOConfigs:              []ACOConfig{kccACO},
+		V3NoPartialClaimsModels: []string{"CKCC"},
+	}
+	repository := models.NewMockRepository(t)
+	svc := NewService(repository, cfg, "").(*service)
+	ctx := context.WithValue(context.Background(), middleware.CtxTransactionKey, "test-txn")
+	args := worker_types.PrepareJobArgs{
+		Job:           models.Job{ID: 1, TransactionTime: time.Now()},
+		CMSID:         "C5678",
+		ACOID:         uuid.NewUUID(),
+		BFDPath:       constants.BFDV3Path,
+		ResourceTypes: []string{"ExplanationOfBenefit"},
+		CreationTime:  time.Now(),
+	}
+	benes := []*models.CCLFBeneficiary{getCCLFBeneficiary(1, "MBI1")}
+	jobs, err := svc.createQueueJobs(ctx, args, time.Time{}, benes)
+	assert.NoError(t, err)
+	assert.Len(t, jobs, 1)
+	assert.Equal(t, constants.Adjudicated, jobs[0].DataType)
+}
+
 func TestSetClaimsDate_Runout(t *testing.T) {
 	pArgs := worker_types.PrepareJobArgs{
 		CMSID:       "A0000",

conf/configs/dev.yml

@@ -80,3 +80,5 @@ rate_limit_config:
   acos: []
 v3_enabled_acos: []
 v1_v2_deny_regexes: []
+v3_no_partial_claims_models:
+  - "CKCC"

conf/configs/prod.yml

@@ -80,4 +80,6 @@ rate_limit_config:
   acos: []
 v3_enabled_acos:
   - "TEST994"
-v1_v2_deny_regexes: ["IOTA\\d{3}"]
+v1_v2_deny_regexes: ["IOTA\\d{3}"]
+v3_no_partial_claims_models:
+  - "CKCC"

conf/configs/sandbox.yml

@@ -87,3 +87,5 @@ rate_limit_config:
   acos: ["SBXBM0002"]
 v3_enabled_acos: []
 v1_v2_deny_regexes: []
+v3_no_partial_claims_models:
+  - "CKCC"

conf/configs/test.yml

@@ -80,3 +80,5 @@ rate_limit_config:
   acos: []
 v3_enabled_acos: []
 v1_v2_deny_regexes: []
+v3_no_partial_claims_models:
+  - "CKCC"