Perbaikan Service Satu Sehat

This commit is contained in:
meninjar
2026-04-14 05:43:33 +00:00
parent 0adf9ef073
commit 135c631021
83 changed files with 95 additions and 5578 deletions
+14 -16
View File
@@ -3,7 +3,6 @@ package main
import (
"context"
"fmt"
"net/http"
"os"
"os/signal"
@@ -28,7 +27,6 @@ import (
satuSehatProcedure "service/internal/satusehat/usecase/procedure"
"service/pkg/logger"
imagingStudyWorker "service/internal/worker/satusehat/imagingstudy"
// roleComponent "service/internal/master/role/component"
roleMaster "service/internal/master/role/master"
rolePages "service/internal/master/role/pages"
@@ -197,21 +195,21 @@ func main() {
// Gunakan errgroup untuk mengelola lifecycle server
g, ctx := errgroup.WithContext(ctx)
// --- [NEW] Start Background Workers ---
if cfg.SatuSehat.Enabled {
imagingStudyWorkerCfg := imagingStudyWorker.Config{
DBManager: dbService,
InternalBaseURL: fmt.Sprintf("http://localhost:%d%s", cfg.Server.REST.Port, cfg.Swagger.BasePath), // otomatis: http://localhost:8080/api/v1
InternalToken: "", // Isi token di sini jika endpoint internal Usecase Anda membutuhkan Bearer Token
OrganizationID: cfg.SatuSehat.OrgID,
}
isWorker := imagingStudyWorker.NewWorker(imagingStudyWorkerCfg)
// // --- [NEW] Start Background Workers ---
// if cfg.SatuSehat.Enabled {
// imagingStudyWorkerCfg := imagingStudyWorker.Config{
// DBManager: dbService,
// InternalBaseURL: fmt.Sprintf("http://localhost:%d%s", cfg.Server.REST.Port, cfg.Swagger.BasePath), // otomatis: http://localhost:8080/api/v1
// InternalToken: "", // Isi token di sini jika endpoint internal Usecase Anda membutuhkan Bearer Token
// OrganizationID: cfg.SatuSehat.OrgID,
// }
// isWorker := imagingStudyWorker.NewWorker(imagingStudyWorkerCfg)
g.Go(func() error {
isWorker.Run(ctx)
return nil
})
}
// g.Go(func() error {
// isWorker.Run(ctx)
// return nil
// })
// }
serverCount := 0