hearings

Documentation

Index

• type Config
• type Parser
  • func NewParser() *Parser
  • func (p *Parser) Content(hearing domain.Hearing) (domain.Hearing, error)
• type Service
  • func New(cfg *Config) *Service
  • func (s Service) FetchLinks(ctx context.Context) ([]string, error)
  • func (s Service) Find(ctx context.Context, link string) (domain.Hearing, error)
  • func (s Service) List(ctx context.Context) ([]domain.Hearing, error)
  • func (s Service) ListUnpublished(ctx context.Context, mark bool) ([]domain.IHearing, error)
  • func (s Service) NewHearings(ctx context.Context) ([]domain.Hearing, error)
  • func (s Service) ProcessLink(ctx context.Context, link string) (domain.Hearing, error)
  • func (s Service) Publish(ctx context.Context, format string) (int, error)

Types

type Config

type Config struct {
	Database  *database.Client
	Logger    *zerolog.Logger
	Scrapper  *scrapper.Scrapper
	Publisher *publisher.Publisher
}

Config for hearings service

type Parser

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

Parser is preparing data about public hearings

func NewParser

func NewParser() *Parser

NewParser return instance of public hearings parser

func (*Parser) Content

func (p *Parser) Content(hearing domain.Hearing) (domain.Hearing, error)

Content return full data of public hearing

type Service

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

Service to manage public hearings

func New

func New(cfg *Config) *Service

New returns an instance of hearing service

func (Service) FetchLinks

func (s Service) FetchLinks(ctx context.Context) ([]string, error)

FetchLinks of public hearings

func (Service) Find

func (s Service) Find(ctx context.Context, link string) (domain.Hearing, error)

Find public hearing by URL

func (Service) List

func (s Service) List(ctx context.Context) ([]domain.Hearing, error)

List of hearings

func (Service) ListUnpublished

func (s Service) ListUnpublished(ctx context.Context, mark bool) ([]domain.IHearing, error)

ListUnpublished returns list of unpublished hearings

func (Service) NewHearings

func (s Service) NewHearings(ctx context.Context) ([]domain.Hearing, error)

NewHearings returns list of new hearings from site

func (Service) ProcessLink

func (s Service) ProcessLink(ctx context.Context, link string) (domain.Hearing, error)

ProcessLink and get information about public hearing

func (Service) Publish

func (s Service) Publish(ctx context.Context, format string) (int, error)

Publish all unpublished hearings. Get it from DB and publish them one by one to telegram channel.