refactor(server): replace user/workspace with account in reearthx (#568)

server/e2e/common.go

@@ -14,6 +14,11 @@ import (
 	"github.com/reearth/reearth/server/internal/infrastructure/mongo"
 	"github.com/reearth/reearth/server/internal/usecase/gateway"
 	"github.com/reearth/reearth/server/internal/usecase/repo"
+	"github.com/reearth/reearthx/account/accountinfrastructure/accountmemory"
+	"github.com/reearth/reearthx/account/accountinfrastructure/accountmongo"
+	"github.com/reearth/reearthx/account/accountusecase/accountgateway"
+	"github.com/reearth/reearthx/account/accountusecase/accountrepo"
+	"github.com/reearth/reearthx/mailer"
 	"github.com/reearth/reearthx/mongox/mongotest"
 	"github.com/samber/lo"
 	"github.com/spf13/afero"
@@ -98,3 +103,77 @@ type GraphQLRequest struct {
 	Query         string         `json:"query"`
 	Variables     map[string]any `json:"variables"`
 }
+
+func StartGQLServer(t *testing.T, cfg *config.Config, useMongo bool, seeder Seeder) (*httpexpect.Expect, *accountrepo.Container) {
+	e, r := StartGQLServerAndRepos(t, cfg, useMongo, seeder)
+	return e, r
+}
+
+func StartGQLServerAndRepos(t *testing.T, cfg *config.Config, useMongo bool, seeder Seeder) (*httpexpect.Expect, *accountrepo.Container) {
+	ctx := context.Background()
+
+	var repos *repo.Container
+	var accountRepos *accountrepo.Container
+
+	if useMongo {
+		db := mongotest.Connect(t)(t)
+		repos = lo.Must(mongo.New(ctx, db, false))
+		accountRepos = lo.Must(accountmongo.New(ctx, db.Client(), db.Name(), false, true))
+	} else {
+		repos = memory.New()
+		accountRepos = accountmemory.New()
+	}
+
+	if seeder != nil {
+		if err := seeder(ctx, repos); err != nil {
+			t.Fatalf("failed to seed the db: %s", err)
+		}
+	}
+
+	return StartGQLServerWithRepos(t, cfg, repos, accountRepos), accountRepos
+}
+
+func StartGQLServerWithRepos(t *testing.T, cfg *config.Config, repos *repo.Container, accountrepos *accountrepo.Container) *httpexpect.Expect {
+	t.Helper()
+
+	if testing.Short() {
+		t.SkipNow()
+	}
+
+	ctx := context.Background()
+	l, err := net.Listen("tcp", ":0")
+	if err != nil {
+		t.Fatalf("server failed to listen: %v", err)
+	}
+
+	srv := app.NewServer(ctx, &app.ServerConfig{
+		Config:       cfg,
+		Repos:        repos,
+		AccountRepos: accountrepos,
+		Gateways: &gateway.Container{
+			File: lo.Must(fs.NewFile(afero.NewMemMapFs(), "https://example.com")),
+		},
+		AccountGateways: &accountgateway.Container{
+			Mailer: mailer.New(ctx, &mailer.Config{}),
+		},
+		Debug: true,
+	})
+
+	ch := make(chan error)
+	go func() {
+		if err := srv.Serve(l); err != http.ErrServerClosed {
+			ch <- err
+		}
+		close(ch)
+	}()
+	t.Cleanup(func() {
+		if err := srv.Shutdown(context.Background()); err != nil {
+			t.Fatalf("server shutdown: %v", err)
+		}
+
+		if err := <-ch; err != nil {
+			t.Fatalf("server serve: %v", err)
+		}
+	})
+	return httpexpect.New(t, "http://"+l.Addr().String())
+}

server/e2e/gql_project_test.go

@@ -31,6 +31,7 @@ func TestCreateProject(t *testing.T) {
 
 	e.POST("/api/graphql").
 		WithHeader("Origin", "https://example.com").
+		WithHeader("authorization", "Bearer test").
 		// WithHeader("authorization", "Bearer test").
 		WithHeader("X-Reearth-Debug-User", uID.String()).
 		WithHeader("Content-Type", "application/json").

server/e2e/gql_user_test.go

@@ -0,0 +1,291 @@
+package e2e
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+	"testing"
+
+	"github.com/reearth/reearth/server/internal/app/config"
+	"github.com/reearth/reearth/server/internal/usecase/repo"
+	"github.com/reearth/reearthx/account/accountdomain"
+	"github.com/reearth/reearthx/account/accountdomain/user"
+	"github.com/reearth/reearthx/account/accountdomain/workspace"
+	"github.com/reearth/reearthx/idx"
+	"github.com/reearth/reearthx/rerror"
+	"github.com/stretchr/testify/assert"
+	"golang.org/x/text/language"
+)
+
+var (
+	uId1 = accountdomain.NewUserID()
+	uId2 = accountdomain.NewUserID()
+	uId3 = accountdomain.NewUserID()
+	wId1 = accountdomain.NewWorkspaceID()
+	wId2 = accountdomain.NewWorkspaceID()
+	iId1 = accountdomain.NewIntegrationID()
+)
+
+func baseSeederUser(ctx context.Context, r *repo.Container) error {
+	auth := user.ReearthSub(uId1.String())
+	u := user.New().ID(uId1).
+		Name("e2e").
+		Email("e2e@e2e.com").
+		Auths([]user.Auth{*auth}).
+		Theme(user.ThemeDark).
+		Lang(language.Japanese).
+		Workspace(wId1).
+		MustBuild()
+	if err := r.User.Save(ctx, u); err != nil {
+		return err
+	}
+	u2 := user.New().ID(uId2).
+		Name("e2e2").
+		Workspace(wId2).
+		Email("e2e2@e2e.com").
+		MustBuild()
+	if err := r.User.Save(ctx, u2); err != nil {
+		return err
+	}
+	u3 := user.New().ID(uId3).
+		Name("e2e3").
+		Workspace(wId2).
+		Email("e2e3@e2e.com").
+		MustBuild()
+	if err := r.User.Save(ctx, u3); err != nil {
+		return err
+	}
+	roleOwner := workspace.Member{
+		Role:      workspace.RoleOwner,
+		InvitedBy: uId1,
+	}
+	roleReader := workspace.Member{
+		Role:      workspace.RoleReader,
+		InvitedBy: uId2,
+	}
+
+	w := workspace.New().ID(wId1).
+		Name("e2e").
+		Members(map[idx.ID[accountdomain.User]]workspace.Member{
+			uId1: roleOwner,
+		}).
+		Integrations(map[idx.ID[accountdomain.Integration]]workspace.Member{
+			iId1: roleOwner,
+		}).
+		MustBuild()
+	if err := r.Workspace.Save(ctx, w); err != nil {
+		return err
+	}
+
+	w2 := workspace.New().ID(wId2).
+		Name("e2e2").
+		Members(map[idx.ID[accountdomain.User]]workspace.Member{
+			uId1: roleOwner,
+			uId3: roleReader,
+		}).
+		Integrations(map[idx.ID[accountdomain.Integration]]workspace.Member{
+			iId1: roleOwner,
+		}).
+		MustBuild()
+	if err := r.Workspace.Save(ctx, w2); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// func TestSignUp(t *testing.T) {
+// 	e, _ := StartGQLServer(t, &config.Config{
+// 		Origins: []string{"https://example.com"},
+// 		AuthSrv: config.AuthSrvConfig{
+// 			Disabled: true,
+// 		},
+// 	}, true, baseSeederUser)
+// 	query := `mutation { signup(input: {lang: "ja",theme: DEFAULT,secret: "Ajsownndww1"}){ user{ id name email } }}`
+// 	request := GraphQLRequest{
+// 		Query: query,
+// 	}
+// 	jsonData, err := json.Marshal(request)
+// 	if err != nil {
+// 		assert.NoError(t, err)
+// 	}
+// 	o := e.POST("/api/graphql").
+// 		WithHeader("authorization", "Bearer test").
+// 		WithHeader("Content-Type", "application/json").
+// 		WithHeader("X-Reearth-Debug-User", uId1.String()).
+// 		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object().Value("data").Object().Value("signup").Object().Value("user").Object()
+// 	o.Value("name").String().Equal("updated")
+// 	o.Value("email").String().Equal("hoge@test.com")
+// }
+
+func TestUpdateMe(t *testing.T) {
+	e, _ := StartGQLServer(t, &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}, true, baseSeederUser)
+	query := `mutation { updateMe(input: {name: "updated",email:"hoge@test.com",lang: "ja",theme: DEFAULT,password: "Ajsownndww1",passwordConfirmation: "Ajsownndww1"}){ me{ id name email lang theme } }}`
+	request := GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	o := e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object().Value("data").Object().Value("updateMe").Object().Value("me").Object()
+	o.Value("name").String().Equal("updated")
+	o.Value("email").String().Equal("hoge@test.com")
+	o.Value("lang").String().Equal("ja")
+	o.Value("theme").String().Equal("default")
+}
+
+func TestRemoveMyAuth(t *testing.T) {
+	e, r := StartGQLServer(t, &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}, true, baseSeederUser)
+	u, err := r.User.FindByID(context.Background(), uId1)
+	assert.Nil(t, err)
+	assert.Equal(t, &user.Auth{Provider: "reearth", Sub: "reearth|" + uId1.String()}, u.Auths().GetByProvider("reearth"))
+
+	query := `mutation { removeMyAuth(input: {auth: "reearth"}){ me{ id name email lang theme } }}`
+	request := GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object()
+
+	u, err = r.User.FindByID(context.Background(), uId1)
+	assert.Nil(t, err)
+	assert.Nil(t, u.Auths().Get("sub"))
+}
+
+func TestDeleteMe(t *testing.T) {
+	e, r := StartGQLServer(t, &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}, true, baseSeederUser)
+	u, err := r.User.FindByID(context.Background(), uId1)
+	assert.Nil(t, err)
+	assert.NotNil(t, u)
+
+	query := fmt.Sprintf(`mutation { deleteMe(input: {userId: "%s"}){ userId }}`, uId1)
+	request := GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object()
+
+	_, err = r.User.FindByID(context.Background(), uId1)
+	assert.Equal(t, rerror.ErrNotFound, err)
+}
+
+func TestSearchUser(t *testing.T) {
+	e, _ := StartGQLServer(t, &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}, true, baseSeederUser)
+	query := fmt.Sprintf(` { searchUser(nameOrEmail: "%s"){ id name email } }`, "e2e")
+	request := GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	o := e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object().Value("data").Object().Value("searchUser").Object()
+	o.Value("id").String().Equal(uId1.String())
+	o.Value("name").String().Equal("e2e")
+	o.Value("email").String().Equal("e2e@e2e.com")
+
+	query = fmt.Sprintf(` { searchUser(nameOrEmail: "%s"){ id name email } }`, "notfound")
+	request = GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err = json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object().
+		Value("data").Object().Value("searchUser").Null()
+}
+
+func TestNode(t *testing.T) {
+	e, _ := StartGQLServer(t, &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}, true, baseSeederUser)
+	query := fmt.Sprintf(` { node(id: "%s", type: USER){ id } }`, uId1.String())
+	request := GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	o := e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object().Value("data").Object().Value("node").Object()
+	o.Value("id").String().Equal(uId1.String())
+}
+
+func TestNodes(t *testing.T) {
+	e, _ := StartGQLServer(t, &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+	}, true, baseSeederUser)
+	query := fmt.Sprintf(` { nodes(id: "%s", type: USER){ id } }`, uId1.String())
+	request := GraphQLRequest{
+		Query: query,
+	}
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		assert.NoError(t, err)
+	}
+	o := e.POST("/api/graphql").
+		WithHeader("authorization", "Bearer test").
+		WithHeader("Content-Type", "application/json").
+		WithHeader("X-Reearth-Debug-User", uId1.String()).
+		WithBytes(jsonData).Expect().Status(http.StatusOK).JSON().Object().Value("data").Object().Value("nodes")
+	o.Array().Contains(map[string]string{"id": uId1.String()})
+}