mirror of
https://github.com/gitpod-io/gitpod.git
synced 2025-12-08 17:36:30 +00:00
112 lines
2.9 KiB
Go
112 lines
2.9 KiB
Go
// Copyright (c) 2023 Gitpod GmbH. All rights reserved.
|
|
// Licensed under the GNU Affero General Public License (AGPL).
|
|
// See License.AGPL.txt in the project root for license information.
|
|
|
|
package apiv1
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"strings"
|
|
|
|
connect "github.com/bufbuild/connect-go"
|
|
"github.com/gitpod-io/gitpod/common-go/namegen"
|
|
"github.com/google/uuid"
|
|
"github.com/relvacode/iso8601"
|
|
"google.golang.org/protobuf/proto"
|
|
"google.golang.org/protobuf/types/known/fieldmaskpb"
|
|
"google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
func validateTeamID(id string) (uuid.UUID, error) {
|
|
teamID, err := validateUUID(id)
|
|
if err != nil {
|
|
return uuid.Nil, connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("Team ID must be a valid UUID."))
|
|
}
|
|
|
|
return teamID, nil
|
|
}
|
|
|
|
func parseGitpodTimeStampOrDefault(s string) *timestamppb.Timestamp {
|
|
parsed, err := parseGitpodTimestamp(s)
|
|
if err != nil {
|
|
return ×tamppb.Timestamp{}
|
|
}
|
|
return parsed
|
|
}
|
|
|
|
func parseGitpodTimestamp(input string) (*timestamppb.Timestamp, error) {
|
|
parsed, err := iso8601.ParseString(input)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return timestamppb.New(parsed), nil
|
|
}
|
|
|
|
func validateWorkspaceID(id string) (string, error) {
|
|
if id == "" {
|
|
return "", connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("Empty workspace id specified"))
|
|
}
|
|
|
|
err := namegen.ValidateWorkspaceID(id)
|
|
if err != nil {
|
|
return "", connect.NewError(connect.CodeInvalidArgument, err)
|
|
}
|
|
|
|
return id, nil
|
|
}
|
|
|
|
func validateProjectID(id string) (uuid.UUID, error) {
|
|
projectID, err := validateUUID(id)
|
|
if err != nil {
|
|
return uuid.Nil, connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("Project ID must be a valid UUID."))
|
|
}
|
|
|
|
return projectID, nil
|
|
}
|
|
|
|
func validatePersonalAccessTokenID(id string) (uuid.UUID, error) {
|
|
tokenID, err := validateUUID(id)
|
|
if err != nil {
|
|
return uuid.Nil, connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("Token ID must be a valid UUID"))
|
|
}
|
|
|
|
return tokenID, nil
|
|
}
|
|
|
|
func validateOrganizationID(id string) (uuid.UUID, error) {
|
|
trimmed := strings.TrimSpace(id)
|
|
if trimmed == "" {
|
|
return uuid.Nil, connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("OrganizationID is a required argument."))
|
|
}
|
|
|
|
organizationID, err := uuid.Parse(trimmed)
|
|
if err != nil {
|
|
return uuid.Nil, connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("OrganizationID must be a valid UUID"))
|
|
}
|
|
|
|
return organizationID, nil
|
|
}
|
|
|
|
func validateFieldMask(mask *fieldmaskpb.FieldMask, message proto.Message) (*fieldmaskpb.FieldMask, error) {
|
|
if mask == nil {
|
|
return &fieldmaskpb.FieldMask{}, nil
|
|
}
|
|
|
|
mask.Normalize()
|
|
if !mask.IsValid(message) {
|
|
return nil, connect.NewError(connect.CodeInvalidArgument, errors.New("Invalid field mask specified."))
|
|
}
|
|
|
|
return mask, nil
|
|
}
|
|
|
|
func validateUUID(id string) (uuid.UUID, error) {
|
|
trimmed := strings.TrimSpace(id)
|
|
if trimmed == "" {
|
|
return uuid.Nil, errors.New("empty uuid")
|
|
}
|
|
|
|
return uuid.Parse(trimmed)
|
|
}
|