order_client.go

package fyers

import (
	"encoding/json"
	"fmt"

	"github.com/rishi-anand/fyers-go-client/api"
	"github.com/rishi-anand/fyers-go-client/utils"
)

func (c *client) PlaceOrder(order api.Order) api.OrderResponse {
	if resp, err := c.invoke(utils.POST, c.toUri(ApiV2, OrdersUrl), order); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order place response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) PlaceOrders(orders []api.Order) api.MultiOrderResponse {
	if resp, err := c.invoke(utils.POST, c.toUri(ApiV2, MultiOrderUrl), orders); err != nil {
		return api.MultiOrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.MultiOrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.MultiOrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall orders place response. %v", err).Error()}
			}
			return response
		} else {
			return api.MultiOrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) ListOrders() ([]api.OrderBook, error) {
	if resp, err := c.invoke(utils.GET, c.toUri(ApiV2, OrdersUrl), nil); err != nil {
		return nil, err
	} else {
		if utils.IsSuccessResponse(resp) {
			var response []api.OrderBook
			if json.Unmarshal([]byte(utils.GetJsonValueAtPath(resp, "orderBook")), &response); err != nil {
				return nil, err
			} else {
				return response, nil
			}
		} else {
			return nil, fmt.Errorf("failed to get orders information. %v", utils.GetJsonValueAtPath(resp, "message"))
		}
	}
}

func (c *client) GetOrder(orderId string) (api.OrderBook, error) {
	if resp, err := c.invoke(utils.GET, c.toUri(ApiV2, OrdersUrl, QueryParam, IdQueryParam, orderId), nil); err != nil {
		return api.OrderBook{}, err
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderBook
			if json.Unmarshal([]byte(utils.GetJsonValueAtPath(resp, "orderBook")), &response); err != nil {
				return api.OrderBook{}, err
			} else {
				return response, nil
			}
		} else {
			return api.OrderBook{}, fmt.Errorf("failed to get orders information. %v", utils.GetJsonValueAtPath(resp, "message"))
		}
	}
}

func (c *client) ModifyOrder(order api.OrderUpdate) api.OrderResponse {
	if resp, err := c.invoke(utils.PUT, c.toUri(ApiV2, OrdersUrl), order); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order modify response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) CancelOrder(orderId string) api.OrderResponse {
	if resp, err := c.invoke(utils.DELETE, c.toUri(ApiV2, OrdersUrl), api.NewOrderId(orderId)); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order cancel response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) ExitPosition(positionId string) api.OrderResponse {
	if resp, err := c.invoke(utils.DELETE, c.toUri(ApiV2, PositionsUrl), api.NewOrderId(positionId)); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order cancel response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) ExitPositions(positions []string) api.OrderResponse {
	positionsReq := make([]api.OrderId, 0, 1)
	for _, pId := range positions {
		positionsReq = append(positionsReq, api.NewOrderId(pId))
	}
	if resp, err := c.invoke(utils.DELETE, c.toUri(ApiV2, PositionsUrl), positionsReq); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order cancel response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) ExitAllPositions() api.OrderResponse {
	if resp, err := c.invoke(utils.DELETE, c.toUri(ApiV2, PositionsUrl), "{}"); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order cancel response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}

func (c *client) ConvertPosition(position api.ConvertPosition) api.OrderResponse {
	if resp, err := c.invoke(utils.PUT, c.toUri(ApiV2, PositionsUrl), position); err != nil {
		return api.OrderResponse{IsFailed: true, Message: err.Error()}
	} else {
		if utils.IsSuccessResponse(resp) {
			var response api.OrderResponse
			if err := json.Unmarshal(resp, &response); err != nil {
				return api.OrderResponse{IsFailed: true, Message: fmt.Errorf("failed to unmarshall order cancel response. %v", err).Error()}
			}
			return response
		} else {
			return api.OrderResponse{IsFailed: true, Message: utils.GetJsonValueAtPath(resp, "message")}
		}
	}
}