Method Run

raid/mapgenerator.go:69–100

(ctx context.Context, wg *sync.WaitGroup, errch chan error)

}

func (g *MapGenerator) Run(ctx context.Context, wg *sync.WaitGroup, errch chan error) {
	defer log.Debug("mapgenerator: exit")

	defer wg.Done()
	wg.Add(1)

	events := g.updates.Subscribe("mapgenerator", func(u Update) bool {
		return u.IsFresh
	})
	defer g.updates.Unsubscribe(events)

	for {
		select {
		case event, ok := <-events:
			if !ok {
				return
			}

			if !event.IsLast {
				continue
			}

			if err := g.GenerateMap(g.updaterState, "", true); err != nil {
				errch <- fmt.Errorf("mapgenerator: regenerate map: %w", err)

				return
			}
		case <-ctx.Done():
			return
		}
	}
}

func (g *MapGenerator) GenerateMap(updaterState *UpdaterState, title string, transparent bool) error {
	stateAlerts := map[int]bool{}