aczc.go

package zenfo

// All events here, but too much stuff:
// https://www.aczc.org/events-calendar/?view=calendar&month=July-2018
// https://www.aczc.org/api/open/GetItemsByMonth?month=July-2018&collectionId=594a9d2920099e63d87a096e

// Special events listed here:
// https://www.aczc.org/schedule/

import (
	"fmt"
	"time"

	"github.com/PuerkitoBio/goquery"
)

// Aczc crawls aczc.org, satisfies Worker interface
type Aczc struct {
	venueMap map[string]*Venue
	client   *Client
	log      chan string
}

// Name return human-friendly name for worker for logs
func (a *Aczc) Name() string {
	return "Angel City Zen Center (aczc.org)"
}

// Init sets HTTP client and defines internal venue map
func (a *Aczc) Init(client *Client, log chan string) error {
	a.client = client
	a.log = log
	a.venueMap = make(map[string]*Venue)

	a.venueMap["Angel City"] = &Venue{
		Name:    "Angel City Zen Center",
		Addr:    "1407 W 2nd St Los Angeles, CA 90026",
		Phone:   "+1 (323) 426-6269",
		Email:   "angelcityzencenter@gmail.com",
		Lat:     34.060979,
		Lng:     -118.260530,
		Website: "https://aczc.org",
	}
	a.venueMap["Mount Baldy"] = &Venue{
		Name:    "Mount Baldy Zen Center",
		Addr:    "7901 Mount Baldy Road, Mount Baldy, CA 91759",
		Phone:   "+1 (909) 985-6410",
		Email:   "office@mbzc.org",
		Lat:     34.264256,
		Lng:     -117.632916,
		Website: "http://mbzc.org",
	}
	a.log <- "Initialized!"

	return nil
}

// Desc returns description for website crawled
func (a *Aczc) Desc() string {
	return "Angel City Zen Center (aczc.org)"
}

// Events hits aczc events page and returns slice of Event types
// https://www.aczc.org/schedule/
func (a *Aczc) Events() ([]*Event, error) {

	resp, err := a.client.Get("https://www.aczc.org/schedule/")
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	doc, err := goquery.NewDocumentFromReader(resp.Body)
	if err != nil {
		return nil, err
	}

	var (
		domErr error
		events []*Event
	)
	doc.Find("h1").EachWithBreak(func(_ int, h1 *goquery.Selection) bool {

		if h1.Text() != "Upcoming Special Events" {
			return true
		}

		h1.Siblings().EachWithBreak(func(_ int, p *goquery.Selection) bool {
			href, ok := p.Find("a").First().Attr("href")
			if !ok {
				a.log <- fmt.Sprintf("Yikes! Event did not have a tag! event=%s", h1.Text())
			}

			a.log <- fmt.Sprintf("Fetching event: %s", href)
			resp, err := a.client.Get(href)
			if err != nil {
				domErr = err
				return false
			}

			eventDoc, err := goquery.NewDocumentFromReader(resp.Body)
			if err != nil {
				domErr = err
				return false
			}

			title := eventDoc.Find("h1.eventitem-title").Text()

			desc := eventDoc.Find("div.sqs-block-content").Text()
			//a.log <- fmt.Sprintf("title=%s desc=%s", title, desc)

			date := eventDoc.Find("li.eventitem-meta-date time.event-date")

			if date.Length() > 2 {
				domErr = fmt.Errorf("Recived %d date items, no more than 2 expected", date.Length())
				return false
			}

			var (
				start time.Time
				end   time.Time
			)
			date.EachWithBreak(func(i int, t *goquery.Selection) bool {
				day, _ := t.Attr("datetime")
				hour := t.SiblingsFiltered(".eventitem-meta-time").First().Find(".event-time-24hr").Text()

				if len(hour) == 0 {
					hour = "00:00"
				}

				//log.Printf("ok=%t\n", ok)
				//log.Printf("day=%s hour=%s\n", day, hour)

				parsed, err := time.Parse(time.RFC3339, fmt.Sprintf("%sT%s:00-07:00", day, hour))
				if err != nil {
					domErr = err
					return false
				}

				if i == 0 {
					start = parsed
				} else {
					end = parsed
				}
				return true
			})

			// a tag text = name
			// href = website
			// some are broken, have multiple a tags, but same link

			// em = date
			// easier to parse from url, probably
			e := &Event{
				URL:   href,
				Name:  title,
				Desc:  desc,
				Start: start,
				End:   end,
				Venue: a.venueMap["Angel City"], // XXX parse this from dom
			}

			a.log <- fmt.Sprintf("Found event: %s", e.Name)
			events = append(events, e)

			return true
		})
		a.log <- fmt.Sprintf("Found %d total events", len(events))
		if domErr != nil {
			return false
		}

		return true
	})

	return events, domErr
}