113 lines
3.1 KiB
TypeScript
113 lines
3.1 KiB
TypeScript
#!/usr/bin/env tsx
|
|
|
|
// a script for making edits to the couchdb records - run with tsnode
|
|
|
|
import Nano from "nano";
|
|
import { DocumentInsertResponse } from "nano";
|
|
import env from "./src/lib/env-vars";
|
|
import * as T from "../website/src/types/account-types";
|
|
import {
|
|
addCouchDbAuthUser,
|
|
generateWordlistDbPassword,
|
|
getAllLingdocsUsers,
|
|
getLingdocsUser,
|
|
insertLingdocsUser,
|
|
updateLingdocsUser,
|
|
} from "./src/lib/couch-db";
|
|
|
|
const nano = Nano(env.couchDbURL);
|
|
// const usersDb = nano.db.use("lingdocs-users");
|
|
// const userDbPrefix = "userdb-";
|
|
|
|
function processAPIResponse(
|
|
user: T.LingdocsUser,
|
|
response: DocumentInsertResponse
|
|
): T.LingdocsUser | undefined {
|
|
if (response.ok !== true) return undefined;
|
|
return {
|
|
...user,
|
|
_id: response.id,
|
|
_rev: response.rev,
|
|
};
|
|
}
|
|
|
|
async function main() {
|
|
const users = await getAllLingdocsUsers();
|
|
const usersWDbs = users.filter((x) => x.level !== "basic");
|
|
for (let user of usersWDbs) {
|
|
// if (!user.docs.length) return;
|
|
// const u = user.docs[0];
|
|
// await authUsers.destroy(u._id, u._rev);
|
|
if (user.level === "basic") {
|
|
throw new Error("");
|
|
}
|
|
process.stdout.write(
|
|
`Checking for _user for ${user.name} - ${user.email}...`
|
|
);
|
|
const uzrs = nano.db.use("_users");
|
|
const r = await uzrs.find({
|
|
selector: { _id: `org.couchdb.user:${user.userId}` },
|
|
});
|
|
console.log(r.docs.length ? "✅" : "❌");
|
|
if (!r.docs.length) {
|
|
console.log(`Creating wordlist db for ${user.name} - ${user.email}...`);
|
|
const { password, userDbName } = await addCouchDbAuthUser(user.userId);
|
|
await updateLingdocsUser(user.userId, {
|
|
couchDbPassword: password,
|
|
wordlistDbName: userDbName,
|
|
});
|
|
}
|
|
process.stdout.write(`Checking for db for ${user.name} - ${user.email}...`);
|
|
const userDb = nano.db.use(user.wordlistDbName);
|
|
try {
|
|
// await userDb.insert(
|
|
// {
|
|
// admins: {
|
|
// names: [user.userId],
|
|
// roles: ["_admin"],
|
|
// },
|
|
// members: {
|
|
// names: [user.userId],
|
|
// roles: ["_admin"],
|
|
// },
|
|
// },
|
|
// "_security"
|
|
// );
|
|
const { admins, members } = await userDb.get("_security");
|
|
if (
|
|
admins?.names?.[0] === user.userId &&
|
|
members?.names?.[0] === user.userId
|
|
) {
|
|
console.log("✅");
|
|
} else {
|
|
console.log("check", user.wordlistDbName);
|
|
console.log("uid", user.userId);
|
|
console.log("RR");
|
|
}
|
|
} catch (e) {
|
|
// console.log(e);
|
|
console.log("❌");
|
|
console.log(`needs ${user.wordlistDbName} - ${user.userId}`);
|
|
}
|
|
}
|
|
const allDbs = await nano.db.list();
|
|
const strayDbs = allDbs.reduce<string[]>((acc, curr) => {
|
|
if (!curr.startsWith("userdb-")) {
|
|
return acc;
|
|
}
|
|
if (
|
|
!usersWDbs.some((x) => x.level !== "basic" && x.wordlistDbName === curr)
|
|
) {
|
|
return [...acc, curr];
|
|
}
|
|
return acc;
|
|
}, []);
|
|
console.log("STRAY USERDBS");
|
|
console.log(strayDbs);
|
|
return "done";
|
|
}
|
|
|
|
main().then((res) => {
|
|
console.log(res);
|
|
});
|