New Feature

可以获取和设置微信保持登录同步的属性
利用本特性可以做免扫码登录

Author: spacelan

run-core.js

@@ -5,7 +5,13 @@ const qrcode = require('qrcode-terminal')
 const fs = require('fs')
 const request = require('request')
 
-let bot = new Wechat()
+let bot
+// 尝试获取本地登录数据，免扫码
+try {
+  bot = new Wechat(require('./sync-data.json'))
+} catch (e) {
+  bot = new Wechat()
+}
 
 bot.on('error', err => {
   console.log('错误：', err)
@@ -26,13 +32,12 @@ bot.on('user-avatar', avatar => {
 
 bot.on('login', () => {
   console.log('登录成功')
-  let ToUserName = bot.contacts['filehelper'].UserName || 'filehelper'
 
+  // 保存登录数据
+  fs.writeFileSync('./sync-data.json', JSON.stringify(bot.botData))
+
+  let ToUserName = bot.contacts['filehelper'].UserName || 'filehelper'
   // 发送文本消息，可以包含emoji(😒)和QQ表情([坏笑])
-  // bot.sendText('发送文本消息，可以包含emoji(😒)和QQ表情([坏笑])', ToUserName)
-  //   .catch(err => {
-  //     console.log(err)
-  //   })
   bot.sendMsg('发送文本消息，可以包含emoji(😒)和QQ表情([坏笑])', ToUserName)
     .catch(err => {
       console.log(err)
@@ -50,9 +55,9 @@ bot.on('login', () => {
   //     console.log(err)
   //   })
   bot.sendMsg({
-      file: request('https://raw.githubusercontent.com/nodeWechat/wechat4u/master/bot-qrcode.jpg'),
-      filename: 'bot-qrcode.jpg'
-    }, ToUserName)
+    file: request('https://raw.githubusercontent.com/nodeWechat/wechat4u/master/bot-qrcode.jpg'),
+    filename: 'bot-qrcode.jpg'
+  }, ToUserName)
     .catch(err => {
       console.log(err)
     })
@@ -72,8 +77,8 @@ bot.on('login', () => {
   //     console.log(err)
   //   })
   bot.sendMsg({
-      file: fs.createReadStream('./media/test.gif')
-    }, ToUserName)
+    file: fs.createReadStream('./media/test.gif')
+  }, ToUserName)
     .catch(err => {
       console.log(err)
     })
@@ -87,8 +92,8 @@ bot.on('login', () => {
   //     console.log(err)
   //   })
   bot.sendMsg({
-      file: fs.createReadStream('./media/test.mp4')
-    }, ToUserName)
+    file: fs.createReadStream('./media/test.mp4')
+  }, ToUserName)
     .catch(err => {
       console.log(err)
     })
@@ -102,8 +107,8 @@ bot.on('login', () => {
   //     console.log(err)
   //   })
   bot.sendMsg({
-      file: fs.createReadStream('./media/test.txt')
-    }, ToUserName)
+    file: fs.createReadStream('./media/test.txt')
+  }, ToUserName)
     .catch(err => {
       console.log(err)
     })
@@ -142,6 +147,13 @@ bot.on('message', msg => {
       }).catch(err => {
         console.log(err)
       })
+      // 直接转发图片消息
+      bot.sendPic({
+        Content: msg.Content
+      }, msg.FromUserName)
+        .catch(err => {
+          bot.emit('error', err)
+        })
       break
     case bot.CONF.MSGTYPE_VOICE:
       // 语音消息
@@ -172,6 +184,13 @@ bot.on('message', msg => {
       }).catch(err => {
         console.log(err)
       })
+      // 直接转发视频消息
+      bot.sendVideo({
+        Content: msg.Content
+      }, msg.FromUserName)
+        .catch(err => {
+          bot.emit('error', err)
+        })
       break
     case bot.CONF.MSGTYPE_MICROVIDEO:
       // 小视频消息

src/core.js

@@ -16,7 +16,7 @@ const debug = _debug('core')
 
 export default class WechatCore {
 
-  constructor () {
+  constructor (data) {
     this.PROP = {
       uuid: '',
       uin: '',
@@ -29,10 +29,29 @@ export default class WechatCore {
         List: []
       }
     }
-
     this.CONF = getCONF()
+    this.COOKIE = {}
     this.user = {}
-    this.request = new Request()
+    if (data) {
+      this.botData = data
+    }
+
+    this.request = new Request({
+      Cookie: this.COOKIE
+    })
+  }
+
+  get botData () {
+    return {
+      PROP: this.PROP,
+      CONF: this.CONF,
+      COOKIE: this.COOKIE,
+      user: this.user
+    }
+  }
+
+  set botData (data) {
+    Object.assign(this, data)
   }
 
   getUUID () {

src/util/request.js

@@ -1,5 +1,4 @@
 import axios from 'axios'
-import CM from 'cookie-manager'
 import {isStandardBrowserEnv} from './global'
 
 const getPgv = c => {
@@ -19,20 +18,24 @@ export function Request (defaults) {
 
   this.axios = axios.create(defaults)
   if (!isStandardBrowserEnv) {
-    this.cm = new CM()
-    this.cm.store('', ['pgv_pvi=' + getPgv() + '; Domain=.qq.com; Path=/', 'pgv_si=' + getPgv('s') + '; Domain=.qq.com; Path=/'])
-    this.axios.interceptors.request.use(config => {
-      config.headers['cookie'] = config.url ? decodeURIComponent(this.cm.prepare(config.url)) : ''
-      return config
-    }, err => {
-      return Promise.reject(err)
-    })
+    this.Cookie = defaults.Cookie || {}
+    this.Cookie['pgv_pvi'] = getPgv()
+    this.Cookie['pgv_si'] = getPgv('s')
+    this.axios.defaults.headers.common['cookie'] = Object.keys(this.Cookie).map(key => {
+      return `${key}=${this.Cookie[key]}`
+    }).join('; ')
     this.axios.interceptors.response.use(res => {
       let setCookie = res.headers['set-cookie']
       if (setCookie) {
-        this.cm.store(res.config.url, setCookie.map(item => {
-          return item.replace(/=\s*?(?=(\w+\.)*(wx\d?\.qq\.com|wechat\.com))/, '=.')
-        }))
+        setCookie.forEach(item => {
+          let pm = item.match(/^(.+?)\s?\=\s?(.+?);/)
+          if (pm) {
+            this.Cookie[pm[1]] = pm[2]
+          }
+        })
+        this.axios.defaults.headers.common['cookie'] = Object.keys(this.Cookie).map(key => {
+          return `${key}=${this.Cookie[key]}`
+        }).join('; ')
       }
       return res
     }, err => {

src/wechat.js

@@ -21,8 +21,8 @@ if (!isStandardBrowserEnv) {
 
 class Wechat extends WechatCore {
 
-  constructor () {
-    super()
+  constructor (data) {
+    super(data)
     _.extend(this, new EventEmitter())
     this.state = this.CONF.STATE.init
     this.contacts = {} // 所有联系人
@@ -155,10 +155,21 @@ class Wechat extends WechatCore {
   }
 
   start () {
-    return this.startLogin()
-      .then(() => this.startInit())
-      .then(() => this.startGetContact())
+    Promise.resolve(this.PROP.uin ? Promise.resolve() : Promise.reject())
       .then(() => {
+        return this.init()
+          .then(() => this.notifyMobile())
+      })
+      .catch(() => {
+        return this.startLogin()
+          .then(() => this.startInit())
+      })
+      .then(() => {
+        this.startGetContact()
+          .catch(err => {
+            debug(err)
+            bot.emit('error', err)
+          })
         this.emit('login')
         this.state = this.CONF.STATE.login
         this.lastSyncTime = Date.now()