From cc62620719faa47175a62e71ba0f684393432eaf Mon Sep 17 00:00:00 2001
From: meninjar <meninjar@dev.meninjar.rssa>
Date: Mon, 4 May 2026 03:41:24 +0000
Subject: [PATCH] Update worker
 medication,servicerequest,imagingstudy,medicationrequest,medicationdispance

---
 internal/worker/worker.go | 125 ++++++++++++++++++++------------------
 1 file changed, 65 insertions(+), 60 deletions(-)

diff --git a/internal/worker/worker.go b/internal/worker/worker.go
index e64547d..98cc9c7 100644
--- a/internal/worker/worker.go
+++ b/internal/worker/worker.go
@@ -11,6 +11,11 @@ import (
 	"service/internal/infrastructure/database"
 	"service/internal/interfaces/satusehat"
 	"service/internal/master/kfa"
+	"service/internal/worker/satusehat/imagingstudy"
+	"service/internal/worker/satusehat/medication"
+	"service/internal/worker/satusehat/medicationdispense"
+	"service/internal/worker/satusehat/medicationrequest"
+	"service/internal/worker/satusehat/servicerequest"
 	"service/pkg/logger"
 )
 
@@ -81,17 +86,17 @@ func (m *Manager) Start(ctx context.Context) {
 		// 		// condition.NewWorker(...).Run(c)
 		// 	},
 		// },
-		// {
-		// 	name:  "Medication (Master)",
-		// 	delay: 0, // Master data berjalan seketika
-		// 	run: func(c context.Context) {
-		// 		medication.NewWorker(medication.Config{
-		// 			DBManager:       m.db,
-		// 			InternalBaseURL: internalBaseURL,
-		// 			OrganizationID:  orgID,
-		// 		}, m).Run(c)
-		// 	},
-		// },
+		{
+			name:  "Medication (Master)",
+			delay: 0, // Master data berjalan seketika
+			run: func(c context.Context) {
+				medication.NewWorker(medication.Config{
+					DBManager:       m.db,
+					InternalBaseURL: internalBaseURL,
+					OrganizationID:  orgID,
+				}, m).Run(c)
+			},
+		},
 		// {
 		// 	name:  "Observation",
 		// 	delay: 2 * time.Second,
@@ -143,17 +148,17 @@ func (m *Manager) Start(ctx context.Context) {
 		// 		}, m).Run(c)
 		// 	},
 		// },
-		// {
-		// 	name:  "ServiceRequest (Radiology)",
-		// 	delay: 2 * time.Second,
-		// 	run: func(c context.Context) {
-		// 		servicerequest.NewRadiologyWorker(servicerequest.Config{
-		// 			DBManager:       m.db,
-		// 			InternalBaseURL: internalBaseURL,
-		// 			OrganizationID:  orgID,
-		// 		}, m).Run(c)
-		// 	},
-		// },
+		{
+			name:  "ServiceRequest (Radiology)",
+			delay: 2 * time.Second,
+			run: func(c context.Context) {
+				servicerequest.NewRadiologyWorker(servicerequest.Config{
+					DBManager:       m.db,
+					InternalBaseURL: internalBaseURL,
+					OrganizationID:  orgID,
+				}, m).Run(c)
+			},
+		},
 		// {
 		// 	name:  "Specimen",
 		// 	delay: 2 * time.Second,
@@ -170,16 +175,16 @@ func (m *Manager) Start(ctx context.Context) {
 		// 		// diagnosticreport.NewWorker(...).Run(c)
 		// 	},
 		// },
-		// {
-		// 	name:  "ImagingStudy",
-		// 	delay: 2 * time.Second,
-		// 	run: func(c context.Context) {
-		// 		// The Manager 'm' now acts as the TokenManager
-		// 		imagingstudy.NewWorker(imagingstudy.Config{
-		// 			DBManager: m.db, InternalBaseURL: internalBaseURL, OrganizationID: orgID,
-		// 		}, m).Run(c)
-		// 	},
-		// },
+		{
+			name:  "ImagingStudy",
+			delay: 2 * time.Second,
+			run: func(c context.Context) {
+				// The Manager 'm' now acts as the TokenManager
+				imagingstudy.NewWorker(imagingstudy.Config{
+					DBManager: m.db, InternalBaseURL: internalBaseURL, OrganizationID: orgID,
+				}, m).Run(c)
+			},
+		},
 		// {
 		// 	name:  "Composition",
 		// 	delay: 2 * time.Second,
@@ -204,39 +209,39 @@ func (m *Manager) Start(ctx context.Context) {
 		// 		// episodeofcare.NewWorker(...).Run(c)
 		// 	},
 		// },
-		// {
-		// 	name:  "MedicationRequest",
-		// 	delay: 2 * time.Second,
-		// 	run: func(c context.Context) {
-		// 		medicationrequest.NewWorker(medicationrequest.Config{
-		// 			DBManager:       m.db,
-		// 			InternalBaseURL: internalBaseURL,
-		// 			OrganizationID:  orgID,
-		// 		}, m).Run(c)
-		// 	},
-		// },
-		// {
-		// 	name:  "MedicationDispense",
-		// 	delay: 2 * time.Second,
-		// 	run: func(c context.Context) {
-		// 		medicationdispense.NewWorker(medicationdispense.Config{
-		// 			DBManager:       m.db,
-		// 			InternalBaseURL: internalBaseURL,
-		// 			OrganizationID:  orgID,
-		// 		}, m).Run(c)
-		// 	},
-		// },
 		{
-			name:  "KFA Master Puller",
-			delay: 5 * time.Second,
+			name:  "MedicationRequest",
+			delay: 2 * time.Second,
 			run: func(c context.Context) {
-				repo := kfa.NewCommandRepository(m.db, "default")
-				kfa.NewWorker(kfa.Config{
+				medicationrequest.NewWorker(medicationrequest.Config{
+					DBManager:       m.db,
 					InternalBaseURL: internalBaseURL,
-					PageSize:        100,
-				}, repo, m).Run(c)
+					OrganizationID:  orgID,
+				}, m).Run(c)
 			},
 		},
+		{
+			name:  "MedicationDispense",
+			delay: 2 * time.Second,
+			run: func(c context.Context) {
+				medicationdispense.NewWorker(medicationdispense.Config{
+					DBManager:       m.db,
+					InternalBaseURL: internalBaseURL,
+					OrganizationID:  orgID,
+				}, m).Run(c)
+			},
+		},
+		// {
+		// 	name:  "KFA Master Puller",
+		// 	delay: 5 * time.Second,
+		// 	run: func(c context.Context) {
+		// 		repo := kfa.NewCommandRepository(m.db, "default")
+		// 		kfa.NewWorker(kfa.Config{
+		// 			InternalBaseURL: internalBaseURL,
+		// 			PageSize:        100,
+		// 		}, repo, m).Run(c)
+		// 	},
+		// },
 		// {
 		// 	name:  "MedicationStatement",
 		// 	delay: 2 * time.Second,