mrpastewart/platform
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Updates websocket analysis warnings

Browse source
This commit is contained in:
thomashii@dukefirehawk.com 2022-08-18 21:33:58 +08:00
parent 0043114180
commit 1540394586
1 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
packages/websocket/lib/server.dart
View file

@ -234,28 +234,27 @@ class AngelWebSocket {
try {
if (actionName == indexAction) {
socket.send(
'${split[0]}::' + indexedEvent, await service.index(params));
socket.send('${split[0]}::$indexedEvent', await service.index(params));
return null;
} else if (actionName == readAction) {
socket.send(
'${split[0]}::' + readEvent, await service.read(action.id, params));
'${split[0]}::$readEvent', await service.read(action.id, params));
return null;
} else if (actionName == createAction) {
return WebSocketEvent(
eventName: '${split[0]}::' + createdEvent,
eventName: '${split[0]}::$createdEvent',
data: await service.create(action.data, params));
} else if (actionName == modifyAction) {
return WebSocketEvent(
eventName: '${split[0]}::' + modifiedEvent,
eventName: '${split[0]}::$modifiedEvent',
data: await service.modify(action.id, action.data, params));
} else if (actionName == updateAction) {
return WebSocketEvent(
eventName: '${split[0]}::' + updatedEvent,
eventName: '${split[0]}::$updatedEvent',
data: await service.update(action.id, action.data, params));
} else if (actionName == removeAction) {
return WebSocketEvent(
eventName: '${split[0]}::' + removedEvent,
eventName: '${split[0]}::$removedEvent',
data: await service.remove(action.id, params));
} else {
socket.sendError(AngelHttpException.methodNotAllowed(