Skip to content

Added the hangar switcher #68

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
dm94 wants to merge 1 commit into
base: master
Choose a base branch
from
Draft

Added the hangar switcher #68

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
214 changes: 214 additions & 0 deletions shared/src/main/java/eu/darkbot/shared/modules/HangarSwitcher.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,214 @@
package eu.darkbot.shared.modules;

import com.github.manolo8.darkbot.Main;
import com.github.manolo8.darkbot.backpage.HangarManager;
import com.github.manolo8.darkbot.backpage.hangar.Hangar;

import eu.darkbot.api.PluginAPI;
import eu.darkbot.api.game.other.Gui;
import eu.darkbot.api.managers.BackpageAPI;
import eu.darkbot.api.managers.BotAPI;
import eu.darkbot.api.managers.GameScreenAPI;
import eu.darkbot.api.managers.HeroAPI;
import eu.darkbot.api.utils.Inject;

public class HangarSwitcher extends TemporalModule {
protected final PluginAPI api;
protected final HeroAPI heroapi;
protected final BackpageAPI backpageAPI;

protected final Gui lostConnectionGUI;
protected final Gui logout;

private Integer activeHangar = null;
private Integer hangarToChage = null;
private final Main main;
private final HangarManager hangarManager;
private State currentStatus;

private long waitinUntil = 0;
private int hangarTry = 0;
private boolean hangarChanged = false;
private int checkCount = 0;

private enum State {
WAIT("Waiting"),
SWITCHING_HANGAR("Changing the hangar"),
HANGAR_CHANGED("Hangar changed"),
DISCONNECTING("Disconnecting"),
RELOAD_GAME("Reloading the game"),
LOADING_HANGARS("Waiting - Loading hangars"),
WAITING_HANGARS("Waiting - For change hangars"),
SID_KO("Error - SID KO - Reconnecting the game"),
NO_HANGAR_ERROR("Error - Hangars not configured");

private final String message;

State(String message) {
this.message = message;
}
}

public HangarSwitcher(Main m, PluginAPI api, Integer hangar) {
this(m, api, api.requireAPI(BotAPI.class), hangar);
}

@Inject
public HangarSwitcher(Main m, PluginAPI api, BotAPI bot, Integer hangar) {
super(bot);
this.main = m;
this.hangarManager = main.backpage.hangarManager;

this.api = api;
this.heroapi = api.getAPI(HeroAPI.class);
this.backpageAPI = api.getAPI(BackpageAPI.class);
this.hangarToChage = hangar;
this.checkCount = 0;

GameScreenAPI gameScreenAPI = api.getAPI(GameScreenAPI.class);
this.lostConnectionGUI = gameScreenAPI.getGui("lost_connection");
this.logout = gameScreenAPI.getGui("logout");

this.currentStatus = State.WAIT;
}

@Override
public String getStatus() {
return "Hangar Switcher | " + currentStatus.message + waitingTime() + " | Attempts: " + hangarTry;
}

@Override
public String getStoppedStatus() {
return this.getStatus();
}

@Override
public void goBack() {
bot.setRunning(true);
bot.handleRefresh();
super.goBack();
}

@Override
public void onTickStopped() {
this.onTickModule();
}

@Override
public void onTickModule() {
try {
if (hangarToChage == null) {
this.currentStatus = State.NO_HANGAR_ERROR;
goBack();
}
if (waitinUntil > System.currentTimeMillis()) {
return;
}
if (activeHangar == null) {
updateHangarActive();
} else if (!activeHangar.equals(hangarToChage)) {
if (!heroapi.isMoving()) {
if (isDisconnect()) {
if (!this.backpageAPI.isInstanceValid() || !this.backpageAPI.getSidStatus().contains("OK")) {
this.currentStatus = State.SID_KO;
waitinUntil = System.currentTimeMillis() + 60000;
} else {
if (hangarChanged) {
waitinUntil = System.currentTimeMillis() + 10000;
activeHangar = null;
checkCount++;
if (checkCount > 6) {
hangarChanged = false;
}
} else if (hangarTry >= 3) {
this.currentStatus = State.RELOAD_GAME;
goBack();
} else {
this.currentStatus = State.SWITCHING_HANGAR;
if (changeHangar(hangarToChage)) {
hangarChanged = true;
this.currentStatus = State.HANGAR_CHANGED;
waitinUntil = System.currentTimeMillis() + 10000;
} else if (hangarTry < 4) {
hangarTry++;
waitinUntil = System.currentTimeMillis() + 20000;
}
this.activeHangar = null;
}
}
} else if (!heroapi.isAttacking() && !SharedFunctions.hasAttacker(heroapi, main)) {
disconnect();
} else {
goBack();
}
} else {
goBack();
}
} else {
goBack();
}
} catch (Exception e) {
e.printStackTrace();
}
}

private String waitingTime() {
if (waitinUntil > System.currentTimeMillis()) {
return " | Waiting " + (System.currentTimeMillis() - waitinUntil);
}
return "";
}

private boolean isDisconnect() {
return lostConnectionGUI != null && lostConnectionGUI.isVisible();
}

private void disconnect() {
this.currentStatus = State.DISCONNECTING;
bot.setRunning(false);
if (heroapi.getMap() != null && heroapi.getMap().getId() > 0
&& !logout.isVisible() && !heroapi.isMoving()) {
logout.setVisible(true);
}
}

private void updateHangarActive() {
this.currentStatus = State.LOADING_HANGARS;
try {
hangarManager.updateHangarList();
activeHangar = hangarManager.getHangarList().getData().getRet().getHangars().stream()
.filter(Hangar::isActive)
.map(Hangar::getHangarId)
.findFirst()
.orElse(null);
} catch (Exception ignored) {
activeHangar = null;
}
}

private boolean changeHangar(Integer hangarId) {
String token = "";
try {
token = main.backpage
.getReloadToken(backpageAPI.getConnection("indexInternal.es?action=internalDock").getInputStream());
} catch (Exception e) {
e.printStackTrace();
}

if (token == null || token.isEmpty()) {
this.currentStatus = State.SID_KO;
return false;
}

String url = "indexInternal.es?action=internalDock&subAction=changeHangar&hangarId=" + hangarId
+ "&reloadToken=" + token;
try {
backpageAPI.getConnection(url, 2000).getResponseCode();
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}

}