]> git.p6c8.net - jirafeau_mojo42.git/blob - lib/functions.php
87d2cff173a9e0542c7b718d520c7eb8b0845a1a
[jirafeau_mojo42.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 .
805 str_replace (NL, '', trim ($type)) . NL . $password . NL .
806 $time . NL . ($one_time ? 'O' : 'R') . NL . $ip . NL .
807 date ('U') . NL . $code . NL);
808 fclose ($handle);
809
810 return $ref . NL . $code ;
811 }
812
813 /**
814 * Append a piece of file on the asynchronous upload.
815 * @param $ref asynchronous upload reference
816 * @param $file piece of data
817 * @param $code client code for this operation
818 * @return a string containing a next code to use or the string "Error"
819 */
820 function
821 jirafeau_async_push ($ref, $data, $code)
822 {
823 /* Get async infos. */
824 $a = jirafeau_get_async_ref ($ref);
825
826 /* Check some errors. */
827 if (count ($a) == 0
828 || $a['next_code'] != "$code"
829 || empty ($data['tmp_name'])
830 || !is_uploaded_file ($data['tmp_name']))
831 return "Error";
832
833 $p = s2p ($ref);
834
835 /* Concatenate data. */
836 $r = fopen ($data['tmp_name'], 'r');
837 $w = fopen (VAR_ASYNC . $p . $ref . '_data', 'a');
838 while (!feof ($r))
839 {
840 if (fwrite ($w, fread ($r, 1024)) === false)
841 {
842 fclose ($r);
843 fclose ($w);
844 jirafeau_async_delete ($ref);
845 return "Error";
846 }
847 }
848 fclose ($r);
849 fclose ($w);
850 unlink ($data['tmp_name']);
851
852 /* Update async file. */
853 $code = jirafeau_gen_random (4);
854 $handle = fopen (VAR_ASYNC . $p . $ref, 'w');
855 fwrite ($handle,
856 $a['file_name'] . NL. $a['mime_type'] . NL. $a['key'] . NL .
857 $a['time'] . NL . $a['onetime'] . NL . $a['ip'] . NL .
858 date ('U') . NL . $code . NL);
859 fclose ($handle);
860 return $code;
861 }
862
863 /**
864 * Finalyze an asynchronous upload.
865 * @param $ref asynchronous upload reference
866 * @param $code client code for this operation
867 * @return a string containing the download reference followed by a delete code or the string "Error"
868 */
869 function
870 jirafeau_async_end ($ref, $code)
871 {
872 /* Get async infos. */
873 $a = jirafeau_get_async_ref ($ref);
874 if (count ($a) == 0
875 || $a['next_code'] != "$code")
876 return "Error";
877
878 /* Generate link infos. */
879 $p = VAR_ASYNC . s2p ($ref) . $ref . "_data";
880 if (!file_exists($p))
881 return "Error";
882 $md5 = md5_file ($p);
883 $size = filesize($p);
884 $np = s2p ($md5);
885 $delete_link_code = jirafeau_gen_random (8);
886
887 /* File already exist ? */
888 if (!file_exists (VAR_FILES . $np))
889 @mkdir (VAR_FILES . $np, 0755, true);
890 if (!file_exists (VAR_FILES . $np . $md5))
891 rename ($p, VAR_FILES . $np . $md5);
892
893 /* Increment or create count file. */
894 $counter = 0;
895 if (file_exists (VAR_FILES . $np . $md5 . '_count'))
896 {
897 $content = file (VAR_FILES . $np . $md5. '_count');
898 $counter = trim ($content[0]);
899 }
900 $counter++;
901 $handle = fopen (VAR_FILES . $np . $md5. '_count', 'w');
902 fwrite ($handle, $counter);
903 fclose ($handle);
904
905 /* Create link. */
906 $link_tmp_name = VAR_LINKS . $md5 . rand (0, 10000) . ' .tmp';
907 $handle = fopen ($link_tmp_name, 'w');
908 fwrite ($handle,
909 $a['file_name'] . NL . $a['mime_type'] . NL . $size . NL .
910 $a['key'] . NL . $a['time'] . NL . $md5 . NL . $a['onetime'] . NL .
911 date ('U') . NL . $a['ip'] . NL . $delete_link_code . NL);
912 fclose ($handle);
913 $md5_link = base_16_to_64 (md5_file ($link_tmp_name));
914 $l = s2p ("$md5_link");
915 if (!@mkdir (VAR_LINKS . $l, 0755, true) ||
916 !rename ($link_tmp_name, VAR_LINKS . $l . $md5_link))
917 echo "Error";
918
919 /* Clean async upload. */
920 jirafeau_async_delete ($ref);
921 return $md5_link . NL . $delete_link_code;
922 }
923 ?>

patrick-canterino.de