mirror: New command, makes two repositories contain the same set of files.
This is a simple approach for setting up a mirroring repository. It will work with any type of remotes. Mirror --from is more expensive than mirror --to in general. OTOH, mirror --from will get the file from any remote that has it, not only the named mirror remote. And if the named mirror remote is not the fastest available remote with a file, that can speed things up. It would be possible to make the assistant or watch command do a more dynamic mirroring, that didn't need to scan every time.
This commit is contained in:
parent
f5623af6ec
commit
0f921307e7
10 changed files with 103 additions and 21 deletions
|
@ -9,6 +9,7 @@ module Command.Copy where
|
||||||
|
|
||||||
import Common.Annex
|
import Common.Annex
|
||||||
import Command
|
import Command
|
||||||
|
import GitAnnex.Options
|
||||||
import qualified Command.Move
|
import qualified Command.Move
|
||||||
import qualified Remote
|
import qualified Remote
|
||||||
import Annex.Wanted
|
import Annex.Wanted
|
||||||
|
@ -19,8 +20,8 @@ def = [withOptions Command.Move.moveOptions $ command "copy" paramPaths seek
|
||||||
|
|
||||||
seek :: [CommandSeek]
|
seek :: [CommandSeek]
|
||||||
seek =
|
seek =
|
||||||
[ withField Command.Move.toOption Remote.byNameWithUUID $ \to ->
|
[ withField toOption Remote.byNameWithUUID $ \to ->
|
||||||
withField Command.Move.fromOption Remote.byNameWithUUID $ \from ->
|
withField fromOption Remote.byNameWithUUID $ \from ->
|
||||||
withKeyOptions (Command.Move.startKey to from False) $
|
withKeyOptions (Command.Move.startKey to from False) $
|
||||||
withFilesInGit $ whenAnnexed $ start to from
|
withFilesInGit $ whenAnnexed $ start to from
|
||||||
]
|
]
|
||||||
|
|
|
@ -33,7 +33,7 @@ import qualified Option
|
||||||
import Types.Key
|
import Types.Key
|
||||||
import Utility.HumanTime
|
import Utility.HumanTime
|
||||||
import Git.FilePath
|
import Git.FilePath
|
||||||
import GitAnnex.Options
|
import GitAnnex.Options hiding (fromOption)
|
||||||
|
|
||||||
#ifndef mingw32_HOST_OS
|
#ifndef mingw32_HOST_OS
|
||||||
import System.Posix.Process (getProcessID)
|
import System.Posix.Process (getProcessID)
|
||||||
|
|
|
@ -11,10 +11,10 @@ import Common.Annex
|
||||||
import Command
|
import Command
|
||||||
import qualified Remote
|
import qualified Remote
|
||||||
import Annex.Content
|
import Annex.Content
|
||||||
import qualified Command.Move
|
|
||||||
import Logs.Transfer
|
import Logs.Transfer
|
||||||
import Annex.Wanted
|
import Annex.Wanted
|
||||||
import GitAnnex.Options
|
import GitAnnex.Options
|
||||||
|
import qualified Command.Move
|
||||||
import Types.Key
|
import Types.Key
|
||||||
|
|
||||||
def :: [Command]
|
def :: [Command]
|
||||||
|
@ -22,11 +22,11 @@ def = [withOptions getOptions $ command "get" paramPaths seek
|
||||||
SectionCommon "make content of annexed files available"]
|
SectionCommon "make content of annexed files available"]
|
||||||
|
|
||||||
getOptions :: [Option]
|
getOptions :: [Option]
|
||||||
getOptions = [Command.Move.fromOption] ++ keyOptions
|
getOptions = fromOption : keyOptions
|
||||||
|
|
||||||
seek :: [CommandSeek]
|
seek :: [CommandSeek]
|
||||||
seek =
|
seek =
|
||||||
[ withField Command.Move.fromOption Remote.byNameWithUUID $ \from ->
|
[ withField fromOption Remote.byNameWithUUID $ \from ->
|
||||||
withKeyOptions (startKeys from) $
|
withKeyOptions (startKeys from) $
|
||||||
withFilesInGit $ whenAnnexed $ start from
|
withFilesInGit $ whenAnnexed $ start from
|
||||||
]
|
]
|
||||||
|
|
58
Command/Mirror.hs
Normal file
58
Command/Mirror.hs
Normal file
|
@ -0,0 +1,58 @@
|
||||||
|
{- git-annex command
|
||||||
|
-
|
||||||
|
- Copyright 2013 Joey Hess <joey@kitenet.net>
|
||||||
|
-
|
||||||
|
- Licensed under the GNU GPL version 3 or higher.
|
||||||
|
-}
|
||||||
|
|
||||||
|
module Command.Mirror where
|
||||||
|
|
||||||
|
import Common.Annex
|
||||||
|
import Command
|
||||||
|
import GitAnnex.Options
|
||||||
|
import qualified Command.Move
|
||||||
|
import qualified Command.Drop
|
||||||
|
import qualified Command.Get
|
||||||
|
import qualified Remote
|
||||||
|
import Annex.Content
|
||||||
|
import qualified Annex
|
||||||
|
|
||||||
|
def :: [Command]
|
||||||
|
def = [withOptions fromToOptions $ command "mirror" paramPaths seek
|
||||||
|
SectionCommon "mirror content of files to/from another repository"]
|
||||||
|
|
||||||
|
seek :: [CommandSeek]
|
||||||
|
seek =
|
||||||
|
[ withField toOption Remote.byNameWithUUID $ \to ->
|
||||||
|
withField fromOption Remote.byNameWithUUID $ \from ->
|
||||||
|
withFilesInGit $ whenAnnexed $ start to from
|
||||||
|
]
|
||||||
|
|
||||||
|
start :: Maybe Remote -> Maybe Remote -> FilePath -> (Key, Backend) -> CommandStart
|
||||||
|
start to from file (key, _backend) = do
|
||||||
|
noAuto
|
||||||
|
case (from, to) of
|
||||||
|
(Nothing, Nothing) -> error "specify either --from or --to"
|
||||||
|
(Nothing, Just r) -> mirrorto r
|
||||||
|
(Just r, Nothing) -> mirrorfrom r
|
||||||
|
_ -> error "only one of --from or --to can be specified"
|
||||||
|
where
|
||||||
|
noAuto = whenM (Annex.getState Annex.auto) $
|
||||||
|
error "--auto is not supported for mirror"
|
||||||
|
mirrorto r = ifM (inAnnex key)
|
||||||
|
( Command.Move.toStart r False (Just file) key
|
||||||
|
, do
|
||||||
|
numcopies <- numCopies file
|
||||||
|
Command.Drop.startRemote file numcopies key r
|
||||||
|
)
|
||||||
|
mirrorfrom r = do
|
||||||
|
haskey <- Remote.hasKey r key
|
||||||
|
case haskey of
|
||||||
|
Left _ -> stop
|
||||||
|
Right True -> Command.Get.start' (return True) Nothing key (Just file)
|
||||||
|
Right False -> ifM (inAnnex key)
|
||||||
|
( do
|
||||||
|
numcopies <- numCopies file
|
||||||
|
Command.Drop.startLocal file numcopies key Nothing
|
||||||
|
, stop
|
||||||
|
)
|
|
@ -14,7 +14,6 @@ import qualified Annex
|
||||||
import Annex.Content
|
import Annex.Content
|
||||||
import qualified Remote
|
import qualified Remote
|
||||||
import Annex.UUID
|
import Annex.UUID
|
||||||
import qualified Option
|
|
||||||
import Logs.Presence
|
import Logs.Presence
|
||||||
import Logs.Transfer
|
import Logs.Transfer
|
||||||
import GitAnnex.Options
|
import GitAnnex.Options
|
||||||
|
@ -24,14 +23,8 @@ def :: [Command]
|
||||||
def = [withOptions moveOptions $ command "move" paramPaths seek
|
def = [withOptions moveOptions $ command "move" paramPaths seek
|
||||||
SectionCommon "move content of files to/from another repository"]
|
SectionCommon "move content of files to/from another repository"]
|
||||||
|
|
||||||
fromOption :: Option
|
|
||||||
fromOption = Option.field ['f'] "from" paramRemote "source remote"
|
|
||||||
|
|
||||||
toOption :: Option
|
|
||||||
toOption = Option.field ['t'] "to" paramRemote "destination remote"
|
|
||||||
|
|
||||||
moveOptions :: [Option]
|
moveOptions :: [Option]
|
||||||
moveOptions = [fromOption, toOption] ++ keyOptions
|
moveOptions = fromToOptions ++ keyOptions
|
||||||
|
|
||||||
seek :: [CommandSeek]
|
seek :: [CommandSeek]
|
||||||
seek =
|
seek =
|
||||||
|
@ -54,7 +47,7 @@ start' to from move afile key = do
|
||||||
(Nothing, Nothing) -> error "specify either --from or --to"
|
(Nothing, Nothing) -> error "specify either --from or --to"
|
||||||
(Nothing, Just dest) -> toStart dest move afile key
|
(Nothing, Just dest) -> toStart dest move afile key
|
||||||
(Just src, Nothing) -> fromStart src move afile key
|
(Just src, Nothing) -> fromStart src move afile key
|
||||||
(_ , _) -> error "only one of --from or --to can be specified"
|
_ -> error "only one of --from or --to can be specified"
|
||||||
where
|
where
|
||||||
noAuto = when move $ whenM (Annex.getState Annex.auto) $ error
|
noAuto = when move $ whenM (Annex.getState Annex.auto) $ error
|
||||||
"--auto is not supported for move"
|
"--auto is not supported for move"
|
||||||
|
|
|
@ -15,23 +15,23 @@ import Logs.Location
|
||||||
import Logs.Transfer
|
import Logs.Transfer
|
||||||
import qualified Remote
|
import qualified Remote
|
||||||
import Types.Remote
|
import Types.Remote
|
||||||
import qualified Command.Move
|
import GitAnnex.Options
|
||||||
import qualified Option
|
import qualified Option
|
||||||
|
|
||||||
def :: [Command]
|
def :: [Command]
|
||||||
def = [withOptions options $
|
def = [withOptions transferKeyOptions $
|
||||||
noCommit $ command "transferkey" paramKey seek SectionPlumbing
|
noCommit $ command "transferkey" paramKey seek SectionPlumbing
|
||||||
"transfers a key from or to a remote"]
|
"transfers a key from or to a remote"]
|
||||||
|
|
||||||
options :: [Option]
|
transferKeyOptions :: [Option]
|
||||||
options = [fileOption, Command.Move.fromOption, Command.Move.toOption]
|
transferKeyOptions = fileOption : fromToOptions
|
||||||
|
|
||||||
fileOption :: Option
|
fileOption :: Option
|
||||||
fileOption = Option.field [] "file" paramFile "the associated file"
|
fileOption = Option.field [] "file" paramFile "the associated file"
|
||||||
|
|
||||||
seek :: [CommandSeek]
|
seek :: [CommandSeek]
|
||||||
seek = [withField Command.Move.toOption Remote.byNameWithUUID $ \to ->
|
seek = [withField toOption Remote.byNameWithUUID $ \to ->
|
||||||
withField Command.Move.fromOption Remote.byNameWithUUID $ \from ->
|
withField fromOption Remote.byNameWithUUID $ \from ->
|
||||||
withField fileOption return $ \file ->
|
withField fileOption return $ \file ->
|
||||||
withKeys $ start to from file]
|
withKeys $ start to from file]
|
||||||
|
|
||||||
|
|
|
@ -56,6 +56,7 @@ import qualified Command.Content
|
||||||
import qualified Command.Ungroup
|
import qualified Command.Ungroup
|
||||||
import qualified Command.Vicfg
|
import qualified Command.Vicfg
|
||||||
import qualified Command.Sync
|
import qualified Command.Sync
|
||||||
|
import qualified Command.Mirror
|
||||||
import qualified Command.AddUrl
|
import qualified Command.AddUrl
|
||||||
#ifdef WITH_FEED
|
#ifdef WITH_FEED
|
||||||
import qualified Command.ImportFeed
|
import qualified Command.ImportFeed
|
||||||
|
@ -93,6 +94,7 @@ cmds = concat
|
||||||
, Command.Unlock.def
|
, Command.Unlock.def
|
||||||
, Command.Lock.def
|
, Command.Lock.def
|
||||||
, Command.Sync.def
|
, Command.Sync.def
|
||||||
|
, Command.Mirror.def
|
||||||
, Command.AddUrl.def
|
, Command.AddUrl.def
|
||||||
#ifdef WITH_FEED
|
#ifdef WITH_FEED
|
||||||
, Command.ImportFeed.def
|
, Command.ImportFeed.def
|
||||||
|
|
|
@ -65,3 +65,12 @@ keyOptions =
|
||||||
, Option ['U'] ["unused"] (NoArg (Annex.setFlag "unused"))
|
, Option ['U'] ["unused"] (NoArg (Annex.setFlag "unused"))
|
||||||
"operate on files found by last run of git-annex unused"
|
"operate on files found by last run of git-annex unused"
|
||||||
]
|
]
|
||||||
|
|
||||||
|
fromOption :: Option
|
||||||
|
fromOption = Option.field ['f'] "from" paramRemote "source remote"
|
||||||
|
|
||||||
|
toOption :: Option
|
||||||
|
toOption = Option.field ['t'] "to" paramRemote "destination remote"
|
||||||
|
|
||||||
|
fromToOptions :: [Option]
|
||||||
|
fromToOptions = [fromOption, toOption]
|
||||||
|
|
1
debian/changelog
vendored
1
debian/changelog
vendored
|
@ -6,6 +6,7 @@ git-annex (4.20130816) UNRELEASED; urgency=low
|
||||||
* sync, merge: Bug fix: Don't try to merge into master when in a bare repo.
|
* sync, merge: Bug fix: Don't try to merge into master when in a bare repo.
|
||||||
* import: Add options to control handling of duplicate files:
|
* import: Add options to control handling of duplicate files:
|
||||||
--duplicate, --deduplicate, and --clean-duplicates
|
--duplicate, --deduplicate, and --clean-duplicates
|
||||||
|
* mirror: New command, makes two repositories contain the same set of files.
|
||||||
|
|
||||||
-- Joey Hess <joeyh@debian.org> Thu, 15 Aug 2013 15:47:52 +0200
|
-- Joey Hess <joeyh@debian.org> Thu, 15 Aug 2013 15:47:52 +0200
|
||||||
|
|
||||||
|
|
|
@ -157,6 +157,24 @@ subdirectories).
|
||||||
post-receive hook. Then any syncs to the repository will update its working
|
post-receive hook. Then any syncs to the repository will update its working
|
||||||
copy automatically.
|
copy automatically.
|
||||||
|
|
||||||
|
* mirror [path ...]
|
||||||
|
|
||||||
|
This causes a destination repository to mirror a source repository.
|
||||||
|
|
||||||
|
To use the local repository as the source repository,
|
||||||
|
specify mirror --to remote.
|
||||||
|
|
||||||
|
To use a remote as the source repository, specify mirror --from remote.
|
||||||
|
|
||||||
|
Each specified file in the source repository is mirrored to the destination
|
||||||
|
repository. If a file's content is present in the source repository, it is
|
||||||
|
copied to the destination repository. If a file's content is not present in
|
||||||
|
the source repository, it will be dropped from the destination repository
|
||||||
|
when possible.
|
||||||
|
|
||||||
|
Note that mirror does not sync the git repository, but only the file
|
||||||
|
contents.
|
||||||
|
|
||||||
* addurl [url ...]
|
* addurl [url ...]
|
||||||
|
|
||||||
Downloads each url to its own file, which is added to the annex.
|
Downloads each url to its own file, which is added to the annex.
|
||||||
|
|
Loading…
Add table
Reference in a new issue