yawaflua/Informatis
1
0
Fork 0
mirror of https://github.com/yawaflua/Informatis.git synced 2026-02-04 10:24:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

search fragment completely done

Browse Source
This commit is contained in:
Sharlotte
2022-09-19 09:12:33 +09:00
parent f6551ed7ca
commit 2838a80196
1 changed files with 47 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

98
src/informatis/ui/fragments/ServerSearchFragment.java
View File

@@ -2,12 +2,8 @@ package informatis.ui.fragments;
import arc.Core; import arc.Core;
import arc.Events; import arc.Events;
import arc.func.Cons; import arc.scene.Element;
import arc.func.Prov; import arc.scene.ui.*;
import arc.scene.actions.DelayAction;
import arc.scene.actions.RepeatAction;
import arc.scene.ui.Label;
import arc.scene.ui.TextButton;
import arc.scene.ui.layout.Table; import arc.scene.ui.layout.Table;
import arc.struct.*; import arc.struct.*;
import arc.util.*; import arc.util.*;
@@ -25,17 +21,17 @@ import static mindustry.Vars.*;
public class ServerSearchFragment extends Table { public class ServerSearchFragment extends Table {
String mode; String mode;
Seq<ServerGroup> tempGroup = new Seq<>(); Seq<ServerGroup> originServerGroup = new Seq<>();
ObjectMap<ServerGroup, String[]> addresses = new ObjectMap<>(); ObjectMap<ServerGroup, String[]> originServerAddresses = new ObjectMap<>();
boolean loading = false; boolean loading = false;
Label loadingLabel = new Label("loading"); Label loadingLabel = new Label("");
public ServerSearchFragment() { public ServerSearchFragment() {
super(); super();
Core.app.post(() -> { Core.app.post(() -> {
tempGroup.set(Vars.defaultServers.copy()); originServerGroup.set(Vars.defaultServers.copy());
tempGroup.each(group -> addresses.put(group, group.addresses)); originServerGroup.each(group -> originServerAddresses.put(group, group.addresses));
Log.info("[Informatis] Fetched @ community servers.", tempGroup.size); Log.info("[Informatis] Fetched @ community servers.", originServerGroup.size);
}); });
final int[] i = {0}; final int[] i = {0};
@@ -49,15 +45,17 @@ public class ServerSearchFragment extends Table {
loadingLabel.setText("loading" + (count[0] % 4 == 0 ? "" : count[0] % 4 == 1 ? "." : count[0] % 4 == 2 ? ".." : count[0] % 4 == 3 ? "..." : "")); loadingLabel.setText("loading" + (count[0] % 4 == 0 ? "" : count[0] % 4 == 1 ? "." : count[0] % 4 == 2 ? ".." : count[0] % 4 == 3 ? "..." : ""));
} }
}); });
setBackground(Tex.button); setBackground(Tex.button);
addButton("survival"); addButton("survival");
addButton("pvp"); addButton("pvp");
addButton("attack"); addButton("attack");
addButton("sandbox"); addButton("sandbox");
addButton("custom"); addButton("custom");
Vars.ui.join.shown(() -> { Vars.ui.join.shown(() -> {
Table serverTable = (Table) Vars.ui.join.getChildren().get(1); Table serverTable = (Table) Vars.ui.join.getChildren().get(1);
var saved = serverTable.getChildren().copy(); Seq<Element> saved = serverTable.getChildren().copy();
serverTable.clear(); serverTable.clear();
serverTable.add(saved.get(0)).row(); serverTable.add(saved.get(0)).row();
serverTable.add(this).row(); serverTable.add(this).row();
@@ -68,24 +66,22 @@ public class ServerSearchFragment extends Table {
} }
void refreshAll() { void refreshAll() {
Method refreshAll;
try { try {
refreshAll = Vars.ui.join.getClass().getDeclaredMethod("refreshAll"); Method refreshAll = Vars.ui.join.getClass().getDeclaredMethod("refreshAll");
refreshAll.setAccessible(true);
try {
refreshAll.invoke(Vars.ui.join);
} catch (IllegalAccessException | InvocationTargetException ex) {
throw new RuntimeException(ex);
}
} catch (NoSuchMethodException e) { } catch (NoSuchMethodException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
refreshAll.setAccessible(true);
try {
refreshAll.invoke(Vars.ui.join);
} catch (IllegalAccessException | InvocationTargetException ex) {
throw new RuntimeException(ex);
}
} }
void loadingEnd() { void loadingEnd() {
loadingLabel.setText(""); loadingLabel.setText("");
loading = false; loading = false;
mode = "";
getChildren().each(elem -> ((TextButton)elem).setDisabled(false)); getChildren().each(elem -> ((TextButton)elem).setDisabled(false));
refreshAll(); refreshAll();
} }
@@ -93,35 +89,39 @@ public class ServerSearchFragment extends Table {
void refresh() { void refresh() {
loading = true; loading = true;
getChildren().each(elem -> ((TextButton)elem).setDisabled(true)); getChildren().each(elem -> ((TextButton)elem).setDisabled(true));
Time.run(15 * 60, this::loadingEnd); Time.run(15 * 60, () -> {
if(loading) loadingEnd();
});
final int[] iStack = {0}; final int[] iStack = {0};
for(int i = 0; i < tempGroup.size; i ++){ for(int i = 0; i < originServerGroup.size; i ++){
int j = i; int j = i;
ServerGroup group = tempGroup.get((i + tempGroup.size/2) % tempGroup.size); ServerGroup group = originServerGroup.get((i + originServerGroup.size/2) % originServerGroup.size);
Seq<String> tmp = Seq.with(group.addresses); Seq<String> tmp = new Seq<>();
final int[] iiStack = {0}; final int[] iiStack = {0};
int addressesLength = group.addresses.length; int addressesLength = group.addresses.length;
Cons<Void> checkLast = ignore -> { Runnable checkLast = () -> {
if(!loading) return; if(!loading) return;
if(++iiStack[0] < addressesLength) return; if(++iiStack[0] < addressesLength) return;
if(++iStack[0] < tempGroup.size) return; if(++iStack[0] < originServerGroup.size) return;
loadingEnd(); loadingEnd();
}; };
for(int ii = 0; ii < addressesLength; ii++){ for(int ii = 0; ii < addressesLength; ii++){
String address = tmp.get(ii); String address = group.addresses[ii];
String resaddress = address.contains(":") ? address.split(":")[0] : address; Vars.net.pingHost(
int resport = address.contains(":") ? Strings.parseInt(address.split(":")[1]) : Vars.port; address.contains(":") ? address.split(":")[0] : address,
Vars.net.pingHost(resaddress, resport, res -> { address.contains(":") ? Strings.parseInt(address.split(":")[1]) : Vars.port,
if(!loading || (tmp.contains(address) && res.mode == null res -> {
? Objects.equals(res.modeName, mode) if(loading &&
: !Objects.equals(mode, "custom") && res.mode.equals(Gamemode.valueOf(mode)) !tmp.contains(address) &&
)) { (res.mode == null ? Objects.equals(res.modeName, mode)
tmp.remove(address); : !Objects.equals(mode, "custom") && res.mode.equals(Gamemode.valueOf(mode)))
group.addresses = tmp.toArray(); ) tmp.add(address);
group.addresses = tmp.toArray(String.class);
Vars.defaultServers.set((j + Vars.defaultServers.size/2) % Vars.defaultServers.size, group); Vars.defaultServers.set((j + Vars.defaultServers.size/2) % Vars.defaultServers.size, group);
} checkLast.run();
checkLast.get(); },
}, e -> checkLast.get()); e -> checkLast.run()
);
} }
} }
} }
@@ -130,18 +130,12 @@ public class ServerSearchFragment extends Table {
TextButton button = new TextButton("@mode." + string + ".name", Styles.flatTogglet); TextButton button = new TextButton("@mode." + string + ".name", Styles.flatTogglet);
button.getLabel().setWrap(false); button.getLabel().setWrap(false);
button.clicked(()-> { button.clicked(()-> {
getChildren().each(elem -> {
if(!elem.equals(button)) ((TextButton)elem).setChecked(false);
});
mode = string; mode = string;
if(button.isChecked()) { getChildren().each(elem -> !elem.equals(button), elem -> ((TextButton)elem).setChecked(false));
refresh(); Vars.defaultServers.set(originServerGroup);
} else { defaultServers.each(group -> group.addresses = originServerAddresses.get(group));
Log.info("trying backdown"); if(button.isChecked()) refresh();
Vars.defaultServers.set(tempGroup); else refreshAll();
defaultServers.each(group -> group.addresses = addresses.get(group));
refreshAll();
}
}); });
add(button).minWidth(100).height(50); add(button).minWidth(100).height(50);
} }