@@ -33,15 +33,15 @@ import {
3333} from './utils'
3434
3535export const ensureCurrentApp : Operator < Message > = action (
36- ( { value : message , state } ) => {
36+ ( { state } , message ) => {
3737 if ( ! state . currentAppName ) {
3838 state . currentAppName = message . appName
3939 }
4040 }
4141)
4242
4343export const runGetterMutation : Operator < GetterMessage > = action (
44- ( { value : message , state } ) => {
44+ ( { state } , message ) => {
4545 runMutation ( state . apps [ message . appName ] . state ) ( {
4646 method : 'set' ,
4747 path : message . data . path ,
@@ -60,20 +60,15 @@ export const isPortExistsMessage: (
6060 false : Operator < Message , any >
6161 }
6262) => Operator < Message > = ( paths ) =>
63- when (
64- ( { value : message } ) => message . messages [ 0 ] . type === 'PORT_EXISTS' ,
65- paths
66- )
67-
68- export const addState : Operator < InitMessage > = action (
69- ( { value : message , state } ) => {
70- state . isConnecting = false
71- state . apps [ message . appName ] . state = message . data . state
72- }
73- )
63+ when ( ( _ , message ) => message . messages [ 0 ] . type === 'PORT_EXISTS' , paths )
64+
65+ export const addState : Operator < InitMessage > = action ( ( { state } , message ) => {
66+ state . isConnecting = false
67+ state . apps [ message . appName ] . state = message . data . state
68+ } )
7469
7570export const addFlushAndRunMutations : Operator < FlushMessage > = action (
76- ( { value : message , state } ) => {
71+ ( { state } , message ) => {
7772 ensureFlushExists ( state . apps [ message . appName ] . flushes , message . data . flushId )
7873 state . apps [ message . appName ] . flushes [ message . data . flushId ] . mutations =
7974 message . data . mutations
@@ -96,21 +91,19 @@ export const addFlushAndRunMutations: Operator<FlushMessage> = action(
9691 }
9792)
9893
99- export const ensureApp : Operator < Message > = action (
100- ( { value : message , state } ) => {
101- if (
102- ! state . apps [ message . appName ] ||
103- message . messages [ 0 ] . type === ExecutionType . INIT
104- ) {
105- state . apps [ message . appName ] = createApp ( {
106- name : message . appName ,
107- } )
108- }
94+ export const ensureApp : Operator < Message > = action ( ( { state } , message ) => {
95+ if (
96+ ! state . apps [ message . appName ] ||
97+ message . messages [ 0 ] . type === ExecutionType . INIT
98+ ) {
99+ state . apps [ message . appName ] = createApp ( {
100+ name : message . appName ,
101+ } )
109102 }
110- )
103+ } )
111104
112105export const addClientMessages : Operator < Message > = action (
113- ( { value : message , state } ) => {
106+ ( { state } , message ) => {
114107 state . apps [ message . appName ] . messages = JSON . parse (
115108 JSON . stringify ( message . messages )
116109 )
@@ -120,7 +113,7 @@ export const addClientMessages: Operator<Message> = action(
120113)
121114
122115export const addComponent : Operator < AddComponentMessage > = action (
123- ( { value : message , state } ) => {
116+ ( { state } , message ) => {
124117 const id = `${ message . data . componentId } _${ message . data . componentInstanceId } `
125118
126119 state . apps [ message . appName ] . components [ id ] = {
@@ -134,7 +127,7 @@ export const addComponent: Operator<AddComponentMessage> = action(
134127)
135128
136129export const updateComponent : Operator < UpdateComponentMessage > = action (
137- ( { value : message , state } ) => {
130+ ( { state } , message ) => {
138131 const id = `${ message . data . componentId } _${ message . data . componentInstanceId } `
139132
140133 state . apps [ message . appName ] . components [ id ] . paths = message . data . paths
@@ -155,15 +148,15 @@ export const updateComponent: Operator<UpdateComponentMessage> = action(
155148)
156149
157150export const removeComponent : Operator < RemoveComponentMessage > = action (
158- ( { value : message , state } ) => {
151+ ( { state } , message ) => {
159152 const id = `${ message . data . componentId } _${ message . data . componentInstanceId } `
160153
161154 state . apps [ message . appName ] . components [ id ] . isMounted = false
162155 }
163156)
164157
165158export const updateDerived : Operator < DerivedMessage > = action (
166- ( { value : message , state } ) => {
159+ ( { state } , message ) => {
167160 const appState = state . apps [ message . appName ] . state
168161 const path = message . data . path . split ( '.' )
169162 const key = path . pop ( )
@@ -175,7 +168,7 @@ export const updateDerived: Operator<DerivedMessage> = action(
175168)
176169
177170export const updateFlushWithDerived : Operator < DirtyDerivedMessage > = action (
178- ( { value : message , state } ) => {
171+ ( { state } , message ) => {
179172 ensureFlushExists ( state . apps [ message . appName ] . flushes , message . data . flushId )
180173 state . apps [ message . appName ] . flushes [ message . data . flushId ] . derived . push (
181174 message . data . path
@@ -184,7 +177,7 @@ export const updateFlushWithDerived: Operator<DirtyDerivedMessage> = action(
184177)
185178
186179export const addAction : Operator < StartActionMessage > = action (
187- ( { value : message , state } ) => {
180+ ( { state } , message ) => {
188181 const app = state . apps [ message . appName ]
189182 const action = message . data
190183 const actionId = getActionId ( action )
@@ -228,7 +221,7 @@ export const addAction: Operator<StartActionMessage> = action(
228221)
229222
230223export const addOperator : Operator < StartOperatorMessage > = action (
231- ( { value : message , state } ) => {
224+ ( { state } , message ) => {
232225 const operatorData = message . data
233226 const actionId = getActionId ( operatorData )
234227 const action = state . apps [ message . appName ] . actions [ actionId ]
@@ -263,7 +256,7 @@ export const addOperator: Operator<StartOperatorMessage> = action(
263256)
264257
265258export const updateOperator : Operator < EndOperatorMessage > = action (
266- ( { value : message , state } ) => {
259+ ( { state } , message ) => {
267260 const operatorData = message . data
268261 const actionId = getActionId ( operatorData )
269262 const action = state . apps [ message . appName ] . actions [ actionId ]
@@ -278,7 +271,7 @@ export const updateOperator: Operator<EndOperatorMessage> = action(
278271)
279272
280273export const updateAction : Operator < EndActionMessage > = action (
281- ( { value : message , state } ) => {
274+ ( { state } , message ) => {
282275 const app = state . apps [ message . appName ]
283276 const action = message . data
284277 const id = `${ action . actionId } _${ action . executionId } `
@@ -288,7 +281,7 @@ export const updateAction: Operator<EndActionMessage> = action(
288281)
289282
290283export const addMutations : Operator < MutationsMessage > = action (
291- ( { value : message , state } ) => {
284+ ( { state } , message ) => {
292285 const mutations = message . data
293286 const id = `${ mutations . actionId } _${ mutations . executionId } `
294287 const operator =
@@ -304,7 +297,7 @@ export const addMutations: Operator<MutationsMessage> = action(
304297)
305298
306299export const updateEffect : Operator < EffectMessage > = action (
307- ( { value : message , state } ) => {
300+ ( { state } , message ) => {
308301 const effect = message . data
309302 const id = getActionId ( effect )
310303 const action = state . apps [ message . appName ] . actions [ id ]
@@ -332,7 +325,7 @@ export const updateEffect: Operator<EffectMessage> = action(
332325)
333326
334327export const getMessages : Operator < Message , AppMessage < any > [ ] > = map (
335- ( { value } ) =>
328+ ( _ , value ) =>
336329 value . messages . map ( ( message ) => ( { ...message , appName : value . appName } ) )
337330)
338331
@@ -341,7 +334,7 @@ export const forkEachMessage: (
341334 [ key : string ] : Operator < AppMessage < any > , any >
342335 }
343336) => Operator < AppMessage < any > [ ] > = ( paths ) =>
344- forEach ( fork ( ( { value } ) => value . type , paths ) as Operator < AppMessage < any > > )
337+ forEach ( fork ( ( _ , value ) => value . type , paths ) as Operator < AppMessage < any > > )
345338
346339export const updateOperatorAsync : Operator < AsyncOperatorMessage > = action (
347340 ( ) => { }
0 commit comments