Merge pull request #1 from MuShare/develop/user-info

Fetch user infos

Author: lm2343635

build.gradle

@@ -45,7 +45,7 @@ publishing {
 
     publications {
         maven(MavenPublication) {
-            version '0.1.5'
+            version '0.1.6'
             group 'org.mushare'
             from components.java
         }

src/main/java/org/mushare/pluto/Pluto.java

@@ -1,16 +1,23 @@
 package org.mushare.pluto;
 
+import com.github.kevinsawicki.http.HttpRequest;
+import net.sf.json.JSONArray;
 import net.sf.json.JSONObject;
 import org.mushare.pluto.exception.PlutoErrorCode;
 import org.mushare.pluto.exception.PlutoException;
 
 import java.io.UnsupportedEncodingException;
 import java.security.Signature;
+import java.util.ArrayList;
 import java.util.Base64;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
 
 public class Pluto {
 
     private PublicKeyManager keyManager;
+    private String server;
     private String appId;
 
     private Pluto() {
@@ -21,6 +28,7 @@ private Pluto() {
 
     public static void setup(String server, String appId) {
         shared.keyManager = new PublicKeyManager(server);
+        shared.server = server;
         shared.appId = appId;
     }
 
@@ -68,4 +76,31 @@ public static PlutoUser auth(String token) throws PlutoException {
         return new PlutoUser(payload);
     }
 
+    public static List<PlutoUserInfo> fetUserInfos(List<Long> userIds) {
+        if (userIds == null || userIds.size() == 0) {
+            return new ArrayList<>();
+        }
+        String ids = userIds.stream()
+                .map(userId -> userId + "-")
+                .reduce("", (s1, s2) -> {
+                    return s1 + s2;
+                });
+        ids = ids.substring(0, ids.length() - 1);
+        String response = HttpRequest.get(shared.server + "api/user/info/" + ids).body();
+        JSONArray body = JSONObject.fromObject(response).getJSONArray("body");
+        return IntStream.range(0, body.size())
+                .mapToObj(index -> {
+                    JSONObject object = body.getJSONObject(index);
+                    PlutoUserInfo info = new PlutoUserInfo();
+                    info.setUserId(object.getLong("id"));
+                    if (object.containsKey("err_code") && object.getInt("err_code") == 403) {
+                        return info;
+                    }
+                    info.setAvatar(object.getString("avatar"));
+                    info.setName(object.getString("name"));
+                    return info;
+                })
+                .collect(Collectors.toList());
+    }
+
 }

src/main/java/org/mushare/pluto/PlutoUserInfo.java

@@ -0,0 +1,40 @@
+package org.mushare.pluto;
+
+public class PlutoUserInfo {
+    private long userId;
+    private String name;
+    private String avatar;
+
+    public long getUserId() {
+        return userId;
+    }
+
+    public void setUserId(long userId) {
+        this.userId = userId;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getAvatar() {
+        return avatar;
+    }
+
+    public void setAvatar(String avatar) {
+        this.avatar = avatar;
+    }
+
+    @Override
+    public String toString() {
+        return "PlutoUserInfo{" +
+                "userId=" + userId +
+                ", name='" + name + '\'' +
+                ", avatar='" + avatar + '\'' +
+                '}';
+    }
+}

src/test/java/org/mushare/pluto/PlutoTest.java

@@ -6,6 +6,9 @@
 import org.mushare.pluto.exception.PlutoErrorCode;
 import org.mushare.pluto.exception.PlutoException;
 
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
 import static org.junit.Assert.assertTrue;
 
 public class PlutoTest {
@@ -41,5 +44,13 @@ public void testScopes() throws PlutoException {
         String token = "eyJ0eXBlIjoiand0IiwiYWxnIjoicnNhIn0.eyJ0eXBlIjoiYWNjZXNzIiwiY3JlYXRlX3RpbWUiOjE1ODU0NDg1MTcsImV4cGlyZV90aW1lIjoxNTg1NDUyMTE3LCJ1c2VySWQiOjQ4LCJkZXZpY2VJZCI6IkM5QTExQTIzLTg1QTMtNEMwRC04RjQxLTE5QURBNEIwOTJFRSIsImFwcElkIjoib3JnLm11c2hhcmUuZWFzeWphcGFuZXNlIiwic2NvcGVzIjpudWxsLCJsb2dpbl90eXBlIjoiZ29vZ2xlIn0.LyYEgEIxc1ghirESmvvpDE/EEd9B0U10BRgbKt3YdfiCb6L3URizHIqJVoc6IhPZOOBNy2x2Dk/sCZ5JV1rtaZ8niMdAb7VL7PwObZiWuWT8TieuV+7DaPxcJrPdzgz46GOOX7o3+fWRr64ucOYZeiY/g0PBCL07dMPRHYyzHK7e8Wrb/59rUjO4GCad5vM5qny9jTXihB+IokBPOYDkhKCinOfMAqOOFOtVRVdxt/mCLhnjkxexwWM/a7vmJQ4qOZYHxAB9mbgDq+mbBfzWafFWhbADdZdSqyKnKUDguBE1fPRODLqTIqB0KL4cttgSHKivlwwiVaaxZUEkwGN4GQ";
         Pluto.auth(token);
     }
+
+    @Test
+    public void testFetchUserInfos() {
+        Pluto.setup("https://staging.easyjapanese-api-gateway.mushare.cn/pluto/", "org.mushare.easyjapanese");
+        Pluto.fetUserInfos(Stream.of(1L, 2L, 3L).collect(Collectors.toList())).forEach(plutoUserInfo -> {
+            System.out.println(plutoUserInfo);
+        });
+    }
 
 }