ffm

Documentation

Index

• Variables
• type Config
• type DecodeAudioRequest
• type Downloader
• type ErrorResponse
• type FFM
  • func (f *FFM) CP(ctx context.Context, input FileCopyRequest) (*FileInfo, error)
  • func (f *FFM) DecodeAudio(ctx context.Context, request DecodeAudioRequest) (*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) MV(ctx context.Context, input FileMoveRequest) (*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) Unpack(ctx context.Context, request FileUnpackRequest) (*FileInfo, error)
  • func (f *FFM) Upload(ctx context.Context, request UploadRequest) ([]FileInfo, error)
  • func (f *FFM) ValidateLink(ctx context.Context, tokenString string) (string, error)
• type FileCopyRequest
• type FileInfo
• type FileManager
  • func New(cfg Config) (FileManager, error)
• type FileMoveRequest
• type FileUnpackRequest
• 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", apperr.WithTextTranslate(translator.Translate{translator.RU: "Сервис не найден", translator.EN: "Service not found"}), apperr.WithCode(code.NotFound))
	ErrInvalidFilter             = apperr.New("service_invalid_filter", apperr.WithTextTranslate(translator.Translate{translator.RU: "Неправильный фильтр", translator.EN: "Invalid filter"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectIsNotFile           = apperr.New("service_object_is_not_file", apperr.WithTextTranslate(translator.Translate{translator.RU: "Объект не является файлом", translator.EN: "Object is not file"}), apperr.WithCode(code.InvalidArgument))
	ErrInvalidFileExt            = apperr.New("service_invalid_file_ext", apperr.WithTextTranslate(translator.Translate{translator.RU: "Неверное расширение файла", translator.EN: "Invalid file extension"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectIsNotDir            = apperr.New("service_object_is_not_dir", apperr.WithTextTranslate(translator.Translate{translator.RU: "Объект не является директорией", translator.EN: "Object is not dir"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectIsNotFound          = apperr.New("service_object_is_not_found", apperr.WithTextTranslate(translator.Translate{translator.RU: "Объект не найден", translator.EN: "Object is not found"}), apperr.WithCode(code.InvalidArgument))
	ErrCreateDirectory           = apperr.New("service_create_directory", apperr.WithTextTranslate(translator.Translate{translator.RU: "Невозможно создать директорию", translator.EN: "Can't create directory"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectRemove              = apperr.New("service_object_remove", apperr.WithTextTranslate(translator.Translate{translator.RU: "Невозможно удалить объект", translator.EN: "Can't remove object"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectIsAlreadyExists     = apperr.New("service_object_is_already_exists", apperr.WithTextTranslate(translator.Translate{translator.RU: "Объект уже добавлен", translator.EN: "Object is already exists"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectNoWritePermissions  = apperr.New("service_object_no_write_permissions", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на запись", translator.EN: "No write permissions"}), apperr.WithCode(code.InvalidArgument))
	ErrObjectNoRemovePermissions = apperr.New("service_object_no_remove_permissions", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на удаление", translator.EN: "No remove permissions"}), apperr.WithCode(code.InvalidArgument))
	ErrDecode                    = apperr.New("service_decode", apperr.WithTextTranslate(translator.Translate{translator.RU: "Ошибка декодирования", translator.EN: "Decode error"}), apperr.WithCode(code.InvalidArgument))
	ErrRemoveObject              = apperr.New("service_remove_object", apperr.WithTextTranslate(translator.Translate{translator.RU: "Ошибка удаления объекта", translator.EN: "Remove object error"}), apperr.WithCode(code.InvalidArgument))
	ErrNoPermissionsToRemoveFile = apperr.New("service_no_permissions_to_remove_file", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на удаление файла", translator.EN: "No permissions to remove file"}), apperr.WithCode(code.InvalidArgument))
	ErrNoPermissionsToCreateFile = apperr.New("service_no_permissions_to_create_file", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на создание файла", translator.EN: "No permissions to create file"}), apperr.WithCode(code.InvalidArgument))
	ErrNoPermissionsToRemoveDir  = apperr.New("service_no_permissions_to_remove_dir", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на удаление директории", translator.EN: "No permissions to remove dir"}), apperr.WithCode(code.InvalidArgument))
	ErrNoPermissionsToCreateDir  = apperr.New("service_no_permissions_to_create_dir", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на создание директории", translator.EN: "No permissions to create dir"}), apperr.WithCode(code.InvalidArgument))
	ErrNoPermissionsToDownload   = apperr.New("service_no_permissions_to_download", apperr.WithTextTranslate(translator.Translate{translator.RU: "Нет прав на загрузку", translator.EN: "No permissions to download"}), apperr.WithCode(code.InvalidArgument))
)

Types

type Config

type Config struct {
	Addr    string
	Service string
	Debug   string
}

type DecodeAudioRequest

type DecodeAudioRequest 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) CP

func (f *FFM) CP(ctx context.Context, input FileCopyRequest) (*FileInfo, error)

func (*FFM) DecodeAudio

func (f *FFM) DecodeAudio(ctx context.Context, request DecodeAudioRequest) (*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) MV

func (f *FFM) MV(ctx context.Context, input FileMoveRequest) (*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) Unpack

func (f *FFM) Unpack(ctx context.Context, request FileUnpackRequest) (*FileInfo, error)

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 FileCopyRequest

type FileCopyRequest struct {
	Src             string `json:"src"`
	Dst             string `json:"dst"`
	ReplaceIfExists bool   `json:"replace_if_exists"`
}

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)
	DecodeAudio(ctx context.Context, request DecodeAudioRequest) (*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
	CP(ctx context.Context, input FileCopyRequest) (*FileInfo, error)
	MV(ctx context.Context, input FileMoveRequest) (*FileInfo, error)
	Unpack(ctx context.Context, request FileUnpackRequest) (*FileInfo, error)
}

func New

func New(cfg Config) (FileManager, error)

type FileMoveRequest

type FileMoveRequest struct {
	Src             string `json:"src"`
	Dst             string `json:"dst"`
	ReplaceIfExists bool   `json:"replace_if_exists"`
}

type FileUnpackRequest

type FileUnpackRequest struct {
	Src           string `json:"src"`
	Dst           string `json:"dst"`
	SkipParentDir bool   `json:"skip_parent_dir"`
}

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
}