//복구정책을 정의합니다.
public class Policy {	
	public static SupervisorStrategy strategy1 = new OneForOneStrategy(10, Duration.create(1, TimeUnit.MINUTES),		//복구시도제한 : 1분이내에 10번만 시도한다
		      DeciderBuilder
		           //다양한 예외에대한 가이드를 서비스코드와 분리할수가 있습니다.
		          .match(ArithmeticException.class, e -> SupervisorStrategy.resume())
		          .match(NullPointerException.class, e -> SupervisorStrategy.restart())
		          .match(IllegalArgumentException.class, e -> SupervisorStrategy.stop())
		          .matchAny(o -> SupervisorStrategy.escalate())
		          .build());
}

@Component("Supervisor")
@Scope("prototype")
public class Supervisor extends AbstractActor{
    private final LoggingAdapter log = Logging.getLogger(getContext().system(), "Supervisor");
    
	@Override
    public SupervisorStrategy supervisorStrategy() {
		//자신의 아이가 문제가 생길때 복구전략
      return Policy.strategy1;
    }
	
    @Override
    public Receive createReceive() {
      return receiveBuilder()
    	//부모가 아이를 책임지는구조로, 생성도 부모만 할수가 있습니다.(여기서는 생성의기능만 존재)
        .match(Props.class, props -> {
          getSender().tell(getContext().actorOf(props), getSelf());
        })
        .build();
    }    
}

@Component("BadChild")
@Scope("prototype")
public class BadChild extends AbstractActor {
	//우리가 생성한 클래스는 항상 착하지 않다.
	private final LoggingAdapter log = Logging.getLogger(getContext().system(), "BadChild");	
	int state = 0;
  
	@Override
	public Receive createReceive() {
		return receiveBuilder()
			.match(Exception.class, exception -> {
				log.error(exception.toString());
				/*
				전통적인 익센셥처리의 문제는, 익센셥은 스택구조이기때문에
				자기자신에게 발생한 익센셥을 해결하지못하는데 있고
				서비스코드에 처리방법이 썩임으로 예외처리코드가 서비스코드를 덮는데 있다.
				Akka의 예외처리는 예외가발생하도록 놔두고, 예외처리정책을 우아하게 분리할수가 있다.
				이것이 Let it Crash 전략이다.
				*/
				throw exception;
			})
			.match(Integer.class, i -> state = i)
			.matchEquals("get", s -> getSender().tell(state, getSelf()))
			.build();
	}
}

	protected void supervisorTest(ActorSystem system,SpringExtension ext) throws Exception {
		new TestKit(system) {{
			Props superprops = ext.props("Supervisor");
			ActorRef supervisor = system.actorOf(superprops, "supervisor");
			ActorRef probe = getRef();
			
			//나쁜아이를 허용하는 전략으로 부모(감독)를 통해 아이를 생성합니다.
			final CompletableFuture<Object> future = PatternsCS.ask(supervisor, ext.props("BadChild") , 5000).toCompletableFuture();
			ActorRef badChild = (ActorRef)future.get();
			
			//나쁜아이의 상태를 42로 만든다...
			badChild.tell(42, ActorRef.noSender());
			
			//나쁜아이의 상태를 물어보고, probe에 전달하도록한다
			badChild.tell("get", probe);
			
			//prove에 저장된 메시지가 42인지 확인한다.
			expectMsgEquals(42);
			
			// ArithmeticException 예외는 그냥 진행하도록 정의를 하였다.
			badChild.tell( new ArithmeticException(), ActorRef.noSender() );
			
			//아이가 살아있는지 확인...
			badChild.tell("get", probe);
			expectMsgEquals(42);
			
			// NullPointerException 예외는 아이를 다시 초기화하도록 정의하였다.
			badChild.tell( new NullPointerException(), ActorRef.noSender() );
			
			//아이가 초기화 되었는지 확인 ( 초기상태 0)
			badChild.tell("get", probe);
			expectMsgEquals(0);
			
			//액터를 확인하기위한 Util 액터로, 죽은지 여부를 확인할수가 있습니다.
			TestProbe probe2 = new TestProbe(system);
			probe2.watch(badChild);
			
			// IllegalArgumentException 익센셥이 발생하면 아이를 보내기로 결정하였다.
			badChild.tell( new IllegalArgumentException(), ActorRef.noSender()  );
									
			// 아이가 사라진지 체크...
			probe2.expectMsgClass(Terminated.class);
			
		}};		
	}