opensource/filestash
1
0
Fork 0
mirror of https://github.com/mickael-kerjean/filestash.git synced 2025-11-03 21:17:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

improvement (webdav): stream all the way down - #23

Browse Source
This commit is contained in:
Mickael KERJEAN
2018-03-26 10:49:03 +11:00
parent 15cf85f752
commit 050a26e99a
2 changed files with 3 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
client/model/files.js
View File

@ -18,7 +18,7 @@ class FileSystem{
return Observable.create((obs) => {
this.obs = obs;
let keep_pulling_from_http = true;
let keep_pulling_from_http = false;
this._ls_from_cache(path, true)
.then(() => {
const fetch_from_http = (_path) => {

35
server/model/backend/webdav.js
View File

@ -10,15 +10,6 @@ function connect(params){
);
}
function encode(path){
return path
.split('/')
.map(function(link){
return encodeURIComponent(link);
})
.join('/')
}
module.exports = {
test: function(params){
return new Promise((done, err) => {
@ -29,18 +20,7 @@ module.exports = {
});
},
cat: function(path, params){
path = encode(path);
return new Promise(function(done, err){
connect(params).readFile(path, 'binary', function(error, res){
if(error){ err(error) }
else{
var stream = new Readable();
stream.push(res);
stream.push(null);
done(stream);
}
});
});
return Promise.resolve(connect(params).createReadStream(path));
},
ls: function(path, params){
return new Promise((done, err) => {
@ -69,16 +49,9 @@ module.exports = {
});
},
write: function(path, content, params){
path = encode(path);
return new Promise((done, err) => {
connect(params).writeFile(path, content, 'binary', function(error) {
if(error){ err(error); }
else{ done('done'); }
});
});
return Promise.resolve(content.pipe(connect(params).createWriteStream(path)));
},
rm: function(path, params){
path = encode(path);
return new Promise((done, err) => {
connect(params).unlink(path, function (error) {
if(error){ err(error); }
@ -87,8 +60,6 @@ module.exports = {
});
},
mv: function(from, to, params){
from = encode(from);
to = encode(to);
return new Promise((done, err) => {
connect(params).rename(from, to, function (error) {
if(error){ err(error); }
@ -97,7 +68,6 @@ module.exports = {
});
},
mkdir: function(path, params){
path = encode(path);
return new Promise((done, err) => {
connect(params).mkdir(path, function(error) {
if(error){ err(error); }
@ -106,7 +76,6 @@ module.exports = {
});
},
touch: function(path, params){
path = encode(path);
return new Promise((done, err) => {
connect(params).writeFile(path, '', function(error) {
if(error){ err(error); }