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
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
|
<?php
//$Id$
/**
* @file
* Renders a video. This script is called concurrently by video_scheduler.php
* This script has to be launched with "php video_render.php nid vid"
* If you are not using sites/default/settings.php as your settings file,
* add an optional parameter for the drupal site url:
* "php video_render.php nid vid http://example.com/" or
* "php video_render.php nid vid http://example.org/drupal/"
*
* @author Fabio Varesano <fvaresano at yahoo dot it>
* porting to Drupal 6
* @author Heshan Wanigasooriya <heshan at heidisoft.com><heshanmw@gmail.com>
* @todo
*/
/**
* video_scheduler.php configuration
*/
// set to the ffmpeg executable
define('VIDEO_RENDERING_FFMPEG_PATH', '/home2/heidisof/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);
// nice value to append at the beginning of the command
define('VIDEO_RENDERING_NICE', 'nice -n 19');
/**
* video_scheduler.php configuration ends.
* DO NOT EDIT BELOW THIS LINE
*/
/**
* Define some constants
*/
define('VIDEO_RENDERING_PENDING', 1);
define('VIDEO_RENDERING_ACTIVE', 5);
define('VIDEO_RENDERING_COMPLETE', 10);
define('VIDEO_RENDERING_FAILED', 20);
if (isset($_SERVER['argv'][3])) {
$url = parse_url($_SERVER['argv'][3]);
$_SERVER['SCRIPT_NAME'] = $url['path'];
$_SERVER['HTTP_HOST'] = $url['host'];
}
include_once('./includes/bootstrap.inc');
//module_load_include('/includes/bootstrap.inc', 'video_render', 'includes/bootstrap');
//
// 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'])) {
if($_SERVER['argc'] < 3) { // check for command line arguments
watchdog('video_render', 'Incorrect parameters to the video_render.php script.', WATCHDOG_ERROR);
print t('Incorrect parameters');
}
else {
video_render_main();
}
}
else {
print t('This script is only executable from the command line.');
die();
}
print("\n");
function video_render_main() {
// get parameters passed from command line
$nid = $_SERVER['argv'][1];
$vid = $_SERVER['argv'][2];
// set the status to active
_video_render_job_change_status($nid, $vid, VIDEO_RENDERING_ACTIVE);
// load the job object
$job = _video_render_load_job($nid, $vid, VIDEO_RENDERING_ACTIVE);
if($job == NULL) {
watchdog('video_render', 'video_render.php has been called with an invalid job resource. exiting.');
die;
}
$command = _video_render_get_command($job);
//print('executing ' . $command); die;
watchdog('video_render', '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) || !filesize($job->convfile)) {
watchdog('video_render', 'video conversion failed. ffmpeg reported the following output: ' . $command_output, WATCHDOG_ERROR);
_video_render_set_video_encoded_fid($job->nid, $job->vid, -1);
_video_render_job_change_status($job->nid, $job->vid, VIDEO_RENDERING_FAILED);
}
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') .'/';
// the above no more works as token supports - use dirname
$dest_dir = dirname($job->origfile) . '/';
if (file_copy($file, $dest_dir)) {
//$file->fid = db_next_id('{files}_fid');
//print_r($file);
db_query("INSERT INTO {files} (fid, uid, filename, filepath, filemime, filesize) VALUES (%d, %d, '%s', '%s', '%s', %d)", $file->fid, $job->uid, $file->filename, $file->filepath, $file->filemime, $file->filesize);
// to know other modules of fid
$file->fid = db_last_insert_id('files', 'fid');
db_query("INSERT INTO {video_upload} (vid, nid, fid) VALUES (%d, %d, %d)", $job->vid, $job->vid, $file->fid);
// update the video table
db_query('UPDATE {video} SET vidfile = "%s", videox = %d, videoy = %d WHERE nid=%d AND vid=%d', "", $job->calculatedx, $job->calculatedy, $job->nid, $job->vid);
// update the video_encoded_fid in video serial data
_video_render_set_video_encoded_fid($job->nid, $job->vid, $file->fid);
_video_render_job_change_status($job->nid, $job->vid, VIDEO_RENDERING_COMPLETE);
watchdog('video_render', 'successfully converted %orig to %dest', array('%orig' => $job->origfile, '%dest' => $file->filepath));
// delete the temp file
unlink($job->convfile);
}
else {
// get the username of the process owner
$ownerarray = posix_getpwuid(posix_getuid());
$owner=$ownerarray['name'];
// get the username of the destination folder owner
$fownerarray = posix_getpwuid(fileowner($dest_dir));
$fowner=$fownerarray['name'];
// get destination folder permissions
$perms = substr(sprintf('%o', fileperms($dest_dir)), -4);
watchdog('video_render', 'error moving video %vid_file with nid = %nid to %dir the final directory. Check folder permissions.<br />The script was run by %uname .<br />The folder owner is %fowner .<br />The folder permissions are %perms .', array('%vid_file' => $job->origfile, '%nid' => $job->nid, '%dir' => $dest_dir, '%uname' => $owner, '%fowner' => $fowner, '%perms' => $perms), WATCHDOG_ERROR);
_video_render_set_video_encoded_fid($job->nid, $job->vid, -1);
_video_render_job_change_status($job->nid, $job->vid, VIDEO_RENDERING_FAILED);
}
}
}
/**
* Set the video_encoded_fid in the video table
* We store -1 as video_encoded_fid if the encoding failed
*/
function _video_render_set_video_encoded_fid($nid, $vid, $encoded_fid) {
db_lock_table('video');
$node = db_fetch_object(db_query("SELECT serialized_data FROM {video} WHERE nid = %d AND vid = %d", $nid, $vid));
$node->serial_data = unserialize($node->serialized_data);
$node->serial_data['video_encoded_fid'] = $encoded_fid;
$node->serialized_data = serialize($node->serial_data);
db_query("UPDATE {video} SET serialized_data = '%s' WHERE nid = %d AND vid = %d", $node->serialized_data, $nid, $vid);
db_unlock_tables();
}
/**
* 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_cvr_audio_bitrate', 64);
$videobitrate = variable_get('video_ffmpeg_helper_auto_cvr_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_cvr_options', '-y -i %videofile -f flv -ar 22050 -ab %audiobitrate -s %size -b %videobitrate -qscale 1 %convertfile'));
// set to the converted file output
$job->convfile = $convfile;
return VIDEO_RENDERING_NICE . " $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_cvr_width', 400);
$height = $def_width * ($job->videoy / $job->videox); // do you remember proportions?? :-)
$height = round($height);
// add one if odd
if($height % 2) {
$height++;
}
$job->calculatedx = $def_width;
$job->calculatedy = $height;
return $def_width . 'x' . $height;
}
/**
* Load a job
*/
function _video_render_load_job($nid, $vid, $status) {
$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 AND n.nid = %d AND n.vid = %d', $status, $nid, $vid);
return db_fetch_object($result);
}
/**
* Change the status to $status of the job having nid=$nid and vid=$vid
*/
function _video_render_job_change_status($nid, $vid, $status) {
$result = db_query('UPDATE {video_rendering} SET status = %d WHERE nid = %d AND vid = %d', $status, $nid, $vid);
}
?>
|