added the GetCreditSendMaxLimit function
This commit is contained in:
		
							parent
							
								
									96c323f202
								
							
						
					
					
						commit
						01569b9b39
					
				| @ -30,4 +30,5 @@ type AccountService interface { | |||||||
| 	PoolSwap(ctx context.Context, amount, from, fromTokenAddress, poolAddress, toTokenAddress string) (*models.PoolSwapResult, error) | 	PoolSwap(ctx context.Context, amount, from, fromTokenAddress, poolAddress, toTokenAddress string) (*models.PoolSwapResult, error) | ||||||
| 	GetSwapFromTokenMaxLimit(ctx context.Context, poolAddress, fromTokenAddress, toTokenAddress, publicKey string) (*models.MaxLimitResult, error) | 	GetSwapFromTokenMaxLimit(ctx context.Context, poolAddress, fromTokenAddress, toTokenAddress, publicKey string) (*models.MaxLimitResult, error) | ||||||
| 	CheckTokenInPool(ctx context.Context, poolAddress, tokenAddress string) (*models.TokenInPoolResult, error) | 	CheckTokenInPool(ctx context.Context, poolAddress, tokenAddress string) (*models.TokenInPoolResult, error) | ||||||
|  | 	GetCreditSendMaxLimit(ctx context.Context, poolAddress, fromTokenAddress, toTokenAddress, publicKey string) (*models.CreditSendLimitsResult, error) | ||||||
| } | } | ||||||
|  | |||||||
| @ -742,6 +742,26 @@ func (as *HTTPAccountService) SendPINResetSMS(ctx context.Context, admin, phone | |||||||
| 	return nil | 	return nil | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
|  | // GetCreditSendMaxLimit calls the API to check credit limits and return the maxRAT and maxSAT
 | ||||||
|  | func (as *HTTPAccountService) GetCreditSendMaxLimit(ctx context.Context, poolAddress, fromTokenAddress, toTokenAddress, publicKey string) (*models.CreditSendLimitsResult, error) { | ||||||
|  | 	var r models.CreditSendLimitsResult | ||||||
|  | 
 | ||||||
|  | 	ep, err := url.JoinPath(config.CreditSendURL, poolAddress, fromTokenAddress, toTokenAddress, publicKey) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 	req, err := http.NewRequest("GET", ep, nil) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 	_, err = doRequest(ctx, req, &r) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	return &r, nil | ||||||
|  | } | ||||||
|  | 
 | ||||||
| // TODO: remove eth-custodial api dependency
 | // TODO: remove eth-custodial api dependency
 | ||||||
| func doRequest(ctx context.Context, req *http.Request, rcpt any) (*api.OKResponse, error) { | func doRequest(ctx context.Context, req *http.Request, rcpt any) (*api.OKResponse, error) { | ||||||
| 	var okResponse api.OKResponse | 	var okResponse api.OKResponse | ||||||
|  | |||||||
		Loading…
	
		Reference in New Issue
	
	Block a user