package io.infinite.bobbin.destinations

import io.infinite.bobbin.BobbinFile
import io.infinite.bobbin.Level
import io.infinite.bobbin.config.DestinationConfig
import org.slf4j.helpers.Util

class FileDestination extends Destination {

ThreadLocal<BobbinFile> bobbinFileMap = new ThreadLocal<BobbinFile>()

///////////////////CONSTRUCTOR \/\/\/\/\/\/
FileDestination(DestinationConfig destinationConfig) {
super(destinationConfig)
}
///////////////////CONSTRUCTOR /\/\/\/\/\/\

@Override
protected void store(String finalOutputMessageText, Level level, String className, String date) {
String newFileName = bobbinScriptEngine.evalFileName(level.value(), className, date)
refreshCurrentFile(newFileName)
bobbinFileMap.get().writer.write(finalOutputMessageText)
bobbinFileMap.get().writer.flush()
}

void refreshCurrentFile(String newFileName) {
if (bobbinFileMap.get() == null) {
bobbinFileMap.set(initFile(newFileName))
} else {
if (bobbinFileMap.get().fileName != newFileName) {
bobbinFileMap.get().writer.close()
bobbinFileMap.set(initFile(newFileName))
}
}
}

BobbinFile initFile(String fileName) {
BobbinFile file = new BobbinFile(fileName)
file.fileName = fileName
file.getParentFile().mkdirs()
file.writer = new FileWriter(file, true)
return file
}

static {
Util.report("Bobbin: " + Thread.currentThread().getName().padRight(16) + ": " + "application working dir: " + new BobbinFile("./").getCanonicalPath())
}

}

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

package io.infinite.bobbin.destinations;

import groovy.transform.Generated;
import io.infinite.bobbin.BobbinFile;
import io.infinite.bobbin.Level;
import io.infinite.bobbin.config.DestinationConfig;
import java.io.FileWriter;
import org.codehaus.groovy.runtime.ScriptBytecodeAdapter;
import org.codehaus.groovy.runtime.StringGroovyMethods;
import org.slf4j.helpers.Util;

public class FileDestination extends Destination {
private ThreadLocal<BobbinFile> bobbinFileMap;

public FileDestination(DestinationConfig destinationConfig) {
super(destinationConfig);
ThreadLocal var2 = new ThreadLocal();
this.bobbinFileMap = var2;
}

protected void store(String finalOutputMessageText, Level level, String className, String date) {
String newFileName = ((FileDestination)this).getBobbinScriptEngine().evalFileName(level.value(), className, date);
this.refreshCurrentFile(newFileName);
Object var10000 = null;
((FileWriter)((BobbinFile)this.bobbinFileMap.get()).getWriter()).write(finalOutputMessageText);
var10000 = null;
((FileWriter)((BobbinFile)this.bobbinFileMap.get()).getWriter()).flush();
var10000 = null;
}

public void refreshCurrentFile(String newFileName) {
Object var10000;
if (this.bobbinFileMap.get() == null) {
this.bobbinFileMap.set(this.initFile(newFileName));
var10000 = null;
} else if (ScriptBytecodeAdapter.compareNotEqual(((BobbinFile)this.bobbinFileMap.get()).getFileName(), newFileName)) {
((FileWriter)((BobbinFile)this.bobbinFileMap.get()).getWriter()).close();
var10000 = null;
this.bobbinFileMap.set(this.initFile(newFileName));
var10000 = null;
}

}

public BobbinFile initFile(String fileName) {
BobbinFile file = new BobbinFile(fileName);
file.setFileName(fileName);
Object var10001 = null;
((BobbinFile)file).getParentFile().mkdirs();
FileWriter var4 = new FileWriter(file, true);
file.setWriter(var4);
var10001 = null;
return file;
}

static {
Util.report(StringGroovyMethods.plus(StringGroovyMethods.plus(StringGroovyMethods.plus(StringGroovyMethods.plus("Bobbin: ", StringGroovyMethods.padRight(Thread.currentThread().getName(), 16)), ": "), "application working dir: "), ((BobbinFile)(new BobbinFile("./"))).getCanonicalPath()));
Object var10000 = null;
}

@Generated
public ThreadLocal<BobbinFile> getBobbinFileMap() {
return this.bobbinFileMap;
}

@Generated
public void setBobbinFileMap(ThreadLocal<BobbinFile> var1) {
this.bobbinFileMap = var1;
}
}