TSI SuperTrend Decision Strategy
Combines a correlation-based Trend Strength Index with SuperTrend direction. Long trades are taken when the SuperTrend is bullish and TSI is above -threshold. Short trades are taken when the SuperTrend is bearish and TSI is below +threshold. Optional take profit and stop loss can be enabled.
- Indicators: Correlation, SuperTrend
using System;
using System.Linq;
using System.Collections.Generic;
using Ecng.Common;
using Ecng.Collections;
using Ecng.Serialization;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Correlation-based TSI with SuperTrend direction.
/// Uses RSI momentum with EMA trend for entry/exit decisions.
/// </summary>
public class TsiSuperTrendDecisionStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _tsiLength;
private readonly StrategyParam<int> _stLength;
private readonly StrategyParam<decimal> _stMultiplier;
private readonly StrategyParam<decimal> _threshold;
private decimal _prevRsi;
private decimal _prevFast;
private decimal _prevSlow;
private int _cooldown;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int TsiLength { get => _tsiLength.Value; set => _tsiLength.Value = value; }
public int StLength { get => _stLength.Value; set => _stLength.Value = value; }
public decimal StMultiplier { get => _stMultiplier.Value; set => _stMultiplier.Value = value; }
public decimal Threshold { get => _threshold.Value; set => _threshold.Value = value; }
public TsiSuperTrendDecisionStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Type of candles", "General");
_tsiLength = Param(nameof(TsiLength), 14)
.SetDisplay("TSI Length", "RSI period", "Indicators");
_stLength = Param(nameof(StLength), 8)
.SetDisplay("ST Length", "Fast EMA length", "Indicators");
_stMultiplier = Param(nameof(StMultiplier), 3m)
.SetDisplay("ST Mult", "SuperTrend factor", "Indicators");
_threshold = Param(nameof(Threshold), 21m)
.SetDisplay("TSI Threshold", "Slow EMA length", "Trading");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
protected override void OnReseted()
{
base.OnReseted();
_prevRsi = 0;
_prevFast = 0;
_prevSlow = 0;
_cooldown = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var rsi = new RelativeStrengthIndex { Length = TsiLength };
var emaFast = new ExponentialMovingAverage { Length = StLength };
var emaSlow = new ExponentialMovingAverage { Length = (int)Threshold };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(rsi, emaFast, emaSlow, ProcessCandle).Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, emaFast);
DrawIndicator(area, emaSlow);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal rsiVal, decimal emaFast, decimal emaSlow)
{
if (candle.State != CandleStates.Finished)
return;
if (_prevRsi == 0 || _prevFast == 0 || _prevSlow == 0)
{
_prevRsi = rsiVal;
_prevFast = emaFast;
_prevSlow = emaSlow;
return;
}
if (_cooldown > 0)
{
_cooldown--;
_prevRsi = rsiVal;
_prevFast = emaFast;
_prevSlow = emaSlow;
return;
}
// EMA histogram (like MACD)
var hist = emaFast - emaSlow;
var histUp = hist > 0m;
var histDown = hist < 0m;
// RSI cross 50 as momentum trigger
var rsiCrossUp = _prevRsi <= 50m && rsiVal > 50m;
var rsiCrossDown = _prevRsi >= 50m && rsiVal < 50m;
// Exit on opposite RSI cross
if (Position > 0 && rsiCrossDown)
{
SellMarket();
_cooldown = 80;
}
else if (Position < 0 && rsiCrossUp)
{
BuyMarket();
_cooldown = 80;
}
// Entry: RSI cross + histogram confirms
if (Position == 0)
{
if (rsiCrossUp && histUp)
{
BuyMarket();
_cooldown = 80;
}
else if (rsiCrossDown && histDown)
{
SellMarket();
_cooldown = 80;
}
}
_prevRsi = rsiVal;
_prevFast = emaFast;
_prevSlow = emaSlow;
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
from System import TimeSpan
from StockSharp.Messages import DataType, CandleStates
from StockSharp.Algo.Indicators import ExponentialMovingAverage, RelativeStrengthIndex
from StockSharp.Algo.Strategies import Strategy
class tsi_super_trend_decision_strategy(Strategy):
def __init__(self):
super(tsi_super_trend_decision_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Type of candles", "General")
self._tsi_length = self.Param("TsiLength", 14) \
.SetDisplay("TSI Length", "RSI period", "Indicators")
self._st_length = self.Param("StLength", 8) \
.SetDisplay("ST Length", "Fast EMA length", "Indicators")
self._st_multiplier = self.Param("StMultiplier", 3) \
.SetDisplay("ST Mult", "SuperTrend factor", "Indicators")
self._threshold = self.Param("Threshold", 21) \
.SetDisplay("TSI Threshold", "Slow EMA length", "Trading")
self._prev_rsi = 0.0
self._prev_fast = 0.0
self._prev_slow = 0.0
self._cooldown = 0
@property
def candle_type(self):
return self._candle_type.Value
@property
def tsi_length(self):
return self._tsi_length.Value
@property
def st_length(self):
return self._st_length.Value
@property
def st_multiplier(self):
return self._st_multiplier.Value
@property
def threshold(self):
return self._threshold.Value
def OnReseted(self):
super(tsi_super_trend_decision_strategy, self).OnReseted()
self._prev_rsi = 0.0
self._prev_fast = 0.0
self._prev_slow = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(tsi_super_trend_decision_strategy, self).OnStarted2(time)
rsi = RelativeStrengthIndex()
rsi.Length = self.tsi_length
ema_fast = ExponentialMovingAverage()
ema_fast.Length = self.st_length
ema_slow = ExponentialMovingAverage()
ema_slow.Length = int(self.threshold)
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(rsi, ema_fast, ema_slow, self.on_process).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, ema_fast)
self.DrawIndicator(area, ema_slow)
self.DrawOwnTrades(area)
def on_process(self, candle, rsi_val, ema_fast, ema_slow):
if candle.State != CandleStates.Finished:
return
rsi_val = float(rsi_val)
ema_fast = float(ema_fast)
ema_slow = float(ema_slow)
if self._prev_rsi == 0 or self._prev_fast == 0 or self._prev_slow == 0:
self._prev_rsi = rsi_val
self._prev_fast = ema_fast
self._prev_slow = ema_slow
return
if self._cooldown > 0:
self._cooldown -= 1
self._prev_rsi = rsi_val
self._prev_fast = ema_fast
self._prev_slow = ema_slow
return
hist = ema_fast - ema_slow
hist_up = hist > 0
hist_down = hist < 0
rsi_cross_up = self._prev_rsi <= 50 and rsi_val > 50
rsi_cross_down = self._prev_rsi >= 50 and rsi_val < 50
if self.Position > 0 and rsi_cross_down:
self.SellMarket()
self._cooldown = 80
elif self.Position < 0 and rsi_cross_up:
self.BuyMarket()
self._cooldown = 80
if self.Position == 0:
if rsi_cross_up and hist_up:
self.BuyMarket()
self._cooldown = 80
elif rsi_cross_down and hist_down:
self.SellMarket()
self._cooldown = 80
self._prev_rsi = rsi_val
self._prev_fast = ema_fast
self._prev_slow = ema_slow
def CreateClone(self):
return tsi_super_trend_decision_strategy()