From 0c8b722de4b418336dc44acb4aaf0aefcfc247fe Mon Sep 17 00:00:00 2001
From: Marc Fornos <marc.fornos@gmail.com>
Date: Tue, 4 Jul 2023 10:34:53 +0200
Subject: [PATCH] fix criteria tests

---
 packages/core/src/operators/mongo-filter.spec.ts           | 4 ++--
 packages/pallets/contracts/src/operators/contracts.spec.ts | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/packages/core/src/operators/mongo-filter.spec.ts b/packages/core/src/operators/mongo-filter.spec.ts
index 2eb9ca1..2465b00 100644
--- a/packages/core/src/operators/mongo-filter.spec.ts
+++ b/packages/core/src/operators/mongo-filter.spec.ts
@@ -1,6 +1,6 @@
 import { mockRxApi } from '@sodazone/ocelloids-test';
 import { blocks } from '../index.js';
-import { mongoFilter, mongoFilterFrom } from './mongo-filter.js';
+import { mongoFilter } from './mongo-filter.js';
 import { ControlQuery } from '../subjects/query.js';
 
 describe('control query', () => {
@@ -34,7 +34,7 @@ describe('control query', () => {
     const found = jest.fn();
 
     blocks()(mockRxApi).pipe(
-      mongoFilterFrom({
+      mongoFilter({
         'block.extrinsics.call.section': 'balances',
         'block.extrinsics.call.method': 'transferKeepAlive'
       })
diff --git a/packages/pallets/contracts/src/operators/contracts.spec.ts b/packages/pallets/contracts/src/operators/contracts.spec.ts
index 468dfe2..dcbdb3f 100644
--- a/packages/pallets/contracts/src/operators/contracts.spec.ts
+++ b/packages/pallets/contracts/src/operators/contracts.spec.ts
@@ -11,7 +11,7 @@ import { Abi } from '@polkadot/api-contract';
 
 import { from } from 'rxjs';
 
-import { types, mongoFilterFrom } from '@sodazone/ocelloids';
+import { types, mongoFilter } from '@sodazone/ocelloids';
 
 import { contractConstructors, contractEvents, contractMessages } from './contracts.js';
 import { ContractMessageWithTx } from '../types/interfaces.js';
@@ -77,7 +77,7 @@ describe('Wasm contracts operator', () => {
       const testPipe = contractMessages(testAbi, testContractAddress)(from(extrinsics));
 
       testPipe.pipe(
-        mongoFilterFrom(
+        mongoFilter(
           {
             'args.value': { $bn_gt: 800000000 },
             'message.identifier': 'transfer'
@@ -148,7 +148,7 @@ describe('Wasm contracts operator', () => {
       const testPipe = contractEvents(testAbi, testContractAddress)(from(testEventsWithIdAndTx));
 
       testPipe.pipe(
-        mongoFilterFrom(
+        mongoFilter(
           {
             'args.value': { $bn_gt: 800000000 },
             'event.identifier': 'Transfer'