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

Give good error message if running in a QQQ instance without script tables

Browse Source
This commit is contained in:
darin.kelkhoff
2023-02-24 16:18:05 -06:00
parent 4db174b66d
commit 1baf7d8f86
1 changed files with 61 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

106
qqq-middleware-javalin/src/main/java/com/kingsrook/qqq/backend/javalin/QJavalinScriptsHandler.java
View File

@ -35,9 +35,11 @@ import com.kingsrook.qqq.backend.core.actions.scripts.StoreAssociatedScriptActio
import com.kingsrook.qqq.backend.core.actions.scripts.TestScriptActionInterface; import com.kingsrook.qqq.backend.core.actions.scripts.TestScriptActionInterface;
import com.kingsrook.qqq.backend.core.actions.tables.GetAction; import com.kingsrook.qqq.backend.core.actions.tables.GetAction;
import com.kingsrook.qqq.backend.core.actions.tables.QueryAction; import com.kingsrook.qqq.backend.core.actions.tables.QueryAction;
import com.kingsrook.qqq.backend.core.context.QContext;
import com.kingsrook.qqq.backend.core.exceptions.QException; import com.kingsrook.qqq.backend.core.exceptions.QException;
import com.kingsrook.qqq.backend.core.exceptions.QNotFoundException; import com.kingsrook.qqq.backend.core.exceptions.QNotFoundException;
import com.kingsrook.qqq.backend.core.instances.QInstanceEnricher; import com.kingsrook.qqq.backend.core.instances.QInstanceEnricher;
import com.kingsrook.qqq.backend.core.logging.QLogger;
import com.kingsrook.qqq.backend.core.model.actions.scripts.StoreAssociatedScriptInput; import com.kingsrook.qqq.backend.core.model.actions.scripts.StoreAssociatedScriptInput;
import com.kingsrook.qqq.backend.core.model.actions.scripts.StoreAssociatedScriptOutput; import com.kingsrook.qqq.backend.core.model.actions.scripts.StoreAssociatedScriptOutput;
import com.kingsrook.qqq.backend.core.model.actions.scripts.TestScriptInput; import com.kingsrook.qqq.backend.core.model.actions.scripts.TestScriptInput;
@ -56,6 +58,7 @@ import com.kingsrook.qqq.backend.core.model.metadata.code.QCodeType;
import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldMetaData; import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldMetaData;
import com.kingsrook.qqq.backend.core.model.metadata.tables.AssociatedScript; import com.kingsrook.qqq.backend.core.model.metadata.tables.AssociatedScript;
import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableMetaData; import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableMetaData;
import com.kingsrook.qqq.backend.core.model.scripts.Script;
import com.kingsrook.qqq.backend.core.model.scripts.ScriptType; import com.kingsrook.qqq.backend.core.model.scripts.ScriptType;
import com.kingsrook.qqq.backend.core.processes.utils.GeneralProcessUtils; import com.kingsrook.qqq.backend.core.processes.utils.GeneralProcessUtils;
import com.kingsrook.qqq.backend.core.utils.CollectionUtils; import com.kingsrook.qqq.backend.core.utils.CollectionUtils;
@ -72,6 +75,9 @@ import static io.javalin.apibuilder.ApiBuilder.post;
*******************************************************************************/ *******************************************************************************/
public class QJavalinScriptsHandler public class QJavalinScriptsHandler
{ {
private static final QLogger LOG = QLogger.getLogger(QJavalinScriptsHandler.class);
/******************************************************************************* /*******************************************************************************
** Define routes under the basic /data/${table}/${primaryKey} path - e.g., ** Define routes under the basic /data/${table}/${primaryKey} path - e.g.,
@ -132,57 +138,67 @@ public class QJavalinScriptsHandler
ArrayList<HashMap<String, Serializable>> associatedScripts = new ArrayList<>(); ArrayList<HashMap<String, Serializable>> associatedScripts = new ArrayList<>();
rs.put("associatedScripts", associatedScripts); rs.put("associatedScripts", associatedScripts);
Map<Serializable, QRecord> scriptTypeMap = GeneralProcessUtils.loadTableToMap(getInput, ScriptType.TABLE_NAME, "id"); QTableMetaData scriptTypeTable = QContext.getQInstance().getTable(ScriptType.TABLE_NAME);
QTableMetaData scriptRevisionTable = QContext.getQInstance().getTable(ScriptType.TABLE_NAME);
/////////////////////////////////////////////////////// QTableMetaData scriptTable = QContext.getQInstance().getTable(Script.TABLE_NAME);
// process each associated script type for the table // if(scriptTypeTable != null && scriptTable != null && scriptRevisionTable != null)
///////////////////////////////////////////////////////
QInstanceEnricher qInstanceEnricher = new QInstanceEnricher(QJavalinImplementation.qInstance);
for(AssociatedScript associatedScript : CollectionUtils.nonNullList(table.getAssociatedScripts()))
{ {
HashMap<String, Serializable> thisScriptData = new HashMap<>(); Map<Serializable, QRecord> scriptTypeMap = GeneralProcessUtils.loadTableToMap(getInput, ScriptType.TABLE_NAME, "id");
associatedScripts.add(thisScriptData);
thisScriptData.put("associatedScript", associatedScript);
thisScriptData.put("scriptType", scriptTypeMap.get(associatedScript.getScriptTypeId()));
///////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////
// load the associated script and current revision from the record // // process each associated script type for the table //
///////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////
String fieldName = associatedScript.getFieldName(); QInstanceEnricher qInstanceEnricher = new QInstanceEnricher(QJavalinImplementation.qInstance);
Serializable scriptId = record.getValue(fieldName); for(AssociatedScript associatedScript : CollectionUtils.nonNullList(table.getAssociatedScripts()))
if(scriptId != null)
{ {
GetInput getScriptInput = new GetInput(); HashMap<String, Serializable> thisScriptData = new HashMap<>();
QJavalinImplementation.setupSession(context, getScriptInput); associatedScripts.add(thisScriptData);
getScriptInput.setTableName("script"); thisScriptData.put("associatedScript", associatedScript);
getScriptInput.setPrimaryKey(scriptId); thisScriptData.put("scriptType", scriptTypeMap.get(associatedScript.getScriptTypeId()));
GetOutput getScriptOutput = new GetAction().execute(getScriptInput);
if(getScriptOutput.getRecord() != null)
{
thisScriptData.put("script", getScriptOutput.getRecord());
QueryInput queryInput = new QueryInput(); /////////////////////////////////////////////////////////////////////
QJavalinImplementation.setupSession(context, queryInput); // load the associated script and current revision from the record //
queryInput.setTableName("scriptRevision"); /////////////////////////////////////////////////////////////////////
queryInput.setFilter(new QQueryFilter() String fieldName = associatedScript.getFieldName();
.withCriteria(new QFilterCriteria("scriptId", QCriteriaOperator.EQUALS, List.of(getScriptOutput.getRecord().getValue("id")))) Serializable scriptId = record.getValue(fieldName);
.withOrderBy(new QFilterOrderBy("id", false)) if(scriptId != null)
); {
QueryOutput queryOutput = new QueryAction().execute(queryInput); GetInput getScriptInput = new GetInput();
thisScriptData.put("scriptRevisions", new ArrayList<>(queryOutput.getRecords())); QJavalinImplementation.setupSession(context, getScriptInput);
getScriptInput.setTableName("script");
getScriptInput.setPrimaryKey(scriptId);
GetOutput getScriptOutput = new GetAction().execute(getScriptInput);
if(getScriptOutput.getRecord() != null)
{
thisScriptData.put("script", getScriptOutput.getRecord());
QueryInput queryInput = new QueryInput();
QJavalinImplementation.setupSession(context, queryInput);
queryInput.setTableName("scriptRevision");
queryInput.setFilter(new QQueryFilter()
.withCriteria(new QFilterCriteria("scriptId", QCriteriaOperator.EQUALS, List.of(getScriptOutput.getRecord().getValue("id"))))
.withOrderBy(new QFilterOrderBy("id", false))
);
QueryOutput queryOutput = new QueryAction().execute(queryInput);
thisScriptData.put("scriptRevisions", new ArrayList<>(queryOutput.getRecords()));
}
}
///////////////////////////////////////////////////////////
// load testing info about the script type, if available //
///////////////////////////////////////////////////////////
QCodeReference scriptTesterCodeRef = associatedScript.getScriptTester();
if(scriptTesterCodeRef != null)
{
TestScriptActionInterface scriptTester = QCodeLoader.getAdHoc(TestScriptActionInterface.class, scriptTesterCodeRef);
thisScriptData.put("testInputFields", enrichFieldsToArrayList(qInstanceEnricher, scriptTester.getTestInputFields()));
thisScriptData.put("testOutputFields", enrichFieldsToArrayList(qInstanceEnricher, scriptTester.getTestOutputFields()));
} }
} }
}
/////////////////////////////////////////////////////////// else
// load testing info about the script type, if available // {
/////////////////////////////////////////////////////////// LOG.info("One or more script tables was not found in the instance.");
QCodeReference scriptTesterCodeRef = associatedScript.getScriptTester();
if(scriptTesterCodeRef != null)
{
TestScriptActionInterface scriptTester = QCodeLoader.getAdHoc(TestScriptActionInterface.class, scriptTesterCodeRef);
thisScriptData.put("testInputFields", enrichFieldsToArrayList(qInstanceEnricher, scriptTester.getTestInputFields()));
thisScriptData.put("testOutputFields", enrichFieldsToArrayList(qInstanceEnricher, scriptTester.getTestOutputFields()));
}
} }
QJavalinAccessLogger.logEndSuccess(); QJavalinAccessLogger.logEndSuccess();