package com.eomcs.pms.listener;

import com.eomcs.context.ApplicationContextListener;

public class AppInitListener implements ApplicationContextListener {
  @Override
  public void contextInitialized() {
    System.out.println("프로젝트 관리 시스템(PMS)에 오신 걸 환영합니다!");
  }
  
  @Override
  public void contextDestroyed() {
    System.out.println("프로젝트 관리 시스템(PMS)을 종료합니다!");
  }
}

public void service () {
    System.out.println("프로젝트 관리 시스템(PMS)에 오신 걸 환영합니다!");
    //...
    System.out.println("프로젝트 관리 시스템(PMS)을 종료합니다!");
}

public class App {

  // 옵저버를 보관할 컬렉션 객체
  List<ApplicationContextListener> listeners = new ArrayList<>();

  // 옵저버를 등록하는 메서드
  public void addApplicationContextListener(ApplicationContextListener listener) {
    listeners.add(listener);
  }

  // 옵저버를 제거하는 메서드
  public void removeApplicationContextListener(ApplicationContextListener listener) {
    listeners.remove(listener);
  }

  // service() 실행 전에 옵저버에게 통지한다.
  private void notifyApplicationContextListenerOnServiceStarted() {
    for (ApplicationContextListener listener : listeners) {
      // 곧 서비스를 시작할테니 준비하라고,
      // 서비스 시작에 관심있는 각 옵저버에게 통지한다.
      listener.contextInitialized();
    }
  }

  // service() 실행 후에 옵저버에게 통지한다.
  private void notifyApplicationContextListenerOnServiceStopped() {
    for (ApplicationContextListener listener : listeners) {
      // 서비스가 종료되었으니 마무리 작업하라고, 
      // 마무리 작업에 관심있는 각 옵저버에게 통지한다.
      listener.contextDestroyed();
    }
  }


  public static void main(String[] args) throws Exception {
    App app = new App();

    // **옵저버 등록**
    app.addApplicationContextListener(new AppInitListener());

    app.service();
  }

  public void service() throws Exception {

    notifyApplicationContextListenerOnServiceStarted();
    //..생략
      
    notifyApplicationContextListenerOnServiceStopped();
      
  }
}

public interface ApplicationContextListener {
  // 발행자(애플리케이션)가 애플리케이션 시작을 알리기 위해 호출하는 메서드
  void contextInitialized(Map<String, Object> context);

  // 발행자(애플리케이션)가 애플리케이션 종료를 알리기 위해 호출하는 메서드
  void contextDestroyed(Map<String, Object> context);
}

public class AppInitListener implements ApplicationContextListener {
  @Override
  public void contextInitialized(Map<String, Object> context) {
    System.out.println("프로젝트 관리 시스템(PMS)에 오신 걸 환영합니다!");
  }

  @Override
  public void contextDestroyed(Map<String, Object> context) {
    System.out.println("프로젝트 관리 시스템(PMS)을 종료합니다!");
  }
}

public class App {
  Map<String, Object> context = new HashMap<>();
  //...
    // service() 실행 전에 옵저버에게 통지한다.
  private void notifyApplicationContextListenerOnServiceStarted() {
    for (ApplicationContextListener listener : listeners) {
      // 서비스가 종료되었으니 마무리 작업하라고, 
      // 마무리 작업에 관심있는 각 옵저버에게 통지한다.
      // => 옵저버에게 맵 객체를 넘겨준다.
      // => 옵저버는 작업 결과를 파라미터로 넘겨준 Map객체에 담아줄 것이다.
      // 빈 그릇 줄 테니까, 작업 결과 담아줘!!
      listener.contextInitialized(context);
    }
  }

  // service() 실행 후에 옵저버에게 통지한다.
  private void notifyApplicationContextListenerOnServiceStopped() {
    for (ApplicationContextListener listener : listeners) {
      // 서비스가 종료되었으니 마무리 작업하라고, 
      // 마무리 작업에 관심있는 각 옵저버에게 통지한다.
      // => 옵저버에게 맵 객체를 넘겨준다.
      // => 옵저버는 작업 결과를 파라미터로 넘겨준 Map객체에 담아줄 것이다.
      listener.contextDestroyed(context);
    }
  }
//..
}

package com.eomcs.pms.listener;


// 게시물, 회원, 프로젝트, 작업 데이터를 파일에서 로딩하고 파일로 저장하는 일을 한다.
public class DataHandlerListener implements ApplicationContextListener {
  
  //(1) List, File을 인스턴스 필드로 선언한다.
  // 여기서 List 객체는 App에서 모른다. 따라서 App에서 사용하기 위해
  // 파라미터로 받은 Map 객체에 넣어줘야 한다.
  List<Board> boardList = new ArrayList<>();
  File boardFile = new File("./board.json"); // 게시글을 저장할 파일 정보

  List<Member> memberList = new LinkedList<>();
  File memberFile = new File("./member.json"); // 회원을 저장할 파일 정보

  List<Project> projectList = new LinkedList<>();
  File projectFile = new File("./project.json"); // 프로젝트를 저장할 파일 정보

  List<Task> taskList = new ArrayList<>();
  File taskFile = new File("./task.json"); // 작업을 저장할 파일 정보

  
  @Override
  public void contextInitialized(Map<String, Object> context) {
    // 애플리케이션의 서비스가 시작되면 먼저 파일에서 데이터를 로딩한다.
    // 파일에서 데이터 로딩
    loadData(boardList, boardFile, Board[].class);
    loadData(memberList, memberFile, Member[].class);
    loadData(projectList, projectFile, Project[].class);
    loadData(taskList, taskFile, Task[].class);
    
    // 옵저버가 파일에서 데이터(게시물, 회원, 프로젝트, 작업 데이터)를 읽어 
    // List 컬렉션에 저장한 다음 
    // 발행자(App 객체)가 를 사용할 수 있도록  객체에 담아서 공유한다.
    context.put("boardList", boardList);
    context.put("memberList", memberList);
    context.put("projectList", projectList);
    context.put("taskList", taskList);
  }

  @Override
  public void contextDestroyed(Map<String, Object> context) {
    // 애플리케이션 서비스가 종료되면 컬렉션 객체에 보관 데이터를 저장한다.
    // 데이터를 파일에 저장
    saveData(boardList, boardFile);
    saveData(memberList, memberFile);
    saveData(projectList, projectFile);
    saveData(taskList, taskFile);
  }
  

  // 파일에서 JSON 문자열을 읽어 지정한 타입의 객체를 생성한 후 컬렉션에 저장한다.
  private <T> void loadData(
      Collection<T> list, // 객체를 담을 컬렉션
      File file, // JSON 문자열이 저장된 파일
      Class<T[]> clazz // JSON 문자열을 어떤 타입의 배열로 만들 것인지 알려주는 클래스 정보
      ) {
      //.....생략
  }
  
  private void saveData(Collection<?> list, File file) {
    //.....생략
  }
}

public class App {
  public static void main(String[] args) throws Exception {
    App app = new App();

    // 옵저버 등록
    app.addApplicationContextListener(new AppInitListener());
    app.addApplicationContextListener(new DataHandlerListener());
    
	app.service();
  }
  @SuppressWarnings("unchecked")
  public void service() {

    notifyApplicationContextListenerOnServiceStarted();
    // 옵저버 실행이 끝난 다음에 결과가 Map에 담겨 있다고 가정하고 get하면 된다.
    Map<String,Command> commandMap = new HashMap<>();

    // 옵저버가 작업한 결과를 맵에서 꺼낸다.
    List<Board> boardList = (List<Board>) context.get((List<Board>) context.get("boardList"));
    List<Board> memberList = (List<Board>) context.get((List<Board>) context.get("memberList"));
    List<Board> projectList = (List<Board>) context.get((List<Board>) context.get("projectList"));
    List<Board> taskList = (List<Board>) context.get((List<Board>) context.get("taskList"));
    //...
    notifyApplicationContextListenerOnServiceStopped();
  }
  //....
}