don't pass .local hostname over the wire

The remote computer may not support mDNS. Instead, pass over the uname -a
hostname, and the IP address, and leave best hostname calculation to the
remote side.
This commit is contained in:
Joey Hess 2012-09-08 14:23:35 -04:00
parent 92b1f42730
commit 3e070b947a
2 changed files with 52 additions and 57 deletions
Assistant
Pairing.hs
WebApp/Configurators

View file

@ -10,7 +10,6 @@ module Assistant.Pairing where
import Common import Common
import Utility.Verifiable import Utility.Verifiable
import Utility.ThreadScheduler import Utility.ThreadScheduler
import Utility.Network
import Network.Multicast import Network.Multicast
import Network.Info import Network.Info
@ -41,7 +40,9 @@ data PairMsg
deriving (Eq, Read, Show) deriving (Eq, Read, Show)
data PairData = PairData data PairData = PairData
{ remoteHostName :: HostName -- uname -n output, not a full domain name
{ remoteHostName :: Maybe HostName
, remoteAddress :: SomeAddr
, remoteUserName :: UserName , remoteUserName :: UserName
, sshPubKey :: SshPubKey , sshPubKey :: SshPubKey
} }
@ -67,26 +68,21 @@ multicastAddress :: SomeAddr -> HostName
multicastAddress (IPv4Addr _) = "224.0.0.1" multicastAddress (IPv4Addr _) = "224.0.0.1"
multicastAddress (IPv6Addr _) = "ff02::1" multicastAddress (IPv6Addr _) = "ff02::1"
type MkPairMsg = HostName -> PairMsg
{- Multicasts a message repeatedly on all interfaces until its thread {- Multicasts a message repeatedly on all interfaces until its thread
- is killed, with a 2 second delay between each transmission. - is killed, with a 2 second delay between each transmission.
- -
- The remoteHostName is set to the best host name that can be found for - The remoteHostAddress is set to the interface's IP address.
- each interface's IP address. When possible, that's a .local name.
- If not, it's whatever is found in the DNS for the address, or failing
- that, the IP address.
- -
- Note that new sockets are opened each time. This is hardly efficient, - Note that new sockets are opened each time. This is hardly efficient,
- but it allows new network interfaces to be used as they come up. - but it allows new network interfaces to be used as they come up.
- On the other hand, the expensive DNS lookups are cached. - On the other hand, the expensive DNS lookups are cached.
-} -}
multicastPairMsg :: MkPairMsg -> IO ThreadId multicastPairMsg :: (SomeAddr -> PairMsg) -> IO ThreadId
multicastPairMsg mkmsg = forkIO $ go =<< initMsgCache mkmsg multicastPairMsg mkmsg = forkIO $ go M.empty
where where
go cache = do go cache = do
addrs <- activeNetworkAddresses addrs <- activeNetworkAddresses
cache' <- updateMsgCache mkmsg cache addrs let cache' = updatecache cache addrs
mapM_ (sendinterface cache') addrs mapM_ (sendinterface cache') addrs
threadDelaySeconds (Seconds 2) threadDelaySeconds (Seconds 2)
go cache' go cache'
@ -95,56 +91,53 @@ multicastPairMsg mkmsg = forkIO $ go =<< initMsgCache mkmsg
(multicastSender (multicastAddress i) pairingPort) (multicastSender (multicastAddress i) pairingPort)
(sClose . fst) (sClose . fst)
(\(sock, addr) -> do (\(sock, addr) -> do
setInterface sock (show i) setInterface sock (showAddr i)
maybe noop (\s -> void $ sendTo sock s addr) maybe noop (\s -> void $ sendTo sock s addr)
(M.lookup i cache) (M.lookup i cache)
) )
updatecache cache [] = cache
updatecache cache (i:is)
| M.member i cache = updatecache cache is
| otherwise = updatecache (M.insert i (show $ mkmsg i) cache) is
{- A cache of serialized messages. -} {- Finds the best hostname to use for the host that sent the PairData.
type MsgCache = M.Map SomeAddr String -
- If remoteHostName is set, tries to use a .local address based on it.
{- Ensures that the cache has messages for each address. -} - That's the most robust, if this system supports .local.
updateMsgCache :: MkPairMsg -> MsgCache -> [SomeAddr] -> IO MsgCache - Otherwise, looks up the hostname in the DNS for the remoteAddress,
updateMsgCache _ m [] = return m - if any. May fall back to remoteAddress if there's no DNS. Ugh. -}
updateMsgCache mkmsg m (v:vs) bestHostName :: PairData -> IO HostName
| M.member v m = updateMsgCache mkmsg m vs bestHostName d = case remoteHostName d of
| otherwise = do Just h -> do
let sockaddr = case v of let localname = h ++ ".local"
IPv4Addr (IPv4 a) -> SockAddrInet (PortNum 0) a addrs <- catchDefaultIO (getAddrInfo Nothing (Just localname) Nothing) []
IPv6Addr (IPv6 o1 o2 o3 o4) -> SockAddrInet6 (PortNum 0) 0 (o1, o2, o3, o4) 0 maybe fallback (const $ return localname) (headMaybe addrs)
mhostname <- catchDefaultIO (fst <$> getNameInfo [] True False sockaddr) Nothing Nothing -> fallback
let cache' = M.insert v (show $ mkmsg $ fromMaybe (show v) mhostname) m
updateMsgCache mkmsg cache' vs
{- An initial message cache. Look up hostname.local, and if found,
- put it in the cache. -}
initMsgCache :: MkPairMsg -> IO MsgCache
initMsgCache mkmsg = go =<< getHostname
where where
go Nothing = return M.empty fallback = do
go (Just n) = do let sockaddr = case remoteAddress d of
let localname = n ++ ".local" IPv4Addr a -> SockAddrInet (PortNum 0) a
addrs <- catchDefaultIO (getAddrInfo Nothing (Just localname) Nothing) [] IPv6Addr a -> SockAddrInet6 (PortNum 0) 0 a 0
case headMaybe addrs of fromMaybe (show $ remoteAddress d)
Nothing -> return M.empty <$> catchDefaultIO (fst <$> getNameInfo [] True False sockaddr) Nothing
Just addr -> case addrAddress addr of
SockAddrInet _ a ->
use localname $
IPv4Addr $ IPv4 a
SockAddrInet6 _ _ (o1, o2, o3, o4) _ ->
use localname $
IPv6Addr $ IPv6 o1 o2 o3 o4
_ -> return M.empty
use hostname addr = return $ M.fromList [(addr, show $ mkmsg hostname)]
data SomeAddr = IPv4Addr IPv4 | IPv6Addr IPv6 data SomeAddr = IPv4Addr HostAddress | IPv6Addr HostAddress6
deriving (Ord, Eq) deriving (Ord, Eq, Read, Show)
instance Show SomeAddr where class ToSomeAddr a where
show (IPv4Addr x) = show x toSomeAddr :: a -> SomeAddr
show (IPv6Addr x) = show x
instance ToSomeAddr IPv4 where
toSomeAddr (IPv4 a) = IPv4Addr a
instance ToSomeAddr IPv6 where
toSomeAddr (IPv6 o1 o2 o3 o4) = IPv6Addr (o1, o2, o3, o4)
showAddr :: SomeAddr -> HostName
showAddr (IPv4Addr a) = show $ IPv4 a
showAddr (IPv6Addr (o1, o2, o3, o4)) = show $ IPv6 o1 o2 o3 o4
activeNetworkAddresses :: IO [SomeAddr] activeNetworkAddresses :: IO [SomeAddr]
activeNetworkAddresses = filter (not . all (`elem` "0.:") . show) activeNetworkAddresses = filter (not . all (`elem` "0.:") . showAddr)
. concat . map (\ni -> [IPv4Addr $ ipv4 ni, IPv6Addr $ ipv6 ni]) . concat . map (\ni -> [toSomeAddr $ ipv4 ni, toSomeAddr $ ipv6 ni])
<$> getNetworkInterfaces <$> getNetworkInterfaces

View file

@ -35,6 +35,7 @@ import Assistant.WebApp
import Assistant.WebApp.Types import Assistant.WebApp.Types
import Assistant.WebApp.SideBar import Assistant.WebApp.SideBar
import Utility.Yesod import Utility.Yesod
import Utility.Network
import Yesod import Yesod
import Data.Text (Text) import Data.Text (Text)
@ -46,10 +47,11 @@ import System.Posix.User
getStartPairR :: Handler RepHtml getStartPairR :: Handler RepHtml
getStartPairR = promptSecret Nothing $ \rawsecret secret -> do getStartPairR = promptSecret Nothing $ \rawsecret secret -> do
hostname <- liftIO $ getHostname
username <- liftIO $ getUserName username <- liftIO $ getUserName
let sshkey = "" -- TODO generate/read ssh key let sshkey = "" -- TODO generate/read ssh key
let mkmsg hostname = PairReqM $ PairReq $ let mkmsg addr = PairReqM $ PairReq $
mkVerifiable (PairData hostname username sshkey) secret mkVerifiable (PairData hostname addr username sshkey) secret
pip <- liftIO $ PairingInProgress secret <$> multicastPairMsg mkmsg pip <- liftIO $ PairingInProgress secret <$> multicastPairMsg mkmsg
dstatus <- daemonStatus <$> lift getYesod dstatus <- daemonStatus <$> lift getYesod
liftIO $ modifyDaemonStatus_ dstatus $ liftIO $ modifyDaemonStatus_ dstatus $
@ -96,7 +98,7 @@ promptSecret req cont = bootstrap (Just Config) $ do
let badphrase = isJust mproblem let badphrase = isJust mproblem
let msg = fromMaybe "" mproblem let msg = fromMaybe "" mproblem
let (username, hostname) = maybe ("", "") let (username, hostname) = maybe ("", "")
(\v -> (T.pack $ remoteUserName v, T.pack $ remoteHostName v)) (\v -> (T.pack $ remoteUserName v, T.pack $ fromMaybe (showAddr $ remoteAddress v) (remoteHostName v)))
(verifiableVal . fromPairReq <$> req) (verifiableVal . fromPairReq <$> req)
u <- T.pack <$> liftIO getUserName u <- T.pack <$> liftIO getUserName
let sameusername = username == u let sameusername = username == u