Background Jobs

backend/pkg/constants.go

@@ -1,6 +1,9 @@
 package pkg
 
 type ResourceGraphType string
+type BackgroundJobStatus string
+type BackgroundJobType string
+type BackgroundJobSchedule string
 
 const (
 	ResourceListPageSize int = 20
@@ -10,13 +13,27 @@ const (
 	ContextKeyTypeLogger         string = "LOGGER"
 	ContextKeyTypeEventBusServer string = "EVENT_BUS_SERVER"
 
-	ContextKeyTypeAuthUsername string = "AUTH_USERNAME"
-	ContextKeyTypeAuthToken    string = "AUTH_TOKEN"
+	ContextKeyTypeAuthUsername    string = "AUTH_USERNAME"
+	ContextKeyTypeAuthToken       string = "AUTH_TOKEN"
+	ContextKeyTypeBackgroundJobID string = "BACKGROUND_JOB_ID"
 
 	FhirResourceTypeComposition string = "Composition"
 
 	ResourceGraphTypeMedicalHistory ResourceGraphType = "MedicalHistory"
 	ResourceGraphTypeAddressBook    ResourceGraphType = "AddressBook"
 	ResourceGraphTypeMedications    ResourceGraphType = "Medications"
 	ResourceGraphTypeBillingReport  ResourceGraphType = "BillingReport"
+
+	BackgroundJobStatusReady  BackgroundJobStatus = "STATUS_READY"
+	BackgroundJobStatusLocked BackgroundJobStatus = "STATUS_LOCKED"
+	BackgroundJobStatusFailed BackgroundJobStatus = "STATUS_FAILED"
+	BackgroundJobStatusDone   BackgroundJobStatus = "STATUS_DONE"
+
+	BackgroundJobTypeSync          BackgroundJobType = "SYNC"
+	BackgroundJobTypeScheduledSync BackgroundJobType = "SCHEDULED_SYNC"
+
+	BackgroundJobScheduleDaily    BackgroundJobSchedule = "DAILY"
+	BackgroundJobScheduleWeekly   BackgroundJobSchedule = "WEEKLY"
+	BackgroundJobScheduleBiWeekly BackgroundJobSchedule = "BIWEEKLY"
+	BackgroundJobScheduleMonthly  BackgroundJobSchedule = "MONTHLY"
 )

backend/pkg/database/interface.go

@@ -42,11 +42,18 @@ type DatabaseRepository interface {
 	CreateGlossaryEntry(ctx context.Context, glossaryEntry *models.Glossary) error
 	GetGlossaryEntry(ctx context.Context, code string, codeSystem string) (*models.Glossary, error)
 
+	//background jobs
+	CreateBackgroundJob(ctx context.Context, backgroundJob *models.BackgroundJob) error
+	GetBackgroundJob(ctx context.Context, backgroundJobId string) (*models.BackgroundJob, error)
+	UpdateBackgroundJob(ctx context.Context, backgroundJob *models.BackgroundJob) error
+	ListBackgroundJobs(ctx context.Context, queryOptions models.BackgroundJobQueryOptions) ([]models.BackgroundJob, error)
+
 	//settings
 	LoadUserSettings(ctx context.Context) (*models.UserSettings, error)
 	SaveUserSettings(context.Context, *models.UserSettings) error
 	PopulateDefaultUserSettings(ctx context.Context, userId uuid.UUID) error
 
 	//used by fasten-sources Clients
 	UpsertRawResource(ctx context.Context, sourceCredentials sourcePkg.SourceCredential, rawResource sourcePkg.RawResourceFhir) (bool, error)
+	BackgroundJobCheckpoint(ctx context.Context, checkpointData map[string]interface{}, errorData map[string]interface{})
 }