mirror of
https://github.com/filecoin-project/slate.git
synced 2024-12-27 02:52:25 +03:00
75 lines
2.2 KiB
JavaScript
75 lines
2.2 KiB
JavaScript
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 SearchManager from "~/node_common/managers/search";
|
|
|
|
import { Buckets, PrivateKey } from "@textile/hub";
|
|
|
|
import JWT from "jsonwebtoken";
|
|
|
|
const TEXTILE_KEY_INFO = {
|
|
key: Environment.TEXTILE_HUB_KEY,
|
|
secret: Environment.TEXTILE_HUB_SECRET,
|
|
};
|
|
|
|
export default async (req, res) => {
|
|
const id = Utilities.getIdFromCookie(req);
|
|
if (!id) {
|
|
return res.status(500).send({ decorator: "SERVER_USER_DELETE", error: true });
|
|
}
|
|
|
|
const user = await Data.getUserById({
|
|
id,
|
|
});
|
|
|
|
if (!user) {
|
|
return res.status(404).send({ decorator: "SERVER_USER_DELETE_USER_NOT_FOUND", error: true });
|
|
}
|
|
|
|
if (user.error) {
|
|
return res.status(500).send({ decorator: "SERVER_USER_DELETE_USER_NOT_FOUND", error: true });
|
|
}
|
|
|
|
let slates = await Data.getSlatesByUserId({ userId: user.id, publicOnly: true });
|
|
for (let slate of slates) {
|
|
SearchManager.updateSlate(slate, "REMOVE");
|
|
}
|
|
|
|
await Data.deleteAPIKeysForUserId({ userId: user.id });
|
|
await Data.deleteSlatesForUserId({ userId: user.id });
|
|
|
|
const i = await PrivateKey.fromString(user.data.tokens.api);
|
|
const b = await Buckets.withKeyInfo(TEXTILE_KEY_INFO);
|
|
const defaultData = await Utilities.getBucketAPIFromUserToken({ user });
|
|
|
|
// NOTE(jim): Just assume they all delete even if exception is thrown, it seems like they do.
|
|
try {
|
|
const roots = await defaultData.buckets.list();
|
|
|
|
for (let i = 0; i < roots.length; i++) {
|
|
await defaultData.buckets.remove(roots[i].key);
|
|
}
|
|
} catch (e) {
|
|
Social.sendTextileSlackMessage({
|
|
file: "/pages/api/users/delete.js",
|
|
user,
|
|
message: e.message,
|
|
code: e.code,
|
|
functionName: `b.remove`,
|
|
});
|
|
}
|
|
|
|
SearchManager.updateUser(user, "REMOVE");
|
|
|
|
const deleted = await Data.deleteUserByUsername({
|
|
username: user.username,
|
|
});
|
|
|
|
if (!deleted || deleted.error) {
|
|
return res.status(500).send({ decorator: "SERVER_USER_DELETE", error: true });
|
|
}
|
|
|
|
return res.status(200).send({ decorator: "SERVER_USER_DELETE", deleted });
|
|
};
|