/* ConvertService 接口增加 close方法 */
package org.dbsyncer.common.spi;

public interface ConvertService {
    void convert(ConvertContext var1);

    default void postProcessAfter(ConvertContext context) {
    }

    default String getVersion() {
        return "1.0.0";
    }

    default String getName() {
        return this.getClass().getSimpleName();
    }

    default void close() {
    }
}

    /**
     * SPI, 扫描jar扩展接口实现，注册为本地服务
     *
     * @param jar
     */
    private void loadPlugin(File jar) {
        try {
            String fileName = jar.getName();
            URL url = jar.toURI().toURL();
            URLClassLoader loader = new URLClassLoader(new URL[] {url}, Thread.currentThread().getContextClassLoader());
            ServiceLoader<ConvertService> services = ServiceLoader.load(ConvertService.class, loader);
            for (ConvertService s : services) {
                String className = s.getClass().getName();
                /*增加一个销毁注销接口*/
                if (service.containsKey(className)) {
                    try {
                        ConvertService convertService = service.get(className);
                        convertService.close();
                    } catch (Exception e) {
                        logger.error(e.getMessage(),e);
                    }
                }
                service.put(className, s);
                plugins.add(new Plugin(s.getName(), className, s.getVersion(), fileName));
                logger.info("{}, {}_{} {}", fileName, s.getName(), s.getVersion(), className);
            }
        } catch (MalformedURLException e) {
            logger.error(e.getMessage());
        }

    }