mirror of
https://github.com/amark/gun.git
synced 2025-06-05 21:56:51 +00:00
RSE S3 no console
This commit is contained in:
parent
a32fa7cc8c
commit
922e39a6a1
10
lib/rs3.js
10
lib/rs3.js
@ -41,7 +41,7 @@ function Store(opt){
|
||||
var store = function Store(){};
|
||||
store.put = function(file, data, cb){
|
||||
var params = {Bucket: opts.bucket, Key: file, Body: data};
|
||||
console.log("RS3 PUT ---->", (data||"").slice(0,20));
|
||||
//console.log("RS3 PUT ---->", (data||"").slice(0,20));
|
||||
Gun.obj.del(c.g, file);
|
||||
Gun.obj.del(c.l, 1);
|
||||
s3.putObject(params, cb);
|
||||
@ -50,9 +50,9 @@ function Store(opt){
|
||||
if(c.g[file]){ return c.g[file].push(cb) }
|
||||
var cbs = c.g[file] = [cb];
|
||||
var params = {Bucket: opts.bucket, Key: file||''};
|
||||
console.log("RS3 GET ---->", file);
|
||||
//console.log("RS3 GET ---->", file);
|
||||
s3.getObject(params, function(err, ack){
|
||||
console.log("RS3 GOT <----", err, file, cbs.length, ((ack||{}).Body||'').toString().slice(0,20));
|
||||
//console.log("RS3 GOT <----", err, file, cbs.length, ((ack||{}).Body||'').toString().slice(0,20));
|
||||
Gun.obj.del(c.g, file);
|
||||
var data, cbe = function(cb){
|
||||
if(!ack){ cb(null); return; }
|
||||
@ -68,9 +68,9 @@ function Store(opt){
|
||||
cbs = c.l[1] = [cb];
|
||||
}
|
||||
params = params || {Bucket: opts.bucket};
|
||||
console.log("RS3 LIST --->");
|
||||
//console.log("RS3 LIST --->");
|
||||
s3.listObjectsV2(params, function(err, data){
|
||||
console.log("RS3 LIST <---", err, data, cbs.length);
|
||||
//console.log("RS3 LIST <---", err, data, cbs.length);
|
||||
if(err){ return Gun.log(err, err.stack) }
|
||||
var IT = data.IsTruncated, cbe = function(cb){
|
||||
if(cb.end){ return }
|
||||
|
Loading…
x
Reference in New Issue
Block a user