telegram

Documentation

Index

• type Client
  • func NewClient(apiID int, apiHash, sessionFile, botToken, proxyAddr string, log *zap.Logger) *Client
  • func (c *Client) GetChatInfo(ctx context.Context, chatID string) (domain.ChatInfo, error)
  • func (c *Client) IterateMessages(ctx context.Context, chatID string, since time.Time, limit int) ([]domain.Message, error)
  • func (c *Client) SendMessage(ctx context.Context, chatID, text string) (int, error)
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) Stop(ctx context.Context) error
  • func (c *Client) WaitReady() <-chan struct{}
• type ClientInterface

Types

type Client

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

func NewClient

func NewClient(apiID int, apiHash, sessionFile, botToken, proxyAddr string, log *zap.Logger) *Client

func (*Client) GetChatInfo

func (c *Client) GetChatInfo(ctx context.Context, chatID string) (domain.ChatInfo, error)

func (*Client) IterateMessages

func (c *Client) IterateMessages(ctx context.Context, chatID string, since time.Time, limit int) ([]domain.Message, error)

func (*Client) SendMessage

func (c *Client) SendMessage(ctx context.Context, chatID, text string) (int, error)

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) Stop

func (c *Client) Stop(ctx context.Context) error

func (*Client) WaitReady

func (c *Client) WaitReady() <-chan struct{}

type ClientInterface

type ClientInterface interface {
	SendMessage(ctx context.Context, chatID string, text string) (int, error)
	GetChatInfo(ctx context.Context, chatID string) (domain.ChatInfo, error)
	IterateMessages(ctx context.Context, chatID string, since time.Time, limit int) ([]domain.Message, error)
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	WaitReady() <-chan struct{}
}