feat: 更新订阅信息
This commit is contained in:
parent
9a378275e1
commit
645bfa7f85
@ -42,12 +42,13 @@ redisSubscriber.on('message', (channel, message) => {
|
|||||||
const m = JSON.parse(message) as MessageData;
|
const m = JSON.parse(message) as MessageData;
|
||||||
clients.forEach((client) => {
|
clients.forEach((client) => {
|
||||||
const data = client.data as any;
|
const data = client.data as any;
|
||||||
const { cid, cids = [] } = data || {};
|
const { cid, cids = [], pid } = data || {};
|
||||||
const wrapper = (data: any) => {
|
const wrapper = (data: any) => {
|
||||||
const res = {
|
const res = {
|
||||||
type: 'pageEdit',
|
type: 'pageEdit',
|
||||||
source: 'container',
|
source: 'container',
|
||||||
data,
|
data,
|
||||||
|
pid,
|
||||||
};
|
};
|
||||||
return JSON.stringify(res);
|
return JSON.stringify(res);
|
||||||
};
|
};
|
||||||
|
Loading…
x
Reference in New Issue
Block a user