Function pullModel

app/src/utils/pullModelManager.ts:56–132

(modelName: string, serverAddress: string)

}

const pullModel = async (modelName: string, serverAddress: string) => {
  if (state.status === 'pulling') {
    Logger.warn('PULL_MANAGER', 'A pull is already in progress.');
    return;
  }

  abortController = new AbortController();
  setState({
    status: 'pulling',
    modelName,
    statusText: 'Preparing to download...',
    progress: 0,
    completedBytes: 0,
    totalBytes: 0,
    errorText: ''
  });

  Logger.info('PULL_MANAGER', `Starting pull for model: ${modelName} from ${serverAddress}`);

  try {
    const response = await platformFetch(`${serverAddress}/api/pull`, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ name: modelName, stream: true }),
      signal: abortController.signal,
    });

    if (!response.body) throw new Error('Response body is empty.');
    if (response.status !== 200) {
      const errorData = await response.json();
      throw new Error(errorData.error || `Server responded with status ${response.status}`);
    }

    const reader = response.body.getReader();
    const decoder = new TextDecoder();

    while (true) {
      const { done, value } = await reader.read();
      if (done) {
        setState({ statusText: 'Verifying checksum...' });
        break;
      }

      const chunk = decoder.decode(value);
      const jsonLines = chunk.split('\n').filter(line => line.trim() !== '');

      jsonLines.forEach(line => {
        try {
          const data = JSON.parse(line);
          const newState: Partial<PullState> = { statusText: data.status };
          if (data.total && data.completed) {
            newState.progress = Math.round((data.completed / data.total) * 100);
            newState.completedBytes = data.completed;
            newState.totalBytes = data.total;
          }
          setState(newState);
          if (data.error) throw new Error(data.error);
        } catch(e) {