package Task_4;

import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.ObservableEmitter;
import io.reactivex.rxjava3.core.ObservableOnSubscribe;

import java.util.Timer;
import java.util.TimerTask;

public class GeneratorFile implements ObservableOnSubscribe<FileData> {
    private final String[] arrTypes;
    private final int MIN_SIZE;
    private final int MAX_SIZE;
    private final int MIN_PERIOD;
    private final int MAX_PERIOD;

    public GeneratorFile(String[] arrTypes, int MIN_SIZE, int MAX_SIZE, int MIN_PERIOD, int MAX_PERIOD) {
        this.arrTypes = arrTypes;
        this.MIN_SIZE = MIN_SIZE;
        this.MAX_SIZE = MAX_SIZE;
        this.MIN_PERIOD = MIN_PERIOD;
        this.MAX_PERIOD = MAX_PERIOD;
    }

    @Override
    public void subscribe(@NonNull ObservableEmitter<FileData> emitter) {
        generateSchedule(emitter);
    }

    private void generateSchedule(@NonNull ObservableEmitter<FileData> emitter) {
        Timer timer = new Timer();
        TimerTask task = new TimerTask() {
            public void run()
            {
                emitter.onNext(new FileData(generateType(), generateSize()));
                generateSchedule(emitter);
            }
        };

        timer.schedule(task, generatePeriod());
    }

    private String generateType() {
        int index = (int) Math.floor(Math.random()  * this.arrTypes.length);

        return this.arrTypes[index];
    }

    private int generateSize() {
        return generateNumberInRange(MIN_SIZE, MAX_SIZE);
    }

    private int generatePeriod() {
        return generateNumberInRange(MIN_PERIOD, MAX_PERIOD);
    }

    private int generateNumberInRange(int min, int max) {
        return min + (int) Math.round(Math.random() * (max - min));
    }
}