// Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

library services.src.index.store.temporary_folder_file_mananer;

import 'dart:async';
import 'dart:io';

import 'package:analysis_server/src/services/index/store/split_store.dart';
import 'package:path/path.dart' as pathos;


/**
 * An implementation of [FileManager] that keeps each file in a separate file
 * in a temporary folder.
 */
class TemporaryFolderFileManager implements FileManager {
  Directory _directory;

  Directory get test_directory => _directory;

  @override
  void clear() {
    if (_directory != null) {
      try {
        _directory.deleteSync(recursive: true);
      } on FileSystemException {
        // For some reason, on Windows this sometimes results in the error:
        // "FileSystemException: Deletion failed, path = '...' (OS Error: The
        // process cannot access the file because it is being used by another
        // process., errno = 32).  (Speculation: perhaps createTempSync is not
        // successfully creating a unique name, so multiple processes are
        // trying to access the same file?)
        //
        // For now, work around the problem by ignoring the exception.
        // TODO(paulberry): fix the actual root cause of this bug.
      }
      _directory = null;
    }
  }

  @override
  void delete(String name) {
    if (_directory == null) {
      return;
    }
    File file = _getFile(name);
    try {
      file.deleteSync();
    } catch (e) {
    }
  }

  @override
  List<String> inspect_getAllNodeNames() {
    List<String> names = <String>[];
    List<FileSystemEntity> filePathList = _directory.listSync();
    for (FileSystemEntity file in filePathList) {
      String filePath = file.path;
      String name = pathos.basename(filePath);
      names.add(name);
    }
    return names;
  }

  @override
  Future<List<int>> read(String name) {
    if (_directory == null) {
      return new Future.value(null);
    }
    File file = _getFile(name);
    return file.readAsBytes().catchError((e) {
      return null;
    });
  }

  @override
  Future write(String name, List<int> bytes) {
    _ensureDirectory();
    return _getFile(name).writeAsBytes(bytes);
  }

  void _ensureDirectory() {
    if (_directory == null) {
      Directory temp = Directory.systemTemp;
      _directory = temp.createTempSync('AnalysisServices_Index');
    }
  }

  File _getFile(String name) {
    String path = pathos.join(_directory.path, name);
    return new File(path);
  }
}