parcer/src/api/storage.ts

import { default as axios } from "axios";
import { WorkflowFile } from "maxun-core";
import { RunSettings } from "../components/molecules/RunSettings";
import { CreateRunResponse } from "../pages/MainPage";

export const getStoredRecordings = async (): Promise<string[] | null> => {
  try {
    const response = await axios.get('http://localhost:8080/storage/recordings');
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error('Couldn\'t retrieve stored recordings');
    }
  } catch(error: any) {
    console.log(error);
    return null;
  }
};

export const getStoredRuns = async (): Promise<string[] | null> => {
  try {
    const response = await axios.get('http://localhost:8080/storage/runs');
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error('Couldn\'t retrieve stored recordings');
    }
  } catch(error: any) {
    console.log(error);
    return null;
  }
};

export const deleteRecordingFromStorage = async (fileName: string): Promise<boolean> => {
  try {
    const response = await axios.delete(`http://localhost:8080/storage/recordings/${fileName}`);
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error(`Couldn't delete stored recording ${fileName}`);
    }
  } catch(error: any) {
    console.log(error);
    return false;
  }
};

export const deleteRunFromStorage = async (fileName: string): Promise<boolean> => {
  try {
    const response = await axios.delete(`http://localhost:8080/storage/runs/${fileName}`);
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error(`Couldn't delete stored recording ${fileName}`);
    }
  } catch(error: any) {
    console.log(error);
    return false;
  }
};

export const editRecordingFromStorage = async (browserId: string, fileName: string): Promise<WorkflowFile | null> => {
  try {
    const response = await axios.put(`http://localhost:8080/workflow/${browserId}/${fileName}`);
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error(`Couldn't edit stored recording ${fileName}`);
    }
  } catch(error: any) {
    console.log(error);
    return null;
  }
};

export const createRunForStoredRecording = async (fileName: string, settings: RunSettings): Promise<CreateRunResponse> => {
  try {
    const response = await axios.put(
      `http://localhost:8080/storage/runs/${fileName}`,
      {...settings});
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error(`Couldn't create a run for a recording ${fileName}`);
    }
  } catch(error: any) {
    console.log(error);
    return {browserId: '', runId: ''};
  }
}

export const interpretStoredRecording = async (fileName: string, runId: string): Promise<boolean> => {
  try {
    const response = await axios.post(`http://localhost:8080/storage/runs/run/${fileName}/${runId}`);
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error(`Couldn't run a recording ${fileName}`);
    }
  } catch(error: any) {
    console.log(error);
    return false;
  }
}

export const notifyAboutAbort = async (fileName: string, runId:string): Promise<boolean> => {
  try {
    const response = await axios.post(`http://localhost:8080/storage/runs/abort/${fileName}/${runId}`);
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error(`Couldn't abort a running recording ${fileName} with id ${runId}`);
    }
  } catch(error: any) {
    console.log(error);
    return false;
  }
}