2 Commits

Author SHA1 Message Date
marc barbier 1a52c650c5 debug 2021-07-08 22:42:14 +02:00
marc barbier 098f6876ed fix all copetition error 2021-07-08 22:13:16 +02:00
6 changed files with 43 additions and 28 deletions
@@ -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);
+1 -1
View File
@@ -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");