1#@!#!123s

ALWAYS HENGHENG888 1#@!#!123s
: / var / www / chinawholesale-frontend-next / src / __server__ /
Filename : generale.ts
back
import { revalidateTag } from 'next/cache'
import { ProviderType } from '@/types/global'
import { fetchServerApi } from '@/__server__/fetch-server-api'
import { CACHE_KEY } from '@/__server__/cache-key'
import { CACHE_TTL } from '@/__server__/cache-ttl'

process.env.NODE_TLS_REJECT_UNAUTHORIZED = process.env.NEXT_PUBLIC_NODE_ENV === 'production' ? '1' : '0'

export const BASE_URL = process.env.NEXT_PUBLIC_API_ENDPOINT + `api/v1`

async function fetchWithTag({
                                endpoint,
                                params,
                            }: {
    endpoint: string
    params: {
        provider: ProviderType
        tag: string
        expire: number
        keyword?: string
        page?: string
    }
}) {
    const newParams = new URLSearchParams({ ...params, expire: params.expire.toString() })
    const url = `${endpoint}?${newParams.toString()}`
    // console.log({url})
    return await fetchServerApi(url, {
        next: { tags: [params.tag], revalidate: params.expire },
    })
}

export const CACHE_REVALIDATE = (tagName = '') => {
    if (tagName) revalidateTag(tagName)
}

export const fetchData = async (url = '', rest = {}) => {
    try {
        const result = await fetch(`${BASE_URL}/${url}`, {
            headers: {
                Accept: 'application/json',
                'Content-Type': 'application/json',
            },
            ...rest,
        })
        return await result.json()
    } catch (error) {
        console.error(error)
    }

    return null
}

export async function getUsersData(token?: string | null) {
    try {
        const result = await fetch(`${BASE_URL}/user`, {
            method: 'GET',
            headers: {
                Accept: 'application/json',
                Authorization: `Bearer ${token}`,
            },
            // referrerPolicy: 'origin',
            // redirect: 'follow',
            cache: 'no-store',
        })
        const data = await result.json()
        return data?.data || null
    } catch (e) {
        console.error('Invalid JSON:', e)
    }
    return null
}

export const getSettingsData = async () => {
    const response = await fetchServerApi('general', {
        next: { tags: [CACHE_KEY.SETTINGS], revalidate: CACHE_TTL.ONE_HOUR },
    })
    return response?.data || null
}

export const getBannersData = async () => {
    const tagName = 'banners'
    const data = await fetchData(`banners`, {
        // cache: 'no-store',
        next: { tags: [tagName], revalidate: 100 },
    })
    const banners = data?.banners || []
    if (!banners.length) {
        CACHE_REVALIDATE(tagName)
    }
    return banners
}

export async function getAllCategoriesData(provider: ProviderType = 'Alibaba1688') {
    const tag = CACHE_KEY.CATEGORIES([provider, 'all'], provider)
    const expire = CACHE_TTL.ONE_DAY
    const response = await fetchWithTag({
        endpoint: 'all-categories',
        params: {
            provider,
            tag,
            expire,
        },
    })

    // console.log({ CategoriesData: response })

    return response?.data || []
}

export async function getTopCategoriesData(provider: ProviderType = 'Alibaba1688') {
    const tag = CACHE_KEY.CATEGORIES(['top'], provider)
    const expire = CACHE_TTL.ONE_DAY
    const response = await fetchWithTag({
        endpoint: 'top-categories',
        params: {
            provider,
            tag,
            expire,
        },
    })
    return response?.data
}

export async function getSingleCategory(slug: string, provider: ProviderType = 'Alibaba1688') {
    const tag = CACHE_KEY.CATEGORIES([slug], provider)
    const expire = CACHE_TTL.ONE_HOUR
    const response = await fetchWithTag({
        endpoint: `single-category/${slug}`,
        params: {
            provider,
            tag,
            expire,
        },
    })
    return response?.data
}

export const getWholesaleSectionData = async (section: string, provider: ProviderType = 'Alibaba1688') => {
    const tag = CACHE_KEY.SECTION([section], provider)
    const expire = CACHE_TTL.FIFTEEN_DAY
    const response = await fetchWithTag({
        endpoint: `section-products/${section}`,
        params: {
            provider,
            tag,
            expire,
        },
    })

    if (!response?.data?.Content?.length) {
        revalidateTag(tag)
    }
    return response?.data?.Content || []
}

export async function getCategoryProducts(slug: string, query = {}) {
    const newQuery = new URLSearchParams(query)
    const pagePrepare = newQuery.get('page') as string
    const page = pagePrepare ? pagePrepare : '1'
    const tag = CACHE_KEY.CATEGORIES([slug, 'products', page], 'Alibaba1688')
    const expire = CACHE_TTL.THREE_DAY
    const response = await fetchWithTag({
        endpoint: `category-products/${slug}`,
        params: {
            provider: 'Alibaba1688',
            tag,
            expire,
            page,
        },
    })

    if (!response?.data?.Content?.length) {
        revalidateTag(tag)
    }

    return response?.data
}

export async function getSearchProducts(query = {}) {
    const newQuery = new URLSearchParams(query)
    const pagePrepare = newQuery.get('page') as string
    const page = pagePrepare ? pagePrepare : '1'
    const keyword = newQuery.get('keyword') as string
    const tag = CACHE_KEY.SEARCH([keyword, page], 'Alibaba1688')
    const expire = CACHE_TTL.SIX_HOUR

    const response = await fetchWithTag({
        endpoint: `search`,
        params: {
            provider: 'Alibaba1688',
            tag,
            expire,
            keyword,
            page,
        },
    })

    if (!response?.data?.Content?.length) {
        revalidateTag(tag)
    }

    return response?.data
}

export async function getImageSearchProducts(query = {}) {
    const newQuery = new URLSearchParams(query)
    const pagePrepare = newQuery.get('page') as string
    const page = pagePrepare ? pagePrepare : '1'
    const keyword = newQuery.get('uuid') as string
    const tag = CACHE_KEY.PICTURE([keyword, page], 'Alibaba1688')
    const expire = CACHE_TTL.FIFTEEN_DAY
    const response = await fetchWithTag({
        endpoint: `get-picture-result`,
        params: {
            provider: 'Alibaba1688',
            tag,
            expire,
            keyword,
            page,
        },
    })

    if (!response?.data?.Content?.length) {
        revalidateTag(tag)
    }

    return response?.data
}

export async function getSingleProducts(id: string) {
    const tag = CACHE_KEY.PRODUCT([id], 'Alibaba1688')
    const expire = CACHE_TTL.THREE_DAY
    const response = await fetchWithTag({
        endpoint: `product/${id}`,
        params: {
            provider: 'Alibaba1688',
            tag,
            expire,
        },
    })
    return response?.data
}

export async function getSellerWithProducts(id: string, query = {}, provider: ProviderType = 'Alibaba1688') {
    const newQuery = new URLSearchParams(query)
    const pagePrepare = newQuery.get('page') as string
    const page = pagePrepare ? pagePrepare : '1'
    const tag = CACHE_KEY.SELLER([id, page], provider)
    const expire = CACHE_TTL.ONE_MONTH
    const response = await fetchWithTag({
        endpoint: `vendor-items/${id}`,
        params: {
            provider: provider,
            tag,
            expire,
        },
    })

    if (!response?.data?.Content?.length) {
        revalidateTag(tag)
    }
    return response?.data
}

export const getPageData = async (slug: string) => {
    return await fetchData(`page/${slug}`, {
        // cache: 'no-store',
        next: { tags: ['page', slug], revalidate: CACHE_TTL.ONE_DAY },
    })
}