Team2890/PhotonVision
4
0
Fork 0
mirror of https://github.com/PhotonVision/photonvision synced 2026-06-20 00:51:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'folderStructure' into Java

Browse Source 
# Conflicts:
#	Main/pom.xml
#	Main/src/main/java/com/chameleonvision/web/Server.java
This commit is contained in:
Banks Troutman
2019-09-15 15:11:26 -04:00
parent e80f35b39f 25652ba32e
commit f26b7df000
14 changed files with 183 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
Main/src/main/java/com/chameleonvision/web/Server.java Normal file
View File

@@ -0,0 +1,64 @@
package com.chameleonvision.web;
import com.chameleonvision.settings.SettingsManager;
import io.javalin.Javalin;
import io.javalin.websocket.WsContext;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.List;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springframework.beans.BeanUtils;
public class Server {
private static List<WsContext> users = new ArrayList<WsContext>();
public static void main(int port) {
Javalin app = Javalin.create();
app.config.addStaticFiles("web");
app.ws("/websocket", ws ->{
ws.onConnect(ctx -> {
users.add(ctx);
System.out.println("Socket Connected");
});
ws.onClose(ctx -> {
users.remove(ctx);
System.out.println("Socket Disconnected");
SettingsManager.getInstance().SaveSettings();
});
ws.onMessage(ctx -> {
broadcastMessage(ctx, ctx.message());
JSONObject jsonObject = new JSONObject(ctx.message());
String key =jsonObject.keySet().toArray()[0].toString();
Object value = jsonObject.get(key);
System.out.println("Key: "+key+" Value: "+value);
Field[] fields = Pipeline.class.getFields();
for (Field f : fields)
{//TODO: check calibration in output tab for crashes
if(f.getName().equals(key))
{
if(BeanUtils.isSimpleValueType(value.getClass()))
f.set(SettingsManager.getInstance().GetCurrentPipeline(),value);
else
if(value.getClass()==JSONArray.class){
f.set(SettingsManager.getInstance().GetCurrentPipeline(),((JSONArray)value).toList());
}
}
}
});
});
app.start(port);
}
private static void broadcastMessage(WsContext sendingUser, String message){
for (var user : users)
{
if (user != sendingUser){
user.send(message);
}
}
}
}