41
41
42
42
symbol = 'TS1'
43
43
symbol2 = 'TS2'
44
+ symbol3 = 'TS3'
44
45
45
46
46
47
def test_ArcticTransaction_can_do_first_writes (library ):
@@ -121,6 +122,9 @@ def test_metadata_changes_writes(library):
121
122
122
123
123
124
def test_audit_read (library ):
125
+ with ArcticTransaction (library , symbol3 , 'u3' , 'foo' ) as mt :
126
+ mt .write (symbol3 , ts1 )
127
+
124
128
with ArcticTransaction (library , symbol , 'u1' , 'l1' ) as mt :
125
129
mt .write (symbol , ts1 )
126
130
@@ -142,6 +146,14 @@ def test_audit_read(library):
142
146
assert symbol_audit_log == [{u'new_v' : 2 , u'symbol' : u'TS1' , u'message' : u'l2' , u'user' : u'u2' , u'orig_v' : 1 },
143
147
{u'new_v' : 1 , u'symbol' : u'TS1' , u'message' : u'l1' , u'user' : u'u1' , u'orig_v' : 0 }]
144
148
149
+
150
+ symbols_audit_log = library .read_audit_log (symbol = [symbol , symbol2 ])
151
+
152
+ assert symbols_audit_log == [{u'new_v' : 1 , u'symbol' : u'TS2' , u'message' : u'l2' , u'user' : u'u2' , u'orig_v' : 0 },
153
+ {u'new_v' : 2 , u'symbol' : u'TS1' , u'message' : u'l2' , u'user' : u'u2' , u'orig_v' : 1 },
154
+ {u'new_v' : 1 , u'symbol' : u'TS1' , u'message' : u'l1' , u'user' : u'u1' , u'orig_v' : 0 }]
155
+
156
+
145
157
symbol_message_audit_log = library .read_audit_log (symbol = symbol , message = 'l2' )
146
158
147
159
assert symbol_message_audit_log == [{u'new_v' : 2 , u'symbol' : u'TS1' , u'message' : u'l2' , u'user' : u'u2' , u'orig_v' : 1 }, ]
0 commit comments