# noqa: D100
from src.connectors.ack_storage import AckStorage

from os import listdir
from os import path


class LocalStorage(AckStorage):  # noqa: D101
    def acks(self, unacked_deliveries):  # noqa: D102
        acks = []
        for unacked_delivery in unacked_deliveries:
            mypath = f"./tests/acks/{unacked_delivery['sfn_execution_id']}/"
            files: list[str] = []

            if not path.exists(mypath):
                acks.append({'ack_content': None, 'unacked_delivery': unacked_delivery})
                continue

            if path.exists(mypath):
                files = files + [f for f in listdir(mypath) if path.isfile(path.join(mypath, f))]

            for f in files:
                with open(mypath + f, 'r') as file:
                    acks.append({'ack_content': file.read(), 'unacked_delivery': unacked_delivery})
                    file.close()

        return acks