2016-11-29 21:30:27 +00:00
|
|
|
{- P2P protocol addresses
|
|
|
|
-
|
|
|
|
- Copyright 2016 Joey Hess <id@joeyh.name>
|
|
|
|
-
|
|
|
|
- Licensed under the GNU GPL version 3 or higher.
|
|
|
|
-}
|
|
|
|
|
|
|
|
module P2P.Address where
|
|
|
|
|
|
|
|
import qualified Annex
|
|
|
|
import Annex.Common
|
|
|
|
import Git
|
2016-12-06 16:19:47 +00:00
|
|
|
import Git.Types
|
2016-11-29 21:30:27 +00:00
|
|
|
import Creds
|
|
|
|
import Utility.AuthToken
|
|
|
|
import Utility.Tor
|
|
|
|
|
|
|
|
import qualified Data.Text as T
|
|
|
|
|
|
|
|
-- | A P2P address, without an AuthToken.
|
|
|
|
--
|
|
|
|
-- This is enough information to connect to the peer,
|
|
|
|
-- but not enough to authenticate with it.
|
|
|
|
data P2PAddress = TorAnnex OnionAddress OnionPort
|
|
|
|
deriving (Eq, Show)
|
|
|
|
|
2016-11-30 18:35:24 +00:00
|
|
|
-- | A P2P address, with an AuthToken.
|
|
|
|
--
|
|
|
|
-- This is enough information to connect to the peer, and authenticate with
|
|
|
|
-- it.
|
2016-11-29 21:30:27 +00:00
|
|
|
data P2PAddressAuth = P2PAddressAuth P2PAddress AuthToken
|
|
|
|
deriving (Eq, Show)
|
|
|
|
|
|
|
|
class FormatP2PAddress a where
|
|
|
|
formatP2PAddress :: a -> String
|
|
|
|
unformatP2PAddress :: String -> Maybe a
|
|
|
|
|
|
|
|
instance FormatP2PAddress P2PAddress where
|
|
|
|
formatP2PAddress (TorAnnex (OnionAddress onionaddr) onionport) =
|
2016-12-09 20:02:43 +00:00
|
|
|
torAnnexScheme ++ ":" ++ onionaddr ++ ":" ++ show onionport
|
2016-11-29 21:30:27 +00:00
|
|
|
unformatP2PAddress s
|
2016-12-09 20:02:43 +00:00
|
|
|
| (torAnnexScheme ++ ":") `isPrefixOf` s = do
|
2016-11-29 21:30:27 +00:00
|
|
|
let s' = dropWhile (== ':') $ dropWhile (/= ':') s
|
|
|
|
let (onionaddr, ps) = separate (== ':') s'
|
|
|
|
onionport <- readish ps
|
|
|
|
return (TorAnnex (OnionAddress onionaddr) onionport)
|
|
|
|
| otherwise = Nothing
|
|
|
|
|
2016-12-09 20:02:43 +00:00
|
|
|
torAnnexScheme :: String
|
|
|
|
torAnnexScheme = "tor-annex:"
|
|
|
|
|
2016-11-29 21:30:27 +00:00
|
|
|
instance FormatP2PAddress P2PAddressAuth where
|
|
|
|
formatP2PAddress (P2PAddressAuth addr authtoken) =
|
|
|
|
formatP2PAddress addr ++ ":" ++ T.unpack (fromAuthToken authtoken)
|
|
|
|
unformatP2PAddress s = do
|
|
|
|
let (ra, rs) = separate (== ':') (reverse s)
|
|
|
|
addr <- unformatP2PAddress (reverse rs)
|
|
|
|
authtoken <- toAuthToken (T.pack $ reverse ra)
|
|
|
|
return (P2PAddressAuth addr authtoken)
|
|
|
|
|
2016-12-06 16:19:47 +00:00
|
|
|
repoP2PAddress :: Repo -> Maybe P2PAddress
|
|
|
|
repoP2PAddress (Repo { location = Url url }) = unformatP2PAddress (show url)
|
|
|
|
repoP2PAddress _ = Nothing
|
|
|
|
|
2016-11-29 21:33:49 +00:00
|
|
|
-- | Load known P2P addresses for this repository.
|
2016-11-29 21:30:27 +00:00
|
|
|
loadP2PAddresses :: Annex [P2PAddress]
|
|
|
|
loadP2PAddresses = mapMaybe unformatP2PAddress . maybe [] lines
|
|
|
|
<$> readCacheCreds p2pAddressCredsFile
|
|
|
|
|
2016-11-29 21:33:49 +00:00
|
|
|
-- | Store a new P2P address for this repository.
|
2016-11-29 21:30:27 +00:00
|
|
|
storeP2PAddress :: P2PAddress -> Annex ()
|
|
|
|
storeP2PAddress addr = do
|
|
|
|
addrs <- loadP2PAddresses
|
|
|
|
unless (addr `elem` addrs) $ do
|
|
|
|
let s = unlines $ map formatP2PAddress (addr:addrs)
|
|
|
|
let tmpnam = p2pAddressCredsFile ++ ".new"
|
|
|
|
writeCacheCreds s tmpnam
|
|
|
|
tmpf <- cacheCredsFile tmpnam
|
|
|
|
destf <- cacheCredsFile p2pAddressCredsFile
|
|
|
|
-- This may be run by root, so make the creds file
|
|
|
|
-- and directory have the same owner and group as
|
|
|
|
-- the git repository directory has.
|
|
|
|
st <- liftIO . getFileStatus =<< Annex.fromRepo repoLocation
|
|
|
|
let fixowner f = setOwnerAndGroup f (fileOwner st) (fileGroup st)
|
|
|
|
liftIO $ do
|
|
|
|
fixowner tmpf
|
|
|
|
fixowner (takeDirectory tmpf)
|
|
|
|
fixowner (takeDirectory (takeDirectory tmpf))
|
|
|
|
renameFile tmpf destf
|
|
|
|
|
|
|
|
p2pAddressCredsFile :: FilePath
|
|
|
|
p2pAddressCredsFile = "p2paddrs"
|
2016-12-21 18:31:27 +00:00
|
|
|
|
|
|
|
torAppName :: AppName
|
|
|
|
torAppName = "tor-annex"
|