#define _LUNA_SYSTEM_ERROR_EXTENSIONS
#include <luna/Alignment.h>
#include <luna/Alloc.h>
#include <luna/CString.h>
#include <luna/NumberParsing.h>
#include <luna/TarStream.h>

TarStream::TarStream(void* base, usize size) : m_base(base), m_pos(base), m_size(size)
{
}

void TarStream::initialize(void* base, usize size)
{
    m_base = m_pos = base;
    m_size = size;
    m_offset = 0;
}

void TarStream::rewind()
{
    m_pos = m_base;
    m_offset = 0;
}

void TarStream::read_header(TarHeader* out, bool& success)
{
    if ((m_offset + 512) > m_size)
    {
        success = false;
        return;
    };
    memcpy(out, m_pos, sizeof(TarHeader));
    m_pos = offset_ptr(m_pos, 512);
    m_offset += 512;
    success = true;
}

Result<TarStream::Entry> TarStream::parse_header(const TarStream::TarHeader* hdr)
{
    Entry entry;

    char size[13];
    nullcpy(size, hdr->size, 12);
    entry.size = parse_unsigned_integer(size, nullptr, 8);

    entry.mode = (mode_t)parse_unsigned_integer(hdr->mode, nullptr, 8);

    entry.m_pos = m_offset;
    entry.m_data = (u8*)m_base + m_offset;

    switch (hdr->typeflag)
    {
    case '\0':
    case '0': entry.type = EntryType::RegularFile; break;
    case '5': entry.type = EntryType::Directory; break;
    default: return err(EFIXME);
    }

    if (!strlen(hdr->prefix)) { nullcpy(entry.name, hdr->name, 100); }
    else { return err(EFIXME); }

    if (entry.size)
    {
        m_pos = offset_ptr(m_pos, align_up<512ul>(entry.size));
        m_offset += align_up<512ul>(entry.size);
    }

    return entry;
}

void TarStream::find_valid_header(TarStream::TarHeader* out, bool& success)
{
    success = false;
    while (true)
    {
        read_header(out, success);
        if (!success) return;
        if (!memcmp(out->magic, "ustar", 5))
        {
            success = true;
            return;
        }
    }
}

Result<bool> TarStream::read_next_entry(Entry& out)
{
    bool success;
    TarHeader header;
    find_valid_header(&header, success);
    if (!success) return false;

    out = TRY(parse_header(&header));

    return true;
}

usize TarStream::read_contents(const Entry& entry, void* buf, usize offset, usize length) const
{
    if (offset >= entry.size) return 0;
    if ((length + offset) > entry.size) length = entry.size - offset;

    memcpy(buf, offset_ptr(m_base, entry.m_pos + offset), length);

    return length;
}

Result<OwnedStringView> TarStream::read_contents_as_string(const Entry& entry, usize offset, usize max) const
{
    char* const buf = TRY(make_array<char>(max + 1));

    usize nread = read_contents(entry, buf, offset, max);

    buf[nread] = 0;

    return OwnedStringView { buf };
}