6. productsディレクトリ

import {db, FirebaseTimestamp} from '../../firebase/index';
import {push} from "connected-react-router";
import {deleteProductAction, fetchProductsAction} from "./actions"
import {hideLoadingAction, showLoadingAction} from "../loading/actions";
import {createPaymentIntent} from "../payments/operations";

const productsRef = db.collection('products')

export const deleteProduct = (id) => {
  return async (dispatch, getState) => {
    productsRef.doc(id).delete()
      .then(() => {
        const prevProducts = getState().products.list
        const nextProducts = prevProducts.filter(product => product.id !== id)
        dispatch(deleteProductAction(nextProducts))
      })
  }
}

export const fetchProducts = (gender, category) => {
  return async (dispatch) => {
    let query = productsRef.orderBy('updated_at', 'desc');
    query = (gender !== "") ? query.where('gender', '==', gender) : query;
    query = (category !== "") ? query.where('category', '==', category) : query;

    query.get()
      .then(snapshots => {
        const productList = []
        snapshots.forEach(snapshot => {
          const product = snapshot.data()
          productList.push(product)
        })
        dispatch(fetchProductsAction(productList))
      })
  }
}

export const orderProduct = (productsInCart, price) => {
  return async (dispatch, getState) => {
    dispatch(showLoadingAction("決済処理中..."));

    const uid = getState().users.uid;
    const userRef = db.collection('users').doc(uid);
    const timestamp = FirebaseTimestamp.now();
    let products = {};
    let soldOutProducts = [];

    const batch = db.batch();

    for (const product of productsInCart) {
      const snapshot = await productsRef.doc(product.productId).get();
      const sizes = snapshot.data().sizes;

      // Create a new array of the product sizes
      const updateSizes = sizes.map(size => {
        if (size.size === product.size) {
          if (size.quantity === 0) {
            soldOutProducts.push(product.name);
            return size
          }
          return {
            size: size.size,
            quantity: size.quantity - 1
          }
        } else {
          return size
        }
      });

      products[product.productId] = {
        id: product.productId,
        images: product.images,
        name: product.name,
        price: product.price,
        size: product.size
      };

      batch.update(productsRef.doc(product.productId), {sizes: updateSizes});
      batch.delete(userRef.collection('cart').doc(product.cartId));
    }

    if (soldOutProducts.length > 0) {
      const errorMessage = (soldOutProducts.length > 1) ? soldOutProducts.join('と') : soldOutProducts[0];
      alert('大変申し訳ありません。' + errorMessage + 'が在庫切れとなったため注文処理を中断しました。');
      return false
    } else {
      // 注文履歴データを作成
      const orderRef = userRef.collection('orders').doc();
      const date = timestamp.toDate();
      // 配送日を3日後に設定
      const shippingDate = FirebaseTimestamp.fromDate(new Date(date.setDate(date.getDate() + 3)));

      const history = {
        amount: price,
        created_at: timestamp,
        id: orderRef.id,
        products: products,
        shipping_date: shippingDate,
        updated_at: timestamp
      };

      batch.set(orderRef, history, {merge: true});

      // Stripeの決済処理を実行する
      const customerId = getState().users.customer_id
      const paymentMethodId = getState().users.payment_method_id
      const paymentIntent = await createPaymentIntent(price, customerId, paymentMethodId)

      // 決済処理が成功
      if (paymentIntent) {
        // DBを更新
        return batch.commit()
          .then(() => {
            dispatch(hideLoadingAction());
            dispatch(push('/order/complete'))
          })
          .catch(() => {
            dispatch(hideLoadingAction());
            alert('注文処理に失敗しました。通信環境をご確認のうえ、もう一度お試しください。')
          })
      } else {
        dispatch(hideLoadingAction());
        alert('注文処理に失敗しました。通信環境をご確認のうえ、もう一度お試しください。')
      }
    }
  }
}

export const saveProduct = (id, name, description, category, gender, price, sizes, images) => {
  return async (dispatch) => {
    const timestamp = FirebaseTimestamp.now();

    const data = {
      category: category,
      description: description,
      gender: gender,
      images: images,
      name: name,
      price: parseInt(price, 10),
      sizes: sizes,
      updated_at: timestamp
    }

    if (id === "") {
      const ref = productsRef.doc()
      data.created_at = timestamp;
      id = ref.id;
      data.id = id;
    }

    return productsRef.doc(id).set(data, {merge: true})
      .then(() => {
        dispatch(push('/'))
      }).catch((error) => {
        throw new Error(error)
      })
  }
}

export const DELETE_PRODUCT = "DELETE_PRODUCT";
export const deleteProductAction = (products) => {
    return {
        type: "DELETE_PRODUCT",
        payload: products
    }
}

export const FETCH_PRODUCTS = "FETCH_PRODUCTS";
export const fetchProductsAction = (products) => {
    return {
        type: "FETCH_PRODUCTS",
        payload: products
    }
}

export const INIT_PRODUCTS = "INIT_PRODUCTS";
export const initProductsAction = () => {
    return {
        type: "INIT_PRODUCTS",
        payload: null
    }
}

import * as Actions from './actions';
import { initialState } from '../store/initialState';

export const ProductsReducer = (state = initialState.products, action) => {
    switch (action.type) {
        case Actions.DELETE_PRODUCT:
            return {
                ...state,
                list: action.payload
            };
        case Actions.FETCH_PRODUCTS:
            return {
                ...state,
                list: action.payload
            };
        case Actions.INIT_PRODUCTS:
            return {
                ...initialState.products
            };
        default:
            return state
    }
}

import { createSelector } from 'reselect';

const productsSelector = (state) => state.products;

export const getProducts = createSelector(
    [productsSelector],
    state => state.list
);