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
|
<?php
/**
* Created by PhpStorm.
* User: zdev
* Date: 12.01.15
* Time: 23:49
*/
namespace Files\Core;
require_once __DIR__ . "/class.accountstore.php";
require_once __DIR__ . "/Util/class.pathutil.php";
require_once __DIR__ . "/Util/util.php";
require_once __DIR__ . "/Util/class.logger.php";
use \Files\Core\AccountStore;
use \Files\Core\Util\PathUtil;
use \Files\Core\Util\Logger;
class UploadHandler
{
const LOG_CONTEXT = "UploadHandler"; // Context for the Logger
public static function doUpload()
{
// parse account id.
if (isset($_POST["parentID"])) { // will be set if a standard upload is used.
$dstID = $_POST["parentID"];
} else {
if (isset($_SERVER['HTTP_X_FILE_DESTINATION'])) { // will be set if the upload is a ajax upload.
$dstID = $_SERVER['HTTP_X_FILE_DESTINATION'];
} else {
Logger::error(self::LOG_CONTEXT, "upload failed: No destination given");
echo json_encode(array('success' => false, 'response' => 'No destination given', 'message' => 'No destination given'));
die();
}
}
$accountID = substr($dstID, 3, (strpos($dstID, '/') - 3));
// relative node ID. We need to trim off the #R# and account ID
$relNodeId = substr($dstID, strpos($dstID, '/'));
// Initialize the account and backendstore
$accountStore = new \Files\Core\AccountStore();
$backendStore = \Files\Backend\BackendStore::getInstance();
$account = $accountStore->getAccount($accountID);
// initialize the backend
$initializedBackend = $backendStore->getInstanceOfBackend($account->getBackend());
$initializedBackend->init_backend($account->getBackendConfig());
try {
$initializedBackend->open();
} catch (\Files\Backend\Exception $e) {
Logger::error(self::LOG_CONTEXT, "backend initialization failed: " . $e->getMessage());
echo json_encode(array('success' => false, 'response' => $e->getCode(), 'message' => $e->getMessage()));
die();
}
// check if we are getting the file via the "new" method (ajax - XMLHttpRequest) or the standard way
if (isset($_SERVER['HTTP_X_FILE_NAME']) && isset($_SERVER['HTTP_X_FILE_SIZE'])) { // use the ajax method
$targetPath = stringToUTF8Encode($relNodeId . $_SERVER['HTTP_X_FILE_NAME']);
// check if backend supports streaming - this is the preferred way to upload files!
if ($initializedBackend->supports(\Files\Backend\BackendStore::FEATURE_STREAMING)) {
$fileReader = fopen('php://input', "r");
$targetPath = UploadHandler::checkFilesNameConflict($targetPath, $initializedBackend, $relNodeId);
$fileWriter = $initializedBackend->getStreamwriter($targetPath);
while (true) {
set_time_limit(0);
$buffer = fgets($fileReader, 4096);
if (strlen($buffer) == 0) {
fclose($fileReader);
fclose($fileWriter);
break;
}
fwrite($fileWriter, $buffer);
}
} else { // fallback to tmp files
$targetPath = UploadHandler::checkFilesNameConflict($targetPath, $initializedBackend, $relNodeId);
$targetPath = rawurldecode($targetPath);
$temp_file = tempnam(TMP_PATH, "$targetPath");
$fileReader = fopen('php://input', "r");
$fileWriter = fopen($temp_file, "w");
// store post data to tmp file
while (true) {
set_time_limit(0);
$buffer = fgets($fileReader, 4096);
if (strlen($buffer) == 0) {
fclose($fileReader);
fclose($fileWriter);
break;
}
fwrite($fileWriter, $buffer);
}
// upload tmp file to backend
$initializedBackend->put_file($targetPath, $temp_file);
// clean up tmp file
unlink($temp_file);
}
echo json_encode(array('success' => true, 'parent' => $dstID, 'item' => $targetPath));
die();
} else { // upload the standard way with $_FILES
$items = array();
try {
for ($i = 0; $i < count($_FILES['attachments']['name']); $i++) {
$targetPath = stringToUTF8Encode($relNodeId . $_FILES['attachments']['name'][$i]);
// upload the file
// check if backend supports streaming - this is the preferred way to upload files!
if ($initializedBackend->supports(\Files\Backend\BackendStore::FEATURE_STREAMING)) {
$fileReader = fopen($_FILES['attachments']['tmp_name'][$i], "r");
$fileWriter = $initializedBackend->getStreamwriter($targetPath);
while (true) {
set_time_limit(0);
$buffer = fgets($fileReader, 4096);
if (strlen($buffer) == 0) {
fclose($fileReader);
fclose($fileWriter);
break;
}
fwrite($fileWriter, $buffer);
}
} else { // use the normal way - might have a high memory footprint
$initializedBackend->put_file($targetPath, $_FILES['attachments']['tmp_name'][$i]);
}
$items[] = array('tmp_name' => $_FILES['attachments']['tmp_name'][$i], 'name' => $_FILES['attachments']['name'][$i]);
}
echo json_encode(array('success' => true, 'parent' => $dstID, 'items' => $items));
die();
} catch (\Files\Backend\Exception $e) {
Logger::error(self::LOG_CONTEXT, "upload failed: " . $e->getMessage());
echo json_encode(array('success' => false, 'response' => $e->getCode(), 'message' => $e->getMessage()));
die();
}
}
}
/**
* Create a unique file name if file is already exist in backend and user
* wants to keep both on server.
*
* @param string $targetPath targeted files path
* @param Object $initializedBackend Supported abstract backend object (i.e fpt,smb,owncloud etc.. )
* @param string $relNodeId relay node id
* @return string target file path
*/
public static function checkFilesNameConflict($targetPath, $initializedBackend, $relNodeId)
{
$keepBoth = isset($_REQUEST["keep_both"])? $_REQUEST["keep_both"] : false;
// Check if file was already exist in directory and $keepBoth is true
// then append the counter in files name.
if (strtolower($keepBoth) === 'true') {
$lsNodes = $initializedBackend->ls($relNodeId);
$nodeExist = array_key_exists(rawurldecode($targetPath), $lsNodes);
if($nodeExist) {
$i = 1;
$targetPathInfo = pathinfo($targetPath);
do {
$targetPath = $targetPathInfo["dirname"] . "/" . $targetPathInfo["filename"] . " (" . $i . ")." . $targetPathInfo["extension"];
$targetPath = str_replace('//', '/', $targetPath);
$i++;
} while (array_key_exists(rawurldecode($targetPath), $lsNodes));
}
}
return $targetPath;
}
}
|
