chore: Close file after write

Signed-off-by: Javier Aliaga <javier@diagrid.io>

Author: javier-aliaga

bindings/sftp/sftp.go

@@ -173,6 +173,13 @@ func (sftp *Sftp) create(_ context.Context, req *bindings.InvokeRequest) (*bindi
 		return nil, fmt.Errorf("sftp binding error: error create file %s: %w", path, err)
 	}
 
+	defer func() {
+		closeErr := file.Close()
+		if closeErr != nil {
+			sftp.logger.Errorf("sftp binding error: error close file: %s", closeErr)
+		}
+	}()
+
 	_, err = file.Write(req.Data)
 	if err != nil {
 		return nil, fmt.Errorf("sftp binding error: error write file: %w", err)

bindings/sftp/sftp_integration_test.go

@@ -0,0 +1,74 @@
+package sftp
+
+import (
+	"encoding/json"
+	"os"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	"github.com/dapr/components-contrib/bindings"
+)
+
+var connectionStringEnvKey = "DAPR_TEST_SFTP_CONNSTRING"
+
+//	docker run \
+//	   -v ./upload:/home/foo/upload \
+//	   -p 2222:22 -d atmoz/sftp \
+//	   foo:pass:1001
+func TestIntegrationCases(t *testing.T) {
+	connectionString := os.Getenv(connectionStringEnvKey)
+	if connectionString == "" {
+		t.Skipf(`sftp binding integration tests skipped. To enable this test, define the connection string using environment variable '%[1]s' (example 'export %[1]s="localhost:2222")'`, connectionStringEnvKey)
+	}
+
+	t.Run("List operation", testListOperation)
+	t.Run("Create operation", testCreateOperation)
+}
+
+func testListOperation(t *testing.T) {
+	c := Sftp{}
+	m := bindings.Metadata{}
+	m.Properties = map[string]string{
+		"rootPath":              "/upload",
+		"address":               os.Getenv(connectionStringEnvKey),
+		"username":              "foo",
+		"password":              "pass",
+		"insecureIgnoreHostKey": "true",
+	}
+	err := c.Init(t.Context(), m)
+	require.NoError(t, err)
+
+	r, err := c.Invoke(t.Context(), &bindings.InvokeRequest{Operation: bindings.ListOperation})
+	require.NoError(t, err)
+	assert.NotNil(t, r.Data)
+
+	var d []listResponse
+	err = json.Unmarshal(r.Data, &d)
+	require.NoError(t, err)
+}
+
+func testCreateOperation(t *testing.T) {
+	c := Sftp{}
+	m := bindings.Metadata{}
+	m.Properties = map[string]string{
+		"rootPath":              "/upload",
+		"address":               os.Getenv(connectionStringEnvKey),
+		"username":              "sftpuser",
+		"password":              "sftpsecret",
+		"insecureIgnoreHostKey": "true",
+	}
+	err := c.Init(t.Context(), m)
+	require.NoError(t, err)
+
+	r, err := c.Invoke(t.Context(), &bindings.InvokeRequest{
+		Operation: bindings.CreateOperation,
+		Data:      []byte("test data 1"),
+		Metadata: map[string]string{
+			"fileName": "test.txt",
+		},
+	})
+	require.NoError(t, err)
+	assert.NotNil(t, r.Data)
+}

minio/bootstrap/user-s3.json

@@ -0,0 +1,17 @@
+{
+  "status": 1,
+  "username": "sftpuser",
+  "password": "sftpsecret",
+  "permissions": { "/": ["*"] },
+  "filesystem": {
+    "provider": 1,
+    "s3config": {
+      "bucket": "sftp-bucket",
+      "region": "us-east-1",
+      "endpoint": "http://minio:9000",
+      "access_key": "minioadmin",
+      "access_secret": { "status": "Plain", "payload": "minioadmin123" },
+      "force_path_style": true
+    }
+  }
+}