// package arena_net -- сетевая арена package arena_net import ( "fmt" "strings" "sync" . "wartank/app/lev0/types" "wartank/kernel" . "wartank/kernel/kernel_types" ) // АренаСеть -- базовый тип для сетевых арен type АренаСеть struct { ИБотСеть клиент ИХттпВоркер арена ИАрена стрУрл string блок sync.Mutex лог ИЯдроЛог } // НовАренаСеть -- возвращает новый *АренаСеть func НовАренаСеть_(конт ИБотКонтекст, арена ИАрена, стрУрл string) *АренаСеть { лог := kernel.НовЛог("АренаСеть") лог.Инфо("НовАренаСеть(): strUrl=%q\n", стрУрл) лог.Паника(арена == nil, "НовАренаСеть(): ИСценаСтр == nil") лог.Паника(стрУрл == "", "НовАренаСеть(): стрУрл пустой\n") сам := &АренаСеть{ ИБотСеть: арена.Бот().Сеть(), арена: арена, стрУрл: стрУрл, клиент: арена.Бот().Сеть().ВебВоркер(), лог: лог, } _ = ИАренаСеть(сам) return сам } // Обновить -- обновляет список строк func (сам *АренаСеть) Обновить() { сам.блок.Lock() defer сам.блок.Unlock() // FIXME: попытка разобраться, что за фигня творится // time.Sleep(time.Millisecond * 500) сам.лог.Отладка("Обновить(): бот=%s\tсцена=%v\n", сам.арена.Бот().Имя(), сам.арена.Имя()) lstString := сам.клиент.Получ(сам.стрУрл) if ош := сам.арена.СтрОбновить(lstString); ош != nil { сам.лог.Ошибка("Обновить(): при обновлении строк сцены, ош=\n\t%v\n", ош) } } // Get -- выполняет GET-запрос по указанному URL func (сам *АренаСеть) Get(strLink string) (lstString []string, err error) { сам.блок.Lock() defer сам.блок.Unlock() // log._rintf("INFO АренаСеть.Get(): link=%v\n", сам.strUrl) if !strings.Contains(strLink, сам.стрУрл) { return nil, fmt.Errorf("АренаСеть.Get(): strLink(%v) не содержит strUrl(%v)", strLink, сам.стрУрл) } lstString = сам.клиент.Получ(strLink) return lstString, nil }