iqoption api to connect to www.iqoption.com (unofficial), with .netcore based for another framework you can suggest,
| Branch | Build | Nuget |
|---|---|---|
| master | ||
| developer(Pre-release) |
PM> Install-Package iqoptionapialpha version now available
PM> Install-Package iqoptionapi -Version 2.0.0-alpha1This api using websocket to communicate realtime-data to Iqoption server through secured websocket channel, so the realtime meta data that come on this channel will be handles by .net reactive programming called "Rx.NET", cause of a haundred of data type stream on only one channle so we need to selected subscribe on specific topic.
- BuyBack Position
- Subscribe to the channel
- support open Long/Short for CFD contract (Digital Options)
var client = new IqOptionApi("emailaddress", "password");
//begin connect
if(await client.ConnectAsync()){
//get user profile
var profile = await client.GetProfileAsync();
// open order EurUsd in smallest period (1min)
var exp = DateTime.Now.AddMinutes(1);
var buyResult = await api.BuyAsync(ActivePair.EURUSD, 1, OrderDirection.Call, exp);
// get candles data
var candles = await api.GetCandlesAsync(ActivePair.EURUSD, TimeFrame.Min1, 100, DateTimeOffset.Now);
_logger.LogInformation($"CandleCollections received {candles.Count}");
// subscribe to pair to get real-time data for tf1min and tf5min
var streamMin1 = await api.SubscribeRealtimeDataAsync(ActivePair.EURUSD, TimeFrame.Min1);
var streamMin5 = await api.SubscribeRealtimeDataAsync(ActivePair.EURUSD, TimeFrame.Min5);
streamMin5.Merge(streamMin1)
.Subscribe(candleInfo => {
_logger.LogInformation($"Now {ActivePair.EURUSD} {candleInfo.TimeFrame} : Bid={candleInfo.Bid}\t Ask={candleInfo.Ask}\t");
});
// after this line no-more realtime data for min5 print on console
await api.UnSubscribeRealtimeData(ActivePair.EURUSD, TimeFrame.Min5);
}This is example use cases that this api could solve your problems
public async Task TradingFollower_ExampleAsync() {
var trader = new IqOptionApi("[email protected]", "passcode");
var follower = new IqOptionApi("[email protected]", "passcode");
await Task.WhenAll(trader.ConnectAsync(), follower.ConnectAsync());
trader.InfoDatasObservable.Select(x => x[0]).Where(x => x.Win == "equal").Subscribe(x => {
follower.BuyAsync(x.ActiveId, (int) x.Sum, x.Direction, x.Expired);
});
}Now you can open order like this
var api = new IqOptionApi("[email protected]", "passcode");
try {
//logging in
if (await api.ConnectAsync()) {
//open order EurUsd in smallest period(1min)
var exp = DateTime.Now.AddMinutes(1);
await api.BuyAsync(ActivePair.EURUSD, 1, OrderDirection.Call, exp);
}
}
catch (Exception ex) {
Console.WriteLine(ex.Message);
}
finally {
Console.ReadLine();
}now using ReactiveUI way for subscribe the changing of model following this
using System;
using System.Reactive.Linq;
using System.Threading.Tasks;
using IqOptionApi.Models;
using ReactiveUI;
namespace IqOptionApi.Sample {
public class TradingExample {
public async Task RunAsync() {
var trader = new IqOptionApi("[email protected]", "passcode");
var follower = new IqOptionApi("[email protected]", "passcode");
await Task.WhenAll(trader.ConnectAsync(), follower.ConnectAsync());
trader.WsClient.WhenAnyValue(x => x.InfoData)
.Where(x => x != null && x.Win == WinType.Equal)
.Subscribe(x => { follower.BuyAsync(x.ActiveId, (int) x.Sum, x.Direction, x.Expired); });
//var exp = DateTime.Now.AddMinutes(1);
var exp = DateTime.Now.AddMinutes(1);
await trader.BuyAsync(ActivePair.EURUSD, 1, OrderDirection.Call, exp);
}
}
}If you've got value from any of the content which I have created, but pull requests are not your thing, then I would also very much appreciate your support by buying me a coffee.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent