mykola/mptv
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

implement fetching m3u from url

Browse source
This commit is contained in:
mykola2312 2024-04-30 23:11:21 +03:00
parent 59801a6ddd
commit a28da85ec4
1 changed files with 23 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
src/main/java/com/mykola2312/mptv/crawler/Crawler.java
View file

@ -141,17 +141,17 @@ public class Crawler implements Task {
public void crawl() { public void crawl() {
crawlId = beginCrawl(); crawlId = beginCrawl();
for (Source source : loadSources()) { for (Source source : loadSources()) {
if (source.urlOrPath == null) {
logger.error("m3u local has to have \"path\" variable");
continue;
} else if (source.rootName == null) {
logger.error("source has to have \"rootCategory\"");
continue;
}
switch (source.type) { switch (source.type) {
case "m3u-local" -> { case "m3u-local" -> {
try { try {
if (source.urlOrPath == null) {
logger.error("m3u local has to have \"path\" variable");
continue;
} else if (source.rootName == null) {
logger.error("source has to have \"rootCategory\"");
continue;
}
String m3uData = Files.readString(Paths.get(source.urlOrPath), StandardCharsets.UTF_8); String m3uData = Files.readString(Paths.get(source.urlOrPath), StandardCharsets.UTF_8);
ArrayList<M3U> m3u = M3UParser.parse(m3uData); ArrayList<M3U> m3u = M3UParser.parse(m3uData);
@ -160,8 +160,21 @@ public class Crawler implements Task {
logger.error(e.toString()); logger.error(e.toString());
logger.error(String.format("failed to read local m3u file: %s", e.getMessage())); logger.error(String.format("failed to read local m3u file: %s", e.getMessage()));
} catch (M3UException e) { } catch (M3UException e) {
logger.error(e.toString()); logger.error("failed to parse m3u", e);
logger.error(String.format("failed to parse m3u: %s", e.getMessage())); }
}
case "m3u" -> {
try {
WebRequest get = new WebRequest(source.urlOrPath);
WebContent content = get.fetch();
ArrayList<M3U> m3u = M3UParser.parse(content.body);
updateAllChannels(m3u, source.rootName);
} catch (WebException e) {
logger.warn("failed to fetch " + source.urlOrPath);
} catch (M3UException e) {
logger.error("failed to parse m3u", e);
} }
} }