[Apache Shindig][お勉強][OpenSocial] メモ83 DataRequest.newFetchActivitiesRequestのサーバ側実装をしてみる(2)

jsonrpccontainer.jsを元にコンテナを実装した場合、activityIdが渡せないので、

view plainprint?

1. JsonRpcContainer.prototype.newFetchActivitiesRequest = function(idSpec,    
2.     opt_params) {    
3.   var rpc = { method : "activities.get" };    
4.   rpc.params = this.translateIdSpec(idSpec);    
5.   rpc.params.appId = "@app";    
6.   /* ここから */    
7.   if (opt_params['activityId']) {    
8.     rpc.params.activityId = opt_params['activityId'];    
9.   }    
10.   /* ここまで */    
11.   FieldTranslations.translateStandardArguments(opt_params, rpc.params);    
12.   FieldTranslations.translateNetworkDistance(idSpec, rpc.params);    
13.     
14.   return new JsonRpcRequestItem(rpc,    
15.       function(rawJson) {    
16.         /* さらに修正 ここから */    
17.         if (rawJson['list']) {    
18.           rawJson = rawJson['list'];    
19.         }    
20.         else {    
21.           rawJson = [rawJson];    
22.         }    
23.         /* さらに修正 ここまで */    
24.         var activities = [];    
25.         for (var i = 0; i < rawJson.length; i++) {    
26.           activities.push(new JsonActivity(rawJson[i]));    
27.         }    
28.         return new opensocial.Collection(activities);    
29.       });    
30. };    

   JsonRpcContainer.prototype.newFetchActivitiesRequest = function(idSpec,  
       opt_params) {  
     var rpc = { method : "activities.get" };  
     rpc.params = this.translateIdSpec(idSpec);  
     rpc.params.appId = "@app";  
     /* ここから */  
     if (opt_params['activityId']) {  
       rpc.params.activityId = opt_params['activityId'];  
     }  
     /* ここまで */  
     FieldTranslations.translateStandardArguments(opt_params, rpc.params);  
     FieldTranslations.translateNetworkDistance(idSpec, rpc.params);  
     
     return new JsonRpcRequestItem(rpc,  
         function(rawJson) {  
           /* さらに修正 ここから */  
           if (rawJson['list']) {  
             rawJson = rawJson['list'];  
           }  
           else {  
             rawJson = [rawJson];  
           }  
           /* さらに修正 ここまで */  
           var activities = [];  
           for (var i = 0; i < rawJson.length; i++) {  
             activities.push(new JsonActivity(rawJson[i]));  
           }  
           return new opensocial.Collection(activities);  
         });  
   };  

とした。

んで、ActivityServiceの方は、

view plainprint?

1. public Future<Activity> getActivity(UserId userId, GroupId groupId, String appId,  
2.     Set<String> fields, String activityId, SecurityToken token)  
3.     throws ProtocolException {  
4.   if (logger.isDebugEnabled()) {  
5.     logger.debug("userId:[" + userId + "]:");  
6.     logger.debug("groupId:[" + groupId + "]:");  
7.     logger.debug("appId:[" + appId + "]:");  
8.     for (String field: fields) {  
9.       logger.debug("field:[" + field + "]");  
10.     }  
11.     logger.debug("activityId:[" + activityId + "]");  
12.   }  
13.   Activity activity = logic.getActivity(userId, activityId, token);  
14.   if ( activity != null  ) {  
15.     return ImmediateFuture.newInstance(activity);  
16.   }  
17.   throw new ProtocolException(HttpServletResponse.SC_BAD_REQUEST,"Cant find activity");  
18. }  

  public Future<Activity> getActivity(UserId userId, GroupId groupId, String appId,
      Set<String> fields, String activityId, SecurityToken token)
      throws ProtocolException {
    if (logger.isDebugEnabled()) {
      logger.debug("userId:[" + userId + "]:");
      logger.debug("groupId:[" + groupId + "]:");
      logger.debug("appId:[" + appId + "]:");
      for (String field: fields) {
        logger.debug("field:[" + field + "]");
      }
      logger.debug("activityId:[" + activityId + "]");
    }
    Activity activity = logic.getActivity(userId, activityId, token);
    if ( activity != null  ) {
      return ImmediateFuture.newInstance(activity);
    }
    throw new ProtocolException(HttpServletResponse.SC_BAD_REQUEST,"Cant find activity");
  }

とした。
logic.getActivityは、ただ単にテーブルからactivityをひっぱってくるだけ。

一応これでactivityId指定の1件取得newFetchActivitiesRequest完成。

次はgetActivities()の2つ。
.