dongho/czzk-stream
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

scheduler

Browse Source
This commit is contained in:
Dongho Kim
2026-06-22 14:55:51 +02:00
parent 514be76202
commit 62c5db97b2
1 changed files with 130 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
index.js
+122 -21
View File
@@ -33,27 +33,137 @@ app.get('/playlist.m3u', (req, res) => {
res.send(m3u);
});
app.get('/stream/:channelId', async (req, res) => {
const { channelId } = req.params;
try {
// Helper: build request headers with optional Naver auth cookies
const buildHeaders = () => {
const headers = {
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
};
const cookies = [];
if (process.env.NID_AUT) cookies.push(`NID_AUT=${process.env.NID_AUT}`);
if (process.env.NID_SES) cookies.push(`NID_SES=${process.env.NID_SES}`);
if (cookies.length > 0) {
headers['Cookie'] = cookies.join('; ');
}
return headers;
};
const response = await axios.get(`https://api.chzzk.naver.com/service/v3/channels/${channelId}/live-detail`, {
headers
// Helper: fetch live-detail for a single channel
const fetchLiveDetail = async (channelId) => {
const response = await axios.get(
`https://api.chzzk.naver.com/service/v3/channels/${channelId}/live-detail`,
{ headers: buildHeaders() }
);
return response.data && response.data.content;
};
// Schedule endpoint — returns live status for all configured channels as JSON
app.get('/schedule', async (req, res) => {
const channels = parseChannels();
if (channels.length === 0) {
return res.json({ channels: [], fetchedAt: new Date().toISOString() });
}
const results = await Promise.allSettled(
channels.map(async (ch) => {
try {
const content = await fetchLiveDetail(ch.id);
if (!content) {
return { id: ch.id, name: ch.name, status: 'OFFLINE' };
}
return {
id: ch.id,
name: ch.name,
status: content.status || 'UNKNOWN',
liveTitle: content.liveTitle || null,
liveCategory: content.liveCategoryValue || content.liveCategory || null,
openDate: content.openDate || null,
concurrentUserCount: content.concurrentUserCount || 0,
channelImageUrl: content.channel && content.channel.channelImageUrl || null,
liveImageUrl: content.liveImageUrl || null,
};
} catch {
return { id: ch.id, name: ch.name, status: 'ERROR' };
}
})
);
const schedule = results.map(r => r.status === 'fulfilled' ? r.value : r.reason);
res.json({ channels: schedule, fetchedAt: new Date().toISOString() });
});
const data = response.data;
const content = data && data.content;
// EPG endpoint — generates XMLTV-format guide data for Jellyfin
app.get('/epg.xml', async (req, res) => {
const channels = parseChannels();
const results = await Promise.allSettled(
channels.map(async (ch) => {
try {
const content = await fetchLiveDetail(ch.id);
return { ch, content };
} catch {
return { ch, content: null };
}
})
);
const escapeXml = (str) => {
if (!str) return '';
return str.replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;')
.replace(/"/g, '&quot;').replace(/'/g, '&apos;');
};
let xml = '<?xml version="1.0" encoding="UTF-8"?>\n';
xml += '<!DOCTYPE tv SYSTEM "xmltv.dtd">\n';
xml += '<tv generator-info-name="czzk-stream">\n';
// Channel definitions
channels.forEach(ch => {
xml += ` <channel id="${escapeXml(ch.id)}">\n`;
xml += ` <display-name>${escapeXml(ch.name)}</display-name>\n`;
xml += ` </channel>\n`;
});
// Programme entries for live channels
results.forEach(r => {
if (r.status !== 'fulfilled') return;
const { ch, content } = r.value;
if (!content || content.status !== 'OPEN') return;
const openDate = content.openDate
? content.openDate.replace(/[-: ]/g, '').substring(0, 14) + ' +0900'
: null;
// Assume a 6-hour window for the programme end (no real end time available)
const endDate = content.openDate
? (() => {
const d = new Date(content.openDate);
d.setHours(d.getHours() + 6);
const pad = n => String(n).padStart(2, '0');
return `${d.getFullYear()}${pad(d.getMonth()+1)}${pad(d.getDate())}${pad(d.getHours())}${pad(d.getMinutes())}${pad(d.getSeconds())} +0900`;
})()
: null;
if (openDate && endDate) {
xml += ` <programme start="${openDate}" stop="${endDate}" channel="${escapeXml(ch.id)}">\n`;
xml += ` <title>${escapeXml(content.liveTitle || ch.name)}</title>\n`;
if (content.liveCategoryValue || content.liveCategory) {
xml += ` <category>${escapeXml(content.liveCategoryValue || content.liveCategory)}</category>\n`;
}
if (content.liveImageUrl) {
xml += ` <icon src="${escapeXml(content.liveImageUrl)}" />\n`;
}
xml += ` </programme>\n`;
}
});
xml += '</tv>\n';
res.header('Content-Type', 'application/xml');
res.send(xml);
});
app.get('/stream/:channelId', async (req, res) => {
const { channelId } = req.params;
try {
const content = await fetchLiveDetail(channelId);
const playbackJsonString = content && (content.livePlaybackJson || content.previewPlaybackJson);
if (!playbackJsonString) {
@@ -148,18 +258,7 @@ app.get('/key', async (req, res) => {
if (!keyUrl) return res.status(400).send('Missing url parameter');
try {
const headers = {
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
};
const cookies = [];
if (process.env.NID_AUT) cookies.push(`NID_AUT=${process.env.NID_AUT}`);
if (process.env.NID_SES) cookies.push(`NID_SES=${process.env.NID_SES}`);
if (cookies.length > 0) {
headers['Cookie'] = cookies.join('; ');
}
const response = await axios.get(keyUrl, { headers, responseType: 'arraybuffer' });
const response = await axios.get(keyUrl, { headers: buildHeaders(), responseType: 'arraybuffer' });
res.header('Content-Type', 'application/octet-stream');
res.send(response.data);
} catch (error) {
@@ -171,4 +270,6 @@ app.get('/key', async (req, res) => {
app.listen(port, () => {
console.log(`Chzzk IPTV Proxy running on port ${port}`);
console.log(`Playlist URL: http://localhost:${port}/playlist.m3u`);
console.log(`Schedule URL: http://localhost:${port}/schedule`);
console.log(`EPG URL: http://localhost:${port}/epg.xml`);
});