Method fetchToTempFile

apps/cli/src/sync/adapters.ts:28–47

(baseUrl: string, remoteSessionId: string, token: string, params: FetchParams)

export class NodeFetcher implements HttpFetcher {
  async fetchToTempFile(baseUrl: string, remoteSessionId: string, token: string, params: FetchParams): Promise<string> {
    const url = buildPullUrl(baseUrl, remoteSessionId, params)
    const headers: Record<string, string> = {
      Accept: 'application/json',
    }
    if (token) headers['Authorization'] = `Bearer ${token}`

    const response = await fetch(url, { headers, signal: AbortSignal.timeout(120_000) })
    if (!response.ok) {
      throw new Error(`HTTP ${response.status}`)
    }

    const contentType = response.headers.get('content-type') || 'application/json'
    const isJsonl = contentType.includes('ndjson') || contentType.includes('jsonl')
    const tempFile = getTempFilePath(isJsonl ? '.jsonl' : '.json')

    const buffer = Buffer.from(await response.arrayBuffer())
    fs.writeFileSync(tempFile, buffer)
    return tempFile
  }
}

// ==================== DirectImporter ====================