Files
Bingbing b09cde814d refactor: extract insomnia-data into workspace package (#10010)
Move insomnia-data models, services, database code, and common utilities into a dedicated workspace package. Update consumers to import from the new package entrypoints and declare workspace dependencies for the extracted package.
2026-06-02 09:49:10 +00:00

68 lines
1.8 KiB
TypeScript

import type { Request } from 'insomnia-data';
import { database as db, models } from 'insomnia-data';
const { type, name } = models.request;
export function create(patch: Partial<Request> = {}) {
if (!patch.parentId) {
throw new Error(`New Requests missing \`parentId\`: ${JSON.stringify(patch)}`);
}
return db.docCreate<Request>(type, patch);
}
export function getById(id: string): Promise<Request | undefined> {
return db.findOne<Request>(type, { _id: id });
}
export function getByParentId(parentId: string) {
return db.findOne<Request>(type, { parentId: parentId });
}
export function findByParentId(parentId: string) {
return db.find<Request>(type, { parentId: parentId });
}
export function update(request: Request, patch: Partial<Request>) {
return db.docUpdate<Request>(request, patch);
}
export async function duplicate(request: Request, patch: Partial<Request> = {}) {
// Only set name and "(Copy)" if the patch does
// not define it and the request itself has a name.
// Otherwise leave it blank so the request URL can
// fill it in automatically.
if (!patch.name && request.name) {
patch.name = `${request.name} (Copy)`;
}
// Get sort key of next request
const q = {
metaSortKey: {
$gt: request.metaSortKey,
},
};
const [nextRequest] = await db.find<Request>(type, q, {
metaSortKey: 1,
});
const nextSortKey = nextRequest ? nextRequest.metaSortKey : request.metaSortKey + 100;
// Calculate new sort key
const sortKeyIncrement = (nextSortKey - request.metaSortKey) / 2;
const metaSortKey = request.metaSortKey + sortKeyIncrement;
return db.duplicate<Request>(request, {
name,
metaSortKey,
...patch,
});
}
export function remove(request: Request) {
return db.remove(request);
}
export async function all() {
return db.find<Request>(type);
}