import axios from "axios";
import { getSession } from "next-auth/react";
import {
  CLEAR_ERRORS,
  ENQUIRY_SUBMIT_FAIL,
  ENQUIRY_SUBMIT_REQUEST,
  ENQUIRY_SUBMIT_SUCCESS,
  GET_ENQUIRIES_BY_VENDOR_FAIL,
  GET_ENQUIRIES_BY_VENDOR_REQUEST,
  GET_ENQUIRIES_BY_VENDOR_SUCCESS
} from "../constants/enquiryConstants";
import qs from "qs";

export const sendEnquiry = async ({ activityId, userId, date, vendorId, quantity }) => {
  const data = {
    data: {
      experience: activityId,
      end_user: userId,
      vendor: vendorId,
      date,
      status: "pending",
      quantity
    }
  };
  const config = {
    headers: {
      "Content-Type": "application/json"
    }
  };
  console.log("data", data);
  const response = await axios.post(`${process.env.NEXT_PUBLIC_BACKEND_API_URL}/api/enquires`, data, config);

  return response.data;
};

// Clear errors
export const clearErrors = () => async dispatch => {
  dispatch({
    type: CLEAR_ERRORS
  });
};

export const getEnquiriesByVendor = () => async dispatch => {
  try {
    const session = await getSession();
    if (!session) {
      return;
    }
    const vendorConfig = {
      headers: {
        "Content-Type": "application/json",
        Authorization: `Bearer ${session.jwt}`
      }
    };
    const vendorQuery = {
      filters: {
        user: {
          id: { $eq: session.id }
        }
      }
    };

    const vendorQueryString = qs.stringify(vendorQuery, {
      encodeValuesOnly: true
    });

    const vendorResponse = await axios.get(`${process.env.NEXT_PUBLIC_BACKEND_API_URL}/api/vendors/?${vendorQueryString}`, vendorConfig);
    console.log("session", vendorResponse.data.data[0].id);
    dispatch({
      type: GET_ENQUIRIES_BY_VENDOR_REQUEST
    });

    const config = {
      headers: {
        "Content-type": "application/json",
        Authorization: `Bearer ${session.jwt}`
      }
    };

    const query = {
      filters: {
        vendor: {
          id: { $eq: vendorResponse.data.data[0].id }
        }
      },
      populate: ["vendor", "experience", "end_user"]
    };

    const queryString = qs.stringify(query, {
      encodeValuesOnly: true
    });
    // console.log("querystring", query);
    const response = await axios.get(`${process.env.NEXT_PUBLIC_BACKEND_API_URL}/api/enquires/?${queryString}`, config);
    console.log("response", response);
    dispatch({
      type: GET_ENQUIRIES_BY_VENDOR_SUCCESS,
      payload: response.data.data
    });
  } catch (error) {
    dispatch({
      type: GET_ENQUIRIES_BY_VENDOR_FAIL,
      payload: error.response.data
    });
  }
};

export const changeEnquiryStatus = async ({ status, id }) => {
  try {
    const session = await getSession();
    if (!session) {
      return;
    }
    const config = {
      headers: {
        "Content-type": "application/json",
        Authorization: `Bearer ${session.jwt}`
      }
    };

    const response = await axios.put(`${process.env.NEXT_PUBLIC_BACKEND_API_URL}/api/enquires/${id}`, { data: { status } }, config);
    return response.data;
  } catch (error) {}
};