fix(xod-client, xod-client-electron): clear the queued chunks of a re…

…sponse data on connection close

packages/xod-client-electron/src/debugger/tetheringInetMiddleware.js

@@ -73,6 +73,15 @@ const createListener = (dispatch, transmit, nodeId) =>
 
 const isReadOkResponse = R.startsWith(ACK);
 
+// In case that the connection is closed before than all request has been received
+// there is no reason to continue sending the response data.
+const clearQueueOnCloseConnection = R.curry((dispatch, command) =>
+  R.when(
+    R.equals('AT+CIPCLOSE'),
+    R.compose(dispatch, client.tetheringInetClearChunks)
+  )(command)
+);
+
 export default ({ getState, dispatch }) => next => action => {
   const state = getState();
   const result = next(action);
@@ -86,7 +95,10 @@ export default ({ getState, dispatch }) => next => action => {
     const worker = action.payload.worker;
     const transmit = createTransmitter(dispatch, worker.sendToWasm);
     const listener = createListener(dispatch, transmit, nodeId);
-    const write = AtNet.create(listener);
+    const write = R.compose(
+      AtNet.create(listener),
+      R.tap(clearQueueOnCloseConnection(dispatch))
+    );
     dispatch(
       client.tetheringInetCreated(
         action.payload.tetheringInetNodeId,

packages/xod-client/src/debugger/actionTypes.js

@@ -31,3 +31,5 @@ export const TETHERING_INET_CREATED = 'TETHERING_INET_CREATED';
 export const TETHERING_INET_CHUNKS_ADDED = 'TETHERING_INET_CHUNKS_ADDED';
 
 export const TETHERING_INET_CHUNK_SENT = 'TETHERING_INET_CHUNK_SENT';
+
+export const TETHERING_INET_CLEAR_CHUNKS = 'TETHERING_INET_CLEAR_CHUNKS';

packages/xod-client/src/debugger/actions.js

@@ -106,3 +106,7 @@ export const tetheringInetChunkSent = () => (dispatch, getState) => {
   });
   return maybeProp(0, chunksToSend);
 };
+
+export const tetheringInetClearChunks = () => ({
+  type: AT.TETHERING_INET_CLEAR_CHUNKS,
+});

packages/xod-client/src/debugger/reducer.js

@@ -23,6 +23,7 @@ import {
   TETHERING_INET_CREATED,
   TETHERING_INET_CHUNKS_ADDED,
   TETHERING_INET_CHUNK_SENT,
+  TETHERING_INET_CLEAR_CHUNKS,
 } from './actionTypes';
 
 import * as EAT from '../editor/actionTypes';
@@ -531,6 +532,8 @@ export default (state = initialState, action) => {
         R.tail,
         state
       );
+    case TETHERING_INET_CLEAR_CHUNKS:
+      return R.assocPath(['tetheringInet', 'chunksToSend'], [], state);
 
     case EAT.TABTEST_RUN_REQUESTED:
       return R.compose(