Function updateDashboards

server/crons/updateDashboards.js:137–221

(queue)

}

async function updateDashboards(queue) {
  const conditions = {
    where: {
      updateSchedule: { [Op.ne]: "" }
    },
    attributes: ["id", "team_id", "lastUpdatedAt", "updateSchedule", "timezone"],
  };

  try {
    const dashboards = await db.Project.findAll(conditions);
    if (!dashboards || dashboards.length === 0) {
      return;
    }

    const skippedDashboardIds = [];

    const jobs = dashboards.map(async (dashboard) => {
      const {
        frequency,
        dayOfWeek,
        daysOfWeek,
        time,
        frequencyNumber,
      } = dashboard.updateSchedule || {};
      const timezone = getProjectUpdateTimezone(dashboard);

      const now = DateTime.now().setZone(timezone);
      const lastUpdated = dashboard.lastUpdatedAt
        ? DateTime.fromJSDate(dashboard.lastUpdatedAt, { zone: timezone })
        : null;

      let shouldUpdate = false;

      if (!lastUpdated) {
        shouldUpdate = frequency !== "daily" || shouldRunOnWeekday(daysOfWeek, now);
      } else if (frequency === "daily") {
        const updateTime = DateTime.now()
          .setZone(timezone)
          .set({
            hour: time.hour,
            minute: time.minute,
            second: 0,
            millisecond: 0
          });
        shouldUpdate = shouldRunOnWeekday(daysOfWeek, now)
          && now > updateTime
          && now.diff(lastUpdated, "days").as("days") >= 1;
      } else if (frequency === "weekly" && dayOfWeek) {
        const weekdayNumber = getWeekdayNumber(dayOfWeek);

        if (weekdayNumber) {
          const updateTime = DateTime.now()
            .setZone(timezone)
            .set({
              hour: time.hour,
              minute: time.minute,
              second: 0,
              millisecond: 0,