quickfix/src/C++/test/NullStoreTestCase.cpp at master · githubCode3a/quickfix · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
/****************************************************************************
** Copyright (c) 2001-2014
**
** This file is part of the QuickFIX FIX Engine
**
** This file may be distributed under the terms of the quickfixengine.org
** license as defined by quickfixengine.org and appearing in the file
** LICENSE included in the packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.quickfixengine.org/LICENSE for licensing information.
**
** Contact ask@quickfixengine.org if any conditions of this licensing are
** not clear to you.
**
****************************************************************************/

#ifdef _MSC_VER
#pragma warning( disable : 4503 4355 4786 )
#include "stdafx.h"
#else
#include "config.h"
#endif

#include <UnitTest++.h>
#include <NullStore.h>
#include <fix42/Logon.h>
#include <fix42/Heartbeat.h>
#include <fix42/TestRequest.h>
#include <fix42/NewOrderSingle.h>
#include <fix42/ExecutionReport.h>

using namespace FIX;
using namespace FIX42;

SUITE(NullStoreTests)
{

struct sharedObjectFixture
{
  static NullStore object;
};

NullStore sharedObjectFixture::object;

TEST( setGet )
{
  NullStore object;

  Logon logon;
  logon.getHeader().setField( MsgSeqNum( 1 ) );
  object.set( 1, logon.toString() );

  Heartbeat heartbeat;
  heartbeat.getHeader().setField( MsgSeqNum( 2 ) );
  object.set( 2, heartbeat.toString() );

  NewOrderSingle newOrderSingle;
  newOrderSingle.getHeader().setField( MsgSeqNum( 3 ) );
  object.set( 3, newOrderSingle.toString() );

  std::vector < std::string > messages;
  object.get( 1, 3, messages );
  CHECK_EQUAL( 0U, messages.size() );

  object.get( 4, 6, messages );
  CHECK_EQUAL( 0U, messages.size() );

  object.get( 2, 6, messages );
  CHECK_EQUAL( 0U, messages.size() );
}

TEST( setGetWithQuote )
{
  NullStore object;

  ExecutionReport singleQuote;
  singleQuote.setField( Text("Some Text") );
  object.set( 1, singleQuote.toString() );

  ExecutionReport doubleQuote;
  doubleQuote.setField( Text("\"Some Text\"") );
  object.set( 2, doubleQuote.toString() );

  ExecutionReport bothQuote;
  bothQuote.setField( Text("'\"Some Text\"'") );
  object.set( 3, bothQuote.toString() );

  ExecutionReport escape;
  escape.setField( Text("\\Some Text\\") );
  object.set( 4, escape.toString() );

  std::vector < std::string > messages;
  object.get( 1, 4, messages );
  CHECK_EQUAL( 0U, messages.size() );
}

TEST_FIXTURE( sharedObjectFixture, other )
{
  object.setNextSenderMsgSeqNum( 10 );
  CHECK_EQUAL( 10, object.getNextSenderMsgSeqNum() );
  object.setNextTargetMsgSeqNum( 20 );
  CHECK_EQUAL( 20, object.getNextTargetMsgSeqNum() );
  object.incrNextSenderMsgSeqNum();
  CHECK_EQUAL( 11, object.getNextSenderMsgSeqNum() );
  object.incrNextTargetMsgSeqNum();
  CHECK_EQUAL( 21, object.getNextTargetMsgSeqNum() );

  object.setNextSenderMsgSeqNum( 5 );
  object.setNextTargetMsgSeqNum( 6 );
}

TEST_FIXTURE( sharedObjectFixture, reload )
{
  // use same session from previous test
  CHECK_EQUAL( 5, object.getNextSenderMsgSeqNum() );
  CHECK_EQUAL( 6, object.getNextTargetMsgSeqNum() );
}

TEST_FIXTURE( sharedObjectFixture, refresh )
{
  // use same session from previous test
  object.refresh();
  CHECK_EQUAL( 5, object.getNextSenderMsgSeqNum() );
  CHECK_EQUAL( 6, object.getNextTargetMsgSeqNum() );
}
}