FlatFile.pm 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. package Trog::Data::FlatFile;
  2. use strict;
  3. use warnings;
  4. no warnings 'experimental';
  5. use feature qw{signatures};
  6. use Carp qw{confess};
  7. use JSON::MaybeXS;
  8. use File::Slurper;
  9. use File::Copy;
  10. use Mojo::File;
  11. use List::Util;
  12. use parent qw{Trog::DataModule};
  13. our $datastore = 'data/files/';
  14. sub lang { 'Perl Regex in Quotemeta' }
  15. sub help { 'https://perldoc.perl.org/functions/quotemeta.html' }
  16. our @index;
  17. sub read ($self, $query=undef) {
  18. @index //= $self->_index();
  19. my @items;
  20. foreach my $item (@index) {
  21. my $slurped = File::Slurper::read_text($item);
  22. my $parsed = JSON::MaybeXS::decode_json($slurped);
  23. push(@items,$parsed) unless $self->filter($parsed);
  24. last if scalar(@items) == $query->{limit};
  25. }
  26. return @items;
  27. }
  28. sub _index ($self) {
  29. return @index if @index;
  30. confess "Can't find datastore!" unless -d $datastore;
  31. opendir(my $dh, $datastore) or die;
  32. @index = grep { -f $_ } readdir $dh;
  33. closedir $dh;
  34. return @index;
  35. }
  36. sub write($self,$data) {
  37. open(my $fh, '>', $datastore) or confess;
  38. print $fh JSON::MaybeXS::encode_json($data);
  39. close $fh;
  40. }
  41. sub count ($self) {
  42. @index //= $self->_index();
  43. return scalar(@index);
  44. }
  45. sub delete($self, @posts) {
  46. my $example_posts = $self->read();
  47. foreach my $update (@posts) {
  48. @$example_posts = grep { $_->{id} ne $update->{id} } @$example_posts;
  49. }
  50. $self->write($example_posts);
  51. return 0;
  52. }
  53. 1;