breakhours-transform/api/jobs.js

import express from 'express';
import fetch from 'node-fetch';
import { promises as fs } from 'fs';
import dotenv from 'dotenv';
import path from 'path';
import { fileURLToPath } from 'url';
import { convertToAmsterdamTime } from './utils.js';
import { PauzeManager } from '../services/PauzeManager.js';

dotenv.config();

const __filename = fileURLToPath(import.meta.url);
const __dirname = path.dirname(__filename);

const router = express.Router();

export const getJobs = async (req, res) => {
  const apiKey = req.body.apiKey;
  const apiProdUrl = `https://api.fleks.works/v1/jobs/?limit=100000&page=1&start_date=2024-06-26&isArchived=false`;

  try {
    const timeTableData = await fs.readFile(path.join('data', 'colorcrew_data_transformed_prod.json'), 'utf8');
    const timeTable = JSON.parse(timeTableData);

    const response = await fetch(apiProdUrl, {
      headers: {
        'x-api-key': apiKey
      }
    });

    const data = await response.json();
    const pauzeManager = new PauzeManager();

    const updatedJobs = await pauzeManager.updateJobsWithPauze(data.results, timeTable, convertToAmsterdamTime);

    await pauzeManager.updateJobsInDatabase(37, updatedJobs)

    res.json({ amountOfJobs: updatedJobs.length, updatedJobs: updatedJobs });
  } catch (error) {
    console.log(error);
    res.status(500).json({ error: 'Error fetching data' });
  }
};

export const processAndUpdateJobs = async (req, res) => {
  const { tenantId, jobs } = req.body;

  if (!tenantId) {
    return res.status(400).json({ error: 'Tenant ID is required' });
  }

  if (!jobs || !Array.isArray(jobs)) {
    return res.status(400).json({ error: 'Error with fetching Jobs' });
  }

  try {
    const timeTableData = await fs.readFile(path.join(__dirname, 'data', 'colorcrew_data_transformed_prod.json'), 'utf8');
    const timeTable = JSON.parse(timeTableData);
    const pauzeManager = new PauzeManager();

    const updatedJobs = pauzeManager.updateJobsWithPauze(jobs, timeTable, convertToAmsterdamTime);

    const result = await pauzeManager.updateJobsInDatabase(tenantId, updatedJobs);

    res.json({ message: 'Jobs updated successfully.', result });
  } catch (error) {
    console.error('Error updating jobs:', error);
    res.status(500).json({ error: 'Error updating jobs' });
  }
};

export const removePauzeFromJobs = async (req, res) => {
  const pauzeManager = new PauzeManager();

  try {
    await pauzeManager.removePauzeFromDatabase(8);
    res.json({ message: 'Pauze removed from job descriptions successfully.' });
  } catch (error) {
    console.error('Error removing pauze from job descriptions:', error);
    res.status(500).json({ error: 'Error removing pauze from job descriptions' });
  }
};

export default router;