Skip to content

Mock Fusion instance correctly in IndexStageTestBase #6

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open

Mock Fusion instance correctly in IndexStageTestBase #6

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
90dfc4d
Mock Fusion instance and Documents correctly in IndexStageTestBase
krook1024 Feb 15, 2022
f2f4413
Mimic existing behaviour when calling Fusion::documents from a test e…
krook1024 Feb 15, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 12 additions & 0 deletions index-stage-sdk-test/src/main/java/com/lucidworks/indexing/sdk/test/IndexStageTestBase.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@

import com.lucidworks.indexing.api.Document;
import com.lucidworks.indexing.api.IndexStage;
import com.lucidworks.indexing.api.fusion.Documents;
import com.lucidworks.indexing.api.fusion.Fusion;
import com.lucidworks.indexing.config.IndexStageConfig;
import org.junit.runner.RunWith;
Expand All @@ -11,6 +12,8 @@

import java.util.function.Consumer;

import static org.mockito.ArgumentMatchers.any;

/**
* Base class for index stage unit tests.
* @param <C> index stage config class
Expand All @@ -31,12 +34,21 @@ public abstract class IndexStageTestBase<C extends IndexStageConfig> {
* @throws ReflectiveOperationException when unable to instantiate stage class using default no param constructor
*/
public <S extends IndexStage<C>> S createStage(Class<S> stageClass, C config) throws ReflectiveOperationException {
mockDocumentsInFusion();

S stage = stageClass.getDeclaredConstructor().newInstance();
stage.init(config, fusion);

return stage;
}

private void mockDocumentsInFusion() {
Documents documents = Mockito.mock(Documents.class);
Mockito.when(documents.newDocument()).then(invocation -> newDocument());
Mockito.when(documents.newDocument(any())).then(invocation -> newDocument(invocation.getArgument(0)));
Mockito.when(fusion.documents()).thenReturn(documents);
}

/**
* Create new document without id.
*
Expand Down