Full Restruct API and Services

Signed-off-by: Asai Neko <sugar@sne.moe>

service/service_auth/redirect.go

@@ -2,7 +2,14 @@ package service_auth
 
 import (
 	"context"
+	"net/url"
+	"nixcn-cms/data"
+	"nixcn-cms/internal/authcode"
+	"nixcn-cms/internal/exception"
 	"nixcn-cms/service/shared"
+
+	"github.com/google/uuid"
+	"gorm.io/gorm"
 )
 
 type RedirectData struct {
@@ -23,5 +30,181 @@ type RedirectResult struct {
 }
 
 func (self *AuthServiceImpl) Redirect(payload *RedirectPayload) (result *RedirectResult) {
+	var err error
 
+	authCode, ok := authcode.VerifyAuthCode(payload.Context, payload.Data.Code)
+	if !ok {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRedirect).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthRedirectTokenInvalid).
+			Throw(payload.Context)
+
+		result = &RedirectResult{
+			Common: shared.CommonResult{
+				HttpCode:  403,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	userData, err := new(data.User).
+		GetByEmail(payload.Context, &authCode.Email)
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			userData.UUID = uuid.New()
+			userData.UserId = uuid.New()
+			userData.Email = authCode.Email
+			userData.Username = userData.UserId.String()
+			userData.PermissionLevel = 10
+			if err := userData.Create(payload.Context); err != nil {
+				exception := new(exception.Builder).
+					SetStatus(exception.StatusServer).
+					SetService(exception.ServiceAuth).
+					SetEndpoint(exception.EndpointAuthServiceRedirect).
+					SetType(exception.TypeCommon).
+					SetOriginal(exception.CommonErrorInternal).
+					SetError(err).
+					Throw(payload.Context)
+
+				result = &RedirectResult{
+					Common: shared.CommonResult{
+						HttpCode:  500,
+						Exception: exception,
+					},
+				}
+
+				return
+			}
+		} else {
+			exception := new(exception.Builder).
+				SetStatus(exception.StatusServer).
+				SetService(exception.ServiceAuth).
+				SetEndpoint(exception.EndpointAuthServiceRedirect).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonErrorInternal).
+				SetError(err).
+				Throw(payload.Context)
+
+			result = &RedirectResult{
+				Common: shared.CommonResult{
+					HttpCode:  500,
+					Exception: exception,
+				},
+			}
+
+			return
+		}
+	}
+
+	clientData := new(data.Client)
+	client, err := clientData.GetClientByClientId(payload.Context, payload.Data.ClientId)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRedirect).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthRedirectClientNotFound).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &RedirectResult{
+			Common: shared.CommonResult{
+				HttpCode:  400,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	if err = client.ValidateRedirectURI(payload.Data.RedirectUri); err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRedirect).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthRedirectUriMismatch).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &RedirectResult{
+			Common: shared.CommonResult{
+				HttpCode:  400,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	newCode, err := authcode.NewAuthCode(payload.Context, payload.Data.ClientId, authCode.Email)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRedirect).
+			SetType(exception.TypeCommon).
+			SetOriginal(exception.CommonErrorInternal).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &RedirectResult{
+			Common: shared.CommonResult{
+				HttpCode:  500,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	targetUrl, err := url.Parse(payload.Data.RedirectUri)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRedirect).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthRedirectInvalidUri).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &RedirectResult{
+			Common: shared.CommonResult{
+				HttpCode:  400,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	query := targetUrl.Query()
+	query.Set("code", newCode)
+	if payload.Data.State != "" {
+		query.Set("state", payload.Data.State)
+	}
+	targetUrl.RawQuery = query.Encode()
+
+	result = &RedirectResult{
+		Common: shared.CommonResult{
+			HttpCode: 200,
+			Exception: new(exception.Builder).
+				SetStatus(exception.StatusSuccess).
+				SetService(exception.ServiceAuth).
+				SetEndpoint(exception.EndpointAuthServiceRedirect).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonSuccess).
+				Throw(payload.Context),
+		},
+		Data: targetUrl.String(),
+	}
+
+	return
 }

service/service_auth/refresh.go

@@ -0,0 +1,99 @@
+package service_auth
+
+import (
+	"context"
+	"nixcn-cms/internal/authtoken"
+	"nixcn-cms/internal/exception"
+	"nixcn-cms/service/shared"
+
+	"github.com/spf13/viper"
+)
+
+type RefreshData struct {
+	RefreshToken string `json:"refresh_token"`
+}
+
+type RefreshPayload struct {
+	Context context.Context
+	Data    *RefreshData
+}
+
+type RefreshResult struct {
+	Common shared.CommonResult
+	Data   *TokenResponse
+}
+
+func (self *AuthServiceImpl) Refresh(payload *RefreshPayload) (result *RefreshResult) {
+	JwtTool := authtoken.Token{
+		Application: viper.GetString("server.application"),
+	}
+
+	// 1. Refresh Access Token
+	accessToken, err := JwtTool.RefreshAccessToken(payload.Context, payload.Data.RefreshToken)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRefresh).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthRefreshInvalidToken).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &RefreshResult{
+			Common: shared.CommonResult{
+				HttpCode:  401,
+				Exception: exception,
+			},
+			Data: nil,
+		}
+
+		return
+	}
+
+	// 2. Renew Refresh Token (Rotation)
+	refreshToken, err := JwtTool.RenewRefreshToken(payload.Context, payload.Data.RefreshToken)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceRefresh).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthRefreshRenewFailed).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &RefreshResult{
+			Common: shared.CommonResult{
+				HttpCode:  500,
+				Exception: exception,
+			},
+			Data: nil,
+		}
+
+		return
+	}
+
+	// 3. Success Assignment
+	exception := new(exception.Builder).
+		SetStatus(exception.StatusSuccess).
+		SetService(exception.ServiceAuth).
+		SetEndpoint(exception.EndpointAuthServiceRefresh).
+		SetType(exception.TypeCommon).
+		SetOriginal(exception.CommonSuccess).
+		SetError(nil).
+		Throw(payload.Context)
+
+	result = &RefreshResult{
+		Common: shared.CommonResult{
+			HttpCode:  200,
+			Exception: exception,
+		},
+		Data: &TokenResponse{
+			AccessToken:  accessToken,
+			RefreshToken: refreshToken,
+		},
+	}
+
+	return
+}

service/service_auth/service.go

@@ -3,6 +3,9 @@ package service_auth
 type AuthService interface {
 	Exchange(*ExchangePayload) *ExchangeResult
 	Magic(*MagicPayload) *MagicResult
+	Redirect(*RedirectPayload) *RedirectResult
+	Token(*TokenPayload) *TokenResult
+	Refresh(*RefreshPayload) *RefreshResult
 }
 
 type AuthServiceImpl struct{}

service/service_auth/token.go

@@ -0,0 +1,118 @@
+package service_auth
+
+import (
+	"context"
+	"nixcn-cms/data"
+	"nixcn-cms/internal/authcode"
+	"nixcn-cms/internal/authtoken"
+	"nixcn-cms/internal/exception"
+	"nixcn-cms/service/shared"
+
+	"github.com/spf13/viper"
+)
+
+type TokenData struct {
+	Code string `json:"code"`
+}
+
+type TokenPayload struct {
+	Context context.Context
+	Data    *TokenData
+}
+
+type TokenResult struct {
+	Common shared.CommonResult
+	Data   *TokenResponse
+}
+
+type TokenResponse struct {
+	AccessToken  string `json:"access_token"`
+	RefreshToken string `json:"refresh_token"`
+}
+
+func (self *AuthServiceImpl) Token(payload *TokenPayload) (result *TokenResult) {
+	authCode, ok := authcode.VerifyAuthCode(payload.Context, payload.Data.Code)
+	if !ok {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceToken).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthTokenInvalidToken).
+			Throw(payload.Context)
+
+		result = &TokenResult{
+			Common: shared.CommonResult{
+				HttpCode:  403,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	userData := new(data.User)
+	user, err := userData.GetByEmail(payload.Context, &authCode.Email)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceToken).
+			SetType(exception.TypeCommon).
+			SetOriginal(exception.CommonErrorInternal).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &TokenResult{
+			Common: shared.CommonResult{
+				HttpCode:  500,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	JwtTool := authtoken.Token{
+		Application: viper.GetString("server.application"),
+	}
+	accessToken, refreshToken, err := JwtTool.IssueTokens(payload.Context, authCode.ClientId, user.UserId)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceAuth).
+			SetEndpoint(exception.EndpointAuthServiceToken).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.AuthTokenGenFailed).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &TokenResult{
+			Common: shared.CommonResult{
+				HttpCode:  500,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	result = &TokenResult{
+		Common: shared.CommonResult{
+			HttpCode: 200,
+			Exception: new(exception.Builder).
+				SetStatus(exception.StatusSuccess).
+				SetService(exception.ServiceAuth).
+				SetEndpoint(exception.EndpointAuthServiceToken).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonSuccess).
+				Throw(payload.Context),
+		},
+		Data: &TokenResponse{
+			AccessToken:  accessToken,
+			RefreshToken: refreshToken,
+		},
+	}
+
+	return
+}

service/service_event/checkin.go

@@ -0,0 +1,191 @@
+package service_event
+
+import (
+	"context"
+	"nixcn-cms/data"
+	"nixcn-cms/internal/exception"
+	"nixcn-cms/service/shared"
+	"time"
+
+	"github.com/google/uuid"
+)
+
+type CheckinData struct {
+	EventId uuid.UUID `json:"event_id"`
+}
+
+type CheckinPayload struct {
+	Context context.Context
+	UserId  uuid.UUID
+	Data    *CheckinData
+}
+
+type CheckinResult struct {
+	Common shared.CommonResult
+	Data   *struct {
+		CheckinCode *string `json:"checkin_code"`
+	}
+}
+
+func (self *EventServiceImpl) Checkin(payload *CheckinPayload) (result *CheckinResult) {
+	attendance := &data.Attendance{UserId: payload.UserId}
+	code, err := attendance.GenCheckinCode(payload.Context, payload.Data.EventId)
+	if err != nil {
+		result = &CheckinResult{
+			Common: shared.CommonResult{
+				HttpCode: 500,
+				Exception: new(exception.Builder).
+					SetStatus(exception.StatusServer).
+					SetService(exception.ServiceEvent).
+					SetEndpoint(exception.EndpointEventServiceCheckin).
+					SetType(exception.TypeSpecific).
+					SetOriginal(exception.EventCheckinGenCodeFailed).
+					SetError(err).
+					Throw(payload.Context),
+			},
+		}
+		return
+	}
+
+	result = &CheckinResult{
+		Common: shared.CommonResult{
+			HttpCode: 200,
+			Exception: new(exception.Builder).
+				SetStatus(exception.StatusSuccess).
+				SetService(exception.ServiceEvent).
+				SetEndpoint(exception.EndpointEventServiceCheckin).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonSuccess).
+				Throw(payload.Context),
+		},
+		Data: &struct {
+			CheckinCode *string `json:"checkin_code"`
+		}{code},
+	}
+	return
+}
+
+type CheckinSubmitData struct {
+	CheckinCode string `json:"checkin_code"`
+}
+
+type CheckinSubmitPayload struct {
+	Context context.Context
+	Data    *CheckinSubmitData
+}
+
+type CheckinSubmitResult struct {
+	Common shared.CommonResult
+}
+
+func (self *EventServiceImpl) CheckinSubmit(payload *CheckinSubmitPayload) (result *CheckinSubmitResult) {
+	attendanceData := new(data.Attendance)
+	err := attendanceData.VerifyCheckinCode(payload.Context, payload.Data.CheckinCode)
+	if err != nil {
+		result = &CheckinSubmitResult{
+			Common: shared.CommonResult{
+				HttpCode: 400,
+				Exception: new(exception.Builder).
+					SetStatus(exception.StatusUser).
+					SetService(exception.ServiceEvent).
+					SetEndpoint(exception.EndpointEventServiceCheckinSubmit).
+					SetType(exception.TypeCommon).
+					SetOriginal(exception.CommonErrorInvalidInput).
+					SetError(err).
+					Throw(payload.Context),
+			},
+		}
+		return
+	}
+
+	result = &CheckinSubmitResult{
+		Common: shared.CommonResult{
+			HttpCode: 200,
+			Exception: new(exception.Builder).
+				SetStatus(exception.StatusSuccess).
+				SetService(exception.ServiceEvent).
+				SetEndpoint(exception.EndpointEventServiceCheckinSubmit).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonSuccess).
+				Throw(payload.Context),
+		},
+	}
+	return
+}
+
+type CheckinQueryData struct {
+	EventId uuid.UUID `json:"event_id"`
+}
+
+type CheckinQueryPayload struct {
+	Context context.Context
+	UserId  uuid.UUID
+	Data    *CheckinQueryData
+}
+
+type CheckinQueryResult struct {
+	Common shared.CommonResult
+	Data   *struct {
+		CheckinAt *time.Time `json:"checkin_at"`
+	}
+}
+
+func (self *EventServiceImpl) CheckinQuery(payload *CheckinQueryPayload) (result *CheckinQueryResult) {
+	attendanceData := new(data.Attendance)
+	attendance, err := attendanceData.GetAttendance(payload.Context, payload.UserId, payload.Data.EventId)
+
+	if err != nil {
+		result = &CheckinQueryResult{
+			Common: shared.CommonResult{
+				HttpCode: 500,
+				Exception: new(exception.Builder).
+					SetStatus(exception.StatusServer).
+					SetService(exception.ServiceEvent).
+					SetEndpoint(exception.EndpointEventServiceCheckinQuery).
+					SetType(exception.TypeCommon).
+					SetOriginal(exception.CommonErrorDatabase).
+					SetError(err).
+					Throw(payload.Context),
+			},
+		}
+		return
+	}
+
+	if attendance == nil {
+		result = &CheckinQueryResult{
+			Common: shared.CommonResult{
+				HttpCode: 404,
+				Exception: new(exception.Builder).
+					SetStatus(exception.StatusUser).
+					SetService(exception.ServiceEvent).
+					SetEndpoint(exception.EndpointEventServiceCheckinQuery).
+					SetType(exception.TypeSpecific).
+					SetOriginal(exception.EventCheckinQueryRecordNotFound).
+					Throw(payload.Context),
+			},
+		}
+		return
+	}
+
+	var checkinAt *time.Time
+	if !attendance.CheckinAt.IsZero() {
+		checkinAt = &attendance.CheckinAt
+	}
+
+	result = &CheckinQueryResult{
+		Common: shared.CommonResult{
+			HttpCode: 200,
+			Exception: new(exception.Builder).
+				SetStatus(exception.StatusSuccess).
+				SetService(exception.ServiceEvent).
+				SetEndpoint(exception.EndpointEventServiceCheckinQuery).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonSuccess).
+				Throw(payload.Context),
+		},
+		Data: &struct {
+			CheckinAt *time.Time `json:"checkin_at"`
+		}{checkinAt},
+	}
+	return
+}

service/service_event/info.go

@@ -0,0 +1,78 @@
+package service_event
+
+import (
+	"context"
+	"nixcn-cms/data"
+	"nixcn-cms/internal/exception"
+	"nixcn-cms/service/shared"
+	"time"
+
+	"github.com/google/uuid"
+)
+
+type InfoData struct {
+	EventId uuid.UUID `json:"event_id"`
+}
+
+type InfoPayload struct {
+	Context context.Context
+	Data    *InfoData
+}
+
+type InfoResult struct {
+	Common shared.CommonResult
+	Data   *struct {
+		Name      string    `json:"name"`
+		StartTime time.Time `json:"start_time"`
+		EndTime   time.Time `json:"end_time"`
+	}
+}
+
+func (self *EventServiceImpl) Info(payload *InfoPayload) (result *InfoResult) {
+	event, err := new(data.Event).GetEventById(payload.Context, payload.Data.EventId)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusUser).
+			SetService(exception.ServiceEvent).
+			SetEndpoint(exception.EndpointEventServiceInfo).
+			SetType(exception.TypeSpecific).
+			SetOriginal(exception.EventInfoNotFound).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &InfoResult{
+			Common: shared.CommonResult{
+				HttpCode:  404,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	resultData := struct {
+		Name      string    `json:"name"`
+		StartTime time.Time `json:"start_time"`
+		EndTime   time.Time `json:"end_time"`
+	}{
+		Name:      event.Name,
+		StartTime: event.StartTime,
+		EndTime:   event.EndTime,
+	}
+
+	result = &InfoResult{
+		Common: shared.CommonResult{
+			HttpCode: 200,
+			Exception: new(exception.Builder).
+				SetStatus(exception.StatusSuccess).
+				SetService(exception.ServiceEvent).
+				SetEndpoint(exception.EndpointEventServiceInfo).
+				SetType(exception.TypeCommon).
+				SetOriginal(exception.CommonSuccess).
+				Throw(payload.Context),
+		},
+		Data: &resultData,
+	}
+
+	return
+}

service/service_event/service.go

@@ -0,0 +1,14 @@
+package service_event
+
+type EventService interface {
+	Checkin(*CheckinPayload) *CheckinResult
+	CheckinSubmit(*CheckinSubmitPayload) *CheckinSubmitResult
+	CheckinQuery(*CheckinQueryPayload) *CheckinQueryResult
+	Info(*InfoPayload) *InfoResult
+}
+
+type EventServiceImpl struct{}
+
+func NewEventService() EventService {
+	return &EventServiceImpl{}
+}