///*
// * Licensed to the Apache Software Foundation (ASF) under one or more
// * contributor license agreements.  See the NOTICE file distributed with
// * this work for additional information regarding copyright ownership.
// * The ASF licenses this file to You under the Apache License, Version 2.0
// * (the "License"); you may not use this file except in compliance with
// * the License.  You may obtain a copy of the License at
// *
// *     http://www.apache.org/licenses/LICENSE-2.0
// *
// * Unless required by applicable law or agreed to in writing, software
// * distributed under the License is distributed on an "AS IS" BASIS,
// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// * See the License for the specific language governing permissions and
// * limitations under the License.
// */
//package org.apache.dubbo.rpc.protocol.dubbo;
//
//
//import org.apache.dubbo.common.URL;
//import org.apache.dubbo.common.utils.NetUtils;
//import org.apache.dubbo.rpc.Exporter;
//import org.apache.dubbo.rpc.Invoker;
//import org.apache.dubbo.rpc.RpcContext;
//import org.apache.dubbo.rpc.model.ApplicationModel;
//import org.apache.dubbo.rpc.model.ConsumerMethodModel;
//import org.apache.dubbo.rpc.model.ConsumerModel;
//import org.apache.dubbo.rpc.model.ServiceMetadata;
//import org.apache.dubbo.rpc.protocol.dubbo.support.ProtocolUtils;
//
//import org.junit.jupiter.api.AfterEach;
//import org.junit.jupiter.api.Assertions;
//import org.junit.jupiter.api.BeforeEach;
//import org.junit.jupiter.api.Test;
//
//import java.io.Serializable;
//import java.lang.reflect.Method;
//import java.util.ArrayList;
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//import java.util.concurrent.ExecutionException;
//import java.util.concurrent.Future;
//import java.util.concurrent.TimeUnit;
//
//import static org.apache.dubbo.rpc.Constants.ASYNC_KEY;
//
//public class ImplicitCallBackTest {
//
//    protected Exporter<IDemoService> exporter = null;
//    protected Invoker<IDemoService> reference = null;
//
//    protected URL serviceURL = null;
//    protected URL consumerUrl = null;
//    Method onReturnMethod;
//    Method onThrowMethod;
//    Method onInvokeMethod;
//    NofifyImpl notify = new NofifyImpl();
//    //================================================================================================
//    IDemoService demoProxy = null;
//
//    @BeforeEach
//    public void setUp() throws SecurityException, NoSuchMethodException {
//        onReturnMethod = Nofify.class.getMethod("onreturn", new Class<?>[]{Person.class, Integer.class});
//        onThrowMethod = Nofify.class.getMethod("onthrow", new Class<?>[]{Throwable.class, Integer.class});
//        onInvokeMethod = Nofify.class.getMethod("oninvoke", new Class<?>[]{Integer.class});
//    }
//
//    @AfterEach
//    public void tearDown() {
//        ProtocolUtils.closeAll();
//    }
//
//    public void initOrResetService() {
//        destroyService();
//        exportService();
//        referService();
//    }
//
//    public void initOrResetExService() {
//        destroyService();
//        exportExService();
//        referService();
//    }
//
//    public void destroyService() {
//        demoProxy = null;
//        try {
//            if (exporter != null) exporter.unexport();
//            if (reference != null) reference.destroy();
//        } catch (Exception e) {
//        }
//    }
//
//    void referService() {
//        demoProxy = (IDemoService) ProtocolUtils.refer(IDemoService.class, consumerUrl);
//    }
//
//    public void exportService() {
//        exporter = ProtocolUtils.export(new NormalDemoService(), IDemoService.class, serviceURL);
//    }
//
//    public void exportExService() {
//        exporter = ProtocolUtils.export(new ExceptionDemoExService(), IDemoService.class, serviceURL);
//    }
//
//    public void initOrResetUrl(boolean isAsync) throws Exception {
//        int port = NetUtils.getAvailablePort();
//        consumerUrl = serviceURL = URL.valueOf("dubbo://127.0.0.1:" + port + "/" + IDemoService.class.getName() + "?group=" + System.nanoTime() + "&async=" + isAsync + "&timeout=100000&reference.filter=future");
//    }
//
//    public void initImplicitCallBackURL_onlyOnthrow() throws Exception {
//        Map<String, Object> attitudes = new HashMap<>();
//        ConsumerMethodModel.AsyncMethodInfo asyncMethodInfo = new ConsumerMethodModel.AsyncMethodInfo();
//        asyncMethodInfo.setOnthrowInstance(notify);
//        asyncMethodInfo.setOnthrowMethod(onThrowMethod);
//        ServiceMetadata metada = new ServiceMetadata();
//
//        ConsumerModel consumerModel = new ConsumerModel(consumerUrl.getServiceInterface(), "Dubbo", "1.0.0", IDemoService.class);
//        consumerModel.getMethodModel("get").addAttribute(ASYNC_KEY, asyncMethodInfo);
//        ApplicationModel.initConsumerModel(consumerUrl.getServiceKey(), consumerModel);
//    }
//
//    //================================================================================================
//
//    public void initImplicitCallBackURL_onlyOnreturn() throws Exception {
//        Map<String, Object> attitudes = new HashMap<>();
//        ConsumerMethodModel.AsyncMethodInfo asyncMethodInfo = new ConsumerMethodModel.AsyncMethodInfo();
//        asyncMethodInfo.setOnreturnInstance(notify);
//        asyncMethodInfo.setOnreturnMethod(onReturnMethod);
//        ConsumerModel consumerModel = new ConsumerModel(consumerUrl.getServiceInterface(), "Dubbo", "1.0.0", IDemoService.class);
//        consumerModel.getMethodModel("get").addAttribute(ASYNC_KEY, asyncMethodInfo);
//        ApplicationModel.initConsumerModel(consumerUrl.getServiceKey(), consumerModel);
//    }
//
//    public void initImplicitCallBackURL_onlyOninvoke() throws Exception {
//        Map<String, Object> attitudes = new HashMap<>();
//        ConsumerMethodModel.AsyncMethodInfo asyncMethodInfo = new ConsumerMethodModel.AsyncMethodInfo();
//        asyncMethodInfo.setOninvokeInstance(notify);
//        asyncMethodInfo.setOninvokeMethod(onInvokeMethod);
//        ConsumerModel consumerModel = new ConsumerModel(consumerUrl.getServiceInterface(), "Dubbo", "1.0.0", IDemoService.class);
//        consumerModel.getMethodModel("get").addAttribute(ASYNC_KEY, asyncMethodInfo);
//        ApplicationModel.initConsumerModel(consumerUrl.getServiceKey(), consumerModel);
//    }
//
//    @Test
//    public void test_CloseCallback() throws Exception {
//        initOrResetUrl(false);
//        initOrResetService();
//        Person ret = demoProxy.get(1);
//        Assertions.assertEquals(1, ret.getId());
//        destroyService();
//    }
//
//    @Test
//    public void test_Sync_Onreturn() throws Exception {
//        initOrResetUrl(false);
//        initOrResetService();
//        initImplicitCallBackURL_onlyOnreturn();
//
//        int requestId = 2;
//        Person ret = demoProxy.get(requestId);
//        Assertions.assertEquals(requestId, ret.getId());
//        for (int i = 0; i < 10; i++) {
//            if (!notify.ret.containsKey(requestId)) {
//                Thread.sleep(200);
//            } else {
//                break;
//            }
//        }
//        Assertions.assertEquals(requestId, notify.ret.get(requestId).getId());
//        destroyService();
//    }
//
//    @Test
//    public void test_Ex_OnReturn() throws Exception {
//        initOrResetUrl(true);
//        initOrResetExService();
//        initImplicitCallBackURL_onlyOnreturn();
//
//
//        int requestId = 2;
//        Person ret = demoProxy.get(requestId);
//        Assertions.assertNull(ret);
//        for (int i = 0; i < 10; i++) {
//            if (!notify.errors.containsKey(requestId)) {
//                Thread.sleep(200);
//            } else {
//                break;
//            }
//        }
//        Assertions.assertTrue(!notify.errors.containsKey(requestId));
//        destroyService();
//    }
//
//    @Test
//    public void test_Ex_OnInvoke() throws Exception {
//        initOrResetUrl(true);
//        initOrResetExService();
//        initImplicitCallBackURL_onlyOninvoke();
//
//        int requestId = 2;
//        Person ret = demoProxy.get(requestId);
//        Assertions.assertNull(ret);
//        for (int i = 0; i < 10; i++) {
//            if (!notify.inv.contains(requestId)) {
//                Thread.sleep(200);
//            } else {
//                break;
//            }
//        }
//        Assertions.assertTrue(notify.inv.contains(requestId));
//        destroyService();
//    }
//
//    @Test
//    public void test_Ex_Onthrow() throws Exception {
//        initOrResetUrl(true);
//        initOrResetExService();
//        initImplicitCallBackURL_onlyOnthrow();
//
//        int requestId = 2;
//        Person ret = demoProxy.get(requestId);
//        Assertions.assertNull(ret);
//        for (int i = 0; i < 10; i++) {
//            if (!notify.errors.containsKey(requestId)) {
//                Thread.sleep(200);
//            } else {
//                break;
//            }
//        }
//        Assertions.assertTrue(notify.errors.containsKey(requestId));
//        Assertions.assertTrue(notify.errors.get(requestId) instanceof Throwable);
//        destroyService();
//    }
//
//    @Test
//    public void test_Sync_NoFuture() throws Exception {
//        initOrResetUrl(false);
//        initOrResetService();
//        initImplicitCallBackURL_onlyOnreturn();
//
//        int requestId = 2;
//        Person ret = demoProxy.get(requestId);
//        Assertions.assertEquals(requestId, ret.getId());
//        Future<Person> pFuture = RpcContext.getContext().getFuture();
//        Assertions.assertEquals(ret, pFuture.get());
//        destroyService();
//    }
//
//    @Test
//    public void test_Async_Future() throws Exception {
//        initOrResetUrl(true);
//        initOrResetService();
//
//        int requestId = 2;
//        Person ret = demoProxy.get(requestId);
//        Assertions.assertNull(ret);
//        Future<Person> pFuture = RpcContext.getContext().getFuture();
//        ret = pFuture.get(1000 * 1000, TimeUnit.MICROSECONDS);
//        Assertions.assertEquals(requestId, ret.getId());
//        destroyService();
//    }
//
//    @Test
//    public void test_Async_Future_Multi() throws Exception {
//        initOrResetUrl(true);
//        initOrResetService();
//
//        int requestId1 = 1;
//        Person ret = demoProxy.get(requestId1);
//        Assertions.assertNull(ret);
//        Future<Person> p1Future = RpcContext.getContext().getFuture();
//
//        int requestId2 = 1;
//        Person ret2 = demoProxy.get(requestId2);
//        Assertions.assertNull(ret2);
//        Future<Person> p2Future = RpcContext.getContext().getFuture();
//
//        ret = p1Future.get(1000 * 1000, TimeUnit.MICROSECONDS);
//        ret2 = p2Future.get(1000 * 1000, TimeUnit.MICROSECONDS);
//        Assertions.assertEquals(requestId1, ret.getId());
//        Assertions.assertEquals(requestId2, ret.getId());
//        destroyService();
//    }
//
//    @Test
//    public void test_Async_Future_Ex() throws Throwable {
//        Assertions.assertThrows(RuntimeException.class, () -> {
//            try {
//                initOrResetUrl(true);
//                initOrResetExService();
//
//                int requestId = 2;
//                Person ret = demoProxy.get(requestId);
//                Assertions.assertNull(ret);
//                Future<Person> pFuture = RpcContext.getContext().getFuture();
//                ret = pFuture.get(1000 * 1000, TimeUnit.MICROSECONDS);
//                Assertions.assertEquals(requestId, ret.getId());
//            } catch (ExecutionException e) {
//                throw e.getCause();
//            } finally {
//                destroyService();
//            }
//        });
//    }
//
//    @Test
//    public void test_Normal_Ex() throws Exception {
//        Assertions.assertThrows(RuntimeException.class, () -> {
//            initOrResetUrl(false);
//            initOrResetExService();
//
//            int requestId = 2;
//            Person ret = demoProxy.get(requestId);
//            Assertions.assertEquals(requestId, ret.getId());
//        });
//    }
//
//    interface Nofify {
//        void onreturn(Person msg, Integer id);
//
//        void onthrow(Throwable ex, Integer id);
//
//        void oninvoke(Integer id);
//    }
//
//    interface IDemoService {
//        Person get(int id);
//    }
//
//    public static class Person implements Serializable {
//        private static final long serialVersionUID = 1L;
//        private int id;
//        private String name;
//        private int age;
//
//        public Person(int id, String name, int age) {
//            this.id = id;
//            this.name = name;
//            this.age = age;
//        }
//
//        public String getName() {
//            return name;
//        }
//
//        public void setName(String name) {
//            this.name = name;
//        }
//
//        public int getAge() {
//            return age;
//        }
//
//        public void setAge(int age) {
//            this.age = age;
//        }
//
//        public int getId() {
//            return id;
//        }
//
//        public void setId(int id) {
//            this.id = id;
//        }
//
//        @Override
//        public String toString() {
//            return "Person [name=" + name + ", age=" + age + "]";
//        }
//    }
//
//    class NofifyImpl implements Nofify {
//        public List<Integer> inv = new ArrayList<Integer>();
//        public Map<Integer, Person> ret = new HashMap<Integer, Person>();
//        public Map<Integer, Throwable> errors = new HashMap<Integer, Throwable>();
//        public boolean exd = false;
//
//        public void onreturn(Person msg, Integer id) {
//            System.out.println("onNotify:" + msg);
//            ret.put(id, msg);
//        }
//
//        public void onthrow(Throwable ex, Integer id) {
//            errors.put(id, ex);
////            ex.printStackTrace();
//        }
//
//        public void oninvoke(Integer id) {
//            inv.add(id);
//        }
//    }
//
//    class NormalDemoService implements IDemoService {
//        public Person get(int id) {
//            return new Person(id, "charles", 4);
//        }
//    }
//
//    class ExceptionDemoExService implements IDemoService {
//        public Person get(int id) {
//            throw new RuntimeException("request persion id is :" + id);
//        }
//    }
//}