media

Documentation

Index

• type Manager
  • func NewManager(rootDir string) *Manager
  • func (m *Manager) Register(channel string, resolver Resolver)
  • func (m *Manager) StageInbound(ctx context.Context, channel string, attachment *bus.MediaAttachment) (*bus.MediaAttachment, error)
• type ResolvedMedia
• type Resolver
• type TelegramResolver
  • func NewTelegramResolver(rootDir, token, proxy string) *TelegramResolver
  • func (r *TelegramResolver) Stage(ctx context.Context, attachment *bus.MediaAttachment) (*ResolvedMedia, error)
• type URLResolver
  • func NewQQResolver(rootDir string, client *http.Client) *URLResolver
  • func (r *URLResolver) Stage(ctx context.Context, attachment *bus.MediaAttachment) (*ResolvedMedia, error)

Types

type Manager

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

func NewManager

func NewManager(rootDir string) *Manager

func (*Manager) Register

func (m *Manager) Register(channel string, resolver Resolver)

func (*Manager) StageInbound

func (m *Manager) StageInbound(ctx context.Context, channel string, attachment *bus.MediaAttachment) (*bus.MediaAttachment, error)

type ResolvedMedia

type ResolvedMedia struct {
	LocalPath string
	Filename  string
	MimeType  string
}

type Resolver

type Resolver interface {
	Stage(ctx context.Context, attachment *bus.MediaAttachment) (*ResolvedMedia, error)
}

type TelegramResolver

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

func NewTelegramResolver

func NewTelegramResolver(rootDir, token, proxy string) *TelegramResolver

func (*TelegramResolver) Stage

func (r *TelegramResolver) Stage(ctx context.Context, attachment *bus.MediaAttachment) (*ResolvedMedia, error)

type URLResolver

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

func NewQQResolver

func NewQQResolver(rootDir string, client *http.Client) *URLResolver

func (*URLResolver) Stage

func (r *URLResolver) Stage(ctx context.Context, attachment *bus.MediaAttachment) (*ResolvedMedia, error)