member, nik ok, bpjs tested but failed from 3rd party

internal/use-case/bpjs-plugin/member/helper.go

@@ -0,0 +1,18 @@
+package member
+
+import (
+	"fmt"
+	e "simrs-vx/internal/domain/bpjs-entities/member"
+	ibpjs "simrs-vx/internal/infra/bpjs"
+)
+
+func endpointMapper(input *e.ReadListDto) string {
+	switch input.ReferenceType {
+	case e.RTBpjs:
+		return fmt.Sprintf("%speserta/nokartu?noKartu=%s&tglpelayanan=%s", ibpjs.O.BaseUrl, input.PathValue1, input.PathValue2)
+	case e.RTNik:
+		return fmt.Sprintf("%speserta/nik?nik=%s&tglpelayanan=%s", ibpjs.O.BaseUrl, input.PathValue1, input.PathValue2)
+	default:
+		return ""
+	}
+}

internal/use-case/bpjs-plugin/member/plugin.go

@@ -0,0 +1,37 @@
+package member
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	e "simrs-vx/internal/domain/bpjs-entities/member"
+
+	"gorm.io/gorm"
+)
+
+func ReadList(input *e.ReadListDto, data *e.Response, tx *gorm.DB) error {
+	endpoint := endpointMapper(input)
+	req, err := http.NewRequest("GET", endpoint, nil)
+	if err != nil {
+		return err
+	}
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+
+	if err := json.Unmarshal(body, &data); err != nil {
+		return fmt.Errorf("failed to parse response JSON: %w", err)
+	}
+
+	return nil
+}

internal/use-case/bpjs-use-case/member/case.go

@@ -0,0 +1,50 @@
+package member
+
+import (
+	e "simrs-vx/internal/domain/bpjs-entities/member"
+
+	dg "github.com/karincake/apem/db-gorm-pg"
+
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+
+	"gorm.io/gorm"
+)
+
+const source = "member"
+
+func ReadList(input e.ReadListDto) (*e.Response, error) {
+	var data e.Response
+	var err error
+
+	event := pl.Event{
+		Feature: "ReadList",
+		Source:  source,
+	}
+
+	// Start log
+	pl.SetLogInfo(&event, input, "started", "readList")
+
+	err = dg.I.Transaction(func(tx *gorm.DB) error {
+		mwRunner := newMiddlewareRunner(&event, tx)
+		mwRunner.setMwType(pu.MWTPre)
+		// Run pre-middleware
+		if err := mwRunner.RunReadListMiddleware(readListPreMw, &input, &data); err != nil {
+			return err
+		}
+
+		mwRunner.setMwType(pu.MWTPost)
+		// Run post-middleware
+		if err := mwRunner.RunReadListMiddleware(readListPostMw, &input, &data); err != nil {
+			return err
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &data, nil
+}

internal/use-case/bpjs-use-case/member/middleware-runner.go

@@ -0,0 +1,42 @@
+package member
+
+import (
+	e "simrs-vx/internal/domain/bpjs-entities/member"
+	pl "simrs-vx/pkg/logger"
+	pu "simrs-vx/pkg/use-case-helper"
+
+	"gorm.io/gorm"
+)
+
+type middlewareRunner struct {
+	Event  *pl.Event
+	Tx     *gorm.DB
+	MwType pu.MWType
+}
+
+// NewMiddlewareExecutor creates a new middleware executor
+func newMiddlewareRunner(event *pl.Event, tx *gorm.DB) *middlewareRunner {
+	return &middlewareRunner{
+		Event: event,
+		Tx:    tx,
+	}
+}
+
+func (me *middlewareRunner) RunReadListMiddleware(middlewares []readListMw, input *e.ReadListDto, data *e.Response) error {
+	for _, middleware := range middlewares {
+		logData := pu.GetLogData(input, data)
+
+		pl.SetLogInfo(me.Event, logData, "started", middleware.Name)
+
+		if err := middleware.Func(input, data, me.Tx); err != nil {
+			return pu.HandleMiddlewareError(me.Event, string(me.MwType), middleware.Name, logData, err)
+		}
+
+		pl.SetLogInfo(me.Event, nil, "complete")
+	}
+	return nil
+}
+
+func (me *middlewareRunner) setMwType(mwType pu.MWType) {
+	me.MwType = mwType
+}

internal/use-case/bpjs-use-case/member/middleware.go

@@ -0,0 +1,12 @@
+package member
+
+import (
+	pm "simrs-vx/internal/use-case/bpjs-plugin/member"
+)
+
+func init() {
+	readListPreMw = append(readListPreMw,
+		readListMw{Name: "readList-member", Func: pm.ReadList},
+	)
+
+}

internal/use-case/bpjs-use-case/member/tycovar.go

@@ -0,0 +1,18 @@
+/*
+member is peserta
+*/
+package member
+
+import (
+	"gorm.io/gorm"
+
+	e "simrs-vx/internal/domain/bpjs-entities/member"
+)
+
+type readListMw struct {
+	Name string
+	Func func(input *e.ReadListDto, data *e.Response, tx *gorm.DB) error
+}
+
+var readListPreMw []readListMw  // ..
+var readListPostMw []readListMw // ..

internal/use-case/bpjs-use-case/reference/case.go

@@ -2,7 +2,6 @@ package reference
 
 import (
 	e "simrs-vx/internal/domain/bpjs-entities/reference"
-	// evsh "simrs-vx/internal/domain/bpjs-entities/vclaim-sep-hist"
 
 	dg "github.com/karincake/apem/db-gorm-pg"
 
@@ -16,7 +15,6 @@ const source = "reference"
 
 func ReadList(input e.ReadListDto) (*e.Response, error) {
 	var data e.Response
-	// var dataList []e.Response
 	var err error
 
 	event := pl.Event{
@@ -35,10 +33,6 @@ func ReadList(input e.ReadListDto) (*e.Response, error) {
 			return err
 		}
 
-		// if dataList, metaList, err = ReadListData(input, &event, tx); err != nil {
-		// 	return err
-		// }
-
 		mwRunner.setMwType(pu.MWTPost)
 		// Run post-middleware
 		if err := mwRunner.RunReadListMiddleware(readListPostMw, &input, &data); err != nil {

internal/use-case/bpjs-use-case/reference/helper.go

@@ -1,22 +0,0 @@
-/*
-DESCRIPTION:
-Any functions that are used internally by the use-case
-*/
-package reference
-
-// import (
-// 	e "simrs-vx/internal/domain/bpjs-entities/vclaim-sep"
-// )
-
-// func setData[T *e.CreateDto | *e.UpdateDto](input T, data *e.VclaimSep) {
-// 	var inputSrc *e.CreateDto
-// 	if inputT, ok := any(input).(*e.CreateDto); ok {
-// 		inputSrc = inputT
-// 	} else {
-// 		inputTemp := any(input).(*e.UpdateDto)
-// 		inputSrc = &inputTemp.CreateDto
-// 	}
-
-// 	data.Encounter_Id = inputSrc.Encounter_Id
-// 	data.Number = inputSrc.Number
-// }

internal/use-case/bpjs-use-case/reference/lib.go

@@ -1 +0,0 @@
-package reference