summaryrefslogtreecommitdiff
path: root/internal/blob
diff options
context:
space:
mode:
authorLibravatar kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com>2021-09-12 10:10:24 +0100
committerLibravatar GitHub <noreply@github.com>2021-09-12 10:10:24 +0100
commitf6492d12d948507021bbe934de94e87e20464c01 (patch)
tree6705d6ef6f3c4d70f3b3ebc77c2960d8e508cf37 /internal/blob
parentMerge pull request #213 from superseriousbusiness/alpine+node_upstep (diff)
parentfix keys used to access storage items (diff)
downloadgotosocial-f6492d12d948507021bbe934de94e87e20464c01.tar.xz
Merge pull request #214 from NyaaaWhatsUpDoc/improvement/update-storage-library
add git.iim.gay/grufwub/go-store for storage backend, replacing blob.Storage
Diffstat (limited to 'internal/blob')
-rw-r--r--internal/blob/inmem.go55
-rw-r--r--internal/blob/local.go70
-rw-r--r--internal/blob/storage.go29
3 files changed, 0 insertions, 154 deletions
diff --git a/internal/blob/inmem.go b/internal/blob/inmem.go
deleted file mode 100644
index 6ea64bcfe..000000000
--- a/internal/blob/inmem.go
+++ /dev/null
@@ -1,55 +0,0 @@
-package blob
-
-import (
- "fmt"
-
- "github.com/sirupsen/logrus"
- "github.com/superseriousbusiness/gotosocial/internal/config"
-)
-
-// NewInMem returns an in-memory implementation of the Storage interface.
-// This is good for testing and whatnot but ***SHOULD ABSOLUTELY NOT EVER
-// BE USED IN A PRODUCTION SETTING***, because A) everything will be wiped out
-// if you restart the server and B) if you store lots of images your RAM use
-// will absolutely go through the roof.
-func NewInMem(c *config.Config, log *logrus.Logger) (Storage, error) {
- return &inMemStorage{
- stored: make(map[string][]byte),
- log: log,
- }, nil
-}
-
-type inMemStorage struct {
- stored map[string][]byte
- log *logrus.Logger
-}
-
-func (s *inMemStorage) StoreFileAt(path string, data []byte) error {
- l := s.log.WithField("func", "StoreFileAt")
- l.Debugf("storing at path %s", path)
- s.stored[path] = data
- return nil
-}
-
-func (s *inMemStorage) RetrieveFileFrom(path string) ([]byte, error) {
- l := s.log.WithField("func", "RetrieveFileFrom")
- l.Debugf("retrieving from path %s", path)
- d, ok := s.stored[path]
- if !ok || len(d) == 0 {
- return nil, fmt.Errorf("no data found at path %s", path)
- }
- return d, nil
-}
-
-func (s *inMemStorage) ListKeys() ([]string, error) {
- keys := []string{}
- for k := range s.stored {
- keys = append(keys, k)
- }
- return keys, nil
-}
-
-func (s *inMemStorage) RemoveFileAt(path string) error {
- delete(s.stored, path)
- return nil
-}
diff --git a/internal/blob/local.go b/internal/blob/local.go
deleted file mode 100644
index 01f82f8d2..000000000
--- a/internal/blob/local.go
+++ /dev/null
@@ -1,70 +0,0 @@
-package blob
-
-import (
- "fmt"
- "os"
- "path/filepath"
- "strings"
-
- "github.com/sirupsen/logrus"
- "github.com/superseriousbusiness/gotosocial/internal/config"
-)
-
-// NewLocal returns an implementation of the Storage interface that uses
-// the local filesystem for storing and retrieving files, attachments, etc.
-func NewLocal(c *config.Config, log *logrus.Logger) (Storage, error) {
- return &localStorage{
- config: c,
- log: log,
- }, nil
-}
-
-type localStorage struct {
- config *config.Config
- log *logrus.Logger
-}
-
-func (s *localStorage) StoreFileAt(path string, data []byte) error {
- l := s.log.WithField("func", "StoreFileAt")
- l.Debugf("storing at path %s", path)
- components := strings.Split(path, "/")
- dir := strings.Join(components[0:len(components)-1], "/")
- if err := os.MkdirAll(dir, 0777); err != nil {
- return fmt.Errorf("error writing file at %s: %s", path, err)
- }
- if err := os.WriteFile(path, data, 0777); err != nil {
- return fmt.Errorf("error writing file at %s: %s", path, err)
- }
- return nil
-}
-
-func (s *localStorage) RetrieveFileFrom(path string) ([]byte, error) {
- l := s.log.WithField("func", "RetrieveFileFrom")
- l.Debugf("retrieving from path %s", path)
- b, err := os.ReadFile(path)
- if err != nil {
- return nil, fmt.Errorf("error reading file at %s: %s", path, err)
- }
- return b, nil
-}
-
-func (s *localStorage) ListKeys() ([]string, error) {
- keys := []string{}
- err := filepath.Walk(s.config.StorageConfig.BasePath, func(path string, info os.FileInfo, err error) error {
- if err != nil {
- return err
- }
- if !info.IsDir() {
- keys = append(keys, path)
- }
- return nil
- })
- if err != nil {
- return nil, err
- }
- return keys, nil
-}
-
-func (s *localStorage) RemoveFileAt(path string) error {
- return os.Remove(path)
-}
diff --git a/internal/blob/storage.go b/internal/blob/storage.go
deleted file mode 100644
index d1deb740f..000000000
--- a/internal/blob/storage.go
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- GoToSocial
- Copyright (C) 2021 GoToSocial Authors admin@gotosocial.org
-
- This program is free software: you can redistribute it and/or modify
- it under the terms of the GNU Affero General Public License as published by
- the Free Software Foundation, either version 3 of the License, or
- (at your option) any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Affero General Public License for more details.
-
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see <http://www.gnu.org/licenses/>.
-*/
-
-package blob
-
-// Storage is an interface for storing and retrieving blobs
-// such as images, videos, and any other attachments/documents
-// that shouldn't be stored in a database.
-type Storage interface {
- StoreFileAt(path string, data []byte) error
- RetrieveFileFrom(path string) ([]byte, error)
- ListKeys() ([]string, error)
- RemoveFileAt(path string) error
-}