Compare commits

..

6 Commits
v1.2.0 ... main

Author SHA1 Message Date
dc983df531 Update .gitea/workflows/build.yml
All checks were successful
SharePulse build / build-jar (push) Successful in 1m1s
SharePulse build / build-docker-image (push) Successful in 51s
2025-04-18 23:58:55 +00:00
Max W.
0f64322af3 Update build.gradle
All checks were successful
SharePulse build / build-jar (push) Successful in 3m47s
SharePulse build / build-docker-image (push) Successful in 13s
Updated libs with cve
2024-09-08 23:59:15 +02:00
e5ce27adfd Update build.gradle 2024-06-09 09:24:36 +00:00
Max
4134367350 Fixed auto file cleanup not working 2024-06-09 11:23:51 +02:00
f65a0d0e22 Merge pull request 'Fixed auto file cleanup not working' (#21) from bugfix/file-cron-auto-delete into main
Reviewed-on: https://git.walzen665.de/Walzen665/sharepulse/pulls/21
2024-06-09 09:01:52 +00:00
Max
e73a2e6e8d Fixed auto file cleanup not working 2024-06-09 11:00:37 +02:00
4 changed files with 36 additions and 34 deletions

View File

@ -66,16 +66,18 @@ jobs:
- name: Initialize Docker runtime - name: Initialize Docker runtime
if: env.SKIP_SUBSEQUENT_STEPS != 'true' if: env.SKIP_SUBSEQUENT_STEPS != 'true'
run: | run: |
apt-get update sudo apt-get update
apt-get install ca-certificates curl gnupg lsb-release -y sudo apt-get install ca-certificates curl
install -m 0755 -d /etc/apt/keyrings sudo install -m 0755 -d /etc/apt/keyrings
curl -fsSL https://download.docker.com/linux/debian/gpg | gpg --dearmor -o /etc/apt/keyrings/docker.gpg sudo curl -fsSL https://download.docker.com/linux/ubuntu/gpg -o /etc/apt/keyrings/docker.asc
chmod a+r /etc/apt/keyrings/docker.gpg sudo chmod a+r /etc/apt/keyrings/docker.asc
# Add the repository to Apt sources:
echo \ echo \
"deb [arch=$(dpkg --print-architecture) signed-by=/etc/apt/keyrings/docker.gpg] https://download.docker.com/linux/debian \ "deb [arch=$(dpkg --print-architecture) signed-by=/etc/apt/keyrings/docker.asc] https://download.docker.com/linux/ubuntu \
$(lsb_release -cs) stable" | \ $(. /etc/os-release && echo "${UBUNTU_CODENAME:-$VERSION_CODENAME}") stable" | \
tee /etc/apt/sources.list.d/docker.list > /dev/null sudo tee /etc/apt/sources.list.d/docker.list > /dev/null
apt-get update sudo apt-get update
apt-get install docker-ce docker-ce-cli containerd.io docker-buildx-plugin -y apt-get install docker-ce docker-ce-cli containerd.io docker-buildx-plugin -y
- name: Download Artifact - name: Download Artifact

View File

@ -5,7 +5,7 @@ plugins {
} }
group = 'de.w665' group = 'de.w665'
version = '1.2.0' version = '1.2.1'
java { java {
sourceCompatibility = '21' sourceCompatibility = '21'
@ -39,11 +39,11 @@ dependencies {
// https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-security // https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-security
implementation group: 'org.springframework.boot', name: 'spring-boot-starter-security', version: '3.2.4' implementation group: 'org.springframework.boot', name: 'spring-boot-starter-security', version: '3.2.4'
// https://mvnrepository.com/artifact/io.jsonwebtoken/jjwt-api // https://mvnrepository.com/artifact/io.jsonwebtoken/jjwt-api
implementation group: 'io.jsonwebtoken', name: 'jjwt-api', version: '0.12.5' implementation group: 'io.jsonwebtoken', name: 'jjwt-api', version: '0.12.6'
// https://mvnrepository.com/artifact/io.jsonwebtoken/jjwt-impl // https://mvnrepository.com/artifact/io.jsonwebtoken/jjwt-impl
runtimeOnly group: 'io.jsonwebtoken', name: 'jjwt-impl', version: '0.12.5' runtimeOnly group: 'io.jsonwebtoken', name: 'jjwt-impl', version: '0.12.6'
// https://mvnrepository.com/artifact/io.jsonwebtoken/jjwt-orgjson // https://mvnrepository.com/artifact/io.jsonwebtoken/jjwt-orgjson
runtimeOnly group: 'io.jsonwebtoken', name: 'jjwt-orgjson', version: '0.12.5' runtimeOnly group: 'io.jsonwebtoken', name: 'jjwt-orgjson', version: '0.12.6'
} }

View File

@ -12,6 +12,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import java.lang.reflect.Type; import java.lang.reflect.Type;
import java.time.Instant;
import java.time.temporal.ChronoUnit;
import java.util.*; import java.util.*;
@Repository @Repository
@ -52,7 +54,12 @@ public class FileUploadRepository {
} catch (NoSuchElementException e) { } catch (NoSuchElementException e) {
return Optional.empty(); return Optional.empty();
} }
}
public List<FileUpload> findAll() {
return r.db("sharepulse").table("file_uploads")
.run(connection, FileUpload.class)
.toList();
} }
public void updateFileUpload(FileUpload updatedFileUpload) { public void updateFileUpload(FileUpload updatedFileUpload) {
@ -79,32 +86,24 @@ public class FileUploadRepository {
.run(connection); .run(connection);
} }
// This query filters all file uploads that are older than 24 hours from the file_uplaods table (not the expired_file_uploads table) public List<FileUpload> getAllExpiredFileUploads() {
public List<FileUpload> findAllExpiredActiveFileUploads() { long timestamp = getTimestamp24HoursAgo();
long timestamp = getOneMinuteAgoTimestamp();
return r.db("sharepulse").table("file_uploads") return r.db("sharepulse").table("file_uploads")
.filter(row -> row.g("uploadDate").lt(timestamp)) .filter(row -> row.g("uploadDate").lt(timestamp))
.run(connection, FileUpload.class) .run(connection, FileUpload.class)
.toList(); .toList();
} }
public List<FileUpload> findAll() { private long getTimestamp24HoursAgo() {
return r.db("sharepulse").table("file_uploads") Instant now = Instant.now();
.run(connection, FileUpload.class) Instant oneMinuteAgo = now.minus(24, ChronoUnit.HOURS);
.toList(); return oneMinuteAgo.toEpochMilli();
} }
private long get24HoursAgoTimestamp() { // For testing only
Calendar calendar = Calendar.getInstance(); private long getTimestampOneMinuteAgo() {
calendar.add(Calendar.HOUR, -24); Instant now = Instant.now();
return calendar.getTimeInMillis() / 1000; Instant oneMinuteAgo = now.minus(1, ChronoUnit.MINUTES);
} return oneMinuteAgo.toEpochMilli();
private long getOneMinuteAgoTimestamp() {
Calendar calendar = Calendar.getInstance();
calendar.add(Calendar.MINUTE, -1); // Subtract 1 minute
return calendar.getTimeInMillis() / 1000; // Convert milliseconds to seconds (Unix timestamp)
} }
} }

View File

@ -23,10 +23,11 @@ public class FileCleanupService {
this.fileService = fileService; this.fileService = fileService;
} }
//@Scheduled(cron = "*/10 * * * * *") // every 10 seconds
@Scheduled(cron = "0 0 * * * *") @Scheduled(cron = "0 0 * * * *")
public void cleanup() { public void cleanup() {
log.debug("Running cleanup..."); log.debug("Running cleanup...");
List<FileUpload> expFileUploads = fileUploadRepository.findAllExpiredActiveFileUploads(); List<FileUpload> expFileUploads = fileUploadRepository.getAllExpiredFileUploads();
for (FileUpload fileUpload : expFileUploads) { for (FileUpload fileUpload : expFileUploads) {
fileService.deleteFile(fileUpload); fileService.deleteFile(fileUpload);
expiredFileUploadRepository.insertExpiredFileUpload(fileUpload); expiredFileUploadRepository.insertExpiredFileUpload(fileUpload);