Move saved filter processes to qqq

qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/model/savedfilters/SavedFiltersMetaDataProvider.java

@@ -29,6 +29,9 @@ import com.kingsrook.qqq.backend.core.model.metadata.possiblevalues.PVSValueForm
 import com.kingsrook.qqq.backend.core.model.metadata.possiblevalues.QPossibleValueSource;
 import com.kingsrook.qqq.backend.core.model.metadata.possiblevalues.QPossibleValueSourceType;
 import com.kingsrook.qqq.backend.core.model.metadata.tables.QTableMetaData;
+import com.kingsrook.qqq.backend.core.processes.implementations.savedfilters.DeleteSavedFilterProcess;
+import com.kingsrook.qqq.backend.core.processes.implementations.savedfilters.QuerySavedFilterProcess;
+import com.kingsrook.qqq.backend.core.processes.implementations.savedfilters.StoreSavedFilterProcess;
 
 
 /*******************************************************************************
@@ -45,6 +48,9 @@ public class SavedFiltersMetaDataProvider
    {
       instance.addTable(defineSavedFilterTable(backendName, backendDetailEnricher));
       instance.addPossibleValueSource(defineSavedFilterPossibleValueSource());
+      instance.addProcess(QuerySavedFilterProcess.getProcessMetaData());
+      instance.addProcess(StoreSavedFilterProcess.getProcessMetaData());
+      instance.addProcess(DeleteSavedFilterProcess.getProcessMetaData());
    }
 
 

qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/savedfilters/DeleteSavedFilterProcess.java

@@ -0,0 +1,88 @@
+/*
+ * QQQ - Low-code Application Framework for Engineers.
+ * Copyright (C) 2021-2023.  Kingsrook, LLC
+ * 651 N Broad St Ste 205 # 6917 | Middletown DE 19709 | United States
+ * contact@kingsrook.com
+ * https://github.com/Kingsrook/
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.kingsrook.qqq.backend.core.processes.implementations.savedfilters;
+
+
+import java.util.List;
+import com.kingsrook.qqq.backend.core.actions.ActionHelper;
+import com.kingsrook.qqq.backend.core.actions.processes.BackendStep;
+import com.kingsrook.qqq.backend.core.actions.tables.DeleteAction;
+import com.kingsrook.qqq.backend.core.exceptions.QException;
+import com.kingsrook.qqq.backend.core.logging.QLogger;
+import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepInput;
+import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepOutput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.delete.DeleteInput;
+import com.kingsrook.qqq.backend.core.model.metadata.code.QCodeReference;
+import com.kingsrook.qqq.backend.core.model.metadata.processes.QBackendStepMetaData;
+import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData;
+import com.kingsrook.qqq.backend.core.model.savedfilters.SavedFilter;
+
+
+/*******************************************************************************
+ ** Process used by the delete filter dialog
+ *******************************************************************************/
+public class DeleteSavedFilterProcess implements BackendStep
+{
+   private static final QLogger LOG = QLogger.getLogger(DeleteSavedFilterProcess.class);
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   public static QProcessMetaData getProcessMetaData()
+   {
+      return (new QProcessMetaData()
+         .withName("deleteSavedFilter")
+         .withStepList(List.of(
+            new QBackendStepMetaData()
+               .withCode(new QCodeReference(DeleteSavedFilterProcess.class))
+               .withName("delete")
+         )));
+   }
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @Override
+   public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
+   {
+      ActionHelper.validateSession(runBackendStepInput);
+
+      try
+      {
+         Integer savedFilterId = runBackendStepInput.getValueInteger("id");
+
+         DeleteInput input = new DeleteInput();
+         input.setTableName(SavedFilter.TABLE_NAME);
+         input.setPrimaryKeys(List.of(savedFilterId));
+         new DeleteAction().execute(input);
+      }
+      catch(Exception e)
+      {
+         LOG.warn("Error deleting saved filter", e);
+         throw (e);
+      }
+   }
+}

qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/savedfilters/QuerySavedFilterProcess.java

@@ -0,0 +1,117 @@
+/*
+ * QQQ - Low-code Application Framework for Engineers.
+ * Copyright (C) 2021-2023.  Kingsrook, LLC
+ * 651 N Broad St Ste 205 # 6917 | Middletown DE 19709 | United States
+ * contact@kingsrook.com
+ * https://github.com/Kingsrook/
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.kingsrook.qqq.backend.core.processes.implementations.savedfilters;
+
+
+import java.io.Serializable;
+import java.util.List;
+import com.kingsrook.qqq.backend.core.actions.ActionHelper;
+import com.kingsrook.qqq.backend.core.actions.processes.BackendStep;
+import com.kingsrook.qqq.backend.core.actions.tables.GetAction;
+import com.kingsrook.qqq.backend.core.actions.tables.QueryAction;
+import com.kingsrook.qqq.backend.core.exceptions.QException;
+import com.kingsrook.qqq.backend.core.logging.QLogger;
+import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepInput;
+import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepOutput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.get.GetInput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.get.GetOutput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.query.QCriteriaOperator;
+import com.kingsrook.qqq.backend.core.model.actions.tables.query.QFilterCriteria;
+import com.kingsrook.qqq.backend.core.model.actions.tables.query.QFilterOrderBy;
+import com.kingsrook.qqq.backend.core.model.actions.tables.query.QQueryFilter;
+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.code.QCodeReference;
+import com.kingsrook.qqq.backend.core.model.metadata.processes.QBackendStepMetaData;
+import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData;
+import com.kingsrook.qqq.backend.core.model.savedfilters.SavedFilter;
+
+
+/*******************************************************************************
+ ** Process used by the saved filter dialogs
+ *******************************************************************************/
+public class QuerySavedFilterProcess implements BackendStep
+{
+   private static final QLogger LOG = QLogger.getLogger(QuerySavedFilterProcess.class);
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   public static QProcessMetaData getProcessMetaData()
+   {
+      return (new QProcessMetaData()
+         .withName("querySavedFilter")
+         .withStepList(List.of(
+            new QBackendStepMetaData()
+               .withCode(new QCodeReference(QuerySavedFilterProcess.class))
+               .withName("query")
+         )));
+   }
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @Override
+   public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
+   {
+      ActionHelper.validateSession(runBackendStepInput);
+
+      try
+      {
+         Integer savedFilterId = runBackendStepInput.getValueInteger("id");
+         if(savedFilterId != null)
+         {
+            GetInput input = new GetInput();
+            input.setTableName(SavedFilter.TABLE_NAME);
+            input.setPrimaryKey(savedFilterId);
+
+            GetOutput output = new GetAction().execute(input);
+            runBackendStepOutput.addRecord(output.getRecord());
+            runBackendStepOutput.addValue("savedFilter", output.getRecord());
+            runBackendStepOutput.addValue("savedFilterList", (Serializable) List.of(output.getRecord()));
+         }
+         else
+         {
+            String tableName = runBackendStepInput.getValueString("tableName");
+
+            QueryInput input = new QueryInput();
+            input.setTableName(SavedFilter.TABLE_NAME);
+            input.setFilter(new QQueryFilter()
+               .withCriteria(new QFilterCriteria("tableName", QCriteriaOperator.EQUALS, tableName))
+               .withOrderBy(new QFilterOrderBy("label")));
+
+            QueryOutput output = new QueryAction().execute(input);
+            runBackendStepOutput.setRecords(output.getRecords());
+            runBackendStepOutput.addValue("savedFilterList", (Serializable) output.getRecords());
+         }
+      }
+      catch(Exception e)
+      {
+         LOG.warn("Error deleting saved filter", e);
+         throw (e);
+      }
+   }
+}

qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/savedfilters/StoreSavedFilterProcess.java

@@ -0,0 +1,117 @@
+/*
+ * QQQ - Low-code Application Framework for Engineers.
+ * Copyright (C) 2021-2023.  Kingsrook, LLC
+ * 651 N Broad St Ste 205 # 6917 | Middletown DE 19709 | United States
+ * contact@kingsrook.com
+ * https://github.com/Kingsrook/
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.kingsrook.qqq.backend.core.processes.implementations.savedfilters;
+
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+import com.kingsrook.qqq.backend.core.actions.ActionHelper;
+import com.kingsrook.qqq.backend.core.actions.processes.BackendStep;
+import com.kingsrook.qqq.backend.core.actions.tables.InsertAction;
+import com.kingsrook.qqq.backend.core.actions.tables.UpdateAction;
+import com.kingsrook.qqq.backend.core.exceptions.QException;
+import com.kingsrook.qqq.backend.core.logging.QLogger;
+import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepInput;
+import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepOutput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertInput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertOutput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.update.UpdateInput;
+import com.kingsrook.qqq.backend.core.model.actions.tables.update.UpdateOutput;
+import com.kingsrook.qqq.backend.core.model.data.QRecord;
+import com.kingsrook.qqq.backend.core.model.metadata.code.QCodeReference;
+import com.kingsrook.qqq.backend.core.model.metadata.processes.QBackendStepMetaData;
+import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData;
+import com.kingsrook.qqq.backend.core.model.savedfilters.SavedFilter;
+
+
+/*******************************************************************************
+ ** Process used by the saved filter dialog
+ *******************************************************************************/
+public class StoreSavedFilterProcess implements BackendStep
+{
+   private static final QLogger LOG = QLogger.getLogger(StoreSavedFilterProcess.class);
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   public static QProcessMetaData getProcessMetaData()
+   {
+      return (new QProcessMetaData()
+         .withName("storeSavedFilter")
+         .withStepList(List.of(
+            new QBackendStepMetaData()
+               .withCode(new QCodeReference(StoreSavedFilterProcess.class))
+               .withName("store")
+         )));
+   }
+
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @Override
+   public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
+   {
+      ActionHelper.validateSession(runBackendStepInput);
+
+      try
+      {
+         QRecord qRecord = new QRecord()
+            .withValue("id", runBackendStepInput.getValueInteger("id"))
+            .withValue("label", runBackendStepInput.getValueString("label"))
+            .withValue("tableName", runBackendStepInput.getValueString("tableName"))
+            .withValue("filterJson", runBackendStepInput.getValueString("filterJson"))
+            .withValue("userId", runBackendStepInput.getSession().getUser().getIdReference());
+
+         List<QRecord> savedFilterList = new ArrayList<>();
+         if(qRecord.getValueInteger("id") == null)
+         {
+            InsertInput input = new InsertInput();
+            input.setTableName(SavedFilter.TABLE_NAME);
+            input.setRecords(List.of(qRecord));
+
+            InsertOutput output = new InsertAction().execute(input);
+            savedFilterList = output.getRecords();
+         }
+         else
+         {
+            UpdateInput input = new UpdateInput();
+            input.setTableName(SavedFilter.TABLE_NAME);
+            input.setRecords(List.of(qRecord));
+
+            UpdateOutput output = new UpdateAction().execute(input);
+            savedFilterList = output.getRecords();
+         }
+
+         runBackendStepOutput.addValue("savedFilterList", (Serializable) savedFilterList);
+      }
+      catch(Exception e)
+      {
+         LOG.warn("Error storing data saved filter", e);
+         throw (e);
+      }
+   }
+}