Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1a52c650c5 | |||
| 098f6876ed |
@@ -6,14 +6,13 @@ import java.io.FileOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.ObjectInputStream;
|
||||
import java.io.ObjectOutputStream;
|
||||
import java.util.SortedMap;
|
||||
import java.util.TreeMap;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
|
||||
import downloader.helper.ArchiveHelper;
|
||||
import downloader.helper.SlugHelper;
|
||||
|
||||
public class CurseUpdateManager {
|
||||
private SortedMap<Integer, String> installedMods;
|
||||
private ConcurrentHashMap<Integer, String> installedMods;
|
||||
|
||||
public CurseUpdateManager()
|
||||
{
|
||||
@@ -27,13 +26,13 @@ public class CurseUpdateManager {
|
||||
{
|
||||
try {
|
||||
ObjectInputStream ois = new ObjectInputStream(new FileInputStream(modsMapFile));
|
||||
installedMods = (SortedMap<Integer, String>) ois.readObject();
|
||||
installedMods = (ConcurrentHashMap<Integer, String>) ois.readObject();
|
||||
ois.close();
|
||||
} catch (Exception e) {
|
||||
modsMapFile.delete();
|
||||
}
|
||||
if(installedMods == null)installedMods = new TreeMap<>();
|
||||
}
|
||||
if(installedMods == null)installedMods = new ConcurrentHashMap<>();
|
||||
this.updateFile();
|
||||
}
|
||||
|
||||
@@ -61,7 +60,7 @@ public class CurseUpdateManager {
|
||||
|
||||
if (alredyInstalledMods.exists()) {
|
||||
//we only check if the jar file still works
|
||||
if(ArchiveHelper.checkJarIntegrity(alredyInstalledMods)) {
|
||||
if(!ArchiveHelper.checkJarIntegrity(alredyInstalledMods)) {
|
||||
alredyInstalledMods.delete();
|
||||
installedMods.remove(modid);
|
||||
updateFile();
|
||||
@@ -110,18 +109,17 @@ public class CurseUpdateManager {
|
||||
* @param fileName
|
||||
* @param modID
|
||||
*/
|
||||
public void addModsToTheList(String fileName,int modID)
|
||||
public synchronized void addModsToTheList(String fileName,int modID)
|
||||
{
|
||||
installedMods.put(modID, fileName);
|
||||
updateFile();
|
||||
}
|
||||
|
||||
public boolean isModIdKnown(int modId)
|
||||
public synchronized boolean isModIdKnown(int modId)
|
||||
{
|
||||
return installedMods.get(modId) != null;
|
||||
}
|
||||
|
||||
private void updateFile()
|
||||
public synchronized void updateFile()
|
||||
{
|
||||
File modsMap = new File("mods/modsMap.sav");
|
||||
try {
|
||||
|
||||
@@ -4,7 +4,9 @@ import java.io.BufferedReader;
|
||||
import java.io.File;
|
||||
import java.io.FileNotFoundException;
|
||||
import java.io.FileReader;
|
||||
import java.io.FileWriter;
|
||||
import java.io.IOException;
|
||||
import java.io.PrintWriter;
|
||||
import java.net.MalformedURLException;
|
||||
|
||||
import downloader.helper.ArchiveHelper;
|
||||
@@ -29,11 +31,22 @@ public class DatabaseVersionManager {
|
||||
if( version == null || !latestVersion.equals(version) ) {
|
||||
Log.i(ME, "new dbVersion avaliable downloading...");
|
||||
downloadDatabase(latestVersion);
|
||||
saveDbVersion(latestVersion);
|
||||
} else {
|
||||
Log.i(ME, "update to Date");
|
||||
}
|
||||
}
|
||||
|
||||
private void saveDbVersion(String latestVersion) {
|
||||
File versionFile = new File("dbVersion");
|
||||
PrintWriter out;
|
||||
try {
|
||||
out = new PrintWriter(new FileWriter(versionFile));
|
||||
out.println(latestVersion);
|
||||
out.close();
|
||||
} catch (IOException e) {}
|
||||
}
|
||||
|
||||
private void downloadDatabase(String dbVersion) {
|
||||
Log.i(ME, "fetching=" + "http://files.mcdex.net/data/mcdex-v5-" + dbVersion + ".dat.bz2");
|
||||
File archive;
|
||||
@@ -81,8 +94,7 @@ public class DatabaseVersionManager {
|
||||
versionFile.delete();
|
||||
return null;
|
||||
}
|
||||
} else {
|
||||
}
|
||||
throw new FileNotFoundException();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
package downloader;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
|
||||
import downloader.helper.ArchiveHelper;
|
||||
import downloader.helper.SlugHelper;
|
||||
@@ -13,12 +14,7 @@ public class DirectUpdateManager {
|
||||
* @return upToDate
|
||||
*/
|
||||
public boolean checkAndDelete(String filename, String slug) {
|
||||
File mod = new File("mods/"+filename);
|
||||
|
||||
if (!mod.isFile()) {
|
||||
mod.delete();
|
||||
return false;
|
||||
}
|
||||
File mod = new File("mods/"+filename.toLowerCase());
|
||||
|
||||
if (!mod.exists()) {
|
||||
SlugHelper.deleteBySlug(slug);
|
||||
|
||||
@@ -4,7 +4,7 @@ public class Log {
|
||||
private Log() {}
|
||||
|
||||
public static void e(String who, String msg) {
|
||||
System.err.println(String.valueOf(who) + " : " + msg);
|
||||
System.out.println(String.valueOf(who) + " : " + msg);
|
||||
}
|
||||
|
||||
public static void i(String who, String msg) {
|
||||
|
||||
@@ -51,12 +51,19 @@ public class ModUpdater {
|
||||
}
|
||||
}
|
||||
in.close();
|
||||
Log.i(ME, "finished");
|
||||
|
||||
} catch( IOException e ) {
|
||||
e.printStackTrace();
|
||||
System.exit(1);
|
||||
}
|
||||
|
||||
//on attend la fin des threads
|
||||
while( !threads.isEmpty() ) {
|
||||
try {
|
||||
Thread.sleep(10);
|
||||
} catch (InterruptedException e) {}
|
||||
}
|
||||
Log.i(ME, "finished");
|
||||
curseUpdateManager.updateFile();
|
||||
}
|
||||
|
||||
public static boolean isAComment(String line)
|
||||
@@ -111,15 +118,16 @@ final class UpdaterThread extends Thread {
|
||||
//le slug est une nom de mods qui se trouve dans le nom du fichier
|
||||
String slug = extractSlugFromLink(line);
|
||||
//on check si le mods est pas déja installé et si il est a jours
|
||||
Log.e("who",slug);
|
||||
boolean upToDate = directUpdateManager.checkAndDelete(filename, slug);
|
||||
if(!upToDate)
|
||||
{
|
||||
Log.i("main","downloading "+ filename);
|
||||
Log.i(ME,"downloading "+ filename);
|
||||
try {
|
||||
HttpHelper.readFileFromUrlToFolder(url,"mods",filename);
|
||||
Log.i("main","done");
|
||||
Log.i(ME,"done");
|
||||
} catch (MalformedURLException e) {
|
||||
Log.e("ModUpdater", "could not update mod, error while downloading");
|
||||
Log.e(ME, "could not update mod, error while downloading");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -143,6 +151,9 @@ final class UpdaterThread extends Thread {
|
||||
else {
|
||||
Log.i("DB", "NEW MOD DETECTED " + modID);
|
||||
upToDate = this.curseUpdateManager.checkAndDelete(new File("mods/" + HttpHelper.getFileNameFromURL(downloadUrl)), pj.getSlug());
|
||||
if(upToDate) {
|
||||
this.curseUpdateManager.addModsToTheList("mods/" + HttpHelper.getFileNameFromURL(downloadUrl), modID);
|
||||
}
|
||||
}
|
||||
|
||||
if (!upToDate) {
|
||||
|
||||
@@ -90,13 +90,11 @@ public class HttpHelper {
|
||||
}
|
||||
|
||||
File downloadingFile = destination;
|
||||
System.out.println(downloadingFile.getAbsolutePath());
|
||||
|
||||
if (downloadingFile.exists()) {
|
||||
return downloadingFile;
|
||||
} else {
|
||||
try {
|
||||
System.out.println(downloadingFile);
|
||||
downloadingFile.createNewFile();
|
||||
} catch (IOException e) {
|
||||
Log.e("HTTPHelper","permission error could not write file");
|
||||
|
||||
Reference in New Issue
Block a user