btc306_test.go 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405
  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. args: args{
  211. portfolio: newStubPortfolio(
  212. PositionStub{
  213. symbol: "569311092",
  214. size: 10938,
  215. price: 8.24685045,
  216. }),
  217. proba: 0.9972525825782994,
  218. time: "2024-09-03T04:00:00Z",
  219. },
  220. want: []string{"569311092"},
  221. },
  222. }
  223. for _, tt := range tests {
  224. var (
  225. c ClockFixed
  226. s _ibkr
  227. err error
  228. )
  229. if c.fix, err = time.ParseInLocation(time.RFC3339, tt.args.time, time.UTC); err != nil {
  230. t.Errorf("ParseInLocation() = %v", err)
  231. return
  232. }
  233. s = _ibkr{
  234. clock: c,
  235. }
  236. t.Run("IBKR:ShouldClosePositions", func(t *testing.T) {
  237. if got := s.ShouldClosePositions(tt.args.portfolio, tt.args.proba); !slices.Equal(got, tt.want) {
  238. t.Errorf("ShouldClosePositions() = %v, want %v", got, tt.want)
  239. }
  240. })
  241. }
  242. }
  243. func Test__ibkr_ShouldOpenPosition(t *testing.T) {
  244. type args struct {
  245. portfolio sentio.Portfolio
  246. proba float64
  247. time string
  248. }
  249. tests := []struct {
  250. args args
  251. symbol *string
  252. size float64
  253. }{
  254. {
  255. args: args{
  256. portfolio: newStubPortfolio(),
  257. proba: 1.00201,
  258. time: "2024-08-02T18:30:00Z",
  259. },
  260. symbol: lo.ToPtr("521525019"),
  261. size: .6,
  262. },
  263. {
  264. args: args{
  265. portfolio: newStubPortfolio(
  266. PositionStub{
  267. symbol: "521525019",
  268. size: 1,
  269. price: 19,
  270. },
  271. ),
  272. proba: 1.00201,
  273. time: "2024-08-02T18:30:00Z",
  274. },
  275. symbol: lo.ToPtr("521525019"),
  276. size: .3,
  277. },
  278. {
  279. args: args{
  280. portfolio: newStubPortfolio(
  281. PositionStub{
  282. symbol: "521525019",
  283. size: -.2,
  284. price: 19,
  285. },
  286. ),
  287. proba: 1.00201,
  288. time: "2024-08-02T18:30:00Z",
  289. },
  290. symbol: lo.ToPtr("521525019"),
  291. size: .6,
  292. },
  293. {
  294. args: args{
  295. portfolio: newStubPortfolio(
  296. PositionStub{
  297. symbol: "521525020",
  298. size: 3,
  299. price: 19,
  300. },
  301. ),
  302. proba: 1.00201,
  303. time: "2024-08-02T18:30:00Z",
  304. },
  305. symbol: lo.ToPtr("521525019"),
  306. size: .6,
  307. },
  308. {
  309. args: args{
  310. portfolio: newStubPortfolio(),
  311. proba: .9979,
  312. time: "2024-08-02T18:30:00Z",
  313. },
  314. symbol: lo.ToPtr("569311092"),
  315. size: .8,
  316. },
  317. {
  318. args: args{
  319. portfolio: newStubPortfolio(
  320. PositionStub{
  321. symbol: "569311092",
  322. size: 100,
  323. price: 8,
  324. },
  325. ),
  326. proba: .9979,
  327. time: "2024-08-02T18:30:00Z",
  328. },
  329. symbol: lo.ToPtr("569311092"),
  330. size: .3,
  331. },
  332. {
  333. args: args{
  334. portfolio: newStubPortfolio(
  335. PositionStub{
  336. symbol: "521525020",
  337. size: 100,
  338. price: 8,
  339. },
  340. ),
  341. proba: .9979,
  342. time: "2024-08-02T19:00:00Z",
  343. },
  344. symbol: nil,
  345. size: 0,
  346. },
  347. {
  348. args: args{
  349. portfolio: newStubPortfolio(
  350. PositionStub{
  351. symbol: "569311092",
  352. size: 100,
  353. price: 8,
  354. },
  355. ),
  356. proba: -1,
  357. time: "2024-08-02T18:30:00Z",
  358. },
  359. symbol: nil,
  360. size: 0,
  361. },
  362. }
  363. for _, tt := range tests {
  364. t.Run("IBKR:ShouldOpenPosition", func(t *testing.T) {
  365. var (
  366. c ClockFixed
  367. s _ibkr
  368. err error
  369. )
  370. if c.fix, err = time.ParseInLocation(time.RFC3339, tt.args.time, time.UTC); err != nil {
  371. t.Errorf("ParseInLocation() = %v", err)
  372. return
  373. }
  374. s = _ibkr{
  375. clock: c,
  376. }
  377. symbol, size := s.ShouldOpenPosition(tt.args.portfolio, tt.args.proba)
  378. if !reflect.DeepEqual(symbol, tt.symbol) {
  379. t.Errorf("ShouldOpenPosition() symbol = %v, want %v", symbol, tt.symbol)
  380. }
  381. if size != tt.size {
  382. t.Errorf("ShouldOpenPosition() size = %v, want %v", size, tt.size)
  383. }
  384. })
  385. }
  386. }