quickapp: add api request

src/platforms/quickapp-vue/service/api/network/request.js

+import {
+  publish
+} from '../../bridge'
+
+import stream from '@system.fetch'
+
+let requestTaskId = 0
+const requestTasks = {}
+
+const publishStateChange = res => {
+  publish('onRequestTaskStateChange', res)
+  delete requestTasks[requestTaskId]
+}
+
+export function createRequestTaskById (requestTaskId, {
+  url,
+  data,
+  header,
+  method = 'GET',
+  responseType,
+  sslVerify = true
+} = {}) {
+  let abortTimeout
+  let aborted
+
+  const timeout = 60000
+  if (timeout) {
+    abortTimeout = setTimeout(() => {
+      aborted = true
+      publishStateChange({
+        requestTaskId,
+        state: 'fail',
+        statusCode: 0,
+        errMsg: 'timeout'
+      })
+    }, (timeout + 100))
+  }
+  const options = {
+    method,
+    url: url.trim(),
+    header,
+    type: responseType,
+    timeout: timeout || 6e5
+  }
+  if (method !== 'GET') {
+    options.body = data
+  }
+  try {
+    stream.fetch({
+      ...options,
+      success: ({
+        code,
+        data,
+        headers
+      }) => {
+        console.log(data)
+        if (aborted) {
+          return
+        }
+        if (abortTimeout) {
+          clearTimeout(abortTimeout)
+        }
+        const statusCode = code
+        if (statusCode > 0) {
+          publishStateChange({
+            requestTaskId,
+            state: 'success',
+            data: data,
+            statusCode,
+            header: headers
+          })
+        } else {
+          publishStateChange({
+            requestTaskId,
+            state: 'fail',
+            statusCode,
+            errMsg: 'abort statusCode:' + statusCode
+          })
+        }
+      },
+      fail: (data, code) => {
+        publishStateChange({
+          requestTaskId,
+          state: 'fail',
+          statusCode: code,
+          errMsg: 'abort statusCode:' + code
+        })
+      }
+    })
+    requestTasks[requestTaskId] = {
+      abort () {
+        aborted = true
+        if (abortTimeout) {
+          clearTimeout(abortTimeout)
+        }
+        publishStateChange({
+          requestTaskId,
+          state: 'fail',
+          statusCode: 0,
+          errMsg: 'abort'
+        })
+      }
+    }
+  } catch (e) {
+    return {
+      requestTaskId,
+      errMsg: 'createRequestTask:fail'
+    }
+  }
+  return {
+    requestTaskId,
+    errMsg: 'createRequestTask:ok'
+  }
+}
+
+export function createRequestTask (args) {
+  return createRequestTaskById(++requestTaskId, args)
+}
+
+export function operateRequestTask ({
+  requestTaskId,
+  operationType
+} = {}) {
+  const requestTask = requestTasks[requestTaskId]
+  if (requestTask && operationType === 'abort') {
+    requestTask.abort()
+    return {
+      errMsg: 'operateRequestTask:ok'
+    }
+  }
+  return {
+    errMsg: 'operateRequestTask:fail'
+  }
+}

src/platforms/quickapp-vue/service/base-api.js

@@ -5,5 +5,6 @@ export * from 'uni-core/service/api/base/interceptor'
 export * from 'uni-core/service/api/base/upx2px'
 
 export * from 'uni-core/service/api/context/audio'
-export * from 'uni-core/service/api/context/background-audio'
+export * from 'uni-core/service/api/context/background-audio'
+export * from 'uni-core/service/api/network/request'
 // TODO

src/platforms/quickapp-vue/service/bridge.js

 export function invoke (...args) {
   return global.UniServiceJSBridge.invokeCallbackHandler(...args)
 }
+
+export function publish (name, ...args) {
+  return global.UniServiceJSBridge.emit('api.' + name, ...args)
+}

src/platforms/quickapp-vue/service/platform-api.js

@@ -4,3 +4,6 @@ export * from './api/route/redirect-to'
 
 // device
 export * from './api/device/clipboard'
+
+// network
+export * from './api/network/request'