init redis

internal/integration/servicerequest_integration.go

@@ -2,6 +2,7 @@ package integration
 
 import (
 	"bytes"
+	"context"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -9,6 +10,7 @@ import (
 	"satusehat-rssa/internal/constant"
 	"satusehat-rssa/internal/model"
 	"satusehat-rssa/pkg/httputil"
+	"satusehat-rssa/pkg/redis"
 )
 
 type ServiceRequestInterface interface {
@@ -133,17 +135,15 @@ func (s *ServiceRequestRepository) CreateServiceRequest(req model.ServiceRequest
 	if err != nil {
 		return nil, err
 	}
-	oauth := model.OauthRequest{
-		ClientId:     s.akses.ClientId,
-		ClientSecret: s.akses.ClientSecret,
-	}
-	OauthInterface := NewOauthRequestRepo(s.akses)
-	token, err := OauthInterface.GenerateToken(oauth)
+	// use redis auth helper to get or create token
+	redisRepo := redis.NewRedisAuth(s.akses)
+	token, err := redisRepo.GetOrCreateTokenSS(context.Background())
 	if err != nil {
 		return nil, err
 	}
-	if token != nil {
-		request.Header.Set("Authorization", "Bearer "+token.AccessToken)
+
+	if token != "" {
+		request.Header.Set("Authorization", "Bearer "+token)
 	}
 	request.Header.Set("Content-Type", constant.ContentTypeFHIRJSON)
 	res, err := client.Do(request)