fix non-existing component dir error (#199)

dapr · Nov 6, 2019 · d793380 · d793380
1 parent 997ab8c
commit d793380
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/pkg/standalone/run.go b/pkg/standalone/run.go
@@ -185,7 +185,6 @@ func createRedisStateStore(redisHost string) error {
 		return err
 	}
 
-	os.Mkdir(componentsDir, 0777)
 	err = ioutil.WriteFile(path.Join(componentsDir, redisStateStoreYamlFileName), b, 0644)
 	if err != nil {
 		return err
@@ -194,6 +193,13 @@ func createRedisStateStore(redisHost string) error {
 	return nil
 }
 
+func createDirectory(dir string) error {
+	if _, err := os.Stat(dir); !os.IsNotExist(err) {
+		return nil
+	}
+	return os.Mkdir(dir, 0777)
+}
+
 func createRedisPubSub(redisHost string) error {
 	redisMessageBus := component{
 		APIVersion: "dapr.io/v1alpha1",
@@ -222,7 +228,6 @@ func createRedisPubSub(redisHost string) error {
 		return err
 	}
 
-	os.Mkdir(componentsDir, 0777)
 	err = ioutil.WriteFile(path.Join(componentsDir, redisMessageBusYamlFileName), b, 0644)
 	if err != nil {
 		return err
@@ -252,6 +257,10 @@ func Run(config *RunConfig) (*RunOutput, error) {
 	if err != nil {
 		return nil, err
 	}
+	err = createDirectory(componentsDir)
+	if err != nil {
+		return nil, err
+	}
 
 	componentsLoader := components.NewStandaloneComponents(modes.StandaloneConfig{ComponentsPath: componentsDir})
 	components, err := componentsLoader.LoadComponents()