diff options
| author | dakkar <dakkar@thenautilus.net> | 2018-11-09 14:41:29 +0000 |
|---|---|---|
| committer | dakkar <dakkar@thenautilus.net> | 2018-11-09 14:41:29 +0000 |
| commit | db72db7fd0c10131dfc3c4a49e3e2c77aae96b25 (patch) | |
| tree | 6a9e16db8a00a8133aed7928e8e1f296fff6b2bd /bayes | |
| parent | let's use Perl 6! (diff) | |
| download | MaildirIndexer-db72db7fd0c10131dfc3c4a49e3e2c77aae96b25.tar.gz MaildirIndexer-db72db7fd0c10131dfc3c4a49e3e2c77aae96b25.tar.bz2 MaildirIndexer-db72db7fd0c10131dfc3c4a49e3e2c77aae96b25.zip | |
move stuff into modules
Diffstat (limited to 'bayes')
| -rw-r--r-- | bayes | 65 |
1 files changed, 16 insertions, 49 deletions
@@ -1,55 +1,22 @@ #!/usr/bin/env perl6 use v6.d.PREVIEW; +use lib 'lib'; +use MaildirIndexer::ScanDir; +use MaildirIndexer::Parser; -grammar Message { - regex TOP { - <headers> - <separator> - <body> +sub MAIN($maildir) { + my $file-supply = scan-dir($maildir); + my $file-channel = $file-supply.Channel; + for ^10 { + start react { + whenever $file-channel -> $file { + if $file.e && $file.f { + my $email = parse-email($file,:headers-only); + say "{$file} - {$email<headers><Subject>}"; + } + } + } } - token newline { [\x0d\x0a] | [\x0a\x0d] | \x0a | \x0d } - token separator { - [\x0a\x0d\x0a\x0d] | [\x0d\x0a\x0d\x0a] | \x0a ** 2 | \x0d ** 2 - } - token body { .* } - regex headers { - <header>+ % <newline> - } - regex header { - <name> \: \h* <value> - || <junk> - } - token name { - <-[:\s]>+ - } - regex value { - <line>+ % [<newline> \h+] - } - token line { \N* } - token junk { \N+ } -} - -class Message-actions { - method TOP($/) { - make %( headers => $/<headers>.made, body => $/<body>.Str ); - } - method headers($/) { - make %( |$/<header>ยป.made ); - } - method header($/) { - make $/<junk> ?? () !! ( $/<name>.Str => $/<value>.made ); - } - method value($/) { - make $/<line>.join(' ') - } -} - -sub MAIN(*@files) { - say "Starting";my $start = now; - my @messages = @files.race(:degree(10) :batch(100)).map({ - my $email = $_.IO.slurp(:enc<utf8-c8>); - my $match = Message.parse($email,:actions(Message-actions.new)); - }); - say "Took { now - $start } for { +@messages } messages"; + react whenever signal(SIGINT) { exit } } |