Compare commits
1 Commits
6cabe97b30
...
sandbox/Ma
Author | SHA1 | Date | |
---|---|---|---|
a8ce2187d8 |
4
.gitignore
vendored
4
.gitignore
vendored
@ -1,6 +1,2 @@
|
|||||||
dist/
|
dist/
|
||||||
config/config.dhall
|
config/config.dhall
|
||||||
/ctags
|
|
||||||
/TAGS
|
|
||||||
/result*
|
|
||||||
/backend/config
|
|
||||||
|
@ -1,5 +0,0 @@
|
|||||||
# Revision history for backend
|
|
||||||
|
|
||||||
## 0.1.0.0 -- YYYY-mm-dd
|
|
||||||
|
|
||||||
* First version. Released on an unsuspecting world.
|
|
@ -1,30 +0,0 @@
|
|||||||
Copyright (c) 2018, Mats Rauhala
|
|
||||||
|
|
||||||
All rights reserved.
|
|
||||||
|
|
||||||
Redistribution and use in source and binary forms, with or without
|
|
||||||
modification, are permitted provided that the following conditions are met:
|
|
||||||
|
|
||||||
* Redistributions of source code must retain the above copyright
|
|
||||||
notice, this list of conditions and the following disclaimer.
|
|
||||||
|
|
||||||
* Redistributions in binary form must reproduce the above
|
|
||||||
copyright notice, this list of conditions and the following
|
|
||||||
disclaimer in the documentation and/or other materials provided
|
|
||||||
with the distribution.
|
|
||||||
|
|
||||||
* Neither the name of Mats Rauhala nor the names of other
|
|
||||||
contributors may be used to endorse or promote products derived
|
|
||||||
from this software without specific prior written permission.
|
|
||||||
|
|
||||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
||||||
"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
||||||
LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
||||||
A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
||||||
OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
||||||
SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
||||||
LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
||||||
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
||||||
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
||||||
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
||||||
OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
@ -1,2 +0,0 @@
|
|||||||
import Distribution.Simple
|
|
||||||
main = defaultMain
|
|
@ -1,30 +0,0 @@
|
|||||||
Copyright (c) 2018, Mats Rauhala
|
|
||||||
|
|
||||||
All rights reserved.
|
|
||||||
|
|
||||||
Redistribution and use in source and binary forms, with or without
|
|
||||||
modification, are permitted provided that the following conditions are met:
|
|
||||||
|
|
||||||
* Redistributions of source code must retain the above copyright
|
|
||||||
notice, this list of conditions and the following disclaimer.
|
|
||||||
|
|
||||||
* Redistributions in binary form must reproduce the above
|
|
||||||
copyright notice, this list of conditions and the following
|
|
||||||
disclaimer in the documentation and/or other materials provided
|
|
||||||
with the distribution.
|
|
||||||
|
|
||||||
* Neither the name of Mats Rauhala nor the names of other
|
|
||||||
contributors may be used to endorse or promote products derived
|
|
||||||
from this software without specific prior written permission.
|
|
||||||
|
|
||||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
||||||
"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
||||||
LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
||||||
A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
||||||
OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
||||||
SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
||||||
LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
||||||
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
||||||
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
||||||
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
||||||
OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
@ -1,33 +0,0 @@
|
|||||||
name: common
|
|
||||||
version: 0.1.0.0
|
|
||||||
-- synopsis:
|
|
||||||
-- description:
|
|
||||||
license: BSD3
|
|
||||||
license-file: LICENSE
|
|
||||||
author: Mats Rauhala
|
|
||||||
maintainer: mats.rauhala@iki.fi
|
|
||||||
-- copyright:
|
|
||||||
category: Web
|
|
||||||
build-type: Simple
|
|
||||||
extra-source-files: ChangeLog.md
|
|
||||||
cabal-version: >=1.10
|
|
||||||
|
|
||||||
library
|
|
||||||
exposed-modules: Configuration
|
|
||||||
, Data.Versioned
|
|
||||||
-- other-extensions:
|
|
||||||
build-depends: base >=4.10
|
|
||||||
, classy-prelude
|
|
||||||
, dhall
|
|
||||||
, foreign-store
|
|
||||||
, generic-lens
|
|
||||||
, lens
|
|
||||||
, mtl
|
|
||||||
, text
|
|
||||||
, transformers
|
|
||||||
hs-source-dirs: src
|
|
||||||
default-extensions: DeriveGeneric
|
|
||||||
, NoImplicitPrelude
|
|
||||||
, OverloadedStrings
|
|
||||||
, RecordWildCards
|
|
||||||
default-language: Haskell2010
|
|
23
default.nix
23
default.nix
@ -1,15 +1,10 @@
|
|||||||
{ nixpkgs, haskellPackages }:
|
{ mkDerivation, base, stdenv }:
|
||||||
|
mkDerivation {
|
||||||
(import ./project.nix nixpkgs) {
|
pname = "ebook-manager";
|
||||||
packages = {
|
version = "0.1.0.0";
|
||||||
common = ./common;
|
src = ./.;
|
||||||
backend = ./backend;
|
isLibrary = false;
|
||||||
};
|
isExecutable = true;
|
||||||
overrides = self: super: {
|
executableHaskellDepends = [ base ];
|
||||||
generic-lens = nixpkgs.haskell.lib.dontCheck super.generic-lens;
|
license = stdenv.lib.licenses.bsd3;
|
||||||
};
|
|
||||||
tools = with haskellPackages; [
|
|
||||||
ghcid
|
|
||||||
hasktags
|
|
||||||
];
|
|
||||||
}
|
}
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
-- Initial backend.cabal generated by cabal init. For further
|
-- Initial ebook-manager.cabal generated by cabal init. For further
|
||||||
-- documentation, see http://haskell.org/cabal/users-guide/
|
-- documentation, see http://haskell.org/cabal/users-guide/
|
||||||
|
|
||||||
name: backend
|
name: ebook-manager
|
||||||
version: 0.1.0.0
|
version: 0.1.0.0
|
||||||
-- synopsis:
|
-- synopsis:
|
||||||
-- description:
|
-- description:
|
||||||
@ -15,7 +15,7 @@ build-type: Simple
|
|||||||
extra-source-files: ChangeLog.md
|
extra-source-files: ChangeLog.md
|
||||||
cabal-version: >=1.10
|
cabal-version: >=1.10
|
||||||
|
|
||||||
executable backend
|
executable ebook-manager
|
||||||
main-is: Main.hs
|
main-is: Main.hs
|
||||||
other-modules: Devel.Main
|
other-modules: Devel.Main
|
||||||
, API
|
, API
|
||||||
@ -23,6 +23,8 @@ executable backend
|
|||||||
, API.Catalogue
|
, API.Catalogue
|
||||||
, API.Channels
|
, API.Channels
|
||||||
, API.Users
|
, API.Users
|
||||||
|
, Configuration
|
||||||
|
, Data.Versioned
|
||||||
, Database
|
, Database
|
||||||
, Database.Book
|
, Database.Book
|
||||||
, Database.Channel
|
, Database.Channel
|
||||||
@ -36,10 +38,7 @@ executable backend
|
|||||||
, Types
|
, Types
|
||||||
, View
|
, View
|
||||||
-- other-extensions:
|
-- other-extensions:
|
||||||
build-depends: base >=4.10
|
build-depends: base >=4.10 && <4.11
|
||||||
, exceptions
|
|
||||||
, monad-control
|
|
||||||
, common
|
|
||||||
, aeson
|
, aeson
|
||||||
, asn1-data
|
, asn1-data
|
||||||
, asn1-types
|
, asn1-types
|
||||||
@ -81,8 +80,8 @@ executable backend
|
|||||||
, xml-conduit
|
, xml-conduit
|
||||||
, xml-hamlet
|
, xml-hamlet
|
||||||
hs-source-dirs: src
|
hs-source-dirs: src
|
||||||
default-language: Haskell2010
|
|
||||||
default-extensions: DeriveGeneric
|
default-extensions: DeriveGeneric
|
||||||
, NoImplicitPrelude
|
, NoImplicitPrelude
|
||||||
, OverloadedStrings
|
, OverloadedStrings
|
||||||
, RecordWildCards
|
, RecordWildCards
|
||||||
|
default-language: Haskell2010
|
@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"url": "https://github.com/nixos/nixpkgs.git",
|
"url": "https://github.com/nixos/nixpkgs.git",
|
||||||
"rev": "e0d250e5cf6d179e1ccc775472d89718f61fcfd1",
|
"rev": "83a5765b1fea2472ec9cf9d179d3efd18b45c77e",
|
||||||
"date": "2018-01-08T11:52:28+01:00",
|
"date": "2018-01-08T11:52:28+01:00",
|
||||||
"sha256": "1iqpjz4czcpghbv924a5h4jvfmj6c8q6sl3b1z7blz3mi740aivs",
|
"sha256": "01rb61dkbzjbwnb3p8lgs03a94f4584199dlr0cwdmqzaxnp506h",
|
||||||
"fetchSubmodules": true
|
"fetchSubmodules": true
|
||||||
}
|
}
|
||||||
|
39
project.nix
39
project.nix
@ -1,39 +0,0 @@
|
|||||||
nixpkgs:
|
|
||||||
|
|
||||||
let
|
|
||||||
|
|
||||||
inherit (nixpkgs.lib) mapAttrs mapAttrsToList escapeShellArg optionalString concatStringsSep concatMapStringsSep;
|
|
||||||
|
|
||||||
in
|
|
||||||
|
|
||||||
{ packages
|
|
||||||
, overrides ? _ : _ : {}
|
|
||||||
, tools ? []
|
|
||||||
}:
|
|
||||||
|
|
||||||
let
|
|
||||||
|
|
||||||
overrides' = nixpkgs.lib.foldr nixpkgs.lib.composeExtensions (_: _: {}) [
|
|
||||||
(self: super: mapAttrs (name: path: self.callCabal2nix name path {}) packages)
|
|
||||||
overrides
|
|
||||||
];
|
|
||||||
haskellPackages = nixpkgs.haskellPackages.override { overrides = overrides'; };
|
|
||||||
packages' = mapAttrs (name: _: haskellPackages."${name}") packages;
|
|
||||||
mkShell = name: pkg:
|
|
||||||
let
|
|
||||||
n = "${name}-shell";
|
|
||||||
deps = haskellPackages.ghcWithHoogle (pkgs: pkg.buildInputs ++ pkg.propagatedBuildInputs);
|
|
||||||
in
|
|
||||||
{
|
|
||||||
name = "${n}";
|
|
||||||
value = nixpkgs.buildEnv {
|
|
||||||
name = "${n}";
|
|
||||||
paths = tools;
|
|
||||||
buildInputs = tools ++ [deps];
|
|
||||||
};
|
|
||||||
};
|
|
||||||
shells = nixpkgs.lib.listToAttrs (mapAttrsToList mkShell packages');
|
|
||||||
|
|
||||||
in
|
|
||||||
|
|
||||||
packages' // shells
|
|
15
release.nix
15
release.nix
@ -1,15 +0,0 @@
|
|||||||
{ nixpkgs ? import <nixpkgs> {} }:
|
|
||||||
|
|
||||||
let
|
|
||||||
|
|
||||||
pinnedVersion = nixpkgs.lib.importJSON ./nixpkgs-version.json;
|
|
||||||
pinnedPkgs = import (nixpkgs.fetchFromGitHub {
|
|
||||||
owner = "NixOS";
|
|
||||||
repo = "nixpkgs";
|
|
||||||
inherit (pinnedVersion) rev sha256;
|
|
||||||
}) {};
|
|
||||||
inherit (pinnedPkgs) pkgs;
|
|
||||||
|
|
||||||
in
|
|
||||||
|
|
||||||
import ./default.nix { nixpkgs = pinnedPkgs; haskellPackages = pinnedPkgs.haskellPackages; }
|
|
@ -27,8 +27,8 @@ data Index = Index
|
|||||||
|
|
||||||
type API = Get '[HTML] (AppView Index)
|
type API = Get '[HTML] (AppView Index)
|
||||||
:<|> Users.API
|
:<|> Users.API
|
||||||
:<|> "api" :> "current" :> Channels.API
|
:<|> "api" :> Channels.API
|
||||||
:<|> "api" :> "current" :> Books.API
|
:<|> "api" :> Books.API
|
||||||
:<|> "api" :> "1" :> Catalogue.VersionedAPI 1
|
:<|> "api" :> "1" :> Catalogue.VersionedAPI 1
|
||||||
:<|> "api" :> "current" :> Catalogue.VersionedAPI 1
|
:<|> "api" :> "current" :> Catalogue.VersionedAPI 1
|
||||||
|
|
@ -15,36 +15,35 @@
|
|||||||
{-# Language NamedFieldPuns #-}
|
{-# Language NamedFieldPuns #-}
|
||||||
module API.Books where
|
module API.Books where
|
||||||
|
|
||||||
import ClassyPrelude
|
import Servant hiding (contentType)
|
||||||
import Control.Lens
|
import Types
|
||||||
import Control.Monad.Catch (throwM, MonadThrow)
|
import ClassyPrelude
|
||||||
import Data.Aeson
|
import Server.Auth
|
||||||
import Data.Generics.Product
|
import Servant.Auth as SA
|
||||||
import Database
|
import Data.Aeson
|
||||||
import Database.Book
|
import Database.Book
|
||||||
import Database.Channel
|
import Database.Channel
|
||||||
import Database.Tag
|
import Database.Tag
|
||||||
import Servant hiding (contentType)
|
import Database
|
||||||
import Servant.Auth as SA
|
import Control.Lens
|
||||||
import Server.Auth
|
import Data.Generics.Product
|
||||||
import Types
|
|
||||||
|
|
||||||
import Control.Monad.Trans.Maybe
|
import Control.Monad.Trans.Maybe
|
||||||
|
|
||||||
import qualified Datastore as DS
|
import qualified Datastore as DS
|
||||||
import Data.ByteArray (convert)
|
import Data.ByteArray (convert)
|
||||||
import Crypto.Hash (digestFromByteString)
|
import Crypto.Hash (digestFromByteString)
|
||||||
|
|
||||||
data JsonBook = JsonBook { identifier :: BookID
|
data JsonBook = JsonBook { identifier :: BookID
|
||||||
, contentType :: Text
|
, contentType :: Text
|
||||||
, title :: Text
|
, title :: Maybe Text
|
||||||
, description :: Maybe Text
|
, description :: Maybe Text
|
||||||
, channels :: [Text]
|
, channels :: [Text]
|
||||||
, tags :: [Text] }
|
, tags :: [Text] }
|
||||||
deriving (Generic, Show)
|
deriving (Generic, Show)
|
||||||
|
|
||||||
data PostBook = PostBook { contentType :: Text
|
data PostBook = PostBook { contentType :: Text
|
||||||
, title :: Text
|
, title :: Maybe Text
|
||||||
, description :: Maybe Text
|
, description :: Maybe Text
|
||||||
, channels :: [Text]
|
, channels :: [Text]
|
||||||
, tags :: [Text] }
|
, tags :: [Text] }
|
||||||
@ -62,9 +61,7 @@ type BaseAPI = "books" :> Get '[JSON] [JsonBook]
|
|||||||
:<|> "books" :> ReqBody '[JSON] PostBook :> Post '[JSON] JsonBook
|
:<|> "books" :> ReqBody '[JSON] PostBook :> Post '[JSON] JsonBook
|
||||||
:<|> "books" :> Capture "book_id" BookID :> "meta" :> ReqBody '[JSON] JsonBook :> Put '[JSON] JsonBook
|
:<|> "books" :> Capture "book_id" BookID :> "meta" :> ReqBody '[JSON] JsonBook :> Put '[JSON] JsonBook
|
||||||
:<|> "books" :> Capture "book_id" BookID :> ReqBody '[OctetStream] ByteString :> Put '[JSON] NoContent
|
:<|> "books" :> Capture "book_id" BookID :> ReqBody '[OctetStream] ByteString :> Put '[JSON] NoContent
|
||||||
:<|> GetBook
|
:<|> "books" :> Capture "book_id" BookID :> Get '[OctetStream] ByteString
|
||||||
|
|
||||||
type GetBook = "books" :> Capture "book_id" BookID :> Get '[OctetStream] ByteString
|
|
||||||
|
|
||||||
handler :: ServerT API AppM
|
handler :: ServerT API AppM
|
||||||
handler user = listBooksHandler user
|
handler user = listBooksHandler user
|
@ -16,17 +16,15 @@
|
|||||||
{-# Language ScopedTypeVariables #-}
|
{-# Language ScopedTypeVariables #-}
|
||||||
module API.Catalogue (VersionedAPI, handler) where
|
module API.Catalogue (VersionedAPI, handler) where
|
||||||
|
|
||||||
import qualified API.Books
|
import Types
|
||||||
import ClassyPrelude
|
import Servant
|
||||||
import Database
|
import ClassyPrelude
|
||||||
import Database.Book (Book(..))
|
import GHC.TypeLits
|
||||||
|
import Server.Auth
|
||||||
|
import Servant.Auth as SA
|
||||||
|
import Servant.XML
|
||||||
import qualified Database.Channel as Channel
|
import qualified Database.Channel as Channel
|
||||||
import GHC.TypeLits
|
import Database
|
||||||
import Servant hiding (contentType)
|
|
||||||
import Servant.Auth as SA
|
|
||||||
import Servant.XML
|
|
||||||
import Server.Auth
|
|
||||||
import Types
|
|
||||||
|
|
||||||
-- This is my first try on going to versioned apis, things might change
|
-- This is my first try on going to versioned apis, things might change
|
||||||
-- I think my rule of thumb is that you can add new things as you want, but
|
-- I think my rule of thumb is that you can add new things as you want, but
|
||||||
@ -98,57 +96,30 @@ instance ToNode (Catalog 1) where
|
|||||||
|
|
||||||
class Monad m => VersionedCatalog m (v :: Nat) where
|
class Monad m => VersionedCatalog m (v :: Nat) where
|
||||||
getChannels :: SafeUser -> m (Catalog v)
|
getChannels :: SafeUser -> m (Catalog v)
|
||||||
getBooks :: Channel.ChannelID -> SafeUser -> m (Catalog v)
|
|
||||||
|
|
||||||
instance VersionedCatalog AppM 1 where
|
instance VersionedCatalog AppM 1 where
|
||||||
getChannels = getChannelsV1
|
getChannels SafeUser{username} = do
|
||||||
getBooks = getBooksV1
|
updated <- liftIO getCurrentTime
|
||||||
|
let self = Rel ("/api/current/" <> selfUrl)
|
||||||
relUrl :: Link -> Rel
|
-- I'm not sure if this safe link approach is really useable with this
|
||||||
relUrl x = Rel ("/api/current/" <> (pack . uriPath . linkURI $ x))
|
-- api hierarchy since I can't access the topmost api from here. Also
|
||||||
|
-- authentication would bring a little bit of extra effort as well
|
||||||
getBooksV1 :: Channel.ChannelID -> SafeUser -> AppM (Catalog 1)
|
selfUrl = pack . uriPath . linkURI $ safeLink (Proxy @(BaseAPI 1)) (Proxy @(RootCatalog 1))
|
||||||
getBooksV1 channelID SafeUser{username} = do
|
start = self
|
||||||
updated <- liftIO getCurrentTime
|
pagination = Pagination Nothing Nothing
|
||||||
let self = relUrl selfUrl
|
entries <- map (fromChannel updated) <$> runDB (Channel.userChannels username)
|
||||||
start = relUrl startUrl
|
pure CatalogV1{..}
|
||||||
selfUrl = safeLink (Proxy @(BaseAPI 1)) (Proxy @(ChannelCatalog 1)) channelID
|
where
|
||||||
startUrl = safeLink (Proxy @(BaseAPI 1)) (Proxy @(RootCatalog 1))
|
fromChannel :: UTCTime -> Channel.Channel -> Entry 1
|
||||||
pagination = Pagination Nothing Nothing
|
fromChannel updated Channel.Channel{..} =
|
||||||
entries <- map (toEntry updated) <$> runDB (Channel.channelBooks username channelID)
|
let url = pack . uriPath . linkURI $ safeLink (Proxy @(BaseAPI 1)) (Proxy @(ChannelCatalog 1)) identifier
|
||||||
pure CatalogV1{..}
|
self = Rel ("/api/current/" <> url)
|
||||||
where
|
in EntryV1 channel channel updated channel (Left $ SubSection self)
|
||||||
toEntry updated Book{description,title,identifier=bookId} =
|
|
||||||
let content = fromMaybe "no content" description
|
|
||||||
identifier = pack . show $ bookId
|
|
||||||
link = Right (Acquisition (relUrl (safeLink (Proxy @API.Books.BaseAPI) (Proxy @API.Books.GetBook) bookId)))
|
|
||||||
in EntryV1{..}
|
|
||||||
|
|
||||||
getChannelsV1 :: SafeUser -> AppM (Catalog 1)
|
|
||||||
getChannelsV1 SafeUser{username} = do
|
|
||||||
updated <- liftIO getCurrentTime
|
|
||||||
let self = relUrl selfUrl
|
|
||||||
-- I'm not sure if this safe link approach is really useable with this
|
|
||||||
-- api hierarchy since I can't access the topmost api from here. Also
|
|
||||||
-- authentication would bring a little bit of extra effort as well
|
|
||||||
selfUrl = safeLink (Proxy @(BaseAPI 1)) (Proxy @(RootCatalog 1))
|
|
||||||
start = self
|
|
||||||
pagination = Pagination Nothing Nothing
|
|
||||||
entries <- map (fromChannel updated) <$> runDB (Channel.userChannels username)
|
|
||||||
pure CatalogV1{..}
|
|
||||||
where
|
|
||||||
fromChannel :: UTCTime -> Channel.Channel -> Entry 1
|
|
||||||
fromChannel updated Channel.Channel{..} =
|
|
||||||
let url = safeLink (Proxy @(BaseAPI 1)) (Proxy @(ChannelCatalog 1)) identifier
|
|
||||||
self = relUrl url
|
|
||||||
in EntryV1 channel channel updated channel (Left $ SubSection self)
|
|
||||||
|
|
||||||
type VersionedAPI (v :: Nat) = Auth '[SA.BasicAuth, SA.JWT] SafeUser :> BaseAPI v
|
type VersionedAPI (v :: Nat) = Auth '[SA.BasicAuth, SA.JWT] SafeUser :> BaseAPI v
|
||||||
|
|
||||||
type CatalogContent = '[XML, OPDS]
|
type RootCatalog (v :: Nat) = "catalog" :> Get '[XML] (Catalog v)
|
||||||
|
type ChannelCatalog (v :: Nat) = "catalog" :> "channel" :> Capture "channel_id" Channel.ChannelID :> Get '[XML] (Catalog v)
|
||||||
type RootCatalog (v :: Nat) = "catalog" :> Get CatalogContent (Catalog v)
|
|
||||||
type ChannelCatalog (v :: Nat) = "catalog" :> "channel" :> Capture "channel_id" Channel.ChannelID :> Get CatalogContent (Catalog v)
|
|
||||||
type BaseAPI (v :: Nat) = RootCatalog v
|
type BaseAPI (v :: Nat) = RootCatalog v
|
||||||
:<|> ChannelCatalog v
|
:<|> ChannelCatalog v
|
||||||
|
|
||||||
@ -156,8 +127,6 @@ handler :: forall v. VersionedCatalog AppM v => ServerT (VersionedAPI v) AppM
|
|||||||
handler auth = catalogRoot :<|> catalogChannels
|
handler auth = catalogRoot :<|> catalogChannels
|
||||||
where
|
where
|
||||||
catalogChannels :: Channel.ChannelID -> AppM (Catalog v)
|
catalogChannels :: Channel.ChannelID -> AppM (Catalog v)
|
||||||
-- Channel specific catalog returns tags inside the catalog
|
catalogChannels _ = throwM err403{errBody="Not implemented"}
|
||||||
catalogChannels identifier = flip requireLoggedIn auth (getBooks identifier)
|
|
||||||
catalogRoot :: AppM (Catalog v)
|
catalogRoot :: AppM (Catalog v)
|
||||||
-- catalog root returns channels
|
|
||||||
catalogRoot = flip requireLoggedIn auth getChannels
|
catalogRoot = flip requireLoggedIn auth getChannels
|
@ -15,18 +15,17 @@
|
|||||||
{-# Language NamedFieldPuns #-}
|
{-# Language NamedFieldPuns #-}
|
||||||
module API.Channels (API, handler, JsonChannel(..)) where
|
module API.Channels (API, handler, JsonChannel(..)) where
|
||||||
|
|
||||||
|
import Servant
|
||||||
|
import Types
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
import Control.Lens
|
import Server.Auth
|
||||||
import Control.Monad.Catch (throwM, MonadThrow)
|
import Servant.Auth as SA
|
||||||
import Control.Monad.Logger
|
import Control.Monad.Logger
|
||||||
import Data.Aeson
|
|
||||||
import Data.Generics.Product
|
|
||||||
import Database
|
import Database
|
||||||
import Database.Channel
|
import Database.Channel
|
||||||
import Servant
|
import Data.Aeson
|
||||||
import Servant.Auth as SA
|
import Control.Lens
|
||||||
import Server.Auth
|
import Data.Generics.Product
|
||||||
import Types
|
|
||||||
|
|
||||||
data JsonChannel = JsonChannel { channel :: Text
|
data JsonChannel = JsonChannel { channel :: Text
|
||||||
, visibility :: Visibility }
|
, visibility :: Visibility }
|
@ -7,18 +7,17 @@
|
|||||||
{-# Language TypeApplications #-}
|
{-# Language TypeApplications #-}
|
||||||
module API.Users where
|
module API.Users where
|
||||||
|
|
||||||
import ClassyPrelude
|
|
||||||
import Control.Monad.Catch (throwM, MonadThrow)
|
|
||||||
import Data.Aeson
|
|
||||||
import Database (runDB)
|
|
||||||
import Database.Schema
|
|
||||||
import Database.User
|
|
||||||
import Servant
|
import Servant
|
||||||
import Servant.Auth as SA
|
import ClassyPrelude
|
||||||
import Servant.Auth.Server as SAS
|
|
||||||
import Server.Auth
|
|
||||||
import Types
|
import Types
|
||||||
|
import Data.Aeson
|
||||||
import Web.FormUrlEncoded
|
import Web.FormUrlEncoded
|
||||||
|
import Database (runDB)
|
||||||
|
import Database.User
|
||||||
|
import Database.Schema
|
||||||
|
import Server.Auth
|
||||||
|
import Servant.Auth.Server as SAS
|
||||||
|
import Servant.Auth as SA
|
||||||
|
|
||||||
|
|
||||||
data RegisterForm = RegisterForm { username :: Username
|
data RegisterForm = RegisterForm { username :: Username
|
@ -12,9 +12,7 @@ data Pg = Pg { username :: Text
|
|||||||
, database :: Text }
|
, database :: Text }
|
||||||
deriving (Show, Generic)
|
deriving (Show, Generic)
|
||||||
|
|
||||||
data Store = Filestore { path :: Text }
|
newtype Store = Store { path :: Text } deriving (Show, Generic)
|
||||||
| IPFS { common :: Text }
|
|
||||||
deriving (Show, Generic)
|
|
||||||
|
|
||||||
data Config = Config { database :: Pg
|
data Config = Config { database :: Pg
|
||||||
, store :: Store }
|
, store :: Store }
|
@ -15,17 +15,15 @@ module Database
|
|||||||
, SeldaT )
|
, SeldaT )
|
||||||
where
|
where
|
||||||
|
|
||||||
import ClassyPrelude
|
|
||||||
import Control.Lens (view)
|
|
||||||
import Control.Monad.Catch (MonadMask)
|
|
||||||
import Control.Monad.Trans.Control (MonadBaseControl)
|
|
||||||
import Data.Generics.Product
|
import Data.Generics.Product
|
||||||
|
import Control.Lens (view)
|
||||||
import Data.Pool (Pool, withResource)
|
import Data.Pool (Pool, withResource)
|
||||||
import Database.Selda (query, select, transaction)
|
|
||||||
import Database.Selda.Backend (SeldaConnection, runSeldaT, SeldaT)
|
import Database.Selda.Backend (SeldaConnection, runSeldaT, SeldaT)
|
||||||
|
import Database.Selda (query, select, transaction)
|
||||||
import Database.Selda.Generic (gen, fromRel, fromRels, toRel)
|
import Database.Selda.Generic (gen, fromRel, fromRels, toRel)
|
||||||
|
import ClassyPrelude
|
||||||
|
|
||||||
type DBLike r m = (MonadBaseControl IO m, MonadIO m, MonadReader r m, HasField "database" r r (Pool SeldaConnection) (Pool SeldaConnection), MonadMask m)
|
type DBLike r m = (MonadIO m, MonadReader r m, MonadBaseControl IO m, MonadMask m, HasField' "database" r (Pool SeldaConnection))
|
||||||
|
|
||||||
runDB :: DBLike r m => SeldaT m a -> m a
|
runDB :: DBLike r m => SeldaT m a -> m a
|
||||||
runDB q = do
|
runDB q = do
|
@ -18,17 +18,18 @@ module Database.Book
|
|||||||
, BookID) where
|
, BookID) where
|
||||||
|
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
import Control.Lens (view)
|
|
||||||
import Control.Monad.Catch (MonadCatch)
|
|
||||||
import Data.Generics.Product
|
|
||||||
import Database
|
|
||||||
import Database.Channel (booksChannels, attachChannel, clearChannels)
|
|
||||||
import Database.Schema (books, users, Username, Book(..), BookID(..), UserID, HashDigest(..))
|
import Database.Schema (books, users, Username, Book(..), BookID(..), UserID, HashDigest(..))
|
||||||
|
import Database
|
||||||
import Database.Selda
|
import Database.Selda
|
||||||
import Database.Selda.Generic
|
import Database.Selda.Generic
|
||||||
import Database.Tag (booksTags, attachTag, clearTags)
|
|
||||||
|
|
||||||
usersBooks :: (MonadSelda m, MonadIO m) => Username -> m [Book]
|
import Control.Lens (view)
|
||||||
|
import Data.Generics.Product
|
||||||
|
|
||||||
|
import Database.Tag (booksTags, attachTag, clearTags)
|
||||||
|
import Database.Channel (booksChannels, attachChannel, clearChannels)
|
||||||
|
|
||||||
|
usersBooks :: (MonadSelda m, MonadMask m, MonadIO m) => Username -> m [Book]
|
||||||
usersBooks username = fromRels <$> query q
|
usersBooks username = fromRels <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -40,7 +41,7 @@ usersBooks username = fromRels <$> query q
|
|||||||
return book
|
return book
|
||||||
|
|
||||||
|
|
||||||
getBook :: (MonadSelda m, MonadIO m) => BookID -> Username -> m (Maybe Book)
|
getBook :: (MonadSelda m, MonadMask m, MonadIO m) => BookID -> Username -> m (Maybe Book)
|
||||||
getBook identifier owner = listToMaybe . fromRels <$> query q
|
getBook identifier owner = listToMaybe . fromRels <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -50,12 +51,12 @@ getBook identifier owner = listToMaybe . fromRels <$> query q
|
|||||||
return book
|
return book
|
||||||
|
|
||||||
data InsertBook = InsertBook { contentType :: Text
|
data InsertBook = InsertBook { contentType :: Text
|
||||||
, title :: Text
|
, title :: Maybe Text
|
||||||
, description :: Maybe Text
|
, description :: Maybe Text
|
||||||
, owner :: Username }
|
, owner :: Username }
|
||||||
|
|
||||||
-- Always inserts
|
-- Always inserts
|
||||||
insertBook :: (MonadSelda m, MonadIO m) => InsertBook -> m (Maybe BookID)
|
insertBook :: (MonadSelda m, MonadMask m, MonadIO m) => InsertBook -> m (Maybe BookID)
|
||||||
insertBook InsertBook{..} = do
|
insertBook InsertBook{..} = do
|
||||||
mUserId <- query $ do
|
mUserId <- query $ do
|
||||||
userId :*: _ :*: username' :*: _ <- select (gen users)
|
userId :*: _ :*: username' :*: _ <- select (gen users)
|
||||||
@ -67,14 +68,14 @@ insertBook InsertBook{..} = do
|
|||||||
|
|
||||||
data UpdateBook = UpdateBook { identifier :: BookID
|
data UpdateBook = UpdateBook { identifier :: BookID
|
||||||
, contentType :: Text
|
, contentType :: Text
|
||||||
, title :: Text
|
, title :: Maybe Text
|
||||||
, description :: Maybe Text
|
, description :: Maybe Text
|
||||||
, owner :: Username
|
, owner :: Username
|
||||||
, tags :: [Text]
|
, tags :: [Text]
|
||||||
, channels :: [Text] }
|
, channels :: [Text] }
|
||||||
deriving (Show, Generic)
|
deriving (Show, Generic)
|
||||||
|
|
||||||
bookExists :: (MonadSelda m, MonadIO m) => BookID -> m Bool
|
bookExists :: (MonadSelda m, MonadMask m, MonadIO m) => BookID -> m Bool
|
||||||
bookExists identifier = not . null <$> query q
|
bookExists identifier = not . null <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -82,7 +83,7 @@ bookExists identifier = not . null <$> query q
|
|||||||
restrict (bookId .== literal identifier)
|
restrict (bookId .== literal identifier)
|
||||||
return bookId
|
return bookId
|
||||||
|
|
||||||
isBookOwner :: (MonadSelda m, MonadIO m) => BookID -> Username -> m Bool
|
isBookOwner :: (MonadSelda m, MonadIO m, MonadThrow m) => BookID -> Username -> m Bool
|
||||||
isBookOwner identifier username = not . null <$> query (bookOwner' identifier username)
|
isBookOwner identifier username = not . null <$> query (bookOwner' identifier username)
|
||||||
|
|
||||||
bookOwner' :: BookID -> Username -> Query s (Col s UserID :*: Col s BookID)
|
bookOwner' :: BookID -> Username -> Query s (Col s UserID :*: Col s BookID)
|
||||||
@ -94,7 +95,7 @@ bookOwner' identifier username = do
|
|||||||
restrict (bookId .== literal identifier)
|
restrict (bookId .== literal identifier)
|
||||||
return (userId :*: bookId)
|
return (userId :*: bookId)
|
||||||
|
|
||||||
updateBook :: (MonadCatch m, MonadSelda m, MonadIO m) => UpdateBook -> m (Maybe UpdateBook)
|
updateBook :: (MonadSelda m, MonadMask m, MonadIO m) => UpdateBook -> m (Maybe UpdateBook)
|
||||||
updateBook UpdateBook{..} = do
|
updateBook UpdateBook{..} = do
|
||||||
clearTags identifier >> connectTags
|
clearTags identifier >> connectTags
|
||||||
clearChannels identifier >> connectChannels
|
clearChannels identifier >> connectChannels
|
||||||
@ -113,7 +114,7 @@ updateBook UpdateBook{..} = do
|
|||||||
predicate (bookId :*: _) = bookId .== literal identifier
|
predicate (bookId :*: _) = bookId .== literal identifier
|
||||||
|
|
||||||
|
|
||||||
getUpdateBook :: (MonadIO m, MonadSelda m) => BookID -> Username -> m (Maybe UpdateBook)
|
getUpdateBook :: (MonadMask m, MonadIO m, MonadSelda m) => BookID -> Username -> m (Maybe UpdateBook)
|
||||||
getUpdateBook bookId username = do
|
getUpdateBook bookId username = do
|
||||||
mBook <- getBook bookId username
|
mBook <- getBook bookId username
|
||||||
forM mBook $ \Book{..} -> do
|
forM mBook $ \Book{..} -> do
|
||||||
@ -121,7 +122,7 @@ getUpdateBook bookId username = do
|
|||||||
tags <- map (view (field @"tag")) <$> booksTags bookId
|
tags <- map (view (field @"tag")) <$> booksTags bookId
|
||||||
return UpdateBook{owner=username,..}
|
return UpdateBook{owner=username,..}
|
||||||
|
|
||||||
setContent :: (MonadSelda m, MonadIO m) => BookID -> Username -> HashDigest -> m ()
|
setContent :: (MonadSelda m, MonadMask m, MonadIO m) => BookID -> Username -> HashDigest -> m ()
|
||||||
setContent identifier owner digest = do
|
setContent identifier owner digest = do
|
||||||
mOwner <- query (bookOwner' identifier owner)
|
mOwner <- query (bookOwner' identifier owner)
|
||||||
void $ forM (listToMaybe mOwner) $ \_ ->
|
void $ forM (listToMaybe mOwner) $ \_ ->
|
@ -11,21 +11,19 @@ module Database.Channel
|
|||||||
, Visibility(..)
|
, Visibility(..)
|
||||||
, clearChannels
|
, clearChannels
|
||||||
, booksChannels
|
, booksChannels
|
||||||
, channelBooks
|
|
||||||
, Channel(..)
|
, Channel(..)
|
||||||
, ChannelID(..) )
|
, ChannelID )
|
||||||
where
|
where
|
||||||
|
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
import Control.Monad.Catch (MonadMask)
|
|
||||||
import Database
|
|
||||||
import Database.Schema
|
import Database.Schema
|
||||||
|
import Database
|
||||||
import Database.Selda
|
import Database.Selda
|
||||||
import Database.Selda.Generic
|
import Database.Selda.Generic
|
||||||
|
|
||||||
import Control.Monad.Trans.Maybe
|
import Control.Monad.Trans.Maybe
|
||||||
|
|
||||||
getChannel :: (MonadSelda m, MonadIO m) => ChannelID -> m (Maybe Channel)
|
getChannel :: (MonadSelda m, MonadMask m, MonadIO m) => ChannelID -> m (Maybe Channel)
|
||||||
getChannel identifier = listToMaybe . fromRels <$> query q
|
getChannel identifier = listToMaybe . fromRels <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -33,10 +31,10 @@ getChannel identifier = listToMaybe . fromRels <$> query q
|
|||||||
restrict (channelId .== literal identifier)
|
restrict (channelId .== literal identifier)
|
||||||
return ch
|
return ch
|
||||||
|
|
||||||
channelExists :: (MonadSelda m, MonadIO m) => ChannelID -> m Bool
|
channelExists :: (MonadSelda m, MonadMask m, MonadIO m) => ChannelID -> m Bool
|
||||||
channelExists identifier = not . null <$> getChannel identifier
|
channelExists identifier = not . null <$> getChannel identifier
|
||||||
|
|
||||||
isChannelOwner :: (MonadSelda m, MonadIO m) => ChannelID -> Username -> m Bool
|
isChannelOwner :: (MonadSelda m, MonadIO m, MonadMask m) => ChannelID -> Username -> m Bool
|
||||||
isChannelOwner identifier username = not . null <$> query q
|
isChannelOwner identifier username = not . null <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -57,7 +55,7 @@ userChannels username = fromRels <$> query q
|
|||||||
restrict (username' .== literal username)
|
restrict (username' .== literal username)
|
||||||
return channel
|
return channel
|
||||||
|
|
||||||
updateChannelPrivacy :: (MonadIO m, MonadSelda m) => ChannelID -> Visibility -> m (Maybe Channel)
|
updateChannelPrivacy :: (MonadMask m, MonadIO m, MonadSelda m) => ChannelID -> Visibility -> m (Maybe Channel)
|
||||||
updateChannelPrivacy channelId visibility = do
|
updateChannelPrivacy channelId visibility = do
|
||||||
void $ update (gen channels) predicate (\channel -> channel `with` [pVis := literal visibility])
|
void $ update (gen channels) predicate (\channel -> channel `with` [pVis := literal visibility])
|
||||||
getChannel channelId
|
getChannel channelId
|
||||||
@ -82,20 +80,7 @@ insertChannel username channel visibility = runMaybeT $ do
|
|||||||
restrict (user .== literal username)
|
restrict (user .== literal username)
|
||||||
return userId
|
return userId
|
||||||
|
|
||||||
channelBooks :: (MonadSelda m, MonadIO m) => Username -> ChannelID -> m [Book]
|
booksChannels :: (MonadSelda m, MonadMask m, MonadIO m) => BookID -> m [Channel]
|
||||||
channelBooks username identifier = fromRels <$> query q
|
|
||||||
where
|
|
||||||
q = do
|
|
||||||
channelId :*: bookId' <- select (gen bookChannels)
|
|
||||||
channelId' :*: _ :*: owner :*: _ <- select (gen channels)
|
|
||||||
userId :*: _ :*: username' :*: _ <- select (gen users)
|
|
||||||
book@(bookId :*: _) <- select (gen books)
|
|
||||||
restrict (username' .== literal username .&& owner .== userId)
|
|
||||||
restrict (channelId .== literal identifier .&& channelId .== channelId')
|
|
||||||
restrict (bookId .== bookId')
|
|
||||||
return book
|
|
||||||
|
|
||||||
booksChannels :: (MonadSelda m, MonadIO m) => BookID -> m [Channel]
|
|
||||||
booksChannels bookId = fromRels <$> query q
|
booksChannels bookId = fromRels <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -105,7 +90,7 @@ booksChannels bookId = fromRels <$> query q
|
|||||||
restrict (bookId' .== literal bookId)
|
restrict (bookId' .== literal bookId)
|
||||||
return ch
|
return ch
|
||||||
|
|
||||||
attachChannel :: (MonadIO m, MonadSelda m) => Username -> BookID -> Text -> m ()
|
attachChannel :: (MonadMask m, MonadIO m, MonadSelda m) => Username -> BookID -> Text -> m ()
|
||||||
attachChannel username bookId channel = do
|
attachChannel username bookId channel = do
|
||||||
mCh <- fromRels <$> query channelQ
|
mCh <- fromRels <$> query channelQ
|
||||||
forM_ mCh $ \Channel{identifier} ->
|
forM_ mCh $ \Channel{identifier} ->
|
||||||
@ -124,5 +109,5 @@ attachChannel username bookId channel = do
|
|||||||
restrict (channel' .== literal channel)
|
restrict (channel' .== literal channel)
|
||||||
return ch
|
return ch
|
||||||
|
|
||||||
clearChannels :: (MonadIO m, MonadSelda m) => BookID -> m Int
|
clearChannels :: (MonadMask m, MonadIO m, MonadSelda m) => BookID -> m Int
|
||||||
clearChannels bookId = deleteFrom (gen bookChannels) (\(_ :*: bookId') -> bookId' .== literal bookId)
|
clearChannels bookId = deleteFrom (gen bookChannels) (\(_ :*: bookId') -> bookId' .== literal bookId)
|
@ -42,7 +42,7 @@ instance SqlType Username where
|
|||||||
|
|
||||||
newtype UserID = UserID {unUserID :: Int} deriving (Show)
|
newtype UserID = UserID {unUserID :: Int} deriving (Show)
|
||||||
|
|
||||||
newtype BookID = BookID {unBookID :: Int} deriving (Show, ToJSON, FromJSON, FromHttpApiData, Eq, Ord, ToHttpApiData)
|
newtype BookID = BookID {unBookID :: Int} deriving (Show, ToJSON, FromJSON, FromHttpApiData, Eq, Ord)
|
||||||
|
|
||||||
newtype ChannelID = ChannelID {unChannelID :: Int} deriving (Show, ToHttpApiData, FromHttpApiData, ToJSON, FromJSON)
|
newtype ChannelID = ChannelID {unChannelID :: Int} deriving (Show, ToHttpApiData, FromHttpApiData, ToJSON, FromJSON)
|
||||||
|
|
||||||
@ -101,7 +101,7 @@ newtype HashDigest = HashDigest { unHex :: ByteString } deriving Show
|
|||||||
data Book = Book { identifier :: BookID
|
data Book = Book { identifier :: BookID
|
||||||
, contentHash :: Maybe HashDigest
|
, contentHash :: Maybe HashDigest
|
||||||
, contentType :: Text
|
, contentType :: Text
|
||||||
, title :: Text
|
, title :: Maybe Text
|
||||||
, description :: Maybe Text
|
, description :: Maybe Text
|
||||||
, owner :: UserID }
|
, owner :: UserID }
|
||||||
deriving (Show, Generic)
|
deriving (Show, Generic)
|
@ -12,14 +12,13 @@ module Database.Tag
|
|||||||
, Tag(..) ) where
|
, Tag(..) ) where
|
||||||
|
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
import Control.Monad.Catch (MonadCatch)
|
|
||||||
import Control.Monad.Trans.Maybe
|
|
||||||
import Database
|
|
||||||
import Database.Schema
|
import Database.Schema
|
||||||
|
import Database
|
||||||
import Database.Selda
|
import Database.Selda
|
||||||
import Database.Selda.Generic
|
import Database.Selda.Generic
|
||||||
|
import Control.Monad.Trans.Maybe
|
||||||
|
|
||||||
upsertTag :: (MonadCatch m, MonadIO m, MonadSelda m) => Username -> Text -> m (Maybe Tag)
|
upsertTag :: (MonadMask m, MonadIO m, MonadSelda m) => Username -> Text -> m (Maybe Tag)
|
||||||
upsertTag username tag = runMaybeT $ do
|
upsertTag username tag = runMaybeT $ do
|
||||||
userId <- MaybeT (listToMaybe <$> query userQ)
|
userId <- MaybeT (listToMaybe <$> query userQ)
|
||||||
void $ lift $ upsert (gen tags) (predicate userId) id [toRel (Tag def tag userId)]
|
void $ lift $ upsert (gen tags) (predicate userId) id [toRel (Tag def tag userId)]
|
||||||
@ -35,7 +34,7 @@ upsertTag username tag = runMaybeT $ do
|
|||||||
restrict (username' .== literal username)
|
restrict (username' .== literal username)
|
||||||
return userId
|
return userId
|
||||||
|
|
||||||
booksTags :: (MonadIO m, MonadSelda m) => BookID -> m [Tag]
|
booksTags :: (MonadMask m, MonadIO m, MonadSelda m) => BookID -> m [Tag]
|
||||||
booksTags bookId = fromRels <$> query q
|
booksTags bookId = fromRels <$> query q
|
||||||
where
|
where
|
||||||
q = do
|
q = do
|
||||||
@ -45,7 +44,7 @@ booksTags bookId = fromRels <$> query q
|
|||||||
restrict (bookId' .== literal bookId)
|
restrict (bookId' .== literal bookId)
|
||||||
return tag
|
return tag
|
||||||
|
|
||||||
attachTag :: (MonadCatch m, MonadIO m, MonadSelda m) => Username -> BookID -> Text -> m ()
|
attachTag :: (MonadMask m, MonadIO m, MonadSelda m) => Username -> BookID -> Text -> m ()
|
||||||
attachTag username bookId tag = do
|
attachTag username bookId tag = do
|
||||||
maybeT <- upsertTag username tag
|
maybeT <- upsertTag username tag
|
||||||
forM_ maybeT $ \Tag{identifier} -> do
|
forM_ maybeT $ \Tag{identifier} -> do
|
||||||
@ -57,6 +56,6 @@ attachTag username bookId tag = do
|
|||||||
restrict (tagId' .== literal tagId .&& bookId' .== literal bookId)
|
restrict (tagId' .== literal tagId .&& bookId' .== literal bookId)
|
||||||
return tagId'
|
return tagId'
|
||||||
|
|
||||||
clearTags :: (MonadIO m, MonadSelda m) => BookID -> m Int
|
clearTags :: (MonadMask m, MonadIO m, MonadSelda m) => BookID -> m Int
|
||||||
clearTags bookId = deleteFrom (gen bookTags) (\(_ :*: bookId') -> bookId' .== literal bookId)
|
clearTags bookId = deleteFrom (gen bookTags) (\(_ :*: bookId') -> bookId' .== literal bookId)
|
||||||
|
|
@ -5,21 +5,20 @@
|
|||||||
module Database.User where
|
module Database.User where
|
||||||
|
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
import Control.Lens (view, over, _Just)
|
|
||||||
import Control.Monad (mfilter)
|
|
||||||
import Control.Monad.Catch (MonadMask)
|
|
||||||
import Control.Monad.Logger
|
|
||||||
import Crypto.KDF.BCrypt
|
|
||||||
import Crypto.Random.Types (MonadRandom)
|
|
||||||
import Data.Generics.Product
|
|
||||||
import Database
|
import Database
|
||||||
import Database.Schema
|
import Database.Schema
|
||||||
import Database.Selda
|
import Database.Selda
|
||||||
|
import Control.Lens (view, over, _Just)
|
||||||
|
import Data.Generics.Product
|
||||||
|
import Crypto.KDF.BCrypt
|
||||||
|
import Crypto.Random.Types (MonadRandom)
|
||||||
|
import Control.Monad.Logger
|
||||||
|
import Control.Monad (mfilter)
|
||||||
|
|
||||||
data UserExistsError = UserExistsError
|
data UserExistsError = UserExistsError
|
||||||
|
|
||||||
|
|
||||||
insertUser :: (MonadMask m, MonadLogger m, MonadIO m, MonadRandom m) => Username -> Email -> PlainPassword -> SeldaT m (Either UserExistsError (User NoPassword))
|
insertUser :: (MonadLogger m, MonadIO m, MonadMask m, MonadRandom m) => Username -> Email -> PlainPassword -> SeldaT m (Either UserExistsError (User NoPassword))
|
||||||
insertUser username email (PlainPassword password) =
|
insertUser username email (PlainPassword password) =
|
||||||
getUser' username >>= maybe insert' (const (return $ Left UserExistsError))
|
getUser' username >>= maybe insert' (const (return $ Left UserExistsError))
|
||||||
where
|
where
|
@ -5,7 +5,6 @@
|
|||||||
{-# Language FlexibleContexts #-}
|
{-# Language FlexibleContexts #-}
|
||||||
{-# Language TypeSynonymInstances #-}
|
{-# Language TypeSynonymInstances #-}
|
||||||
{-# Language FlexibleInstances #-}
|
{-# Language FlexibleInstances #-}
|
||||||
{-# Language ScopedTypeVariables #-}
|
|
||||||
module Datastore where
|
module Datastore where
|
||||||
|
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
@ -29,26 +28,26 @@ instance MonadDS AppM where
|
|||||||
get = getLocal
|
get = getLocal
|
||||||
|
|
||||||
putLocal :: ( MonadIO m
|
putLocal :: ( MonadIO m
|
||||||
, HasField "config" r r config config
|
, HasField' "config" r config
|
||||||
, HasField "store" config config store store
|
, HasField' "store" config store
|
||||||
, HasType Text store
|
, HasField' "path" store Text
|
||||||
, MonadReader r m)
|
, MonadReader r m)
|
||||||
=> ByteString -> m (Digest SHA256)
|
=> ByteString -> m (Digest SHA256)
|
||||||
putLocal bs = do
|
putLocal bs = do
|
||||||
store :: FilePath <- unpack <$> view (field @"config" . field @"store" . typed @Text)
|
store <- unpack <$> view (field @"config" . field @"store" . field @"path")
|
||||||
liftIO $ createDirectoryIfMissing True store
|
liftIO $ createDirectoryIfMissing True store
|
||||||
let key = hashWith SHA256 bs
|
let key = hashWith SHA256 bs
|
||||||
writeFile (store </> show key) bs
|
writeFile (store </> show key) bs
|
||||||
return key
|
return key
|
||||||
|
|
||||||
getLocal :: ( MonadIO m
|
getLocal :: ( MonadIO m
|
||||||
, HasField "config" r r config config
|
, HasField' "config" r config
|
||||||
, HasField "store" config config store store
|
, HasField' "store" config store
|
||||||
, HasType Text store
|
, HasField' "path" store Text
|
||||||
, MonadReader r m)
|
, MonadReader r m)
|
||||||
=> Digest SHA256 -> m (Maybe ByteString)
|
=> Digest SHA256 -> m (Maybe ByteString)
|
||||||
getLocal key = do
|
getLocal key = do
|
||||||
store <- unpack <$> view (field @"config" . field @"store" . typed @Text)
|
store <- unpack <$> view (field @"config" . field @"store" . field @"path")
|
||||||
liftIO $ createDirectoryIfMissing True store
|
liftIO $ createDirectoryIfMissing True store
|
||||||
let file = store </> show key
|
let file = store </> show key
|
||||||
exists <- liftIO $ doesFileExist file
|
exists <- liftIO $ doesFileExist file
|
@ -3,18 +3,19 @@
|
|||||||
{-# Language FlexibleContexts #-}
|
{-# Language FlexibleContexts #-}
|
||||||
module Devel.Main where
|
module Devel.Main where
|
||||||
|
|
||||||
|
import Prelude
|
||||||
|
import Control.Monad.Trans.Reader (runReaderT)
|
||||||
|
import Main (withApp, defaultMain)
|
||||||
import Control.Concurrent
|
import Control.Concurrent
|
||||||
import Control.Monad (void)
|
import Control.Monad (void)
|
||||||
import Control.Monad.Trans.Reader (runReaderT)
|
|
||||||
import Data.IORef (IORef, newIORef, readIORef, writeIORef)
|
import Data.IORef (IORef, newIORef, readIORef, writeIORef)
|
||||||
import Database
|
|
||||||
import Database.Schema
|
|
||||||
import Database.Selda (tryCreateTable)
|
|
||||||
import Dhall (input, auto)
|
|
||||||
import Foreign.Store (Store(..), lookupStore, readStore, storeAction, withStore)
|
import Foreign.Store (Store(..), lookupStore, readStore, storeAction, withStore)
|
||||||
import GHC.Word (Word32)
|
import GHC.Word (Word32)
|
||||||
import Main (withApp, defaultMain)
|
import Dhall (input, auto)
|
||||||
import Prelude
|
|
||||||
|
import Database.Schema
|
||||||
|
import Database.Selda (tryCreateTable)
|
||||||
|
import Database
|
||||||
|
|
||||||
update :: IO ()
|
update :: IO ()
|
||||||
update = do
|
update = do
|
||||||
@ -36,7 +37,7 @@ update = do
|
|||||||
|
|
||||||
develMain :: IO ()
|
develMain :: IO ()
|
||||||
develMain = do
|
develMain = do
|
||||||
conf <- input auto "../config/devel.dhall"
|
conf <- input auto "./config/devel.dhall"
|
||||||
withApp conf $ \app -> do
|
withApp conf $ \app -> do
|
||||||
void $ runReaderT (runDB migrate) app
|
void $ runReaderT (runDB migrate) app
|
||||||
defaultMain app
|
defaultMain app
|
@ -25,7 +25,6 @@ withApp :: Config -> (App -> IO ()) -> IO ()
|
|||||||
withApp config f = do
|
withApp config f = do
|
||||||
let pgHost = view (field @"database" . field @"host") config
|
let pgHost = view (field @"database" . field @"host") config
|
||||||
pgPort = 5432
|
pgPort = 5432
|
||||||
pgSchema = Nothing
|
|
||||||
pgDatabase = view (field @"database" . field @"database") config
|
pgDatabase = view (field @"database" . field @"database") config
|
||||||
pgUsername = Just (view (field @"database" . field @"username") config)
|
pgUsername = Just (view (field @"database" . field @"username") config)
|
||||||
pgPassword = Just (view (field @"database" . field @"password") config)
|
pgPassword = Just (view (field @"database" . field @"password") config)
|
@ -1,11 +1,9 @@
|
|||||||
{-# Language OverloadedStrings #-}
|
{-# Language OverloadedStrings #-}
|
||||||
{-# Language FlexibleInstances #-}
|
{-# Language FlexibleInstances #-}
|
||||||
{-# Language MultiParamTypeClasses #-}
|
{-# Language MultiParamTypeClasses #-}
|
||||||
{-# Language TypeApplications #-}
|
|
||||||
module Servant.XML
|
module Servant.XML
|
||||||
( ToNode(..)
|
( ToNode(..)
|
||||||
, XML
|
, XML
|
||||||
, OPDS
|
|
||||||
, Text.Hamlet.XML.xml
|
, Text.Hamlet.XML.xml
|
||||||
, iso8601 )
|
, iso8601 )
|
||||||
where
|
where
|
||||||
@ -18,22 +16,14 @@ import Network.HTTP.Media.MediaType
|
|||||||
|
|
||||||
data XML
|
data XML
|
||||||
|
|
||||||
data OPDS
|
|
||||||
|
|
||||||
instance (ToNode a) => MimeRender XML a where
|
instance (ToNode a) => MimeRender XML a where
|
||||||
mimeRender _ a =
|
mimeRender _ a =
|
||||||
let [NodeElement root] = toNode a
|
let [NodeElement root] = toNode a
|
||||||
in renderLBS def (Document (Prologue [] Nothing []) root [])
|
in renderLBS def (Document (Prologue [] Nothing []) root [])
|
||||||
|
|
||||||
instance (ToNode a) => MimeRender OPDS a where
|
|
||||||
mimeRender _ a = mimeRender (Proxy @XML) a
|
|
||||||
|
|
||||||
instance Accept XML where
|
instance Accept XML where
|
||||||
contentType _ = "application" // "xml" /: ("charset", "utf-8")
|
contentType _ = "application" // "xml" /: ("charset", "utf-8")
|
||||||
|
|
||||||
instance Accept OPDS where
|
|
||||||
contentType _ = "application" // "atom+xml" /: ("charset", "utf-8") /: ("profile", "opds-catalog")
|
|
||||||
|
|
||||||
iso8601 :: UTCTime -> Text
|
iso8601 :: UTCTime -> Text
|
||||||
iso8601 = pack . formatTime defaultTimeLocale "%Y-%m-%dT%H:%M:%SZ"
|
iso8601 = pack . formatTime defaultTimeLocale "%Y-%m-%dT%H:%M:%SZ"
|
||||||
|
|
@ -10,7 +10,6 @@
|
|||||||
{-# Language DeriveGeneric #-}
|
{-# Language DeriveGeneric #-}
|
||||||
{-# Language FlexibleInstances #-}
|
{-# Language FlexibleInstances #-}
|
||||||
{-# Language TypeApplications #-}
|
{-# Language TypeApplications #-}
|
||||||
{-# Language ScopedTypeVariables #-}
|
|
||||||
module Server where
|
module Server where
|
||||||
|
|
||||||
import qualified API as API
|
import qualified API as API
|
||||||
@ -23,21 +22,19 @@ import Control.Monad.Except
|
|||||||
import Servant.Auth.Server as SAS
|
import Servant.Auth.Server as SAS
|
||||||
import Control.Lens
|
import Control.Lens
|
||||||
import Data.Generics.Product
|
import Data.Generics.Product
|
||||||
import Server.Auth (SafeUser)
|
|
||||||
|
|
||||||
type API = API.API :<|> "static" :> Raw
|
type API = API.API :<|> "static" :> Raw
|
||||||
|
|
||||||
type Ctx = '[BasicAuthData -> IO (AuthResult SafeUser), CookieSettings, JWTSettings]
|
|
||||||
|
|
||||||
server :: App -> Application
|
server :: App -> Application
|
||||||
server app = serveWithContext api cfg (hoistServerWithContext (Proxy @ API.API) (Proxy @ Ctx) server' API.handler :<|> serveDirectoryFileServer "static")
|
server app = serveWithContext api cfg (enter server' API.handler :<|> serveDirectoryFileServer "static")
|
||||||
where
|
where
|
||||||
myKey = view (field @"jwk") app
|
myKey = view (field @"jwk") app
|
||||||
jwtCfg = defaultJWTSettings myKey
|
jwtCfg = defaultJWTSettings myKey
|
||||||
authCfg = authCheck app
|
authCfg = authCheck app
|
||||||
cookieSettings = SAS.defaultCookieSettings{cookieIsSecure=SAS.NotSecure}
|
cookieSettings = SAS.defaultCookieSettings{cookieIsSecure=SAS.NotSecure}
|
||||||
cfg = jwtCfg :. cookieSettings :. authCfg :. EmptyContext
|
cfg = jwtCfg :. cookieSettings :. authCfg :. EmptyContext
|
||||||
server' :: AppM a -> Servant.Handler a
|
server' :: AppM :~> Servant.Handler
|
||||||
server' = Handler . ExceptT . try . (`runReaderT` app) . (runFileLoggingT "logs/server.log")
|
server' = NT (Handler . ExceptT . try . (`runReaderT` app) . (runFileLoggingT "logs/server.log"))
|
||||||
api :: Proxy API
|
api :: Proxy API
|
||||||
api = Proxy
|
api = Proxy
|
@ -14,17 +14,16 @@ module Server.Auth
|
|||||||
where
|
where
|
||||||
|
|
||||||
import ClassyPrelude
|
import ClassyPrelude
|
||||||
import Control.Lens (view)
|
import Servant.Auth.Server as SAS
|
||||||
import Control.Monad.Logger
|
|
||||||
import Control.Monad.Catch (throwM, MonadThrow)
|
|
||||||
import Data.Aeson
|
import Data.Aeson
|
||||||
import Data.Generics.Product
|
|
||||||
import Database
|
|
||||||
import Database.Schema
|
import Database.Schema
|
||||||
import Database.User
|
import Database.User
|
||||||
import Servant (err401)
|
import Database
|
||||||
import Servant.Auth.Server as SAS
|
|
||||||
import Types
|
import Types
|
||||||
|
import Control.Lens (view)
|
||||||
|
import Data.Generics.Product
|
||||||
|
import Servant (err401)
|
||||||
|
import Control.Monad.Logger
|
||||||
|
|
||||||
-- generic-lens can convert similar types to this
|
-- generic-lens can convert similar types to this
|
||||||
-- I'm trying out servant-auth-server which uses a jwt style login. IIRC anyone
|
-- I'm trying out servant-auth-server which uses a jwt style login. IIRC anyone
|
||||||
@ -54,6 +53,6 @@ authCheck app (BasicAuthData username password) = flip runReaderT app $
|
|||||||
password' = PlainPassword $ decodeUtf8 password
|
password' = PlainPassword $ decodeUtf8 password
|
||||||
authenticated = SAS.Authenticated . view (super @SafeUser)
|
authenticated = SAS.Authenticated . view (super @SafeUser)
|
||||||
|
|
||||||
requireLoggedIn :: (MonadThrow m, MonadLogger m, Monad m) => (SafeUser -> m a) -> AuthResult SafeUser -> m a
|
requireLoggedIn :: (MonadLogger m, MonadThrow m, Monad m) => (SafeUser -> m a) -> AuthResult SafeUser -> m a
|
||||||
requireLoggedIn f (Authenticated user) = f user
|
requireLoggedIn f (Authenticated user) = f user
|
||||||
requireLoggedIn _ u = $logError (pack (show u)) >> throwM err401
|
requireLoggedIn _ u = $logError (pack (show u)) >> throwM err401
|
Reference in New Issue
Block a user