// package arena_death -- арена схватки (все против всех) package arena_death import ( "time" . "wartank/app/lev0/types" "wartank/app/lev2/arena" "wartank/app/lev2/arena_duel/battle_register" "wartank/app/lev2/arena_duel/battle_wait" "wartank/app/lev2/arena_duel/battle_worker" . "wartank/kernel/kernel_types" ) // АренаСхватка -- объект схватки type АренаСхватка struct { ИАрена бот ИБот клиент ИХттпВоркер регистрация *battle_register.СхваткаРегистрация // Регистратор на сражение ожидание *battle_wait.СхваткаОжидание // Ожидатель начала схватки действие *battle_worker.СхваткаИсполнитель // Исполнитель схватки } // НовСражение -- возвращает новый *Battle func НовСхватка(конт ИЯдроКонтекст, бот ИБот) *АренаСхватка { сам := &АренаСхватка{ бот: бот, клиент: бот.Сеть().ВебВоркер(), } аренаКонфиг := arena.АренаКонфиг{ Бот_: бот, АренаИмя_: "Арена схватки", СтрКонтроль_: `до начала `, ФнПуск_: сам.пуск, СтрУрл_: "https://wartank.ru/dm", } сам.ИАрена = arena.НовАрена(конт, аренаКонфиг) сам.регистрация = battle_register.НовСражениеРегистрация(конт, бот) сам.ожидание = battle_wait.НовСражениеОжидание(конт, бот) сам.действие = battle_worker.НовСражениеИсполнитель(конт, бот) // сам.shotTimeFull.Set(8000) // 8000 msec return сам } func (сам *АренаСхватка) Пуск() error { go сам.пуск() return nil } // запускает в работу сражение func (сам *АренаСхватка) пуск() { for { select { case <-сам.бот.Контекст().Done(): return default: сам.регистрация.Зарегистрироваться() сам.ожидание.Ожидать() сам.действие.Пуск() time.Sleep(time.Second * 2) // Пауза между циклами, чтобы сервер не долбить запросами } } } // ЕслиНачало -- возвращает признак начала схватки (для браузера) func (сам *АренаСхватка) ЕслиНачало() ИСтатПарам { return сам.действие.Тревога() }