Method getStats

src/database.js:539–620

()

  }

  async getStats() {
    if (!this.initialized) {
      await this.initialize();
    }

    return new Promise((resolve, reject) => {
      const queries = [
        "SELECT COUNT(*) as total FROM workflows",
        "SELECT COUNT(*) as active FROM workflows WHERE active = 1",
        "SELECT COUNT(*) as inactive FROM workflows WHERE active = 0",
        "SELECT trigger_type, COUNT(*) as count FROM workflows GROUP BY trigger_type",
        "SELECT complexity, COUNT(*) as count FROM workflows GROUP BY complexity",
        "SELECT SUM(node_count) as total_nodes FROM workflows",
        "SELECT analyzed_at FROM workflows ORDER BY analyzed_at DESC LIMIT 1",
      ];

      Promise.all(
        queries.map(
          (sql) =>
            new Promise((resolve, reject) => {
              this.db.all(sql, (err, rows) => {
                if (err) reject(err);
                else resolve(rows);
              });
            })
        )
      )
        .then((results) => {
          const [
            total,
            active,
            inactive,
            triggers,
            complexity,
            nodes,
            lastIndexed,
          ] = results;

          const triggersMap = {};
          triggers.forEach((row) => {
            triggersMap[row.trigger_type] = row.count;
          });

          const complexityMap = {};
          complexity.forEach((row) => {
            complexityMap[row.complexity] = row.count;
          });

          // Count unique integrations
          this.db.all("SELECT integrations FROM workflows", (err, rows) => {
            if (err) {
              reject(err);
              return;
            }

            const allIntegrations = new Set();
            rows.forEach((row) => {
              try {