[Jasoet] feat(metadata): Show jobs list now depends on user's authent…

…ication group

internal/app/service/metadata/handler/http.go

@@ -5,8 +5,10 @@ import (
 	"net/http"
 	"proctor/internal/app/service/infra/logger"
 	"proctor/internal/app/service/metadata/repository"
+	"proctor/internal/app/service/security/middleware"
 	"proctor/internal/pkg/constant"
 	modelMetadata "proctor/internal/pkg/model/metadata"
+	"proctor/pkg/auth"
 )
 
 type metadataHTTPHandler struct {
@@ -55,7 +57,19 @@ func (handler *metadataHTTPHandler) Post() http.HandlerFunc {
 func (handler *metadataHTTPHandler) GetAll() http.HandlerFunc {
 	return func(w http.ResponseWriter, req *http.Request) {
 
-		metadataSlice, err := handler.repository.GetAll()
+		userDetailContext := req.Context().Value(middleware.ContextUserDetailKey)
+		if userDetailContext == nil {
+			w.WriteHeader(http.StatusUnauthorized)
+			return
+		}
+
+		userDetail, ok := userDetailContext.(*auth.UserDetail)
+		if !ok {
+			w.WriteHeader(http.StatusUnauthorized)
+			return
+		}
+
+		metadataSlice, err := handler.repository.GetAllByGroups(userDetail.Groups)
 		if err != nil {
 			logger.Error("Error fetching metadata", err.Error())
 

internal/app/service/metadata/handler/http_test.go

@@ -2,12 +2,15 @@ package handler
 
 import (
 	"bytes"
+	"context"
 	"encoding/json"
 	"errors"
 	"fmt"
 	"net/http"
 	"net/http/httptest"
 	metadataRepository "proctor/internal/app/service/metadata/repository"
+	"proctor/internal/app/service/security/middleware"
+	"proctor/pkg/auth"
 	"testing"
 
 	"proctor/internal/pkg/model/metadata/env"
@@ -121,10 +124,20 @@ func (s *MetadataHandlerTestSuite) TestHandleBulkDisplay() {
 	t := s.T()
 
 	req := httptest.NewRequest("GET", "/metadata", bytes.NewReader([]byte{}))
+	groups := []string{"admin", "migratior"}
+	userDetail := &auth.UserDetail{
+		Name:   "jasoet",
+		Email:  "[email protected]",
+		Active: true,
+		Groups: groups,
+	}
+
+	ctx := context.WithValue(req.Context(), middleware.ContextUserDetailKey, userDetail)
+	req = req.WithContext(ctx)
 	responseRecorder := httptest.NewRecorder()
 
-	jobsMetadata := []modelMetadata.Metadata{}
-	s.mockRepository.On("GetAll").Return(jobsMetadata, nil).Once()
+	var jobsMetadata []modelMetadata.Metadata
+	s.mockRepository.On("GetAllByGroups", groups).Return(jobsMetadata, nil).Once()
 
 	s.metadataHTTPHandler.GetAll()(responseRecorder, req)
 
@@ -141,10 +154,20 @@ func (s *MetadataHandlerTestSuite) TestHandleBulkDisplayStoreFailure() {
 	t := s.T()
 
 	req := httptest.NewRequest("GET", "/metadata", bytes.NewReader([]byte{}))
+	groups := []string{"admin", "migratior"}
+	userDetail := &auth.UserDetail{
+		Name:   "jasoet",
+		Email:  "[email protected]",
+		Active: true,
+		Groups: groups,
+	}
+
+	ctx := context.WithValue(req.Context(), middleware.ContextUserDetailKey, userDetail)
+	req = req.WithContext(ctx)
 	responseRecorder := httptest.NewRecorder()
 
 	jobsMetadata := []modelMetadata.Metadata{}
-	s.mockRepository.On("GetAll").Return(jobsMetadata, errors.New("error")).Once()
+	s.mockRepository.On("GetAllByGroups", groups).Return(jobsMetadata, errors.New("error")).Once()
 
 	s.metadataHTTPHandler.GetAll()(responseRecorder, req)
 

internal/app/service/metadata/repository/metadata.go

@@ -11,6 +11,7 @@ const KeySuffix = "-metadata"
 type MetadataRepository interface {
 	Save(metadata metadata.Metadata) error
 	GetAll() ([]metadata.Metadata, error)
+	GetAllByGroups(groups []string) ([]metadata.Metadata, error)
 	GetByName(name string) (*metadata.Metadata, error)
 }
 
@@ -68,6 +69,55 @@ func (repository *metadataRepository) GetAll() ([]metadata.Metadata, error) {
 	return metadataSlice, nil
 }
 
+func (repository *metadataRepository) GetAllByGroups(groups []string) ([]metadata.Metadata, error) {
+	searchKey := "*" + KeySuffix
+
+	keys, err := repository.redisClient.KEYS(searchKey)
+	if err != nil {
+		return nil, err
+	}
+
+	availableKeys := make([]interface{}, len(keys))
+	for i := range keys {
+		availableKeys[i] = keys[i]
+	}
+
+	values, err := repository.redisClient.MGET(availableKeys...)
+	if err != nil {
+		return nil, err
+	}
+
+	metadataSlice := make([]metadata.Metadata, len(values))
+	for i := range values {
+		err = json.Unmarshal(values[i], &metadataSlice[i])
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	var filteredMetadata []metadata.Metadata
+	for _, meta := range metadataSlice {
+		if len(meta.AuthorizedGroups) == 0 {
+			filteredMetadata = append(filteredMetadata, meta)
+		} else if duplicateItemExists(meta.AuthorizedGroups, groups) {
+			filteredMetadata = append(filteredMetadata, meta)
+		}
+	}
+
+	return filteredMetadata, nil
+}
+
+func duplicateItemExists(first []string, second []string) bool {
+	for _, firstString := range first {
+		for _, secondString := range second {
+			if firstString == secondString {
+				return true
+			}
+		}
+	}
+	return false
+}
+
 func (repository *metadataRepository) GetByName(name string) (*metadata.Metadata, error) {
 	binaryMetadata, err := repository.redisClient.GET(applySuffix(name))
 	if err != nil {

internal/app/service/metadata/repository/metadata_mock.go

@@ -19,6 +19,11 @@ func (m *MockMetadataRepository) GetAll() ([]modelMetadata.Metadata, error) {
 	return args.Get(0).([]modelMetadata.Metadata), args.Error(1)
 }
 
+func (m *MockMetadataRepository) GetAllByGroups(group []string) ([]modelMetadata.Metadata, error) {
+	args := m.Called(group)
+	return args.Get(0).([]modelMetadata.Metadata), args.Error(1)
+}
+
 func (m *MockMetadataRepository) GetByName(name string) (*modelMetadata.Metadata, error) {
 	args := m.Called(name)
 	return args.Get(0).(*modelMetadata.Metadata), args.Error(1)

internal/app/service/metadata/repository/metadata_test.go

@@ -113,6 +113,84 @@ func (s *MetadataRepositoryTestSuite) TestGetAllFailure() {
 	s.mockRedisClient.AssertExpectations(t)
 }
 
+func (s *MetadataRepositoryTestSuite) TestGetAllByGroups() {
+	t := s.T()
+
+	metadata1 := modelMetadata.Metadata{
+		Name:             "job1",
+		ImageName:        "job1-image-name",
+		Description:      "desc1",
+		Author:           "Test User<[email protected]",
+		Contributors:     "Test User<[email protected]",
+		Organization:     "Test Org",
+		AuthorizedGroups: []string{"group_one", "group_two", "group_three", "group_four"},
+	}
+
+	metadata2 := modelMetadata.Metadata{
+		Name:             "job2",
+		ImageName:        "job2-image-name",
+		Description:      "desc2",
+		Author:           "Test User 2<[email protected]",
+		Contributors:     "Test User 2<[email protected]",
+		Organization:     "Test Org2",
+		AuthorizedGroups: []string{"group_x", "group_y", "group_z", "group_a"},
+	}
+
+	metadata3 := modelMetadata.Metadata{
+		Name:         "job3",
+		ImageName:    "job3-image-name",
+		Description:  "desc3",
+		Author:       "Test User 3<[email protected]",
+		Contributors: "Test User 3<[email protected]",
+		Organization: "Test Org3",
+	}
+
+	s.mockRedisClient.On("KEYS", "*-metadata").Return(
+		[]string{"job1-metadata", "job2-metadata", "job3-metadata"}, nil).Times(5)
+
+	jsonMetadata1, err := json.Marshal(metadata1)
+	assert.NoError(t, err)
+	jsonMetadata2, err := json.Marshal(metadata2)
+	assert.NoError(t, err)
+	jsonMetadata3, err := json.Marshal(metadata3)
+	assert.NoError(t, err)
+	values := [][]byte{jsonMetadata1, jsonMetadata2, jsonMetadata3}
+
+	keys := []string{"job1-metadata", "job2-metadata", "job3-metadata"}
+	jobKeys := make([]interface{}, len(keys))
+	for i := range keys {
+		jobKeys[i] = keys[i]
+	}
+
+	s.mockRedisClient.On("MGET", jobKeys...).Return(values, nil).Times(5)
+
+	metadataSlice1, err := s.testMetadataStore.GetAllByGroups([]string{"group_two", "group_a"})
+	assert.NoError(t, err)
+
+	assert.EqualValues(t, []modelMetadata.Metadata{metadata1, metadata2, metadata3}, metadataSlice1)
+
+	metadataSlice2, err := s.testMetadataStore.GetAllByGroups([]string{"group_two"})
+	assert.NoError(t, err)
+
+	assert.EqualValues(t, []modelMetadata.Metadata{metadata1,metadata3}, metadataSlice2)
+
+	metadataSlice3, err := s.testMetadataStore.GetAllByGroups([]string{"group_a"})
+	assert.NoError(t, err)
+
+	assert.EqualValues(t, []modelMetadata.Metadata{metadata2,metadata3}, metadataSlice3)
+
+	metadataSlice4, err := s.testMetadataStore.GetAllByGroups([]string{"group_a", "group_x"})
+	assert.NoError(t, err)
+
+	assert.EqualValues(t, []modelMetadata.Metadata{metadata2,metadata3}, metadataSlice4)
+
+	metadataSlice5, err := s.testMetadataStore.GetAllByGroups([]string{"groupz", "group3"})
+	assert.NoError(t, err)
+
+	assert.EqualValues(t, []modelMetadata.Metadata{metadata3}, metadataSlice5)
+	s.mockRedisClient.AssertExpectations(t)
+}
+
 func (s *MetadataRepositoryTestSuite) TestGetAllMgetFailure() {
 	t := s.T()