summaryrefslogtreecommitdiff
path: root/modules/server_add/helpers/server_add_task.php
blob: 2812777d44d5a23cff9f9bd0bbe70b2501bac33b (plain)
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
<?php defined("SYSPATH") or die("No direct script access.");
/**
 * Gallery - a web based photo album viewer and editor
 * Copyright (C) 2000-2008 Bharat Mediratta
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or (at
 * your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street - Fifth Floor, Boston, MA  02110-1301, USA.
 */
class server_add_task_Core {
  static function available_tasks() {
    // Return empty array so nothing appears in the maintenance screen
    return array();
  }

  static function add_from_server($task) {
    $context = unserialize($task->context);
    try {
      $paths = array_keys(unserialize(module::get_var("server_add", "authorized_paths")));
      $path = $paths[$context["next_path"]];
      $file = $context["files"][$path][$context["position"]];
      $parent = ORM::factory("item", $file["parent_id"]);
      access::required("server_add", $parent);
      if (!$parent->is_album()) {
        throw new Exception("@todo BAD_ALBUM");
      }

      $name = $file["name"];
      if ($file["type"] == "album") {
        $album = ORM::factory("item")
          ->where("name", $name)
          ->where("parent_id", $parent->id)
          ->find();
        if (!$album->loaded) {
          $album = album::create($parent, $name, $name, null, user::active()->id);
        }
        /*
         * Now that we have a new album. Go through the remaining files to import and change the
         * parent_id of any file that has the same relative path as this album's path.
         */
        $album_path = "{$file['path']}/$name";
        for ($idx = $context["position"] + 1; $idx < count($context["files"][$path]); $idx++) {
          if (strpos($context["files"][$path][$idx]["path"], $album_path) === 0) {
            $context["files"][$path][$idx]["parent_id"] = $album->id;
          }
        }
      } else {
        $extension = strtolower(substr(strrchr($name, '.'), 1));
        $source_path = "$path{$file['path']}/$name";
        if (in_array($extension, array("flv", "mp4"))) {
          $movie = movie::create($parent, $source_path, $name, $name,
                                 null, user::active()->id);
        } else {
          $photo = photo::create($parent, $source_path, $name, $name,
                                 null, user::active()->id);
        }
      }

      $context["counter"]++;
      if (++$context["position"] >= count($context["files"][$path])) {
        $context["next_path"]++;
        $context["position"] = 0;
      }
    } catch(Exception $e) {
      $context["errors"][$path] = $e->getMessage();
    }
    $task->context = serialize($context);
    $task->state = "success";
    $task->percent_complete = ($context["counter"] / (float)$context["total"]) * 100;
    $task->done = $context["counter"] == (float)$context["total"];
  }
}