Skip to content

Commit

Permalink
Converted tabs to 4 spaces.
Browse files Browse the repository at this point in the history
  • Loading branch information
@dscalzi
dscalzi committed Jun 18, 2018
1 parent 3d44686 commit 0cbd1fd
Show file tree
Hide file tree
Showing 18 changed files with 2,203 additions and 2,141 deletions.
849 changes: 428 additions & 421 deletions src/main/java/com/dscalzi/zipextractor/MainExecutor.java
View file

Large diffs are not rendered by default.

46 changes: 21 additions & 25 deletions src/main/java/com/dscalzi/zipextractor/ZipExtractor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,35 +18,31 @@
import com.dscalzi.zipextractor.providers.ZipProvider;
import com.dscalzi.zipextractor.util.ZServicer;

public class ZipExtractor extends JavaPlugin{

@SuppressWarnings("unused")
private Metrics metrics;
private static final TypeProvider[] PROVIDERS = {
new ZipProvider(),
new RarProvider(),
new JarProvider(),
new PackProvider(),
new XZProvider()
};

public class ZipExtractor extends JavaPlugin {

@SuppressWarnings("unused")
private Metrics metrics;
private static final TypeProvider[] PROVIDERS = { new ZipProvider(), new RarProvider(), new JarProvider(),
new PackProvider(), new XZProvider() };

@Override
public void onEnable(){
ConfigManager.initialize(this);
MessageManager.initialize(this);
ZServicer.initalize(ConfigManager.getInstance().getMaxQueueSize(), ConfigManager.getInstance().getMaxPoolSize());
this.getCommand("zipextractor").setExecutor(new MainExecutor(this));
metrics = new Metrics(this);
public void onEnable() {
ConfigManager.initialize(this);
MessageManager.initialize(this);
ZServicer.initalize(ConfigManager.getInstance().getMaxQueueSize(),
ConfigManager.getInstance().getMaxPoolSize());
this.getCommand("zipextractor").setExecutor(new MainExecutor(this));
metrics = new Metrics(this);
}

@Override
public void onDisable(){
boolean wait = ConfigManager.getInstance().waitForTasksOnShutdown();
ZServicer.getInstance().terminate(!wait, wait);
public void onDisable() {
boolean wait = ConfigManager.getInstance().waitForTasksOnShutdown();
ZServicer.getInstance().terminate(!wait, wait);
}

public static TypeProvider[] getProviders() {
return PROVIDERS;
return PROVIDERS;
}

}
321 changes: 162 additions & 159 deletions src/main/java/com/dscalzi/zipextractor/managers/ConfigManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,163 +21,166 @@

public class ConfigManager {

private static boolean initialized;
private static ConfigManager instance;

//TODO Will be implemented in a later version
private final double configVersion = 1.9;
private ZipExtractor plugin;
private FileConfiguration config;

private ConfigManager(ZipExtractor plugin){
this.plugin = plugin;
loadConfig();
}

public void loadConfig(){
verifyFile();
this.plugin.reloadConfig();
this.config = this.plugin.getConfig();
}

public void verifyFile(){
File file = new File(this.plugin.getDataFolder(), "config.yml");
if (!file.exists()){
this.plugin.saveDefaultConfig();
}
}

public static void initialize(ZipExtractor plugin){
if(!initialized){
instance = new ConfigManager(plugin);
initialized = true;
}
}

public static boolean reload(){
if(!initialized) return false;
try{
getInstance().loadConfig();
return true;
} catch(Exception e){
e.printStackTrace();
return false;
}
}

public static ConfigManager getInstance(){
return ConfigManager.instance;
}

/* Configuration Accessors */

public String getSourceRaw() {
return this.config.getString("file_settings.source_directory", null);
}

public String getDestRaw() {
return this.config.getString("file_settings.destination_directory", null);
}

private Optional<File> runValidations(String abstractPath){
abstractPath = PathUtils.formatPath(abstractPath, false);
File f = new File(abstractPath);

return PathUtils.validateFilePath(f) ? Optional.of(f) : Optional.empty();
}

public Optional<File> getSourceFile(){
return runValidations(getSourceRaw());
}

public Optional<File> getDestFile(){
return runValidations(getDestRaw());
}


public boolean setSourcePath(String path){
boolean ret = this.updateValue("file_settings.source_directory", path);
this.plugin.saveDefaultConfig();
return ret;
}

public boolean setDestPath(String path){
boolean ret = this.updateValue("file_settings.destination_directory", path);
this.plugin.saveDefaultConfig();
return ret;
}

public boolean getLoggingProperty(){
return this.config.getBoolean("general_settings.log_files", false);
}

public boolean warnOnConflitcts() {
return this.config.getBoolean("general_settings.warn_on_conflicts", true);
}

public boolean waitForTasksOnShutdown(){
return this.config.getBoolean("general_settings.wait_on_shutdown", true);
}

public int getMaxQueueSize(){
int limit = this.config.getInt("general_settings.max_queue_size", 3);
return limit > 0 ? limit : Integer.MAX_VALUE;
}

public int getMaxPoolSize(){
int limit = this.config.getInt("general_settings.maximum_thread_pool", 1);
if(limit < 1) limit = 1;
return limit > 0 ? limit : 1;
}

public double getVersion(){
return this.configVersion;
}

public boolean updateValue(String path, String value) {
try {
BufferedReader file = new BufferedReader(new FileReader(this.plugin.getDataFolder() + File.separator + "config.yml"));
String line;
String input = "";

List<String> paths = new ArrayList<String>(Arrays.asList(path.split("\\.")));

while ((line = file.readLine()) != null) {
String lline = line.toLowerCase();
if(paths.size() > 0){
if(lline.contains(paths.get(0).toLowerCase())){
paths.remove(0);
if(paths.size() == 0){
int firstIndex = line.indexOf("\"");
int lastIndex = line.lastIndexOf("\"");
if(firstIndex == -1){
line = line.replaceAll(" +$", "");
line += " \"";
firstIndex = line.indexOf("\"");
}
if(lastIndex == -1){
line += "\"";
lastIndex = line.lastIndexOf("\"");
}
line = line.substring(0, firstIndex+1) + value + line.substring(lastIndex);
}
}
}
input += line + '\n';
}


file.close();

if(paths.size() > 0) return false;

FileOutputStream fileOut = new FileOutputStream(this.plugin.getDataFolder() + File.separator + "config.yml");
fileOut.write(input.getBytes());
fileOut.close();
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
private static boolean initialized;
private static ConfigManager instance;

// TODO Will be implemented in a later version
private final double configVersion = 1.9;
private ZipExtractor plugin;
private FileConfiguration config;

private ConfigManager(ZipExtractor plugin) {
this.plugin = plugin;
loadConfig();
}

public void loadConfig() {
verifyFile();
this.plugin.reloadConfig();
this.config = this.plugin.getConfig();
}

public void verifyFile() {
File file = new File(this.plugin.getDataFolder(), "config.yml");
if (!file.exists()) {
this.plugin.saveDefaultConfig();
}
}

public static void initialize(ZipExtractor plugin) {
if (!initialized) {
instance = new ConfigManager(plugin);
initialized = true;
}
}

public static boolean reload() {
if (!initialized)
return false;
try {
getInstance().loadConfig();
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}

public static ConfigManager getInstance() {
return ConfigManager.instance;
}

/* Configuration Accessors */

public String getSourceRaw() {
return this.config.getString("file_settings.source_directory", null);
}

public String getDestRaw() {
return this.config.getString("file_settings.destination_directory", null);
}

private Optional<File> runValidations(String abstractPath) {
abstractPath = PathUtils.formatPath(abstractPath, false);
File f = new File(abstractPath);

return PathUtils.validateFilePath(f) ? Optional.of(f) : Optional.empty();
}

public Optional<File> getSourceFile() {
return runValidations(getSourceRaw());
}

public Optional<File> getDestFile() {
return runValidations(getDestRaw());
}

public boolean setSourcePath(String path) {
boolean ret = this.updateValue("file_settings.source_directory", path);
this.plugin.saveDefaultConfig();
return ret;
}

public boolean setDestPath(String path) {
boolean ret = this.updateValue("file_settings.destination_directory", path);
this.plugin.saveDefaultConfig();
return ret;
}

public boolean getLoggingProperty() {
return this.config.getBoolean("general_settings.log_files", false);
}

public boolean warnOnConflitcts() {
return this.config.getBoolean("general_settings.warn_on_conflicts", true);
}

public boolean waitForTasksOnShutdown() {
return this.config.getBoolean("general_settings.wait_on_shutdown", true);
}

public int getMaxQueueSize() {
int limit = this.config.getInt("general_settings.max_queue_size", 3);
return limit > 0 ? limit : Integer.MAX_VALUE;
}

public int getMaxPoolSize() {
int limit = this.config.getInt("general_settings.maximum_thread_pool", 1);
if (limit < 1)
limit = 1;
return limit > 0 ? limit : 1;
}

public double getVersion() {
return this.configVersion;
}

public boolean updateValue(String path, String value) {
try {
BufferedReader file = new BufferedReader(
new FileReader(this.plugin.getDataFolder() + File.separator + "config.yml"));
String line;
String input = "";

List<String> paths = new ArrayList<String>(Arrays.asList(path.split("\\.")));

while ((line = file.readLine()) != null) {
String lline = line.toLowerCase();
if (paths.size() > 0) {
if (lline.contains(paths.get(0).toLowerCase())) {
paths.remove(0);
if (paths.size() == 0) {
int firstIndex = line.indexOf("\"");
int lastIndex = line.lastIndexOf("\"");
if (firstIndex == -1) {
line = line.replaceAll(" +$", "");
line += " \"";
firstIndex = line.indexOf("\"");
}
if (lastIndex == -1) {
line += "\"";
lastIndex = line.lastIndexOf("\"");
}
line = line.substring(0, firstIndex + 1) + value + line.substring(lastIndex);
}
}
}
input += line + '\n';
}

file.close();

if (paths.size() > 0)
return false;

FileOutputStream fileOut = new FileOutputStream(
this.plugin.getDataFolder() + File.separator + "config.yml");
fileOut.write(input.getBytes());
fileOut.close();
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
}
Loading

0 comments on commit 0cbd1fd

Please sign in to comment.