Method sendSimpleChanges

rest/changes_api.go:370–466

(channels base.Set, options db.ChangesOptions, docids []string)

}

func (h *handler) sendSimpleChanges(channels base.Set, options db.ChangesOptions, docids []string) (error, bool) {
	lastSeq := options.Since
	var first bool = true
	var feed <-chan *db.ChangeEntry
	var err error
	if len(docids) > 0 {
		feed, err = h.collection.DocIDChangesFeed(h.ctx(), channels, docids, options)
	} else {
		feed, err = h.collection.MultiChangesFeed(h.ctx(), channels, options)
	}
	if err != nil {
		return err, false
	}

	h.setHeader("Content-Type", "application/json")
	h.setHeader("Cache-Control", "private, max-age=0, no-cache, no-store")
	_, _ = h.response.Write([]byte("{\"results\":[\r\n"))

	logStatus := h.logStatusWithDuration

	if options.Wait {
		logStatus = h.logStatus
		h.flush()
	}

	message := "OK"
	forceClose := false
	if feed != nil {
		var heartbeat, timeout <-chan time.Time
		if options.Wait {
			// Set up heartbeat/timeout
			if options.HeartbeatMs > 0 {
				ticker := time.NewTicker(time.Duration(options.HeartbeatMs) * time.Millisecond)
				defer ticker.Stop()
				heartbeat = ticker.C
			} else if options.TimeoutMs > 0 {
				timer := time.NewTimer(time.Duration(options.TimeoutMs) * time.Millisecond)
				defer timer.Stop()
				timeout = timer.C
			}
		}

		encoder := base.JSONEncoderCanonical(h.response)
	loop:
		for {
			select {
			case entry, ok := <-feed:
				if !ok {
					break loop // end of feed
				}
				if nil != entry {
					if entry.Err != nil {
						break loop // error returned by feed - end changes
					}
					if first {
						first = false
					} else {
						_, _ = h.response.Write([]byte(","))