19 Commits

Author SHA1 Message Date
Godzil
978a3282a4 1.3.0 2018-07-30 22:47:33 +01:00
Manoël Trapier
9f0195bebc Update README.md 2018-07-30 22:47:33 +01:00
Manoël Trapier
ea20108222 Update README.md 2018-07-30 22:47:33 +01:00
Godzil
4ee814864c Add support for changing the batchfile on the command line 2018-07-30 22:47:33 +01:00
Godzil
4cbfd691c3 add missing package 2018-07-30 22:47:32 +01:00
Godzil
7c04fb7282 Make tslint happy! 2018-07-30 22:47:29 +01:00
Godzil
849c7612aa A bit of code reformating and add an option to regenerate the .crpersistant file in case it become corrupted and Crunchy try to redownload everything. 2018-07-30 22:46:29 +01:00
Roei Elisha
6ad4cbed0a make login work 2018-07-30 22:45:28 +01:00
Godzil
9e2f5401d0 Update tslint.json 2018-07-30 22:44:18 +01:00
Roei Elisha
b064b97f2d fix linter problems 2018-05-22 23:55:10 +03:00
Godzil
b248405437 1.2.2 2018-05-09 22:33:45 +01:00
Godzil
bf941819a8 remove unwwanted parameter 2018-05-09 22:31:50 +01:00
Godzil
fcae53baae Node 5, 6 and 7 seems to not like something. Delete them from Travis build 2018-05-08 21:50:58 +01:00
Godzil
05ead50c0d Let's try to make travis happy with older node version 2018-05-08 21:49:11 +01:00
Godzil
0a80f80f91 1.2.1 2018-05-08 21:37:43 +01:00
Godzil
3bf5fea735 Make Crunchy to properly return a return code when running fine or failing 2018-05-08 21:37:34 +01:00
Godzil
3a95994cc2 1.2.0 2018-03-29 22:33:15 +01:00
Godzil
a29870691b Update deps 2018-03-29 22:33:06 +01:00
Godzil
547fdc4aa0 Add a way to select the resolution. Use 1080p by default
Fix #58
2018-03-29 22:29:13 +01:00
18 changed files with 654 additions and 483 deletions

View File

@@ -1,9 +1,6 @@
language: node_js language: node_js
sudo: false sudo: false
node_js: node_js:
- 5
- 6
- 7
- 8 - 8
- 9 - 9
before_install: before_install:

View File

@@ -21,30 +21,39 @@ It is recommended to enable authentication (`-p` and `-u`) so your account permi
## Prerequisites ## Prerequisites
* NodeJS >= 5.x (http://nodejs.org/) * NodeJS >= 8.1 (http://nodejs.org/)
* NPM >= 2.5.x (https://www.npmjs.org/) * NPM >= 5.8 (https://www.npmjs.org/)
## Installation ## Installation
Use the applicable instructions to install. Is your operating system not listed? Please ask or contribute! Use the applicable instructions to install. Is your operating system not listed? Please ask or contribute!
### Debian (Mint, Ubuntu, etc) ### Linux (Debian, Mint, Ubuntu, etc)
1. Run in *Terminal*: `sudo apt-get install nodejs npm mkvtoolnix rtmpdump ffmpeg` 1. Run in *Terminal*: `sudo apt-get install nodejs npm mkvtoolnix rtmpdump ffmpeg`
2. Run in *Terminal*: `sudo ln -s /usr/bin/nodejs /usr/bin/node` 2. Run in *Terminal*: `sudo ln -s /usr/bin/nodejs /usr/bin/node`
3. Run in *Terminal*: `sudo npm install -g crunchy` 3. Run in *Terminal*: `sudo npm install -g crunchy`
#### Updating:
1. Run in *Terminal*: `sudo npm update -g crunchy`
### Mac OS X ### Mac OS X
1. Install *Homebrew* following the instructions at http://brew.sh/ 1. Install *Homebrew* following the instructions at http://brew.sh/
2. Run in *Terminal*: `brew install node mkvtoolnix rtmpdump ffmpeg` 2. Run in *Terminal*: `brew install node mkvtoolnix rtmpdump ffmpeg`
3. Run in *Terminal*: `npm install -g crunchy` 3. Run in *Terminal*: `npm install -g crunchy`
#### Updating:
1. Run in *Terminal*: `sudo npm update -g crunchy`
### Windows ### Windows
1. Install *NodeJS* following the instructions at http://nodejs.org/ 1. Install *NodeJS* following the instructions at http://nodejs.org/
3. Run in *Command Prompt*: `npm install -g crunchy` 3. Run in *Command Prompt*: `npm install -g crunchy`
#### Updating:
1. Run in *Command Prompt*: `npm update -g crunchy`
## Instructions ## Instructions
Use the applicable instructions for the interface of your choice (currently limited to command-line). Use the applicable instructions for the interface of your choice (currently limited to command-line).

10
bin/crunchy.sh Executable file
View File

@@ -0,0 +1,10 @@
#!/bin/bash
PARAMS=$*
for i in {1..20}; do
crunchy ${PARAMS}
if [ $? == 0 ]; then
break
fi
echo "Going to retry..."
sleep 3
done

662
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -15,33 +15,40 @@
"engines": { "engines": {
"node": ">=5.0" "node": ">=5.0"
}, },
"version": "1.1.22", "version": "1.3.0",
"bin": { "bin": {
"crunchy": "./bin/crunchy" "crunchy": "./bin/crunchy",
"crunchy.sh": "./bin/crunchy.sh"
}, },
"dependencies": { "dependencies": {
"big-integer": "^1.4.4", "big-integer": "^1.6.30",
"bluebird": "^3.5.1",
"cheerio": "^0.22.0", "cheerio": "^0.22.0",
"cloudscraper": "^1.5.0", "cloudscraper": "^1.5.0",
"commander": "^2.12.2", "commander": "^2.15.1",
"fs-extra": "^5.0.0", "fs-extra": "^6.0.1",
"mkdirp": "^0.5.0", "mkdirp": "^0.5.0",
"request": "^2.74.0", "request": "^2.87.0",
"request-promise": "^4.2.2",
"xml2js": "^0.4.5" "xml2js": "^0.4.5"
}, },
"devDependencies": { "devDependencies": {
"@types/cheerio": "^0.22.6", "@types/bluebird": "^3.5.20",
"@types/cheerio": "^0.22.7",
"@types/fs-extra": "^5.0.2",
"@types/mkdirp": "^0.5.2", "@types/mkdirp": "^0.5.2",
"@types/request": "^2.0.9", "@types/request": "^2.47.0",
"@types/request-promise": "^4.1.41",
"@types/xml2js": "^0.4.2", "@types/xml2js": "^0.4.2",
"tsconfig-lint": "^0.12.0", "tsconfig-lint": "^0.12.0",
"tslint": "^5.8.0", "tslint": "^5.10.0",
"typescript": "^2.6.2" "typescript": "^2.9.1"
}, },
"scripts": { "scripts": {
"prepublishOnly": "npm run build", "prepublishOnly": "npm run build",
"compile": "tsc",
"build": "tsc", "build": "tsc",
"test": "tslint -c ./tslint.json --project ./tsconfig.json ./src/**/*.ts", "test": "tslint --project .",
"start": "node ./bin/crunchy" "start": "node ./bin/crunchy"
}, },
"bugs": { "bugs": {

View File

@@ -2,33 +2,65 @@
import commander = require('commander'); import commander = require('commander');
import fs = require('fs'); import fs = require('fs');
import path = require('path'); import path = require('path');
import log = require('./log');
import series from './series'; import series from './series';
/* correspondances between resolution and value CR excpect */
const resol_table: { [id: string]: IResolData; } =
{
360: {quality: '60', format: '106'},
480: {quality: '61', format: '106'},
720: {quality: '62', format: '106'},
1080: {quality: '80', format: '108'},
};
/** /**
* Streams the batch of series to disk. * Streams the batch of series to disk.
*/ */
export default function(args: string[], done: (err?: Error) => void) export default function(args: string[], done: (err?: Error) => void)
{ {
const config = parse(args); const config = parse(args);
const batchPath = path.join(config.output || process.cwd(), 'CrunchyRoll.txt'); const batchPath = path.join(config.output || process.cwd(), config.batch);
tasks(config, batchPath, (err, tasks) => // set resolution
if (config.resolution)
{
try
{
config.video_format = resol_table[config.resolution].format;
config.video_quality = resol_table[config.resolution].quality;
}
catch (e)
{
log.warn('Invalid resolution ' + config.resolution + 'p. Setting to 1080p');
config.video_format = resol_table['1080'].format;
config.video_quality = resol_table['1080'].quality;
}
}
else
{
/* 1080 by default */
config.video_format = resol_table['1080'].format;
config.video_quality = resol_table['1080'].quality;
}
tasks(config, batchPath, (err, tasksArr) =>
{ {
if (err) if (err)
{ {
return done(err); return done(err);
} }
let i = 0; let i = 0;
(function next() (function next()
{ {
if (i >= tasks.length) if (i >= tasksArr.length)
{ {
return done(); return done();
} }
series(tasks[i].config, tasks[i].address, (errin) => series(tasksArr[i].config, tasksArr[i].address, (errin) =>
{ {
if (errin) if (errin)
{ {
@@ -150,6 +182,10 @@ function parse(args: string[]): IConfigLine
.option('-o, --output <s>', 'The output path.') .option('-o, --output <s>', 'The output path.')
.option('-s, --series <s>', 'The series override.') .option('-s, --series <s>', 'The series override.')
.option('-n, --filename <s>', 'The name override.') .option('-n, --filename <s>', 'The name override.')
.option('-t, --tag <s>', 'The subgroup. (Default: CrunchyRoll)') .option('-t, --tag <s>', 'The subgroup. (Default: CrunchyRoll)', 'CrunchyRoll')
.option('-r, --resolution <s>', 'The video resolution. (Default: 1080 (360, 480, 720, 1080))',
'1080')
.option('-g, --rebuildcrp', 'Rebuild the crpersistant file.')
.option('-b, --batch <s>', 'Batch file', 'CrunchyRoll.txt')
.parse(args); .parse(args);
} }

View File

@@ -6,5 +6,8 @@ batch(process.argv, (err: any) =>
if (err) if (err)
{ {
console.error(err.stack || err); console.error(err.stack || err);
process.exit(-1);
} }
console.info('Done!');
process.exit(0);
}); });

View File

@@ -57,7 +57,8 @@ function fileExist(path: string)
{ {
fs.statSync(path); fs.statSync(path);
return true; return true;
} catch (e) }
catch (e)
{ {
return false; return false;
} }
@@ -82,6 +83,13 @@ function download(config: IConfig, page: IEpisodePage, player: IEpisodePlayer, d
if (fileExist(filePath + '.mkv')) if (fileExist(filePath + '.mkv'))
{ {
let count = 0; let count = 0;
if (config.rebuildcrp)
{
log.warn('Adding \'' + fileName + '\' to the DB...');
return done(null, false);
}
log.warn('File \'' + fileName + '\' already exist...'); log.warn('File \'' + fileName + '\' already exist...');
do do
@@ -94,6 +102,11 @@ function download(config: IConfig, page: IEpisodePage, player: IEpisodePlayer, d
log.warn('Renaming to \'' + fileName + '\'...'); log.warn('Renaming to \'' + fileName + '\'...');
} }
if (config.rebuildcrp)
{
return done(null, true);
}
mkdirp(path.dirname(filePath), (errM: Error) => mkdirp(path.dirname(filePath), (errM: Error) =>
{ {
if (errM) if (errM)
@@ -258,7 +271,7 @@ function scrapePage(config: IConfig, address: string, done: (err: Error, page?:
const regexp = /\s*([^\n\r\t\f]+)\n?\s*[^0-9]*([0-9][\-0-9.]*)?,?\n?\s\s*[^0-9]*((PV )?[S0-9][P0-9.]*[a-fA-F]?)/; const regexp = /\s*([^\n\r\t\f]+)\n?\s*[^0-9]*([0-9][\-0-9.]*)?,?\n?\s\s*[^0-9]*((PV )?[S0-9][P0-9.]*[a-fA-F]?)/;
const look = $('#showmedia_about_media').text(); const look = $('#showmedia_about_media').text();
const seasonTitle = $('span[itemprop="title"]').text(); const seasonTitle = $('span[itemprop="title"]').text();
let episodeTitle = $('#showmedia_about_name').text().replace(/[“”]/g, ''); const episodeTitle = $('#showmedia_about_name').text().replace(/[“”]/g, '');
const data = regexp.exec(look); const data = regexp.exec(look);
if (!swf || !data) if (!swf || !data)
@@ -303,7 +316,12 @@ function scrapePlayer(config: IConfig, address: string, id: number, done: (err:
} }
my_request.post(config, { my_request.post(config, {
form: {current_page: address}, form: {
current_page: address,
video_format: config.video_format,
video_quality: config.video_quality,
media_id: id
},
url: url[1] + '/xml/?req=RpcApiVideoPlayer_GetStandardConfig&media_id=' + id, url: url[1] + '/xml/?req=RpcApiVideoPlayer_GetStandardConfig&media_id=' + id,
}, (err, result) => }, (err, result) =>
{ {
@@ -328,9 +346,9 @@ function scrapePlayer(config: IConfig, address: string, id: number, done: (err:
let streamMode = 'RTMP'; let streamMode = 'RTMP';
if (player['default:preload'].stream_info.host === '') if (player['default:preload'].stream_info.host === '')
{ {
streamMode = 'HLS'; streamMode = 'HLS';
} }
done(null, { done(null, {
subtitle: isSubtitled ? { subtitle: isSubtitled ? {

View File

@@ -14,4 +14,9 @@ interface IConfig {
series?: string; series?: string;
filename?: string; filename?: string;
tag?: string; tag?: string;
resolution?: string;
video_format?: string;
video_quality?: string;
rebuildcrp?: boolean;
batch?: string;
} }

4
src/interface/IResolData.d.ts vendored Normal file
View File

@@ -0,0 +1,4 @@
interface IResolData {
quality: string;
format: string;
}

View File

@@ -1,7 +1,13 @@
'use strict'; 'use strict';
import request = require('request');
import cheerio = require('cheerio'); import cheerio = require('cheerio');
import request = require('request');
import rp = require('request-promise');
import Promise = require('bluebird');
import log = require('./log'); import log = require('./log');
import { RequestPromise } from 'request-promise';
import { Response } from 'request';
// tslint:disable-next-line:no-var-requires
const cloudscraper = require('cloudscraper'); const cloudscraper = require('cloudscraper');
let isAuthenticated = false; let isAuthenticated = false;
@@ -10,30 +16,84 @@ let isPremium = false;
const defaultHeaders: request.Headers = const defaultHeaders: request.Headers =
{ {
'User-Agent': 'Mozilla/5.0 (Windows NT 6.2; WOW64; x64; rv:58.0) Gecko/20100101 Firefox/58.0', 'User-Agent': 'Mozilla/5.0 (Windows NT 6.2; WOW64; x64; rv:58.0) Gecko/20100101 Firefox/58.0',
// Mozilla/5.0 (Windows NT 6.2; WOW64; rv:34.0) Gecko/20100101 Firefox/34.0',
'Connection': 'keep-alive', 'Connection': 'keep-alive',
'Referer': 'https://www.crunchyroll.com/login' 'Referer': 'https://www.crunchyroll.com/login',
}; };
function generateDeviceId(): string
{
let id = '';
const possible = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
for (let i = 0; i < 32; i++)
{
id += possible.charAt(Math.floor(Math.random() * possible.length));
}
return id;
}
function startSession(): Promise<string>
{
return rp(
{
method: 'GET',
url: 'CR_SESSION_URL',
qs:
{
device_id: generateDeviceId(),
device_type: 'CR_DEVICE_TYPE',
access_token: 'CR_SESSION_KEY',
version: 'CR_API_VERSION',
locale: 'CR_LOCALE',
},
json: true,
})
.then((response: any) =>
{
return response.data.session_id;
});
}
function login(sessionId: string, user: string, pass: string): Promise<any>
{
return rp(
{
method: 'POST',
url: 'CR_LOGIN_URL',
form:
{
account: user,
password: pass,
session_id: sessionId,
version: 'CR_API_VERSION',
},
json: true,
})
.then((response) =>
{
if (response.error) throw new Error('Login failed: ' + response.message);
return response.data;
});
}
// TODO: logout
/** /**
* Performs a GET request for the resource. * Performs a GET request for the resource.
*/ */
export function get(config: IConfig, options: string|request.Options, done: (err: Error, result?: string) => void) export function get(config: IConfig, options: string|request.Options, done: (err: Error, result?: string) => void)
{ {
authenticate(config, err => authenticate(config, (err) =>
{ {
if (err) if (err)
{ {
return done(err); return done(err);
} }
cloudscraper.request(modify(options, 'GET'), (err: Error, response: any, body: any) => cloudscraper.request(modify(options, 'GET'), (error: Error, response: any, body: any) =>
{ {
if (err) if (error) return done(error);
{
return done(err);
}
done(null, typeof body === 'string' ? body : String(body)); done(null, typeof body === 'string' ? body : String(body));
}); });
}); });
@@ -44,20 +104,19 @@ export function get(config: IConfig, options: string|request.Options, done: (err
*/ */
export function post(config: IConfig, options: request.Options, done: (err: Error, result?: string) => void) export function post(config: IConfig, options: request.Options, done: (err: Error, result?: string) => void)
{ {
authenticate(config, err => authenticate(config, (err) =>
{ {
if (err) if (err)
{ {
return done(err); return done(err);
} }
cloudscraper.request(modify(options, 'POST'), (err: Error, response: any, body: any) => cloudscraper.request(modify(options, 'POST'), (error: Error, response: any, body: any) =>
{ {
if (err) if (error)
{ {
return done(err); return done(error);
} }
done(null, typeof body === 'string' ? body : String(body)); done(null, typeof body === 'string' ? body : String(body));
}); });
}); });
@@ -73,107 +132,70 @@ function authenticate(config: IConfig, done: (err: Error) => void)
return done(null); return done(null);
} }
/* Bypass the login page and send a login request directly */ startSession()
let options = .then((sessionId: string) =>
{ {
headers: defaultHeaders, defaultHeaders.Cookie = `sess_id=${sessionId}; c_locale=enUS`;
jar: true, return login(sessionId, config.user, config.pass);
gzip: false, })
method: 'GET', .then((userData) =>
url: 'https://www.crunchyroll.com/login'
};
cloudscraper.request(options, (err: Error, rep: string, body: string) =>
{ {
if (err) return done(err); /**
* The page return with a meta based redirection, as we wan't to check that everything is fine, reload
const $ = cheerio.load(body); * the main page. A bit convoluted, but more sure.
*/
/* Get the token from the login page */ const options =
const token = $('input[name="login_form[_token]"]').attr('value');
if (token === '')
{
return done(new Error('Can`t find token!'));
}
let options =
{ {
headers: defaultHeaders, headers: defaultHeaders,
form:
{
'login_form[name]': config.user,
'login_form[password]': config.pass,
'login_form[redirect_url]': '/',
'login_form[_token]': token
},
jar: true, jar: true,
gzip: false, url: 'http://www.crunchyroll.com/',
method: 'POST', method: 'GET',
url: 'https://www.crunchyroll.com/login'
}; };
cloudscraper.request(options, (err: Error, rep: string, body: string) => cloudscraper.request(options, (err: Error, rep: string, body: string) =>
{ {
if (err) if (err)
{ {
return done(err); return done(err);
} }
/* The page return with a meta based redirection, as we wan't to check that everything is fine, reload const $ = cheerio.load(body);
* the main page. A bit convoluted, but more sure.
*/ /* Check if auth worked */
let options = const regexps = /ga\('set', 'dimension[5-8]', '([^']*)'\);/g;
const dims = regexps.exec($('script').text());
for (let i = 1; i < 5; i++)
{ {
headers: defaultHeaders, if ((dims[i] !== undefined) && (dims[i] !== '') && (dims[i] !== 'not-registered'))
jar: true, {
url: 'http://www.crunchyroll.com/', isAuthenticated = true;
method: 'GET' }
};
cloudscraper.request(options, (err: Error, rep: string, body: string) => if ((dims[i] === 'premium') || (dims[i] === 'premiumplus'))
{
isPremium = true;
}
}
if (isAuthenticated === false)
{ {
if (err) const error = $('ul.message, li.error').text();
{ return done(new Error('Authentication failed: ' + error));
return done(err); }
}
let $ = cheerio.load(body); if (isPremium === false)
{
/* Check if auth worked */ log.warn('Do not use this app without a premium account.');
const regexps = /ga\('set', 'dimension[5-8]', '([^']*)'\);/g; }
const dims = regexps.exec($('script').text()); else
{
for (let i = 1; i < 5; i++) log.info('You have a premium account! Good!');
{ }
if ((dims[i] !== undefined) && (dims[i] !== '') && (dims[i] !== 'not-registered')) done(null);
{
isAuthenticated = true;
}
if ((dims[i] === 'premium') || (dims[i] === 'premiumplus'))
{
isPremium = true;
}
}
if (isAuthenticated === false)
{
const error = $('ul.message, li.error').text();
return done(new Error('Authentication failed: ' + error));
}
if (isPremium === false)
{
log.warn('Do not use this app without a premium account.');
}
else
{
log.info('You have a premium account! Good!');
}
done(null);
});
}); });
}); })
.catch(done);
} }
/** /**
@@ -188,5 +210,10 @@ function modify(options: string|request.Options, reqMethod: string): request.Opt
options.method = reqMethod; options.method = reqMethod;
return options; return options;
} }
return { jar: true, headers: defaultHeaders, url: options.toString(), method: reqMethod }; return {
} jar: true,
headers: defaultHeaders,
url: options.toString(),
method: reqMethod
};
}

View File

@@ -2,7 +2,7 @@
import cheerio = require('cheerio'); import cheerio = require('cheerio');
import episode from './episode'; import episode from './episode';
import fs = require('fs'); import fs = require('fs');
const fse = require('fs-extra'); import fse = require('fs-extra');
import my_request = require('./my_request'); import my_request = require('./my_request');
import path = require('path'); import path = require('path');
import url = require('url'); import url = require('url');
@@ -153,7 +153,7 @@ function page(config: IConfig, address: string, done: (err: Error, result?: ISer
episode: '', episode: '',
volume: 0, volume: 0,
}); });
done(null, {episodes: episodes.reverse(), series: ""}); done(null, {episodes: episodes.reverse(), series: ''});
} }
else else
{ {
@@ -195,7 +195,7 @@ function page(config: IConfig, address: string, done: (err: Error, result?: ISer
}); });
if (episodeCount === 0) if (episodeCount === 0)
{ {
log.warn("No episodes found for " + title + ". Could it be a movie?"); log.warn('No episodes found for ' + title + '. Could it be a movie?');
} }
done(null, {episodes: episodes.reverse(), series: title}); done(null, {episodes: episodes.reverse(), series: title});
}); });

View File

@@ -33,10 +33,10 @@ export default function(input: string|Buffer, done: (err: Error, subtitle?: stri
*/ */
function event(block: ISubtitleEvent): string function event(block: ISubtitleEvent): string
{ {
var format = 'Layer,Start,End,Style,Name,MarginL,MarginR,MarginV,Effect,Text'; const format = 'Layer,Start,End,Style,Name,MarginL,MarginR,MarginV,Effect,Text';
return '[Events]\n' + return '[Events]\n' +
'Format: ' + format + '\n' + [].concat(block.event).map(style => ('Dialogue: 0,' + 'Format: ' + format + '\n' + [].concat(block.event).map((style) => ('Dialogue: 0,' +
style.$.start + ',' + style.$.start + ',' +
style.$.end + ',' + style.$.end + ',' +
style.$.style + ',' + style.$.style + ',' +
@@ -70,13 +70,13 @@ function script(block: ISubtitle): string
*/ */
function style(block: ISubtitleStyle): string function style(block: ISubtitleStyle): string
{ {
var format = 'Name,Fontname,Fontsize,PrimaryColour,SecondaryColour,' + const format = 'Name,Fontname,Fontsize,PrimaryColour,SecondaryColour,' +
'OutlineColour,BackColour,Bold,Italic,Underline,StrikeOut,ScaleX,' + 'OutlineColour,BackColour,Bold,Italic,Underline,StrikeOut,ScaleX,' +
'ScaleY,Spacing,Angle,BorderStyle,Outline,Shadow,Alignment,' + 'ScaleY,Spacing,Angle,BorderStyle,Outline,Shadow,Alignment,' +
'MarginL,MarginR,MarginV,Encoding'; 'MarginL,MarginR,MarginV,Encoding';
return '[V4+ Styles]\n' + return '[V4+ Styles]\n' +
'Format: ' + format + '\n' + [].concat(block.style).map(style => 'Style: ' + 'Format: ' + format + '\n' + [].concat(block.style).map((style) => 'Style: ' +
style.$.name + ',' + style.$.name + ',' +
style.$.font_name + ',' + style.$.font_name + ',' +
style.$.font_size + ',' + style.$.font_size + ',' +

View File

@@ -2,7 +2,7 @@
import ass from './ass'; import ass from './ass';
import srt from './srt'; import srt from './srt';
export default <IFormatterTable> { export default {
ass: ass, ass,
srt: srt srt
}; } as IFormatterTable;

View File

@@ -17,7 +17,7 @@ export default function(config: IConfig, isSubtitled: boolean, rtmpInputPath: st
if (streamMode === 'RTMP') if (streamMode === 'RTMP')
{ {
videoPath += path.extname(rtmpInputPath); videoPath += path.extname(rtmpInputPath);
} }
else else
{ {

View File

@@ -11,30 +11,31 @@ import log = require('../log');
export default function(rtmpUrl: string, rtmpInputPath: string, swfUrl: string, filePath: string, export default function(rtmpUrl: string, rtmpInputPath: string, swfUrl: string, filePath: string,
fileExt: string, mode: string, done: (err: Error) => void) fileExt: string, mode: string, done: (err: Error) => void)
{ {
if (mode === 'RTMP') if (mode === 'RTMP')
{ {
childProcess.exec(command('rtmpdump') + ' ' + childProcess.exec(command('rtmpdump') + ' ' +
'-r "' + rtmpUrl + '" ' + '-r "' + rtmpUrl + '" ' +
'-y "' + rtmpInputPath + '" ' + '-y "' + rtmpInputPath + '" ' +
'-W "' + swfUrl + '" ' + '-W "' + swfUrl + '" ' +
'-o "' + filePath + fileExt + '"', { '-o "' + filePath + fileExt + '"', {
maxBuffer: Infinity, maxBuffer: Infinity,
}, done); }, done);
} }
else if (mode === 'HLS') else if (mode === 'HLS')
{ {
const cmd = command('ffmpeg') + ' ' + const cmd = command('ffmpeg') + ' ' +
'-i "' + rtmpInputPath + '" ' + '-i "' + rtmpInputPath + '" ' +
'-c copy -bsf:a aac_adtstoasc ' + '-c copy -bsf:a aac_adtstoasc ' +
'"' + filePath + '.mp4"'; '"' + filePath + '.mp4"';
childProcess.exec(cmd, { childProcess.exec(cmd,
maxBuffer: Infinity, {
}, done); maxBuffer: Infinity,
} }, done);
else }
{ else
log.error('No such mode: ' + mode); {
} log.error('No such mode: ' + mode);
}
} }
/** /**
@@ -44,7 +45,7 @@ function command(exe: string): string
{ {
if (os.platform() !== 'win32') if (os.platform() !== 'win32')
{ {
return exe; return exe;
} }
return '"' + path.join(__dirname, '../../bin/' + exe + '.exe') + '"'; return '"' + path.join(__dirname, '../../bin/' + exe + '.exe') + '"';

View File

@@ -1,10 +1,14 @@
{ {
"target": "es6",
"compilerOptions": { "compilerOptions": {
"declaration": true, "declaration": true,
"noImplicitAny": true, "noImplicitAny": true,
"removeComments": false, "removeComments": false,
"module": "commonjs", "module": "commonjs",
"outDir": "dist", "outDir": "dist",
"sourceMap": true "sourceMap": true,
"lib": [
"es2015"
]
} }
} }

View File

@@ -9,23 +9,22 @@
"curly": false, "curly": false,
"eofline": false, "eofline": false,
"forin": true, "forin": true,
"indent": [true, 2], "indent": [true, "spaces", 2],
"interface-name": true, "interface-name": true,
"jsdoc-format": true, "jsdoc-format": true,
"label-position": true, "label-position": true,
"max-line-length": [true, 140], "max-line-length": [true, 140],
"member-ordering": [true, "member-ordering": false,
"public-before-private", "no-shadowed-variable": false,
"static-before-instance",
"variables-before-functions"
],
"array-type": [true, "array"], "array-type": [true, "array"],
"trailing-comma": false,
"no-any": false, "no-any": false,
"no-arg": true, "no-arg": true,
"no-bitwise": true, "no-bitwise": true,
"space-within-parens": false,
"no-object-literal-type-assertion": false,
"no-console": [true, "no-console": [true,
"debug", "debug",
"info",
"time", "time",
"timeEnd", "timeEnd",
"trace" "trace"
@@ -42,7 +41,6 @@
"no-use-before-declare": false, "no-use-before-declare": false,
"no-var-requires": true, "no-var-requires": true,
"one-line": [true, "one-line": [true,
"check-catch",
"check-whitespace" "check-whitespace"
], ],
"quotemark": [true, "single"], "quotemark": [true, "single"],
@@ -67,6 +65,8 @@
"check-operator", "check-operator",
"check-separator", "check-separator",
"check-type" "check-type"
] ],
"object-literal-sort-keys": false,
"ordered-imports": false
} }
} }