twhelp
/
shared
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

rename LoadEnnoblementsConfig.EnnobledAtGTE -> LoadEnnoblementsConfig.EnnobledAtGT

This commit is contained in:
Dawid Wysokiński 2021-01-15 17:34:15 +01:00
parent 14fc5c3a7a
commit 972e2df3f7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tw/dataloader/dataloader.go
View File

@ -362,7 +362,7 @@ func (d *dataLoader) parseEnnoblementLine(line []string) (*models.Ennoblement, e
}
type LoadEnnoblementsConfig struct {
EnnobledAtGTE time.Time
EnnobledAtGT time.Time
}
func (d *dataLoader) LoadEnnoblements(cfg *LoadEnnoblementsConfig) ([]*models.Ennoblement, error) {
@ -372,8 +372,8 @@ func (d *dataLoader) LoadEnnoblements(cfg *LoadEnnoblementsConfig) ([]*models.En
yesterdaysDate := time.Now().Add(-23 * time.Hour)
url := d.baseURL + EndpointConquer
compressed := true
if cfg.EnnobledAtGTE.After(yesterdaysDate) || cfg.EnnobledAtGTE.Equal(yesterdaysDate) {
url = d.baseURL + fmt.Sprintf(EndpointGetConquer, cfg.EnnobledAtGTE.Unix())
if cfg.EnnobledAtGT.After(yesterdaysDate) || cfg.EnnobledAtGT.Equal(yesterdaysDate) {
url = d.baseURL + fmt.Sprintf(EndpointGetConquer, cfg.EnnobledAtGT.Unix())
compressed = false
}
lines, err := d.getCSVData(url, compressed)
@ -390,7 +390,7 @@ func (d *dataLoader) LoadEnnoblements(cfg *LoadEnnoblementsConfig) ([]*models.En
if err != nil {
return nil, errors.Wrapf(err, "cannot parse line, url %s, line %s", url, strings.Join(line, ","))
}
if ennoblement.EnnobledAt.After(cfg.EnnobledAtGTE) {
if ennoblement.EnnobledAt.After(cfg.EnnobledAtGT) {
ennoblements = append(ennoblements, ennoblement)
}
}