@@ -7,7 +7,7 @@ import { foldChangeSets } from './folding';
77import { sendRequest } from './send-request' ;
88import { sendBundledRequest } from './bundle-requests' ;
99import {
10- filterChangesestOnPattern ,
10+ filterChangesetsOnPattern ,
1111 tripleMatchesSpec ,
1212 filterMatchesForOrigin ,
1313 hostnameForEntry
@@ -60,33 +60,6 @@ app.post( '/', bodyParser.json({limit: '500mb'}), function( req, res ) {
6060 res . status ( 204 ) . send ( ) ;
6161} ) ;
6262
63-
64- /**
65- * Filters the change sets based on a specified pattern.
66- *
67- * @param {Array<Object> } changeSets - An array of change set objects,
68- * each containing `insert` and `delete` properties.
69- * @param {Object } entry - An object containing the matching criteria.
70- * @param {Array } entry.match - The pattern used to filter the triples
71- * in the `insert` and `delete` arrays.
72- * @returns {Array<Object> } A new array of change set objects with
73- * filtered `insert` and `delete` properties.
74- */
75- function filterChangesestOnPattern ( changeSets , entry ) {
76- const filteredChangesets = [ ] ;
77- for ( const changeSet of changeSets ) {
78- const { insert, delete : deleteSet } = changeSet ;
79- const clonedChangeSet = {
80- ...changeSet ,
81- insert : insert . filter ( ( triple ) => tripleMatchesSpec ( triple , entry . match ) ) ,
82- delete : deleteSet . filter ( ( triple ) => tripleMatchesSpec ( triple , entry . match ) )
83- } ;
84- filteredChangesets . push ( clonedChangeSet ) ;
85- } ;
86- return filteredChangesets ;
87- }
88-
89-
9063async function informWatchers ( changeSets , res , muCallIdTrail , muSessionId ) {
9164 // Iterate over each unique match pattern
9265 for ( const matchKey in groupedServices ) {
@@ -95,7 +68,7 @@ async function informWatchers( changeSets, res, muCallIdTrail, muSessionId ){
9568 const sendMatchesOnly = firstEntry . options . sendMatchesOnly ;
9669 let maybePatternFilteredChangesets = changeSets ;
9770 if ( sendMatchesOnly ) {
98- maybePatternFilteredChangesets = filterChangesestOnPattern ( changeSets , firstEntry ) ;
71+ maybePatternFilteredChangesets = filterChangesetsOnPattern ( changeSets , firstEntry ) ;
9972 }
10073
10174 let allInserts = [ ] ;
0 commit comments