getting-updates.go

package telegram

import "context"

// Update struct.
type Update struct {
	UpdateID           int                 `json:"update_id"`
	Message            *Message            `json:"message,omitempty"`
	EditedMessage      *Message            `json:"edited_message,omitempty"`
	ChannelPost        *Message            `json:"channel_post,omitempty"`
	EditedChannelPost  *Message            `json:"edited_channel_post,omitempty"`
	InlineQuery        *InlineQuery        `json:"inline_query,omitempty"`
	ChosenInlineResult *ChosenInlineResult `json:"chosen_inline_result,omitempty"`
	CallbackQuery      *CallbackQuery      `json:"callback_query,omitempty"`
	ShippingQuery      *ShippingQuery      `json:"shipping_query,omitempty"`
	PreCheckoutQuery   *PreCheckoutQuery   `json:"pre_checkout_query,omitempty"`
	Poll               *Poll               `json:"poll,omitempty"`
	PollAnswer         *PollAnswer         `json:"poll_answer"`
	MyChatMember       *ChatMemberUpdated  `json:"my_chat_member,omitempty"`
	ChatMember         *ChatMemberUpdated  `json:"chat_member,omitempty"`
	ChatJoinRequest    *ChatJoinRequest    `json:"chat_join_request,omitempty"`
}

// GetUpdatesResponse interface.
type GetUpdatesResponse interface {
	Response
	GetUpdates() []Update
}

type getUpdatesResponse struct {
	response
	Result []Update `json:"result,omitempty"`
}

func (r *getUpdatesResponse) GetUpdates() []Update {
	return r.Result
}

func (b *bot) GetUpdates(ctx context.Context, options ...MethodOption) (GetUpdatesResponse, error) {
	var res getUpdatesResponse

	err := b.doRequest(ctx, "getUpdates", &res, options...)
	if err != nil {
		return nil, err
	}

	return &res, nil
}

// SetWebhookResponse interface.
type SetWebhookResponse interface {
	Response
}

type setWebhookResponse struct {
	response
}

func (b *bot) SetWebhook(ctx context.Context, options ...MethodOption) (SetWebhookResponse, error) {
	var res setWebhookResponse

	err := b.doRequest(ctx, "setWebhook", &res, options...)
	if err != nil {
		return nil, err
	}

	return &res, nil
}

// DeleteWebhookResponse interface.
type DeleteWebhookResponse interface {
	Response
}

type deleteWebhookResponse struct {
	response
}

func (b *bot) DeleteWebhook(ctx context.Context) (DeleteWebhookResponse, error) {
	var res deleteWebhookResponse

	err := b.doRequest(ctx, "deleteWebhook", &res)
	if err != nil {
		return nil, err
	}

	return &res, nil
}

// GetWebhookInfoResponse interface.
type GetWebhookInfoResponse interface {
	Response
	GetWebhookInfo() *WebhookInfo
}

type getWebhookInfoResponse struct {
	response
	Result *WebhookInfo `json:"result,omitempty"`
}

func (r *getWebhookInfoResponse) GetWebhookInfo() *WebhookInfo {
	return r.Result
}

func (b *bot) GetWebhookInfo(ctx context.Context) (GetWebhookInfoResponse, error) {
	var res getWebhookInfoResponse

	err := b.doRequest(ctx, "getWebhookInfo", &res)
	if err != nil {
		return nil, err
	}

	return &res, nil
}

// WebhookInfo struct.
type WebhookInfo struct {
	URL                      string   `json:"url"`
	HasCustomCertificate     bool     `json:"has_custom_certificate"`
	PendingUpdateCount       int      `json:"pending_update_count"`
	IPAddress                *string  `json:"ip_address,omitempty"`
	LastErrorDate            *int     `json:"last_error_date,omitempty"`
	LastErrorMessage         *string  `json:"last_error_message,omitempty"`
	LastSynchronizationError *int     `json:"last_synchronization_error_date,omitempty"` // Optional. Unix time of the most recent error that happened when trying to synchronize available updates with Telegram datacenters
	MaxConnections           *int     `json:"max_connections,omitempty"`
	AllowedUpdates           []string `json:"allowed_updates,omitempty"`
}