import { WhereWhatPair, WorkflowFile } from "@wbr-project/wbr-interpret";
import { emptyWorkflow } from "../shared/constants";

const axios = require('axios').default;

export const getActiveWorkflow = async(id: string) : Promise<WorkflowFile> => {
  try {
    const response = await axios.get(`http://localhost:8080/workflow/${id}`)
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error('Something went wrong when fetching a recorded workflow');
    }
  } catch(error: any) {
    console.log(error);
    return emptyWorkflow;
  }
};

export const getParamsOfActiveWorkflow = async(id: string) : Promise<string[]|null> => {
  try {
    const response = await axios.get(`http://localhost:8080/workflow/params/${id}`)
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error('Something went wrong when fetching the parameters of the recorded workflow');
    }
  } catch(error: any) {
    console.log(error);
    return null;
  }
};

export const deletePair = async(index: number): Promise<WorkflowFile> => {
  try {
   const response = await axios.delete(`http://localhost:8080/workflow/pair/${index}`);
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error('Something went wrong when fetching an updated workflow');
    }
  } catch (error: any) {
    console.log(error);
    return emptyWorkflow;
  }
};

export const AddPair = async(index: number, pair: WhereWhatPair): Promise<WorkflowFile> => {
  try {
    const response = await axios.post(`http://localhost:8080/workflow/pair/${index}`, {
      pair,
    }, {headers: {'Content-Type': 'application/json'}});
    if (response.status === 200) {
      return response.data;
    } else {
      throw new Error('Something went wrong when fetching an updated workflow');
    }
  } catch (error: any) {
    console.log(error);
    return emptyWorkflow;
  }
};