Merge lp:~ericsnowcurrently/fake-juju/testing-fixes into lp:~landscape/fake-juju/trunk-old

[Eric Snow]

Fix a couple of broken behaviors for testing.

Without these fixes fake-juju can cause problems in tests.

[lp:~ericsnowcurrently/fake-juju/testing-fixes]

60. By Eric Snow on 2016-10-25

Merge from parent.

61. By Eric Snow on 2016-10-25

Fix a rename.

62. By Eric Snow on 2016-10-26

Merge from parent.

Unmerged revisions

=== modified file '1.25.6/fake-juju.go'
--- 1.25.6/fake-juju.go	2016-06-10 17:07:27 +0000
+++ 1.25.6/fake-juju.go	2016-10-20 21:22:41 +0000
@@ -50,39 +50,36 @@
 	coretesting.MgoTestPackage(t)
 }
 
-type processInfo struct {
-	Username     string
-	WorkDir      string
-	EndpointAddr string
-	Uuid         string
-	CACert       string
-}
-
 func handleCommand(command string) error {
+	filenames := newFakeJujuFilenames("", "", "")
 	if command == "bootstrap" {
-		return bootstrap()
+		return bootstrap(filenames)
 	}
 	if command == "api-endpoints" {
-		return apiEndpoints()
+		return apiEndpoints(filenames)
 	}
 	if command == "api-info" {
-		return apiInfo()
+		return apiInfo(filenames)
 	}
 	if command == "destroy-environment" {
-		return destroyEnvironment()
+		return destroyEnvironment(filenames)
 	}
 	return errors.New("command not found")
 }
 
-func bootstrap() error {
+func bootstrap(filenames fakejujuFilenames) error {
+	if err := filenames.ensureDirsExist(); err != nil {
+		return err
+	}
 	envName, config, err := environmentNameAndConfig()
 	if err != nil {
 		return err
 	}
+	password := config.AdminSecret()
+
 	command := exec.Command(os.Args[0])
 	command.Env = os.Environ()
-	command.Env = append(
-		command.Env, "ADMIN_PASSWORD="+config.AdminSecret())
+	command.Env = append(command.Env, "ADMIN_PASSWORD="+password)
 	defaultSeries, _ := config.DefaultSeries()
 	command.Env = append(command.Env, "DEFAULT_SERIES="+defaultSeries)
 	stdout, err := command.StdoutPipe()
@@ -90,10 +87,23 @@
 		return err
 	}
 	command.Start()
-	apiInfo, err := parseApiInfo(envName, stdout)
+
+	result, err := parseApiInfo(stdout)
 	if err != nil {
 		return err
 	}
+	// Get the API info before changing it.  The new values might
+	// not work yet.
+	apiInfo := result.apiInfo()
+	// We actually want to report the API user we added in SetUpTest().
+	result.username = "admin"
+	if password != "" {
+		result.password = password
+	}
+	if err := result.apply(filenames, envName); err != nil {
+		return err
+	}
+
 	dialOpts := api.DialOpts{
 		DialAddressInterval: 50 * time.Millisecond,
 		Timeout:             5 * time.Second,
@@ -123,8 +133,8 @@
 	return errors.New("invalid delta")
 }
 
-func apiEndpoints() error {
-	info, err := readProcessInfo()
+func apiEndpoints(filenames fakejujuFilenames) error {
+	info, err := readProcessInfo(filenames)
 	if err != nil {
 		return err
 	}
@@ -132,23 +142,22 @@
 	return nil
 }
 
-func apiInfo() error {
-	info, err := readProcessInfo()
+func apiInfo(filenames fakejujuFilenames) error {
+	info, err := readProcessInfo(filenames)
 	if err != nil {
 		return err
 	}
-	username := strings.Replace(string(info.Username), "dummy-", "", 1)
-	fmt.Printf("{\"user\": \"%s\", \"environ-uuid\": \"%s\", \"state-servers\": [\"%s\"]}\n", username, info.Uuid, info.EndpointAddr)
+	fmt.Printf("{\"user\": \"%s\", \"password\": \"%s\", \"environ-uuid\": \"%s\", \"state-servers\": [\"%s\"]}\n", info.Username, info.Password, info.Uuid, info.EndpointAddr)
 	return nil
 }
 
-func destroyEnvironment() error {
-	info, err := readProcessInfo()
+func destroyEnvironment(filenames fakejujuFilenames) error {
+	info, err := readProcessInfo(filenames)
 	if err != nil {
 		return err
 	}
-	fifoPath := filepath.Join(info.WorkDir, "fifo")
-	fd, err := os.OpenFile(fifoPath, os.O_APPEND|os.O_WRONLY, 0600)
+	filenames = newFakeJujuFilenames("", "", info.WorkDir)
+	fd, err := os.OpenFile(filenames.fifo(), os.O_APPEND|os.O_WRONLY, 0600)
 	if err != nil {
 		return err
 	}
@@ -176,93 +185,206 @@
 	return envName, config, nil
 }
 
-func parseApiInfo(envName string, stdout io.ReadCloser) (*api.Info, error) {
+type processInfo struct {
+	Username     string
+	Password     string
+	WorkDir      string
+	EndpointAddr string
+	Uuid         string
+	CACert       []byte
+}
+
+func readProcessInfo(filenames fakejujuFilenames) (*processInfo, error) {
+	infoPath := filenames.info()
+	data, err := ioutil.ReadFile(infoPath)
+	if err != nil {
+		return nil, err
+	}
+	info := &processInfo{}
+	err = goyaml.Unmarshal(data, info)
+	if err != nil {
+		return nil, err
+	}
+	return info, nil
+}
+
+func (info processInfo) write(infoPath string) error {
+	data, _ := goyaml.Marshal(&info)
+	if err := ioutil.WriteFile(infoPath, data, 0644); err != nil {
+		return err
+	}
+	return nil
+}
+
+type fakejujuFilenames struct {
+	datadir string
+	logsdir string
+}
+
+func newFakeJujuFilenames(datadir, logsdir, jujucfgdir string) fakejujuFilenames {
+	if datadir == "" {
+		datadir = os.Getenv("FAKE_JUJU_DATA_DIR")
+		if datadir == "" {
+			if jujucfgdir == "" {
+				jujucfgdir = os.Getenv("JUJU_HOME")
+			}
+			datadir = jujucfgdir
+		}
+	}
+	if logsdir == "" {
+		logsdir = os.Getenv("FAKE_JUJU_LOGS_DIR")
+		if logsdir == "" {
+			logsdir = datadir
+		}
+	}
+	return fakejujuFilenames{datadir, logsdir}
+}
+
+func (fj fakejujuFilenames) ensureDirsExist() error {
+	if err := os.MkdirAll(fj.datadir, 0755); err != nil {
+		return err
+	}
+	if err := os.MkdirAll(fj.logsdir, 0755); err != nil {
+		return err
+	}
+	return nil
+}
+
+func (fj fakejujuFilenames) info() string {
+	return filepath.Join(fj.datadir, "fakejuju")
+}
+
+func (fj fakejujuFilenames) logs() string {
+	return filepath.Join(fj.logsdir, "fake-juju.log")
+}
+
+func (fj fakejujuFilenames) fifo() string {
+	return filepath.Join(fj.datadir, "fifo")
+}
+
+func (fj fakejujuFilenames) cacert() string {
+	return filepath.Join(fj.datadir, "cert.ca")
+}
+
+type bootstrapResult struct {
+	dummyEnvName string
+	cfgdir       string
+	uuid         string
+	username     string
+	password     string
+	addresses    []string
+	caCert       []byte
+}
+
+func (br bootstrapResult) apiInfo() *api.Info {
+	return &api.Info{
+		Addrs:      br.addresses,
+		Tag:        names.NewLocalUserTag(br.username),
+		Password:   br.password,
+		CACert:     string(br.caCert),
+		EnvironTag: names.NewEnvironTag(br.uuid),
+	}
+}
+
+func (br bootstrapResult) fakeJujuInfo() *processInfo {
+	return &processInfo{
+		Username:     br.username,
+		Password:     br.password,
+		WorkDir:      br.cfgdir,
+		EndpointAddr: br.addresses[0],
+		Uuid:         br.uuid,
+		CACert:       br.caCert,
+	}
+}
+
+func (br bootstrapResult) logsSymlink(target string) (string, string) {
+	if os.Getenv("FAKE_JUJU_LOGS_DIR") != "" || os.Getenv("FAKE_JUJU_DATA_DIR") != "" {
+		return "", ""
+	}
+
+	filenames := newFakeJujuFilenames("", "", br.cfgdir)
+	source := filenames.logs()
+	return source, target
+}
+
+func (br bootstrapResult) jenvSymlink(jujuHome, envName string) (string, string) {
+	if jujuHome == "" || envName == "" {
+		return "", ""
+	}
+
+	source := filepath.Join(br.cfgdir, "environments", br.dummyEnvName+".jenv")
+	target := filepath.Join(jujuHome, "environments", envName+".jenv")
+	return source, target
+}
+
+func (br bootstrapResult) apply(filenames fakejujuFilenames, envName string) error {
+	if err := br.fakeJujuInfo().write(filenames.info()); err != nil {
+		return err
+	}
+
+	logsSource, logsTarget := br.logsSymlink(filenames.logs())
+	if logsSource != "" && logsTarget != "" {
+		if err := os.Symlink(logsSource, logsTarget); err != nil {
+			return err
+		}
+	}
+
+	jenvSource, jenvTarget := br.jenvSymlink(os.Getenv("JUJU_HOME"), envName)
+	if jenvSource != "" && jenvTarget != "" {
+		if err := os.MkdirAll(filepath.Dir(jenvTarget), 0755); err != nil {
+			return err
+		}
+		if err := os.Symlink(jenvSource, jenvTarget); err != nil {
+			return err
+		}
+	}
+
+	if err := ioutil.WriteFile(filenames.cacert(), br.caCert, 0644); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// See github.com/juju/juju/blob/juju/testing/conn.go.
+const dummyEnvName = "dummyenv"
+
+func parseApiInfo(stdout io.ReadCloser) (*bootstrapResult, error) {
 	buffer := bufio.NewReader(stdout)
+
 	line, _, err := buffer.ReadLine()
 	if err != nil {
 		return nil, err
 	}
 	uuid := string(line)
-	environTag := names.NewEnvironTag(uuid)
+
 	line, _, err = buffer.ReadLine()
 	if err != nil {
 		return nil, err
 	}
 	workDir := string(line)
+
 	store, err := configstore.NewDisk(workDir)
 	if err != nil {
 		return nil, err
 	}
-	info, err := store.ReadInfo("dummyenv")
+	info, err := store.ReadInfo(dummyEnvName)
 	if err != nil {
 		return nil, err
 	}
+
 	credentials := info.APICredentials()
 	endpoint := info.APIEndpoint()
-	addresses := endpoint.Addresses
-	apiInfo := &api.Info{
-		Addrs:      addresses,
-		Tag:        names.NewLocalUserTag(credentials.User),
-		Password:   credentials.Password,
-		CACert:     endpoint.CACert,
-		EnvironTag: environTag,
-	}
-	err = writeProcessInfo(envName, &processInfo{
-		Username:     credentials.User,
-		WorkDir:      workDir,
-		EndpointAddr: addresses[0],
-		Uuid:         uuid,
-		CACert:       endpoint.CACert,
-	})
-	if err != nil {
-		return nil, err
-	}
-	return apiInfo, nil
-}
-
-func readProcessInfo() (*processInfo, error) {
-	infoPath := filepath.Join(os.Getenv("JUJU_HOME"), "fakejuju")
-	data, err := ioutil.ReadFile(infoPath)
-	if err != nil {
-		return nil, err
-	}
-	info := &processInfo{}
-	err = goyaml.Unmarshal(data, info)
-	if err != nil {
-		return nil, err
-	}
-	return info, nil
-}
-
-func writeProcessInfo(envName string, info *processInfo) error {
-	var err error
-	jujuHome := os.Getenv("JUJU_HOME")
-	infoPath := filepath.Join(jujuHome, "fakejuju")
-	logsDir := os.Getenv("FAKE_JUJU_LOGS_DIR")
-	if logsDir == "" {
-		logsDir = jujuHome
-	}
-	logPath := filepath.Join(logsDir, "fake-juju.log")
-	caCertPath := filepath.Join(jujuHome, "cert.ca")
-	envPath := filepath.Join(jujuHome, "environments")
-	os.Mkdir(envPath, 0755)
-	jEnvPath := filepath.Join(envPath, envName+".jenv")
-	data, _ := goyaml.Marshal(info)
-	if os.Getenv("FAKE_JUJU_LOGS_DIR") == "" {
-		err = os.Symlink(filepath.Join(info.WorkDir, "fake-juju.log"), logPath)
-		if err != nil {
-			return err
-		}
-	}
-	err = os.Symlink(filepath.Join(info.WorkDir, "environments/dummyenv.jenv"), jEnvPath)
-	if err != nil {
-		return err
-	}
-	err = ioutil.WriteFile(infoPath, data, 0644)
-	if err != nil {
-		return err
-	}
-	return ioutil.WriteFile(caCertPath, []byte(info.CACert), 0644)
+	result := &bootstrapResult{
+		dummyEnvName: dummyEnvName,
+		cfgdir:       workDir,
+		uuid:         uuid,
+		username:     credentials.User,
+		password:     credentials.Password,
+		addresses:    endpoint.Addresses,
+		caCert:       []byte(endpoint.CACert),
+	}
+	return result, nil
 }
 
 // Read the failures info file pointed by the FAKE_JUJU_FAILURES environment
@@ -307,7 +429,7 @@
 
 	instanceCount  int
 	machineStarted map[string]bool
-	fifoPath       string
+	filenames      fakejujuFilenames
 	logFile        *os.File
 }
 
@@ -359,7 +481,6 @@
 	c.Assert(err, gc.IsNil)
 
 	apiInfo := s.APIInfo(c)
-	//fmt.Println(apiInfo.Addrs[0])
 	jujuHome := osenv.JujuHome()
 	// IMPORTANT: don't remove this logging because it's used by the
 	// bootstrap command.
@@ -374,15 +495,11 @@
 	c.Assert(err, gc.IsNil)
 	os.Setenv("PATH", binPath+":"+os.Getenv("PATH"))
 
-	s.fifoPath = filepath.Join(jujuHome, "fifo")
-	syscall.Mknod(s.fifoPath, syscall.S_IFIFO|0666, 0)
+	s.filenames = newFakeJujuFilenames("", "", jujuHome)
+	syscall.Mknod(s.filenames.fifo(), syscall.S_IFIFO|0666, 0)
 
 	// Logging
-	logsDir := os.Getenv("FAKE_JUJU_LOGS_DIR")
-	if logsDir == "" {
-		logsDir = jujuHome
-	}
-	logPath := filepath.Join(logsDir, "fake-juju.log")
+	logPath := s.filenames.logs()
 	s.logFile, err = os.OpenFile(logPath, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
 	c.Assert(err, gc.IsNil)
 
@@ -402,16 +519,30 @@
 }
 
 func (s *FakeJujuSuite) TestStart(c *gc.C) {
+	fifoPath := s.filenames.fifo()
 	watcher := s.State.Watch()
 	go func() {
-		log.Println("Open commands FIFO", s.fifoPath)
-		fd, err := os.Open(s.fifoPath)
+		log.Println("Open commands FIFO", fifoPath)
+		fd, err := os.Open(fifoPath)
 		if err != nil {
 			log.Println("Failed to open commands FIFO")
 		}
 		c.Assert(err, gc.IsNil)
+		defer func() {
+			if err := fd.Close(); err != nil {
+				c.Logf("failed closing FIFO file: %s", err)
+			}
+			// Mark the controller as destroyed by renaming some files.
+			if err := os.Rename(fifoPath, fifoPath+".destroyed"); err != nil {
+				c.Logf("failed renaming FIFO file: %s", err)
+			}
+			infofile := s.filenames.info()
+			if err := os.Rename(infofile, infofile+".destroyed"); err != nil {
+				c.Logf("failed renaming info file: %s", err)
+			}
+		}()
 		scanner := bufio.NewScanner(fd)
-		log.Println("Listen for commands on FIFO", s.fifoPath)
+		log.Println("Listen for commands on FIFO", fifoPath)
 		scanner.Scan()
 		log.Println("Stopping fake-juju")
 		watcher.Stop()
 
=== modified file '2.0-beta17/fake-juju.go'
--- 2.0-beta17/fake-juju.go	2016-09-15 19:05:50 +0000
+++ 2.0-beta17/fake-juju.go	2016-10-20 21:22:41 +0000
@@ -51,33 +51,31 @@
 	coretesting.MgoTestPackage(t)
 }
 
-type processInfo struct {
-	WorkDir      string
-	EndpointAddr string
-	Uuid         string
-	CACert       string
-}
-
 func handleCommand(command string) error {
+	filenames := newFakeJujuFilenames("", "", "")
 	if command == "bootstrap" {
-		return bootstrap()
+		return bootstrap(filenames)
 	}
 	if command == "show-controller" {
-		return apiInfo()
+		return apiInfo(filenames)
 	}
 	if command == "destroy-controller" {
-		return destroyEnvironment()
+		return destroyController(filenames)
 	}
 	return errors.New("command not found")
 }
 
-func bootstrap() error {
+func bootstrap(filenames fakejujuFilenames) error {
 	argc := len(os.Args)
 	if argc < 4 {
 		return errors.New(
 			"error: controller name and cloud name are required")
 	}
-	envName := os.Args[argc-2]
+	if err := filenames.ensureDirsExist(); err != nil {
+		return err
+	}
+	// XXX Swap the 2 args for juju-2.0-final.
+	controllerName := os.Args[argc-2]
 	command := exec.Command(os.Args[0])
 	command.Env = os.Environ()
 	command.Env = append(
@@ -89,10 +87,16 @@
 		return err
 	}
 	command.Start()
-	apiInfo, err := parseApiInfo(envName, stdout)
+
+	result, err := parseApiInfo(stdout)
 	if err != nil {
 		return err
 	}
+	if err := result.apply(filenames, controllerName); err != nil {
+		return err
+	}
+	apiInfo := result.apiInfo()
+
 	dialOpts := api.DialOpts{
 		DialAddressInterval: 50 * time.Millisecond,
 		Timeout:             5 * time.Second,
@@ -122,8 +126,8 @@
 	return errors.New("invalid delta")
 }
 
-func apiInfo() error {
-	info, err := readProcessInfo()
+func apiInfo(filenames fakejujuFilenames) error {
+	info, err := readProcessInfo(filenames)
 	if err != nil {
 		return err
 	}
@@ -140,13 +144,13 @@
 	return nil
 }
 
-func destroyEnvironment() error {
-	info, err := readProcessInfo()
+func destroyController(filenames fakejujuFilenames) error {
+	info, err := readProcessInfo(filenames)
 	if err != nil {
 		return err
 	}
-	fifoPath := filepath.Join(info.WorkDir, "fifo")
-	fd, err := os.OpenFile(fifoPath, os.O_APPEND|os.O_WRONLY, 0600)
+	filenames = newFakeJujuFilenames("", "", info.WorkDir)
+	fd, err := os.OpenFile(filenames.fifo(), os.O_APPEND|os.O_WRONLY, 0600)
 	if err != nil {
 		return err
 	}
@@ -158,13 +162,187 @@
 	return nil
 }
 
-func parseApiInfo(envName string, stdout io.ReadCloser) (*api.Info, error) {
+type processInfo struct {
+	WorkDir      string
+	EndpointAddr string
+	Uuid         string
+	CACert       []byte
+}
+
+func readProcessInfo(filenames fakejujuFilenames) (*processInfo, error) {
+	infoPath := filenames.info()
+	data, err := ioutil.ReadFile(infoPath)
+	if err != nil {
+		return nil, err
+	}
+	info := &processInfo{}
+	err = goyaml.Unmarshal(data, info)
+	if err != nil {
+		return nil, err
+	}
+	return info, nil
+}
+
+func (info processInfo) write(infoPath string) error {
+	data, _ := goyaml.Marshal(&info)
+	if err := ioutil.WriteFile(infoPath, data, 0644); err != nil {
+		return err
+	}
+	return nil
+}
+
+type fakejujuFilenames struct {
+	datadir string
+	logsdir string
+}
+
+func newFakeJujuFilenames(datadir, logsdir, jujucfgdir string) fakejujuFilenames {
+	if datadir == "" {
+		datadir = os.Getenv("FAKE_JUJU_DATA_DIR")
+		if datadir == "" {
+			if jujucfgdir == "" {
+				jujucfgdir = os.Getenv("JUJU_DATA")
+			}
+			datadir = jujucfgdir
+		}
+	}
+	if logsdir == "" {
+		logsdir = os.Getenv("FAKE_JUJU_LOGS_DIR")
+		if logsdir == "" {
+			logsdir = datadir
+		}
+	}
+	return fakejujuFilenames{datadir, logsdir}
+}
+
+func (fj fakejujuFilenames) ensureDirsExist() error {
+	if err := os.MkdirAll(fj.datadir, 0755); err != nil {
+		return err
+	}
+	if err := os.MkdirAll(fj.logsdir, 0755); err != nil {
+		return err
+	}
+	return nil
+}
+
+func (fj fakejujuFilenames) info() string {
+	return filepath.Join(fj.datadir, "fakejuju")
+}
+
+func (fj fakejujuFilenames) logs() string {
+	return filepath.Join(fj.logsdir, "fake-juju.log")
+}
+
+func (fj fakejujuFilenames) fifo() string {
+	return filepath.Join(fj.datadir, "fifo")
+}
+
+func (fj fakejujuFilenames) cacert() string {
+	return filepath.Join(fj.datadir, "cert.ca")
+}
+
+type bootstrapResult struct {
+	dummyControllerName string
+	cfgdir              string
+	uuid                string
+	username            string
+	password            string
+	addresses           []string
+	caCert              []byte
+}
+
+func (br bootstrapResult) apiInfo() *api.Info {
+	return &api.Info{
+		Addrs:    br.addresses,
+		Tag:      names.NewUserTag(br.username),
+		Password: br.password,
+		CACert:   string(br.caCert),
+		ModelTag: names.NewModelTag(br.uuid),
+	}
+}
+
+func (br bootstrapResult) fakeJujuInfo() *processInfo {
+	return &processInfo{
+		WorkDir:      br.cfgdir,
+		EndpointAddr: br.addresses[0],
+		Uuid:         br.uuid,
+		CACert:       br.caCert,
+	}
+}
+
+func (br bootstrapResult) logsSymlink(target string) (string, string) {
+	if os.Getenv("FAKE_JUJU_LOGS_DIR") != "" {
+		return "", ""
+	}
+
+	filenames := newFakeJujuFilenames("", "", br.cfgdir)
+	source := filenames.logs()
+	return source, target
+}
+
+func (br bootstrapResult) apply(filenames fakejujuFilenames, controllerName string) error {
+	if err := br.fakeJujuInfo().write(filenames.info()); err != nil {
+		return err
+	}
+
+	logsSource, logsTarget := br.logsSymlink(filenames.logs())
+	if logsSource != "" && logsTarget != "" {
+		if err := os.Symlink(logsSource, logsTarget); err != nil {
+			return err
+		}
+	}
+
+	if err := br.copyConfig(os.Getenv("JUJU_DATA"), controllerName); err != nil {
+		return err
+	}
+
+	if err := ioutil.WriteFile(filenames.cacert(), br.caCert, 0644); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (br bootstrapResult) copyConfig(cfgdir, controllerName string) error {
+	for _, name := range []string{"controllers.yaml", "models.yaml", "accounts.yaml"} {
+		source := filepath.Join(br.cfgdir, name)
+		target := filepath.Join(cfgdir, name)
+
+		input, err := ioutil.ReadFile(source)
+		if err != nil {
+			return err
+		}
+		// Generated configuration by test fixtures has the controller name
+		// hard-coded to "kontroll". A simple replace should fix this for
+		// clients using this config and expecting a specific controller
+		// name.
+		output := strings.Replace(string(input), dummyControllerName, controllerName, -1)
+		err = ioutil.WriteFile(target, []byte(output), 0644)
+		if err != nil {
+			return err
+		}
+	}
+
+	current := filepath.Join(cfgdir, "current-controller")
+	if err := ioutil.WriteFile(current, []byte(controllerName), 0644); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// See github.com/juju/juju/blob/juju/testing/conn.go.
+const dummyControllerName = "kontroll"
+
+func parseApiInfo(stdout io.ReadCloser) (*bootstrapResult, error) {
 	buffer := bufio.NewReader(stdout)
+
 	line, _, err := buffer.ReadLine()
 	if err != nil {
 		return nil, err
 	}
 	uuid := string(line)
+
 	line, _, err = buffer.ReadLine()
 	if err != nil {
 		return nil, err
@@ -175,8 +353,8 @@
 	store := jujuclient.NewFileClientStore()
 	// hard-coded value in juju testing
 	// This will be replaced in JUJU_DATA copy of the juju client config.
-	currentController := "kontroll"
-	one, err := store.ControllerByName("kontroll")
+	currentController := dummyControllerName
+	one, err := store.ControllerByName(currentController)
 	if err != nil {
 		return nil, err
 	}
@@ -185,108 +363,17 @@
 	if err != nil {
 		return nil, err
 	}
-	apiInfo := &api.Info{
-		Addrs:    one.APIEndpoints,
-		Tag:      names.NewUserTag(accountDetails.User),
-		Password: accountDetails.Password,
-		CACert:   one.CACert,
-		ModelTag: names.NewModelTag(uuid),
-	}
-
-	err = writeProcessInfo(envName, &processInfo{
-		WorkDir:      workDir,
-		EndpointAddr: one.APIEndpoints[0],
-		Uuid:         uuid,
-		CACert:       one.CACert,
-	})
-	if err != nil {
-		return nil, err
-	}
-	return apiInfo, nil
-}
-
-func readProcessInfo() (*processInfo, error) {
-	infoPath := filepath.Join(os.Getenv("JUJU_DATA"), "fakejuju")
-	data, err := ioutil.ReadFile(infoPath)
-	if err != nil {
-		return nil, err
-	}
-	info := &processInfo{}
-	err = goyaml.Unmarshal(data, info)
-	if err != nil {
-		return nil, err
-	}
-	return info, nil
-}
-
-func writeProcessInfo(envName string, info *processInfo) error {
-	var err error
-	jujuHome := os.Getenv("JUJU_DATA")
-	infoPath := filepath.Join(jujuHome, "fakejuju")
-	logsDir := os.Getenv("FAKE_JUJU_LOGS_DIR")
-	if logsDir == "" {
-		logsDir = jujuHome
-	}
-	logPath := filepath.Join(logsDir, "fake-juju.log")
-	caCertPath := filepath.Join(jujuHome, "cert.ca")
-	data, _ := goyaml.Marshal(info)
-	if os.Getenv("FAKE_JUJU_LOGS_DIR") == "" {
-		err = os.Symlink(filepath.Join(info.WorkDir, "fake-juju.log"), logPath)
-		if err != nil {
-			return err
-		}
-	}
-
-	err = copyClientConfig(
-		filepath.Join(info.WorkDir, "controllers.yaml"),
-		filepath.Join(jujuHome, "controllers.yaml"),
-		envName)
-	if err != nil {
-		return err
-	}
-	err = copyClientConfig(
-		filepath.Join(info.WorkDir, "models.yaml"),
-		filepath.Join(jujuHome, "models.yaml"),
-		envName)
-	if err != nil {
-		return err
-	}
-	err = copyClientConfig(
-		filepath.Join(info.WorkDir, "accounts.yaml"),
-		filepath.Join(jujuHome, "accounts.yaml"),
-		envName)
-	if err != nil {
-		return err
-	}
-	err = ioutil.WriteFile(
-		filepath.Join(jujuHome, "current-controller"),
-		[]byte(envName), 0644)
-	if err != nil {
-		return err
-	}
-
-	err = ioutil.WriteFile(infoPath, data, 0644)
-	if err != nil {
-		return err
-	}
-	return ioutil.WriteFile(caCertPath, []byte(info.CACert), 0644)
-}
-
-func copyClientConfig(src string, dst string, envName string) error {
-	input, err := ioutil.ReadFile(src)
-	if err != nil {
-		return err
-	}
-	// Generated configuration by test fixtures has the controller name
-	// hard-coded to "kontroll". A simple replace should fix this for
-	// clients using this config and expecting a specific controller
-	// name.
-	output := strings.Replace(string(input), "kontroll", envName, -1)
-	err = ioutil.WriteFile(dst, []byte(output), 0644)
-	if err != nil {
-		return err
-	}
-	return nil
+
+	result := &bootstrapResult{
+		dummyControllerName: dummyControllerName,
+		cfgdir:              workDir,
+		uuid:                uuid,
+		username:            accountDetails.User,
+		password:            accountDetails.Password,
+		addresses:           one.APIEndpoints,
+		caCert:              []byte(one.CACert),
+	}
+	return result, nil
 }
 
 // Read the failures info file pointed by the FAKE_JUJU_FAILURES environment
@@ -331,7 +418,7 @@
 
 	instanceCount  int
 	machineStarted map[string]bool
-	fifoPath       string
+	filenames      fakejujuFilenames
 	logFile        *os.File
 }
 
@@ -398,20 +485,16 @@
 	c.Assert(err, gc.IsNil)
 	os.Setenv("PATH", binPath+":"+os.Getenv("PATH"))
 
-	s.fifoPath = filepath.Join(jujuHome, "fifo")
-	syscall.Mknod(s.fifoPath, syscall.S_IFIFO|0666, 0)
+	s.filenames = newFakeJujuFilenames("", "", jujuHome)
+	syscall.Mknod(s.filenames.fifo(), syscall.S_IFIFO|0666, 0)
 
 	// Logging
-	logsDir := os.Getenv("FAKE_JUJU_LOGS_DIR")
-	if logsDir == "" {
-		logsDir = jujuHome
-	}
-	logPath := filepath.Join(logsDir, "fake-juju.log")
+	logPath := s.filenames.logs()
 	s.logFile, err = os.OpenFile(logPath, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
 	c.Assert(err, gc.IsNil)
 
 	log.SetOutput(s.logFile)
-	log.Println("Started fake-juju at", jujuHome)
+	log.Println("Started fake-juju at ", jujuHome)
 
 }
 
@@ -423,16 +506,30 @@
 }
 
 func (s *FakeJujuSuite) TestStart(c *gc.C) {
+	fifoPath := s.filenames.fifo()
 	watcher := s.State.Watch()
 	go func() {
-		log.Println("Open commands FIFO", s.fifoPath)
-		fd, err := os.Open(s.fifoPath)
+		log.Println("Open commands FIFO", fifoPath)
+		fd, err := os.Open(fifoPath)
 		if err != nil {
 			log.Println("Failed to open commands FIFO")
 		}
 		c.Assert(err, gc.IsNil)
+		defer func() {
+			if err := fd.Close(); err != nil {
+				c.Logf("failed closing FIFO file: %s", err)
+			}
+			// Mark the controller as destroyed by renaming some files.
+			if err := os.Rename(fifoPath, fifoPath+".destroyed"); err != nil {
+				c.Logf("failed renaming FIFO file: %s", err)
+			}
+			infofile := s.filenames.info()
+			if err := os.Rename(infofile, infofile+".destroyed"); err != nil {
+				c.Logf("failed renaming info file: %s", err)
+			}
+		}()
 		scanner := bufio.NewScanner(fd)
-		log.Println("Listen for commands on FIFO", s.fifoPath)
+		log.Println("Listen for commands on FIFO", fifoPath)
 		scanner.Scan()
 		log.Println("Stopping fake-juju")
 		watcher.Stop()
 
=== modified file 'Makefile'
--- Makefile	2016-09-20 18:26:47 +0000
+++ Makefile	2016-10-20 21:22:41 +0000
@@ -11,7 +11,7 @@
 INSTALLDIR = $(DESTDIR)/usr/bin
 INSTALLED = $(INSTALLDIR)/fake-juju-$(JUJU_VERSION)
 
-$(JUJU_VERSION)/$(JUJU_VERSION):
+$(JUJU_VERSION)/$(JUJU_VERSION): $(JUJU_VERSION)/fake-juju.go
 	case $(JUJU_VERSION) in \
 		1.*) $(MAKE) build-common PATH=$$PATH JUJU_VERSION=$(JUJU_VERSION) ;;\
 		2.*) $(MAKE) build-common PATH=/usr/lib/go-$(GO_VERSION)/bin:$$PATH JUJU_VERSION=$(JUJU_VERSION) ;;\
 
=== modified file 'python/Makefile'
--- python/Makefile	2016-10-06 21:44:31 +0000
+++ python/Makefile	2016-10-20 21:22:41 +0000
@@ -6,4 +6,4 @@
 
 .PHONY: install-dev
 install-dev:
-	ln -s $(shell pwd)/fakejuju /usr/local/lib/python2.7/dist-packages/fakejuju
+	ln -snv $(shell pwd)/fakejuju /usr/local/lib/python2.7/dist-packages/fakejuju
 
=== modified file 'python/fakejuju/fakejuju.py'
--- python/fakejuju/fakejuju.py	2016-10-17 15:54:59 +0000
+++ python/fakejuju/fakejuju.py	2016-10-20 21:22:41 +0000
@@ -2,6 +2,7 @@
 
 import os.path
 
+import txjuju
 import txjuju.cli
 
 from .failures import Failures
@@ -23,15 +24,17 @@
     return os.path.join(bindir, filename)
 
 
-def set_envvars(envvars, failures_filename=None, logsdir=None):
+def set_envvars(envvars, datadir=None, failures_filename=None, logsdir=None):
     """Return the environment variables with which to run fake-juju.
 
     @param envvars: The env dict to update.
+    @param datadir: The fake-juju data directory.
     @param failures_filename: The path to the failures file that
         fake-juju will use.
     @params logsdir: The path to the directory where fake-juju will
         write its log files.
     """
+    envvars["FAKE_JUJU_DATA_DIR"] = datadir or ""
     envvars["FAKE_JUJU_FAILURES"] = failures_filename or ""
     envvars["FAKE_JUJU_LOGS_DIR"] = logsdir or ""
 
@@ -40,46 +43,47 @@
     """The fundamental details for fake-juju."""
 
     @classmethod
-    def from_version(cls, version, cfgdir,
+    def from_version(cls, version, datadir,
                      logsdir=None, failuresdir=None, bindir=None):
         """Return a new instance given the provided information.
 
         @param version: The Juju version to fake.
-        @param cfgdir: The "juju home" directory to use.
+        @param datadir: The directory in which to store files specific
+            to fake-juju.
         @param logsdir: The directory where logs will be written.
-            This defaults to cfgdir.
+            This defaults to datadir.
         @params failuresdir: The directory where failure injection
             is managed.
         @param bindir: The directory containing the fake-juju binary.
             This defaults to /usr/bin.
         """
-        if logsdir is None:
-            logsdir = cfgdir
         if failuresdir is None:
-            failuresdir = cfgdir
+            failuresdir = datadir
         filename = get_filename(version, bindir=bindir)
         failures = Failures(failuresdir)
-        return cls(filename, version, cfgdir, logsdir, failures)
+        return cls(filename, version, datadir, logsdir, failures)
 
-    def __init__(self, filename, version, cfgdir, logsdir=None, failures=None):
+    def __init__(self, filename, version, datadir,
+                 logsdir=None, failures=None):
         """
         @param filename: The path to the fake-juju binary.
         @param version: The Juju version to fake.
-        @param cfgdir: The "juju home" directory to use.
+        @param datadir: The directory in which to store files specific
+            to fake-juju.
         @param logsdir: The directory where logs will be written.
-            This defaults to cfgdir.
+            This defaults to datadir.
         @param failures: The set of fake-juju failures to use.
         """
-        logsdir = logsdir if logsdir is not None else cfgdir
-        if failures is None and cfgdir:
-            failures = Failures(cfgdir)
+        logsdir = logsdir if logsdir is not None else datadir
+        if failures is None and datadir:
+            failures = Failures(datadir)
 
         if not filename:
             raise ValueError("missing filename")
         if not version:
             raise ValueError("missing version")
-        if not cfgdir:
-            raise ValueError("missing cfgdir")
+        if not datadir:
+            raise ValueError("missing datadir")
         if not logsdir:
             raise ValueError("missing logsdir")
         if failures is None:
@@ -87,7 +91,7 @@
 
         self.filename = filename
         self.version = version
-        self.cfgdir = cfgdir
+        self.datadir = datadir
         self.logsdir = logsdir
         self.failures = failures
 
@@ -99,19 +103,19 @@
     @property
     def infofile(self):
         """The path to fake-juju's data cache."""
-        return os.path.join(self.cfgdir, "fakejuju")
+        return os.path.join(self.datadir, "fakejuju")
 
     @property
     def fifo(self):
         """The path to the fifo file that triggers shutdown."""
-        return os.path.join(self.cfgdir, "fifo")
+        return os.path.join(self.datadir, "fifo")
 
     @property
     def cacertfile(self):
         """The path to the API server's certificate."""
-        return os.path.join(self.cfgdir, "cert.ca")
+        return os.path.join(self.datadir, "cert.ca")
 
-    def cli(self, envvars=None):
+    def cli(self, cfgdir, envvars=None):
         """Return the txjuju.cli.CLI for this fake-juju.
 
         Currently fake-juju supports only the following juju subcommands:
@@ -123,10 +127,27 @@
           Note that passwords are always omited, even if requested.
         * api-endpoints
         * destroy-environment
+
+        Note that fake-juju ignores local config files.
         """
         if envvars is None:
             envvars = os.environ
         envvars = dict(envvars)
-        set_envvars(envvars, self.failures._filename, self.logsdir)
+        set_envvars(
+            envvars, self.datadir, self.failures._filename, self.logsdir)
         return txjuju.cli.CLI.from_version(
-            self.filename, self.version, self.cfgdir, envvars)
+            self.filename, self.version, cfgdir, envvars)
+
+    def bootstrap(self, name, cfgdir, admin_secret=None):
+        """Return the CLI and APIInfo after bootstrapping from scratch."""
+        from . import get_bootstrap_spec
+        spec = get_bootstrap_spec(name, admin_secret)
+        cfgfile = txjuju.prepare_for_bootstrap(spec, self.version, cfgdir)
+        cli = self.cli(cfgdir)
+        cli.bootstrap(spec, cfgfile=cfgfile)
+        api_info = cli.api_info(spec.name)
+        return cli, api_info
+
+    def is_bootstrapped(self):
+        """Return True if a fake-juju controller is running."""
+        return os.path.exists(self.fifo)
 
=== modified file 'python/fakejuju/testing.py'
--- python/fakejuju/testing.py	2016-10-06 22:51:41 +0000
+++ python/fakejuju/testing.py	2016-10-20 21:22:41 +0000
@@ -1,6 +1,5 @@
 # Copyright 2016 Canonical Limited.  All rights reserved.
 
-import txjuju
 from fixtures import Fixture, TempDir
 from testtools.content import content_from_file
 
@@ -40,29 +39,16 @@
     def setUp(self):
         super(FakeJujuFixture, self).setUp()
         self._juju_home = self.useFixture(TempDir())
-        self._juju = fakejuju.FakeJuju.make(
-            self._juju_home.path, self._version, self._logs_dir)
+        self.fakejuju = fakejuju.FakeJuju.from_version(
+            self._version, self._juju_home.path, self._logs_dir)
 
         if not self._logs_dir:
             # Attach logs as testtools details.
             self.addDetail("log-file", content_from_file(self._juju.logfile))
 
-        spec = fakejuju.get_bootstrap_spec(self._controller, self._password)
-        cfgfile = txjuju.prepare_for_bootstrap(
-            spec, self._version, self._juju_home)
-        cli = self._juju.cli()
-        cli.bootstrap(spec, cfgfile=cfgfile)
-        api_info = cli.api_info(spec.name)
-        if self._version.startswith("1."):
-            # fake-juju doesn't give us the password, so we have to
-            # set it here.
-            api_info = api_info._replace(password=self._password)
-        self.api_info = api_info
+        self._juju, self.all_api_info = self.fakejuju.bootstrap(
+            self._controller, self._password)
 
     def cleanUp(self):
         self._juju.destroy_controller(self._controller)
         super(FakeJujuFixture, self).cleanUp()
-
-    def add_failure(self, entity):
-        """Make the given entity fail with an error status."""
-        self._juju.failures.fail_entity(entity)
 
=== modified file 'python/fakejuju/tests/test_fakejuju.py'
--- python/fakejuju/tests/test_fakejuju.py	2016-10-17 15:36:15 +0000
+++ python/fakejuju/tests/test_fakejuju.py	2016-10-20 21:22:41 +0000
@@ -1,10 +1,15 @@
 # Copyright 2016 Canonical Limited.  All rights reserved.
 
+from contextlib import contextmanager
 import os
+import shutil
+import tempfile
 import unittest
 
 from txjuju import _juju1, _juju2
 from txjuju._utils import Executable
+import txjuju.cli
+import yaml
 
 from fakejuju.failures import Failures
 from fakejuju.fakejuju import get_filename, set_envvars, FakeJuju
@@ -44,9 +49,10 @@
     def test_all_args(self):
         """set_envvars() works correctly when given all args."""
         envvars = {}
-        set_envvars(envvars, "/spam/failures", "/eggs/logsdir")
+        set_envvars(envvars, "/spam", "/spam/failures", "/eggs/logsdir")
 
         self.assertEqual(envvars, {
+            "FAKE_JUJU_DATA_DIR": "/spam",
             "FAKE_JUJU_FAILURES": "/spam/failures",
             "FAKE_JUJU_LOGS_DIR": "/eggs/logsdir",
             })
@@ -57,6 +63,7 @@
         set_envvars(envvars)
 
         self.assertEqual(envvars, {
+            "FAKE_JUJU_DATA_DIR": "",
             "FAKE_JUJU_FAILURES": "",
             "FAKE_JUJU_LOGS_DIR": "",
             })
@@ -64,9 +71,10 @@
     def test_start_empty(self):
         """set_envvars() sets all values on an empty dict."""
         envvars = {}
-        set_envvars(envvars, "x", "y")
+        set_envvars(envvars, "w", "x", "y")
 
         self.assertEqual(envvars, {
+            "FAKE_JUJU_DATA_DIR": "w",
             "FAKE_JUJU_FAILURES": "x",
             "FAKE_JUJU_LOGS_DIR": "y",
             })
@@ -74,10 +82,11 @@
     def test_no_collisions(self):
         """set_envvars() sets all values when none are set yet."""
         envvars = {"SPAM": "eggs"}
-        set_envvars(envvars, "x", "y")
+        set_envvars(envvars, "w", "x", "y")
 
         self.assertEqual(envvars, {
             "SPAM": "eggs",
+            "FAKE_JUJU_DATA_DIR": "w",
             "FAKE_JUJU_FAILURES": "x",
             "FAKE_JUJU_LOGS_DIR": "y",
             })
@@ -85,12 +94,14 @@
     def test_empty_to_nonempty(self):
         """set_envvars() updates empty values."""
         envvars = {
+            "FAKE_JUJU_DATA_DIR": "",
             "FAKE_JUJU_FAILURES": "",
             "FAKE_JUJU_LOGS_DIR": "",
             }
-        set_envvars(envvars, "x", "y")
+        set_envvars(envvars, "w", "x", "y")
 
         self.assertEqual(envvars, {
+            "FAKE_JUJU_DATA_DIR": "w",
             "FAKE_JUJU_FAILURES": "x",
             "FAKE_JUJU_LOGS_DIR": "y",
             })
@@ -98,12 +109,14 @@
     def test_nonempty_to_nonempty(self):
         """set_envvars() overwrites existing values."""
         envvars = {
+            "FAKE_JUJU_DATA_DIR": "spam",
             "FAKE_JUJU_FAILURES": "spam",
             "FAKE_JUJU_LOGS_DIR": "ham",
             }
-        set_envvars(envvars, "x", "y")
+        set_envvars(envvars, "w", "x", "y")
 
         self.assertEqual(envvars, {
+            "FAKE_JUJU_DATA_DIR": "w",
             "FAKE_JUJU_FAILURES": "x",
             "FAKE_JUJU_LOGS_DIR": "y",
             })
@@ -111,12 +124,14 @@
     def test_nonempty_to_empty(self):
         """set_envvars() with no args "unsets" existing values."""
         envvars = {
+            "FAKE_JUJU_DATA_DIR": "w",
             "FAKE_JUJU_FAILURES": "x",
             "FAKE_JUJU_LOGS_DIR": "y",
             }
         set_envvars(envvars)
 
         self.assertEqual(envvars, {
+            "FAKE_JUJU_DATA_DIR": "",
             "FAKE_JUJU_FAILURES": "",
             "FAKE_JUJU_LOGS_DIR": "",
             })
@@ -131,7 +146,7 @@
 
         self.assertEqual(juju.filename, "/bin/dir/fake-juju-1.25.6")
         self.assertEqual(juju.version, "1.25.6")
-        self.assertEqual(juju.cfgdir, "/a/juju/home")
+        self.assertEqual(juju.datadir, "/a/juju/home")
         self.assertEqual(juju.logsdir, "/logs/dir")
         self.assertEqual(juju.failures.filename, "/failures/dir/juju-failures")
 
@@ -141,19 +156,20 @@
 
         self.assertEqual(juju.filename, "/usr/bin/fake-juju-1.25.6")
         self.assertEqual(juju.version, "1.25.6")
-        self.assertEqual(juju.cfgdir, "/my/juju/home")
+        self.assertEqual(juju.datadir, "/my/juju/home")
         self.assertEqual(juju.logsdir, "/my/juju/home")
         self.assertEqual(juju.failures.filename, "/my/juju/home/juju-failures")
 
     def test_full(self):
         """FakeJuju() works correctly when given all args."""
-        cfgdir = "/my/juju/home"
-        failures = Failures(cfgdir)
-        juju = FakeJuju("/fake-juju", "1.25.6", cfgdir, "/some/logs", failures)
+        datadir = "/my/juju/home"
+        failures = Failures(datadir)
+        juju = FakeJuju(
+            "/fake-juju", "1.25.6", datadir, "/some/logs", failures)
 
         self.assertEqual(juju.filename, "/fake-juju")
         self.assertEqual(juju.version, "1.25.6")
-        self.assertEqual(juju.cfgdir, cfgdir)
+        self.assertEqual(juju.datadir, datadir)
         self.assertEqual(juju.logsdir, "/some/logs")
         self.assertIs(juju.failures, failures)
 
@@ -163,7 +179,7 @@
 
         self.assertEqual(juju.filename, "/fake-juju")
         self.assertEqual(juju.version, "1.25.6")
-        self.assertEqual(juju.cfgdir, "/my/juju/home")
+        self.assertEqual(juju.datadir, "/my/juju/home")
         self.assertEqual(juju.logsdir, "/my/juju/home")
         self.assertEqual(juju.failures.filename, "/my/juju/home/juju-failures")
 
@@ -174,7 +190,7 @@
         juju_unicode = FakeJuju(
             u"/fake-juju", u"1.25.6", u"/x", u"/y", Failures(u"/..."))
 
-        for name in ('filename version cfgdir logsdir'.split()):
+        for name in ('filename version datadir logsdir'.split()):
             self.assertIsInstance(getattr(juju_str, name), str)
             self.assertIsInstance(getattr(juju_unicode, name), unicode)
 
@@ -192,8 +208,8 @@
         with self.assertRaises(ValueError):
             FakeJuju("/fake-juju", "", "/my/juju/home")
 
-    def test_missing_cfgdir(self):
-        """FakeJuju() fails if cfgdir is None or empty."""
+    def test_missing_datadir(self):
+        """FakeJuju() fails if datadir is None or empty."""
         with self.assertRaises(ValueError):
             FakeJuju("/fake-juju", "1.25.6", None)
         with self.assertRaises(ValueError):
@@ -226,44 +242,131 @@
     def test_cli_full(self):
         """FakeJuju.cli() works correctly when given all args."""
         juju = FakeJuju("/fake-juju", "1.25.6", "/x")
-        cli = juju.cli({"SPAM": "eggs"})
+        cli = juju.cli("/y", {"SPAM": "eggs"})
 
         self.assertEqual(
             cli._exe,
             Executable("/fake-juju", {
                 "SPAM": "eggs",
+                "FAKE_JUJU_DATA_DIR": "/x",
                 "FAKE_JUJU_FAILURES": "/x/juju-failures",
                 "FAKE_JUJU_LOGS_DIR": "/x",
-                "JUJU_HOME": "/x",
+                "JUJU_HOME": "/y",
                 }),
             )
 
     def test_cli_minimal(self):
         """FakeJuju.cli() works correctly when given minimal args."""
         juju = FakeJuju("/fake-juju", "1.25.6", "/x")
-        cli = juju.cli()
+        cli = juju.cli("/y")
 
         self.assertEqual(
             cli._exe,
             Executable("/fake-juju", dict(os.environ, **{
+                "FAKE_JUJU_DATA_DIR": "/x",
                 "FAKE_JUJU_FAILURES": "/x/juju-failures",
                 "FAKE_JUJU_LOGS_DIR": "/x",
-                "JUJU_HOME": "/x",
+                "JUJU_HOME": "/y",
                 })),
             )
 
     def test_cli_juju1(self):
         """FakeJuju.cli() works correctly for Juju 1.x."""
         juju = FakeJuju.from_version("1.25.6", "/x")
-        cli = juju.cli()
+        cli = juju.cli("/y")
 
-        self.assertEqual(cli._exe.envvars["JUJU_HOME"], "/x")
+        self.assertEqual(cli._exe.envvars["JUJU_HOME"], "/y")
         self.assertIsInstance(cli._juju, _juju1.CLIHooks)
 
     def test_cli_juju2(self):
         """FakeJuju.cli() works correctly for Juju 2.x."""
         juju = FakeJuju.from_version("2.0.0", "/x")
-        cli = juju.cli()
+        cli = juju.cli("/y")
 
-        self.assertEqual(cli._exe.envvars["JUJU_DATA"], "/x")
+        self.assertEqual(cli._exe.envvars["JUJU_DATA"], "/y")
         self.assertIsInstance(cli._juju, _juju2.CLIHooks)
+
+    def test_bootstrap(self):
+        """FakeJuju.bootstrap() bootstraps from scratch using fake-juju."""
+        with tempdir() as datadir:
+            fakejuju = FakeJuju.from_version("1.25.6", datadir)
+            cfgdir = os.path.join(datadir, "juju")
+            cli, api_info = fakejuju.bootstrap("spam", cfgdir, "secret")
+            port = api_info[None].address.split(":")[-1]
+
+            files = os.listdir(datadir)
+            files.extend(os.path.join("juju", name)
+                         for name in os.listdir(cfgdir))
+            files.sort()
+            with open(os.path.join(cfgdir, "environments.yaml")) as envfile:
+                data = envfile.read()
+
+            cli.destroy_controller()
+
+        self.maxDiff = None
+        self.assertEqual(api_info, {
+            'controller': txjuju.cli.APIInfo(
+                endpoints=['localhost:' + port],
+                user='admin',
+                password='secret',
+                model_uuid='deadbeef-0bad-400d-8000-4b1d0d06f00d',
+                ),
+            None: txjuju.cli.APIInfo(
+                endpoints=['localhost:' + port],
+                user='admin',
+                password='secret',
+                model_uuid=None,
+                ),
+            })
+        self.assertItemsEqual(files, [
+            'cert.ca',
+            'fake-juju.log',
+            'fakejuju',
+            'fifo',
+            'juju',
+            'juju/environments',
+            'juju/environments.yaml',
+            ])
+        self.assertEqual(yaml.load(data), {
+            "environments": {
+                "spam": {
+                    "admin-secret": "secret",
+                    "default-series": "trusty",
+                    "type": "dummy",
+                    },
+                },
+            })
+
+    def test_is_bootstrapped_true(self):
+        """FakeJuju.is_bootstrapped() returns True if the fifo file exists."""
+        with tempdir() as datadir:
+            fakejuju = FakeJuju.from_version("1.25.6", datadir)
+            with open(fakejuju.fifo, "w"):
+                pass
+            result = fakejuju.is_bootstrapped()
+
+        self.assertTrue(result)
+
+    def test_is_bootstrapped_false(self):
+        """FakeJuju.is_bootstrapped() returns False if the fifo is gone."""
+        with tempdir() as datadir:
+            fakejuju = FakeJuju.from_version("1.25.6", datadir)
+            result = fakejuju.is_bootstrapped()
+
+        self.assertFalse(result)
+
+    def test_is_bootstrapped_datadir_missing(self):
+        """FakeJuju.is_bootstrapped() returns False if the data dir is gone."""
+        fakejuju = FakeJuju.from_version("1.25.6", "/tmp/fakejuju-no-exist")
+        result = fakejuju.is_bootstrapped()
+
+        self.assertFalse(result)
+
+
+@contextmanager
+def tempdir():
+    cfgdir = tempfile.mkdtemp("fakejuju-test-")
+    try:
+        yield cfgdir
+    finally:
+        shutil.rmtree(cfgdir)