refactor(spx-backend): integrate Casdoor User API

Signed-off-by: Aofei Sheng <aofei@aofeisheng.com>

docs/openapi.yaml

@@ -774,7 +774,7 @@ paths:
  format: uri
  description: URL of the image to process for background removal.
  responses:
- "201":
+ "200":
  description: Successfully processed the image for background removal.
  content:
  application/json:
@@ -932,6 +932,17 @@ components:
  examples:
  - john
  description: Unique username of the user.
+ displayName:
+ type: string
+ examples:
+ - John Doe
+ description: Display name of the user.
+ avatar:
+ type: string
+ format: uri
+ examples:
+ - https://avatars.githubusercontent.com/u/10137?v=4
+ description: URL of the user's avatar image.
  description:
  type: string
  examples:

spx-backend/cmd/spx-backend/get_projects_list.yap

@@ -12,14 +12,13 @@ import (
 
 ctx := &Context
 
-user, _ := controller.UserFromContext(ctx.Context())
 params := controller.NewListProjectsParams()
 
 switch owner := ${owner}; owner {
 case "":
- if user == nil {
-  replyWithCode(ctx, errorUnauthorized)
- return
+ user, ok := controller.UserFromContext(ctx.Context())
+ if !ok {
+ break
  }
  params.Owner = &user.Username
 case "*":

spx-backend/internal/controller/controller.go

@@ -39,7 +39,7 @@ type Controller struct {
  db *gorm.DB
  kodo *kodoConfig
  aigcClient *aigc.AigcClient
- casdoorClient *casdoorsdk.Client
+ casdoorClient casdoorClient
 }
 
 // New creates a new controller.
@@ -92,8 +92,14 @@ func newKodoConfig(logger *qiniuLog.Logger) *kodoConfig {
  }
 }
 
+// casdoorClient is the client interface for Casdoor.
+type casdoorClient interface {
+ ParseJwtToken(token string) (*casdoorsdk.Claims, error)
+ GetUser(name string) (*casdoorsdk.User, error)
+}
+
 // newCasdoorClient creates a new [casdoorsdk.Client].
-func newCasdoorClient(logger *qiniuLog.Logger) *casdoorsdk.Client {
+func newCasdoorClient(logger *qiniuLog.Logger) casdoorClient {
  config := &casdoorsdk.AuthConfig{
  Endpoint: mustEnv(logger, "GOP_CASDOOR_ENDPOINT"),
  ClientId: mustEnv(logger, "GOP_CASDOOR_CLIENTID"),

spx-backend/internal/controller/controller_test.go

@@ -4,6 +4,7 @@ import (
  "testing"
 
  "github.com/DATA-DOG/go-sqlmock"
+ "github.com/casdoor/casdoor-go-sdk/casdoorsdk"
  "github.com/goplus/builder/spx-backend/internal/aigc"
  "github.com/goplus/builder/spx-backend/internal/log"
  "github.com/goplus/builder/spx-backend/internal/model/modeltest"
@@ -47,13 +48,38 @@ VTh1XIl/IELBoZ+rQXozGA==
  t.Setenv("GOP_CASDOOR_APPLICATIONNAME", "fake-application")
 }
 
+type mockCasdoorClient struct {
+ casdoorClient casdoorClient
+ jwt string
+}
+
+func newMockCasdoorClient(casdoorClient casdoorClient, jwt string) *mockCasdoorClient {
+ return &mockCasdoorClient{casdoorClient: casdoorClient, jwt: jwt}
+}
+
+func (m *mockCasdoorClient) ParseJwtToken(token string) (*casdoorsdk.Claims, error) {
+ return m.casdoorClient.ParseJwtToken(token)
+}
+
+func (m *mockCasdoorClient) GetUser(name string) (*casdoorsdk.User, error) {
+ claims, err := m.casdoorClient.ParseJwtToken(m.jwt)
+ if err != nil {
+ return nil, err
+ }
+ return &claims.User, nil
+}
+
+const fakeUserToken = "eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9." +
+ "eyJvd25lciI6IkdvUGx1cyIsIm5hbWUiOiJmYWtlLW5hbWUiLCJpZCI6IjEiLCJpc3MiOiJHb1BsdXMiLCJzdWIiOiIxIiwiZXhwIjo0ODcwNDI5MDQwfQ." +
+ "X0T-v-RJggMRy3Mmui2FoRH-_4DQsNA6DekUx1BfIljTZaEbHbuW59dSlKQ-i2MuYD7_8mI18vZqT3iysbKQ1T70NF97B_A130ML3pulZWlj1ZokgjCkVug25QRbq_N7JMd4apJZFlyZj8Bd2VfqtAKMlJJ4HzKzNXB-GBogDVlKeu4xJ1BiXO2rHL1PNa5KyKLSSMXmuP_Wc108RXZ0BiKDE30IG1fvcyvudXcetmltuWjuU6JRj3FGedxuVEqZLXqcm13dCxHnuFV1x1XU9KExcDvVyVB91FpBe5npzYp6WMX0fx9vU1b4eJ69EZoeMdMolhmvYInT1G8r1PEmbg"
+
 func newTestController(t *testing.T) (ctrl *Controller, dbMock sqlmock.Sqlmock, closeDB func() error) {
  setTestEnv(t)
 
  logger := log.GetLogger()
  kodoConfig := newKodoConfig(logger)
  aigcClient := aigc.NewAigcClient(mustEnv(logger, "AIGC_ENDPOINT"))
- casdoorClient := newCasdoorClient(logger)
+ casdoorClient := newMockCasdoorClient(newCasdoorClient(logger), fakeUserToken)
 
  db, dbMock, closeDB, err := modeltest.NewMockDB()
  require.NoError(t, err)

spx-backend/internal/controller/user.go

@@ -16,6 +16,8 @@ type UserDTO struct {
  ModelDTO
 
  Username string `json:"username"`
+ DisplayName string `json:"displayName"`
+ Avatar string `json:"avatar"`
  Description string `json:"description"`
  FollowerCount int64 `json:"followerCount"`
  FollowingCount int64 `json:"followingCount"`
@@ -29,6 +31,8 @@ func toUserDTO(mUser model.User) UserDTO {
  return UserDTO{
  ModelDTO: toModelDTO(mUser.Model),
  Username: mUser.Username,
+ DisplayName: mUser.DisplayName,
+ Avatar: mUser.Avatar,
  Description: mUser.Description,
  FollowerCount: mUser.FollowerCount,
  FollowingCount: mUser.FollowingCount,
@@ -71,7 +75,11 @@ func (ctrl *Controller) UserFromToken(ctx context.Context, token string) (*model
  if err != nil {
  return nil, fmt.Errorf("ctrl.casdoorClient.ParseJwtToken failed: %w: %w", ErrUnauthorized, err)
  }
- mUser, err := model.FirstOrCreateUser(ctx, ctrl.db, claims.Name)
+ casdoorUser, err := ctrl.casdoorClient.GetUser(claims.Name)
+ if err != nil {
+ return nil, fmt.Errorf("ctrl.casdoorClient.GetUser failed: %w", err)
+ }
+ mUser, err := model.FirstOrCreateUser(ctx, ctrl.db, casdoorUser)
  if err != nil {
  return nil, err
  }

spx-backend/internal/controller/user_test.go

@@ -85,10 +85,6 @@ func TestEnsureUser(t *testing.T) {
  })
 }
 
-const fakeUserToken = "eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9." +
- "eyJvd25lciI6IkdvUGx1cyIsIm5hbWUiOiJmYWtlLW5hbWUiLCJpZCI6IjEiLCJpc3MiOiJHb1BsdXMiLCJzdWIiOiIxIiwiZXhwIjo0ODcwNDI5MDQwfQ." +
- "X0T-v-RJggMRy3Mmui2FoRH-_4DQsNA6DekUx1BfIljTZaEbHbuW59dSlKQ-i2MuYD7_8mI18vZqT3iysbKQ1T70NF97B_A130ML3pulZWlj1ZokgjCkVug25QRbq_N7JMd4apJZFlyZj8Bd2VfqtAKMlJJ4HzKzNXB-GBogDVlKeu4xJ1BiXO2rHL1PNa5KyKLSSMXmuP_Wc108RXZ0BiKDE30IG1fvcyvudXcetmltuWjuU6JRj3FGedxuVEqZLXqcm13dCxHnuFV1x1XU9KExcDvVyVB91FpBe5npzYp6WMX0fx9vU1b4eJ69EZoeMdMolhmvYInT1G8r1PEmbg"
-
 func TestControllerUserFromToken(t *testing.T) {
  t.Run("Normal", func(t *testing.T) {
  ctrl, dbMock, closeDB := newTestController(t)