ffm

Documentation

Index

• Variables
• type Config
• type DecodeMp3Request
• type Downloader
• type ErrorResponse
• type FFM
  • func (f *FFM) DecodeMp3(ctx context.Context, request DecodeMp3Request) (*FileInfo, error)
  • func (f *FFM) DownloadProxy(ctx context.Context, path string) (*httputil.ReverseProxy, *http.Request, error)
  • func (f *FFM) GenCompressDownloadPath(info FileInfo) string
  • func (f *FFM) GenDownloadPath(info FileInfo) string
  • func (f *FFM) GenerateLink(ctx context.Context, path string) (string, error)
  • func (f *FFM) Info(ctx context.Context, path string) (*FileInfo, error)
  • func (f *FFM) LS(ctx context.Context, request LSRequest) ([]FileInfo, error)
  • func (f *FFM) MkDir(ctx context.Context, request MkDirRequest) (*FileInfo, error)
  • func (f *FFM) Remove(ctx context.Context, request RemoveRequest) error
  • func (f *FFM) SetAddr(addr string) FileManager
  • func (f *FFM) Upload(ctx context.Context, request UploadRequest) ([]FileInfo, error)
  • func (f *FFM) ValidateLink(ctx context.Context, tokenString string) (string, error)
• type FileInfo
• type FileManager
  • func New(cfg Config) (FileManager, error)
• type LSRequest
• type MkDirRequest
• type PathRequest
• type RemoveRequest
• type UploadFileRequest
• type UploadRequest

Variables

var (
	ErrServerIsNotUnavailable = apperr.New("ffm_server_is_not_unavailable", apperr.WithTextTranslate(translator.Translate{translator.RU: "Сервер FFM недоступен", translator.EN: "Server FFM is unavailable"}), apperr.WithCode(code.Unavailable))
	ErrGenerateLink           = apperr.New("err_to_generate_link", apperr.WithTextTranslate(translator.Translate{translator.RU: "Ошибка генерации ссылки", translator.EN: "Error to generate link"}), apperr.WithCode(code.InvalidArgument))
	ErrCheckLink              = apperr.New("err_to_check_link", apperr.WithTextTranslate(translator.Translate{translator.RU: "Ошибка проверки ссылки", translator.EN: "Error to check link"}), apperr.WithCode(code.InvalidArgument))

	ErrServiceNotFound           = apperr.New("service_not_found")
	ErrInvalidFilter             = apperr.New("service_invalid_filter")
	ErrObjectIsNotFile           = apperr.New("service_object_is_not_file")
	ErrInvalidFileExt            = apperr.New("service_invalid_file_ext")
	ErrObjectIsNotDir            = apperr.New("service_object_is_not_dir")
	ErrObjectIsNotFound          = apperr.New("service_object_is_not_found")
	ErrCreateDirectory           = apperr.New("service_create_directory")
	ErrObjectRemove              = apperr.New("service_object_remove")
	ErrObjectIsAlreadyExists     = apperr.New("service_object_is_already_exists")
	ErrObjectNoWritePermissions  = apperr.New("service_object_no_write_permissions")
	ErrObjectNoRemovePermissions = apperr.New("service_object_no_remove_permissions")
	ErrDecode                    = apperr.New("service_decode")
	ErrRemoveObject              = apperr.New("service_remove_object")
	ErrNoPermissionsToRemoveFile = apperr.New("service_no_permissions_to_remove_file")
	ErrNoPermissionsToCreateFile = apperr.New("service_no_permissions_to_create_file")
	ErrNoPermissionsToRemoveDir  = apperr.New("service_no_permissions_to_remove_dir")
	ErrNoPermissionsToCreateDir  = apperr.New("service_no_permissions_to_create_dir")
	ErrNoPermissionsToDownload   = apperr.New("service_no_permissions_to_download")
)

Types

type Config

type Config struct {
	Addr    string
	Service string
	Debug   string
}

type DecodeMp3Request

type DecodeMp3Request struct {
	Path            string `json:"path" url:"path"`
	DeleteOriginal  bool   `json:"delete_original" url:"delete_original"`
	ReplaceIfExists bool   `json:"replace_if_exists" url:"replace_if_exists"`
}

type Downloader

type Downloader interface {
	GenerateLink(ctx context.Context, path string) (string, error)
	ValidateLink(ctx context.Context, tokenString string) (string, error)
	DownloadProxy(ctx context.Context, path string) (*httputil.ReverseProxy, *http.Request, error)
}

type ErrorResponse

type ErrorResponse struct {
	ID     string        `json:"id"`
	Text   string        `json:"text"`
	Errors []interface{} `json:"errors"`
}

type FFM

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

func (*FFM) DecodeMp3

func (f *FFM) DecodeMp3(ctx context.Context, request DecodeMp3Request) (*FileInfo, error)

func (*FFM) DownloadProxy

func (f *FFM) DownloadProxy(ctx context.Context, path string) (*httputil.ReverseProxy, *http.Request, error)

func (*FFM) GenCompressDownloadPath

func (f *FFM) GenCompressDownloadPath(info FileInfo) string

func (*FFM) GenDownloadPath

func (f *FFM) GenDownloadPath(info FileInfo) string

func (*FFM) GenerateLink

func (f *FFM) GenerateLink(ctx context.Context, path string) (string, error)

func (*FFM) Info

func (f *FFM) Info(ctx context.Context, path string) (*FileInfo, error)

func (*FFM) LS

func (f *FFM) LS(ctx context.Context, request LSRequest) ([]FileInfo, error)

func (*FFM) MkDir

func (f *FFM) MkDir(ctx context.Context, request MkDirRequest) (*FileInfo, error)

func (*FFM) Remove

func (f *FFM) Remove(ctx context.Context, request RemoveRequest) error

func (*FFM) SetAddr

func (f *FFM) SetAddr(addr string) FileManager

func (*FFM) Upload

func (f *FFM) Upload(ctx context.Context, request UploadRequest) ([]FileInfo, error)

func (*FFM) ValidateLink

func (f *FFM) ValidateLink(ctx context.Context, tokenString string) (string, error)

type FileInfo

type FileInfo struct {
	Path     string    `json:"path"`
	FullPath string    `json:"full_path"`
	Name     string    `json:"name"`
	Size     int64     `json:"size"`
	IsDir    bool      `json:"is_dir"`
	ModTime  time.Time `json:"mod_time"`
}

type FileManager

type FileManager interface {
	Downloader
	SetAddr(addr string) FileManager
	LS(ctx context.Context, request LSRequest) ([]FileInfo, error)
	Info(ctx context.Context, path string) (*FileInfo, error)
	MkDir(ctx context.Context, request MkDirRequest) (*FileInfo, error)
	DecodeMp3(ctx context.Context, request DecodeMp3Request) (*FileInfo, error)
	Upload(ctx context.Context, request UploadRequest) ([]FileInfo, error)
	Remove(ctx context.Context, request RemoveRequest) error
	GenDownloadPath(info FileInfo) string
	GenCompressDownloadPath(info FileInfo) string
}

func New

func New(cfg Config) (FileManager, error)

type LSRequest

type LSRequest struct {
	Path          string  `json:"path" url:"path"`
	Recursive     bool    `json:"recursive" url:"recursive"`
	FileFilter    *string `json:"file_filter" url:"file_filter"`
	DirFilter     *string `json:"dir_filter" url:"dir_filter"`
	SkipDirs      bool    `json:"skip_dirs" url:"skip_dirs"`
	SkipEmptyDirs bool    `json:"skip_empty_dirs" url:"skip_empty_dirs"`
	SkipPath      bool    `json:"skip_path" url:"skip_path"`
}

type MkDirRequest

type MkDirRequest struct {
	Path              string `json:"path" url:"path"`
	Dir               string `json:"dir" url:"dir"`
	Recursive         bool   `json:"recursive" url:"recursive"`
	IgnoreExistsError bool   `json:"ignore_exists_error" url:"ignore_exists_error"`
}

type PathRequest

type PathRequest struct {
	Path string `json:"path" url:"path"`
}

type RemoveRequest

type RemoveRequest struct {
	Path                string `json:"path"`
	IgnoreNotFoundError bool   `json:"ignore_not_found_error"`
	OnlyChildren        bool   `json:"only_children"`
}

type UploadFileRequest

type UploadFileRequest struct {
	Name   string
	Reader io.Reader
}

type UploadRequest

type UploadRequest struct {
	Path   string
	Files  []UploadFileRequest
	Append bool
}