Skip to content

Reformat all files #377

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

Merged
Garmelon merged 1 commit into from
Sep 4, 2025
Merged

Reformat all files #377

Show file tree
Hide file tree
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
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
453 changes: 225 additions & 228 deletions backend/backend/src/main/java/de/aaaaaaah/velcom/backend/GlobalConfig.java
View file
Open in desktop

Large diffs are not rendered by default.

44 changes: 23 additions & 21 deletions backend/backend/src/main/java/de/aaaaaaah/velcom/backend/KnownHostsIgnoringSshdFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,29 +11,31 @@
import org.eclipse.jgit.transport.sshd.ServerKeyDatabase;
import org.eclipse.jgit.transport.sshd.SshdSessionFactory;

/**
* A {@link SshdSessionFactory} that ignores server keys.
*/
/** A {@link SshdSessionFactory} that ignores server keys. */
public class KnownHostsIgnoringSshdFactory extends SshdSessionFactory {

public KnownHostsIgnoringSshdFactory(KeyCache keyCache, ProxyDataFactory proxies) {
super(keyCache, proxies);
}
public KnownHostsIgnoringSshdFactory(KeyCache keyCache, ProxyDataFactory proxies) {
super(keyCache, proxies);
}

@Override
protected ServerKeyDatabase getServerKeyDatabase(File homeDir, File sshDir) {
return new ServerKeyDatabase() {
@Override
public List<PublicKey> lookup(String connectAddress, InetSocketAddress remoteAddress,
Configuration config) {
return Collections.emptyList();
}
@Override
protected ServerKeyDatabase getServerKeyDatabase(File homeDir, File sshDir) {
return new ServerKeyDatabase() {
@Override
public List<PublicKey> lookup(
String connectAddress, InetSocketAddress remoteAddress, Configuration config) {
return Collections.emptyList();
}

@Override
public boolean accept(String connectAddress, InetSocketAddress remoteAddress,
PublicKey serverKey, Configuration config, CredentialsProvider provider) {
return true;
}
};
}
@Override
public boolean accept(
String connectAddress,
InetSocketAddress remoteAddress,
PublicKey serverKey,
Configuration config,
CredentialsProvider provider) {
return true;
}
};
}
}
272 changes: 135 additions & 137 deletions backend/backend/src/main/java/de/aaaaaaah/velcom/backend/RunnerAwareServerFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,141 +24,139 @@
*/
public class RunnerAwareServerFactory implements ServerFactory {

private static final Logger LOGGER = LoggerFactory.getLogger(RunnerAwareServerFactory.class);

private static final RunnerAwareServerFactory instance = new RunnerAwareServerFactory();

private ServerFactory underlying;
private GlobalConfig config;
private Dispatcher dispatcher;
private BenchRepo benchRepo;
private final Serializer serializer;

private RunnerAwareServerFactory() {
this.serializer = new Serializer();
}

@Override
public Server build(Environment environment) {
ensureIsInitialized();

Server server = underlying.build(environment);

HttpConnectorFactory connectorFactory = new HttpConnectorFactory();
connectorFactory.setPort(config.getRunnerPort());
Connector connector = connectorFactory
.build(server, environment.metrics(), "Runner", new ExecutorThreadPool(32));
server.addConnector(
connector
);
Map<Connector, Handler> handlerMap = new HashMap<>();

for (Connector serverConnector : server.getConnectors()) {
handlerMap.put(serverConnector, server.getHandler());
}

MutableServletContextHandler handler = new MutableServletContextHandler();
handler.getServletContext().addServlet(
"Runner Websocket servlet",
new ServerMasterWebsocketServlet(dispatcher, serializer, config.getRunnerToken(), benchRepo)
)
.addMapping("/runner-connector");
handlerMap.put(connector, handler);

server.setHandler(new RoutingHandler(handlerMap));

LOGGER.debug("Registered the websocket servlet");

return server;
}

@Override
public void configure(Environment environment) {
underlying.configure(environment);
}


/**
* Sets the config to use.
*
* @param config the config to use
* @throws IllegalStateException if a config has already been set
*/
public void setConfig(GlobalConfig config) {
if (this.config != null) {
throw new IllegalStateException("I already have a config!");
}
this.config = config;
}

/**
* Sets the server factory to delegate to.
*
* @param underlying the underlying server factory
* @throws IllegalStateException if a server factory has already been set
*/
public void setServerFactory(ServerFactory underlying) {
if (this.underlying != null) {
throw new IllegalStateException("I already have a server factory!");
}

this.underlying = underlying;
}

/**
* Sets the dispatcher to use.
*
* @param dispatcher the dispatcher
* @throws IllegalStateException if a dispatcher has already been set
*/
public void setDispatcher(Dispatcher dispatcher) {
if (this.dispatcher != null) {
throw new IllegalStateException("I already have a dispatcher!");
}
this.dispatcher = dispatcher;
}

/**
* Sets the bench reo to use.
*
* @param benchRepo the bench repo
* @throws IllegalStateException if a bench repo has already been set
*/
public void setBenchRepo(BenchRepo benchRepo) {
if (this.benchRepo != null) {
throw new IllegalStateException("I already have a bench repo!");
}
this.benchRepo = benchRepo;
}

/**
* Returns whether the factory lacks an underlying server factory.
*
* @return true if no underlying server factory is available
*/
public boolean lacksFactory() {
return underlying == null;
}

private void ensureIsInitialized() {
if (config == null) {
throw new IllegalStateException("Config not initialized");
}
if (underlying == null) {
throw new IllegalStateException("Server factory not initialized");
}
if (dispatcher == null) {
throw new IllegalStateException("Dispatcher not initialized");
}
}


/**
* Returns the instance of the {@link RunnerAwareServerFactory}.
*
* @return the instance
*/
public static RunnerAwareServerFactory getInstance() {
return instance;
}
private static final Logger LOGGER = LoggerFactory.getLogger(RunnerAwareServerFactory.class);

private static final RunnerAwareServerFactory instance = new RunnerAwareServerFactory();

private ServerFactory underlying;
private GlobalConfig config;
private Dispatcher dispatcher;
private BenchRepo benchRepo;
private final Serializer serializer;

private RunnerAwareServerFactory() {
this.serializer = new Serializer();
}

@Override
public Server build(Environment environment) {
ensureIsInitialized();

Server server = underlying.build(environment);

HttpConnectorFactory connectorFactory = new HttpConnectorFactory();
connectorFactory.setPort(config.getRunnerPort());
Connector connector =
connectorFactory.build(server, environment.metrics(), "Runner", new ExecutorThreadPool(32));
server.addConnector(connector);
Map<Connector, Handler> handlerMap = new HashMap<>();

for (Connector serverConnector : server.getConnectors()) {
handlerMap.put(serverConnector, server.getHandler());
}

MutableServletContextHandler handler = new MutableServletContextHandler();
handler
.getServletContext()
.addServlet(
"Runner Websocket servlet",
new ServerMasterWebsocketServlet(
dispatcher, serializer, config.getRunnerToken(), benchRepo))
.addMapping("/runner-connector");
handlerMap.put(connector, handler);

server.setHandler(new RoutingHandler(handlerMap));

LOGGER.debug("Registered the websocket servlet");

return server;
}

@Override
public void configure(Environment environment) {
underlying.configure(environment);
}

/**
* Sets the config to use.
*
* @param config the config to use
* @throws IllegalStateException if a config has already been set
*/
public void setConfig(GlobalConfig config) {
if (this.config != null) {
throw new IllegalStateException("I already have a config!");
}
this.config = config;
}

/**
* Sets the server factory to delegate to.
*
* @param underlying the underlying server factory
* @throws IllegalStateException if a server factory has already been set
*/
public void setServerFactory(ServerFactory underlying) {
if (this.underlying != null) {
throw new IllegalStateException("I already have a server factory!");
}

this.underlying = underlying;
}

/**
* Sets the dispatcher to use.
*
* @param dispatcher the dispatcher
* @throws IllegalStateException if a dispatcher has already been set
*/
public void setDispatcher(Dispatcher dispatcher) {
if (this.dispatcher != null) {
throw new IllegalStateException("I already have a dispatcher!");
}
this.dispatcher = dispatcher;
}

/**
* Sets the bench reo to use.
*
* @param benchRepo the bench repo
* @throws IllegalStateException if a bench repo has already been set
*/
public void setBenchRepo(BenchRepo benchRepo) {
if (this.benchRepo != null) {
throw new IllegalStateException("I already have a bench repo!");
}
this.benchRepo = benchRepo;
}

/**
* Returns whether the factory lacks an underlying server factory.
*
* @return true if no underlying server factory is available
*/
public boolean lacksFactory() {
return underlying == null;
}

private void ensureIsInitialized() {
if (config == null) {
throw new IllegalStateException("Config not initialized");
}
if (underlying == null) {
throw new IllegalStateException("Server factory not initialized");
}
if (dispatcher == null) {
throw new IllegalStateException("Dispatcher not initialized");
}
}

/**
* Returns the instance of the {@link RunnerAwareServerFactory}.
*
* @return the instance
*/
public static RunnerAwareServerFactory getInstance() {
return instance;
}
}
Loading