syntax = "proto3";

package pb;

option go_package = "../pb";

service BBGO {
    // should support streaming
    rpc Subcribe(SubscribeRequest) returns (stream SubscribeResponse) {}

    // request-response
    rpc SubmitOrder(SubmitOrderRequest) returns (SubmitOrderResponse) {}
    rpc CancelOrder(CancelOrderRequest) returns (CancelOrderResponse) {}
    rpc QueryOrder(QueryOrderRequest) returns (QueryOrderResponse) {}
    rpc QueryOrders(QueryOrdersRequest) returns (QueryOrdersResponse) {}
    rpc QueryTrades(QueryTradesRequest) returns (QueryTradesResponse) {}
    rpc QueryKLines(QueryKLinesRequest) returns (QueryKLinesResponse) {}
}

message SubscribeRequest {
    repeated Subscription subscriptions = 1;
}

message Subscription {
    string exchange = 1;
    string channel = 2;  // book, trade, ticker
    string symbol = 3;
    int64 depth = 4;
}

message SubscribeResponse {
    string exchange = 1;
    string channel = 2;  // book, trade, ticker, user
    string event = 3;    // snapshot, update, order_snapshot, ...
    string symbol = 4;
    Depth depth = 5;
    repeated Trade trades = 6;
    Ticker ticker = 7;
    repeated Order orders = 8;
    repeated Balance balances = 9;
    int64 subscribed_at = 10;
    int64 error_code = 11;
    string error_message = 12;
}

message Depth {
    string exchange = 1;
    string symbol = 2;
    repeated PriceVolume asks = 3;
    repeated PriceVolume bids = 4;
}

message PriceVolume {
    int64 price = 1;
    int64 volume = 2;
}

// https://maicoin.github.io/max-websocket-docs/#/private_channels?id=trade-response
// https://maicoin.github.io/max-websocket-docs/#/public_trade?id=success-response
message Trade {
    string exchange = 1;
    int64 id = 2;
    double price = 3;
    double volume = 4;
    string symbol = 5;
    int64 created_at = 6;
    string side = 7;
    double fee = 8;
    string fee_currency = 9;
    bool maker = 10;
    string trend = 11;
}

// https://maicoin.github.io/max-websocket-docs/#/public_ticker?id=success-response
message Ticker {
    double open = 1;
    double high = 2;
    double low = 3;
    double close = 4;
    double volume = 5;
}

// https://maicoin.github.io/max-websocket-docs/#/private_channels?id=snapshot
message Order {
    string exchange = 1;
    int64 id = 2;
    string side = 3;
    string order_type = 4;
    double price = 5;
    double stop_price = 6;
    double avg_price = 7;
    string status = 8;
    string symbol = 9;
    int64 created_at = 10;
    double quantity = 11;
    double executed_volume = 12;
    int64 trades_count = 13;
    int64 client_order_id = 14;
    int64 group_id = 15;
}

message SubmitOrder {
    string exchange = 1;
    string symbol = 2;
    string side = 3;
    double quantity = 4;
    double price = 5;
    double stop_price = 6;
    string order_type = 7;
    int64 client_order_id = 8;
    int64 group_id = 9;
}

// https://maicoin.github.io/max-websocket-docs/#/private_channels?id=account-response
message Balance {
    string currency = 1;
    double available = 2;
    double locked = 3;
}

message SubmitOrderRequest {
    SubmitOrder submit_order = 1;
}

message SubmitOrderResponse {
    string exchange = 1;
    Order order = 2;
}

message CancelOrderRequest {
    string exchange = 1;
    int64 id = 2;
    int64 client_order_id = 3;
}

message CancelOrderResponse {
    string exchange = 1;
    Order order = 2;
    int64 status_code = 3;
}

message QueryOrderRequest {
    int64 id = 1;
    int64 client_order_id = 2;
}

message QueryOrderResponse {
    Order order = 1;
    int64 status_code = 2;
}

message QueryOrdersRequest {
    string exchange = 1;
    string symbol = 2;
    repeated string state = 3;
    string order_by = 4;
    int64 group_id = 5;
    bool pagination = 6;
    int64 page = 7;
    int64 limit = 8;
    int64 offset = 9;
}

message QueryOrdersResponse {
    string exchange = 1;
    repeated Order orders = 2;
    int64 status_code = 3;
}

message QueryTradesRequest {
    string exchange = 1;
    string symbol = 2;
    int64 timestamp = 3;
    int64 from = 4;
    int64 to = 5;
    string order_by = 6;
    bool pagination = 7;
    int64 page = 8;
    int64 limit = 9;
    int64 offset = 10;
}

message QueryTradesResponse {
    repeated Trade trades = 1;
    int64 status_code = 2;
}

message QueryKLinesRequest {
    string exchange = 1;
    string symbol = 2;
    int64 limit = 3;
    int64 interval = 4;  // time period of K line in minute
    int64 timestamp = 5;
}

message QueryKLinesResponse {
    repeated KLine klines = 1;
    int64 status_code = 2;
}

message KLine {
    string exchange = 1;
    string symbol = 2;
    int64 timestamp = 3;
    double open = 4;
    double high = 5;
    double low = 6;
    double close = 7;
    double volume = 8;
    double quote_volume = 9;
}