Compare commits
10 Commits
14c251f3e4
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
|
6c3de4b2ef
|
|||
|
a99349e75d
|
|||
|
4f6f54b631
|
|||
|
895146b472
|
|||
|
522012d7d5
|
|||
|
a3c33d7ec1
|
|||
|
d7f28413b2
|
|||
|
d4260f85ec
|
|||
|
6ea3683350
|
|||
|
bc03abeb9d
|
44
Makefile
44
Makefile
@@ -1,15 +1,7 @@
|
|||||||
.DEFAULT_GOAL=help
|
.DEFAULT_GOAL=help
|
||||||
|
|
||||||
BINARY_NAME := iptvc
|
BINARY_NAME := iptvc
|
||||||
ARCH ?= amd64
|
GOARCH ?= amd64
|
||||||
|
|
||||||
LINUX_PATH := "bin/linux_$(ARCH)"
|
|
||||||
WINDOWS_PATH := "bin/windows_$(ARCH)"
|
|
||||||
DARWIN_PATH := "bin/darwin_$(ARCH)"
|
|
||||||
|
|
||||||
LINUX_FILE := "$(LINUX_PATH)/$(BINARY_NAME)"
|
|
||||||
WINDOWS_FILE := "$(WINDOWS_PATH)/$(BINARY_NAME).exe"
|
|
||||||
DARWIN_FILE := "$(DARWIN_PATH)/$(BINARY_NAME)"
|
|
||||||
|
|
||||||
## clean: Remove all compiled binaries
|
## clean: Remove all compiled binaries
|
||||||
clean:
|
clean:
|
||||||
@@ -18,29 +10,35 @@ clean:
|
|||||||
|
|
||||||
## linux: Build new binaries for linux
|
## linux: Build new binaries for linux
|
||||||
linux:
|
linux:
|
||||||
@rm -rf $(LINUX_PATH)
|
@rm -rf bin/linux_$(GOARCH)
|
||||||
@GOARCH=$(ARCH) GOOS=linux go build -o $(LINUX_FILE) . && echo "Compiled: $(LINUX_FILE)"
|
@GOARCH=$(GOARCH) GOOS=linux go build -o bin/linux_$(GOARCH)/$(BINARY_NAME) .
|
||||||
|
@zip -j bin/linux_$(GOARCH).zip bin/linux_$(GOARCH)/$(BINARY_NAME)
|
||||||
|
@echo "Compiled: bin/linux_$(GOARCH)/$(BINARY_NAME) ($(GOARCH))"
|
||||||
|
|
||||||
## win: Build new binaries for windows
|
## win: Build new binaries for windows
|
||||||
win:
|
win:
|
||||||
@rm -rf $(WINDOWS_PATH)
|
@rm -rf bin/windows_$(GOARCH)
|
||||||
@GOARCH=$(ARCH) GOOS=windows go build -o $(WINDOWS_FILE) . && echo "Compiled: $(WINDOWS_FILE)"
|
@GOARCH=$(GOARCH) GOOS=windows go build -o bin/windows_$(GOARCH)/$(BINARY_NAME).exe .
|
||||||
|
@zip -j bin/windows_$(GOARCH).zip bin/windows_$(GOARCH)/$(BINARY_NAME).exe
|
||||||
|
@echo "Compiled: bin/windows_$(GOARCH)/$(BINARY_NAME).exe ($(GOARCH))"
|
||||||
|
|
||||||
## darwin: Build new binaries for darwin
|
## darwin: Build new binaries for darwin
|
||||||
darwin:
|
darwin:
|
||||||
@rm -rf $(DARWIN_PATH)
|
@rm -rf bin/darwin_$(GOARCH)
|
||||||
@GOARCH=$(ARCH) GOOS=darwin go build -o $(DARWIN_FILE) . && echo "Compiled: $(DARWIN_FILE)"
|
@GOARCH=$(GOARCH) GOOS=darwin go build -o bin/darwin_$(GOARCH)/$(BINARY_NAME) .
|
||||||
|
@zip -j bin/darwin_$(GOARCH).zip bin/darwin_$(GOARCH)/$(BINARY_NAME)
|
||||||
## all: Build new binaries for linux, windows and darwin
|
@echo "Compiled: bin/darwin_$(GOARCH)/$(BINARY_NAME) ($(GOARCH))"
|
||||||
all: clean linux win darwin
|
|
||||||
|
|
||||||
## release: Build all binaries and zip them
|
## release: Build all binaries and zip them
|
||||||
release: linux win darwin
|
release: clean
|
||||||
@zip -j $(LINUX_PATH).zip $(LINUX_FILE)
|
@make linux GOARCH=amd64
|
||||||
@zip -j $(DARWIN_PATH).zip $(DARWIN_FILE)
|
@make linux GOARCH=arm64
|
||||||
@zip -j $(WINDOWS_PATH).zip $(WINDOWS_FILE)
|
@make win GOARCH=amd64
|
||||||
|
@make win GOARCH=arm64
|
||||||
|
@make darwin GOARCH=amd64
|
||||||
|
@make darwin GOARCH=arm64
|
||||||
|
|
||||||
## help: Show this message and exit
|
## help: Show this message and exit
|
||||||
help: Makefile
|
help: Makefile
|
||||||
@echo "Available recipes:"
|
@echo "Available recipes:"
|
||||||
@sed -n 's/^##//p' $< | column -t -s ':' | sed -e 's/^/ /'
|
@sed -n 's/^##//p' $< | column -t -s ':' | sed -e 's/^/ /'
|
||||||
|
|||||||
39
README.md
39
README.md
@@ -5,22 +5,21 @@
|
|||||||
Консольная программа для проверки IPTV-плейлистов в формате m3u или m3u8.
|
Консольная программа для проверки IPTV-плейлистов в формате m3u или m3u8.
|
||||||
|
|
||||||
> **Веб-сайт:** [m3u.su](https://m3u.su)
|
> **Веб-сайт:** [m3u.su](https://m3u.su)
|
||||||
> Исходный код: [git.axenov.dev/IPTV/iptvc](https://git.axenov.dev/IPTV/iptvc)
|
> **Документация:** [m3u.su/docs](https://m3u.su/docs)
|
||||||
|
> Исходный код: [git.axenov.dev/IPTV](https://git.axenov.dev/IPTV)
|
||||||
> Telegram-канал: [@iptv_aggregator](https://t.me/iptv_aggregator)
|
> Telegram-канал: [@iptv_aggregator](https://t.me/iptv_aggregator)
|
||||||
> Обсуждение: [@iptv_aggregator_chat](https://t.me/iptv_aggregator_chat)
|
> Обсуждение: [@iptv_aggregator_chat](https://t.me/iptv_aggregator_chat)
|
||||||
> Дополнительные сведения:
|
> Бот: [@iptv_aggregator_bot](https://t.me/iptv_aggregator_bot)
|
||||||
> * [./docs](./docs)
|
|
||||||
> * [git.axenov.dev/IPTV/.profile](https://git.axenov.dev/IPTV/.profile)
|
|
||||||
|
|
||||||
## Установка
|
## Установка
|
||||||
|
|
||||||
Достаточно скачать и распаковать архив с подходящим исполняемым файлом [со страницы последнего релиза](https://git.axenov.dev/IPTV/iptvc/releases/latest):
|
Достаточно скачать и распаковать архив с подходящим исполняемым файлом [со страницы последнего релиза](https://git.axenov.dev/IPTV/iptvc/releases/latest):
|
||||||
|
|
||||||
| ОС | Архив | Платформа |
|
| ОС | Скачать для `amd64` | Скачать для `arm64` |
|
||||||
|---------|----------------------|-----------|
|
| ------- | ------------------------------------------------------------------------------------------------- | ------------------------------------------------------------------------------------------------- |
|
||||||
| Linux | `linux_amd64.zip` | x64 |
|
| Linux | [linux_amd64.zip](https://git.axenov.dev/IPTV/iptvc/releases/download/latest/linux_amd64.zip) | [linux_arm64.zip](https://git.axenov.dev/IPTV/iptvc/releases/download/latest/linux_arm64.zip) |
|
||||||
| MacOS | `darwin_amd64.zip` | x64 |
|
| MacOS | [darwin_amd64.zip](https://git.axenov.dev/IPTV/iptvc/releases/download/latest/darwin_amd64.zip) | [darwin_arm64.zip](https://git.axenov.dev/IPTV/iptvc/releases/download/latest/darwin_arm64.zip) |
|
||||||
| Windows | `windows_amd64.zip` | x64 |
|
| Windows | [windows_amd64.zip](https://git.axenov.dev/IPTV/iptvc/releases/download/latest/windows_amd64.zip) | [windows_arm64.zip](https://git.axenov.dev/IPTV/iptvc/releases/download/latest/windows_arm64.zip) |
|
||||||
|
|
||||||
## Компиляция
|
## Компиляция
|
||||||
|
|
||||||
@@ -29,7 +28,7 @@
|
|||||||
|
|
||||||
1. Склонировать репозиторий
|
1. Склонировать репозиторий
|
||||||
2. Находясь в корне репозитория, следует выполнить `make` или `make help` для получения справки.
|
2. Находясь в корне репозитория, следует выполнить `make` или `make help` для получения справки.
|
||||||
3. Другой способ -- выполнить `go run .` для быстрого запуска.
|
3. Другой способ — выполнить `go run .` для быстрого запуска.
|
||||||
|
|
||||||
## Быстрый старт
|
## Быстрый старт
|
||||||
|
|
||||||
@@ -69,11 +68,11 @@
|
|||||||
|
|
||||||
### Другие возможности команды `check`
|
### Другие возможности команды `check`
|
||||||
|
|
||||||
* `--random|-r X` -- проверить X случайных плейлистов из ini-файла
|
* `--random|-r X` — проверить X случайных плейлистов из ini-файла
|
||||||
* `--json|-j` -- вывести результаты проверки в формате JSON
|
* `--json|-j` — вывести результаты проверки в формате JSON
|
||||||
* `--quiet|-q` -- полностью подавить вывод лога (включая отладочную информацию)
|
* `--quiet|-q` — полностью подавить вывод лога (включая отладочную информацию)
|
||||||
* `--verbose|-v` -- добавить в лог более подробную отладочную информацию (значительно увеличит количество строк!)
|
* `--verbose|-v` — добавить в лог более подробную отладочную информацию (значительно увеличит количество строк!)
|
||||||
* `--tags|-t` -- файл с перечислением тегов (подробности см. [здесь](https://git.axenov.dev/IPTV/playlists#файл-channelsjson))
|
* `--tags|-t` — файл с перечислением тегов (подробности см. [здесь](https://git.axenov.dev/IPTV/playlists#файл-channelsjson))
|
||||||
|
|
||||||
Например, можно получить только json с результатами, передать его в `jq` и, отфильтровав результат, вывести названия оффлайн каналов:
|
Например, можно получить только json с результатами, передать его в `jq` и, отфильтровав результат, вывести названия оффлайн каналов:
|
||||||
|
|
||||||
@@ -126,8 +125,8 @@ pls='https://example.com/list2.m3u'
|
|||||||
### Параметры проверки
|
### Параметры проверки
|
||||||
|
|
||||||
Выше в п.7 видно некоторые служебные данные:
|
Выше в п.7 видно некоторые служебные данные:
|
||||||
* `timeout` -- таймаут каждого запроса в секундах (макс. время ожидания ответа канала);
|
* `timeout` — таймаут каждого запроса в секундах (макс. время ожидания ответа канала);
|
||||||
* `routines` -- количество одновременных проверок.
|
* `routines` — количество одновременных проверок.
|
||||||
|
|
||||||
Эти параметры рассчитываются динамически для каждого плейлиста в отдельности, исходя из количества каналов в каждом (`count`).
|
Эти параметры рассчитываются динамически для каждого плейлиста в отдельности, исходя из количества каналов в каждом (`count`).
|
||||||
См. [app/checker/checker.go](app/checker/checker.go) для подробностей.
|
См. [app/checker/checker.go](app/checker/checker.go) для подробностей.
|
||||||
@@ -151,9 +150,9 @@ pls='https://example.com/list2.m3u'
|
|||||||
|
|
||||||
### Коды возврата
|
### Коды возврата
|
||||||
|
|
||||||
* 0 -- успех
|
* 0 — успех
|
||||||
* 1 -- общая ошибка, см. вывод
|
* 1 — общая ошибка, см. вывод
|
||||||
* 2 -- команде `check` не переданы параметры `--file`, `--url` и `--code`
|
* 2 — команде `check` не переданы параметры `--file`, `--url` и `--code`
|
||||||
|
|
||||||
## Лицензия
|
## Лицензия
|
||||||
|
|
||||||
|
|||||||
16
app/app.go
16
app/app.go
@@ -14,16 +14,18 @@ import (
|
|||||||
"github.com/redis/go-redis/v9"
|
"github.com/redis/go-redis/v9"
|
||||||
)
|
)
|
||||||
|
|
||||||
const VERSION = "1.0.6"
|
const VERSION = "1.1.3"
|
||||||
|
|
||||||
// Arguments описывает аргументы командной строки
|
// Arguments описывает аргументы командной строки
|
||||||
type Arguments struct {
|
type Arguments struct {
|
||||||
IniPath string
|
IniPath string
|
||||||
TagsPath string
|
TagsPath string
|
||||||
RandomCount uint
|
RandomCount uint
|
||||||
NeedJson bool
|
RepeatCount uint
|
||||||
NeedQuiet bool
|
RepeatEverySec uint
|
||||||
Verbose bool
|
NeedJson bool
|
||||||
|
NeedQuiet bool
|
||||||
|
Verbose bool
|
||||||
}
|
}
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|||||||
@@ -196,6 +196,9 @@ func CheckChannels(pls playlist.Playlist) playlist.Playlist {
|
|||||||
return pls
|
return pls
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pls.OnlineCount = 0
|
||||||
|
pls.OfflineCount = 0
|
||||||
|
|
||||||
timeout, routines := calcParameters(count)
|
timeout, routines := calcParameters(count)
|
||||||
httpClient := http.Client{Timeout: timeout}
|
httpClient := http.Client{Timeout: timeout}
|
||||||
chSemaphores := make(chan struct{}, routines)
|
chSemaphores := make(chan struct{}, routines)
|
||||||
|
|||||||
@@ -8,6 +8,8 @@ IPTVC_VERSION="${GIT_TAG}-${GIT_HASH}"
|
|||||||
git checkout "${GIT_TAG}" 2>/dev/null
|
git checkout "${GIT_TAG}" 2>/dev/null
|
||||||
docker build \
|
docker build \
|
||||||
--build-arg IPTVC_VERSION="${IPTVC_VERSION}" \
|
--build-arg IPTVC_VERSION="${IPTVC_VERSION}" \
|
||||||
|
--build-arg GOOS="${GOOS:-linux}" \
|
||||||
|
--build-arg GOARCH="${GOARCH:-amd64}" \
|
||||||
--tag iptvc:"${DOCKER_TAG}" \
|
--tag iptvc:"${DOCKER_TAG}" \
|
||||||
--tag git.axenov.dev/iptv/iptvc:"${DOCKER_TAG}" \
|
--tag git.axenov.dev/iptv/iptvc:"${DOCKER_TAG}" \
|
||||||
.
|
.
|
||||||
|
|||||||
66
cmd/check.go
66
cmd/check.go
@@ -9,6 +9,7 @@ package cmd
|
|||||||
import (
|
import (
|
||||||
"axenov/iptv-checker/app"
|
"axenov/iptv-checker/app"
|
||||||
"axenov/iptv-checker/app/checker"
|
"axenov/iptv-checker/app/checker"
|
||||||
|
"axenov/iptv-checker/app/playlist"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
@@ -27,22 +28,59 @@ var checkCmd = &cobra.Command{
|
|||||||
files, _ := cmd.Flags().GetStringSlice("file")
|
files, _ := cmd.Flags().GetStringSlice("file")
|
||||||
urls, _ := cmd.Flags().GetStringSlice("url")
|
urls, _ := cmd.Flags().GetStringSlice("url")
|
||||||
codes, _ := cmd.Flags().GetStringSlice("code")
|
codes, _ := cmd.Flags().GetStringSlice("code")
|
||||||
lists := checker.PrepareListsToCheck(files, urls, codes)
|
|
||||||
|
|
||||||
startTime := time.Now()
|
waitSeconds := app.Args.RepeatEverySec
|
||||||
onlineCount, offlineCount := checker.CheckPlaylists(lists)
|
if waitSeconds <= 0 {
|
||||||
|
waitSeconds = 5
|
||||||
|
}
|
||||||
|
|
||||||
log.Printf(
|
currentIteration := 1
|
||||||
"Done! count=%d online=%d offline=%d elapsedTime=%.2fs\n",
|
for {
|
||||||
len(lists),
|
if app.Args.RepeatCount != 1 {
|
||||||
onlineCount,
|
log.Printf(
|
||||||
offlineCount,
|
"@ New iteration current=%d count=%d\n",
|
||||||
time.Since(startTime).Seconds(),
|
currentIteration,
|
||||||
)
|
app.Args.RepeatCount,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
if app.Args.NeedJson {
|
var lists []playlist.Playlist
|
||||||
marshal, _ := json.Marshal(lists)
|
if len(files) == 0 && len(urls) == 0 && len(codes) == 0 {
|
||||||
fmt.Println(string(marshal))
|
lists = checker.PrepareListsToCheck(files, urls, codes)
|
||||||
|
} else {
|
||||||
|
if currentIteration == 1 {
|
||||||
|
lists = checker.PrepareListsToCheck(files, urls, codes)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(lists) > 0 {
|
||||||
|
startTime := time.Now()
|
||||||
|
onlineCount, offlineCount := checker.CheckPlaylists(lists)
|
||||||
|
|
||||||
|
log.Printf(
|
||||||
|
"Done! count=%d online=%d offline=%d elapsedTime=%.2fs\n",
|
||||||
|
len(lists),
|
||||||
|
onlineCount,
|
||||||
|
offlineCount,
|
||||||
|
time.Since(startTime).Seconds(),
|
||||||
|
)
|
||||||
|
|
||||||
|
if app.Args.NeedJson {
|
||||||
|
marshal, _ := json.Marshal(lists)
|
||||||
|
fmt.Println(string(marshal))
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log.Println("There are no playlists to check")
|
||||||
|
}
|
||||||
|
|
||||||
|
if app.Args.RepeatCount != 0 {
|
||||||
|
if uint(currentIteration) == app.Args.RepeatCount {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
currentIteration++
|
||||||
|
}
|
||||||
|
log.Printf("Waiting for new iteration... seconds=%d\n", app.Args.RepeatEverySec)
|
||||||
|
time.Sleep(time.Duration(app.Args.RepeatEverySec) * time.Second)
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
@@ -51,6 +89,8 @@ func init() {
|
|||||||
checkCmd.Flags().StringVarP(&app.Args.TagsPath, "tags", "t", "./channels.json", "path to a local tagfile")
|
checkCmd.Flags().StringVarP(&app.Args.TagsPath, "tags", "t", "./channels.json", "path to a local tagfile")
|
||||||
checkCmd.Flags().StringVarP(&app.Args.IniPath, "ini", "i", "./playlists.ini", "path to a local ini-file")
|
checkCmd.Flags().StringVarP(&app.Args.IniPath, "ini", "i", "./playlists.ini", "path to a local ini-file")
|
||||||
checkCmd.Flags().UintVarP(&app.Args.RandomCount, "random", "r", 0, "take this count of random playlists to check from ini-file")
|
checkCmd.Flags().UintVarP(&app.Args.RandomCount, "random", "r", 0, "take this count of random playlists to check from ini-file")
|
||||||
|
checkCmd.Flags().UintVarP(&app.Args.RepeatCount, "repeat", "", 1, "repeat same check X times")
|
||||||
|
checkCmd.Flags().UintVarP(&app.Args.RepeatEverySec, "every", "", 5, "wait N seconds after every check")
|
||||||
checkCmd.Flags().BoolVarP(&app.Args.NeedJson, "json", "j", false, "print results in JSON format in the end")
|
checkCmd.Flags().BoolVarP(&app.Args.NeedJson, "json", "j", false, "print results in JSON format in the end")
|
||||||
checkCmd.Flags().BoolVarP(&app.Args.NeedQuiet, "quiet", "q", false, "suppress logs (does not affect on -j)")
|
checkCmd.Flags().BoolVarP(&app.Args.NeedQuiet, "quiet", "q", false, "suppress logs (does not affect on -j)")
|
||||||
checkCmd.Flags().StringSliceP("file", "f", []string{}, "path to a local playlist file (m3u/m3u8)")
|
checkCmd.Flags().StringSliceP("file", "f", []string{}, "path to a local playlist file (m3u/m3u8)")
|
||||||
|
|||||||
Reference in New Issue
Block a user