feat: account 및 project 기본 구성 및 구조 변경

.gitignore

@@ -1 +1,3 @@
 meonzi
+.idea
+go.sum

Makefile

@@ -0,0 +1,34 @@
+ifndef binary
+	binary=debug
+endif
+
+test:
+	go test -v -cover -covermode=atomic ./...
+
+mod-download:
+	go mod download
+
+generate:
+	bash ./generate.sh
+
+build:
+	go build -o ${binary} .
+
+unittest:
+	go test -short  ./...
+
+clean:
+	if [ -f ${binary} ] ; then rm ${binary} ; fi
+
+lint-prepare:
+	@echo "Installing golangci-lint"
+	curl -sfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh| sh -s latest
+
+lint:
+	./bin/golangci-lint run \
+		--exclude-use-default=false \
+		--enable=golint \
+		--enable=gocyclo \
+		--enable=goconst \
+		--enable=unconvert \
+		./...

account/app/command.go

@@ -0,0 +1,107 @@
+package app
+
+import (
+	"context"
+	"errors"
+	"github/four-servings/meonzi/account/domain"
+	"github/four-servings/meonzi/pipe"
+	"time"
+
+	"golang.org/x/sync/errgroup"
+
+	"github.com/google/uuid"
+	log "github.com/sirupsen/logrus"
+)
+
+type (
+	CommandBus interface {
+		pipe.Bus
+	}
+
+	commandHandler struct {
+		domain.AccountRepository
+		domain.SocialService
+	}
+)
+
+func NewCommandBus(accountRepo domain.AccountRepository, socialService domain.SocialService, timeout time.Duration) (bus CommandBus) {
+	handler := commandHandler{accountRepo, socialService}
+	bus = pipe.NewBusWithTimeout(timeout)
+
+	g, _ := errgroup.WithContext(context.Background())
+	g.Go(func() error {
+		return bus.RegistryHandler(RegisterAccountCommand{}, handler.RegisterAccountHandle)
+	})
+	g.Go(func() error {
+		return bus.RegistryHandler(DeregisterAccountCommand{}, handler.DeregisterAccountHandle)
+	})
+	err := g.Wait()
+	if err != nil {
+		panic(err)
+	}
+
+	return
+}
+
+type RegisterAccountCommand struct {
+	Name     string
+	Token    string
+	Provider domain.AuthProvider
+}
+
+func (ch *commandHandler) RegisterAccountHandle(ctx context.Context, command RegisterAccountCommand) (err error) {
+	id, err := ch.AccountRepository.FindNewID(ctx)
+	if err != nil {
+		log.WithError(err).Error("Can not get new account ID")
+		return
+	}
+
+	thirdUser, err := ch.SocialService.GetUser(ctx, command.Provider, command.Token)
+	if err != nil {
+		log.WithError(err).Errorf("Can not fetch %s user", command.Provider)
+		return
+	}
+
+	exists, _ := ch.AccountRepository.FindByProviderAndSocialID(ctx, command.Provider, command.Token)
+	if exists != nil {
+		err = errors.New("exists account")
+		log.Error("Account is exists")
+		return
+	}
+
+	account := domain.NewAccount(domain.NewAccountOptions{
+		ID:           id,
+		Name:         command.Name,
+		AuthProvider: thirdUser.AuthProvider(),
+		SocialID:     thirdUser.ID(),
+	})
+
+	account, err = ch.AccountRepository.Save(ctx, account)
+	if err != nil {
+		log.WithError(err).Error("Can not save account")
+		return
+	}
+
+	return nil
+}
+
+type DeregisterAccountCommand struct {
+	ID uuid.UUID
+}
+
+//TODO refactor, error handling on http handler
+func (ch *commandHandler) DeregisterAccountHandle(ctx context.Context, command DeregisterAccountCommand) error {
+	account, err := ch.AccountRepository.FindByID(ctx, command.ID)
+	if err != nil {
+		log.WithError(err).Error("Can not found account")
+	}
+
+	account.Deregister()
+
+	account, err = ch.AccountRepository.Save(ctx, account)
+	if err != nil {
+		log.WithError(err).Error("Can not save account")
+	}
+
+	return nil
+}

account/app/event.go

@@ -0,0 +1,13 @@
+package app
+
+import (
+	"github/four-servings/meonzi/pipe"
+)
+
+type EventPublisher interface {
+	pipe.PubSub
+}
+
+func NewEventPublisher() EventPublisher {
+	return pipe.NewPubSub()
+}