Skip to content
This repository was archived by the owner on Mar 13, 2020. It is now read-only.
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Binary file added font-awesome/fonts-old/fontawesome-webfont.eot
Binary file not shown.
16 changes: 16 additions & 0 deletions font-awesome/fonts-old/fontawesome-webfont.svg
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added font-awesome/fonts-old/fontawesome-webfont.ttf
Binary file not shown.
Binary file added font-awesome/fonts-old/fontawesome-webfont.woff
Binary file not shown.
Binary file added font-awesome/fonts-old/fontawesome-webfont.woff2
Binary file not shown.
Binary file modified font-awesome/fonts/fontawesome-webfont.eot
Binary file not shown.
2 changes: 2 additions & 0 deletions font-awesome/fonts/fontawesome-webfont.svg
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file modified font-awesome/fonts/fontawesome-webfont.ttf
Binary file not shown.
Binary file modified font-awesome/fonts/fontawesome-webfont.woff
Binary file not shown.
Binary file modified font-awesome/fonts/fontawesome-webfont.woff2
Binary file not shown.
13 changes: 9 additions & 4 deletions package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions src/browser/js/jsonrpc.js
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ export default class JSONrpc {
options.params = {};
}

let s3Explorer = new S3Explorer(options.params, token);
const s3Explorer = new S3Explorer(options.params, token);

let result;

Expand All @@ -44,7 +44,7 @@ export default class JSONrpc {
result = s3Explorer.getSessionsObject();
break;
case "ListBuckets":
result = s3Explorer.listBuckets();
result = s3Explorer.listBuckets(options.params.marker);
break;
case "StorageInfo":
result = s3Explorer.storageInfo();
Expand Down
41 changes: 29 additions & 12 deletions src/sdk/s3explorer.js
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ class S3Explorer {
/**
* @method: getSessionsObject
* @param {@} cb
* @description: Saved session when Listobject API is working fine.
* @description: Saved session when ListObject API is working fine.
*/

getSessionsObject(cb) {
Expand Down Expand Up @@ -69,10 +69,10 @@ class S3Explorer {
}

// list s3 compatible storage buckets
listBuckets(cb) {
var stream = this.s3Client.listObjects(this.bucketName, "", false);
listBuckets(marker, cb) {
marker = marker ? marker : "";
var stream = this.s3Client.listObjects(this.bucketName, "", marker, false);
let objectsArray = [];
// objectsArray.push({prefix:`${this.bucketName}/`, size:0, name:'Home'})
stream.on("data", function(obj) {
if (obj.prefix) {
obj["name"] = obj.prefix.substring(0, obj.prefix.length - 1);
Expand Down Expand Up @@ -124,13 +124,22 @@ class S3Explorer {
* @param {*} cb
*/
listObjects(bucketName, prefix, marker, cb) {

var stream;
let updatedPrefix = bucketName + "/" + prefix;
if ("Home" == bucketName) {
stream = this.s3Client.listObjects(this.bucketName, prefix, false);
stream = this.s3Client.listObjects(
this.bucketName,
prefix,
marker,
false
);
} else {
stream = this.s3Client.listObjects(this.bucketName, updatedPrefix, false);
stream = this.s3Client.listObjects(
this.bucketName,
updatedPrefix,
marker,
false
);
}

let objectsArray = [];
Expand All @@ -154,10 +163,8 @@ class S3Explorer {
});
}


// list bucket objects from S3 compatible storage
listObjectsRecursive(bucketName, prefix, marker, cb) {

var stream;
let objectNameWithPrefix = bucketName + "/" + prefix;
if ("Home" == bucketName) {
Expand All @@ -174,13 +181,12 @@ class S3Explorer {
let iCount = 0;

// look into optimizing this part
stream.on("data", function(obj) {
stream.on("data", function(obj) {
if (obj.name || obj.prefix) {
obj["name"] = obj.prefix ? obj.prefix : obj.name;
objectsArray.push(obj);
iCount += 1
iCount += 1;
}

});
stream.on("end", function() {
let response = StorageResponses.makeDefaultResponse(
Expand Down Expand Up @@ -548,32 +554,43 @@ S3Explorer.prototype.listObjectsRecursive = promisify(
);
S3Explorer.prototype.storageInfo = promisify(S3Explorer.prototype.storageInfo);
S3Explorer.prototype.makeBucket = promisify(S3Explorer.prototype.makeBucket);

S3Explorer.prototype.deleteBucket = promisify(
S3Explorer.prototype.deleteBucket
);

S3Explorer.prototype.removeObject = promisify(
S3Explorer.prototype.removeObject
);

S3Explorer.prototype.listAllBucketPolicies = promisify(
S3Explorer.prototype.listAllBucketPolicies
);

S3Explorer.prototype.putObject = promisify(S3Explorer.prototype.putObject);

S3Explorer.prototype.fPutObject = promisify(S3Explorer.prototype.fPutObject);

S3Explorer.prototype.presignedGet = promisify(
S3Explorer.prototype.presignedGet
);

S3Explorer.prototype.presignedPutObject = promisify(
S3Explorer.prototype.presignedPutObject
);

S3Explorer.prototype.createURLToken = promisify(
S3Explorer.prototype.createURLToken
);

S3Explorer.prototype.presignedGetObj = promisify(
S3Explorer.prototype.presignedGetObj
);

S3Explorer.prototype.getObjectStat = promisify(
S3Explorer.prototype.getObjectStat
);

S3Explorer.prototype.getEndpointAndBucketName = promisify(
S3Explorer.prototype.getEndpointAndBucketName
);
Expand Down
4 changes: 2 additions & 2 deletions src/sdk/storage.js
Original file line number Diff line number Diff line change
Expand Up @@ -1211,7 +1211,7 @@ export class Client {
// * `obj.size` _number_: size of the object
// * `obj.etag` _string_: etag of the object
// * `obj.lastModified` _Date_: modified time stamp
listObjects(bucketName, prefix, recursive) {
listObjects(bucketName, prefix, marker, recursive) {
if (prefix === undefined) prefix = ''
if (recursive === undefined) recursive = false
if (!isValidBucketName(bucketName)) {
Expand All @@ -1228,7 +1228,7 @@ export class Client {
}
// if recursive is false set delimiter to '/'
var delimiter = recursive ? '' : '/'
var marker = ''
var marker = marker ? marker : ""
var objects = []
var ended = false
var readStream = Stream.Readable({objectMode: true})
Expand Down