misc tidying
This commit is contained in:
parent
dac59966aa
commit
f96518b8e4
@ -90,10 +90,5 @@ public class BungeeContextManager extends ContextManager<ProxiedPlayer> {
|
|||||||
public Contexts getContexts() {
|
public Contexts getContexts() {
|
||||||
return this.contextsCache.get(this.key);
|
return this.contextsCache.get(this.key);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public ImmutableContextSet getContextSet() {
|
|
||||||
return getContexts().getContexts().makeImmutable();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -44,16 +44,16 @@ public final class ContextSetConfigurateSerializer {
|
|||||||
ConfigurationNode data = SimpleConfigurationNode.root();
|
ConfigurationNode data = SimpleConfigurationNode.root();
|
||||||
Map<String, Collection<String>> map = contextSet.toMultimap().asMap();
|
Map<String, Collection<String>> map = contextSet.toMultimap().asMap();
|
||||||
|
|
||||||
map.forEach((k, v) -> {
|
for (Map.Entry<String, Collection<String>> entry : map.entrySet()) {
|
||||||
List<String> values = new ArrayList<>(v);
|
List<String> values = new ArrayList<>(entry.getValue());
|
||||||
int size = values.size();
|
int size = values.size();
|
||||||
|
|
||||||
if (size == 1) {
|
if (size == 1) {
|
||||||
data.getNode(k).setValue(values.get(0));
|
data.getNode(entry.getKey()).setValue(values.get(0));
|
||||||
} else if (size > 1) {
|
} else if (size > 1) {
|
||||||
data.getNode(k).setValue(values);
|
data.getNode(entry.getKey()).setValue(values);
|
||||||
}
|
}
|
||||||
});
|
}
|
||||||
|
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
|
@ -47,20 +47,20 @@ public final class ContextSetJsonSerializer {
|
|||||||
JsonObject data = new JsonObject();
|
JsonObject data = new JsonObject();
|
||||||
Map<String, Collection<String>> map = contextSet.toMultimap().asMap();
|
Map<String, Collection<String>> map = contextSet.toMultimap().asMap();
|
||||||
|
|
||||||
map.forEach((k, v) -> {
|
for (Map.Entry<String, Collection<String>> entry : map.entrySet()) {
|
||||||
List<String> values = new ArrayList<>(v);
|
List<String> values = new ArrayList<>(entry.getValue());
|
||||||
int size = values.size();
|
int size = values.size();
|
||||||
|
|
||||||
if (size == 1) {
|
if (size == 1) {
|
||||||
data.addProperty(k, values.get(0));
|
data.addProperty(entry.getKey(), values.get(0));
|
||||||
} else if (size > 1) {
|
} else if (size > 1) {
|
||||||
JsonArray arr = new JsonArray();
|
JsonArray arr = new JsonArray();
|
||||||
for (String s : values) {
|
for (String s : values) {
|
||||||
arr.add(new JsonPrimitive(s));
|
arr.add(new JsonPrimitive(s));
|
||||||
}
|
}
|
||||||
data.add(k, arr);
|
data.add(entry.getKey(), arr);
|
||||||
}
|
}
|
||||||
});
|
}
|
||||||
|
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
|
@ -35,6 +35,8 @@ public interface ContextsSupplier {
|
|||||||
|
|
||||||
Contexts getContexts();
|
Contexts getContexts();
|
||||||
|
|
||||||
ImmutableContextSet getContextSet();
|
default ImmutableContextSet getContextSet() {
|
||||||
|
return getContexts().getContexts().makeImmutable();
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -92,7 +92,7 @@ public class UserHousekeeper implements Runnable {
|
|||||||
private final long duration;
|
private final long duration;
|
||||||
private final TimeUnit unit;
|
private final TimeUnit unit;
|
||||||
|
|
||||||
private TimeoutSettings(long duration, TimeUnit unit) {
|
TimeoutSettings(long duration, TimeUnit unit) {
|
||||||
this.duration = duration;
|
this.duration = duration;
|
||||||
this.unit = unit;
|
this.unit = unit;
|
||||||
}
|
}
|
||||||
|
@ -47,7 +47,7 @@ public class RedisMessenger implements Messenger {
|
|||||||
private final IncomingMessageConsumer consumer;
|
private final IncomingMessageConsumer consumer;
|
||||||
|
|
||||||
private JedisPool jedisPool;
|
private JedisPool jedisPool;
|
||||||
private LPSub sub;
|
private Subscription sub;
|
||||||
|
|
||||||
public RedisMessenger(LuckPermsPlugin plugin, IncomingMessageConsumer consumer) {
|
public RedisMessenger(LuckPermsPlugin plugin, IncomingMessageConsumer consumer) {
|
||||||
this.plugin = plugin;
|
this.plugin = plugin;
|
||||||
@ -66,7 +66,7 @@ public class RedisMessenger implements Messenger {
|
|||||||
}
|
}
|
||||||
|
|
||||||
this.plugin.getBootstrap().getScheduler().executeAsync(() -> {
|
this.plugin.getBootstrap().getScheduler().executeAsync(() -> {
|
||||||
this.sub = new LPSub(this);
|
this.sub = new Subscription(this);
|
||||||
try (Jedis jedis = this.jedisPool.getResource()) {
|
try (Jedis jedis = this.jedisPool.getResource()) {
|
||||||
jedis.subscribe(this.sub, CHANNEL);
|
jedis.subscribe(this.sub, CHANNEL);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
@ -90,10 +90,10 @@ public class RedisMessenger implements Messenger {
|
|||||||
this.jedisPool.destroy();
|
this.jedisPool.destroy();
|
||||||
}
|
}
|
||||||
|
|
||||||
private static class LPSub extends JedisPubSub {
|
private static class Subscription extends JedisPubSub {
|
||||||
private final RedisMessenger parent;
|
private final RedisMessenger parent;
|
||||||
|
|
||||||
public LPSub(RedisMessenger parent) {
|
private Subscription(RedisMessenger parent) {
|
||||||
this.parent = parent;
|
this.parent = parent;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user