handle beberapa case

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
 	}

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
+}