busetabot

type ArrivingBus struct {
	ServiceNo string
	datamall.ArrivingBus
}

type BusEtaBot struct {
	Handlers            Handlers
	Telegram            *tgbotapi.BotAPI
	Datamall            ETAService
	StreetView          StreetViewProvider
	MeasurementProtocol *MeasurementProtocolClient
	NowFunc             func() time.Time
	BusStops            BusStopRepository
	Users               UserRepository
	TelegramService     TelegramService
}

type BusEtas struct {
	BusStopID   string
	UpdatedTime time.Time
	Services    []IncomingBuses
}

type BusStop struct {
	BusStopCode string   `json:"code"`
	RoadName    string   `json:"road_name"`
	Description string   `json:"description"`
	Latitude    float64  `json:"latitude"`
	Longitude   float64  `json:"longitude"`
	Services    []string `json:"services"`
}

type BusStopGetter interface {
	Get(ID string) *BusStop
}

type BusStopRepository interface {
	BusStopGetter
	Nearby(ctx context.Context, lat, lon, radius float64, limit int) (nearby []NearbyBusStop)
	Search(ctx context.Context, query string, limit int) []BusStop
}

type CallbackData struct {
	Type       string   `json:"t"`
	BusStopID  string   `json:"b,omitempty"`
	ServiceNos []string `json:"s,omitempty"`
	Argstr     string   `json:"a,omitempty"`
	Formatter  string   `json:"f,omitempty"`
}

type CallbackQueryHandler func(ctx context.Context, bot *BusEtaBot, cbq *tgbotapi.CallbackQuery, responses chan<- Response)

type CommandHandler func(ctx context.Context, bot *BusEtaBot, message *tgbotapi.Message, responses chan<- Response)

type DatastoreUserRepository struct {
}

type ETA struct {
	BusStop  BusStop
	Now      time.Time
	Services []datamall.Service
	Error    string
}

type ETAFormatter interface {
	Format(etas BusEtas, services []string) string
}

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

type ETARequest struct {
	UserID   int
	Time     time.Time
	Code     string
	Services []string
}

type ETAService interface {
	GetBusArrival(busStopCode string, serviceNo string) (datamall.BusArrival, error)
}

type Favourites struct {
	Favourites []string
}

type Formatter interface {
	Format(eta ETA) (string, error)
}

type FormatterFactory interface {
	GetFormatter(ctx context.Context, userID int) Formatter
}

type Handlers struct {
	CommandHandlers           map[string]CommandHandler
	FallbackCommandHandler    MessageHandler
	TextHandler               MessageHandler
	LocationHandler           MessageHandler
	CallbackQueryHandlers     map[string]CallbackQueryHandler
	InlineQueryHandler        func(ctx context.Context, bot *BusEtaBot, ilq *tgbotapi.InlineQuery) error
	ChosenInlineResultHandler func(ctx context.Context, bot *BusEtaBot, cir *tgbotapi.ChosenInlineResult) error
	MessageErrorHandler       func(ctx context.Context, bot *BusEtaBot, message *tgbotapi.Message, err error)
	CallbackErrorHandler      func(ctx context.Context, bot *BusEtaBot, query *tgbotapi.CallbackQuery, err error)
}

type HitParsingResult struct {
	Valid          bool            `json:"valid"`
	Hit            string          `json:"hit"`
	ParserMessages []ParserMessage `json:"parserMessage"`
}

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

type IncomingBuses struct {
	ServiceNo string
	Etas      [3]string
	Loads     [3]string
	Features  [3]string
	Types     [3]string
}

type MeasurementProtocolClient struct {
	Endpoint   string
	TrackingID string
	Client     *http.Client
}

type MessageHandler func(context.Context, *BusEtaBot, *tgbotapi.Message) error

type NearbyBusStop struct {
	BusStop
	Distance float64
}

type ParserMessage struct {
	Type        string `json:"messageType"`
	Description string `json:"description"`
	Parameter   string `json:"parameter"`
}

type Response struct {
	Request telegram.Request
	Error   error
}

type StreetViewAPI struct {
	Endpoint string
	APIKey   string
}

type StreetViewProvider interface {
	GetPhotoURLByLocation(lat, lon float64, width, height int) (string, error)
}

type SummaryETAFormatter struct{}

type TelegramService interface {
	Do(request telegram.Request) error
}

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

type User struct {
	LastSeenTime time.Time
	Favourites   []string
}

type UserRepository interface {
	UpdateUserLastSeenTime(ctx context.Context, userID int, t time.Time) error
	GetUserFavourites(ctx context.Context, userID int) (favourites []string, err error)
	SetUserFavourites(ctx context.Context, userID int, favourites []string) error
}

type ValidationServerResponse struct {
	Results []HitParsingResult `json:"hitParsingResult"`
}