Skip to content

Commit

Permalink
Implementing the v2 api for Jupiter and Raydium
Browse files Browse the repository at this point in the history
  • Loading branch information
@tinystarinagalaxy
tinystarinagalaxy committed Jul 13, 2023
1 parent d2b0e33 commit fb19050
Show file tree
Hide file tree
Showing 15 changed files with 31,355 additions and 17,248 deletions.
18,374 changes: 10,509 additions & 7,865 deletions api/api.pb.go
View file

Large diffs are not rendered by default.

823 changes: 790 additions & 33 deletions api/api.pb.gw.go
View file

Large diffs are not rendered by default.

328 changes: 328 additions & 0 deletions api/api_grpc.pb.go
View file

Large diffs are not rendered by default.

219 changes: 146 additions & 73 deletions common/common.pb.go
View file

Large diffs are not rendered by default.

153 changes: 153 additions & 0 deletions js/ffi/proto/api_grpc_pb.d.ts
View file

Large diffs are not rendered by default.

301 changes: 300 additions & 1 deletion js/ffi/proto/api_grpc_pb.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -384,6 +384,50 @@ function deserialize_api_GetDriftUserResponse(buffer_arg) {
return api_pb.GetDriftUserResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetJupiterPricesRequest(arg) {
if (!(arg instanceof api_pb.GetJupiterPricesRequest)) {
throw new Error('Expected argument of type api.GetJupiterPricesRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetJupiterPricesRequest(buffer_arg) {
return api_pb.GetJupiterPricesRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetJupiterPricesResponse(arg) {
if (!(arg instanceof api_pb.GetJupiterPricesResponse)) {
throw new Error('Expected argument of type api.GetJupiterPricesResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetJupiterPricesResponse(buffer_arg) {
return api_pb.GetJupiterPricesResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetJupiterQuotesRequest(arg) {
if (!(arg instanceof api_pb.GetJupiterQuotesRequest)) {
throw new Error('Expected argument of type api.GetJupiterQuotesRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetJupiterQuotesRequest(buffer_arg) {
return api_pb.GetJupiterQuotesRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetJupiterQuotesResponse(arg) {
if (!(arg instanceof api_pb.GetJupiterQuotesResponse)) {
throw new Error('Expected argument of type api.GetJupiterQuotesResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetJupiterQuotesResponse(buffer_arg) {
return api_pb.GetJupiterQuotesResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetKlineRequest(arg) {
if (!(arg instanceof api_pb.GetKlineRequest)) {
throw new Error('Expected argument of type api.GetKlineRequest');
Expand Down Expand Up @@ -967,6 +1011,72 @@ function deserialize_api_GetQuotesStreamResponse(buffer_arg) {
return api_pb.GetQuotesStreamResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRaydiumPoolsRequest(arg) {
if (!(arg instanceof api_pb.GetRaydiumPoolsRequest)) {
throw new Error('Expected argument of type api.GetRaydiumPoolsRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetRaydiumPoolsRequest(buffer_arg) {
return api_pb.GetRaydiumPoolsRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRaydiumPoolsResponse(arg) {
if (!(arg instanceof api_pb.GetRaydiumPoolsResponse)) {
throw new Error('Expected argument of type api.GetRaydiumPoolsResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetRaydiumPoolsResponse(buffer_arg) {
return api_pb.GetRaydiumPoolsResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRaydiumPricesRequest(arg) {
if (!(arg instanceof api_pb.GetRaydiumPricesRequest)) {
throw new Error('Expected argument of type api.GetRaydiumPricesRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetRaydiumPricesRequest(buffer_arg) {
return api_pb.GetRaydiumPricesRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRaydiumPricesResponse(arg) {
if (!(arg instanceof api_pb.GetRaydiumPricesResponse)) {
throw new Error('Expected argument of type api.GetRaydiumPricesResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetRaydiumPricesResponse(buffer_arg) {
return api_pb.GetRaydiumPricesResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRaydiumQuotesRequest(arg) {
if (!(arg instanceof api_pb.GetRaydiumQuotesRequest)) {
throw new Error('Expected argument of type api.GetRaydiumQuotesRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetRaydiumQuotesRequest(buffer_arg) {
return api_pb.GetRaydiumQuotesRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRaydiumQuotesResponse(arg) {
if (!(arg instanceof api_pb.GetRaydiumQuotesResponse)) {
throw new Error('Expected argument of type api.GetRaydiumQuotesResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_GetRaydiumQuotesResponse(buffer_arg) {
return api_pb.GetRaydiumQuotesResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_GetRecentBlockHashRequest(arg) {
if (!(arg instanceof api_pb.GetRecentBlockHashRequest)) {
throw new Error('Expected argument of type api.GetRecentBlockHashRequest');
Expand Down Expand Up @@ -1561,6 +1671,50 @@ function deserialize_api_PostDriftSettlePNLsResponse(buffer_arg) {
return api_pb.PostDriftSettlePNLsResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostJupiterRouteSwapRequest(arg) {
if (!(arg instanceof api_pb.PostJupiterRouteSwapRequest)) {
throw new Error('Expected argument of type api.PostJupiterRouteSwapRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostJupiterRouteSwapRequest(buffer_arg) {
return api_pb.PostJupiterRouteSwapRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostJupiterRouteSwapResponse(arg) {
if (!(arg instanceof api_pb.PostJupiterRouteSwapResponse)) {
throw new Error('Expected argument of type api.PostJupiterRouteSwapResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostJupiterRouteSwapResponse(buffer_arg) {
return api_pb.PostJupiterRouteSwapResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostJupiterSwapRequest(arg) {
if (!(arg instanceof api_pb.PostJupiterSwapRequest)) {
throw new Error('Expected argument of type api.PostJupiterSwapRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostJupiterSwapRequest(buffer_arg) {
return api_pb.PostJupiterSwapRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostJupiterSwapResponse(arg) {
if (!(arg instanceof api_pb.PostJupiterSwapResponse)) {
throw new Error('Expected argument of type api.PostJupiterSwapResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostJupiterSwapResponse(buffer_arg) {
return api_pb.PostJupiterSwapResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostLiquidateDriftPerpRequest(arg) {
if (!(arg instanceof api_pb.PostLiquidateDriftPerpRequest)) {
throw new Error('Expected argument of type api.PostLiquidateDriftPerpRequest');
Expand Down Expand Up @@ -1704,6 +1858,50 @@ function deserialize_api_PostPerpOrderResponse(buffer_arg) {
return api_pb.PostPerpOrderResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostRaydiumRouteSwapRequest(arg) {
if (!(arg instanceof api_pb.PostRaydiumRouteSwapRequest)) {
throw new Error('Expected argument of type api.PostRaydiumRouteSwapRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostRaydiumRouteSwapRequest(buffer_arg) {
return api_pb.PostRaydiumRouteSwapRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostRaydiumRouteSwapResponse(arg) {
if (!(arg instanceof api_pb.PostRaydiumRouteSwapResponse)) {
throw new Error('Expected argument of type api.PostRaydiumRouteSwapResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostRaydiumRouteSwapResponse(buffer_arg) {
return api_pb.PostRaydiumRouteSwapResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostRaydiumSwapRequest(arg) {
if (!(arg instanceof api_pb.PostRaydiumSwapRequest)) {
throw new Error('Expected argument of type api.PostRaydiumSwapRequest');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostRaydiumSwapRequest(buffer_arg) {
return api_pb.PostRaydiumSwapRequest.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostRaydiumSwapResponse(arg) {
if (!(arg instanceof api_pb.PostRaydiumSwapResponse)) {
throw new Error('Expected argument of type api.PostRaydiumSwapResponse');
}
return Buffer.from(arg.serializeBinary());
}

function deserialize_api_PostRaydiumSwapResponse(buffer_arg) {
return api_pb.PostRaydiumSwapResponse.deserializeBinary(new Uint8Array(buffer_arg));
}

function serialize_api_PostReplaceOrderRequest(arg) {
if (!(arg instanceof api_pb.PostReplaceOrderRequest)) {
throw new Error('Expected argument of type api.PostReplaceOrderRequest');
Expand Down Expand Up @@ -1882,6 +2080,107 @@ function deserialize_api_TradeSwapResponse(buffer_arg) {


var ApiService = exports.ApiService = {
// Raydium V2
getRaydiumPools: {
path: '/api.Api/GetRaydiumPools',
requestStream: false,
responseStream: false,
requestType: api_pb.GetRaydiumPoolsRequest,
responseType: api_pb.GetRaydiumPoolsResponse,
requestSerialize: serialize_api_GetRaydiumPoolsRequest,
requestDeserialize: deserialize_api_GetRaydiumPoolsRequest,
responseSerialize: serialize_api_GetRaydiumPoolsResponse,
responseDeserialize: deserialize_api_GetRaydiumPoolsResponse,
},
getRaydiumQuotes: {
path: '/api.Api/GetRaydiumQuotes',
requestStream: false,
responseStream: false,
requestType: api_pb.GetRaydiumQuotesRequest,
responseType: api_pb.GetRaydiumQuotesResponse,
requestSerialize: serialize_api_GetRaydiumQuotesRequest,
requestDeserialize: deserialize_api_GetRaydiumQuotesRequest,
responseSerialize: serialize_api_GetRaydiumQuotesResponse,
responseDeserialize: deserialize_api_GetRaydiumQuotesResponse,
},
getRaydiumPrices: {
path: '/api.Api/GetRaydiumPrices',
requestStream: false,
responseStream: false,
requestType: api_pb.GetRaydiumPricesRequest,
responseType: api_pb.GetRaydiumPricesResponse,
requestSerialize: serialize_api_GetRaydiumPricesRequest,
requestDeserialize: deserialize_api_GetRaydiumPricesRequest,
responseSerialize: serialize_api_GetRaydiumPricesResponse,
responseDeserialize: deserialize_api_GetRaydiumPricesResponse,
},
postRaydiumSwap: {
path: '/api.Api/PostRaydiumSwap',
requestStream: false,
responseStream: false,
requestType: api_pb.PostRaydiumSwapRequest,
responseType: api_pb.PostRaydiumSwapResponse,
requestSerialize: serialize_api_PostRaydiumSwapRequest,
requestDeserialize: deserialize_api_PostRaydiumSwapRequest,
responseSerialize: serialize_api_PostRaydiumSwapResponse,
responseDeserialize: deserialize_api_PostRaydiumSwapResponse,
},
postRaydiumRouteSwap: {
path: '/api.Api/PostRaydiumRouteSwap',
requestStream: false,
responseStream: false,
requestType: api_pb.PostRaydiumRouteSwapRequest,
responseType: api_pb.PostRaydiumRouteSwapResponse,
requestSerialize: serialize_api_PostRaydiumRouteSwapRequest,
requestDeserialize: deserialize_api_PostRaydiumRouteSwapRequest,
responseSerialize: serialize_api_PostRaydiumRouteSwapResponse,
responseDeserialize: deserialize_api_PostRaydiumRouteSwapResponse,
},
// Jupiter V2
getJupiterQuotes: {
path: '/api.Api/GetJupiterQuotes',
requestStream: false,
responseStream: false,
requestType: api_pb.GetJupiterQuotesRequest,
responseType: api_pb.GetJupiterQuotesResponse,
requestSerialize: serialize_api_GetJupiterQuotesRequest,
requestDeserialize: deserialize_api_GetJupiterQuotesRequest,
responseSerialize: serialize_api_GetJupiterQuotesResponse,
responseDeserialize: deserialize_api_GetJupiterQuotesResponse,
},
getJupiterPrices: {
path: '/api.Api/GetJupiterPrices',
requestStream: false,
responseStream: false,
requestType: api_pb.GetJupiterPricesRequest,
responseType: api_pb.GetJupiterPricesResponse,
requestSerialize: serialize_api_GetJupiterPricesRequest,
requestDeserialize: deserialize_api_GetJupiterPricesRequest,
responseSerialize: serialize_api_GetJupiterPricesResponse,
responseDeserialize: deserialize_api_GetJupiterPricesResponse,
},
postJupiterSwap: {
path: '/api.Api/PostJupiterSwap',
requestStream: false,
responseStream: false,
requestType: api_pb.PostJupiterSwapRequest,
responseType: api_pb.PostJupiterSwapResponse,
requestSerialize: serialize_api_PostJupiterSwapRequest,
requestDeserialize: deserialize_api_PostJupiterSwapRequest,
responseSerialize: serialize_api_PostJupiterSwapResponse,
responseDeserialize: deserialize_api_PostJupiterSwapResponse,
},
postJupiterRouteSwap: {
path: '/api.Api/PostJupiterRouteSwap',
requestStream: false,
responseStream: false,
requestType: api_pb.PostJupiterRouteSwapRequest,
responseType: api_pb.PostJupiterRouteSwapResponse,
requestSerialize: serialize_api_PostJupiterRouteSwapRequest,
requestDeserialize: deserialize_api_PostJupiterRouteSwapRequest,
responseSerialize: serialize_api_PostJupiterRouteSwapResponse,
responseDeserialize: deserialize_api_PostJupiterRouteSwapResponse,
},
// Drift V2
postCloseDriftPerpPositions: {
path: '/api.Api/PostCloseDriftPerpPositions',
Expand Down Expand Up @@ -2270,7 +2569,7 @@ getMarketsV2: {
responseSerialize: serialize_api_GetUnsettledResponse,
responseDeserialize: deserialize_api_GetUnsettledResponse,
},
// end o Openbook V2
// end of Openbook V2
//
getPrice: {
path: '/api.Api/GetPrice',
Expand Down
Loading

0 comments on commit fb19050

Please sign in to comment.