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 80 81 82 83 84 85 86 | import { dbClientPromise } from "@/lib/db";
import { insertOne } from "@/lib/dbHelpers/insertOne";
import { ElevenLabsAccountWithProxy } from "@/schemas/ElevenLabsAccountWithProxy";
import { Prettify } from "@/utils/prettify";
import { MongoError, ObjectId } from "mongodb";
import { NoThrow } from "@/utils/NoThrow";
import { ProxyURLBrand } from "@/brands/proxyURL";
export type ElevenLabsAccountWithProxyDocumentType = Prettify<
Omit<ElevenLabsAccountWithProxy, "proxy"> & {
_id: string;
proxyURL: ProxyURLBrand;
ownerID: ObjectId;
},
ProxyURLBrand
>;
export type ElevenLabsAccountWithProxySummaryDocumentType = Prettify<
Omit<ElevenLabsAccountWithProxyDocumentType, "_id" | "password" | "proxyURL" | "ownerID"> & { id: string }
>;
export const ElevenLabsAccountWithProxyRepositoryPromise = (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<ElevenLabsAccountWithProxyDocumentType>("ElevenLabsAccountWithProxy");
return NoThrow.success({
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 findAllByOwnerID(ownerID: ObjectId) {
try {
const result = await collection.find({ ownerID }).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: ElevenLabsAccountWithProxyDocumentType) {
return insertOne(document, collection);
},
});
})();
|