// Code generated by smithy-go-codegen DO NOT EDIT. package workdocs import ( "bytes" "context" "fmt" "github.com/aws/aws-sdk-go-v2/service/workdocs/types" smithy "github.com/aws/smithy-go" "github.com/aws/smithy-go/encoding/httpbinding" smithyjson "github.com/aws/smithy-go/encoding/json" "github.com/aws/smithy-go/middleware" smithytime "github.com/aws/smithy-go/time" smithyhttp "github.com/aws/smithy-go/transport/http" ) type awsRestjson1_serializeOpAbortDocumentVersionUpload struct { } func (*awsRestjson1_serializeOpAbortDocumentVersionUpload) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpAbortDocumentVersionUpload) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*AbortDocumentVersionUploadInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions/{VersionId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsAbortDocumentVersionUploadInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsAbortDocumentVersionUploadInput(v *AbortDocumentVersionUploadInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } type awsRestjson1_serializeOpActivateUser struct { } func (*awsRestjson1_serializeOpActivateUser) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpActivateUser) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*ActivateUserInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/users/{UserId}/activation") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsActivateUserInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsActivateUserInput(v *ActivateUserInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.UserId == nil || len(*v.UserId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member UserId must not be empty")} } if v.UserId != nil { if err := encoder.SetURI("UserId").String(*v.UserId); err != nil { return err } } return nil } type awsRestjson1_serializeOpAddResourcePermissions struct { } func (*awsRestjson1_serializeOpAddResourcePermissions) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpAddResourcePermissions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*AddResourcePermissionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/permissions") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsAddResourcePermissionsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentAddResourcePermissionsInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsAddResourcePermissionsInput(v *AddResourcePermissionsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentAddResourcePermissionsInput(v *AddResourcePermissionsInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.NotificationOptions != nil { ok := object.Key("NotificationOptions") if err := awsRestjson1_serializeDocumentNotificationOptions(v.NotificationOptions, ok); err != nil { return err } } if v.Principals != nil { ok := object.Key("Principals") if err := awsRestjson1_serializeDocumentSharePrincipalList(v.Principals, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateComment struct { } func (*awsRestjson1_serializeOpCreateComment) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateComment) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateCommentInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions/{VersionId}/comment") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsCreateCommentInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateCommentInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateCommentInput(v *CreateCommentInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentCreateCommentInput(v *CreateCommentInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.NotifyCollaborators { ok := object.Key("NotifyCollaborators") ok.Boolean(v.NotifyCollaborators) } if v.ParentId != nil { ok := object.Key("ParentId") ok.String(*v.ParentId) } if v.Text != nil { ok := object.Key("Text") ok.String(*v.Text) } if v.ThreadId != nil { ok := object.Key("ThreadId") ok.String(*v.ThreadId) } if len(v.Visibility) > 0 { ok := object.Key("Visibility") ok.String(string(v.Visibility)) } return nil } type awsRestjson1_serializeOpCreateCustomMetadata struct { } func (*awsRestjson1_serializeOpCreateCustomMetadata) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateCustomMetadata) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateCustomMetadataInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/customMetadata") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PUT" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsCreateCustomMetadataInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateCustomMetadataInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateCustomMetadataInput(v *CreateCustomMetadataInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } if v.VersionId != nil { encoder.SetQuery("versionid").String(*v.VersionId) } return nil } func awsRestjson1_serializeOpDocumentCreateCustomMetadataInput(v *CreateCustomMetadataInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.CustomMetadata != nil { ok := object.Key("CustomMetadata") if err := awsRestjson1_serializeDocumentCustomMetadataMap(v.CustomMetadata, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateFolder struct { } func (*awsRestjson1_serializeOpCreateFolder) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateFolder) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateFolderInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsCreateFolderInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateFolderInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateFolderInput(v *CreateFolderInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } return nil } func awsRestjson1_serializeOpDocumentCreateFolderInput(v *CreateFolderInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Name != nil { ok := object.Key("Name") ok.String(*v.Name) } if v.ParentFolderId != nil { ok := object.Key("ParentFolderId") ok.String(*v.ParentFolderId) } return nil } type awsRestjson1_serializeOpCreateLabels struct { } func (*awsRestjson1_serializeOpCreateLabels) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateLabels) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateLabelsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/labels") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PUT" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsCreateLabelsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateLabelsInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateLabelsInput(v *CreateLabelsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentCreateLabelsInput(v *CreateLabelsInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Labels != nil { ok := object.Key("Labels") if err := awsRestjson1_serializeDocumentSharedLabels(v.Labels, ok); err != nil { return err } } return nil } type awsRestjson1_serializeOpCreateNotificationSubscription struct { } func (*awsRestjson1_serializeOpCreateNotificationSubscription) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateNotificationSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateNotificationSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/organizations/{OrganizationId}/subscriptions") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsCreateNotificationSubscriptionInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateNotificationSubscriptionInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateNotificationSubscriptionInput(v *CreateNotificationSubscriptionInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.OrganizationId == nil || len(*v.OrganizationId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member OrganizationId must not be empty")} } if v.OrganizationId != nil { if err := encoder.SetURI("OrganizationId").String(*v.OrganizationId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentCreateNotificationSubscriptionInput(v *CreateNotificationSubscriptionInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Endpoint != nil { ok := object.Key("Endpoint") ok.String(*v.Endpoint) } if len(v.Protocol) > 0 { ok := object.Key("Protocol") ok.String(string(v.Protocol)) } if len(v.SubscriptionType) > 0 { ok := object.Key("SubscriptionType") ok.String(string(v.SubscriptionType)) } return nil } type awsRestjson1_serializeOpCreateUser struct { } func (*awsRestjson1_serializeOpCreateUser) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpCreateUser) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*CreateUserInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/users") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsCreateUserInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentCreateUserInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsCreateUserInput(v *CreateUserInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } return nil } func awsRestjson1_serializeOpDocumentCreateUserInput(v *CreateUserInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.EmailAddress != nil { ok := object.Key("EmailAddress") ok.String(*v.EmailAddress) } if v.GivenName != nil { ok := object.Key("GivenName") ok.String(*v.GivenName) } if v.OrganizationId != nil { ok := object.Key("OrganizationId") ok.String(*v.OrganizationId) } if v.Password != nil { ok := object.Key("Password") ok.String(*v.Password) } if v.StorageRule != nil { ok := object.Key("StorageRule") if err := awsRestjson1_serializeDocumentStorageRuleType(v.StorageRule, ok); err != nil { return err } } if v.Surname != nil { ok := object.Key("Surname") ok.String(*v.Surname) } if v.TimeZoneId != nil { ok := object.Key("TimeZoneId") ok.String(*v.TimeZoneId) } if v.Username != nil { ok := object.Key("Username") ok.String(*v.Username) } return nil } type awsRestjson1_serializeOpDeactivateUser struct { } func (*awsRestjson1_serializeOpDeactivateUser) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeactivateUser) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeactivateUserInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/users/{UserId}/activation") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeactivateUserInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeactivateUserInput(v *DeactivateUserInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.UserId == nil || len(*v.UserId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member UserId must not be empty")} } if v.UserId != nil { if err := encoder.SetURI("UserId").String(*v.UserId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteComment struct { } func (*awsRestjson1_serializeOpDeleteComment) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteComment) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteCommentInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions/{VersionId}/comment/{CommentId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteCommentInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteCommentInput(v *DeleteCommentInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.CommentId == nil || len(*v.CommentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member CommentId must not be empty")} } if v.CommentId != nil { if err := encoder.SetURI("CommentId").String(*v.CommentId); err != nil { return err } } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteCustomMetadata struct { } func (*awsRestjson1_serializeOpDeleteCustomMetadata) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteCustomMetadata) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteCustomMetadataInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/customMetadata") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteCustomMetadataInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteCustomMetadataInput(v *DeleteCustomMetadataInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DeleteAll { encoder.SetQuery("deleteAll").Boolean(v.DeleteAll) } if v.Keys != nil { for i := range v.Keys { encoder.AddQuery("keys").String(v.Keys[i]) } } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } if v.VersionId != nil { encoder.SetQuery("versionId").String(*v.VersionId) } return nil } type awsRestjson1_serializeOpDeleteDocument struct { } func (*awsRestjson1_serializeOpDeleteDocument) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteDocument) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDocumentInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteDocumentInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteDocumentInput(v *DeleteDocumentInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteDocumentVersion struct { } func (*awsRestjson1_serializeOpDeleteDocumentVersion) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteDocumentVersion) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteDocumentVersionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documentVersions/{DocumentId}/versions/{VersionId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteDocumentVersionInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteDocumentVersionInput(v *DeleteDocumentVersionInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } { encoder.SetQuery("deletePriorVersions").Boolean(v.DeletePriorVersions) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteFolder struct { } func (*awsRestjson1_serializeOpDeleteFolder) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteFolder) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteFolderInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders/{FolderId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteFolderInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteFolderInput(v *DeleteFolderInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.FolderId == nil || len(*v.FolderId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member FolderId must not be empty")} } if v.FolderId != nil { if err := encoder.SetURI("FolderId").String(*v.FolderId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteFolderContents struct { } func (*awsRestjson1_serializeOpDeleteFolderContents) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteFolderContents) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteFolderContentsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders/{FolderId}/contents") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteFolderContentsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteFolderContentsInput(v *DeleteFolderContentsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.FolderId == nil || len(*v.FolderId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member FolderId must not be empty")} } if v.FolderId != nil { if err := encoder.SetURI("FolderId").String(*v.FolderId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteLabels struct { } func (*awsRestjson1_serializeOpDeleteLabels) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteLabels) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteLabelsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/labels") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteLabelsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteLabelsInput(v *DeleteLabelsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DeleteAll { encoder.SetQuery("deleteAll").Boolean(v.DeleteAll) } if v.Labels != nil { for i := range v.Labels { encoder.AddQuery("labels").String(v.Labels[i]) } } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteNotificationSubscription struct { } func (*awsRestjson1_serializeOpDeleteNotificationSubscription) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteNotificationSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteNotificationSubscriptionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/organizations/{OrganizationId}/subscriptions/{SubscriptionId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteNotificationSubscriptionInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteNotificationSubscriptionInput(v *DeleteNotificationSubscriptionInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.OrganizationId == nil || len(*v.OrganizationId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member OrganizationId must not be empty")} } if v.OrganizationId != nil { if err := encoder.SetURI("OrganizationId").String(*v.OrganizationId); err != nil { return err } } if v.SubscriptionId == nil || len(*v.SubscriptionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member SubscriptionId must not be empty")} } if v.SubscriptionId != nil { if err := encoder.SetURI("SubscriptionId").String(*v.SubscriptionId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDeleteUser struct { } func (*awsRestjson1_serializeOpDeleteUser) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDeleteUser) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DeleteUserInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/users/{UserId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDeleteUserInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDeleteUserInput(v *DeleteUserInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.UserId == nil || len(*v.UserId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member UserId must not be empty")} } if v.UserId != nil { if err := encoder.SetURI("UserId").String(*v.UserId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDescribeActivities struct { } func (*awsRestjson1_serializeOpDescribeActivities) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeActivities) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeActivitiesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/activities") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeActivitiesInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeActivitiesInput(v *DescribeActivitiesInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.ActivityTypes != nil { encoder.SetQuery("activityTypes").String(*v.ActivityTypes) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.EndTime != nil { encoder.SetQuery("endTime").String(smithytime.FormatDateTime(*v.EndTime)) } if v.IncludeIndirectActivities { encoder.SetQuery("includeIndirectActivities").Boolean(v.IncludeIndirectActivities) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if v.OrganizationId != nil { encoder.SetQuery("organizationId").String(*v.OrganizationId) } if v.ResourceId != nil { encoder.SetQuery("resourceId").String(*v.ResourceId) } if v.StartTime != nil { encoder.SetQuery("startTime").String(smithytime.FormatDateTime(*v.StartTime)) } if v.UserId != nil { encoder.SetQuery("userId").String(*v.UserId) } return nil } type awsRestjson1_serializeOpDescribeComments struct { } func (*awsRestjson1_serializeOpDescribeComments) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeComments) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeCommentsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions/{VersionId}/comments") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeCommentsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeCommentsInput(v *DescribeCommentsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDescribeDocumentVersions struct { } func (*awsRestjson1_serializeOpDescribeDocumentVersions) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeDocumentVersions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeDocumentVersionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeDocumentVersionsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeDocumentVersionsInput(v *DescribeDocumentVersionsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.Fields != nil { encoder.SetQuery("fields").String(*v.Fields) } if v.Include != nil { encoder.SetQuery("include").String(*v.Include) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } return nil } type awsRestjson1_serializeOpDescribeFolderContents struct { } func (*awsRestjson1_serializeOpDescribeFolderContents) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeFolderContents) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeFolderContentsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders/{FolderId}/contents") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeFolderContentsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeFolderContentsInput(v *DescribeFolderContentsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.FolderId == nil || len(*v.FolderId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member FolderId must not be empty")} } if v.FolderId != nil { if err := encoder.SetURI("FolderId").String(*v.FolderId); err != nil { return err } } if v.Include != nil { encoder.SetQuery("include").String(*v.Include) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if len(v.Order) > 0 { encoder.SetQuery("order").String(string(v.Order)) } if len(v.Sort) > 0 { encoder.SetQuery("sort").String(string(v.Sort)) } if len(v.Type) > 0 { encoder.SetQuery("type").String(string(v.Type)) } return nil } type awsRestjson1_serializeOpDescribeGroups struct { } func (*awsRestjson1_serializeOpDescribeGroups) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeGroups) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeGroupsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/groups") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeGroupsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeGroupsInput(v *DescribeGroupsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if v.OrganizationId != nil { encoder.SetQuery("organizationId").String(*v.OrganizationId) } if v.SearchQuery != nil { encoder.SetQuery("searchQuery").String(*v.SearchQuery) } return nil } type awsRestjson1_serializeOpDescribeNotificationSubscriptions struct { } func (*awsRestjson1_serializeOpDescribeNotificationSubscriptions) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeNotificationSubscriptions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeNotificationSubscriptionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/organizations/{OrganizationId}/subscriptions") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeNotificationSubscriptionsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeNotificationSubscriptionsInput(v *DescribeNotificationSubscriptionsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if v.OrganizationId == nil || len(*v.OrganizationId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member OrganizationId must not be empty")} } if v.OrganizationId != nil { if err := encoder.SetURI("OrganizationId").String(*v.OrganizationId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDescribeResourcePermissions struct { } func (*awsRestjson1_serializeOpDescribeResourcePermissions) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeResourcePermissions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeResourcePermissionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/permissions") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeResourcePermissionsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeResourcePermissionsInput(v *DescribeResourcePermissionsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if v.PrincipalId != nil { encoder.SetQuery("principalId").String(*v.PrincipalId) } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } return nil } type awsRestjson1_serializeOpDescribeRootFolders struct { } func (*awsRestjson1_serializeOpDescribeRootFolders) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeRootFolders) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeRootFoldersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/me/root") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeRootFoldersInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeRootFoldersInput(v *DescribeRootFoldersInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } return nil } type awsRestjson1_serializeOpDescribeUsers struct { } func (*awsRestjson1_serializeOpDescribeUsers) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpDescribeUsers) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*DescribeUsersInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/users") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsDescribeUsersInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsDescribeUsersInput(v *DescribeUsersInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.Fields != nil { encoder.SetQuery("fields").String(*v.Fields) } if len(v.Include) > 0 { encoder.SetQuery("include").String(string(v.Include)) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if len(v.Order) > 0 { encoder.SetQuery("order").String(string(v.Order)) } if v.OrganizationId != nil { encoder.SetQuery("organizationId").String(*v.OrganizationId) } if v.Query != nil { encoder.SetQuery("query").String(*v.Query) } if len(v.Sort) > 0 { encoder.SetQuery("sort").String(string(v.Sort)) } if v.UserIds != nil { encoder.SetQuery("userIds").String(*v.UserIds) } return nil } type awsRestjson1_serializeOpGetCurrentUser struct { } func (*awsRestjson1_serializeOpGetCurrentUser) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetCurrentUser) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetCurrentUserInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/me") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetCurrentUserInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetCurrentUserInput(v *GetCurrentUserInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } return nil } type awsRestjson1_serializeOpGetDocument struct { } func (*awsRestjson1_serializeOpGetDocument) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetDocument) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetDocumentInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetDocumentInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetDocumentInput(v *GetDocumentInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.IncludeCustomMetadata { encoder.SetQuery("includeCustomMetadata").Boolean(v.IncludeCustomMetadata) } return nil } type awsRestjson1_serializeOpGetDocumentPath struct { } func (*awsRestjson1_serializeOpGetDocumentPath) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetDocumentPath) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetDocumentPathInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/path") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetDocumentPathInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetDocumentPathInput(v *GetDocumentPathInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.Fields != nil { encoder.SetQuery("fields").String(*v.Fields) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } return nil } type awsRestjson1_serializeOpGetDocumentVersion struct { } func (*awsRestjson1_serializeOpGetDocumentVersion) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetDocumentVersion) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetDocumentVersionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions/{VersionId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetDocumentVersionInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetDocumentVersionInput(v *GetDocumentVersionInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.Fields != nil { encoder.SetQuery("fields").String(*v.Fields) } if v.IncludeCustomMetadata { encoder.SetQuery("includeCustomMetadata").Boolean(v.IncludeCustomMetadata) } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } type awsRestjson1_serializeOpGetFolder struct { } func (*awsRestjson1_serializeOpGetFolder) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetFolder) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetFolderInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders/{FolderId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetFolderInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetFolderInput(v *GetFolderInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.FolderId == nil || len(*v.FolderId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member FolderId must not be empty")} } if v.FolderId != nil { if err := encoder.SetURI("FolderId").String(*v.FolderId); err != nil { return err } } if v.IncludeCustomMetadata { encoder.SetQuery("includeCustomMetadata").Boolean(v.IncludeCustomMetadata) } return nil } type awsRestjson1_serializeOpGetFolderPath struct { } func (*awsRestjson1_serializeOpGetFolderPath) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetFolderPath) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetFolderPathInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders/{FolderId}/path") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetFolderPathInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetFolderPathInput(v *GetFolderPathInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.Fields != nil { encoder.SetQuery("fields").String(*v.Fields) } if v.FolderId == nil || len(*v.FolderId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member FolderId must not be empty")} } if v.FolderId != nil { if err := encoder.SetURI("FolderId").String(*v.FolderId); err != nil { return err } } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } return nil } type awsRestjson1_serializeOpGetResources struct { } func (*awsRestjson1_serializeOpGetResources) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpGetResources) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*GetResourcesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "GET" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsGetResourcesInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsGetResourcesInput(v *GetResourcesInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if len(v.CollectionType) > 0 { encoder.SetQuery("collectionType").String(string(v.CollectionType)) } if v.Limit != nil { encoder.SetQuery("limit").Integer(*v.Limit) } if v.Marker != nil { encoder.SetQuery("marker").String(*v.Marker) } if v.UserId != nil { encoder.SetQuery("userId").String(*v.UserId) } return nil } type awsRestjson1_serializeOpInitiateDocumentVersionUpload struct { } func (*awsRestjson1_serializeOpInitiateDocumentVersionUpload) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpInitiateDocumentVersionUpload) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*InitiateDocumentVersionUploadInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsInitiateDocumentVersionUploadInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentInitiateDocumentVersionUploadInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsInitiateDocumentVersionUploadInput(v *InitiateDocumentVersionUploadInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } return nil } func awsRestjson1_serializeOpDocumentInitiateDocumentVersionUploadInput(v *InitiateDocumentVersionUploadInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.ContentCreatedTimestamp != nil { ok := object.Key("ContentCreatedTimestamp") ok.Double(smithytime.FormatEpochSeconds(*v.ContentCreatedTimestamp)) } if v.ContentModifiedTimestamp != nil { ok := object.Key("ContentModifiedTimestamp") ok.Double(smithytime.FormatEpochSeconds(*v.ContentModifiedTimestamp)) } if v.ContentType != nil { ok := object.Key("ContentType") ok.String(*v.ContentType) } if v.DocumentSizeInBytes != nil { ok := object.Key("DocumentSizeInBytes") ok.Long(*v.DocumentSizeInBytes) } if v.Id != nil { ok := object.Key("Id") ok.String(*v.Id) } if v.Name != nil { ok := object.Key("Name") ok.String(*v.Name) } if v.ParentFolderId != nil { ok := object.Key("ParentFolderId") ok.String(*v.ParentFolderId) } return nil } type awsRestjson1_serializeOpRemoveAllResourcePermissions struct { } func (*awsRestjson1_serializeOpRemoveAllResourcePermissions) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpRemoveAllResourcePermissions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RemoveAllResourcePermissionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/permissions") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsRemoveAllResourcePermissionsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsRemoveAllResourcePermissionsInput(v *RemoveAllResourcePermissionsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } return nil } type awsRestjson1_serializeOpRemoveResourcePermission struct { } func (*awsRestjson1_serializeOpRemoveResourcePermission) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpRemoveResourcePermission) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RemoveResourcePermissionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/resources/{ResourceId}/permissions/{PrincipalId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "DELETE" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsRemoveResourcePermissionInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsRemoveResourcePermissionInput(v *RemoveResourcePermissionInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.PrincipalId == nil || len(*v.PrincipalId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member PrincipalId must not be empty")} } if v.PrincipalId != nil { if err := encoder.SetURI("PrincipalId").String(*v.PrincipalId); err != nil { return err } } if len(v.PrincipalType) > 0 { encoder.SetQuery("type").String(string(v.PrincipalType)) } if v.ResourceId == nil || len(*v.ResourceId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member ResourceId must not be empty")} } if v.ResourceId != nil { if err := encoder.SetURI("ResourceId").String(*v.ResourceId); err != nil { return err } } return nil } type awsRestjson1_serializeOpRestoreDocumentVersions struct { } func (*awsRestjson1_serializeOpRestoreDocumentVersions) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpRestoreDocumentVersions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*RestoreDocumentVersionsInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documentVersions/restore/{DocumentId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsRestoreDocumentVersionsInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsRestoreDocumentVersionsInput(v *RestoreDocumentVersionsInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } return nil } type awsRestjson1_serializeOpSearchResources struct { } func (*awsRestjson1_serializeOpSearchResources) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpSearchResources) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*SearchResourcesInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/search") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "POST" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsSearchResourcesInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentSearchResourcesInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsSearchResourcesInput(v *SearchResourcesInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } return nil } func awsRestjson1_serializeOpDocumentSearchResourcesInput(v *SearchResourcesInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.AdditionalResponseFields != nil { ok := object.Key("AdditionalResponseFields") if err := awsRestjson1_serializeDocumentAdditionalResponseFieldsList(v.AdditionalResponseFields, ok); err != nil { return err } } if v.Filters != nil { ok := object.Key("Filters") if err := awsRestjson1_serializeDocumentFilters(v.Filters, ok); err != nil { return err } } if v.Limit != nil { ok := object.Key("Limit") ok.Integer(*v.Limit) } if v.Marker != nil { ok := object.Key("Marker") ok.String(*v.Marker) } if v.OrderBy != nil { ok := object.Key("OrderBy") if err := awsRestjson1_serializeDocumentSearchResultSortList(v.OrderBy, ok); err != nil { return err } } if v.OrganizationId != nil { ok := object.Key("OrganizationId") ok.String(*v.OrganizationId) } if v.QueryScopes != nil { ok := object.Key("QueryScopes") if err := awsRestjson1_serializeDocumentSearchQueryScopeTypeList(v.QueryScopes, ok); err != nil { return err } } if v.QueryText != nil { ok := object.Key("QueryText") ok.String(*v.QueryText) } return nil } type awsRestjson1_serializeOpUpdateDocument struct { } func (*awsRestjson1_serializeOpUpdateDocument) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpUpdateDocument) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*UpdateDocumentInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PATCH" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsUpdateDocumentInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUpdateDocumentInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsUpdateDocumentInput(v *UpdateDocumentInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentUpdateDocumentInput(v *UpdateDocumentInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Name != nil { ok := object.Key("Name") ok.String(*v.Name) } if v.ParentFolderId != nil { ok := object.Key("ParentFolderId") ok.String(*v.ParentFolderId) } if len(v.ResourceState) > 0 { ok := object.Key("ResourceState") ok.String(string(v.ResourceState)) } return nil } type awsRestjson1_serializeOpUpdateDocumentVersion struct { } func (*awsRestjson1_serializeOpUpdateDocumentVersion) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpUpdateDocumentVersion) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*UpdateDocumentVersionInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/documents/{DocumentId}/versions/{VersionId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PATCH" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsUpdateDocumentVersionInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUpdateDocumentVersionInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsUpdateDocumentVersionInput(v *UpdateDocumentVersionInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.DocumentId == nil || len(*v.DocumentId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member DocumentId must not be empty")} } if v.DocumentId != nil { if err := encoder.SetURI("DocumentId").String(*v.DocumentId); err != nil { return err } } if v.VersionId == nil || len(*v.VersionId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member VersionId must not be empty")} } if v.VersionId != nil { if err := encoder.SetURI("VersionId").String(*v.VersionId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentUpdateDocumentVersionInput(v *UpdateDocumentVersionInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.VersionStatus) > 0 { ok := object.Key("VersionStatus") ok.String(string(v.VersionStatus)) } return nil } type awsRestjson1_serializeOpUpdateFolder struct { } func (*awsRestjson1_serializeOpUpdateFolder) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpUpdateFolder) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*UpdateFolderInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/folders/{FolderId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PATCH" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsUpdateFolderInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUpdateFolderInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsUpdateFolderInput(v *UpdateFolderInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.FolderId == nil || len(*v.FolderId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member FolderId must not be empty")} } if v.FolderId != nil { if err := encoder.SetURI("FolderId").String(*v.FolderId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentUpdateFolderInput(v *UpdateFolderInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Name != nil { ok := object.Key("Name") ok.String(*v.Name) } if v.ParentFolderId != nil { ok := object.Key("ParentFolderId") ok.String(*v.ParentFolderId) } if len(v.ResourceState) > 0 { ok := object.Key("ResourceState") ok.String(string(v.ResourceState)) } return nil } type awsRestjson1_serializeOpUpdateUser struct { } func (*awsRestjson1_serializeOpUpdateUser) ID() string { return "OperationSerializer" } func (m *awsRestjson1_serializeOpUpdateUser) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, ) { request, ok := in.Request.(*smithyhttp.Request) if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} } input, ok := in.Parameters.(*UpdateUserInput) _ = input if !ok { return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} } opPath, opQuery := httpbinding.SplitURI("/api/v1/users/{UserId}") request.URL.Path = smithyhttp.JoinPath(request.URL.Path, opPath) request.URL.RawQuery = smithyhttp.JoinRawQuery(request.URL.RawQuery, opQuery) request.Method = "PATCH" restEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) if err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if err := awsRestjson1_serializeOpHttpBindingsUpdateUserInput(input, restEncoder); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } restEncoder.SetHeader("Content-Type").String("application/json") jsonEncoder := smithyjson.NewEncoder() if err := awsRestjson1_serializeOpDocumentUpdateUserInput(input, jsonEncoder.Value); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } if request.Request, err = restEncoder.Encode(request.Request); err != nil { return out, metadata, &smithy.SerializationError{Err: err} } in.Request = request return next.HandleSerialize(ctx, in) } func awsRestjson1_serializeOpHttpBindingsUpdateUserInput(v *UpdateUserInput, encoder *httpbinding.Encoder) error { if v == nil { return fmt.Errorf("unsupported serialization of nil %T", v) } if v.AuthenticationToken != nil && len(*v.AuthenticationToken) > 0 { locationName := "Authentication" encoder.SetHeader(locationName).String(*v.AuthenticationToken) } if v.UserId == nil || len(*v.UserId) == 0 { return &smithy.SerializationError{Err: fmt.Errorf("input member UserId must not be empty")} } if v.UserId != nil { if err := encoder.SetURI("UserId").String(*v.UserId); err != nil { return err } } return nil } func awsRestjson1_serializeOpDocumentUpdateUserInput(v *UpdateUserInput, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.GivenName != nil { ok := object.Key("GivenName") ok.String(*v.GivenName) } if len(v.GrantPoweruserPrivileges) > 0 { ok := object.Key("GrantPoweruserPrivileges") ok.String(string(v.GrantPoweruserPrivileges)) } if len(v.Locale) > 0 { ok := object.Key("Locale") ok.String(string(v.Locale)) } if v.StorageRule != nil { ok := object.Key("StorageRule") if err := awsRestjson1_serializeDocumentStorageRuleType(v.StorageRule, ok); err != nil { return err } } if v.Surname != nil { ok := object.Key("Surname") ok.String(*v.Surname) } if v.TimeZoneId != nil { ok := object.Key("TimeZoneId") ok.String(*v.TimeZoneId) } if len(v.Type) > 0 { ok := object.Key("Type") ok.String(string(v.Type)) } return nil } func awsRestjson1_serializeDocumentAdditionalResponseFieldsList(v []types.AdditionalResponseFieldType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil } func awsRestjson1_serializeDocumentCustomMetadataMap(v map[string]string, value smithyjson.Value) error { object := value.Object() defer object.Close() for key := range v { om := object.Key(key) om.String(v[key]) } return nil } func awsRestjson1_serializeDocumentDateRangeType(v *types.DateRangeType, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.EndValue != nil { ok := object.Key("EndValue") ok.Double(smithytime.FormatEpochSeconds(*v.EndValue)) } if v.StartValue != nil { ok := object.Key("StartValue") ok.Double(smithytime.FormatEpochSeconds(*v.StartValue)) } return nil } func awsRestjson1_serializeDocumentFilters(v *types.Filters, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.AncestorIds != nil { ok := object.Key("AncestorIds") if err := awsRestjson1_serializeDocumentSearchAncestorIdList(v.AncestorIds, ok); err != nil { return err } } if v.ContentCategories != nil { ok := object.Key("ContentCategories") if err := awsRestjson1_serializeDocumentSearchContentCategoryTypeList(v.ContentCategories, ok); err != nil { return err } } if v.CreatedRange != nil { ok := object.Key("CreatedRange") if err := awsRestjson1_serializeDocumentDateRangeType(v.CreatedRange, ok); err != nil { return err } } if v.Labels != nil { ok := object.Key("Labels") if err := awsRestjson1_serializeDocumentSearchLabelList(v.Labels, ok); err != nil { return err } } if v.ModifiedRange != nil { ok := object.Key("ModifiedRange") if err := awsRestjson1_serializeDocumentDateRangeType(v.ModifiedRange, ok); err != nil { return err } } if v.Principals != nil { ok := object.Key("Principals") if err := awsRestjson1_serializeDocumentSearchPrincipalTypeList(v.Principals, ok); err != nil { return err } } if v.ResourceTypes != nil { ok := object.Key("ResourceTypes") if err := awsRestjson1_serializeDocumentSearchResourceTypeList(v.ResourceTypes, ok); err != nil { return err } } if v.SearchCollectionTypes != nil { ok := object.Key("SearchCollectionTypes") if err := awsRestjson1_serializeDocumentSearchCollectionTypeList(v.SearchCollectionTypes, ok); err != nil { return err } } if v.SizeRange != nil { ok := object.Key("SizeRange") if err := awsRestjson1_serializeDocumentLongRangeType(v.SizeRange, ok); err != nil { return err } } if v.TextLocales != nil { ok := object.Key("TextLocales") if err := awsRestjson1_serializeDocumentTextLocaleTypeList(v.TextLocales, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentLongRangeType(v *types.LongRangeType, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.EndValue != nil { ok := object.Key("EndValue") ok.Long(*v.EndValue) } if v.StartValue != nil { ok := object.Key("StartValue") ok.Long(*v.StartValue) } return nil } func awsRestjson1_serializeDocumentNotificationOptions(v *types.NotificationOptions, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.EmailMessage != nil { ok := object.Key("EmailMessage") ok.String(*v.EmailMessage) } if v.SendEmail { ok := object.Key("SendEmail") ok.Boolean(v.SendEmail) } return nil } func awsRestjson1_serializeDocumentSearchAncestorIdList(v []string, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsRestjson1_serializeDocumentSearchCollectionTypeList(v []types.SearchCollectionType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil } func awsRestjson1_serializeDocumentSearchContentCategoryTypeList(v []types.ContentCategoryType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil } func awsRestjson1_serializeDocumentSearchLabelList(v []string, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsRestjson1_serializeDocumentSearchPrincipalRoleList(v []types.PrincipalRoleType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil } func awsRestjson1_serializeDocumentSearchPrincipalType(v *types.SearchPrincipalType, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Id != nil { ok := object.Key("Id") ok.String(*v.Id) } if v.Roles != nil { ok := object.Key("Roles") if err := awsRestjson1_serializeDocumentSearchPrincipalRoleList(v.Roles, ok); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentSearchPrincipalTypeList(v []types.SearchPrincipalType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentSearchPrincipalType(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentSearchQueryScopeTypeList(v []types.SearchQueryScopeType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil } func awsRestjson1_serializeDocumentSearchResourceTypeList(v []types.SearchResourceType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil } func awsRestjson1_serializeDocumentSearchResultSortList(v []types.SearchSortResult, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentSearchSortResult(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentSearchSortResult(v *types.SearchSortResult, value smithyjson.Value) error { object := value.Object() defer object.Close() if len(v.Field) > 0 { ok := object.Key("Field") ok.String(string(v.Field)) } if len(v.Order) > 0 { ok := object.Key("Order") ok.String(string(v.Order)) } return nil } func awsRestjson1_serializeDocumentSharedLabels(v []string, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(v[i]) } return nil } func awsRestjson1_serializeDocumentSharePrincipal(v *types.SharePrincipal, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.Id != nil { ok := object.Key("Id") ok.String(*v.Id) } if len(v.Role) > 0 { ok := object.Key("Role") ok.String(string(v.Role)) } if len(v.Type) > 0 { ok := object.Key("Type") ok.String(string(v.Type)) } return nil } func awsRestjson1_serializeDocumentSharePrincipalList(v []types.SharePrincipal, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() if err := awsRestjson1_serializeDocumentSharePrincipal(&v[i], av); err != nil { return err } } return nil } func awsRestjson1_serializeDocumentStorageRuleType(v *types.StorageRuleType, value smithyjson.Value) error { object := value.Object() defer object.Close() if v.StorageAllocatedInBytes != nil { ok := object.Key("StorageAllocatedInBytes") ok.Long(*v.StorageAllocatedInBytes) } if len(v.StorageType) > 0 { ok := object.Key("StorageType") ok.String(string(v.StorageType)) } return nil } func awsRestjson1_serializeDocumentTextLocaleTypeList(v []types.LanguageCodeType, value smithyjson.Value) error { array := value.Array() defer array.Close() for i := range v { av := array.Value() av.String(string(v[i])) } return nil }