import { ObjectId, Filter } from "mongodb"; import { Subscription, SimpleSubscriptionFilter, simpleFields, SimpleField, } from "../index"; export const buildSimpleQuery = ( filter: SimpleSubscriptionFilter, ): Filter => { const query: Filter = {}; if (filter._id) { query._id = new ObjectId(filter._id); } simpleFields.forEach((field: SimpleField) => { const val = filter[field]; if (val !== undefined) { query[field] = val as any; } }); return query; }; export const buildDateRangeFilter = (from: Date, to: Date) => { return { $gte: from, $lt: to, }; };