filecoin-project/slate
1
1
Fork 0
mirror of https://github.com/filecoin-project/slate.git synced 2024-09-11 22:07:08 +03:00
Code Issues Packages Projects Releases Wiki Activity

chore(api/data): remove bucket-remove and get-bucket

Browse Source
This commit is contained in:
Aminejv 2023-01-17 16:50:16 +01:00
parent 5dda7eef1e
commit 3ab4b093b0
2 changed files with 0 additions and 162 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
pages/api/data/bucket-remove.js
View File

@ -1,104 +0,0 @@
import * as Data from "~/node_common/data";
import * as Utilities from "~/node_common/utilities";
import * as Strings from "~/common/strings";
import * as Social from "~/node_common/social";
import * as RequestUtilities from "~/node_common/request-utilities";
export default async (req, res) => {
const userInfo = await RequestUtilities.checkAuthorizationInternal(req, res);
if (!userInfo) return;
const { id, user } = userInfo;
if (Strings.isEmpty(req.body.data?.cid)) {
return res.status(500).send({ decorator: "SERVER_BUCKET_REMOVE_NO_CID", error: true });
}
const { buckets, bucketKey } = await Utilities.getBucket({
user,
bucketName: req.body.data.bucketName,
});
if (!buckets) {
return res.status(500).send({
decorator: "SERVER_NO_BUCKET_DATA",
error: true,
});
}
// TODO(jim): Put this call into a file for all Textile related calls.
let r = null;
try {
r = await buckets.list();
} catch (e) {
Social.sendTextileSlackMessage({
file: "/pages/api/data/bucket-remove.js",
user,
message: e.message,
code: e.code,
functionName: `buckets.list`,
});
}
if (!r) {
return res.status(500).send({ decorator: "SERVER_NO_BUCKET_DATA", error: true });
}
const targetBucket = r.find((d) => d.name === req.body.data.bucketName);
if (!targetBucket) {
return res
.status(404)
.send({ decorator: "SERVER_BUCKET_REMOVE_BUCKET_NOT_FOUND", error: true });
}
let items = null;
try {
const path = await buckets.listPath(targetBucket.key, "/");
items = path.item;
} catch (e) {
Social.sendTextileSlackMessage({
file: "/pages/api/data/bucket-remove.js",
user,
message: e.message,
code: e.code,
functionName: `buckets.listPath`,
});
}
if (!items) {
return res.status(500).send({ decorator: "SERVER_BUCKET_REMOVE_NO_BUCKET_ITEMS", error: true });
}
let entity;
for (let i = 0; i < items.items.length; i++) {
if (items.items[i].cid === req.body.data.cid) {
entity = items.items[i];
break;
}
}
if (!entity) {
return res.status(500).send({ decorator: "SERVER_BUCKET_REMOVE_NO_MATCHING_CID", error: true });
}
let bucketRemoval;
try {
bucketRemoval = await buckets.removePath(bucketKey, entity.name);
} catch (e) {
Social.sendTextileSlackMessage({
file: "/pages/api/data/bucket-remove.js",
user,
message: e.message,
code: e.code,
functionName: `buckets.removePath`,
});
return res.status(500).send({ decorator: "SERVER_BUCKET_REMOVE_FAILED", error: true });
}
return res.status(200).send({
decorator: "SERVER_BUCKET_REMOVE",
success: true,
bucketItems: items.items,
});
};

58
pages/api/data/get-bucket.js
View File

@ -1,58 +0,0 @@
import * as Environment from "~/node_common/environment";
import * as Data from "~/node_common/data";
import * as Utilities from "~/node_common/utilities";
import * as Social from "~/node_common/social";
import * as RequestUtilities from "~/node_common/request-utilities";
export default async (req, res) => {
const userInfo = await RequestUtilities.checkAuthorizationInternal(req, res);
if (!userInfo) return;
const { id, user } = userInfo;
const { buckets, bucketKey } = await Utilities.getBucket({ user });
if (!buckets) {
return res.status(500).send({ decorator: "SERVER_NO_BUCKET_DATA", error: true });
}
// TODO(jim): Put this call into a file for all Textile related calls.
let r = null;
try {
r = await buckets.list();
} catch (e) {
Social.sendTextileSlackMessage({
file: "/pages/api/data/get-bucket.js",
user,
message: e.message,
code: e.code,
functionName: `buckets.list`,
});
}
if (!r) {
return res.status(500).send({ decorator: "SERVER_NO_BUCKET_DATA", error: true });
}
// TODO(jim): Put this call into a file for all Textile related calls.
let items = null;
try {
items = await buckets.listIpfsPath(r[0].path);
} catch (e) {
Social.sendTextileSlackMessage({
file: "/pages/api/data/get.js",
user,
message: e.message,
code: e.code,
functionName: `buckets.listIpfsPath`,
});
}
if (!items) {
return res.status(500).send({ decorator: "SERVER_NO_BUCKET_DATA", error: true });
}
return res.status(200).send({
decorator: "SERVER_GET",
data: items.items,
});
};