refactor: project structure refactor (#138)

* refactor(store): put model package inside postgres

* refactor: remove service interfaces from domain package

* refactor: extract out job handlers from core packages

* refactor: simplify jobs package

Author: rahmatrhd

api/handler/v1beta1/grpc.go

@@ -8,6 +8,7 @@ import (
 	ctx_logrus "github.com/grpc-ecosystem/go-grpc-middleware/tags/logrus"
 	guardianv1beta1 "github.com/odpf/guardian/api/proto/odpf/guardian/v1beta1"
 	"github.com/odpf/guardian/core/appeal"
+	"github.com/odpf/guardian/core/approval"
 	"github.com/odpf/guardian/core/policy"
 	"github.com/odpf/guardian/core/provider"
 	"github.com/odpf/guardian/core/resource"
@@ -38,11 +39,11 @@ type ProtoAdapter interface {
 }
 
 type GRPCServer struct {
-	resourceService domain.ResourceService
-	providerService domain.ProviderService
-	policyService   domain.PolicyService
-	appealService   domain.AppealService
-	approvalService domain.ApprovalService
+	resourceService *resource.Service
+	providerService *provider.Service
+	policyService   *policy.Service
+	appealService   *appeal.Service
+	approvalService *approval.Service
 	adapter         ProtoAdapter
 
 	authenticatedUserHeaderKey string
@@ -51,11 +52,11 @@ type GRPCServer struct {
 }
 
 func NewGRPCServer(
-	resourceService domain.ResourceService,
-	providerService domain.ProviderService,
-	policyService domain.PolicyService,
-	appealService domain.AppealService,
-	approvalService domain.ApprovalService,
+	resourceService *resource.Service,
+	providerService *provider.Service,
+	policyService *policy.Service,
+	appealService *appeal.Service,
+	approvalService *approval.Service,
 	adapter ProtoAdapter,
 	authenticatedUserHeaderKey string,
 ) *GRPCServer {

app/server.go

@@ -21,6 +21,7 @@ import (
 	"github.com/odpf/guardian/domain"
 	"github.com/odpf/guardian/internal/crypto"
 	"github.com/odpf/guardian/internal/scheduler"
+	"github.com/odpf/guardian/jobs"
 	"github.com/odpf/guardian/plugins/identities"
 	"github.com/odpf/guardian/plugins/notifiers"
 	"github.com/odpf/guardian/plugins/providers"
@@ -108,22 +109,26 @@ func RunServer(c *Config) error {
 		logger,
 	)
 
-	providerJobHandler := provider.NewJobHandler(providerService)
-	appealJobHandler := appeal.NewJobHandler(logger, appealService, notifier)
+	jobHandler := jobs.NewHandler(
+		logger,
+		appealService,
+		providerService,
+		notifier,
+	)
 
 	// init scheduler
 	tasks := []*scheduler.Task{
 		{
 			CronTab: c.Jobs.FetchResourcesInterval,
-			Func:    providerJobHandler.GetResources,
+			Func:    jobHandler.FetchResources,
 		},
 		{
 			CronTab: c.Jobs.RevokeExpiredAccessInterval,
-			Func:    appealJobHandler.RevokeExpiredAccess,
+			Func:    jobHandler.RevokeExpiredAppeals,
 		},
 		{
 			CronTab: c.Jobs.ExpiringAccessNotificationInterval,
-			Func:    appealJobHandler.NotifyAboutToExpireAccess,
+			Func:    jobHandler.AppealExpirationReminder,
 		},
 	}
 	s, err := scheduler.New(tasks)