backend/controllers/SlurmStatsController.js - master - Krams/nodemon2

backend/controllers/SlurmStatsController.js
77 строк2 KB
Иван Новиков
postgresql update
04 май 2026, 09:46
04 май 2026, 09:4627e975d
import {
  getSlurmJobStatsDetails,
  getSlurmJobsStats,
  getSlurmTaskStatsSummary,
  getSlurmUsersStats,
  syncSlurmTaskStats,
} from '../services/SlurmStatsService.js';

export async function getSlurmStatsSummaryController(req, res) {
  try {
    const data = await getSlurmTaskStatsSummary();
    res.json(data);
  } catch (error) {
    const message = error instanceof Error ? error.message : String(error || 'unknown error');
    res.status(500).json({ error: message });
  }
}

export async function getSlurmStatsUsersController(req, res) {
  try {
    const data = await getSlurmUsersStats({
      search: req.query.search,
      sortBy: req.query.sortBy,
      sortOrder: req.query.sortOrder,
      limit: req.query.limit,
    });
    res.json(data);
  } catch (error) {
    const message = error instanceof Error ? error.message : String(error || 'unknown error');
    res.status(500).json({ error: message });
  }
}

export async function getSlurmStatsJobsController(req, res) {
  try {
    const data = await getSlurmJobsStats({
      page: req.query.page,
      limit: req.query.limit,
      search: req.query.search,
      userName: req.query.userName,
      partition: req.query.partition,
      state: req.query.state,
      status: req.query.status,
      from: req.query.from,
      to: req.query.to,
      sortBy: req.query.sortBy,
      sortOrder: req.query.sortOrder,
    });
    res.json(data);
  } catch (error) {
    const message = error instanceof Error ? error.message : String(error || 'unknown error');
    res.status(500).json({ error: message });
  }
}

export async function getSlurmStatsJobDetailsController(req, res) {
  try {
    const data = await getSlurmJobStatsDetails(req.params.jobId, req.query.clusterName);
    if (!data.local && !data.live) {
      return res.status(404).json({ error: 'Job details not found' });
    }
    res.json(data);
  } catch (error) {
    const message = error instanceof Error ? error.message : String(error || 'unknown error');
    res.status(502).json({ error: message });
  }
}

export async function runSlurmStatsSyncController(req, res) {
  try {
    const data = await syncSlurmTaskStats();
    res.json({ ok: true, sync: data });
  } catch (error) {
    const message = error instanceof Error ? error.message : String(error || 'unknown error');
    res.status(502).json({ error: message });
  }
}