Function resolveBarSource

src/tool/source-resolve.ts:40–67

(
  barService: BarService,
  input: { query?: string; barId?: string; asset?: AssetArg },
)

}

export async function resolveBarSource(
  barService: BarService,
  input: { query?: string; barId?: string; asset?: AssetArg },
): Promise<ResolveResult | { error: string }> {
  if (input.barId) {
    return { ref: { barId: input.barId, ...(input.asset ? { assetClass: input.asset } : {}) } }
  }
  if (!input.query) return { error: 'Pass either query (a symbol) or barId.' }

  const candidates = await barService.searchBarSources(input.query, { limit: 12 })
  if (candidates.length === 0) {
    return { error: `No bar source found for "${input.query}". Try searchBars to see candidates, or pass a barId.` }
  }
  const best = [...candidates].sort((a, b) => {
    const da = Number(isDerivative(a.barId))
    const db = Number(isDerivative(b.barId))
    if (da !== db) return da - db // non-derivative (the real contract) first
    const fa = a.barCapability ? FRESHNESS_RANK[a.barCapability] : 5
    const fb = b.barCapability ? FRESHNESS_RANK[b.barCapability] : 5
    return fa - fb // then freshest
  })[0]

  const assetClass = best.assetClass !== 'unknown' ? (best.assetClass as AssetClass) : undefined
  return {
    ref: { barId: best.barId, ...(assetClass ? { assetClass: assetClass as AssetArg } : {}) },
    pickedFrom: `${best.barId} (${best.barCapability ?? 'unknown'})`,
  }
}