file

Documentation

Overview

Package file contains file service implementation for tgtest server.

Index

• type Config
• type File
• type InMemory
  • func NewInMemory() *InMemory
  • func (i *InMemory) Open(name string) (File, error)
• type Service
  • func NewService(cfg Config) *Service
  • func (m *Service) OnMessage(server *tgtest.Server, req *tgtest.Request) error
  • func (m *Service) Register(dispatcher *tgtest.Dispatcher)
  • func (m *Service) UploadGetFile(ctx context.Context, request *tg.UploadGetFileRequest) (tg.UploadFileClass, error)
  • func (m *Service) UploadGetFileHashes(ctx context.Context, request *tg.UploadGetFileHashesRequest) ([]tg.FileHash, error)
  • func (m *Service) UploadSaveBigFilePart(ctx context.Context, request *tg.UploadSaveBigFilePartRequest) (bool, error)
  • func (m *Service) UploadSaveFilePart(ctx context.Context, request *tg.UploadSaveFilePartRequest) (bool, error)
• type Storage

Types

type Config

type Config struct {
	// Storage to store files.
	// InMemory will be used.
	Storage Storage
	// HashPartSize is a size of part to use in tg.FileHash.
	HashPartSize int
	// HashRangeSize is size of range to return in upload.getFileHashes.
	HashRangeSize int
}

type File

type File interface {
	io.ReaderAt
	io.WriterAt
	io.Closer
	PartSize() int
	SetPartSize(v int)
	Size() int
}

File represents Telegram file.

type InMemory

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

InMemory is an inmemory implementation of file storage.

func NewInMemory

func NewInMemory() *InMemory

NewInMemory creates new InMemory.

func (*InMemory) Open

func (i *InMemory) Open(name string) (File, error)

Open implement Storage.

type Service

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

Service is a Telegram file service.

func NewService

func NewService(cfg Config) *Service

NewService creates new file Service.

func (*Service) OnMessage

func (m *Service) OnMessage(server *tgtest.Server, req *tgtest.Request) error

OnMessage implements tgtest.Handler.

func (*Service) Register

func (m *Service) Register(dispatcher *tgtest.Dispatcher)

Register registers service handlers.

func (*Service) UploadGetFile

func (m *Service) UploadGetFile(ctx context.Context, request *tg.UploadGetFileRequest) (tg.UploadFileClass, error)

func (*Service) UploadGetFileHashes

func (m *Service) UploadGetFileHashes(
	ctx context.Context,
	request *tg.UploadGetFileHashesRequest,
) ([]tg.FileHash, error)

func (*Service) UploadSaveBigFilePart

func (m *Service) UploadSaveBigFilePart(ctx context.Context, request *tg.UploadSaveBigFilePartRequest) (bool, error)

func (*Service) UploadSaveFilePart

func (m *Service) UploadSaveFilePart(ctx context.Context, request *tg.UploadSaveFilePartRequest) (bool, error)

type Storage

type Storage interface {
	Open(name string) (File, error)
}

Storage is an abstraction for Telegram file storage.