プロミスを使用したWebSocketsの制御フロー

Question

現在、Node.jsをサーバー（Express.js）として使用し、クライアントサイドでAngularJを使用しています。パフォーマンス向上のために、HTTPベースのAPIからWebSocket（Socket.ioを使用）に切り替えました。

WebSocketはステータスコード/エラー管理が不足しているため、オプションのコールバックでJSONを返すだけなので、このエラー管理を実装する必要があります。 エラーが発生したときに一貫した動作が必要で、手動でこのエラーチェックを行う代わりに、悪い古いコールバックベースのプロミスを使用してコード内のボイルプレートを減らすようにしたいと思います。代わりに、角度で生socket.ioの使用例については

：要求 - を実装する際の推奨JSON構造は何

webSocketClient 
    .request('users/read', {id:2}) 
    .then(function(user){ 
     return webSocketClient.request('projects/by-user', {userId: user.id}) 
    }) 
    .then(function(projects){ 
     // Do something with projects 
    }) 
    .catch(function(err){ 
     // Something went bad 
    }) 

：

socket.emit('users/read', {id: 2}, function handleResponse(res){ 
    if(res.success){ 
     var user = res.data; 
     socket.emit('projects/by-user', {userId: user.id}, function handleResponse(res){ 
      if(res.success){ 
       var projects = res.data; 
       // Do something with the data 
      } else{ 
       // Error getting user's projects 
       console.log(res.error) 
      } 
     }) 
    } else{ 
     // Error getting user 
     console.log(res.error) 
    } 
}) 

私はこのような何かを持っていると思います応答WebSocketsベースのAPI？または私のためにこれを行うことができるライブラリがありますか？

私は現在、午前には対応してこのように構成されたJSONを考える：

{ 
    success: true/false, 
    data: [if exists], 
    statusCode: [default 200 for success or 500 for failure], 
    error: [if exists] 
} 

私はは約束を使ってWebSocketを代わりにコールバックでの作業は基本的かつobious要件ですが、いくつかの理由で、すべてのことを考えます私が見つけた図書館は、約束でコールバックをラップしませんでした。私は何かを逃しているのか疑問に繋がります。

おかげ

Answer 1

var ownhandler={}; 
ownhandler.request(query){ 
o={}; 
o.query=query; 
o.then=function (callback){ 
    calltheserver(this.query,function(){ 
     callback(); 
    } 
}; 
return o; 
} 

イムわからない場合は、その希望が、今あなたが何ができるかかなったように：あなたは本当の機能と「）calltheserver（」交換する必要が

ownhandler.request("whatever").then(function(){ 
//function finished 
} 

。

Answer 2

WebsocketベースのリクエストレスポンスAPIに対処するための優れたライブラリまたはソリューションがあるかどうかは、これまでのところクライアント側（テスト済み）で実装した方法です。

クライアント側コード（Angular.js）

angular.module('app.web-sockets', []) 
.factory('wsClient', function createWebSocketClient(socket, $q, assert, $timeout) { 
    function WebSocketClient(socket) { 
     this._socket = socket; 
    } 

    WebSocketClient.prototype.request = function request(url, data, options) { 

     var wrappedRequest = { 
      data: data 
     }; 

     var deferred = $q.defer(); 
     var resolved = false; 

     socket.emit(url, wrappedRequest, function responseCallback(response) { 
      if (response.success) { 
       deferred.resolve(response.data); 
       resolved = true; 
      } else { 
       deferred.reject(response); 
       resolved = true; 
      } 
     }); 

     return deferred.promise; 
    }; 

    return new WebSocketClient(socket); 
}) 

。