go get github.com/anima-labs-ai/go

package main

import (
    "context"
    "fmt"
    "log"

    "github.com/anima-labs-ai/go"
)

func main() {
    ctx := context.Background()
    client := anima.NewClient("ak_...")

    // Create an agent
    agent, err := client.Agents.Create(ctx, &anima.CreateAgentParams{
        Name: "Go Agent",
    })
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Agent: %s\n", agent.ID)

    // Send an email
    _, err = client.Messages.SendEmail(ctx, &anima.SendEmailParams{
        AgentID: agent.ID,
        To:      "user@example.com",
        Subject: "Hello from Go",
        Body:    "This email was sent by an AI agent using the Go SDK.",
    })
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("Email sent!")
}

// Basic client
client := anima.NewClient("ak_...")

// Client with options
client := anima.NewClient("ak_...",
    anima.WithBaseURL("https://api.useanima.sh"),
    anima.WithTimeout(30 * time.Second),
    anima.WithRetries(3),
    anima.WithPodID("pod_prod"),
)

// Create
agent, err := client.Agents.Create(ctx, &anima.CreateAgentParams{
    Name: "Research Bot",
})

// Get
agent, err := client.Agents.Get(ctx, "ag_abc123")

// List
agents, err := client.Agents.List(ctx, &anima.ListAgentsParams{
    Limit: 20,
})

// Update
agent, err := client.Agents.Update(ctx, "ag_abc123", &anima.UpdateAgentParams{
    Name: "Updated Bot",
})

// Delete
err := client.Agents.Delete(ctx, "ag_abc123")

// Send email
msg, err := client.Messages.SendEmail(ctx, &anima.SendEmailParams{
    AgentID: "ag_abc123",
    To:      "user@example.com",
    Subject: "Hello",
    Body:    "Sent from Go",
})

// List messages
messages, err := client.Messages.List(ctx, &anima.ListMessagesParams{
    AgentID: "ag_abc123",
    Limit:   50,
})

// Get a message
msg, err := client.Messages.Get(ctx, "msg_xyz789")

// Store a secret
secret, err := client.Vault.Store(ctx, &anima.StoreSecretParams{
    AgentID: "ag_abc123",
    Key:     "openai_key",
    Value:   "sk-...",
    Tags:    []string{"llm", "production"},
})

// Retrieve a secret
secret, err := client.Vault.Get(ctx, "ag_abc123", "openai_key")
fmt.Println(secret.Value)

// List secrets (metadata only)
secrets, err := client.Vault.List(ctx, &anima.ListSecretsParams{
    AgentID: "ag_abc123",
})

// Resolve DID
doc, err := client.Identity.ResolveDID(ctx, "did:web:agents.useanima.sh:org_abc123:ag_abc123")

// Issue a credential
cred, err := client.Identity.Credentials.Issue(ctx, &anima.IssueCredentialParams{
    AgentID: "ag_abc123",
    Type:    "AgentAuthorization",
    Claims:  map[string]any{"role": "purchasing-agent"},
})

// Publish Agent Card
card, err := client.Identity.AgentCards.Publish(ctx, &anima.PublishAgentCardParams{
    AgentID: "ag_abc123",
    Domain:  "agent.acme.com",
})

// Submit a task to one of your own agents
task, err := client.A2A.SubmitTask(ctx, "ag_receiver", anima.SubmitA2ATaskParams{
    Input: map[string]any{"dataset": "q1-sales"},
})

// Get task result
task, err = client.A2A.GetTask(ctx, "ag_receiver", task.ID)
fmt.Printf("Status: %s\n", task.Status)

// Dispatch a signed task to another agent by DID
task, err = client.A2A.Dispatch(ctx, "ag_sender", anima.DispatchA2ATaskParams{
    ToDID: "did:web:agents.useanima.sh:org_xyz:ag_receiver",
    Type:  "purchase-order",
    Input: map[string]any{"budget": 200},
})

// Discover another agent's public Agent Card
card, err := client.A2A.Discover(ctx, "https://receiver.useanima.sh")

// Create a wallet
wallet, err := client.Wallet.Create(ctx, &anima.CreateWalletParams{
    AgentID:  "ag_abc123",
    Currency: "usd",
    BudgetGuards: &anima.BudgetGuards{
        DailyLimitCents: 50000,
    },
})

// Check balance
balance, err := client.Wallet.GetBalance(ctx, wallet.ID)
fmt.Printf("Available: %d cents\n", balance.AvailableCents)

// Create a webhook, with the auth Anima presents to your endpoint
// (on top of the X-Anima-Signature HMAC) plus delivery throttling.
rateLimit, maxAttempts := 120, 5
wh, err := client.Webhooks.Create(ctx, anima.CreateWebhookParams{
    URL:    "https://example.com/hooks/anima",
    Events: []anima.WebhookEventType{anima.WebhookEventMessageReceived},
    // Also: NewBasicAuth(user, pass), NewCustomHeaderAuth(name, value), NewNoAuth().
    AuthConfig:         anima.NewBearerAuth("your-endpoint-token"),
    RateLimitPerMinute: &rateLimit,  // omit for unlimited
    MaxAttempts:        &maxAttempts, // 1-10, default 3
})

// The credential is write-only — only the scheme (wh.AuthType) is returned.
fmt.Println(wh.ID, wh.AuthType)

agent, err := client.Agents.Get(ctx, "ag_nonexistent")
if err != nil {
    var apiErr *anima.APIError
    if errors.As(err, &apiErr) {
        fmt.Printf("API error: %d %s\n", apiErr.StatusCode, apiErr.Message)
        fmt.Printf("Request ID: %s\n", apiErr.RequestID)
    }
    log.Fatal(err)
}

var allAgents []anima.Agent
cursor := ""

for {
    result, err := client.Agents.List(ctx, &anima.ListAgentsParams{
        Limit:  100,
        Cursor: cursor,
    })
    if err != nil {
        log.Fatal(err)
    }

    allAgents = append(allAgents, result.Data...)

    if !result.HasMore {
        break
    }
    cursor = result.NextCursor
}