Thibaut/ffsaf-site
1
0
Fork 0
Code Issues Pull Requests Actions Packages Releases Activity

Merge pull request #25

Browse Source 
dev
This commit is contained in:
TitiOnFire 2024-03-22 20:44:00 +01:00 committed by GitHub
commit 0c9f1ccb0d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 27 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -47,3 +47,4 @@ nb-configuration.xml
/cle_prive.jks
/src/main/resources/META-INF/resources/
/media/
/media-ext/

27
src/main/java/fr/titionfire/ffsaf/ws/FileSocket.java
View File

@ -46,6 +46,7 @@ public class FileSocket {
try {
if (sessions.containsKey(code)) {
FileRecv fileRecv = sessions.get(code);
fileRecv.session = session;
fileRecv.file = new File(media + "-ext", "record/" + fileRecv.name);
fileRecv.fos = new FileOutputStream(fileRecv.file, false);
logger.info("Start reception of file: " + fileRecv.file.getAbsolutePath());
@ -116,15 +117,39 @@ public class FileSocket {
@OnMessage
public void onMessage(byte[] data, @PathParam("code") String code) {
int length = (data[1] << 7) | data[2];
byte check_sum = 0;
for (int j = 3; j < length + 3; j++) {
check_sum = (byte) (check_sum ^ data[j]);
}
// System.out.println(length + " - " + data[1] + " - " + data[0] + " - " + check_sum);
if (sessions.containsKey(code)) {
FileRecv fileRecv = sessions.get(code);
if (check_sum != data[0]) {
fileRecv.session.getAsyncRemote().sendText("Error: Checksum error", result -> {
if (result.getException() != null) {
logger.error("Unable to send message: " + result.getException());
}
});
return;
}
try {
fileRecv.fos.write(data);
fileRecv.fos.write(data, 3, length);
} catch (IOException e) {
StringWriter errors = new StringWriter();
e.printStackTrace(new PrintWriter(errors));
logger.error(errors.toString());
}
fileRecv.session.getAsyncRemote().sendText("ok", result -> {
if (result.getException() != null) {
logger.error("Unable to send message: " + result.getException());
}
});
}
}