Getting Started

go get github.com/chainstream-io/chainstream-go-sdk

package main

import (
    "log"
    "github.com/chainstream-io/chainstream-go-sdk"
)

func main() {
    // Initialize the client
    client, err := chainstream.NewDexClient("YOUR_ACCESS_TOKEN", &chainstream.DexAggregatorOptions{
        ServerUrl: "https://api-dex.chainstream.io",
        StreamUrl: "wss://realtime-dex.chainstream.io/connection/websocket",
    })
    if err != nil {
        log.Fatal(err)
    }
    defer client.Close()
}

// Get token details
tokenInfo, err := client.Token.GetToken(context.Background(), "sol", "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN")
if err != nil {
    log.Fatal(err)
}

// Subscribe to candle data
unsubscribe, err := client.Stream.SubscribeTokenCandles(&api.SubscribeTokenCandlesRequest{
    Chain:        "sol",
    TokenAddress: "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
    Resolution:   "1m",
    Callback: func(candle *api.TokenCandle) {
        log.Printf("New candle: %+v", candle)
    },
})
if err != nil {
    log.Fatal(err)
}
defer unsubscribe()

type MyTokenProvider struct {
    // Your token provider implementation
}

func (p *MyTokenProvider) GetToken() (string, error) {
    // Return current token
    return "your-current-token", nil
}

// Initialize with token provider
client, err := chainstream.NewDexClientWithTokenProvider(&MyTokenProvider{}, &chainstream.DexAggregatorOptions{})