btc306_test.go 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392
  1. package main
  2. import (
  3. "fmt"
  4. "git.beejay.kim/Gshopper/sentio"
  5. "github.com/samber/lo"
  6. "reflect"
  7. "slices"
  8. "testing"
  9. "time"
  10. )
  11. func Test__ibkr_IsOpen(t *testing.T) {
  12. tests := []struct {
  13. time string
  14. want bool
  15. }{
  16. {
  17. time: "2024-08-26T13:29:59Z", // 1s before open
  18. want: false,
  19. },
  20. {
  21. time: "2024-08-02T15:04:05Z", // Opened
  22. want: true,
  23. },
  24. {
  25. time: "2024-08-03T18:34:00Z", // Saturday
  26. want: false,
  27. },
  28. {
  29. time: "2024-08-25T15:00:00Z", // Sunday
  30. want: false,
  31. },
  32. {
  33. time: "2024-08-26T19:00:05Z", // Closed
  34. want: false,
  35. },
  36. }
  37. for _, tt := range tests {
  38. var (
  39. c ClockFixed
  40. s _ibkr
  41. err error
  42. )
  43. if c.fix, err = time.ParseInLocation(time.RFC3339, tt.time, time.UTC); err != nil {
  44. t.Errorf("ParseInLocation() = %v", err)
  45. return
  46. }
  47. s = _ibkr{
  48. clock: c,
  49. }
  50. t.Run(fmt.Sprintf("IBKR:IsOpen:%s", tt.time), func(t *testing.T) {
  51. got := s.IsOpen()
  52. if got != tt.want {
  53. t.Errorf("IsOpen() = %v, want %v", got, tt.want)
  54. }
  55. })
  56. }
  57. }
  58. func Test__ibkr_ShouldClosePositions(t *testing.T) {
  59. type args struct {
  60. portfolio sentio.Portfolio
  61. proba float64
  62. time string
  63. }
  64. tests := []struct {
  65. args args
  66. want []string
  67. }{
  68. { // should close SHORT position
  69. args: args{
  70. portfolio: newStubPortfolio(
  71. PositionStub{
  72. symbol: "521525019",
  73. size: 10,
  74. price: 20,
  75. },
  76. PositionStub{
  77. symbol: "569311092",
  78. size: 10,
  79. price: 8,
  80. },
  81. ),
  82. proba: 1.00001,
  83. time: "2024-08-02T15:04:05Z",
  84. },
  85. want: []string{"569311092"},
  86. },
  87. { // should close LONG position
  88. args: args{
  89. portfolio: newStubPortfolio(
  90. PositionStub{
  91. symbol: "521525019",
  92. size: 10,
  93. price: 20,
  94. },
  95. PositionStub{
  96. symbol: "569311092",
  97. size: 10,
  98. price: 8,
  99. },
  100. ),
  101. proba: .9,
  102. time: "2024-08-02T15:04:05Z",
  103. },
  104. want: []string{"521525019"},
  105. },
  106. { // nothing to close
  107. args: args{
  108. portfolio: newStubPortfolio(),
  109. proba: .9,
  110. time: "2024-08-02T15:04:05Z",
  111. },
  112. want: nil,
  113. },
  114. { // should close both positions
  115. args: args{
  116. portfolio: newStubPortfolio(
  117. PositionStub{
  118. symbol: "521525019",
  119. size: 10,
  120. price: 20,
  121. },
  122. PositionStub{
  123. symbol: "521525020",
  124. size: 10,
  125. price: 20,
  126. },
  127. PositionStub{
  128. symbol: "569311092",
  129. size: 10,
  130. price: 8,
  131. },
  132. ),
  133. proba: .9,
  134. time: "2024-08-02T19:00:05Z",
  135. },
  136. want: []string{"521525019", "569311092"},
  137. },
  138. { // should close nothing
  139. args: args{
  140. portfolio: newStubPortfolio(
  141. PositionStub{
  142. symbol: "569311092",
  143. size: 10,
  144. price: 8,
  145. },
  146. PositionStub{
  147. symbol: "521525020",
  148. size: 10,
  149. price: 20,
  150. },
  151. ),
  152. proba: .9,
  153. time: "2024-08-02T18:00:05Z",
  154. },
  155. want: nil,
  156. },
  157. { // should close nothing
  158. args: args{
  159. portfolio: newStubPortfolio(
  160. PositionStub{
  161. symbol: "521525019",
  162. size: 10,
  163. price: 20,
  164. },
  165. PositionStub{
  166. symbol: "521525020",
  167. size: 10,
  168. price: 20,
  169. },
  170. ),
  171. proba: 1.2,
  172. time: "2024-08-02T18:00:05Z",
  173. },
  174. want: nil,
  175. },
  176. { // should close all
  177. args: args{
  178. portfolio: newStubPortfolio(
  179. PositionStub{
  180. symbol: "521525019",
  181. size: 10,
  182. price: 20,
  183. },
  184. PositionStub{
  185. symbol: "521525020",
  186. size: 10,
  187. price: 20,
  188. },
  189. ),
  190. proba: 1.2,
  191. time: "2024-08-02T12:00:05Z",
  192. },
  193. want: []string{"521525019"},
  194. },
  195. { // should close nothing
  196. args: args{
  197. portfolio: newStubPortfolio(
  198. PositionStub{
  199. symbol: "521525020",
  200. size: 10,
  201. price: 20,
  202. },
  203. ),
  204. proba: 1.1,
  205. time: "2024-08-02T12:00:05Z",
  206. },
  207. want: nil,
  208. },
  209. }
  210. for _, tt := range tests {
  211. var (
  212. c ClockFixed
  213. s _ibkr
  214. err error
  215. )
  216. if c.fix, err = time.ParseInLocation(time.RFC3339, tt.args.time, time.UTC); err != nil {
  217. t.Errorf("ParseInLocation() = %v", err)
  218. return
  219. }
  220. s = _ibkr{
  221. clock: c,
  222. }
  223. t.Run("IBKR:ShouldClosePositions", func(t *testing.T) {
  224. if got := s.ShouldClosePositions(tt.args.portfolio, tt.args.proba); !slices.Equal(got, tt.want) {
  225. t.Errorf("ShouldClosePositions() = %v, want %v", got, tt.want)
  226. }
  227. })
  228. }
  229. }
  230. func Test__ibkr_ShouldOpenPosition(t *testing.T) {
  231. type args struct {
  232. portfolio sentio.Portfolio
  233. proba float64
  234. time string
  235. }
  236. tests := []struct {
  237. args args
  238. symbol *string
  239. size float64
  240. }{
  241. {
  242. args: args{
  243. portfolio: newStubPortfolio(),
  244. proba: 1.00201,
  245. time: "2024-08-02T18:30:00Z",
  246. },
  247. symbol: lo.ToPtr("521525019"),
  248. size: .6,
  249. },
  250. {
  251. args: args{
  252. portfolio: newStubPortfolio(
  253. PositionStub{
  254. symbol: "521525019",
  255. size: 1,
  256. price: 19,
  257. },
  258. ),
  259. proba: 1.00201,
  260. time: "2024-08-02T18:30:00Z",
  261. },
  262. symbol: lo.ToPtr("521525019"),
  263. size: .3,
  264. },
  265. {
  266. args: args{
  267. portfolio: newStubPortfolio(
  268. PositionStub{
  269. symbol: "521525019",
  270. size: -.2,
  271. price: 19,
  272. },
  273. ),
  274. proba: 1.00201,
  275. time: "2024-08-02T18:30:00Z",
  276. },
  277. symbol: lo.ToPtr("521525019"),
  278. size: .6,
  279. },
  280. {
  281. args: args{
  282. portfolio: newStubPortfolio(
  283. PositionStub{
  284. symbol: "521525020",
  285. size: 3,
  286. price: 19,
  287. },
  288. ),
  289. proba: 1.00201,
  290. time: "2024-08-02T18:30:00Z",
  291. },
  292. symbol: lo.ToPtr("521525019"),
  293. size: .6,
  294. },
  295. {
  296. args: args{
  297. portfolio: newStubPortfolio(),
  298. proba: .9979,
  299. time: "2024-08-02T18:30:00Z",
  300. },
  301. symbol: lo.ToPtr("569311092"),
  302. size: .8,
  303. },
  304. {
  305. args: args{
  306. portfolio: newStubPortfolio(
  307. PositionStub{
  308. symbol: "569311092",
  309. size: 100,
  310. price: 8,
  311. },
  312. ),
  313. proba: .9979,
  314. time: "2024-08-02T18:30:00Z",
  315. },
  316. symbol: lo.ToPtr("569311092"),
  317. size: .3,
  318. },
  319. {
  320. args: args{
  321. portfolio: newStubPortfolio(
  322. PositionStub{
  323. symbol: "521525020",
  324. size: 100,
  325. price: 8,
  326. },
  327. ),
  328. proba: .9979,
  329. time: "2024-08-02T19:00:00Z",
  330. },
  331. symbol: nil,
  332. size: 0,
  333. },
  334. {
  335. args: args{
  336. portfolio: newStubPortfolio(
  337. PositionStub{
  338. symbol: "569311092",
  339. size: 100,
  340. price: 8,
  341. },
  342. ),
  343. proba: -1,
  344. time: "2024-08-02T18:30:00Z",
  345. },
  346. symbol: nil,
  347. size: 0,
  348. },
  349. }
  350. for _, tt := range tests {
  351. t.Run("IBKR:ShouldOpenPosition", func(t *testing.T) {
  352. var (
  353. c ClockFixed
  354. s _ibkr
  355. err error
  356. )
  357. if c.fix, err = time.ParseInLocation(time.RFC3339, tt.args.time, time.UTC); err != nil {
  358. t.Errorf("ParseInLocation() = %v", err)
  359. return
  360. }
  361. s = _ibkr{
  362. clock: c,
  363. }
  364. symbol, size := s.ShouldOpenPosition(tt.args.portfolio, tt.args.proba)
  365. if !reflect.DeepEqual(symbol, tt.symbol) {
  366. t.Errorf("ShouldOpenPosition() symbol = %v, want %v", symbol, tt.symbol)
  367. }
  368. if size != tt.size {
  369. t.Errorf("ShouldOpenPosition() size = %v, want %v", size, tt.size)
  370. }
  371. })
  372. }
  373. }