refactor(utils): extract asyncSuit scope

Author: mydearxym

containers/WikiThread/logic.js

@@ -3,25 +3,19 @@ import { useEffect } from 'react'
 
 import {
   buildLog,
-  // asyncSuit,
+  asyncSuit,
   CONSTANT,
-  // SR71,
-  $solver,
-  asyncRes,
-  asyncErr,
   errRescue,
   BStore,
   nilOrEmpty,
 } from '@utils'
 
-// import CONSTANT from '@utils/constant'
 import { githubApi } from '@services'
-
-import SR71 from '@utils/async/sr71'
 import S from './schema'
 
-// const { SR71, $solver, asyncRes, asyncErr } = asyncSuit
+const { SR71, $solver, asyncRes, asyncErr } = asyncSuit
 const { TYPE, EVENT, ERR, THREAD } = CONSTANT
+
 const sr71$ = new SR71({
   resv_event: [EVENT.COMMUNITY_CHANGE, EVENT.TABBER_CHANGE],
 })

utils/async/handler.js

@@ -3,12 +3,16 @@ import R from 'ramda'
 /* import { Observable } from 'rxjs/Observable' */
 import { of } from 'rxjs'
 
-import { buildLog, ERR } from '..'
+import constant from '../constant'
+
 import { TIMEOUT_THRESHOLD } from './setup'
+import { buildLog } from '../logger'
 
 /* eslint-disable-next-line */
 const log = buildLog('Async')
 
+const { ERR } = constant
+
 export const TimoutObservable = of({
   error: ERR.TIMEOUT,
   details: `server has no-response in ${Math.round(

utils/async/index.js

@@ -1,51 +1,2 @@
-import { from } from 'rxjs'
-import fetch from 'isomorphic-fetch'
-
-import { buildLog } from '@utils'
-import { client, context } from './setup'
-
-import { getThenHandler, getCatchHandler, formatGraphErrors } from './handler'
-
-/* eslint-disable-next-line */
-const log = buildLog('Async')
-
-const doQuery = (query, variables) =>
-  client
-    .query({
-      query,
-      variables,
-      context,
-    })
-    .then(res => {
-      if (res.errors) return formatGraphErrors(res.errors)
-      return res.data
-    })
-    .catch(formatGraphErrors)
-
-const doMutate = (mutation, variables) =>
-  client
-    .mutate({
-      mutation,
-      variables,
-      context,
-    })
-    .then(res => {
-      // once login user has mutation to server
-      // then clear all the cache store in Apollo client.
-      client.clearStore()
-      return res.data
-    })
-    .catch(formatGraphErrors)
-
-const GET = url =>
-  fetch(`${url}`)
-    .then(getThenHandler)
-    .catch(getCatchHandler)
-
-export const queryPromise = ({ query, variables }) =>
-  from(doQuery(query, variables))
-
-export const mutatePromise = ({ mutation, variables }) =>
-  from(doMutate(mutation, variables))
-
-export const restGetPromise = url => from(GET(url))
+export { default as SR71 } from './sr71'
+export const holder = 1

utils/async/methods.js

@@ -0,0 +1,51 @@
+import { from } from 'rxjs'
+import fetch from 'isomorphic-fetch'
+
+import { buildLog } from '../logger'
+import { client, context } from './setup'
+
+import { getThenHandler, getCatchHandler, formatGraphErrors } from './handler'
+
+/* eslint-disable-next-line */
+const log = buildLog('Async')
+
+const doQuery = (query, variables) =>
+  client
+    .query({
+      query,
+      variables,
+      context,
+    })
+    .then(res => {
+      if (res.errors) return formatGraphErrors(res.errors)
+      return res.data
+    })
+    .catch(formatGraphErrors)
+
+const doMutate = (mutation, variables) =>
+  client
+    .mutate({
+      mutation,
+      variables,
+      context,
+    })
+    .then(res => {
+      // once login user has mutation to server
+      // then clear all the cache store in Apollo client.
+      client.clearStore()
+      return res.data
+    })
+    .catch(formatGraphErrors)
+
+const GET = url =>
+  fetch(`${url}`)
+    .then(getThenHandler)
+    .catch(getCatchHandler)
+
+export const queryPromise = ({ query, variables }) =>
+  from(doQuery(query, variables))
+
+export const mutatePromise = ({ mutation, variables }) =>
+  from(doMutate(mutation, variables))
+
+export const restGetPromise = url => from(GET(url))

utils/async/setup.js

@@ -5,16 +5,19 @@ import { onError } from 'apollo-link-error'
 import { ApolloClient } from 'apollo-client'
 import { InMemoryCache } from 'apollo-cache-inmemory'
 import fetch from 'isomorphic-fetch'
-import { GRAPHQL_ENDPOINT } from '@config'
-import { errRescue } from '../functions'
-import { ERR } from '../constants'
 
 /* import { onError } from 'apollo-link-error' */
 
-import { buildLog, BStore } from '..'
+import { GRAPHQL_ENDPOINT } from '@config'
+
+import { errRescue } from '../functions'
+import constant from '../constant'
+import { buildLog } from '../logger'
+import BStore from '../bstore'
 
 /* eslint-disable-next-line */
 const log = buildLog('Async')
+const { ERR } = constant
 
 const graphLink = new HttpLink({ uri: GRAPHQL_ENDPOINT, fetch })
 

utils/async/sr71.js

@@ -14,7 +14,7 @@ import {
 import { TimoutObservable } from './handler'
 import { TIMEOUT_THRESHOLD } from './setup'
 
-import { queryPromise, mutatePromise, restGetPromise } from './index'
+import { queryPromise, mutatePromise, restGetPromise } from './methods'
 
 // import { debounceTime, switchMap, merge, timeoutWith } from 'rxjs/operator'
 

utils/async_suit.js

@@ -0,0 +1,10 @@
+import SR71 from './async/sr71'
+import { asyncErr, asyncRes } from './graphql_helper'
+import { $solver } from './mobx_helper'
+
+export default {
+  SR71,
+  asyncErr,
+  asyncRes,
+  $solver,
+}

utils/index.js

@@ -1,12 +1,8 @@
 /*
  * utils functiosn
  */
-// import SR71 from './async/sr71'
-// import { asyncErr, asyncRes } from './graphql_helper'
-// import { $solver } from './mobx_helper'
 
-// aka network staff
-// export const asyncSuit = { SR71, asyncErr, asyncRes, $solver }
+export { default as asyncSuit } from './async_suit'
 export { default as CONSTANT } from './constant'
 
 export {
@@ -26,8 +22,6 @@ export {
   PAYMENT_METHOD,
 } from './constants'
 
-// export { default as CONSTANT } from './constant'
-
 export { buildLog } from './logger'
 
 export { default as uid } from './uid'