]> git.p6c8.net - jirafeau.git/blob - lib/functions.php
d70a17c77826715cfcc846e6e96f113c419d38bc
[jirafeau.git] / lib / functions.php
1 <?php
2 /*
3 * Jirafeau, your web file repository
4 * Copyright (C) 2008 Julien "axolotl" BERNARD <axolotl@magieeternelle.org>
5 * Copyright (C) 2012 Jerome Jutteau <j.jutteau@gmail.com>
6 *
7 * This program is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU Affero General Public License as
9 * published by the Free Software Foundation, either version 3 of the
10 * License, or (at your option) any later version.
11 *
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU Affero General Public License for more details.
16 *
17 * You should have received a copy of the GNU Affero General Public License
18 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 */
20
21 /**
22 * Transform a string in a path by seperating each letters by a '/'.
23 * @return path finishing with a '/'
24 */
25 function
26 s2p ($s)
27 {
28 $p = '';
29 for ($i = 0; $i < strlen ($s); $i++)
30 $p .= $s{$i} . '/';
31 return $p;
32 }
33
34 /**
35 * Convert base 16 to base 64
36 * @returns A string based on 64 characters (0-9, a-z, A-Z, "-" and "_")
37 */
38 function
39 base_16_to_64 ($num)
40 {
41 $m = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ-_';
42 $hex2bin = array ('0000', # 0
43 '0001', # 1
44 '0010', # 2
45 '0011', # 3
46 '0100', # 4
47 '0101', # 5
48 '0110', # 6
49 '0111', # 7
50 '1000', # 8
51 '1001', # 9
52 '1010', # a
53 '1011', # b
54 '1100', # c
55 '1101', # d
56 '1110', # e
57 '1111'); # f
58 $o = '';
59 $b = '';
60 $i = 0;
61 # Convert long hex string to bin.
62 $size = strlen ($num);
63 for ($i = 0; $i < $size; $i++)
64 $b .= $hex2bin{hexdec ($num{$i})};
65 # Convert long bin to base 64.
66 $size *= 4;
67 for ($i = $size - 6; $i >= 0; $i -= 6)
68 $o = $m{bindec (substr ($b, $i, 6))} . $o;
69 # Some few bits remaining ?
70 if ($i < 0 && $i > -6)
71 $o = $m{bindec (substr ($b, 0, $i + 6))} . $o;
72 return $o;
73 }
74
75 /**
76 * Generate a random code.
77 * @param $l code length
78 * @return random code.
79 */
80 function
81 jirafeau_gen_random ($l)
82 {
83 if ($l <= 0)
84 return 42;
85
86 $code="";
87 for ($i = 0; $i < $l; $i++)
88 $code .= dechex (rand (0, 15));
89
90 return $code;
91 }
92
93 function
94 jirafeau_human_size ($octets)
95 {
96 $u = array ('B', 'KB', 'MB', 'GB', 'TB');
97 $o = max ($octets, 0);
98 $p = min (floor (($o ? log ($o) : 0) / log (1024)), count ($u) - 1);
99 $o /= pow (1024, $p);
100 return round ($o, 1) . $u[$p];
101 }
102
103 function
104 jirafeau_clean_rm_link ($link)
105 {
106 $p = s2p ("$link");
107 if (file_exists (VAR_LINKS . $p . $link))
108 unlink (VAR_LINKS . $p . $link);
109 $parse = VAR_LINKS . $p;
110 $scan = array();
111 while (file_exists ($parse)
112 && ($scan = scandir ($parse))
113 && count ($scan) == 2 // '.' and '..' folders => empty.
114 && basename ($parse) != basename (VAR_LINKS))
115 {
116 rmdir ($parse);
117 $parse = substr ($parse, 0, strlen($parse) - strlen(basename ($parse)) - 1);
118 }
119 }
120
121 function
122 jirafeau_clean_rm_file ($md5)
123 {
124 $p = s2p ("$md5");
125 if (file_exists (VAR_FILES . $p . $md5))
126 unlink (VAR_FILES . $p . $md5);
127 if (file_exists (VAR_FILES . $p . $md5 . '_count'))
128 unlink (VAR_FILES . $p . $md5 . '_count');
129 $parse = VAR_FILES . $p;
130 $scan = array();
131 while (file_exists ($parse)
132 && ($scan = scandir ($parse))
133 && count ($scan) == 2 // '.' and '..' folders => empty.
134 && basename ($parse) != basename (VAR_FILES))
135 {
136 rmdir ($parse);
137 $parse = substr ($parse, 0, strlen($parse) - strlen(basename ($parse)) - 1);
138 }
139 }
140
141 /**
142 * transforms a php.ini string representing a value in an integer
143 * @param $value the value from php.ini
144 * @returns an integer for this value
145 */
146 function jirafeau_ini_to_bytes ($value)
147 {
148 $modifier = substr ($value, -1);
149 $bytes = substr ($value, 0, -1);
150 switch (strtoupper ($modifier))
151 {
152 case 'P':
153 $bytes *= 1024;
154 case 'T':
155 $bytes *= 1024;
156 case 'G':
157 $bytes *= 1024;
158 case 'M':
159 $bytes *= 1024;
160 case 'K':
161 $bytes *= 1024;
162 default:
163 break;
164 }
165 return $bytes;
166 }
167
168 /**
169 * gets the maximum upload size according to php.ini
170 * @returns the maximum upload size in bytes
171 */
172 function
173 jirafeau_get_max_upload_size_bytes ()
174 {
175 return min (jirafeau_ini_to_bytes (ini_get ('post_max_size')),
176 jirafeau_ini_to_bytes (ini_get ('upload_max_filesize')));
177 }
178
179 /**
180 * gets the maximum upload size according to php.ini
181 * @returns the maximum upload size string
182 */
183 function
184 jirafeau_get_max_upload_size ()
185 {
186 return jirafeau_human_size(
187 min (jirafeau_ini_to_bytes (ini_get ('post_max_size')),
188 jirafeau_ini_to_bytes (ini_get ('upload_max_filesize'))));
189 }
190
191 /**
192 * gets a string explaining the error
193 * @param $code the error code
194 * @returns a string explaining the error
195 */
196 function
197 jirafeau_upload_errstr ($code)
198 {
199 switch ($code)
200 {
201 case UPLOAD_ERR_INI_SIZE:
202 case UPLOAD_ERR_FORM_SIZE:
203 return t('Your file exceeds the maximum authorized file size. ');
204 break;
205
206 case UPLOAD_ERR_PARTIAL:
207 case UPLOAD_ERR_NO_FILE:
208 return
209 t
210 ('Your file was not uploaded correctly. You may succeed in retrying. ');
211 break;
212
213 case UPLOAD_ERR_NO_TMP_DIR:
214 case UPLOAD_ERR_CANT_WRITE:
215 case UPLOAD_ERR_EXTENSION:
216 return t('Internal error. You may not succeed in retrying. ');
217 break;
218
219 default:
220 break;
221 }
222 return t('Unknown error. ');
223 }
224
225 /** Remove link and it's file
226 * @param $link the link's name (hash)
227 */
228
229 function
230 jirafeau_delete_link ($link)
231 {
232 $l = jirafeau_get_link ($link);
233 if (!count ($l))
234 return;
235
236 jirafeau_clean_rm_link ($link);
237
238 $md5 = $l['md5'];
239 $p = s2p ("$md5");
240
241 $counter = 1;
242 if (file_exists (VAR_FILES . $p . $md5. '_count'))
243 {
244 $content = file (VAR_FILES . $p . $md5. '_count');
245 $counter = trim ($content[0]);
246 }
247 $counter--;
248
249 if ($counter >= 1)
250 {
251 $handle = fopen (VAR_FILES . $p . $md5. '_count', 'w');
252 fwrite ($handle, $counter);
253 fclose ($handle);
254 }
255
256 if ($counter == 0)
257 jirafeau_clean_rm_file ($md5);
258 }
259
260 /**
261 * Delete a file and it's links.
262 */
263 function
264 jirafeau_delete_file ($md5)
265 {
266 $count = 0;
267 /* Get all links files. */
268 $stack = array (VAR_LINKS);
269 while (($d = array_shift ($stack)) && $d != NULL)
270 {
271 $dir = scandir ($d);
272
273 foreach ($dir as $node)
274 {
275 if (strcmp ($node, '.') == 0 || strcmp ($node, '..') == 0 ||
276 preg_match ('/\.tmp/i', "$node"))
277 continue;
278
279 if (is_dir ($d . $node))
280 {
281 /* Push new found directory. */
282 $stack[] = $d . $node . '/';
283 }
284 elseif (is_file ($d . $node))
285 {
286 /* Read link informations. */
287 $l = jirafeau_get_link (basename ($node));
288 if (!count ($l))
289 continue;
290 if ($l['md5'] == $md5)
291 {
292 $count++;
293 jirafeau_delete_link ($node);
294 }
295 }
296 }
297 }
298 jirafeau_clean_rm_file ($md5);
299 return $count;
300 }
301
302 /**
303 * handles an uploaded file
304 * @param $file the file struct given by $_FILE[]
305 * @param $one_time_download is the file a one time download ?
306 * @param $key if not empty, protect the file with this key
307 * @param $time the time of validity of the file
308 * @param $ip uploader's ip
309 * @returns an array containing some information
310 * 'error' => information on possible errors
311 * 'link' => the link name of the uploaded file
312 * 'delete_link' => the link code to delete file
313 */
314 function
315 jirafeau_upload ($file, $one_time_download, $key, $time, $ip)
316 {
317 if (empty ($file['tmp_name']) || !is_uploaded_file ($file['tmp_name']))
318 {
319 return (array(
320 'error' =>
321 array ('has_error' => true,
322 'why' => jirafeau_upload_errstr ($file['error'])),
323 'link' => '',
324 'delete_link' => ''));
325 }
326
327 /* array representing no error */
328 $noerr = array ('has_error' => false, 'why' => '');
329
330 /* file informations */
331 $md5 = md5_file ($file['tmp_name']);
332 $name = str_replace (NL, '', trim ($file['name']));
333 $mime_type = $file['type'];
334 $size = $file['size'];
335
336 /* does file already exist ? */
337 $rc = false;
338 $p = s2p ("$md5");
339 if (file_exists (VAR_FILES . $p . $md5))
340 {
341 $rc = unlink ($file['tmp_name']);
342 }
343 elseif ((file_exists (VAR_FILES . $p) || @mkdir (VAR_FILES . $p, 0755, true))
344 && move_uploaded_file ($file['tmp_name'], VAR_FILES . $p . $md5))
345 {
346 $rc = true;
347 }
348 if (!$rc)
349 {
350 return (array(
351 'error' =>
352 array ('has_error' => true,
353 'why' => t('Internal error during file creation.')),
354 'link' =>'',
355 'delete_link' => ''));
356 }
357
358 /* Increment or create count file. */
359 $counter = 0;
360 if (file_exists (VAR_FILES . $p . $md5 . '_count'))
361 {
362 $content = file (VAR_FILES . $p . $md5. '_count');
363 $counter = trim ($content[0]);
364 }
365 $counter++;
366 $handle = fopen (VAR_FILES . $p . $md5. '_count', 'w');
367 fwrite ($handle, $counter);
368 fclose ($handle);
369
370 /* Create delete code. */
371 $delete_link_code = jirafeau_gen_random (8);
372
373 /* md5 password or empty */
374 $password = '';
375 if (!empty ($key))
376 $password = md5 ($key);
377
378 /* create link file */
379 $link_tmp_name = VAR_LINKS . $md5 . rand (0, 10000) . ' .tmp';
380 $handle = fopen ($link_tmp_name, 'w');
381 fwrite ($handle,
382 $name . NL. $mime_type . NL. $size . NL. $password . NL. $time .
383 NL . $md5. NL . ($one_time_download ? 'O' : 'R') . NL . date ('U') .
384 NL . $ip . NL. $delete_link_code . NL);
385 fclose ($handle);
386 $md5_link = base_16_to_64 (md5_file ($link_tmp_name));
387 $l = s2p ("$md5_link");
388 if (!@mkdir (VAR_LINKS . $l, 0755, true) ||
389 !rename ($link_tmp_name, VAR_LINKS . $l . $md5_link))
390 {
391 if (file_exists ($link_tmp_name))
392 unlink ($link_tmp_name);
393
394 $counter--;
395 if ($counter >= 1)
396 {
397 $handle = fopen (VAR_FILES . $p . $md5. '_count', 'w');
398 fwrite ($handle, $counter);
399 fclose ($handle);
400 }
401 else
402 {
403 jirafeau_clean_rm_file ($md5_link);
404 }
405 return (array(
406 'error' =>
407 array ('has_error' => true,
408 'why' => t('Internal error during file creation. ')),
409 'link' =>'',
410 'delete_link' => ''));
411 }
412 return (array ('error' => $noerr,
413 'link' => $md5_link,
414 'delete_link' => $delete_link_code));
415 }
416
417 /**
418 * tells if a mime-type is viewable in a browser
419 * @param $mime the mime type
420 * @returns a boolean telling if a mime type is viewable
421 */
422 function
423 jirafeau_is_viewable ($mime)
424 {
425 if (!empty ($mime))
426 {
427 /* Actually, verify if mime-type is an image or a text. */
428 $viewable = array ('image', 'text');
429 $decomposed = explode ('/', $mime);
430 return in_array ($decomposed[0], $viewable);
431 }
432 return false;
433 }
434
435 // Error handling functions.
436 //! Global array that contains all registered errors.
437 $error_list = array ();
438
439 /**
440 * Adds an error to the list of errors.
441 * @param $title the error's title
442 * @param $description is a human-friendly description of the problem.
443 */
444 function
445 add_error ($title, $description)
446 {
447 global $error_list;
448 $error_list[] = '<p>' . $title. '<br />' . $description. '</p>';
449 }
450
451 /**
452 * Informs whether any error has been registered yet.
453 * @return true if there are errors.
454 */
455 function
456 has_error ()
457 {
458 global $error_list;
459 return !empty ($error_list);
460 }
461
462 /**
463 * Displays all the errors.
464 */
465 function
466 show_errors ()
467 {
468 if (has_error ())
469 {
470 global $error_list;
471 echo '<div class="error">';
472 foreach ($error_list as $error)
473 {
474 echo $error;
475 }
476 echo '</div>';
477 }
478 }
479
480 function check_errors ()
481 {
482 if (file_exists (JIRAFEAU_ROOT . 'install.php')
483 && !file_exists (JIRAFEAU_ROOT . 'lib/config.local.php'))
484 {
485 header('Location: install.php');
486 exit;
487 }
488
489 /* check if the destination dirs are writable */
490 $writable = is_writable (VAR_FILES) && is_writable (VAR_LINKS);
491
492 /* Checking for errors. */
493 if (!is_writable (VAR_FILES))
494 add_error (t('The file directory is not writable!'), VAR_FILES);
495
496 if (!is_writable (VAR_LINKS))
497 add_error (t('The link directory is not writable!'), VAR_LINKS);
498
499 if (!is_writable (VAR_ASYNC))
500 add_error (t('The async directory is not writable!'), VAR_ASYNC);
501
502 /* Check if the install.php script is still in the directory. */
503 if (file_exists (JIRAFEAU_ROOT . 'install.php'))
504 add_error (t('Installer script still present'),
505 t('Please make sure to delete the installer script ' .
506 '"install.php" before continuing.'));
507 }
508
509 /**
510 * Read link informations
511 * @return array containing informations.
512 */
513 function
514 jirafeau_get_link ($hash)
515 {
516 $out = array ();
517 $link = VAR_LINKS . s2p ("$hash") . $hash;
518
519 if (!file_exists ($link))
520 return $out;
521
522 $c = file ($link);
523 $out['file_name'] = trim ($c[0]);
524 $out['mime_type'] = trim ($c[1]);
525 $out['file_size'] = trim ($c[2]);
526 $out['key'] = trim ($c[3], NL);
527 $out['time'] = trim ($c[4]);
528 $out['md5'] = trim ($c[5]);
529 $out['onetime'] = trim ($c[6]);
530 $out['upload_date'] = trim ($c[7]);
531 $out['ip'] = trim ($c[8]);
532 $out['link_code'] = trim ($c[9]);
533
534 return $out;
535 }
536
537 /**
538 * List files in admin interface.
539 */
540 function
541 jirafeau_admin_list ($name, $file_hash, $link_hash)
542 {
543 echo '<fieldset><legend>';
544 if (!empty ($name))
545 echo t('Filename') . ": $name ";
546 if (!empty ($file_hash))
547 echo t('file') . ": $file_hash ";
548 if (!empty ($link_hash))
549 echo t('link') . ": $link_hash ";
550 if (empty ($name) && empty ($file_hash) && empty ($link_hash))
551 echo t('List all files');
552 echo '</legend>';
553 echo '<table>';
554 echo '<tr>';
555 echo '<td>' . t('Filename') . '</td>';
556 echo '<td>' . t('Type') . '</td>';
557 echo '<td>' . t('Size') . '</td>';
558 echo '<td>' . t('Expire') . '</td>';
559 echo '<td>' . t('Onetime') . '</td>';
560 echo '<td>' . t('Upload date') . '</td>';
561 echo '<td>' . t('Origin') . '</td>';
562 echo '<td>' . t('Action') . '</td>';
563 echo '</tr>';
564
565 /* Get all links files. */
566 $stack = array (VAR_LINKS);
567 while (($d = array_shift ($stack)) && $d != NULL)
568 {
569 $dir = scandir ($d);
570 foreach ($dir as $node)
571 {
572 if (strcmp ($node, '.') == 0 || strcmp ($node, '..') == 0 ||
573 preg_match ('/\.tmp/i', "$node"))
574 continue;
575 if (is_dir ($d . $node))
576 {
577 /* Push new found directory. */
578 $stack[] = $d . $node . '/';
579 }
580 elseif (is_file ($d . $node))
581 {
582 /* Read link informations. */
583 $l = jirafeau_get_link ($node);
584 if (!count ($l))
585 continue;
586
587 /* Filter. */
588 if (!empty ($name) && !preg_match ("/$name/i", $l['file_name']))
589 continue;
590 if (!empty ($file_hash) && $file_hash != $l['md5'])
591 continue;
592 if (!empty ($link_hash) && $link_hash != $node)
593 continue;
594 /* Print link informations. */
595 echo '<tr>';
596 echo '<td>' .
597 '<form action = "admin.php" method = "post">' .
598 '<input type = "hidden" name = "action" value = "download"/>' .
599 '<input type = "hidden" name = "link" value = "' . $node . '"/>' .
600 '<input type = "submit" value = "' . $l['file_name'] . '" />' .
601 '</form>';
602 echo '</td>';
603 echo '<td>' . $l['mime_type'] . '</td>';
604 echo '<td>' . jirafeau_human_size ($l['file_size']) . '</td>';
605 echo '<td>' . ($l['time'] == -1 ? '' : strftime ('%c', $l['time'])) .
606 '</td>';
607 echo '<td>' . $l['onetime'] . '</td>';
608 echo '<td>' . strftime ('%c', $l['upload_date']) . '</td>';
609 echo '<td>' . $l['ip'] . '</td>';
610 echo '<td>' .
611 '<form action = "admin.php" method = "post">' .
612 '<input type = "hidden" name = "action" value = "delete_link"/>' .
613 '<input type = "hidden" name = "link" value = "' . $node . '"/>' .
614 '<input type = "submit" value = "' . t('Del link') . '" />' .
615 '</form>' .
616 '<form action = "admin.php" method = "post">' .
617 '<input type = "hidden" name = "action" value = "delete_file"/>' .
618 '<input type = "hidden" name = "md5" value = "' . $l['md5'] . '"/>' .
619 '<input type = "submit" value = "' . t('Del file and links') . '" />' .
620 '</form>' .
621 '</td>';
622 echo '</tr>';
623 }
624 }
625 }
626 echo '</table></fieldset>';
627 }
628
629 /**
630 * Clean expired files.
631 * @return number of cleaned files.
632 */
633 function
634 jirafeau_admin_clean ()
635 {
636 $count = 0;
637 /* Get all links files. */
638 $stack = array (VAR_LINKS);
639 while (($d = array_shift ($stack)) && $d != NULL)
640 {
641 $dir = scandir ($d);
642
643 foreach ($dir as $node)
644 {
645 if (strcmp ($node, '.') == 0 || strcmp ($node, '..') == 0 ||
646 preg_match ('/\.tmp/i', "$node"))
647 continue;
648
649 if (is_dir ($d . $node))
650 {
651 /* Push new found directory. */
652 $stack[] = $d . $node . '/';
653 }
654 elseif (is_file ($d . $node))
655 {
656 /* Read link informations. */
657 $l = jirafeau_get_link (basename ($node));
658 if (!count ($l))
659 continue;
660 $p = s2p ($l['md5']);
661 if ($l['time'] > 0 && $l['time'] < time () || // expired
662 !file_exists (VAR_FILES . $p . $l['md5']) || // invalid
663 !file_exists (VAR_FILES . $p . $l['md5'] . '_count')) // invalid
664 {
665 jirafeau_delete_link ($node);
666 $count++;
667 }
668 }
669 }
670 }
671 return $count;
672 }
673
674
675 /**
676 * Clean old async transferts.
677 * @return number of cleaned files.
678 */
679 function
680 jirafeau_admin_clean_async ()
681 {
682 $count = 0;
683 /* Get all links files. */
684 $stack = array (VAR_ASYNC);
685 while (($d = array_shift ($stack)) && $d != NULL)
686 {
687 $dir = scandir ($d);
688
689 foreach ($dir as $node)
690 {
691 if (strcmp ($node, '.') == 0 || strcmp ($node, '..') == 0 ||
692 preg_match ('/\.tmp/i', "$node"))
693 continue;
694
695 if (is_dir ($d . $node))
696 {
697 /* Push new found directory. */
698 $stack[] = $d . $node . '/';
699 }
700 elseif (is_file ($d . $node))
701 {
702 /* Read async informations. */
703 $a = jirafeau_get_async_ref (basename ($node));
704 if (!count ($a))
705 continue;
706 /* Delete transferts older than 1 hour. */
707 if (date ('U') - $a['last_edited'] > 3600)
708 {
709 jirafeau_async_delete (basename ($node));
710 $count++;
711 }
712 }
713 }
714 }
715 return $count;
716 }
717 /**
718 * Read async transfert informations
719 * @return array containing informations.
720 */
721 function
722 jirafeau_get_async_ref ($ref)
723 {
724 $out = array ();
725 $refinfos = VAR_ASYNC . s2p ("$ref") . "$ref";
726
727 if (!file_exists ($refinfos))
728 return $out;
729
730 $c = file ($refinfos);
731 $out['file_name'] = trim ($c[0]);
732 $out['mime_type'] = trim ($c[1]);
733 $out['key'] = trim ($c[2], NL);
734 $out['time'] = trim ($c[3]);
735 $out['onetime'] = trim ($c[4]);
736 $out['ip'] = trim ($c[5]);
737 $out['last_edited'] = trim ($c[6]);
738 $out['next_code'] = trim ($c[7]);
739 return $out;
740 }
741
742 /**
743 * Delete async transfert informations
744 */
745 function
746 jirafeau_async_delete ($ref)
747 {
748 $p = s2p ("$ref");
749 if (file_exists (VAR_ASYNC . $p . $ref))
750 unlink (VAR_ASYNC . $p . $ref);
751 if (file_exists (VAR_ASYNC . $p . $ref . '_data'))
752 unlink (VAR_ASYNC . $p . $ref . '_data');
753 $parse = VAR_ASYNC . $p;
754 $scan = array();
755 while (file_exists ($parse)
756 && ($scan = scandir ($parse))
757 && count ($scan) == 2 // '.' and '..' folders => empty.
758 && basename ($parse) != basename (VAR_ASYNC))
759 {
760 rmdir ($parse);
761 $parse = substr ($parse, 0, strlen($parse) - strlen(basename ($parse)) - 1);
762 }
763 }
764
765 /**
766 * Init a new asynchronous upload.
767 * @param $finename Name of the file to send
768 * @param $one_time One time upload parameter
769 * @param $key eventual password (or blank)
770 * @param $time time limit
771 * @param $ip ip address of the client
772 * @return a string containing a temporary reference followed by a code or the string "Error"
773 */
774 function
775 jirafeau_async_init ($filename, $type, $one_time, $key, $time, $ip)
776 {
777 $res = 'Error';
778
779 /* Create temporary folder. */
780 $ref;
781 $p;
782 $code = jirafeau_gen_random (4);
783 do
784 {
785 $ref = jirafeau_gen_random (32);
786 $p = VAR_ASYNC . s2p ($ref);
787 } while (file_exists ($p));
788 @mkdir ($p, 0755, true);
789 if (!file_exists ($p))
790 {
791 echo "Error";
792 return;
793 }
794
795 /* md5 password or empty */
796 $password = '';
797 if (!empty ($key))
798 $password = md5 ($key);
799
800 /* Store informations. */
801 $p .= $ref;
802 $handle = fopen ($p, 'w');
803 fwrite ($handle,
804 str_replace (NL, '', trim ($filename)) . NL. trim ($type) . NL. $password . NL. $time . NL .
805 ($one_time ? 'O' : 'R') . NL . $ip . NL . date ('U') . NL .
806 $code . NL);
807 fclose ($handle);
808
809 return $ref . NL . $code ;
810 }
811
812 /**
813 * Append a piece of file on the asynchronous upload.
814 * @param $ref asynchronous upload reference
815 * @param $file piece of data
816 * @param $code client code for this operation
817 * @return a string containing a next code to use or the string "Error"
818 */
819 function
820 jirafeau_async_push ($ref, $data, $code)
821 {
822 /* Get async infos. */
823 $a = jirafeau_get_async_ref ($ref);
824
825 /* Check some errors. */
826 if (count ($a) == 0
827 || $a['next_code'] != "$code"
828 || empty ($data['tmp_name'])
829 || !is_uploaded_file ($data['tmp_name']))
830 return "Error";
831
832 $p = s2p ($ref);
833
834 /* Concatenate data. */
835 $r = fopen ($data['tmp_name'], 'r');
836 $w = fopen (VAR_ASYNC . $p . $ref . '_data', 'a');
837 while (!feof ($r))
838 {
839 if (fwrite ($w, fread ($r, 1024)) === false)
840 {
841 fclose ($r);
842 fclose ($w);
843 jirafeau_async_delete ($ref);
844 return "Error";
845 }
846 }
847 fclose ($r);
848 fclose ($w);
849 unlink ($data['tmp_name']);
850
851 /* Update async file. */
852 $code = jirafeau_gen_random (4);
853 $handle = fopen (VAR_ASYNC . $p . $ref, 'w');
854 fwrite ($handle,
855 $a['file_name'] . NL. $a['mime_type'] . NL. $a['key'] . NL .
856 $a['time'] . NL . $a['onetime'] . NL . $a['ip'] . NL .
857 date ('U') . NL . $code . NL);
858 fclose ($handle);
859 return $code;
860 }
861
862 /**
863 * Finalyze an asynchronous upload.
864 * @param $ref asynchronous upload reference
865 * @param $code client code for this operation
866 * @return a string containing the download reference followed by a delete code or the string "Error"
867 */
868 function
869 jirafeau_async_end ($ref, $code)
870 {
871 /* Get async infos. */
872 $a = jirafeau_get_async_ref ($ref);
873 if (count ($a) == 0
874 || $a['next_code'] != "$code")
875 return "Error";
876
877 /* Generate link infos. */
878 $p = VAR_ASYNC . s2p ($ref) . $ref . "_data";
879 if (!file_exists($p))
880 return "Error";
881 $md5 = md5_file ($p);
882 $size = filesize($p);
883 $np = s2p ($md5);
884 $delete_link_code = jirafeau_gen_random (8);
885
886 /* File already exist ? */
887 if (!file_exists (VAR_FILES . $np))
888 @mkdir (VAR_FILES . $np, 0755, true);
889 if (!file_exists (VAR_FILES . $np . $md5))
890 rename ($p, VAR_FILES . $np . $md5);
891
892 /* Increment or create count file. */
893 $counter = 0;
894 if (file_exists (VAR_FILES . $np . $md5 . '_count'))
895 {
896 $content = file (VAR_FILES . $np . $md5. '_count');
897 $counter = trim ($content[0]);
898 }
899 $counter++;
900 $handle = fopen (VAR_FILES . $np . $md5. '_count', 'w');
901 fwrite ($handle, $counter);
902 fclose ($handle);
903
904 /* Create link. */
905 $link_tmp_name = VAR_LINKS . $md5 . rand (0, 10000) . ' .tmp';
906 $handle = fopen ($link_tmp_name, 'w');
907 fwrite ($handle,
908 $a['file_name'] . NL . $a['mime_type'] . NL . $size . NL .
909 $a['key'] . NL . $a['time'] . NL . $md5 . NL . $a['onetime'] . NL .
910 date ('U') . NL . $a['ip'] . NL . $delete_link_code . NL);
911 fclose ($handle);
912 $md5_link = base_16_to_64 (md5_file ($link_tmp_name));
913 $l = s2p ("$md5_link");
914 if (!@mkdir (VAR_LINKS . $l, 0755, true) ||
915 !rename ($link_tmp_name, VAR_LINKS . $l . $md5_link))
916 echo "Error";
917
918 /* Clean async upload. */
919 jirafeau_async_delete ($ref);
920 return $md5_link . NL . $delete_link_code;
921 }
922 ?>

patrick-canterino.de