File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -47,24 +47,26 @@ def start
47
47
end
48
48
49
49
def process_message ( message , method )
50
- message = JSON . parse ( message . data , symbolize_names : true )
51
50
@config . logger . debug ( "[LDClient] Stream received #{ method } message" )
52
51
if method == PUT
52
+ message = JSON . parse ( message . data , symbolize_names : true )
53
53
@store . init ( message )
54
54
@initialized . make_true
55
55
@config . logger . info ( "[LDClient] Stream initialized" )
56
56
elsif method == PATCH
57
+ message = JSON . parse ( message . data , symbolize_names : true )
57
58
@store . upsert ( message [ :path ] [ 1 ..-1 ] , message [ :data ] )
58
59
elsif method == DELETE
60
+ message = JSON . parse ( message . data , symbolize_names : true )
59
61
@store . delete ( message [ :path ] [ 1 ..-1 ] , message [ :version ] )
60
62
elsif method == INDIRECT_PUT
61
63
@store . init ( @requestor . request_all_flags )
62
64
@initialized . make_true
63
65
@config . logger . info ( "[LDClient] Stream initialized (via indirect message)" )
64
66
elsif method == INDIRECT_PATCH
65
- @store . upsert ( @requestor . request_flag ( message [ : data] ) )
67
+ @store . upsert ( @requestor . request_flag ( message . data ) )
66
68
else
67
- @config . logger . error ( "[LDClient] Unknown message received: #{ method } " )
69
+ @config . logger . warn ( "[LDClient] Unknown message received: #{ method } " )
68
70
end
69
71
end
70
72
You can’t perform that action at this time.
0 commit comments