api

package

Go to main page

Versions in this module

v0

v0.58.2

Jul 14, 2026

v0.58.1

Jul 6, 2026

v0.58.0

Jun 26, 2026

Changes in this version

+ func CleanupExpired()

+ func StartCleanupLoop(ctx interface{ ... })

type TaskProgress

+ DownloadedFiles int

+ TotalFiles int

type TaskProgressInfo

+ StartedAt time.Time

+ func (t *TaskProgressInfo) Emit(e taskevent.Event)

v0.57.1

Jun 25, 2026

v0.57.0

May 24, 2026

Changes in this version

+ type ExecutableWrapper struct

+ func NewExecutableWrapper(inner core.Executable) *ExecutableWrapper

+ func (w *ExecutableWrapper) Execute(ctx context.Context) error

+ func (w *ExecutableWrapper) TaskID() string

+ func (w *ExecutableWrapper) Title() string

+ func (w *ExecutableWrapper) Type() tasktype.TaskType

v0.56.1

May 5, 2026

v0.56.0

Apr 14, 2026

v0.55.3

Mar 30, 2026

v0.55.2

Mar 30, 2026

v0.55.1

Mar 11, 2026

v0.55.0

Mar 5, 2026

Changes in this version

+ func AuthMiddleware() func(http.Handler) http.Handler

+ func DeleteTask(taskID string)

+ func ExtractFilesFromLinks(ctx context.Context, links []string) ([]tfile.TGFileMessage, error)

+ func ExtractTelegraphImages(ctx context.Context, pageURL string) ([]string, string, error)

+ func MethodNotAllowedHandler(w http.ResponseWriter, r *http.Request)

+ func NotFoundHandler(w http.ResponseWriter, r *http.Request)

+ func ParseMessageLink(ctx context.Context, link string) (int64, int, error)

+ func SendWebhook(ctx context.Context, payload *WebhookPayload)

+ func Start(ctx context.Context) error

+ func WrapTaskWithWebhook(ctx context.Context, taskID string, fn func() error) error

+ func WriteError(w http.ResponseWriter, statusCode int, errCode, message string) error

+ func WriteJSON(w http.ResponseWriter, statusCode int, data any) error

+ type APIError struct

+ ErrorCode string

+ Message string

+ StatusCode int

+ func (e *APIError) Error() string

+ type Aria2Params struct

+ Options map[string]string

+ URLs []string

+ type CreateTaskRequest struct

+ Params json.RawMessage

+ Path string

+ Storage string

+ Type tasktype.TaskType

+ Webhook string

+ type CreateTaskResponse struct

+ CreatedAt time.Time

+ Status TaskStatus

+ TaskID string

+ Type tasktype.TaskType

+ type DirectLinksParams struct

+ URLs []string

+ type ErrorResponse struct

+ Error string

+ Message string

+ type Handlers struct

+ func NewHandlers(factory *TaskFactory) *Handlers

+ func (h *Handlers) CancelTaskHandler(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) CreateTaskHandler(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) GetTaskHandler(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) GetTaskTypesHandler(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HealthCheckHandler(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) ListStoragesHandler(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) ListTasksHandler(w http.ResponseWriter, r *http.Request)

+ type MessageContext struct

+ Client *ext.Context

+ Message *tg.Message

+ type ParsedParams struct

+ URL string

+ type ProgressTracker struct

+ func NewProgressTracker(taskID, taskType, storage, path, title, webhook string) *ProgressTracker

+ func (p *ProgressTracker) GetInfo() *TaskProgressInfo

+ func (p *ProgressTracker) OnDone(err error)

+ func (p *ProgressTracker) OnProgress(downloadedBytes int64, downloadedFiles int)

+ func (p *ProgressTracker) OnStart(totalBytes int64, totalFiles int)

+ func (p *ProgressTracker) UpdateProgressBytes(bytes int64)

+ func (p *ProgressTracker) UpdateProgressFiles(files int)

+ type Server struct

+ func NewServer(ctx context.Context) *Server

+ func (s *Server) Start(ctx context.Context) error

+ type StorageInfo struct

+ Name string

+ Type string

+ type StoragesResponse struct

+ Storages []StorageInfo

+ type TGFilesParams struct

+ MessageLinks []string

+ type TPHPicsParams struct

+ TelegraphURL string

+ type TaskFactory struct

+ func NewTaskFactory(ctx context.Context) *TaskFactory

+ func (f *TaskFactory) CreateTask(req *CreateTaskRequest) (*CreateTaskResponse, error)

+ type TaskInfoResponse struct

+ CreatedAt time.Time

+ Error string

+ Path string

+ Progress *TaskProgress

+ Status TaskStatus

+ Storage string

+ TaskID string

+ Title string

+ Type tasktype.TaskType

+ UpdatedAt time.Time

+ type TaskProgress struct

+ DownloadedBytes int64

+ Percent float64

+ SpeedMBPS float64

+ TotalBytes int64

+ type TaskProgressInfo struct

+ CreatedAt time.Time

+ DownloadedBytes int64

+ DownloadedFiles int

+ Error string

+ Path string

+ Status TaskStatus

+ Storage string

+ TaskID string

+ Title string

+ TotalBytes int64

+ TotalFiles int

+ Type string

+ UpdatedAt time.Time

+ Webhook string

+ func GetAllTasks() []*TaskProgressInfo

+ func GetTask(taskID string) (*TaskProgressInfo, bool)

+ func RegisterTask(taskID, taskType, storage, path, title, webhook string) *TaskProgressInfo

+ func (t *TaskProgressInfo) SetError(err string)

+ func (t *TaskProgressInfo) UpdateStatus(status TaskStatus)

+ type TaskStatus string

+ const TaskStatusCancelled

+ const TaskStatusCompleted

+ const TaskStatusFailed

+ const TaskStatusQueued

+ const TaskStatusRunning

+ type TasksListResponse struct

+ Tasks []TaskInfoResponse

+ Total int

+ type TransferParams struct

+ SourcePath string

+ SourceStorage string

+ TargetPath string

+ TargetStorage string

+ type WebhookPayload struct

+ CompletedAt *time.Time

+ Error string

+ Path string

+ Status TaskStatus

+ Storage string

+ TaskID string

+ Type string

+ func CreateWebhookPayload(taskID string, taskType string, status TaskStatus, storage, path string, ...) *WebhookPayload

+ type YTDLPParams struct

+ Flags []string

+ URLs []string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL