Project.java

package pro.insideagent;

import io.micronaut.runtime.Micronaut;
import jakarta.annotation.Nullable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import pro.insideagent.redis.JedisManager;
import pro.insideagent.utils.SecretData;

import java.io.IOException;
import java.security.SecureRandom;
import java.util.Base64;
import java.util.UUID;
import java.util.concurrent.ExecutionException;

public class Project {
    private static final JedisManager jedis = JedisManager.getInstance();
    private static final UUID test_uuid = UUID.fromString("7cd8e56a-d41a-434a-9d14-e99455b1fd0b");
    private static final Logger LOGGER = LoggerFactory.getLogger(Project.class);

    static void main(String[] args) throws IOException {
        Micronaut.run(Project.class, args);
        SecretData.initLoginInfo();
        String session = tokenGenerator();
        LOGGER.info("test");
        jedis.initPubSub();
        jedis.executeAction(j -> j.set(test_uuid + "_sessionToken", session)).queue();
        System.out.println(session);
    }


    public static boolean validateToken(@Nullable UUID user_id, @Nullable String token) {
        if (token != null) token = token.substring(7);
        if (user_id == null) return false;
        try {
            String session = jedis.submit(j -> j.get(user_id + "_sessionToken")).get();
            return (session != null && session.equals(token));

        } catch (InterruptedException | ExecutionException ignored) {}
        return false;
    }

    private static String tokenGenerator() {
        SecureRandom secureRandom = new SecureRandom();
        Base64.Encoder encoder = Base64.getUrlEncoder();
        byte[] randomBytes = new byte[124];
        secureRandom.nextBytes(randomBytes);
        return encoder.encodeToString(randomBytes);
    }
}