diff --git a/internal/integration/servicerequest_integration.go b/internal/integration/servicerequest_integration.go index fff527b..230e55f 100644 --- a/internal/integration/servicerequest_integration.go +++ b/internal/integration/servicerequest_integration.go @@ -137,7 +137,7 @@ func (s *ServiceRequestRepository) CreateServiceRequest(req model.ServiceRequest } // use redis auth helper to get or create token redisRepo := redis.NewRedisAuth(s.akses) - token, err := redisRepo.GetOrCreateTokenSS(context.Background()) + token, err := redisRepo.GetOrCreateTokenSS(context.Background(), req.Subject.Reference) if err != nil { return nil, err } diff --git a/pkg/redis/redis-auth.go b/pkg/redis/redis-auth.go index 544d6a3..29be1b9 100644 --- a/pkg/redis/redis-auth.go +++ b/pkg/redis/redis-auth.go @@ -3,7 +3,9 @@ package redis import ( "context" "encoding/json" + "errors" "net/http" + "satusehat-rssa/internal/constant" "satusehat-rssa/internal/model" "strings" @@ -15,7 +17,7 @@ type RedisAkses struct { } type RedisInterface interface { - GetOrCreateTokenSS(ctx context.Context) (string, error) + GetOrCreateTokenSS(ctx context.Context, nik string) (string, error) } func NewRedisAuth(akses *model.Akses) RedisInterface { @@ -25,21 +27,30 @@ func NewRedisAuth(akses *model.Akses) RedisInterface { } -func (s *RedisAkses) GetOrCreateTokenSS(ctx context.Context) (string, error) { +func (s *RedisAkses) GetOrCreateTokenSS(ctx context.Context, nik string) (string, error) { const redisKey = "token-ss" + var code string // 1️⃣ ambil dari redis token, err := s.akses.Redis.Get(ctx, redisKey).Result() if err == nil && token != "" { - return token, nil + code, err = s.GetPatientByNIK(nik, token) + if err != nil { + return "", err + } } - + // redis error selain key not found if err != nil && err != redis.Nil { return "", err } - // 2️⃣ generate token baru + if code == "invalid-access-token" || token == "" { + // hapus token dari redis + if err := s.akses.Redis.Del(ctx, redisKey).Err(); err != nil { + return "", err + } + // 2️⃣ generate token baru oauth := model.OauthRequest{ ClientId: s.akses.ClientId, ClientSecret: s.akses.ClientSecret, @@ -56,6 +67,10 @@ func (s *RedisAkses) GetOrCreateTokenSS(ctx context.Context) (string, error) { } return obj_token.AccessToken, nil + }else{ + return token, nil + } + } func (o *RedisAkses) GenerateToken(req model.OauthRequest) (*model.OauthResponse, error) { @@ -88,3 +103,51 @@ func (o *RedisAkses) GenerateToken(req model.OauthRequest) (*model.OauthResponse } return data, nil } + +func (p *RedisAkses) GetPatientByNIK(nik string, token string) (string, error) { + var ( + data *map[string]interface{} + ) + url := p.akses.BaseUrl + "/Patient?identifier=https://fhir.kemkes.go.id/id/nik|" + nik + method := "GET" + client := &http.Client{} + request, err := http.NewRequest(method, url, nil) + if err != nil { + return "", err + } + if token != "" { + request.Header.Add("Authorization", "Bearer "+token) + } else { + return "", errors.New(constant.ErrGenerateToken) + } + + request.Header.Set("Content-Type", constant.ContentTypeFHIRJSON) + request.Header.Set("Accept", constant.ContentTypeFHIRJSON) + + res, err := client.Do(request) + if err != nil { + return "", err + } + defer res.Body.Close() + + err = json.NewDecoder(res.Body).Decode(&data) + if err != nil { + return "", err + } + + // Cek jika response adalah OperationOutcome dan ambil code + if data != nil { + if rt, ok := (*data)["resourceType"].(string); ok && rt == "OperationOutcome" { + if issues, ok := (*data)["issue"].([]interface{}); ok && len(issues) > 0 { + if issueMap, ok := issues[0].(map[string]interface{}); ok { + if code, ok := issueMap["code"].(string); ok { + return code, nil + } + } + } + } + } + + dataJSON, _ := json.Marshal(data) + return string(dataJSON), nil +}