2010-12-31 17:39:30 +00:00
|
|
|
{- git-annex command
|
|
|
|
-
|
2012-07-02 05:31:10 +00:00
|
|
|
- Copyright 2010,2012 Joey Hess <joey@kitenet.net>
|
2010-12-31 17:39:30 +00:00
|
|
|
-
|
|
|
|
- Licensed under the GNU GPL version 3 or higher.
|
|
|
|
-}
|
|
|
|
|
|
|
|
module Command.SendKey where
|
|
|
|
|
2011-10-05 20:02:51 +00:00
|
|
|
import Common.Annex
|
2010-12-31 17:39:30 +00:00
|
|
|
import Command
|
2011-10-04 04:40:47 +00:00
|
|
|
import Annex.Content
|
2013-03-29 00:34:07 +00:00
|
|
|
import Annex
|
2012-09-19 18:28:32 +00:00
|
|
|
import Utility.Rsync
|
2012-07-02 05:31:10 +00:00
|
|
|
import Logs.Transfer
|
2012-08-23 19:22:23 +00:00
|
|
|
import qualified Fields
|
2013-03-28 21:03:04 +00:00
|
|
|
import Utility.Metered
|
2010-12-31 17:39:30 +00:00
|
|
|
|
2011-10-29 19:19:05 +00:00
|
|
|
def :: [Command]
|
2012-09-16 00:46:38 +00:00
|
|
|
def = [noCommit $ command "sendkey" paramKey seek
|
2013-03-24 22:28:21 +00:00
|
|
|
SectionPlumbing "runs rsync in server mode to send content"]
|
2010-12-31 17:39:30 +00:00
|
|
|
|
|
|
|
seek :: [CommandSeek]
|
|
|
|
seek = [withKeys start]
|
|
|
|
|
2011-09-15 20:50:49 +00:00
|
|
|
start :: Key -> CommandStart
|
2013-03-29 00:34:07 +00:00
|
|
|
start key = do
|
2013-03-30 23:05:51 +00:00
|
|
|
opts <- filterRsyncSafeOptions . maybe [] words
|
|
|
|
<$> getField "RsyncOptions"
|
2013-03-29 00:34:07 +00:00
|
|
|
ifM (inAnnex key)
|
|
|
|
( fieldTransfer Upload key $ \_p ->
|
|
|
|
sendAnnex key rollback $ liftIO . rsyncServerSend (map Param opts)
|
|
|
|
, do
|
|
|
|
warning "requested key is not present"
|
|
|
|
liftIO exitFailure
|
|
|
|
)
|
2013-01-09 22:42:29 +00:00
|
|
|
where
|
|
|
|
{- No need to do any rollback; when sendAnnex fails, a nonzero
|
|
|
|
- exit will be propigated, and the remote will know the transfer
|
|
|
|
- failed. -}
|
|
|
|
rollback = noop
|
2012-08-23 19:22:23 +00:00
|
|
|
|
2012-09-21 18:50:14 +00:00
|
|
|
fieldTransfer :: Direction -> Key -> (MeterUpdate -> Annex Bool) -> CommandStart
|
2012-08-23 19:22:23 +00:00
|
|
|
fieldTransfer direction key a = do
|
|
|
|
afile <- Fields.getField Fields.associatedFile
|
2012-09-19 20:08:37 +00:00
|
|
|
ok <- maybe (a $ const noop)
|
2012-09-23 17:27:13 +00:00
|
|
|
(\u -> runTransfer (Transfer direction (toUUID u) key) afile noRetry a)
|
2012-08-23 19:22:23 +00:00
|
|
|
=<< Fields.getField Fields.remoteUUID
|
|
|
|
if ok
|
|
|
|
then liftIO exitSuccess
|
|
|
|
else liftIO exitFailure
|