diff options
author | Gregor Kleen <pngwjpgh@users.noreply.github.com> | 2016-12-12 15:21:04 +0100 |
---|---|---|
committer | Gregor Kleen <pngwjpgh@users.noreply.github.com> | 2016-12-12 15:21:04 +0100 |
commit | 692a3961f1788abe8fd284d744e7389888dc2353 (patch) | |
tree | e40ab31dd17f98d3e90aad9a96c891f644ef2998 /ymir/mlmmj-expose.nix | |
parent | e90f3e6aa3853a17c0d33aef5306739cb36269b6 (diff) | |
download | nixos-692a3961f1788abe8fd284d744e7389888dc2353.tar nixos-692a3961f1788abe8fd284d744e7389888dc2353.tar.gz nixos-692a3961f1788abe8fd284d744e7389888dc2353.tar.bz2 nixos-692a3961f1788abe8fd284d744e7389888dc2353.tar.xz nixos-692a3961f1788abe8fd284d744e7389888dc2353.zip |
mlmmj-serve-exposed
Diffstat (limited to 'ymir/mlmmj-expose.nix')
-rw-r--r-- | ymir/mlmmj-expose.nix | 114 |
1 files changed, 14 insertions, 100 deletions
diff --git a/ymir/mlmmj-expose.nix b/ymir/mlmmj-expose.nix index 2bdcf619..370219d3 100644 --- a/ymir/mlmmj-expose.nix +++ b/ymir/mlmmj-expose.nix | |||
@@ -1,110 +1,24 @@ | |||
1 | { config, pkgs, ... }: | 1 | { config, pkgs, ... }: |
2 | 2 | ||
3 | let | 3 | let |
4 | haskellEnv = pkgs.haskellPackages.ghcWithPackages (pkgs: with pkgs; [ filepath directory cryptonite bytestring uuid ]); | 4 | haskellEnv = pkgs.haskellPackages.ghcWithPackages dependencies; |
5 | dependencies = pkgs: with pkgs; [ filepath | ||
6 | directory | ||
7 | cryptonite | ||
8 | bytestring | ||
9 | uuid | ||
10 | aeson | ||
11 | aeson-pretty | ||
12 | ]; | ||
5 | mlmmj-exposed = pkgs.stdenv.mkDerivation { | 13 | mlmmj-exposed = pkgs.stdenv.mkDerivation { |
6 | name = "mlmmj-exposed"; | 14 | name = "mlmmj-expose"; |
7 | src = pkgs.writeText "mlmmj-exposed.hs" '' | 15 | src = ./mlmmj-expose.hs; |
8 | {-# LANGUAGE ViewPatterns #-} | ||
9 | |||
10 | import System.IO | ||
11 | import System.IO.Error | ||
12 | import System.FilePath | ||
13 | import System.Environment | ||
14 | import System.Exit | ||
15 | import System.Directory | ||
16 | import System.Process | ||
17 | import Text.Printf | ||
18 | |||
19 | import Data.Char | ||
20 | |||
21 | import Control.Monad | ||
22 | |||
23 | import Crypto.Hash | ||
24 | |||
25 | import qualified Data.ByteString.Lazy as LBS | ||
26 | import qualified Data.ByteString.Char8 as CBS | ||
27 | |||
28 | import qualified Data.UUID as UUID (toString) | ||
29 | import qualified Data.UUID.V4 as UUID (nextRandom) | ||
30 | |||
31 | main :: IO () | ||
32 | main = do | ||
33 | progName <- takeFileName <$> getProgName | ||
34 | case progName of | ||
35 | "mlmmj-exposed" -> do | ||
36 | args <- getArgs | ||
37 | case args of | ||
38 | [listDir, (map toLower -> extension)] -> do | ||
39 | setCurrentDirectory listDir | ||
40 | identities <- getIdentities | ||
41 | subscribers <- getSubscribers | ||
42 | let hashes = filter ((==) extension . snd) [((ident, sub), hash' (ident, sub)) | ident <- identities, sub <- subscribers] | ||
43 | case hashes of | ||
44 | [((_, recipient), _)] -> do | ||
45 | uuid <- UUID.nextRandom | ||
46 | let fName = "queue" </> "exposed" <.> uuidTrans uuid | ||
47 | uuidTrans = uuidTrans' . UUID.toString | ||
48 | where | ||
49 | uuidTrans' [] = [] | ||
50 | uuidTrans' ('-':xs) = uuidTrans' xs | ||
51 | uuidTrans' (x:xs) = x : uuidTrans' xs | ||
52 | getContents >>= writeFile fName | ||
53 | hPrintf stdout "Forwarding mail to <%s>, subscribed to %s\n" recipient (takeBaseName listDir) | ||
54 | callProcess "${pkgs.mlmmj}/bin/mlmmj-send" ["-L", listDir, "-l", "6", "-m", fName, "-T", recipient] | ||
55 | removeFile fName | ||
56 | [] -> die "Unknown extension" | ||
57 | _ -> die "Ambiguous extension" | ||
58 | _ -> hPutStrLn stderr ("Called without expected arguments (<listDirectory> <recipientExtension>)") >> exitWith (ExitFailure 2) | ||
59 | "mlmmj-expose" -> do | ||
60 | args <- getArgs | ||
61 | case args of | ||
62 | [listDir, (map toLower -> ident)] -> do | ||
63 | setCurrentDirectory listDir | ||
64 | identities <- getIdentities | ||
65 | case ident `elem` identities of | ||
66 | True -> putStrLn "Identity is already known" | ||
67 | False -> writeFile "exposed.ids" . unlines $ ident : identities | ||
68 | _ -> hPutStrLn stderr ("Called without expected arguments (<listDirectory> <senderIdentity>)") >> exitWith (ExitFailure 2) | ||
69 | "mlmmj-get-exposed" -> do | ||
70 | args <- getArgs | ||
71 | case args of | ||
72 | [(dropTrailingPathSeparator -> listDir), (map toLower -> ident)] -> do | ||
73 | setCurrentDirectory listDir | ||
74 | identities <- getIdentities | ||
75 | unless (ident `elem` identities) . die $ "Unknown sender: ‘" ++ ident ++ "’" | ||
76 | mapM_ (\sub -> putStrLn $ sub ++ " " ++ takeFileName listDir ++ "+" ++ hash' (ident, sub) ++ "@subs.lists.yggdrasil.li") =<< getSubscribers | ||
77 | (dropTrailingPathSeparator -> listDir) : (map toLower -> ident) : (map (map toLower) -> recipients) -> do | ||
78 | setCurrentDirectory listDir | ||
79 | identities <- getIdentities | ||
80 | unless (ident `elem` identities) . die $ "Unknown sender: ‘" ++ ident ++ "’" | ||
81 | subscribers <- getSubscribers | ||
82 | forM_ recipients (\recipient -> do { | ||
83 | unless (recipient `elem` subscribers) . die $ "Unknown recipient: ‘" ++ recipient ++ "’"; | ||
84 | putStrLn $ takeFileName listDir ++ "+" ++ hash' (ident, recipient) ++ "@subs.lists.yggdrasil.li"; | ||
85 | }) | ||
86 | _ -> hPutStrLn stderr ("Called without expected arguments (<listDirectory> <senderIdentity> [<recipient> [...]])") >> exitWith (ExitFailure 2) | ||
87 | _ -> hPutStrLn stderr ("Called under unsupported name ‘" ++ progName ++ "’") >> exitWith (ExitFailure 2) | ||
88 | getIdentities :: IO [String] | ||
89 | getIdentities = (filter (not . null) . lines <$> readFile "exposed.ids") `catchIOError` (\e -> if isDoesNotExistError e then return [] else ioError e) | ||
90 | |||
91 | getSubscribers :: IO [String] | ||
92 | getSubscribers = map (map toLower) . concat <$> mapM (flip catchIOError (\e -> if isDoesNotExistError e then return [] else ioError e) . readDir) ["subscribers.d", "digesters.d"] | ||
93 | where | ||
94 | readDir dir = concat <$> (mapM (fmap lines . readFile) . map (dir </>) . filter (not . (`elem` [".", ".."]))=<< (getDirectoryContents dir)) | ||
95 | |||
96 | hash' :: Show a => a -> String | ||
97 | hash' = take len . map toLower . show . (hash :: CBS.ByteString -> Digest SHA256) . CBS.pack . map toLower . show | ||
98 | |||
99 | len :: Int | ||
100 | len = 32 | ||
101 | ''; | ||
102 | buildCommand = '' | 16 | buildCommand = '' |
103 | mkdir -p $out/bin | 17 | mkdir -p $out/bin |
104 | #cp $src $out/bin/.mlmmj-exposed | 18 | #cp $src $out/bin/.mlmmj-exposed |
105 | ${haskellEnv}/bin/ghc -o $out/bin/.mlmmj-exposed -odir . -hidir . $src | 19 | ${haskellEnv}/bin/ghc -o $out/bin/.mlmmj-expose -odir . -hidir . $src |
106 | for f in mlmmj-exposed mlmmj-expose mlmmj-get-exposed; do | 20 | for f in mlmmj-exposed mlmmj-expose mlmmj-get-exposed mlmmj-serve-exposed; do |
107 | ln -s .mlmmj-exposed $out/bin/$f | 21 | ln -s .mlmmj-expose $out/bin/$f |
108 | done | 22 | done |
109 | ''; | 23 | ''; |
110 | }; | 24 | }; |