Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 | import { dbClientPromise } from "@/lib/db";
import { insertOne } from "@/lib/dbHelpers/insertOne";
import { MongoError, ObjectId } from "mongodb";
import { NoThrow } from "@/utils/NoThrow";
export type PRAOSessionDocumentType = {
userID: ObjectId;
accountIDs: string[];
};
/* export type ElevenLabsAccountWithProxySummaryDocumentType = Prettify<
Omit<ElevenLabsAccountWithProxyDocumentType, "_id" | "password" | "apiKey" | "proxyURL"> & { id: string }
>; */
export const PRAOSessionRepositoryPromise = (async function () {
const dbClientResult = await dbClientPromise;
if (dbClientResult.isErr()) {
console.log("dbClientResultError:", dbClientResult.error);
return dbClientResult;
}
console.log("dbClientResult...");
const dbClient = dbClientResult.value;
const db = dbClient.db("core");
const collection = db.collection<PRAOSessionDocumentType>("PRAOSession");
return NoThrow.success({
async findAllByUserID(userID: ObjectId) {
try {
const result = await collection.find({ userID }).toArray();
return NoThrow.success(result);
} catch (error) {
if (error instanceof MongoError) {
return NoThrow.error(error);
}
if (error instanceof Error) {
return NoThrow.error(error);
}
return NoThrow.error(new Error("Unknown error"));
}
},
/* async findAllSummaries() {
try {
const result = await collection
.aggregate<ElevenLabsAccountWithProxySummaryDocumentType>([
{
$project: {
id: "$_id",
_id: 0,
email: 1,
},
},
])
.toArray();
return NoThrow.success(result);
} catch (error) {
if (error instanceof MongoError) {
return NoThrow.error(error);
}
if (error instanceof Error) {
return NoThrow.error(error);
}
return NoThrow.error(new Error("Unknown error"));
}
}, */
async insertOne(document: PRAOSessionDocumentType) {
return insertOne(document, collection);
},
/* async deleteOneByID(id: ObjectId) {}, */
});
})();
|