wartank/pkg/arena/arena.go

// package arena -- типовая арена работы части игры (банк, арсенал и т.п.)
package arena

import (
	"fmt"
	"log"
	"sync"
	"wartank/pkg/alias"
	"wartank/pkg/arena/arena_context"
	"wartank/pkg/arena/arena_string"
	"wartank/pkg/arena/down_time"
	. "wartank/pkg/helpers"
	. "wartank/pkg/kernel/kernel_types"
	. "wartank/server/lev0/types"
)

// АренаКонфиг -- конфигурация арены
type АренаКонфиг struct {
	Бот_         ИБот
	АренаИмя_    alias.АренаИмя
	СтрКонтроль_ string // Контрольная строка для арены
	СтрУрл_      string // Адрес арены
	ФнПуск_      func()
}

// Контролирует правильность параметров
func (конф *АренаКонфиг) контроль() {
	ПроверТверд(конф.СтрКонтроль_ == "", "АренаКонфиг.СтрКонтроль_ == \"\"")
	ПроверТверд(конф.ФнПуск_ == nil, "АренаКонфиг.ФнПуск_ == nil")
	ПроверТверд(конф.Бот_ == nil, "АренаКонфиг.Бот_ == nil")
	ПроверТверд(конф.АренаИмя_ == "", "АренаКонфиг.СценаИмя_ == \"\"")
	ПроверТверд(конф.СтрУрл_ == "", "АренаКонфиг.СтрУрл_ == \"\"")
}

// Арена -- арена игры
type Арена struct {
	ИАренаКонтекст
	времяОстат ИВремяОстат               // Обратный отсчёт до окончания работы режима
	списСтр    *arena_string.АренаСтроки // Список строк из сети для анализа секции
	конф       АренаКонфиг
	блок       sync.RWMutex
}

// НовАрена -- возвращает новую арену игры
func НовАрена(конт ИЯдроКонтекст, конф АренаКонфиг) *Арена {
	log.Printf("НовАрена(): стрКонтроль=%q\n", конф.СтрКонтроль_)
	конф.контроль()
	аренаКонтекст := arena_context.НовАренаКонтекст(конт, конф.Бот_, конф.АренаИмя_)
	сам := &Арена{
		ИАренаКонтекст: аренаКонтекст,
		времяОстат:     down_time.НовВремОбрат(аренаКонтекст, 5),
		списСтр:        arena_string.НовАренаСтроки(конт, конф.СтрКонтроль_),
		конф:           конф,
	}
	_ = ИАрена(сам)
	return сам
}

// Пуск -- запускает арену
func (сам *Арена) Пуск() {
	сам.Обновить()
	сам.конф.ФнПуск_()
}

// Обновить -- обновляет арену
func (сам *Арена) Обновить() {
	списСтр := сам.СписПолучить()
	if len(списСтр) == 0 {
		списСтр = сам.Бот().Сеть().ВебВоркер().Получ(сам.конф.СтрУрл_)
	}
	ош := сам.СтрОбновить(списСтр)
	if ош != nil {
		log.Printf("Арена.Обновить(): ош=\n\t%v\n", ош)
		сам.Отмена()
	}
}

// СтрОбновить -- обновляет список строк секции по требованию
func (сам *Арена) СтрОбновить(lstString []string) error {
	if err := сам.списСтр.Set(lstString); err != nil {
		return fmt.Errorf("Арена.СтрОбновить(): при установке lstString, err=\n\t%w", err)
	}
	return nil
}

// СписПолучить -- возвращает список строк секции
func (сам *Арена) СписПолучить() []string {
	return сам.списСтр.Получ()
}

// ОбратВремяУст -- устанавливает новое значение обратного счётчика времени
func (сам *Арена) ОбратВремяУст(времяСек alias.Время) error {
	ош := сам.времяОстат.Уст(времяСек)
	if ош != nil {
		return fmt.Errorf("Арена.ОбратВремяУст(): ош=\n\t%w", ош)
	}
	return nil
}

// ВремяОстат -- объект оставшегося времени
func (сам *Арена) ВремяОстат() ИВремяОстат {
	сам.блок.RLock()
	defer сам.блок.RUnlock()
	return сам.времяОстат
}