package com.amazonaws.greengrass.cddsensehat.leds;

import com.amazonaws.greengrass.cddsensehat.data.Topics;
import com.awslabs.aws.iot.greengrass.cdd.communication.Dispatcher;

import javax.inject.Inject;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.OutputStreamWriter;
import java.nio.charset.Charset;

public class LinuxOutputStreamWriterFactory implements OutputStreamWriterFactory {
    private final long minimumMillisecondsBetweenErrors = 5000;
    @Inject
    Topics topics;
    @Inject
    Dispatcher dispatcher;
    private long lastErrorSentTimestamp = 0;

    @Inject
    public LinuxOutputStreamWriterFactory() {
    }

    @Override
    public OutputStreamWriter get(File file, Charset charset) throws FileNotFoundException {
        try {
            return new OutputStreamWriter(new FileOutputStream(file), charset);
        } catch (FileNotFoundException e) {
            long now = System.nanoTime() / 1000;

            if ((now - lastErrorSentTimestamp) > minimumMillisecondsBetweenErrors) {
                dispatcher.publishMessageEvent(topics.getDebugOutputTopic(), "File not found error reported for [" + file.getAbsolutePath() + "], has the local resource been associated with this function? Is the function running inside the Greengrass container?");
                lastErrorSentTimestamp = now;
            }

            throw e;
        }
    }
}