GenericConfig.java

package test;

import java.io.BufferedReader;
import java.io.FileReader;
import java.lang.reflect.Constructor;
import java.util.ArrayList;
import java.util.List;

public class GenericConfig implements Config {
    private String configFile;
    private List<ParallelAgent> agents = new ArrayList<>();

    public void setConfFile(String configFile) {
        this.configFile = configFile;
    }

    @Override
    public void create() {
        try (BufferedReader reader = new BufferedReader(new FileReader(configFile))) {
            List<String> lines = new ArrayList<>();
            String line;
            while ((line = reader.readLine()) != null) {
                lines.add(line.trim());
            }

            // Validate config file structure
            if (lines.size() % 3 != 0) {
                System.err.println("Invalid config file format");
                return;
            }

            // Process agents
            for (int i = 0; i < lines.size(); i += 3) {
                String className = lines.get(i);
                String[] subs = lines.get(i + 1).split(",");
                String[] pubs = lines.get(i + 2).split(",");

                // Remove empty strings from subs and pubs
                subs = subs[0].isEmpty() ? new String[0] : subs;
                pubs = pubs[0].isEmpty() ? new String[0] : pubs;

                // Load class dynamically
                Class<?> agentClass = Class.forName(className);
                Constructor<?> constructor = agentClass.getConstructor(String[].class, String[].class);
                Agent agent = (Agent) constructor.newInstance((Object) subs, (Object) pubs);

                // Wrap with ParallelAgent
                ParallelAgent parallelAgent = new ParallelAgent(agent);
                agents.add(parallelAgent);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public String getName() {
        return "Generic Config";
    }

    @Override
    public int getVersion() {
        return 1;
    }

    @Override
    public void close() {
        for (ParallelAgent agent : agents) {
            agent.close();
        }
        agents.clear();
    }
}