parsing subs as specced for state v3

lib/sync/subscription/parse.js

@@ -1,5 +1,5 @@
 'use strict'
-
+const isFn = /^\$fn-/
 module.exports = function (subs) {
   subs = parse(subs)
   return subs
@@ -8,11 +8,12 @@ module.exports = function (subs) {
 function parse (obj) {
   const result = {}
   for (let i in obj) {
-    if (/^\$fn-/.test(i)) {
+    if (isFn.test(i)) {
       let val = obj[i]
       i = i.slice(4)
       // need to fix babel stuff in these parses
-      obj[i] = new Function('return ' + val)() //eslint-disable-line
+      // a posbility is to add some extra arguments
+      obj[i] = new Function('return ' + val)() // eslint-disable-line
     }
     if (i === 'val' || i === 'done') {
       result[i] = obj[i]

lib/sync/subscription/serialize.js

@@ -3,7 +3,6 @@ module.exports = function serializeSubscription (state, subs) {
   if ('client' in subs) {
     let hub = state.getRoot()
     if (hub === state) {
-      console.log('special handle for client')
       subs.clients = { [hub.id]: subs.client }
       delete subs.client
     }
@@ -18,15 +17,10 @@ function parse (obj, last) {
   const result = {}
   for (let i in obj) {
     if (i !== '_') {
-      // also check for field 'map'
-      if (i === 'map' && typeof obj[i] === 'function') {
+      if (i === 'exec' && typeof obj[i] === 'function') {
         result['$fn-' + i] = obj[i].toString()
       } else if (i === 'val' || i === 'done') {
-        if (typeof obj[i] === 'function') {
-          result['$fn-' + i] = obj[i].toString()
-        } else {
-          result[i] = obj[i]
-        }
+        result[i] = obj[i]
       } else {
         result[i] = parse(obj[i])
       }