2017-09-01 17:02:07 +00:00
|
|
|
{- exports to remotes
|
|
|
|
-
|
|
|
|
- Copyright 2017 Joey Hess <id@joeyh.name>
|
|
|
|
-
|
|
|
|
- Licensed under the GNU GPL version 3 or higher.
|
|
|
|
-}
|
|
|
|
|
2017-09-07 17:45:31 +00:00
|
|
|
{-# LANGUAGE FlexibleInstances #-}
|
|
|
|
|
2017-09-01 17:02:07 +00:00
|
|
|
module Remote.Helper.Export where
|
|
|
|
|
|
|
|
import Annex.Common
|
|
|
|
import Types.Remote
|
2017-09-04 20:39:56 +00:00
|
|
|
import Types.Backend
|
|
|
|
import Types.Key
|
|
|
|
import Backend
|
2017-09-04 16:40:33 +00:00
|
|
|
import Remote.Helper.Encryptable (isEncrypted)
|
2017-09-04 20:39:56 +00:00
|
|
|
import Database.Export
|
2017-09-19 18:20:47 +00:00
|
|
|
import Annex.Export
|
2017-09-01 17:02:07 +00:00
|
|
|
|
2017-09-04 16:40:33 +00:00
|
|
|
import qualified Data.Map as M
|
2017-09-18 22:40:16 +00:00
|
|
|
import Control.Concurrent.STM
|
2017-09-04 16:40:33 +00:00
|
|
|
|
|
|
|
-- | Use for remotes that do not support exports.
|
2017-09-07 17:45:31 +00:00
|
|
|
class HasExportUnsupported a where
|
|
|
|
exportUnsupported :: a
|
2017-09-04 16:40:33 +00:00
|
|
|
|
2017-09-07 17:45:31 +00:00
|
|
|
instance HasExportUnsupported (RemoteConfig -> RemoteGitConfig -> Annex Bool) where
|
|
|
|
exportUnsupported = \_ _ -> return False
|
|
|
|
|
2017-09-12 20:59:04 +00:00
|
|
|
instance HasExportUnsupported (Annex (ExportActions Annex)) where
|
|
|
|
exportUnsupported = return $ ExportActions
|
2017-09-08 18:24:05 +00:00
|
|
|
{ storeExport = \_ _ _ _ -> do
|
|
|
|
warning "store export is unsupported"
|
|
|
|
return False
|
|
|
|
, retrieveExport = \_ _ _ _ -> return False
|
2017-09-07 17:45:31 +00:00
|
|
|
, checkPresentExport = \_ _ -> return False
|
2017-09-15 17:15:47 +00:00
|
|
|
, removeExport = \_ _ -> return False
|
|
|
|
, removeExportDirectory = Just $ \_ -> return False
|
2017-09-07 17:45:31 +00:00
|
|
|
, renameExport = \_ _ _ -> return False
|
|
|
|
}
|
|
|
|
|
|
|
|
exportIsSupported :: RemoteConfig -> RemoteGitConfig -> Annex Bool
|
|
|
|
exportIsSupported = \_ _ -> return True
|
|
|
|
|
|
|
|
-- | Prevent or allow exporttree=yes when setting up a new remote,
|
|
|
|
-- depending on exportSupported and other configuration.
|
|
|
|
adjustExportableRemoteType :: RemoteType -> RemoteType
|
|
|
|
adjustExportableRemoteType rt = rt { setup = setup' }
|
|
|
|
where
|
|
|
|
setup' st mu cp c gc = do
|
|
|
|
let cont = setup rt st mu cp c gc
|
|
|
|
ifM (exportSupported rt c gc)
|
|
|
|
( case st of
|
2017-09-08 20:44:00 +00:00
|
|
|
Init
|
|
|
|
| exportTree c && isEncrypted c ->
|
2017-09-07 17:45:31 +00:00
|
|
|
giveup "cannot enable both encryption and exporttree"
|
2017-09-08 20:44:00 +00:00
|
|
|
| otherwise -> cont
|
2017-09-07 17:45:31 +00:00
|
|
|
Enable oldc
|
2017-09-08 20:44:00 +00:00
|
|
|
| exportTree c /= exportTree oldc ->
|
2017-09-07 17:45:31 +00:00
|
|
|
giveup "cannot change exporttree of existing special remote"
|
|
|
|
| otherwise -> cont
|
2017-09-08 20:44:00 +00:00
|
|
|
, if exportTree c
|
|
|
|
then giveup "exporttree=yes is not supported by this special remote"
|
|
|
|
else cont
|
2017-09-07 17:45:31 +00:00
|
|
|
)
|
2017-09-04 20:39:56 +00:00
|
|
|
|
2017-09-07 17:45:31 +00:00
|
|
|
-- | If the remote is exportSupported, and exporttree=yes, adjust the
|
|
|
|
-- remote to be an export.
|
|
|
|
adjustExportable :: Remote -> Annex Remote
|
|
|
|
adjustExportable r = case M.lookup "exporttree" (config r) of
|
|
|
|
Just "yes" -> ifM (isExportSupported r)
|
|
|
|
( isexport
|
|
|
|
, notexport
|
|
|
|
)
|
2017-09-08 18:24:05 +00:00
|
|
|
Nothing -> notexport
|
|
|
|
Just "no" -> notexport
|
2018-10-10 14:44:54 +00:00
|
|
|
Just _ -> do
|
|
|
|
warning $ "bad exporttree value for " ++ name r ++ ", assuming not an export"
|
|
|
|
notexport
|
2017-09-07 17:45:31 +00:00
|
|
|
where
|
2017-09-13 16:05:53 +00:00
|
|
|
notexport = return $ r
|
|
|
|
{ exportActions = exportUnsupported
|
|
|
|
, remotetype = (remotetype r)
|
|
|
|
{ exportSupported = exportUnsupported
|
|
|
|
}
|
|
|
|
}
|
2017-09-07 17:45:31 +00:00
|
|
|
isexport = do
|
|
|
|
db <- openDb (uuid r)
|
2017-09-18 22:40:16 +00:00
|
|
|
|
|
|
|
updateflag <- liftIO newEmptyTMVarIO
|
|
|
|
let updateonce = liftIO $ atomically $
|
|
|
|
ifM (isEmptyTMVar updateflag)
|
|
|
|
( do
|
|
|
|
putTMVar updateflag ()
|
|
|
|
return True
|
|
|
|
, return False
|
|
|
|
)
|
|
|
|
|
|
|
|
-- Get export locations for a key. Checks once
|
|
|
|
-- if the export log is different than the database and
|
|
|
|
-- updates the database, to notice when an export has been
|
|
|
|
-- updated from another repository.
|
|
|
|
let getexportlocs = \k -> do
|
2017-09-20 20:22:32 +00:00
|
|
|
whenM updateonce $
|
|
|
|
updateExportTreeFromLog db
|
2017-09-18 22:40:16 +00:00
|
|
|
liftIO $ getExportTree db k
|
|
|
|
|
2017-09-07 17:45:31 +00:00
|
|
|
return $ r
|
2017-09-18 18:40:08 +00:00
|
|
|
-- Storing a key on an export could be implemented,
|
|
|
|
-- but it would perform unncessary work
|
|
|
|
-- when another repository has already stored the
|
|
|
|
-- key, and the local repository does not know
|
|
|
|
-- about it. To avoid unnecessary costs, don't do it.
|
2017-09-04 20:39:56 +00:00
|
|
|
{ storeKey = \_ _ _ -> do
|
|
|
|
warning "remote is configured with exporttree=yes; use `git-annex export` to store content on it"
|
|
|
|
return False
|
2018-08-30 15:41:44 +00:00
|
|
|
-- Keys can be retrieved using retrieveExport,
|
|
|
|
-- but since that retrieves from a path in the
|
|
|
|
-- remote that another writer could have replaced
|
|
|
|
-- with content not of the requested key,
|
|
|
|
-- the content has to be strongly verified.
|
|
|
|
--
|
|
|
|
-- But, appendonly remotes have a key/value store,
|
|
|
|
-- so don't need to use retrieveExport.
|
|
|
|
, retrieveKeyFile = if appendonly r
|
|
|
|
then retrieveKeyFile r
|
|
|
|
else retrieveKeyFileFromExport getexportlocs
|
|
|
|
, retrieveKeyFileCheap = if appendonly r
|
|
|
|
then retrieveKeyFileCheap r
|
|
|
|
else \_ _ _ -> return False
|
2017-09-17 21:56:33 +00:00
|
|
|
-- Removing a key from an export would need to
|
|
|
|
-- change the tree in the export log to not include
|
|
|
|
-- the file. Otherwise, conflicts when removing
|
|
|
|
-- files would not be dealt with correctly.
|
|
|
|
-- There does not seem to be a good use case for
|
|
|
|
-- removing a key from an export in any case.
|
|
|
|
, removeKey = \_k -> do
|
|
|
|
warning "dropping content from an export is not supported; use `git annex export` to export a tree that lacks the files you want to remove"
|
|
|
|
return False
|
2017-09-04 20:39:56 +00:00
|
|
|
-- Can't lock content on exports, since they're
|
|
|
|
-- not key/value stores, and someone else could
|
|
|
|
-- change what's exported to a file at any time.
|
2018-08-30 15:41:44 +00:00
|
|
|
--
|
|
|
|
-- (except for appendonly remotes)
|
|
|
|
, lockContent = if appendonly r
|
|
|
|
then lockContent r
|
|
|
|
else Nothing
|
|
|
|
-- Check if any of the files a key was exported to
|
|
|
|
-- are present. This doesn't guarantee the export
|
|
|
|
-- contains the right content, which is why export
|
|
|
|
-- remotes are untrusted.
|
|
|
|
--
|
|
|
|
-- (but appendonly remotes work the same as any
|
|
|
|
-- non-export remote)
|
|
|
|
, checkPresent = if appendonly r
|
|
|
|
then checkPresent r
|
|
|
|
else \k -> do
|
|
|
|
ea <- exportActions r
|
|
|
|
anyM (checkPresentExport ea k)
|
|
|
|
=<< getexportlocs k
|
2017-09-04 20:55:31 +00:00
|
|
|
, mkUnavailable = return Nothing
|
|
|
|
, getInfo = do
|
|
|
|
is <- getInfo r
|
|
|
|
return (is++[("export", "yes")])
|
2017-09-04 20:39:56 +00:00
|
|
|
}
|
2018-08-30 15:41:44 +00:00
|
|
|
retrieveKeyFileFromExport getexportlocs k _af dest p = unVerified $
|
|
|
|
if maybe False (isJust . verifyKeyContent) (maybeLookupBackendVariety (keyVariety k))
|
|
|
|
then do
|
|
|
|
locs <- getexportlocs k
|
|
|
|
case locs of
|
|
|
|
[] -> do
|
|
|
|
warning "unknown export location"
|
|
|
|
return False
|
|
|
|
(l:_) -> do
|
|
|
|
ea <- exportActions r
|
|
|
|
retrieveExport ea k l dest p
|
|
|
|
else do
|
|
|
|
warning $ "exported content cannot be verified due to using the " ++ formatKeyVariety (keyVariety k) ++ " backend"
|
|
|
|
return False
|