filecoin-project/slate
1
1
Fork 0
mirror of https://github.com/filecoin-project/slate.git synced 2024-12-24 17:44:50 +03:00
Code Issues Packages Projects Releases Wiki Activity

getBucketAPIFromUserToken: updates, more logging

Browse Source
This commit is contained in:
@wwwjim 2020-09-22 17:34:17 -07:00
parent bf70a7f182
commit c9d50047c4
1 changed files with 35 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
node_common/utilities.js
View File

@ -27,8 +27,22 @@ export const checkTextile = async () => {
if (response.status === 204) {
return true;
}
Social.sendTextileSlackMessage({
file: "/node_common/utilities.js",
user: { username: "UNDEFINED" },
message: "https://slate.textile.io/health is down",
code: "N/A",
functionName: `checkTextile`,
});
} catch (e) {
console.log(e);
Social.sendTextileSlackMessage({
file: "/node_common/utilities.js",
user: { username: "UNDEFINED" },
message: e.message,
code: e.code,
functionName: `checkTextile`,
});
}
return false;
@ -127,35 +141,36 @@ export const getBucketAPIFromUserToken = async (token, user) => {
const identity = await PrivateKey.fromString(token);
const buckets = await Buckets.withKeyInfo(TEXTILE_KEY_INFO);
await buckets.getToken(identity);
let root
let root;
// TODO(jim): Put this call into a file for all Textile related calls.
console.log(`[buckets] getOrCreate`);
try {
// Create a threads client
const client = new Client(buckets.context)
const client = new Client(buckets.context);
try {
// Get a default thread to store our buckets
const res = await client.getThread('buckets')
buckets.withThread(res.id.toString())
console.log(`[buckets] getThread success ${res.id.toString()}`);
const res = await client.getThread("buckets");
buckets.withThread(res.id.toString());
console.log(`[buckets] getThread success`);
} catch (error) {
if (error.message !== 'Thread not found') {
throw new Error(error.message)
if (error.message !== "Thread not found") {
throw new Error(error.message);
}
const newId = ThreadID.fromRandom()
await client.newDB(newId, 'buckets')
const threadID = newId.toString()
buckets.withThread(threadID)
console.log(`[buckets] newDB success ${newId.toString()}`);
const newId = ThreadID.fromRandom();
await client.newDB(newId, "buckets");
const threadID = newId.toString();
buckets.withThread(threadID);
console.log(`[buckets] newDB success`);
}
const roots = await buckets.list()
roots.find((bucket) => bucket.name === BUCKET_NAME)
const roots = await buckets.list();
root = roots.find((bucket) => bucket.name === BUCKET_NAME);
if (!root) {
const created = await buckets.create(BUCKET_NAME)
root = created.root
const created = await buckets.create(BUCKET_NAME);
root = created.root;
}
} catch (e) {
Social.sendTextileSlackMessage({
@ -167,9 +182,9 @@ export const getBucketAPIFromUserToken = async (token, user) => {
});
return { buckets: null, bucketKey: null, bucketRoot: null };
}
console.log(`[buckets] getOrCreate succes!`);
console.log(`[buckets] getOrCreate success!`);
return {
buckets,
bucketKey: root.key,