aboutsummaryrefslogtreecommitdiff
path: root/src/storage/image-manager/root.zig
diff options
context:
space:
mode:
Diffstat (limited to 'src/storage/image-manager/root.zig')
-rw-r--r--src/storage/image-manager/root.zig138
1 files changed, 0 insertions, 138 deletions
diff --git a/src/storage/image-manager/root.zig b/src/storage/image-manager/root.zig
deleted file mode 100644
index efc216f..0000000
--- a/src/storage/image-manager/root.zig
+++ /dev/null
@@ -1,138 +0,0 @@
-const std = @import("std");
-
-const memora = @import("memora");
-const Storage = memora.Storage;
-pub const Image = @import("image.zig");
-
-const Self = @This();
-
-pub const empty: Self = .{};
-
-const Timestamp = struct {
- index: usize,
- node: std.DoublyLinkedList.Node,
-
- pub fn next(self: *Timestamp) ?*Timestamp {
- return @fieldParentPtr("node", self.node.next orelse return null);
- }
-
- pub fn prev(self: *Timestamp) ?*Timestamp {
- return @fieldParentPtr("node", self.node.prev orelse return null);
- }
-};
-
-items: std.ArrayList(Image) = .empty,
-rw_lock: std.Thread.RwLock = .{},
-timestamp_order: std.DoublyLinkedList = .{},
-
-pub fn init(
- self: *Self,
- storage: *Storage,
-) !void {
- var dir = storage.dir.openDir("image", .{ .iterate = true }) catch blk: {
- try storage.dir.makeDir("image");
- break :blk try storage.dir.openDir("image", .{ .iterate = true });
- };
- defer dir.close();
-
- var iterator = dir.iterate();
-
- errdefer self.items.deinit(storage.allocator);
-
- while (try iterator.next()) |entry| {
- if (entry.kind == .file and std.mem.endsWith(u8, entry.name, ".jpg")) {
- try self.add(
- storage.allocator,
- try .init(storage, entry.name[0..entry.name.len - 4])
- );
- }
- }
-}
-
-pub fn add(self: *Self, allocator: std.mem.Allocator, image: Image) !void {
- self.rw_lock.lock();
- defer self.rw_lock.unlock();
-
- try self.items.append(
- allocator,
- image,
- );
-
- var current = self.timestamp_order.first;
-
- while (current) |c| {
- const index = @as(*Timestamp, @fieldParentPtr("node", c)).index;
- if (image.timestamp orelse 0 > self.items.items[index].timestamp orelse 0) {
- const timestamp = try allocator.create(Timestamp);
- timestamp.index = self.items.items.len - 1;
- self.timestamp_order.insertBefore(c, &timestamp.node);
- return;
- }
-
- current = c.next;
- }
-
- const timestamp = try allocator.create(Timestamp);
- timestamp.index = self.items.items.len - 1;
- self.timestamp_order.append(&timestamp.node);
- return;
-}
-
-pub fn save(
- self: *Self,
- storage: *Storage,
- reader: *std.Io.Reader,
- size: usize,
-) !void {
- return self.add(storage.allocator, try Image.new(storage, reader, size));
-}
-
-pub fn list(self: *Self) memora.locked.Shared([]Image) {
- self.rw_lock.lockShared();
- return .{
- .value = self.items.items,
- .rw_lock = &self.rw_lock,
- };
-}
-
-pub fn first_by_timestamp(self: *Self) memora.locked.Shared(?*Timestamp) {
- self.rw_lock.lockShared();
- return .{
- .value = if (self.timestamp_order.first) |first| @fieldParentPtr("node", first)
- else null,
- .rw_lock = &self.rw_lock,
- };
-}
-
-pub fn delete(self: *Self, storage: *Storage, id: []const u8) !void {
- self.rw_lock.lock();
- defer self.rw_lock.unlock();
-
- const index = index: {
- for (self.items.items, 0..) |image, index| {
- if (std.mem.eql(u8, image.id, id)) {
- break :index index;
- }
- }
- break :index null;
- };
-
- if (index) |idx| {
- try self.items.items[idx].delete(storage);
- const old_index = self.items.items.len - 1;
- _ = self.items.swapRemove(idx);
-
- var current: ?*Timestamp = if (self.timestamp_order.first) |c| @fieldParentPtr("node", c) else null;
-
- while (current) |c| {
- if (c.index == idx) {
- self.timestamp_order.remove(&c.node);
- storage.allocator.destroy(c);
- } else if (c.index == old_index) {
- c.index = idx;
- }
-
- current = c.next();
- }
- }
-}