boursecu_user/src/utils/price.ts

import { getLastPrice, getPrice } from '@/api/home'
import type { Price, PriceUp } from '@/models/home'
import { ref } from 'vue'

let interval: ReturnType<typeof setInterval> | undefined

/** @deprecated از lastPrice استفاده کنید — برای سازگاری با کد قدیمی sync می‌شود */
export const price = ref<Price>()
export const lastPrice = ref<Price>()
export const olderPrice = ref<number | undefined>(0)

/** buy/sell نمایش و معامله — همان buy/sell/price_last از /api/price/last */
export function getTradeBuyPrice(p?: Price | null) {
  return p?.buy ?? p?.price_last ?? p?.up?.buy ?? 0
}

export function getTradeSellPrice(p?: Price | null) {
  return p?.sell ?? p?.up?.sell ?? 0
}

/** up جدا نگه داشته می‌شود؛ buy/sell/price_last از lastPrice سرور دست‌نخورده می‌ماند */
export function normalizePriceResponse(data: Price): Price {
  return data
}

export async function setIntervalGetAllPrice() {
  try {
    interval = setInterval(async () => {
      await getLastPrices()
    }, 10000)
  } catch (e) {
    console.log(e)
  }
}

export async function setIntervalGetLastPrice() {
  return setIntervalGetAllPrice()
}

/** @deprecated فقط getLastPrices را صدا بزنید */
export async function getUpPrice() {
  await getLastPrices()
}

async function fetchUpPrices(): Promise<PriceUp | undefined> {
  try {
    const up = await getPrice()
    if (up?.buy != null && up?.sell != null) {
      return { buy: up.buy, sell: up.sell }
    }
  } catch (e) {
    console.log(e)
  }
}

export async function getLastPrices() {
  try {
    let dataLast = await getLastPrice()

    if (!dataLast?.up) {
      const up = await fetchUpPrices()
      if (up) {
        dataLast = { ...dataLast, up }
      }
    }

    const normalized = normalizePriceResponse(dataLast)
    if (lastPrice.value?.price_last != normalized.price_last) {
      olderPrice.value = lastPrice.value?.price_last
    }
    lastPrice.value = normalized
    price.value = {
      ...normalized,
      buy: getTradeBuyPrice(normalized),
      sell: getTradeSellPrice(normalized),
    }
  } catch (e) {
    console.log(e)
  }
}

export function stopPriceInterval() {
  if (interval) {
    clearInterval(interval)
    interval = undefined
  }
}

export function percentPriceChanged() {
  if (!olderPrice.value) {
    return 0
  }
  return ((lastPrice.value?.price_last! - olderPrice.value) * 100) / olderPrice.value
}