JamesQ/MatchmakingBackend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added RID Timer & Deletion, these are for future use as redundancy for clear delete issues.

Browse Source 
These may end up not being used but they're here so yippe, also starting work on account deletion after this commit.
This commit is contained in:
James Quinley 2022-02-11 15:41:30 -08:00
parent c685c6c476
commit cf1e88b37f
2 changed files with 30 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/com/jamesquinley/DelegationServices/delegationServices.java
View File

@ -126,7 +126,7 @@ public class delegationServices {
} else {
System.out.println("Sync Failure");
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("rid",(int) Lrequest.get("rid"));
searchQuery.append("rid", Lrequest.get("rid"));
BasicDBObject updateQuery = new BasicDBObject();
BasicDBObject updateQuery1 = new BasicDBObject();
@ -173,7 +173,6 @@ public class delegationServices {
}
//sync read request
//TODO This has issues, and won't get past line 171. Working on a fix for that.
if (requesttype == 1) {
delegationTimer.DeleteTargetRequest(ClientID);
System.out.println("Sync Request (Write)");
@ -436,6 +435,9 @@ public class delegationServices {
updateQuery4.append("$set",
new BasicDBObject().append("User", UserName));
updateQuery5.append("$set",
new BasicDBObject().append("Password", Password));
updateQuery7.append("$set",
new BasicDBObject().append("Email", Email));
@ -626,11 +628,19 @@ public class delegationServices {
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("clientid",CID);
dCollection.deleteMany(searchQuery);
System.out.println("Flushed a targeted request from the server");
System.out.println("Flushed a targeted request (CID) from the server");
}
public static void delegate ()
public static void TargetDeleteRID (int CID) {
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.append("rid",CID);
dCollection.deleteMany(searchQuery);
System.out.println("Flushed a targeted request (RID) from the server");
} public static void delegate ()
{
userAuthetication();
}

17
src/main/java/com/jamesquinley/DelegationServices/delegationTimer.java
View File

@ -39,4 +39,19 @@ public class delegationTimer {
};
scheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
}
}
public static void DeleteTargetRequestRID (int RID)
{
final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
final Runnable runnable = new Runnable() {
int countdownStarter = 9;
public void run() {
countdownStarter--;
if (countdownStarter <= 0) {
countdownStarter = 9;
delegationServices.TargetDeleteRID(RID);
scheduler.shutdown();
}
}
};
scheduler.scheduleAtFixedRate(runnable, 0, 1, TimeUnit.SECONDS);
}}