diff --git a/cobalt.js b/cobalt.js
index f7d3b0e3..521e8f49 100644
--- a/cobalt.js
+++ b/cobalt.js
@@ -61,7 +61,7 @@ if (fs.existsSync('./.env') && fs.existsSync('./config.json')) {
req.query.url.trim(),
req.header('x-forwarded-for') ? req.header('x-forwarded-for') : req.ip,
req.header('Accept-Language') ? req.header('Accept-Language').slice(0, 2) : "en",
- req.query.format ? req.query.format.slice(0, 5) : "webm",
+ req.query.format ? req.query.format.slice(0, 5) : "mp4",
req.query.quality ? req.query.quality.slice(0, 3) : "max"
)
res.status(j.status).json(j.body);
diff --git a/files/cobalt.js b/files/cobalt.js
index f47c5c46..b8523730 100644
--- a/files/cobalt.js
+++ b/files/cobalt.js
@@ -147,7 +147,7 @@ async function download(url) {
changeDownloadButton(2, '...');
eid("url-input-area").disabled = true;
let format = '';
- if (url.includes(".youtube.com/") || url.includes("/youtu.be/")) {
+ if (url.includes("youtube.com/") || url.includes("/youtu.be/")) {
format = `&format=${localStorage.getItem("youtubeFormat")}`
}
fetch(`/api/json?quality=${localStorage.getItem("quality")}${format}&url=${encodeURIComponent(url)}`).then(async (response) => {
diff --git a/modules/api.js b/modules/api.js
index 69484ab4..0fdeb1b1 100644
--- a/modules/api.js
+++ b/modules/api.js
@@ -5,7 +5,7 @@ import { services as patterns } from "./config.js";
import { cleanURL, apiJSON } from "./sub/api-helper.js";
import { errorUnsupported } from "./sub/errors.js";
import loc from "./sub/loc.js";
-import match from "./sub/match.js";
+import match from "./match.js";
export async function getJSON(originalURL, ip, lang, format, quality) {
try {
diff --git a/modules/sub/match.js b/modules/match.js
similarity index 91%
rename from modules/sub/match.js
rename to modules/match.js
index c1b747e7..ec28531e 100644
--- a/modules/sub/match.js
+++ b/modules/match.js
@@ -1,11 +1,11 @@
-import { apiJSON } from "./api-helper.js";
-import { errorUnsupported, genericError } from "./errors.js";
+import { apiJSON } from "./sub/api-helper.js";
+import { errorUnsupported, genericError } from "./sub/errors.js";
-import bilibili from "../services/bilibili.js";
-import reddit from "../services/reddit.js";
-import twitter from "../services/twitter.js";
-import youtube from "../services/youtube.js";
-import vk from "../services/vk.js";
+import bilibili from "./services/bilibili.js";
+import reddit from "./services/reddit.js";
+import twitter from "./services/twitter.js";
+import youtube from "./services/youtube.js";
+import vk from "./services/vk.js";
export default async function (host, patternMatch, url, ip, lang, format, quality) {
try {
@@ -47,6 +47,9 @@ export default async function (host, patternMatch, url, ip, lang, format, qualit
lang: lang, quality: quality,
format: "mp4"
};
+ if (url.match('music.youtube.com')) {
+ format = "audio"
+ }
switch (format) {
case "webm":
fetchInfo["format"] = "webm";
@@ -57,9 +60,6 @@ export default async function (host, patternMatch, url, ip, lang, format, qualit
fetchInfo["quality"] = "max";
break;
}
- if (url.match('music.youtube.com')) {
- fetchInfo["isAudioOnly"] = true;
- }
let r = await youtube(fetchInfo);
return (!r.error) ? apiJSON(2, {
type: r.type, urls: r.urls, service: host, ip: ip,
diff --git a/modules/page-renderer.js b/modules/page-renderer.js
index 83a2fb05..a82b74de 100644
--- a/modules/page-renderer.js
+++ b/modules/page-renderer.js
@@ -24,7 +24,7 @@ export default function(obj) {
-
+
${appName}
diff --git a/modules/services/youtube.js b/modules/services/youtube.js
index 6f2f4c69..02a55d05 100644
--- a/modules/services/youtube.js
+++ b/modules/services/youtube.js
@@ -9,50 +9,50 @@ export default async function (obj) {
if (info) {
info = info.formats;
if (!info[0]["isLive"]) {
- if (obj.isAudioOnly) {
- obj.format = "webm"
- obj.quality = "max"
- }
- let selectedVideo, videoMatch = [], video = [], audio = info.filter((a) => {
- if (!a["isLive"] && !a["isHLS"] && !a["isDashMPD"] && a["hasAudio"] && !a["hasVideo"] && a["container"] == obj.format) {
- return true;
- }
+ let videoMatch = [], fullVideoMatch = [], video = [], audio = info.filter((a) => {
+ if (!a["isHLS"] && !a["isDashMPD"] && a["hasAudio"] && !a["hasVideo"] && a["container"] == obj.format) return true;
}).sort((a, b) => Number(b.bitrate) - Number(a.bitrate));
if (!obj.isAudioOnly) {
video = info.filter((a) => {
- if (!a["isLive"] && !a["isHLS"] && !a["isDashMPD"] && !a["hasAudio"] && a["hasVideo"] && a["container"] == obj.format && a["height"] != 4320) {
- if (obj.quality != "max" && mq[obj.quality] == a["height"]) {
- videoMatch.push(a)
+ if (!a["isHLS"] && !a["isDashMPD"] && a["hasVideo"] && a["container"] == obj.format && a["height"] != 4320) {
+ if (obj.quality != "max") {
+ if (a["hasAudio"] && mq[obj.quality] == a["height"]) {
+ fullVideoMatch.push(a)
+ } else if (!a["hasAudio"] && mq[obj.quality] == a["height"]) {
+ videoMatch.push(a);
+ }
}
- return true;
+ return true
}
}).sort((a, b) => Number(b.bitrate) - Number(a.bitrate));
- selectedVideo = video[0]
if (obj.quality != "max") {
- if (videoMatch.length > 0) {
- selectedVideo = videoMatch[0]
- } else {
+ if (videoMatch.length == 0) {
let ss = selectQuality("youtube", obj.quality, video[0]["height"])
- selectedVideo = video.filter((a) => {
- if (a["height"] == ss) {
- return true
- }
+ videoMatch = video.filter((a) => {
+ if (a["height"] == ss) return true;
})
- selectedVideo = selectedVideo[0]
+ } else if (fullVideoMatch.length > 0) {
+ videoMatch = [fullVideoMatch[0]]
}
- }
- if (obj.quality == "los") {
- selectedVideo = video[video.length - 1]
- }
+ } else videoMatch = [video[0]];
+ if (obj.quality == "los") videoMatch = [video[video.length - 1]];
}
if (audio[0]["approxDurationMs"] <= maxVideoDuration) {
- if (!obj.isAudioOnly && video.length > 0) {
- let filename = `youtube_${obj.id}_${selectedVideo["width"]}x${selectedVideo["height"]}.${obj.format}`;
+ if (!obj.isAudioOnly && videoMatch.length > 0) {
if (video.length > 0 && audio.length > 0) {
- return { type: "render", urls: [selectedVideo["url"], audio[0]["url"]], time: video[0]["approxDurationMs"], filename: filename };
+ if (videoMatch[0]["hasVideo"] && videoMatch[0]["hasAudio"]) {
+ return { type: "bridge", urls: videoMatch[0]["url"], time: videoMatch[0]["approxDurationMs"],
+ filename: `youtube_${obj.id}_${videoMatch[0]["width"]}x${videoMatch[0]["height"]}.${obj.format}` };
+ } else {
+ return { type: "render", urls: [videoMatch[0]["url"], audio[0]["url"]], time: videoMatch[0]["approxDurationMs"],
+ filename: `youtube_${obj.id}_${videoMatch[0]["width"]}x${videoMatch[0]["height"]}.${obj.format}` };
+ }
} else {
return { error: loc('en', 'apiError', 'youtubeBroke') };
}
+ } else if (!obj.isAudioOnly) {
+ return { type: "render", urls: [video[0]["url"], audio[0]["url"]], time: video[0]["approxDurationMs"],
+ filename: `youtube_${obj.id}_${video[0]["width"]}x${video[0]["height"]}.${video[0]["container"]}` };
} else if (audio.length > 0) {
return { type: "render", isAudioOnly: true, urls: [audio[0]["url"]], filename: `youtube_${obj.id}_${audio[0]["audioBitrate"]}kbps.opus` };
} else {
diff --git a/modules/stream/types.js b/modules/stream/types.js
index 66d20dde..6dc54915 100644
--- a/modules/stream/types.js
+++ b/modules/stream/types.js
@@ -40,8 +40,8 @@ export async function streamLiveRender(streamInfo, res) {
'-loglevel', '-8',
'-i', 'pipe:3',
'-i', 'pipe:4',
- '-map', '0:a',
- '-map', '1:v',
+ '-map', '0:v',
+ '-map', '1:a',
'-c:v', 'copy',
'-c:a', 'copy',
];
@@ -75,11 +75,11 @@ export async function streamLiveRender(streamInfo, res) {
});
res.setHeader('Content-Disposition', `attachment; filename="${streamInfo.filename}"`);
ffmpegProcess.stdio[5].pipe(res);
- audio.pipe(ffmpegProcess.stdio[3]).on('error', (err) => {
+ video.pipe(ffmpegProcess.stdio[3]).on('error', (err) => {
ffmpegProcess.kill();
internalError(res);
});
- video.pipe(ffmpegProcess.stdio[4]).on('error', (err) => {
+ audio.pipe(ffmpegProcess.stdio[4]).on('error', (err) => {
ffmpegProcess.kill();
internalError(res);
});