Method GetSince

asset/sql_repository.go:117–149

GetSince attempts to return a channel of snapshots for the asset with the given name since the given date.

(name string, date time.Time)

// GetSince attempts to return a channel of snapshots for the asset with the given name since the given date.
func (s *SQLRepository) GetSince(name string, date time.Time) (<-chan *Snapshot, error) {
	rows, err := s.getSinceQuery.Query(name, date)
	if err != nil {
		return nil, fmt.Errorf("unable to get since: %w", err)
	}

	snapshots := make(chan *Snapshot)

	go func() {
		defer helper.CloseDatabaseRows(rows)
		defer close(snapshots)

		for rows.Next() {
			snapshot := &Snapshot{}

			err := rows.Scan(
				&snapshot.Date,
				&snapshot.Open,
				&snapshot.High,
				&snapshot.Low,
				&snapshot.Close,
				&snapshot.Volume,
			)
			if err != nil {
				log.Printf("unable to scan row: %v", err)
			}

			snapshots <- snapshot
		}
	}()

	return snapshots, nil
}

// LastDate returns the date of the last snapshot for the asset with the given name.
func (s *SQLRepository) LastDate(name string) (time.Time, error) {