QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-19 05:30:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update qqq versions to 0.2.0-SNAPSHOT, with package reorg and request/result rename to input/output

Browse Source
This commit is contained in:
darin.kelkhoff
2022-07-15 09:36:33 -05:00
parent ba213e0667
commit cd691aa0c1
2 changed files with 37 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
src/test/java/com/kingsrook/sampleapp/SampleMetaDataProviderTest.java
View File

@ -25,14 +25,14 @@ package com.kingsrook.sampleapp;
import java.io.File;
import java.io.IOException;
import java.util.UUID;
import com.kingsrook.qqq.backend.core.actions.QueryAction;
import com.kingsrook.qqq.backend.core.actions.RunProcessAction;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunProcessRequest;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunProcessResult;
import com.kingsrook.qqq.backend.core.model.actions.query.QueryRequest;
import com.kingsrook.qqq.backend.core.model.actions.query.QueryResult;
import com.kingsrook.qqq.backend.core.actions.tables.QueryAction;
import com.kingsrook.qqq.backend.core.actions.processes.RunProcessAction;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunProcessInput;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunProcessOutput;
import com.kingsrook.qqq.backend.core.model.actions.tables.query.QueryInput;
import com.kingsrook.qqq.backend.core.model.actions.tables.query.QueryOutput;
import com.kingsrook.qqq.backend.core.model.metadata.QInstance;
import com.kingsrook.qqq.backend.core.model.metadata.QTableMetaData;
import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableMetaData;
import com.kingsrook.qqq.backend.core.model.session.QSession;
import com.kingsrook.qqq.backend.module.filesystem.local.actions.FilesystemQueryAction;
import com.kingsrook.qqq.backend.module.filesystem.local.model.metadata.FilesystemTableBackendDetails;
@ -60,13 +60,13 @@ class SampleMetaDataProviderTest
try
{
QueryRequest queryRequest = new QueryRequest();
queryRequest.setInstance(SampleMetaDataProvider.defineInstance());
queryRequest.setTableName(fileTable.getName());
QueryInput queryInput = new QueryInput();
queryInput.setInstance(SampleMetaDataProvider.defineInstance());
queryInput.setTableName(fileTable.getName());
QueryResult queryResult = new FilesystemQueryAction().execute(queryRequest);
System.out.println(queryResult);
Assertions.assertEquals(3, queryResult.getRecords().size(), "Should load all records from the file");
QueryOutput queryOutput = new FilesystemQueryAction().execute(queryInput);
System.out.println(queryOutput);
Assertions.assertEquals(3, queryOutput.getRecords().size(), "Should load all records from the file");
}
finally
{
@ -101,21 +101,21 @@ class SampleMetaDataProviderTest
public void testGreetProcess() throws Exception
{
QInstance qInstance = SampleMetaDataProvider.defineInstance();
QTableMetaData personTable = SampleMetaDataProvider.defineTablePerson();
RunProcessRequest request = new RunProcessRequest(qInstance);
QTableMetaData personTable = SampleMetaDataProvider.defineTablePerson();
RunProcessInput request = new RunProcessInput(qInstance);
request.setSession(new QSession());
request.setProcessName(SampleMetaDataProvider.PROCESS_NAME_GREET);
QueryRequest queryRequest = new QueryRequest(qInstance);
queryRequest.setTableName(personTable.getName());
queryRequest.setSession(new QSession());
QueryResult queryResult = new QueryAction().execute(queryRequest);
QueryInput queryInput = new QueryInput(qInstance);
queryInput.setTableName(personTable.getName());
queryInput.setSession(new QSession());
QueryOutput queryOutput = new QueryAction().execute(queryInput);
request.setRecords(queryResult.getRecords());
request.setRecords(queryOutput.getRecords());
request.addValue("greetingPrefix", "Hello");
request.addValue("greetingSuffix", "there");
RunProcessResult result = new RunProcessAction().execute(request);
RunProcessOutput result = new RunProcessAction().execute(request);
assertNotNull(result);
assertTrue(result.getRecords().stream().allMatch(r -> r.getValues().containsKey("id")), "records should have an id, set by the process");
}