Walrus Go SDK

The walrus-go SDK provides a Go client for interacting with the Walrus HTTP API. Walrus is a decentralized storage system built on the Sui blockchain, allowing you to store and retrieve blobs efficiently.

Table of Contents

• Features
• Installation
• Getting Started
  • Initializing the Client
  • Storing Data
  • Retrieving Data
  • Storing and Retrieving Files
• API Reference
  • Client
  • StoreOptions
  • Methods
    • Store
    • StoreReader
    • StoreFromURL
    • StoreFile
    • Head
    • Read
    • ReadToFile
    • GetAPISpec
    • ReadToReader
• Contributing
• License

Features

• Store data and files on the Walrus Publisher.
• Retrieve data and files from the Walrus Aggregator.
• Supports specifying storage epochs.
• Handles response parsing and error handling.

Installation

To install the walrus-go SDK, use go get:

go get github.com/suiet/walrus-go

Replace github.com/suiet/walrus-go with the actual import path of your module.

Getting Started

Below is a guide to help you start using the walrus-go SDK in your Go projects.

Initializing the Client

First, import the walrus package and create a new client instance:

package main

import (
    "github.com/suiet/walrus-go"
)

func main() {
    client := walrus.NewClient(
        "https://aggregator.walrus-testnet.walrus.space",
        "https://publisher.walrus-testnet.walrus.space",
    )

    // Your code here
}

Replace the URLs with the aggregator and publisher endpoints you wish to use.

Storing Data

You can store data on the Walrus Publisher using the Store method:

data := []byte("some string")
resp, err := client.Store(data, &walrus.StoreOptions{Epochs: 1})
if err != nil {
    log.Fatalf("Error storing data: %v", err)
}

// Check response type and handle accordingly
if resp.NewlyCreated != nil {
    blobID := resp.NewlyCreated.BlobObject.BlobID
    fmt.Printf("Stored new blob ID: %s with cost: %d\n",
        blobID, resp.NewlyCreated.Cost)
} else if resp.AlreadyCertified != nil {
    blobID := resp.AlreadyCertified.BlobID
    fmt.Printf("Blob already exists with ID: %s, end epoch: %d\n",
        blobID, resp.AlreadyCertified.EndEpoch)
}

Methods

Store

Stores data on the Walrus Publisher and returns detailed response information.

func (c *Client) Store(data []byte, opts *StoreOptions) (*StoreResponse, error)

Parameters:

• data []byte: The data to store.
• opts *StoreOptions: Storage options, such as the number of epochs.

Returns:

• *StoreResponse: The complete response containing either NewlyCreated or AlreadyCertified information.
• error: Error if the operation fails.

StoreReader

Stores data from an io.Reader on the Walrus Publisher.

func (c *Client) StoreReader(reader io.Reader, contentLength int64, opts *StoreOptions) (*StoreResponse, error)

Parameters:

• reader io.Reader: The source to read data from.
• contentLength int64: The total size of the data to be stored. Use -1 if unknown.
• opts *StoreOptions: Storage options, such as the number of epochs.

Returns:

• *StoreResponse: The complete response containing either NewlyCreated or AlreadyCertified information.
• error: Error if the operation fails.

StoreFromURL

Downloads and stores content from a URL on the Walrus Publisher.

func (c *Client) StoreFromURL(sourceURL string, opts *StoreOptions) (*StoreResponse, error)

Parameters:

• sourceURL string: The URL to download content from.
• opts *StoreOptions: Storage options, such as the number of epochs.

Returns:

• *StoreResponse: The complete response containing either NewlyCreated or AlreadyCertified information.
• error: Error if the operation fails.

StoreFile

Stores a file on the Walrus Publisher.

func (c *Client) StoreFile(filePath string, opts *StoreOptions) (*StoreResponse, error)

Parameters:

• filePath string: Path to the file to store.
• opts *StoreOptions: Storage options.

Returns:

• *StoreResponse: The complete response containing either NewlyCreated or AlreadyCertified information.
• error: Error if the operation fails.

Head

Retrieves blob metadata from the Walrus Aggregator without downloading the content.

func (c *Client) Head(blobID string) (*BlobMetadata, error)

Parameters:

• blobID string: The blob ID to get metadata for.

Returns:

• *BlobMetadata: Contains metadata information including:
  • ContentLength: Size of the blob in bytes
  • ContentType: MIME type of the content
  • LastModified: Last modification timestamp
  • ETag: Entity tag for cache validation
• error: Error if the operation fails.

Example:

metadata, err := client.Head("your-blob-id")
if err != nil {
    log.Fatalf("Error getting metadata: %v", err)
}
fmt.Printf("Blob size: %d bytes\n", metadata.ContentLength)
fmt.Printf("Content type: %s\n", metadata.ContentType)
fmt.Printf("Last modified: %s\n", metadata.LastModified)

Retrieving Data

Retrieve the stored data using the Read method:

retrievedData, err := client.Read(blobID)
if err != nil {
    log.Fatalf("Error reading data: %v", err)
}
fmt.Printf("Retrieved data: %s\n", string(retrievedData))

Storing and Retrieving Files

Store a file on the Walrus Publisher:

fileBlobID, err := client.StoreFile("path/to/your/file.txt", &walrus.StoreOptions{Epochs: 5})
if err != nil {
    log.Fatalf("Error storing file: %v", err)
}
fmt.Printf("Stored file blob ID: %s\n", fileBlobID)

Retrieve the file and save it locally:

err = client.ReadToFile(fileBlobID, "path/to/save/file.txt")
if err != nil {
    log.Fatalf("Error reading file: %v", err)
}
fmt.Println("File retrieved successfully")

ReadToReader

Retrieves a blob and returns an io.ReadCloser for streaming the content.

func (c *Client) ReadToReader(blobID string) (io.ReadCloser, error)

Parameters:

• blobID string: The blob ID to retrieve.

Returns:

• io.ReadCloser: A reader containing the blob content. Remember to close it after use.
• error: Error if the operation fails.

Example:

reader, err := client.ReadToReader("your-blob-id")
if err != nil {
    log.Fatalf("Error getting reader: %v", err)
}
defer reader.Close()

// Use the reader as needed
_, err = io.Copy(os.Stdout, reader)
if err != nil {
    log.Fatalf("Error reading content: %v", err)
}

API Reference

Client

The Client struct is used to interact with the Walrus API.

Fields

• AggregatorURL string: The base URL of the Walrus Aggregator.
• PublisherURL string: The base URL of the Walrus Publisher.
• httpClient *http.Client: The HTTP client used for requests.

NewClient

Creates a new Client instance.

func NewClient(aggregatorURL, publisherURL string) *Client

Parameters:

• aggregatorURL string: The aggregator's base URL.
• publisherURL string: The publisher's base URL.

StoreOptions

Options for storing data.

Fields

• Epochs int: Number of storage epochs. Determines how long the data is stored.

Methods

Store

Stores data on the Walrus Publisher.

func (c *Client) Store(data []byte, opts *StoreOptions) (string, error)

Parameters:

• data []byte: The data to store.
• opts *StoreOptions: Storage options, such as the number of epochs.

Returns:

• string: The blob ID of the stored data.
• error: Error if the operation fails.

StoreFile

Stores a file on the Walrus Publisher.

func (c *Client) StoreFile(filePath string, opts *StoreOptions) (string, error)

Parameters:

• filePath string: Path to the file to store.
• opts *StoreOptions: Storage options.

Returns:

• string: The blob ID of the stored file.
• error: Error if the operation fails.

Read

Retrieves data from the Walrus Aggregator.

func (c *Client) Read(blobID string) ([]byte, error)

Parameters:

• blobID string: The blob ID of the data to retrieve.

Returns:

• []byte: The retrieved data.
• error: Error if the operation fails.

ReadToFile

Retrieves data and saves it to a file.

func (c *Client) ReadToFile(blobID, filePath string) error

Parameters:

• blobID string: The blob ID of the data to retrieve.
• filePath string: Path to save the retrieved file.

Returns:

• error: Error if the operation fails.

GetAPISpec

Retrieves the API specification from the aggregator or publisher.

func (c *Client) GetAPISpec(isAggregator bool) ([]byte, error)

Parameters:

• isAggregator bool: Set to true to get the aggregator's API spec; false for the publisher.

Returns:

• []byte: The API specification data.
• error: Error if the operation fails.

ReadToReader

Retrieves a blob and returns an io.ReadCloser for streaming the content.

func (c *Client) ReadToReader(blobID string) (io.ReadCloser, error)

Parameters:

• blobID string: The blob ID to retrieve.

Returns:

• io.ReadCloser: A reader containing the blob content. Remember to close it after use.
• error: Error if the operation fails.

Example:

reader, err := client.ReadToReader("your-blob-id")
if err != nil {
    log.Fatalf("Error getting reader: %v", err)
}
defer reader.Close()

// Use the reader as needed
_, err = io.Copy(os.Stdout, reader)
if err != nil {
    log.Fatalf("Error reading content: %v", err)
}

Contributing

Contributions are welcome! Please open an issue or submit a pull request on GitHub.

1. Fork the repository.
2. Create a new branch (git checkout -b feature/your-feature).
3. Commit your changes (git commit -am 'Add new feature').
4. Push to the branch (git push origin feature/your-feature).
5. Open a pull request.

License

This project is licensed under the MIT License. See the LICENSE file for details.

Contact

For any questions or support, please open an issue on the GitHub repository.