srjp-td2/src/stores/api.store.ts

import type { AxiosInstance } from 'axios';
import axios from 'axios';
import { defineStore } from 'pinia';
import {
  DataStatus,
  type ActiveDataResponse,
  type SceneriesDataResponse
} from '../types/api.types';
import type { ActiveData, JournalTimetableShort, SceneryData } from '../types/common.types';

let activeDataInterval = -1;

export const useApiStore = defineStore('api', {
  state() {
    return {
      client: null as AxiosInstance | null,

      activeData: null as ActiveData | null,
      sceneryData: null as SceneryData[] | null,
      journalTimetablesData: null as JournalTimetableShort[] | null,

      outdatedTimerId: -1,
      isActiveDataOutdated: false,

      activeDataStatus: DataStatus.LOADING,
      journalDataStatus: DataStatus.SUCCESS,

      connectionMode: 'online' as 'online' | 'offline'
    };
  },

  actions: {
    async setupAPIData() {
      if (this.client == null) {
        let baseURL = 'https://stacjownik.spythere.eu';

        switch (import.meta.env.VITE_API_MODE) {
          case 'development':
            baseURL = 'http://localhost:3001';
            break;
          case 'mocking':
            baseURL = 'http://localhost:3123';
            break;
          default:
            break;
        }

        this.client = axios.create({
          baseURL
        });
      }

      clearInterval(activeDataInterval);

      activeDataInterval = setInterval(() => {
        this.fetchActiveData();
      }, 25000);

      this.fetchSceneriesData();
      await this.fetchActiveData();
    },

    async fetchActiveData() {
      try {
        const response = (await this.client!.get<ActiveDataResponse>('/api/getActiveData')).data;

        this.activeData = response;
        this.activeDataStatus = DataStatus.SUCCESS;
        this.isActiveDataOutdated = false;

        if (this.outdatedTimerId != -1) clearTimeout(this.outdatedTimerId);

        this.outdatedTimerId = setTimeout(() => {
          this.isActiveDataOutdated = true;
        }, 60000);
      } catch (error) {
        console.error(error);
      }
    },

    async fetchSceneriesData() {
      try {
        const response = (await this.client!.get<SceneriesDataResponse>('/api/getSceneries')).data;

        this.sceneryData = response;
      } catch (error) {
        console.error(error);
      }
    }
  }
});