| 858 | } |
| 859 | |
| 860 | const loadPersistedBaselineForQuery = async ( |
| 861 | hashedQueryKey: string, |
| 862 | ): Promise< |
| 863 | Map< |
| 864 | string | number, |
| 865 | { |
| 866 | value: any |
| 867 | owners: Set<string> |
| 868 | } |
| 869 | > |
| 870 | > => { |
| 871 | const knownRows = queryToRows.get(hashedQueryKey) |
| 872 | if ( |
| 873 | knownRows && |
| 874 | Array.from(knownRows).every((rowKey) => collection.has(rowKey)) |
| 875 | ) { |
| 876 | const baseline = new Map< |
| 877 | string | number, |
| 878 | { value: any; owners: Set<string> } |
| 879 | >() |
| 880 | knownRows.forEach((rowKey) => { |
| 881 | const value = collection.get(rowKey) |
| 882 | const owners = rowToQueries.get(rowKey) |
| 883 | if (value && owners) { |
| 884 | baseline.set(rowKey, { |
| 885 | value, |
| 886 | owners: new Set(owners), |
| 887 | }) |
| 888 | } |
| 889 | }) |
| 890 | return baseline |
| 891 | } |
| 892 | |
| 893 | const scanPersisted = persistedMetadata?.row.scanPersisted |
| 894 | if (!scanPersisted) { |
| 895 | const baseline = new Map< |
| 896 | string | number, |
| 897 | { value: any; owners: Set<string> } |
| 898 | >() |
| 899 | getHydratedOwnedRowsForQueryBaseline(hashedQueryKey).forEach( |
| 900 | (rowKey) => { |
| 901 | const value = collection.get(rowKey) |
| 902 | const owners = rowToQueries.get(rowKey) |
| 903 | if (value && owners) { |
| 904 | baseline.set(rowKey, { |
| 905 | value, |
| 906 | owners: new Set(owners), |
| 907 | }) |
| 908 | } |
| 909 | }, |
| 910 | ) |
| 911 | return baseline |
| 912 | } |
| 913 | |
| 914 | const baseline = new Map< |
| 915 | string | number, |
| 916 | { value: any; owners: Set<string> } |
| 917 | >() |