slack_event_entry_point.go

package slack_event

import (
	"context"
	"fmt"
	"os"

	"github.com/shintaro-uchiyama/slack-suite/functions/slack_event/presentation"

	"cloud.google.com/go/pubsub"
	"github.com/shintaro-uchiyama/slack-suite/functions/slack_event/application"
	"github.com/shintaro-uchiyama/slack-suite/functions/slack_event/domain"
	"github.com/shintaro-uchiyama/slack-suite/functions/slack_event/infrastructure"
	"github.com/sirupsen/logrus"
)

func initLog() {
	logrus.SetFormatter(&logrus.TextFormatter{})
	logrus.SetLevel(logrus.InfoLevel)
	logrus.SetOutput(os.Stdout)
}

func injectDependencies() (*presentation.SlackEventHandler, error) {
	secretManager, err := infrastructure.NewSecretManager()
	if err != nil {
		return nil, fmt.Errorf("NewSecretManager error: %w", err)
	}

	slackAccessToken, err := secretManager.GetSecret("slack-access-token")
	if err != nil {
		return nil, fmt.Errorf("get slack access token secret error: %w", err)
	}
	slack := infrastructure.NewSlack(string(slackAccessToken))

	zubePrivateKey, err := secretManager.GetSecret("zube-private-key")
	if err != nil {
		return nil, fmt.Errorf("get zube private key secret error: %w", err)
	}
	zube, err := infrastructure.NewZube(zubePrivateKey)
	if err != nil {
		return nil, fmt.Errorf("NewZube error: %w", err)
	}

	taskRepository, err := infrastructure.NewTaskDataStore()
	if err != nil {
		return nil, fmt.Errorf("NewTaskDataStore error: %w", err)
	}
	projectRepository, err := infrastructure.NewProjectDataStore()
	if err != nil {
		return nil, fmt.Errorf("NewProjectDataStore error: %w", err)
	}
	labelRepository, err := infrastructure.NewLabelDataStore()
	if err != nil {
		return nil, fmt.Errorf("NewLabelDataStore error: %w", err)
	}

	slackEventHandler := presentation.NewSlackEventHandler(
		application.NewTaskApplication(
			domain.NewProjectService(projectRepository),
			domain.NewTaskService(taskRepository, slack, zube),
			projectRepository,
			taskRepository,
			labelRepository,
			slack,
			zube,
		))
	return slackEventHandler, nil
}

func CreateTaskEntryPoint(ctx context.Context, m pubsub.Message) error {
	initLog()

	slackEventHandler, err := injectDependencies()
	if err != nil {
		return fmt.Errorf("inject dependencies error: %w", err)
	}

	err = slackEventHandler.Create(ctx, m)
	if err != nil {
		err = fmt.Errorf("create task error: %w", err)
		logrus.Error(err)
		return err
	}
	return nil
}

func DeleteTaskEntryPoint(ctx context.Context, m pubsub.Message) error {
	initLog()

	slackEventHandler, err := injectDependencies()
	if err != nil {
		return fmt.Errorf("inject dependencies error: %w", err)
	}

	err = slackEventHandler.Delete(ctx, m)
	if err != nil {
		err = fmt.Errorf("delete task error: %w", err)
		logrus.Error(err)
		return err
	}
	return nil
}