package io.infinite.pigeon.threads

import groovy.transform.ToString
import groovy.util.logging.Slf4j
import io.infinite.blackbox.BlackBox
import io.infinite.blackbox.BlackBoxLevel
import io.infinite.pigeon.conf.OutputQueue
import io.infinite.pigeon.springdatarest.entities.OutputMessage
import io.infinite.pigeon.other.MessageStatusSets
import io.infinite.pigeon.springdatarest.services.PigeonService
import org.springframework.context.annotation.Scope
import org.springframework.stereotype.Component

import javax.annotation.PostConstruct
import java.time.Duration
import java.time.Instant

@BlackBox(level = BlackBoxLevel.METHOD)
@Slf4j
@ToString(includeNames = true, includeFields = true, includeSuper = true)
@Component
@Scope("prototype")
class OutputThreadRetry extends OutputThread {

    OutputThreadRetry(OutputQueue outputQueue) {
        super(outputQueue)
        senderThreadRobin.clear()
        name = name + "_RETRY"
    }

    @Override
    @PostConstruct
    void initSenderThreads() {
        (1..outputQueue.retryThreadCount).each { threadCounter ->
            SenderThread senderThread = applicationContext.getBean(SenderThread.class, outputQueue, "_RETRY_" + threadCounter)
            senderThreadRobin.add(senderThread)
            senderThread.start()
        }
    }

    @BlackBox(level = BlackBoxLevel.ERROR, suppressExceptions = true)
    void dbScanRetry() {
        Date lastSendTime = (Instant.now() - Duration.ofSeconds(outputQueue.resendIntervalSeconds)).toDate()
        Integer countToRetry = outputMessageRepository.markForRetry(
                outputQueue.name,
                MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(),
                outputQueue.maxRetryCount,
                lastSendTime,
                PigeonService.staticUUID
        )
        if (countToRetry > 0) {
            LinkedHashSet<OutputMessage> outputMessages = outputMessageRepository.selectForRetry(
                    outputQueue.name,
                    MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(),
                    outputQueue.maxRetryCount,
                    lastSendTime,
                    PigeonService.staticUUID
            )
            outputMessages.each { outputMessage ->
                senderEnqueue(outputMessage)
            }
        }
    }

    @Override
    @BlackBox(level = BlackBoxLevel.METHOD)
    void run() {
        while (true) {
            dbScanRetry()
            sleep(outputQueue.pollPeriodMillisecondsRetry)
        }
    }

}

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package io.infinite.pigeon.threads;

import groovy.lang.Closure;
import groovy.lang.IntRange;
import groovy.transform.Generated;
import groovy.transform.ToString;
import io.infinite.blackbox.BlackBox;
import io.infinite.blackbox.BlackBoxLevel;
import io.infinite.blackbox.BlackBoxRuntime;
import io.infinite.blackbox.MethodMetaData;
import io.infinite.pigeon.conf.OutputQueue;
import io.infinite.pigeon.other.MessageStatusSets;
import io.infinite.pigeon.other.RoundRobin;
import io.infinite.pigeon.springdatarest.entities.OutputMessage;
import io.infinite.pigeon.springdatarest.services.PigeonService;
import java.time.Duration;
import java.time.Instant;
import java.util.Date;
import java.util.LinkedHashSet;
import java.util.Map;
import javax.annotation.PostConstruct;
import org.apache.groovy.datetime.extensions.DateTimeExtensions;
import org.codehaus.groovy.runtime.DefaultGroovyMethods;
import org.codehaus.groovy.runtime.GeneratedClosure;
import org.codehaus.groovy.runtime.InvokerHelper;
import org.codehaus.groovy.runtime.ScriptBytecodeAdapter;
import org.codehaus.groovy.runtime.StringGroovyMethods;
import org.codehaus.groovy.runtime.typehandling.DefaultTypeTransformation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;

@BlackBox(
    level = BlackBoxLevel.METHOD
)
@ToString(
    includeNames = true,
    includeSuper = true,
    includeFields = true
)
@Component
@Scope("prototype")
public class OutputThreadRetry extends OutputThread {
    public static final transient Logger automaticLog;
    public static final transient BlackBoxRuntime blackBoxRuntime;
    private static final transient Logger log;

    public OutputThreadRetry(OutputQueue outputQueue) {
        super(outputQueue);
        Object resultPlaceHolder = null;
        ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, blackBoxRuntime, (String)"methodBegin", new Object[]{new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "<init>", 25, 29, 5, 6), ScriptBytecodeAdapter.createMap(new Object[]{"outputQueue", outputQueue})});

        Object var10000;
        try {
            ((RoundRobin)((OutputThreadRetry)this).getSenderThreadRobin()).clear();
            var10000 = null;
            String var3 = StringGroovyMethods.plus(((OutputThreadRetry)this).getName(), "_RETRY");
            ScriptBytecodeAdapter.setGroovyObjectProperty(var3, OutputThreadRetry.class, this, (String)"name");
        } catch (Exception var8) {
            ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, blackBoxRuntime, (String)"methodException", new Object[]{new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "<init>", 25, 29, 5, 6), ScriptBytecodeAdapter.createMap(new Object[]{"outputQueue", outputQueue}), var8});
            throw (Throwable)var8;
        } finally {
            blackBoxRuntime.methodEnd(new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "<init>", 25, 29, 5, 6));
            var10000 = null;
        }

    }

    @PostConstruct
    public void initSenderThreads() {
        Object resultPlaceHolder = null;
        blackBoxRuntime.methodBegin(new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "initSenderThreads", 31, 39, 5, 6), (Map)null);
        Object var10000 = null;

        try {
            final class _initSenderThreads_closure1 extends Closure implements GeneratedClosure {
                public _initSenderThreads_closure1(Object _outerInstance, Object _thisObject) {
                    super(_outerInstance, _thisObject);
                }

                public Object doCall(Object threadCounter) {
                    SenderThread senderThread = (SenderThread)ScriptBytecodeAdapter.castToType(((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_initSenderThreads_closure1)this).getThisObject(), OutputThread.class))).getApplicationContext().getBean(SenderThread.class, new Object[]{((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_initSenderThreads_closure1)this).getThisObject(), OutputThread.class))).getOutputQueue(), StringGroovyMethods.plus("_RETRY_", threadCounter)}), SenderThread.class);
                    ((RoundRobin)((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_initSenderThreads_closure1)this).getThisObject(), OutputThread.class))).getSenderThreadRobin()).add(senderThread);
                    ((SenderThread)senderThread).start();
                    return null;
                }

                public Object call(Object args) {
                    return this.doCall(args);
                }

                public Object call() {
                    return this.doCall((Object)null);
                }
            }

            DefaultGroovyMethods.each(new IntRange(true, 1, ((OutputThreadRetry)this).getOutputQueue().getRetryThreadCount()), new _initSenderThreads_closure1(this, this));
        } catch (Exception var6) {
            blackBoxRuntime.methodException(new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "initSenderThreads", 31, 39, 5, 6), (Map)null, var6);
            var10000 = null;
            throw (Throwable)var6;
        } finally {
            blackBoxRuntime.methodEnd(new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "initSenderThreads", 31, 39, 5, 6));
            var10000 = null;
        }

    }

    @BlackBox(
        suppressExceptions = true,
        level = BlackBoxLevel.ERROR
    )
    public void dbScanRetry() {
        try {
            try {
                Date lastSendTime = DateTimeExtensions.toDate(Instant.now().minus(Duration.ofSeconds(DefaultTypeTransformation.longUnbox(((OutputThreadRetry)this).getOutputQueue().getResendIntervalSeconds()))));
                Integer countToRetry = ((OutputThreadRetry)this).getOutputMessageRepository().markForRetry(((OutputThreadRetry)this).getOutputQueue().getName(), MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(), ((OutputThreadRetry)this).getOutputQueue().getMaxRetryCount(), lastSendTime, PigeonService.getStaticUUID());
                if (ScriptBytecodeAdapter.compareGreaterThan(countToRetry, 0)) {
                    LinkedHashSet outputMessages = ((OutputThreadRetry)this).getOutputMessageRepository().selectForRetry(((OutputThreadRetry)this).getOutputQueue().getName(), MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(), ((OutputThreadRetry)this).getOutputQueue().getMaxRetryCount(), lastSendTime, PigeonService.getStaticUUID());

                    final class _dbScanRetry_closure2 extends Closure implements GeneratedClosure {
                        public _dbScanRetry_closure2(Object _outerInstance, Object _thisObject) {
                            super(_outerInstance, _thisObject);
                        }

                        public Object doCall(Object outputMessage) {
                            ((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_dbScanRetry_closure2)this).getThisObject(), OutputThread.class))).senderEnqueue((OutputMessage)ScriptBytecodeAdapter.castToType(outputMessage, OutputMessage.class));
                            return null;
                        }

                        public Object call(Object args) {
                            return this.doCall(args);
                        }

                        public Object call() {
                            return this.doCall((Object)null);
                        }
                    }

                    DefaultGroovyMethods.each(outputMessages, new _dbScanRetry_closure2(this, this));
                }
            } catch (Exception var8) {
                ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, blackBoxRuntime, (String)"methodException", new Object[]{new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "dbScanRetry", 41, 63, 5, 6), null, var8});
            }

        } finally {
            ;
        }
    }

    @BlackBox(
        level = BlackBoxLevel.METHOD
    )
    public void run() {
        Object resultPlaceHolder = null;
        ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, blackBoxRuntime, (String)"methodBegin", new Object[]{new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "run", 65, 72, 5, 6), null});

        try {
            while(true) {
                this.dbScanRetry();
                Object var10000 = null;
                Thread.sleep(((OutputThreadRetry)this).getOutputQueue().getPollPeriodMillisecondsRetry());
                var10000 = null;
            }
        } catch (Exception var6) {
            ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, blackBoxRuntime, (String)"methodException", new Object[]{new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "run", 65, 72, 5, 6), null, var6});
            throw (Throwable)var6;
        } finally {
            ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, blackBoxRuntime, (String)"methodEnd", new Object[]{new MethodMetaData("io.infinite.pigeon.threads.OutputThreadRetry", "run", 65, 72, 5, 6)});
        }
    }

    @Generated
    public String toString() {
        StringBuilder _result = new StringBuilder();
        Boolean $toStringFirst = Boolean.TRUE;
        _result.append("io.infinite.pigeon.threads.OutputThreadRetry(");
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var3 = Boolean.FALSE;
            $toStringFirst = var3;
        } else {
            _result.append(", ");
        }

        _result.append("state:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getState()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var4 = Boolean.FALSE;
            $toStringFirst = var4;
        } else {
            _result.append(", ");
        }

        _result.append("stackTrace:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getStackTrace()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var5 = Boolean.FALSE;
            $toStringFirst = var5;
        } else {
            _result.append(", ");
        }

        _result.append("interrupted:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).isInterrupted()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var6 = Boolean.FALSE;
            $toStringFirst = var6;
        } else {
            _result.append(", ");
        }

        _result.append("daemon:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).isDaemon()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var7 = Boolean.FALSE;
            $toStringFirst = var7;
        } else {
            _result.append(", ");
        }

        _result.append("uncaughtExceptionHandler:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getUncaughtExceptionHandler()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var8 = Boolean.FALSE;
            $toStringFirst = var8;
        } else {
            _result.append(", ");
        }

        _result.append("priority:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getPriority()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var9 = Boolean.FALSE;
            $toStringFirst = var9;
        } else {
            _result.append(", ");
        }

        _result.append("threadGroup:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getThreadGroup()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var10 = Boolean.FALSE;
            $toStringFirst = var10;
        } else {
            _result.append(", ");
        }

        _result.append("contextClassLoader:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getContextClassLoader()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var11 = Boolean.FALSE;
            $toStringFirst = var11;
        } else {
            _result.append(", ");
        }

        _result.append("alive:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).isAlive()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var12 = Boolean.FALSE;
            $toStringFirst = var12;
        } else {
            _result.append(", ");
        }

        _result.append("name:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getName()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var13 = Boolean.FALSE;
            $toStringFirst = var13;
        } else {
            _result.append(", ");
        }

        _result.append("id:");
        _result.append(InvokerHelper.toString(((OutputThreadRetry)this).getId()));
        if ($toStringFirst == null ? false : $toStringFirst) {
            Boolean var14 = Boolean.FALSE;
        } else {
            _result.append(", ");
        }

        _result.append("super:");
        _result.append(InvokerHelper.toString(super.toString()));
        _result.append(")");
        return _result.toString();
    }

    static {
        Logger var0 = LoggerFactory.getLogger("io.infinite.pigeon.threads.OutputThreadRetry");
        automaticLog = var0;
        Object var1 = ScriptBytecodeAdapter.invokeMethodN(OutputThreadRetry.class, new BlackBoxRuntime(), (String)"getInstance", new Object[]{automaticLog});
        blackBoxRuntime = (BlackBoxRuntime)ScriptBytecodeAdapter.castToType(var1, BlackBoxRuntime.class);
        Logger var2 = LoggerFactory.getLogger("io.infinite.pigeon.threads.OutputThreadRetry");
        log = var2;
    }
}

package io.infinite.pigeon.threads


import io.infinite.pigeon.conf.OutputQueue
import io.infinite.pigeon.other.MessageStatusSets
import io.infinite.pigeon.springdatarest.entities.OutputMessage
import io.infinite.pigeon.springdatarest.services.PigeonService
import org.springframework.context.annotation.Scope
import org.springframework.stereotype.Component

import javax.annotation.PostConstruct
import java.time.Duration
import java.time.Instant

@Component
@Scope("prototype")
class OutputThreadRetry extends OutputThread {

    OutputThreadRetry(OutputQueue outputQueue) {
        super(outputQueue)
        senderThreadRobin.clear()
        name = name + "_RETRY"
    }

    @Override
    @PostConstruct
    void initSenderThreads() {
        (1..outputQueue.retryThreadCount).each { threadCounter ->
            SenderThread senderThread = applicationContext.getBean(SenderThread.class, outputQueue, "_RETRY_" + threadCounter)
            senderThreadRobin.add(senderThread)
            senderThread.start()
        }
    }

    void dbScanRetry() {
        Date lastSendTime = (Instant.now() - Duration.ofSeconds(outputQueue.resendIntervalSeconds)).toDate()
        Integer countToRetry = outputMessageRepository.markForRetry(
                outputQueue.name,
                MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(),
                outputQueue.maxRetryCount,
                lastSendTime,
                PigeonService.staticUUID
        )
        if (countToRetry > 0) {
            LinkedHashSet<OutputMessage> outputMessages = outputMessageRepository.selectForRetry(
                    outputQueue.name,
                    MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(),
                    outputQueue.maxRetryCount,
                    lastSendTime,
                    PigeonService.staticUUID
            )
            outputMessages.each { outputMessage ->
                senderEnqueue(outputMessage)
            }
        }
    }

    @Override
    void run() {
        while (true) {
            dbScanRetry()
            sleep(outputQueue.pollPeriodMillisecondsRetry)
        }
    }

}

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package io.infinite.pigeon.threads;

import groovy.lang.Closure;
import groovy.lang.IntRange;
import io.infinite.pigeon.conf.OutputQueue;
import io.infinite.pigeon.other.MessageStatusSets;
import io.infinite.pigeon.other.RoundRobin;
import io.infinite.pigeon.springdatarest.entities.OutputMessage;
import io.infinite.pigeon.springdatarest.services.PigeonService;
import java.time.Duration;
import java.time.Instant;
import java.util.Date;
import java.util.LinkedHashSet;
import javax.annotation.PostConstruct;
import org.apache.groovy.datetime.extensions.DateTimeExtensions;
import org.codehaus.groovy.runtime.DefaultGroovyMethods;
import org.codehaus.groovy.runtime.GeneratedClosure;
import org.codehaus.groovy.runtime.ScriptBytecodeAdapter;
import org.codehaus.groovy.runtime.StringGroovyMethods;
import org.codehaus.groovy.runtime.typehandling.DefaultTypeTransformation;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;

@Component
@Scope("prototype")
public class OutputThreadRetry extends OutputThread {
    public OutputThreadRetry(OutputQueue outputQueue) {
        super(outputQueue);
        ((RoundRobin)((OutputThreadRetry)this).getSenderThreadRobin()).clear();
        Object var10000 = null;
        String var2 = StringGroovyMethods.plus(((OutputThreadRetry)this).getName(), "_RETRY");
        ScriptBytecodeAdapter.setGroovyObjectProperty(var2, OutputThreadRetry.class, this, (String)"name");
    }

    @PostConstruct
    public void initSenderThreads() {
        final class _initSenderThreads_closure1 extends Closure implements GeneratedClosure {
            public _initSenderThreads_closure1(Object _outerInstance, Object _thisObject) {
                super(_outerInstance, _thisObject);
            }

            public Object doCall(Object threadCounter) {
                SenderThread senderThread = (SenderThread)ScriptBytecodeAdapter.castToType(((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_initSenderThreads_closure1)this).getThisObject(), OutputThread.class))).getApplicationContext().getBean(SenderThread.class, new Object[]{((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_initSenderThreads_closure1)this).getThisObject(), OutputThread.class))).getOutputQueue(), StringGroovyMethods.plus("_RETRY_", threadCounter)}), SenderThread.class);
                ((RoundRobin)((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_initSenderThreads_closure1)this).getThisObject(), OutputThread.class))).getSenderThreadRobin()).add(senderThread);
                ((SenderThread)senderThread).start();
                return null;
            }

            public Object call(Object args) {
                return this.doCall(args);
            }

            public Object call() {
                return this.doCall((Object)null);
            }
        }

        DefaultGroovyMethods.each(new IntRange(true, 1, ((OutputThreadRetry)this).getOutputQueue().getRetryThreadCount()), new _initSenderThreads_closure1(this, this));
    }

    public void dbScanRetry() {
        Date lastSendTime = DateTimeExtensions.toDate(Instant.now().minus(Duration.ofSeconds(DefaultTypeTransformation.longUnbox(((OutputThreadRetry)this).getOutputQueue().getResendIntervalSeconds()))));
        Integer countToRetry = ((OutputThreadRetry)this).getOutputMessageRepository().markForRetry(((OutputThreadRetry)this).getOutputQueue().getName(), MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(), ((OutputThreadRetry)this).getOutputQueue().getMaxRetryCount(), lastSendTime, PigeonService.getStaticUUID());
        if (ScriptBytecodeAdapter.compareGreaterThan(countToRetry, 0)) {
            LinkedHashSet outputMessages = ((OutputThreadRetry)this).getOutputMessageRepository().selectForRetry(((OutputThreadRetry)this).getOutputQueue().getName(), MessageStatusSets.OUTPUT_RETRY_MESSAGE_STATUSES.value(), ((OutputThreadRetry)this).getOutputQueue().getMaxRetryCount(), lastSendTime, PigeonService.getStaticUUID());

            final class _dbScanRetry_closure2 extends Closure implements GeneratedClosure {
                public _dbScanRetry_closure2(Object _outerInstance, Object _thisObject) {
                    super(_outerInstance, _thisObject);
                }

                public Object doCall(Object outputMessage) {
                    ((OutputThreadRetry)((OutputThread)ScriptBytecodeAdapter.castToType(((_dbScanRetry_closure2)this).getThisObject(), OutputThread.class))).senderEnqueue((OutputMessage)ScriptBytecodeAdapter.castToType(outputMessage, OutputMessage.class));
                    return null;
                }

                public Object call(Object args) {
                    return this.doCall(args);
                }

                public Object call() {
                    return this.doCall((Object)null);
                }
            }

            DefaultGroovyMethods.each(outputMessages, new _dbScanRetry_closure2(this, this));
        }

    }

    public void run() {
        while(true) {
            this.dbScanRetry();
            Thread.sleep(((OutputThreadRetry)this).getOutputQueue().getPollPeriodMillisecondsRetry());
        }
    }
}