feat: add onlyTokenizedProjects filter

src/controllers/project.controller.js

@@ -126,6 +126,7 @@ export const findAll = async (req, res) => {
       projectIds,
       filter,
       order,
+      onlyMarketplaceProjects,
     } = req.query;
 
     let where = orgUid != null && orgUid !== 'all' ? { orgUid } : undefined;
@@ -209,6 +210,18 @@ export const findAll = async (req, res) => {
       };
     }
 
+    if (onlyMarketplaceProjects) {
+      if (!where) {
+        where = {};
+      }
+
+      const marketplaceProjectIds = await Project.getTokenizedProjectIds();
+
+      where.warehouseProjectId = {
+        [Sequelize.Op.in]: _.flatten([marketplaceProjectIds]),
+      };
+    }
+
     const query = {
       ...columnsToInclude(columns, includes),
       ...pagination,

src/models/projects/projects.model.js

@@ -157,6 +157,27 @@ class Project extends Model {
     return upsertResult;
   }
 
+  static async getTokenizedProjectIds() {
+    const sqlQuery = `
+    SELECT Projects.warehouseProjectId
+    FROM Projects
+    INNER JOIN Issuances ON Projects.warehouseProjectId = Issuances.warehouseProjectId
+    INNER JOIN Units ON Issuances.id = Units.issuanceId
+    WHERE Units.marketplaceIdentifier IS NOT NULL AND Units.marketplaceIdentifier != '';
+  `;
+
+    try {
+      const results = await sequelize.query(sqlQuery, {
+        type: sequelize.QueryTypes.SELECT,
+      });
+      return results.map((row) => row.warehouseProjectId);
+    } catch (error) {
+      // Handle errors
+      console.error(error);
+      throw error;
+    }
+  }
+
   static async fts(searchStr, orgUid, pagination, columns = []) {
     const dialect = sequelize.getDialect();
 

src/validations/projects.validations.js

@@ -72,6 +72,7 @@ export const projectsGetQuerySchema = Joi.object()
     projectIds: Joi.array().items(Joi.string()).single(),
     order: Joi.string().regex(genericSortColumnRegex),
     filter: Joi.string().regex(genericFilterRegex),
+    onlyMarketplaceProjects: Joi.boolean(),
   })
   .with('page', 'limit')
   .with('limit', 'page');