import (
	"log"
	"time"
	"github.com/hysuki/go-upbit"
)

func main() {
	client, err := upbit.NewUpbitClient(
		upbit.WithKeys("ACCESS_KEY", "SECRET_KEY"),
		upbit.WithPingInterval(30*time.Second),
	)
	if err != nil {
		log.Fatal(err)
	}
}

REST API 사용 예시

// 마켓 코드 조회
markets, err := client.RestAPI.GetQuotation().GetMarkets(false)
if err != nil {
	log.Printf("에러: %v", err)
	return
}
log.Printf("마켓 목록: %+v", markets)

// 계좌 조회
accounts, err := client.RestAPI.GetExchange().GetAccounts()
if err != nil {
	log.Printf("에러: %v", err)
	return
}
log.Printf("계좌 정보: %+v", accounts)

// 주문하기
order, err := client.RestAPI.GetExchange().CreateOrder(&exchange.CreateOrderRequest{
	Market:    "KRW-BTC",
	Side:      exchange.OrderSideBid,
	Volume:    "0.01",
	Price:     "30000000",
	OrderType: exchange.OrderTypeLimit,
})
if err != nil {
	log.Printf("에러: %v", err)
	return
}
log.Printf("주문 결과: %+v", order)

WebSocket API 사용 예시

// 원화 마켓 코드 필터링
var codes []string
markets, err := client.RestAPI.GetQuotation().GetMarkets(false)
if err != nil {
    log.Fatal(err)
}

for _, market := range markets {
    if strings.HasPrefix(market.Market, "KRW-") {
        codes = append(codes, market.Market)
    }
}

// WebSocket 구독 설정
isOnlyRealtime := true
opts := common.SubscribeOptions{
    IsOnlyRealtime: &isOnlyRealtime,
}

client.PublicWS.Subscribe(nil,
    public.AddSubscribe(public.MessageTypeOrderbook, codes, &opts),
    public.AddSubscribe(public.MessageTypeTicker, codes, &opts),
    public.AddSubscribe(public.MessageTypeTrade, codes, &opts),
)

// 메시지 핸들러 시작
client.PublicWS.StartMessageHandler()

// 현재가 정보 처리
go func() {
    onTicker(ctx, client, func(ticker *public.Ticker) {
        log.Printf("현재가: %+v", ticker)
    })
}()

// 체결 정보 처리
tradeChan := make(chan *public.Trade, 1000)
go func() {
    onTrade(ctx, client, func(trade *public.Trade) {
        log.Printf("체결: %+v", trade)
        tradeChan <- trade
    })
}()

// 호가 정보 처리
go func() {
    onOrderBook(ctx, client, func(orderBook *public.Orderbook) {
        log.Printf("호가: %+v", orderBook)
    })
}()