const std = @import("std");
const Storage = @import("../root.zig");

const id_size = 32;

const log = std.log.scoped(.image);

fn new_id() [id_size]u8 {
    var buffer: [id_size]u8 = undefined;
    var raw_buffer: [id_size / 2]u8 = undefined;
    std.crypto.random.bytes(&raw_buffer);

    var writer = std.Io.Writer.fixed(buffer[0..]);
    writer.print("{x}", .{raw_buffer}) catch unreachable;

    return buffer[0..].*;
}

const Self = @This();

id: []const u8,

pub fn new(
    storage: *Storage,
    reader: *std.Io.Reader,
    size: usize,
) !Self {
    var dir = try storage.dir.openDir("image", .{});
    defer dir.close();

    var file_name: [id_size+4]u8 = undefined;
    const self: Self = .{ .id = &new_id() };
    @memcpy(file_name[0..id_size], self.id);
    @memcpy(file_name[id_size..], ".jpg");

    var image_file = try dir.createFile(&file_name, .{});
    defer image_file.close();

    var buffer: [1024]u8 = undefined;
    var file_writer = image_file.writer(&buffer);

    try reader.streamExact(&file_writer.interface, size);

    try file_writer.interface.flush();

    log.info("uploaded {s} [{} bytes]", .{self.id, size});

    return self;
}

pub fn init(allocator: std.mem.Allocator, id: []const u8) !Self {
    return .{
        .id = try allocator.dupe(u8, id),
    };
}

pub fn file(self: *Self, storage: *Storage) !std.fs.File {
    var dir = storage.dir.openDir("image", .{}) catch blk: {
        try storage.dir.makeDir("image");
        break :blk try storage.dir.openDir("image", .{});
    };
    defer dir.close();

    var file_name: [id_size+4]u8 = undefined;
    @memcpy(file_name[0..id_size], self.id);
    @memcpy(file_name[id_size..], ".jpg");

    return dir.openFile(&file_name, .{});
}

pub fn deinit(self: *Self, allocator: std.mem.Allocator) void {
    allocator.free(self.id);
}