Class ElectronFetcher

apps/desktop/main/api/adapters.ts:28–69

// ==================== ElectronFetcher ====================

export class ElectronFetcher implements HttpFetcher {
  fetchToTempFile(baseUrl: string, remoteSessionId: string, token: string, params: FetchParams): Promise<string> {
    return new Promise<string>((resolve, reject) => {
      const url = buildPullUrl(baseUrl, remoteSessionId, params)
      const request = net.request(url)

      if (token) request.setHeader('Authorization', `Bearer ${token}`)
      request.setHeader('Accept', 'application/json')

      let tempFile = ''
      let writeStream: fs.WriteStream | null = null

      request.on('response', (response) => {
        if (response.statusCode !== 200) {
          reject(new Error(`HTTP ${response.statusCode}`))
          return
        }

        const contentType = (response.headers['content-type'] as string) || 'application/json'
        const isJsonl = contentType.includes('ndjson') || contentType.includes('jsonl')
        tempFile = getTempFilePath(isJsonl ? '.jsonl' : '.json')
        writeStream = fs.createWriteStream(tempFile)

        response.on('data', (chunk: Buffer) => writeStream!.write(chunk))
        response.on('end', () => writeStream!.end(() => resolve(tempFile)))
        response.on('error', (err: Error) => {
          writeStream?.end()
          cleanupTempFile(tempFile)
          reject(err)
        })
      })

      request.on('error', (err: Error) => {
        if (writeStream) writeStream.end()
        if (tempFile) cleanupTempFile(tempFile)
        reject(err)
      })

      request.end()
    })
  }
}

function cleanupTempFile(filePath: string): void {
  try {