summaryrefslogtreecommitdiff
path: root/adapters
diff options
context:
space:
mode:
Diffstat (limited to 'adapters')
-rw-r--r--adapters/external_dns/cloudflare/cloudflare.go (renamed from adapters/cloudflare/cloudflare.go)0
-rw-r--r--adapters/external_dns/external_dns.go (renamed from adapters/external_dns.go)0
-rw-r--r--adapters/files/files_adapter.go8
-rw-r--r--adapters/files/filesystem/filesystem.go37
4 files changed, 45 insertions, 0 deletions
diff --git a/adapters/cloudflare/cloudflare.go b/adapters/external_dns/cloudflare/cloudflare.go
index c302037..c302037 100644
--- a/adapters/cloudflare/cloudflare.go
+++ b/adapters/external_dns/cloudflare/cloudflare.go
diff --git a/adapters/external_dns.go b/adapters/external_dns/external_dns.go
index c861283..c861283 100644
--- a/adapters/external_dns.go
+++ b/adapters/external_dns/external_dns.go
diff --git a/adapters/files/files_adapter.go b/adapters/files/files_adapter.go
new file mode 100644
index 0000000..bf3ea5f
--- /dev/null
+++ b/adapters/files/files_adapter.go
@@ -0,0 +1,8 @@
+package files
+
+import "io"
+
+type FilesAdapter interface {
+ CreateFile(path string, content io.Reader) (string, error)
+ DeleteFile(path string) error
+}
diff --git a/adapters/files/filesystem/filesystem.go b/adapters/files/filesystem/filesystem.go
new file mode 100644
index 0000000..726a588
--- /dev/null
+++ b/adapters/files/filesystem/filesystem.go
@@ -0,0 +1,37 @@
+package filesystem
+
+import (
+ "io"
+ "os"
+ "path/filepath"
+)
+
+type FilesystemAdapter struct {
+ BasePath string
+ Permissions os.FileMode
+}
+
+func (f *FilesystemAdapter) CreateFile(path string, content io.Reader) (string, error) {
+ fullPath := f.BasePath + path
+ dir := filepath.Dir(fullPath)
+ if _, err := os.Stat(dir); os.IsNotExist(err) {
+ os.MkdirAll(dir, f.Permissions)
+ }
+
+ file, err := os.Create(f.BasePath + path)
+ if err != nil {
+ return "", err
+ }
+ defer file.Close()
+
+ _, err = io.Copy(file, content)
+ if err != nil {
+ return "", err
+ }
+
+ return path, nil
+}
+
+func (f *FilesystemAdapter) DeleteFile(path string) error {
+ return os.Remove(f.BasePath + path)
+}