ra/runelite
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

xp tracker: limit lookups to most 1 per 3 seconds

Browse Source 
Drop the rest to prevent backlogging. The hiscore API throttling is
fairly strict.
This commit is contained in:
Adam
2018-12-20 14:04:15 -05:00
parent ee455e93dd
commit 1001ddf11b
2 changed files with 25 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
http-service/src/main/java/net/runelite/http/service/xp/XpTrackerController.java
View File

@@ -42,9 +42,9 @@ public class XpTrackerController
private XpTrackerService xpTrackerService; private XpTrackerService xpTrackerService;
@RequestMapping("/update") @RequestMapping("/update")
public void update(@RequestParam String username) throws ExecutionException public void update(@RequestParam String username)
{ {
xpTrackerService.update(username); xpTrackerService.tryUpdate(username);
} }
@RequestMapping("/get") @RequestMapping("/get")

23
http-service/src/main/java/net/runelite/http/service/xp/XpTrackerService.java
View File

@@ -36,6 +36,7 @@ import net.runelite.http.service.xp.beans.PlayerEntity;
import net.runelite.http.service.xp.beans.XpEntity; import net.runelite.http.service.xp.beans.XpEntity;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.sql2o.Connection; import org.sql2o.Connection;
import org.sql2o.Sql2o; import org.sql2o.Sql2o;
@@ -53,12 +54,19 @@ public class XpTrackerService
@Autowired @Autowired
private HiscoreService hiscoreService; private HiscoreService hiscoreService;
private String nextUsername;
public void update(String username) throws ExecutionException public void update(String username) throws ExecutionException
{ {
HiscoreResult hiscoreResult = hiscoreService.lookupUsername(username, HiscoreEndpoint.NORMAL); HiscoreResult hiscoreResult = hiscoreService.lookupUsername(username, HiscoreEndpoint.NORMAL);
update(username, hiscoreResult); update(username, hiscoreResult);
} }
public void tryUpdate(String username)
{
nextUsername = username;
}
public void update(String username, HiscoreResult hiscoreResult) public void update(String username, HiscoreResult hiscoreResult)
{ {
try (Connection con = sql2o.open()) try (Connection con = sql2o.open())
@@ -189,4 +197,19 @@ public class XpTrackerService
return findXpAtTime(con, username, time); return findXpAtTime(con, username, time);
} }
} }
@Scheduled(fixedDelay = 3000)
public void update() throws ExecutionException
{
String next = nextUsername;
nextUsername = null;
if (next == null)
{
return;
}
HiscoreResult hiscoreResult = hiscoreService.lookupUsername(next, HiscoreEndpoint.NORMAL);
update(next, hiscoreResult);
}
} }