adapter

Documentation

Index

• func NewPostgresConnPool() (*sql.DB, error)
• type ChannelMessageModel
• type MemoryChannelRepository
  • func NewMemoryChannelRepository() *MemoryChannelRepository
  • func (m *MemoryChannelRepository) GetChannelsByHashtags(ctx context.Context, hashtags []string) ([]domain.Channel, error)
  • func (m *MemoryChannelRepository) Save(ctx context.Context, channel domain.Channel) error
• type PostgresChannelRepository
  • func NewPostgresChannelRepository(conn *sql.DB) *PostgresChannelRepository
  • func (r *PostgresChannelRepository) DeleteAll(ctx context.Context) error
  • func (r *PostgresChannelRepository) GetChannelsByHashtags(ctx context.Context, hashtags []string) ([]domain.Channel, error)
  • func (r *PostgresChannelRepository) Save(ctx context.Context, channel domain.Channel) error
• type PostgresMessageRepository
  • func NewPostgresMessageRepository(conn *sql.DB) *PostgresMessageRepository
  • func (p *PostgresMessageRepository) GetByID(ctx context.Context, messageID string) (domain.Message, error)
  • func (p *PostgresMessageRepository) Save(ctx context.Context, msg domain.Message) error
• type TgMessageSender
  • func NewMessageSender(tgBot *tgbotapi.BotAPI) *TgMessageSender
  • func (t *TgMessageSender) SendMessageToTgChan(tgChanId string, text string, username string, originMessageId string, ...) (domain.ChannelMessage, error)

Functions

func NewPostgresConnPool

func NewPostgresConnPool() (*sql.DB, error)

Types

type ChannelMessageModel

type ChannelMessageModel struct {
	ID        string `json:"id"`
	ChannelID string `json:"channel_id"`
}

type MemoryChannelRepository

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

func NewMemoryChannelRepository

func NewMemoryChannelRepository() *MemoryChannelRepository

func (*MemoryChannelRepository) GetChannelsByHashtags

func (m *MemoryChannelRepository) GetChannelsByHashtags(ctx context.Context, hashtags []string) ([]domain.Channel, error)

func (*MemoryChannelRepository) Save

func (m *MemoryChannelRepository) Save(ctx context.Context, channel domain.Channel) error

type PostgresChannelRepository

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

func NewPostgresChannelRepository

func NewPostgresChannelRepository(conn *sql.DB) *PostgresChannelRepository

func (*PostgresChannelRepository) DeleteAll

func (r *PostgresChannelRepository) DeleteAll(ctx context.Context) error

func (*PostgresChannelRepository) GetChannelsByHashtags

func (r *PostgresChannelRepository) GetChannelsByHashtags(ctx context.Context, hashtags []string) ([]domain.Channel, error)

func (*PostgresChannelRepository) Save

func (r *PostgresChannelRepository) Save(ctx context.Context, channel domain.Channel) error

type PostgresMessageRepository

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

func NewPostgresMessageRepository

func NewPostgresMessageRepository(conn *sql.DB) *PostgresMessageRepository

func (*PostgresMessageRepository) GetByID

func (p *PostgresMessageRepository) GetByID(ctx context.Context, messageID string) (domain.Message, error)

func (*PostgresMessageRepository) Save

func (p *PostgresMessageRepository) Save(ctx context.Context, msg domain.Message) error

type TgMessageSender

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

func NewMessageSender

func NewMessageSender(tgBot *tgbotapi.BotAPI) *TgMessageSender

func (*TgMessageSender) SendMessageToTgChan

func (t *TgMessageSender) SendMessageToTgChan(tgChanId string, text string, username string, originMessageId string, tgFile domain.TgFile) (domain.ChannelMessage, error)