31 篇博文 含有标签「node.js」

const puppeteer = require('puppeteer');
const pageUrl = 'https://some-url.com';

(async () => {
  const browser = await puppeteer.launch();
  const page = await browser.newPage();
  await page.setRequestInterception(true);

  page.on('request', (interceptedRequest) => {
    // Don't intercept main document request
    if (interceptedRequest.url === pageUrl) {
      interceptedRequest.continue();
      return;
    }

    // Intercept if request url starts with https
    if (interceptedRequest.url.startsWith('https://')) {
      interceptedRequest.continue({
        // Replace https:// in url with http://
        url: interceptedRequest.url.replace('https://', 'http://'),
      });
      return;
    }

    // Don't override other requests
    interceptedRequest.continue();
  })

  await page.goto(pageUrl);
  await browser.close();
})();

// 查询并增加一次计数
async incr (id) {
    const key = `${this.namespace}:${id}`
    const now = getMicrotime()
    const start = now - this.duration * 1000

    const operations = [
      ['zremrangebyscore', key, 0, start],
      ['zcard', key],
      ['zadd', key, now, now],
      ['pexpire', key, this.duration]
    ]

    const res = await this.redis.multi(operations).exec()
    const count = toNumber(res[1][1])
    return count
}

Cannot read property '1' of undefined

const Fs = require('fs')
const Path = require('path')
const Axios = require('axios')

async function downloadImage () {
  const url = 'https://unsplash.com/photos/AaEQmoufHLk/download?force=true'
  const path = Path.resolve(__dirname, 'images', 'code.jpg')
  const writer = Fs.createWriteStream(path)

  const response = await Axios({
    url,
    method: 'GET',
    responseType: 'stream'
  })

  response.data.pipe(writer)

  return new Promise((resolve, reject) => {
    writer.on('finish', resolve)
    writer.on('error', reject)
  })
}

downloadImage()

Error: Invalid login: 535 Error: authentication failed

const _ = require('lodash')
const nodemailer = require('nodemailer')

async function main () {
  const mailer = nodemailer.createTransport({
    host: 'smtp.126.com',
    port: 465,
    pool: true,
    secure: true,
    auth: {
      type: 'login',
      user: 'xxxxx@126.com',
      pass: 'xxxxx'    // 如果开启了客户端授权码，则这里需要填写客户端授权码
    },
    tls: {
      rejectUnauthorized: false
    }
  })

  const sendMailOptions = {
    from: 'xxxxxxx@126.com',
    to: 'xxxxxx@163.com',
    subject: ' 测试主题 ',
    html: ' 测试内容 '
  }

  const result = await mailer.sendMail(sendMailOptions)

  if (!_.startsWith(_.get(result, 'response'), '250 Mail OK')) {
    return Promise.reject(new Error('Send mail fail'))
  }

  return result.response
}

main()

var vim = require('child_process').spawn('vim', ['test.txt'], {stdio: 'inherit'});

vim.on('exit', () => {
  console.log('saved txt')
  process.exit(0)
});

const redis = require('redis')
const CONF = {db:3}

let pub, sub

// Activate "notify-keyspace-events" for expired type events
pub = redis.createClient(CONF)
pub.send_command('config', ['set','notify-keyspace-events','Ex'], subscribeExpired)

// Subscribe to the "notify-keyspace-events" channel used for expired type events
function subscribeExpired(e, r){
 sub = redis.createClient(CONF)
 const expired_subKey = `__keyevent@${CONF.db}__:expired`

 sub.subscribe(expired_subKey, function () {
  console.log(' [i] Subscribed to "'+expired_subKey+'" event channel : '+r)
  sub.on('message', function (chan, msg){
  	console.log('[expired]', msg)}
  )
  TestKey()
 })
}

//例如，设置一个 key 并设置 10s 超时
function TestKey(){
 pub.set('testing', 'redis notify-keyspace-events : expired')
 pub.expire('testing', 10)
}