content

Documentation

Index

• Variables
• type API
  • func NewContentAPI(endpoint string, username string, password string, xPolicies []string, ...) *API
  • func (api *API) Endpoint() string
  • func (api *API) GTG() error
  • func (api *API) Get(ctx context.Context, contentUUID string, log *logger.UPPLogger) (*http.Response, error)
• type DraftContentRW
  • func NewDraftContentRWService(endpoint string, resolver DraftContentValidatorResolver, ...) DraftContentRW
• type DraftContentValidator
  • func NewSparkDraftContentValidatorService(endpoint string, httpClient *http.Client) DraftContentValidator
• type DraftContentValidatorResolver
  • func NewDraftContentValidatorResolver(contentTypeToValidator map[string]DraftContentValidator) DraftContentValidatorResolver
• type Handler
  • func NewHandler(uppAPI contentProviderAPI, draftContentRW DraftContentRW, ...) *Handler
  • func (h *Handler) ReadContent(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) WriteNativeContent(w http.ResponseWriter, r *http.Request)
• type ValidatorError
  • func (e ValidatorError) Error() string
  • func (e ValidatorError) StatusCode() int

Variables

var (
	ErrDraftNotFound                = errors.New("draft content not found in PAC")
	ErrDraftNotValid                = errors.New("draft content is invalid")
	ErrDraftContentTypeNotSupported = errors.New("draft content-type is invalid")
)

var (
	AllowedOriginSystemIDValues = map[string]struct{}{}
	AllowedContentTypes         = map[string]struct{}{}
)

Types

type API

type API struct {
	// contains filtered or unexported fields
}

func NewContentAPI

func NewContentAPI(endpoint string, username string, password string, xPolicies []string, httpClient *http.Client) *API

func (*API) Endpoint

func (api *API) Endpoint() string

func (*API) GTG

func (api *API) GTG() error

func (*API) Get

func (api *API) Get(ctx context.Context, contentUUID string, log *logger.UPPLogger) (*http.Response, error)

type DraftContentRW

type DraftContentRW interface {
	Read(ctx context.Context, contentUUID string, log *logger.UPPLogger) (io.ReadCloser, error)
	Write(ctx context.Context, contentUUID string, content *string, headers map[string]string, log *logger.UPPLogger) error
	GTG() error
	Endpoint() string
}

func NewDraftContentRWService

func NewDraftContentRWService(endpoint string, resolver DraftContentValidatorResolver, httpClient *http.Client) DraftContentRW

type DraftContentValidator

type DraftContentValidator interface {
	Validate(ctx context.Context, contentUUID string, nativeBody io.Reader, contentType string, log *logger.UPPLogger) (io.ReadCloser, error)
	GTG() error
	Endpoint() string
}

func NewSparkDraftContentValidatorService

func NewSparkDraftContentValidatorService(endpoint string, httpClient *http.Client) DraftContentValidator

type DraftContentValidatorResolver

type DraftContentValidatorResolver interface {
	// ValidatorForContentType Resolves and returns a DraftContentValidator implementation if present.
	ValidatorForContentType(contentType string) (DraftContentValidator, error)
}

DraftContentValidatorResolver manages the validators available for a given originId/content-type pair.

func NewDraftContentValidatorResolver

func NewDraftContentValidatorResolver(contentTypeToValidator map[string]DraftContentValidator) DraftContentValidatorResolver

NewDraftContentValidatorResolver returns a DraftContentValidatorResolver implementation

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(uppAPI contentProviderAPI, draftContentRW DraftContentRW, timeout time.Duration, log *logger.UPPLogger) *Handler

func (*Handler) ReadContent

func (h *Handler) ReadContent(w http.ResponseWriter, r *http.Request)

func (*Handler) WriteNativeContent

func (h *Handler) WriteNativeContent(w http.ResponseWriter, r *http.Request)

type ValidatorError

type ValidatorError struct {
	// contains filtered or unexported fields
}

func (ValidatorError) Error

func (e ValidatorError) Error() string

func (ValidatorError) StatusCode

func (e ValidatorError) StatusCode() int