Skip to content

Commit

Permalink
Large refactor, remove last of the Bukkit dependencies
Browse files Browse the repository at this point in the history
  • Loading branch information
@zford
zford committed Apr 17, 2013
1 parent 5979ea3 commit 51d8dba
Show file tree
Hide file tree
Showing 39 changed files with 1,310 additions and 677 deletions.
256 changes: 221 additions & 35 deletions src/main/java/me/zford/jobs/Jobs.java
View file
Expand Up @@ -24,96 +24,124 @@
import java.util.WeakHashMap;
import java.util.logging.Logger;

import me.zford.jobs.bukkit.JobsPlugin;
import me.zford.jobs.config.ConfigManager;
import me.zford.jobs.container.ActionInfo;
import me.zford.jobs.container.Job;
import me.zford.jobs.container.JobProgression;
import me.zford.jobs.container.JobsPlayer;
import me.zford.jobs.dao.JobsDAO;
import me.zford.jobs.economy.BufferedEconomy;
import me.zford.jobs.economy.Economy;
import me.zford.jobs.i18n.Language;
import me.zford.jobs.tasks.BufferedPaymentThread;
import me.zford.jobs.tasks.DatabaseSaveThread;
import me.zford.jobs.util.JobsClassLoader;

public class Jobs {
private Logger pLogger;
private Logger sLogger;
private File dataFolder;
private JobsClassLoader classLoader = new JobsClassLoader(this);
private JobsDAO dao = null;
private List<Job> jobs = null;
private Job noneJob = null;
private WeakHashMap<Job, Integer> usedSlots = new WeakHashMap<Job, Integer>();
private static Jobs instance = new Jobs();
private static PlayerManager pManager = new PlayerManager();

public Jobs(JobsPlugin plugin) {
this.pLogger = plugin.getLogger();
this.sLogger = plugin.getServer().getLogger();
this.dataFolder = plugin.getDataFolder();
private static Logger pLogger;
private static File dataFolder;
private static JobsClassLoader classLoader = new JobsClassLoader(instance);
private static JobsDAO dao = null;
private static List<Job> jobs = null;
private static Job noneJob = null;
private static WeakHashMap<Job, Integer> usedSlots = new WeakHashMap<Job, Integer>();
private static Server server;
private static TaskScheduler scheduler;
private static BufferedEconomy economy;
private static PermissionHandler permissionHandler;

private static BufferedPaymentThread paymentThread = null;
private static DatabaseSaveThread saveTask = null;

private Jobs() {}

/**
* Returns player manager
* @return the player manager
*/
public static PlayerManager getPlayerManager() {
return pManager;
}

/**
* Sets the plugin logger
*/
public static void setPluginLogger(Logger logger) {
pLogger = logger;
}

/**
* Retrieves the plugin logger
* @return the plugin logger
*/
public Logger getPluginLogger() {
public static Logger getPluginLogger() {
return pLogger;
}

/**
* Retrieves the server logger
* @return the server logger
* Sets the data folder
* @param dir - the data folder
*/
public Logger getServerLogger() {
return sLogger;
public static void setDataFolder(File dir) {
dataFolder = dir;
}

/**
* Retrieves the data folder
* @return data folder
*/
public File getDataFolder() {
public static File getDataFolder() {
return dataFolder;
}

/**
* Sets the Data Access Object
* @param dao - the DAO
*/
public void setDAO(JobsDAO dao) {
this.dao = dao;
public static void setDAO(JobsDAO value) {
dao = value;
}

/**
* Get the Data Access Object
* @return the DAO
*/
public JobsDAO getJobsDAO() {
public static JobsDAO getJobsDAO() {
return dao;
}

/**
* Sets the list of jobs
* @param jobs - list of jobs
*/
public void setJobs(List<Job> jobs) {
this.jobs = jobs;
public static void setJobs(List<Job> list) {
jobs = list;
}

/**
* Retrieves the list of active jobs
* @return list of jobs
*/
public List<Job> getJobs() {
public static List<Job> getJobs() {
return Collections.unmodifiableList(jobs);
}

/**
* Sets the none job
* @param noneJob - the none job
*/
public void setNoneJob(Job noneJob) {
this.noneJob = noneJob;
public static void setNoneJob(Job job) {
noneJob = job;
}

/**
* Retrieves the "none" job
* @return the none job
*/
public Job getNoneJob() {
public static Job getNoneJob() {
return noneJob;
}

Expand All @@ -122,21 +150,75 @@ public Job getNoneJob() {
* @param jobName - the ame of the job given
* @return the job that matches the name
*/
public Job getJob(String jobName) {
public static Job getJob(String jobName) {
for (Job job : jobs) {
if (job.getName().equalsIgnoreCase(jobName))
return job;
}
return null;
}

/**
* Executes startup
*/
public static void startup() {
reload();

// add all online players
for (Player online: getServer().getOnlinePlayers()){
Jobs.getPlayerManager().playerJoin(online.getName());
}
}

/**
* Reloads all data
*/
public void reload() {
public static void reload() {
ConfigManager.getJobsConfiguration().reload();
Language.reload(ConfigManager.getJobsConfiguration().getLocale());
ConfigManager.getJobConfig().reload();
usedSlots.clear();
for (Job job: jobs) {
usedSlots.put(job, dao.getSlotsTaken(job));
usedSlots.put(job, getJobsDAO().getSlotsTaken(job));
}
pManager.reload();
permissionHandler.registerPermissions();

if (paymentThread != null) {
paymentThread.shutdown();
paymentThread = null;
}

if (saveTask != null) {
saveTask.shutdown();
saveTask = null;
}

// set the system to auto save
if (ConfigManager.getJobsConfiguration().getSavePeriod() > 0) {
saveTask = new DatabaseSaveThread(ConfigManager.getJobsConfiguration().getSavePeriod());
saveTask.start();
}

// schedule payouts to buffered payments
paymentThread = new BufferedPaymentThread(ConfigManager.getJobsConfiguration().getEconomyBatchDelay());
paymentThread.start();
}

/**
* Executes clean shutdown
*/
public static void shutdown() {
if (saveTask != null)
saveTask.shutdown();

if (paymentThread != null)
paymentThread.shutdown();

pManager.saveAll();

if (dao != null) {
dao.closeConnections();
}
}

Expand All @@ -145,30 +227,134 @@ public void reload() {
* @param job - the job
* @return the number of slots
*/
public int getUsedSlots(Job job){
public static int getUsedSlots(Job job){
return usedSlots.get(job);
}

/**
* Function to increase the number of used slots for a job
* @param job - the job someone is taking
*/
public void takeSlot(Job job) {
public static void takeSlot(Job job) {
usedSlots.put(job, usedSlots.get(job)+1);
}

/**
* Function to decrease the number of used slots for a job
* @param job - the job someone is leaving
*/
public void leaveSlot(Job job) {
public static void leaveSlot(Job job) {
usedSlots.put(job, usedSlots.get(job)-1);
}

/**
* Returns the jobs classloader
* @return the classloader
*/
public JobsClassLoader getJobsClassloader() {
public static JobsClassLoader getJobsClassloader() {
return classLoader;
}

/**
* Sets the server
* @param s - the server
*/
public static void setServer(Server s) {
server = s;
}

/**
* Gets the server
* @return server
*/
public static Server getServer() {
return server;
}

/**
* Sets the task scheduler
* @param s - task scheduler
*/
public static void setScheduler(TaskScheduler s) {
scheduler = s;
}

/**
* Gets the task scheduler
* @return task scheduler
*/
public static TaskScheduler getScheduler() {
return scheduler;
}

/**
* Sets the permission handler
* @param h - the permission handler
*/
public static void setPermissionHandler(PermissionHandler h) {
permissionHandler = h;
}

/**
* Gets the permission handler
* @return the permission handler
*/
public static PermissionHandler getPermissionHandler() {
return permissionHandler;
}

/**
* Sets the economy handler
* @param eco - the economy handler
*/
public static void setEconomy(Economy eco) {
economy = new BufferedEconomy(eco);
}

/**
* Gets the economy handler
* @return the economy handler
*/
public static BufferedEconomy getEconomy() {
return economy;
}

/**
* Performed an action
*
* Give correct experience and income
* @param jPlayer - the player
* @param action - the action
* @param multiplier - the payment/xp multiplier
*/
public static void action(JobsPlayer jPlayer, ActionInfo info, double multiplier) {
List<JobProgression> progression = jPlayer.getJobProgression();
int numjobs = progression.size();
// no job
if (numjobs == 0) {
Job jobNone = Jobs.getNoneJob();
if (jobNone != null) {
Double income = jobNone.getIncome(info, 1, numjobs);
if (income != null)
Jobs.getEconomy().pay(jPlayer, income*multiplier);
}
} else {
for (JobProgression prog : progression) {
int level = prog.getLevel();
Double income = prog.getJob().getIncome(info, level, numjobs);
if (income != null) {
Double exp = prog.getJob().getExperience(info, level, numjobs);
if (ConfigManager.getJobsConfiguration().addXpPlayer()) {
Player player = getServer().getPlayer(jPlayer.getName());
if (player != null)
player.giveExp(exp.intValue());
}
// give income
Jobs.getEconomy().pay(jPlayer, income*multiplier);
if (prog.addExperience(exp*multiplier))
Jobs.getPlayerManager().performLevelUp(jPlayer, prog.getJob());
}
}
}
}
}

0 comments on commit 51d8dba

Please sign in to comment.