1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
|
<?php
// $Id$
/**
* @file
* Implement video rendering scheduling.
*
* @author Fabio Varesano <fvaresano at yahoo dot it>
*/
/**
* video_render.php configuration
*/
// set to the ffmpeg executable
define('VIDEO_RENDERING_FFMPEG_PATH', '/usr/bin/ffmpeg');
// set to the temp file path.
//IMPORTANT: the user who runs this script must have permissions to create files there. If this is not the case the default php temporary folder will be used.
define('VIDEO_RENDERING_TEMP_PATH', '/tmp/video');
// number of conversion jobs active at the same time
define('VIDEO_RENDERING_FFMPEG_INSTANCES', 5);
/**
* video_render.php configuration ends.
* DO NOT EDIT BELOW THIS LINE
*/
/**
* Define some constants
*/
define('VIDEO_RENDERING_PENGING', 0);
define('VIDEO_RENDERING_ACTIVE', 5);
define('VIDEO_RENDERING_COMPLETE', 10);
include_once './includes/bootstrap.inc';
// disable error reporting for bootstrap process
error_reporting(E_ERROR);
// let's bootstrap: we will be able to use drupal apis
drupal_bootstrap(DRUPAL_BOOTSTRAP_FULL);
// enable full error reporting again
error_reporting(E_ALL);
// allow execution only from the command line!
if(empty($_SERVER['REQUEST_METHOD'])) {
video_render_main();
}
else {
print t('This script is only executable from the command line.');
die();
}
/**
* Main for video_render.php
*/
function video_render_main() {
if($jobs = video_render_select()) {
foreach ($jobs as $job) {
video_render_start($job);
}
}
else {
watchdog('video_render', t('no video conversion jobs to schedule.'));
}
}
/**
* Starts rendering for a job
*/
function video_render_start($job) {
// print_r($job);
//db_query('DELETE FROM {video_rendering} WHERE nid=%d AND vid=%d', $job->nid, $job->vid);
$command = _video_render_get_command($job);
print('executing ' . $command);
//execute the command
ob_start();
passthru($command." 2>&1", $command_return);
$command_output = ob_get_contents();
ob_end_clean();
print $command_output;
if (!file_exists($job->convfile)) {
watchdog('video_render', t('video conversion failed. ffmpeg reported the following output: ' . $command_output, WATCHDOG_ERROR));
}
else {
// move the video to the definitive location
$file = array(
'filename' => basename($job->origfile . ".flv"),
'filemime' => 'application/octet-stream', // is there something better???
'filesize' => filesize($job->convfile),
'filepath' => $job->convfile,
'nid' => $job->nid,
);
$file = ((object) $file);
print_r($file);
$dest_dir = variable_get('video_upload_default_path', 'videos') .'/';
if (file_copy($file, file_directory_path() . '/' . $dest_dir)) {
$file->fid = db_next_id('{files}_fid');
print_r($file);
db_query("INSERT INTO {files} (fid, nid, filename, filepath, filemime, filesize) VALUES (%d, %d, '%s', '%s', '%s', %d)", $file->fid, $job->nid, $file->filename, $file->filepath, $file->filemime, $file->filesize);
db_query("INSERT INTO {file_revisions} (fid, vid, list, description) VALUES (%d, %d, %d, '%s')", $file->fid, $job->vid, $file->list, $file->description);
// set vidfile to "" to let video_upload overwrite it with the latest uploaded file
db_query('UPDATE {video} SET vidfile = "%s" WHERE nid=%d AND vid=%d', "", $job->nid, $job->vid);
}
else {
watchdog('video_render', t('error moving video to the final directory. Check folder permissions.'), WATCHDOG_ERROR);
}
}
}
/**
* Select VIDEO_RENDERING_FFMPEG_INSTANCES jobs from the queue
*
* @return an array containing jobs
*/
function video_render_select() {
$result = db_query('SELECT * FROM {video_rendering} vr INNER JOIN {node} n ON vr.vid = n.vid INNER JOIN {video} v ON n.vid = v.vid WHERE n.nid = v.nid AND vr.nid = n.nid AND vr.status = %d ORDER BY n.created', VIDEO_RENDERING_PENDING);
// TODO: order jobs by priority
$jobs = array();
$i = 0;
$count = db_num_rows($result);
while($i < $count && $i < VIDEO_RENDERING_FFMPEG_INSTANCES) {
$jobs[] = db_fetch_object($result);
$i++;
}
return $jobs;
}
/**
* Get a string cointaining the command to be executed including options
*/
function _video_render_get_command(&$job) {
$videofile = escapeshellarg($job->origfile); // escape file name for safety
$convfile = tempnam(VIDEO_RENDERING_TEMP_PATH, 'video-rendering');
$audiobitrate = variable_get('video_ffmpeg_helper_auto_converter_audio_bitrate', 64);
$videobitrate = variable_get('video_ffmpeg_helper_auto_converter_video_bitrate', 200);
$size = _video_render_get_size($job);
$converter = VIDEO_RENDERING_FFMPEG_PATH;
$options = preg_replace(array('/%videofile/', '/%convertfile/', '/%audiobitrate/', '/%size/', '/%videobitrate/'), array($videofile, $convfile, $audiobitrate, $size, $videobitrate), variable_get('video_ffmpeg_helper_auto_converter_options', '-y -i %videofile -f flv -ar 22050 -ab %audiobitrate -s %size -b %videobitrate %convertfile'));
// set to the converted file output
$job->convfile = $convfile;
return "$converter $options";
}
/**
* Calculate the converted video size basing on the width set on administration.
* Aspect ration is maintained.
*/
function _video_render_get_size(&$job) {
$def_width = variable_get('video_ffmpeg_helper_auto_converter_width', 400);
$x = $job->videox;
$y = $job->videoy;
$height = $def_width * ($y / $x); // do you remember proportions?? :-)
return $def_width . 'x' . $height;
}
?>
|
