summaryrefslogtreecommitdiff
path: root/Assistant/WebApp/OtherRepos.hs
blob: 0c429d182f57dfdab829da7bc1f426ebf477a0f1 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
{- git-annex assistant webapp switching to other repos
 -
 - Copyright 2012 Joey Hess <joey@kitenet.net>
 -
 - Licensed under the GNU GPL version 3 or higher.
 -}

{-# LANGUAGE CPP, TypeFamilies, QuasiQuotes, MultiParamTypeClasses, TemplateHaskell, OverloadedStrings, RankNTypes #-}

module Assistant.WebApp.OtherRepos where

import Assistant.Common
import Assistant.WebApp.Types
import qualified Git.Construct
import qualified Git.Config
import Locations.UserConfig
import qualified Utility.Url as Url

import Yesod
import Control.Concurrent
import System.Process (cwd)

{- Starts up the assistant in the repository, and waits for it to create
 - a gitAnnexUrlFile. Waits for the assistant to be up and listening for
 - connections by testing the url. Once it's running, redirect to it.
 -}
getSwitchToRepositoryR :: FilePath -> Handler RepHtml
getSwitchToRepositoryR repo = do
	liftIO startassistant
	url <- liftIO geturl
	redirect url
	where
		startassistant = do
			program <- readProgramFile
			void $ forkIO $ void $ createProcess $
				(proc program ["assistant"])
					{ cwd = Just repo }
		geturl = do
			r <- Git.Config.read =<< Git.Construct.fromPath repo
			waiturl $ gitAnnexUrlFile r
		waiturl urlfile = do
			v <- tryIO $ readFile urlfile
			case v of
				Left _ -> delayed $ waiturl urlfile
				Right url -> ifM (listening url)
					( return url
					, delayed $ waiturl urlfile
					)
		listening url = catchBoolIO $ 
			fst <$> Url.exists url []
		delayed a = do
			threadDelay 100000 -- 1/10th of a second
			a