重构2.0

v2
yutent 2023-11-01 15:47:53 +08:00
parent 7cba707799
commit 6e6e97467d
4 changed files with 60 additions and 33 deletions

View File

@ -1,4 +1,6 @@
![module info](https://nodei.co/npm/@gm5/session.png?downloads=true&downloadRank=true&stars=true)
![downloads](https://img.shields.io/npm/dt/@gm5/request.svg)
![version](https://img.shields.io/npm/v/@gm5/request.svg)
# @gm5/session
@ -7,17 +9,20 @@
## 安装
```bash
npm install @gm5/session
npm i @gm5/session
```
## 使用
```js
import { sessionPackage, sessionConnect } from '@gm5/session'
import { createApp } from '@gm5/core
import { createSession, SessionModule } from '@gm5/session'
app.install(sessionPackage)
const app = createApp()
app.use(sessionConnect)
app.install(SessionModule, {domain: 'your_domain'})
.use(createSession)
.run()
```

View File

@ -8,45 +8,57 @@ import { uuid, sha1 } from 'crypto.js'
import RedisStore from './lib/redis-store.js'
// 会话安装包
export function createSessionPlugin(){
const DEFAULT_CONFIG = {
ttl: 3600 * 24 * 7,
domain: '', // NODESSID域, 默认等于domain
level: 0, // 校验级别, 0: 不校验客户端, 2: ua, 4: ip, 6: ua + ip
db: {
host: '127.0.0.1',
port: 6379,
db: 0
}
}
return {
name: 'session',
install() {
var session = this.get('session')
// 这里只创建session的存储器, 而初始化操作在中间件中进行
return new RedisStore(session)
// 会话安装包
export const SessionModule = {
name: 'session',
install(conf = {}) {
if (!conf.domain) {
throw new Error('Please make sure to set the `domain` field')
}
let session = Object.assign({}, DEFAULT_CONFIG, conf)
this.set({ session })
// 这里只创建session的存储器, 而初始化操作在中间件中进行
return new RedisStore(session)
}
}
// 会话中间件
export function createSession(){
export function createSession() {
return function (req, res, next) {
var opt = this.get('session')
var cache = req.cookie('NODESSID')
var deviceID = ''
var ssid
let opt = this.get('session')
let cache = req.cookie('NODESSID')
let deviceID = ''
let ssid
// options请求不处理会话
if (req.method === 'OPTIONS') {
return next()
}
// 校验UA
if (opt.level & 2) {
deviceID += req.header('user-agent')
}
// 校验IP
if (opt.level & 4) {
deviceID += req.ip()
}
if (deviceID) {
deviceID = sha1(deviceID)
// ssid 最后16位是指纹
if (cache) {
if (cache.slice(-16) === deviceID.slice(-16)) {
@ -58,12 +70,16 @@ export function createSession(){
} else {
ssid = cache || sha1(uuid())
}
res.cookie('NODESSID', ssid, { maxAge: opt.ttl, domain: opt.domain })
res.cookie('NODESSID', ssid, {
maxAge: opt.ttl,
httpOnly: true,
domain: opt.domain
})
// 缓存ssid到req上
req.ssid = ssid
this.$$session.update(ssid)
next()
}
}

View File

@ -3,7 +3,7 @@
* @author yutent<yutent.io@gmail.com>
* @date 2020/09/18 16:35:26
*/
import 'es.shim'
import Ioredis from 'ioredis'
export default class Session {
@ -27,7 +27,7 @@ export default class Session {
// 获取session字段值, 需要await指令
get(ssid, key) {
var defer = Promise.defer()
let defer = Promise.defer()
this.#store.hgetall(ssid, (err, obj) => {
if (err) {

View File

@ -1,15 +1,21 @@
{
"name": "@gm5/session",
"version": "1.1.2",
"version": "2.0.0",
"type": "module",
"description": "会话中间件。",
"main": "index.js",
"author": "yutent <yutent.io@gmail.com>",
"keywords": ["fivejs", "session", "http"],
"keywords": [
"fivejs",
"gm5",
"session",
"http"
],
"dependencies": {
"crypto.js": "^2.0.2",
"ioredis": "^4.17.3"
"crypto.js": "^3.1.2",
"ioredis": "^5.3.2",
"es.shim": "^2.2.0"
},
"repository": "https://github.com/bytedo/gmf.session.git",
"repository": "https://git.wkit.fun/gm5/session.git",
"license": "MIT"
}