package main

import (
    "log"

    "go.beyondstorage.io/v5/services"
    "go.beyondstorage.io/v5/types"

    // Добавляем поддержку файловой системы
    _ "go.beyondstorage.io/services/fs/v4"
    // Добавляем поддержку S3
    _ "go.beyondstorage.io/services/s3/v3"
    // Добавляем поддержку GCS
    _ "go.beyondstorage.io/services/gcs/v3"
    // Добавляем поддержку Azure Blob Storage
    _ "go.beyondstorage.io/services/azblob/v3"
    // Больше поддержки можно найти в BeyondStorage.
    _ "go.beyondstorage.io/services/xxx" 
)

func main() {
    // Инициализируем Storager из строки подключения. 
    store, err := services.NewStoragerFromString("s3://bucket_name/path/to/workdir")
    if err != nil {
        log.Fatalf("service init failed: %v", err)
    }

    // Записываем данные из io.Reader в hello.txt
    n, err := store.Write("hello.txt", r, length)

    // Считываем данные из hello.txt в io.Writer
    n, err := store.Read("hello.txt", w)

    // Получаем метаданные объекта hello.txt с помощью Stat
    o, err := store.Stat("hello.txt")

    // Используем функции объекта для получения метаданных
    length, ok := o.GetContentLength()
    
    // List создаёт итератор объектов под путём.
    it, err := store.List("path")
    
    for {
        // Используем iterator.Next для извлечения следующего объекта, пока не встретим IterateDone.
        o, err := it.Next()
        if errors.Is(err, types.IterateDone) {
            break
        }
    }

    // Удаляем hello.txt
    err = store.Delete("hello.txt")
}

meta := store.Metadata()
_ := meta.GetWorkDir() // Получить объект WorkDir
_, ok := meta.GetWriteSizeMaximum() // Получить максимальный размер для операции записи

// Прочитать 2048 байт со смещением 1024 в io.Writer.
n, err := store.Read("path", w, pairs.WithOffset(1024), pairs.WithSize(2048))

// Записать 2048 байт из io.Reader
n, err := store.Write("path", r, 2048)

o, err := store.Stat("path")
if errors.Is(err, services.ErrObjectNotExist) {
    // объект не существует
}
length, ok := o.GetContentLength() // получить длину содержимого объекта.

err := store.Delete("path") // Удалить объект "path"

it, err := store.List("path")
for {
    o, err := it.Next()
    if err != nil && errors.Is(err, types.IterateDone) {
        // список завершён
    }
    length, ok := o.GetContentLength() // получить длину содержимого объекта.
}

err := store.(Copier).Copy(src, dst) // Скопировать объект из src в dst.

err := store.(Mover).Move(src, dst) // Переместить объект из src в dst.

url, err := store.(Reacher).Reach("path") // Сгенерировать URL для объекта.

o, err := store.(Direr).CreateDir("path") // Создать объект dir.

ms := store.(Multiparter)

// Создать многокомпонентный объект.
o, err := ms.CreateMultipart("path")
// Записать 1024 байта из io.Reader в многокомпонентную часть с индексом 1
n, part, err := ms.WriteMultipart(o, r, 1024, 1)
// Завершить многокомпонентный объект. **err := ms.CompleteMultipart(o, []*Part{part})**

err = ms.CompleteMultipart (o, *Part {part}).

**Append: allow appending to an object**

```go
as := store.(Appender)
// Создаём объект, к которому можно добавить данные.
o, err := as.CreateAppend("path")
// Записываем 1024 байта из io.Reader.
n, err := as.WriteAppend(o, r, 1024)
// Фиксируем изменения в добавленном объекте.
err = as.CommitAppend(o)

bs := store.(Blocker)
// Создаем блочный объект.
o, err := bs.CreateBlock("path")
// Пишем 1024 байта из io.Reader с идентификатором блока "id-abc".
n, err := bs.WriteBlock(o, r, 1024, "id-abc")
// Объединяем блоки по идентификаторам.
err := bs.CombineBlock(o, []string{"id-abc"})

ps := store.(Pager)
// Создаём страничный объект.
o, err := ps.CreatePage("path")
// Записываем 1024 байта из io.Reader со смещением 2048.
n, err := ps.WritePage(o, r, 1024, 2048)

o, err := store.Stat("path")

// Получаем системные метаданные сервиса через API, предоставляемый go-service-s3.
om := s3.GetObjectSystemMetadata(o)
_ = om.StorageClass // класс хранения этого объекта
_ = om.ServerSideEncryptionCustomerAlgorithm // алгоритм шифрования SSE этого объекта

func WithContentMd5(v string) Pair {
    return Pair{
        Key:   "content_md5",
        Value: v,
    }
}

func (o *Object) GetContentMd5() (string, bool) {
    o.stat()
    
    if o.bit&objectIndexContentMd5 != 0 {
        return o.contentMd5, true
    }
    
    return "", false
}

func NewS3SseC(key []byte) (types.Storager, error) {
    defaultPairs := s3.DefaultStoragePairs{
        Write: []types.Pair{
            // Required, must be AES256
            s3.WithServerSideEncryptionCustomerAlgorithm(s3.ServerSideEncryptionAes256),
            // Required, your AES-256 key, a 32-byte binary value
            s3.WithServerSideEncryptionCustomerKey(key),
        },
        // Now you have to provide customer key to read encrypted data
        Read: []types.Pair{
            // Required, must be AES256
            s3.WithServerSideEncryptionCustomerAlgorithm(s3.ServerSideEncryptionAes256),
            // Required, your AES-256 key, a 32-byte binary value
            s3.WithServerSideEncryptionCustomerKey(key),
        }}
    
    return s3.NewStorager(..., s3.WithDefaultStoragePairs(defaultPairs))
}