Marthym

package fr.ght1pc9kc.baywatch.notify.infra;

import fr.ght1pc9kc.baywatch.notify.api.NotifyManager;
import fr.ght1pc9kc.baywatch.notify.api.model.BasicEvent;
import fr.ght1pc9kc.baywatch.notify.api.model.EventType;
import fr.ght1pc9kc.baywatch.notify.api.model.ReactiveEvent;
import fr.ght1pc9kc.baywatch.notify.api.model.ServerEventVisitor;
import fr.ght1pc9kc.baywatch.security.api.AuthenticationFacade;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;

Marthym

package fr.ght1pc9kc.baywatch.notify.domain;

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.f4b6a3.ulid.UlidCreator;
import fr.ght1pc9kc.baywatch.notify.api.NotifyManager;
import fr.ght1pc9kc.baywatch.notify.api.NotifyService;
import fr.ght1pc9kc.baywatch.notify.api.model.BasicEvent;
import fr.ght1pc9kc.baywatch.notify.api.model.EventType;
import fr.ght1pc9kc.baywatch.notify.api.model.ReactiveEvent;

Marthym

package fr.ght1pc9kc.baywatch;

import lombok.AllArgsConstructor;
import lombok.Value;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Sinks;
import reactor.test.StepVerifier;

import java.util.List;

Marthym

#!/usr/bin/env bash
set -euo pipefail
IFS=$'\n\t'

#/ Usage: ./backup-dir.sh "gpg-passphrase" "backup-directory" 
#/ Description: Compress, crypt and upload each directory to HubiC
#/ Examples: ./backup-dir.sh "xxxxx" "~/photos" 
#/ Options:
#/   --help: Display this help message
usage() { grep '^#/' "$0" | cut -c4- ; exit 0 ; }

Marthym

#!/usr/bin/env bash
set -euo pipefail
IFS=$'\n\t'

#/ Usage:       git-repos-update-all.sh
#/ Version:     2.0
#/ Description: Find all git repository from `~/` and update them in multi-thread mode.
#/ Options:
#/   --help:     Display this help message
function usage() { grep '^#/' "$0" | cut -c4- ; exit 0 ; }

Marthym

#!/usr/bin/perl
use strict;
use warnings;
$|=1;

my %url;

# read config file
open CONF, $ARGV[0] or die "Error opening $ARGV[0]: $!";
while (<CONF>) {

Marthym

        db = new TestGraphDatabaseFactory().newImpermanentDatabase();

        boolean available = db.isAvailable(5000);
        assert available;

        int start = -1;
        Random random = new Random();
        while (start != 0) {
            port = RANDOM_PORTS_LOWER_BOUND + random.nextInt(RANDOM_PORTS_COUNT);
            try {

Marthym

/* Using a mysql inside docker for executing test, I need to wait for MySQL is completly started before running test */
Awaitility.await().atMost(5, TimeUnit.SECONDS).pollInterval(1, TimeUnit.SECONDS).until(new Callable<Boolean>() {
    @Override
    public Boolean call() throws Exception {
        try (Connection conn = ds.getConnection()) {
            return true;
        } catch (Exception e) {
            System.out.println(e.getClass() + ": " + e.getLocalizedMessage());
            return false;
        }