Method sendPullLogs

agent/pkg/docker/docker.go:456–481

(ctx context.Context, r io.Reader, p events.Publisher[Event])

}

func (d *Client) sendPullLogs(ctx context.Context, r io.Reader, p events.Publisher[Event]) error {
	plf := pullLogFormatter{Known: map[string]*pullInfo{}}

	scanner := bufio.NewScanner(r)
	for scanner.Scan() {
		log := jsonmessage.JSONMessage{}
		if err := json.Unmarshal(scanner.Bytes(), &log); err != nil {
			return fmt.Errorf("error parsing log message: %#v: %w", log, err)
		}

		logMsg := plf.Update(log)
		if logMsg == nil {
			continue
		}

		if err := p.Publish(ctx, NewLogEvent(model.LogLevelInfo, *logMsg)); err != nil {
			return err
		}
	}
	// Always print the complete progress bar, regardless of the backoff time.
	finalLogMsg := plf.RenderProgress()
	if err := p.Publish(ctx, NewLogEvent(model.LogLevelInfo, finalLogMsg)); err != nil {
		return err
	}
	return scanner.Err()
}