Changeset 10494 for extensions/jiwigo-ws-api/src/main/java/fr/mael/jiwigo/dao/impl/ImageDaoImpl.java

Timestamp:

Apr 19, 2011, 3:36:26 AM (13 years ago)

Author:

anthony43

Message:

addSimple ws api method added, with unit tests
​http://piwigo.org/doc/doku.php?id=en:dev:webapi:pwg.images.addsimple
pom upgraded to 0.3.0-SNAPSHOT since this is a minor change, and also a dependency was added (httpmime)
SessionManagerImpl was modified to make available its httpclient.

File:

• extensions/jiwigo-ws-api/src/main/java/fr/mael/jiwigo/dao/impl/ImageDaoImpl.java (modified) (10 diffs)

extensions/jiwigo-ws-api/src/main/java/fr/mael/jiwigo/dao/impl/ImageDaoImpl.java

@@ -1 +1 @@
 package fr.mael.jiwigo.dao.impl;
 
+import java.io.BufferedReader;
 import java.io.File;
 import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
 import java.security.NoSuchAlgorithmException;
 import java.util.ArrayList;
@@ -8 +11 @@
 import java.util.List;
 
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.BufferedHttpEntity;
+import org.apache.http.entity.mime.MultipartEntity;
+import org.apache.http.entity.mime.content.FileBody;
+import org.apache.http.entity.mime.content.StringBody;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -23 +33 @@
 import fr.mael.jiwigo.transverse.exception.WrongChunkSizeException;
 import fr.mael.jiwigo.transverse.session.SessionManager;
+import fr.mael.jiwigo.transverse.session.impl.SessionManagerImpl;
 import fr.mael.jiwigo.transverse.util.Tools;
 
@@ -89 +100 @@
             Document doc = null;
             if (categoryId != null) {
-                doc = sessionManager.executeReturnDocument(MethodsEnum.LISTER_IMAGES.getLabel(), "cat_id", String
-                        .valueOf(categoryId));
+                doc = sessionManager.executeReturnDocument(MethodsEnum.LISTER_IMAGES.getLabel(), "cat_id",
+                        String.valueOf(categoryId));
             } else {
                 doc = sessionManager.executeReturnDocument(MethodsEnum.LISTER_IMAGES.getLabel());
@@ -133 +144 @@
         //sends the thumbnail and gets the result
         Document reponseThumb = (sessionManager.executeReturnDocument("pwg.images.addChunk", "data", thumbnailBase64,
-                "type", "thumb", "position", "1", "original_sum", Tools.getMD5Checksum(image.getOriginale()
-                        .getAbsolutePath())));
+                "type", "thumb", "position", "1", "original_sum",
+                Tools.getMD5Checksum(image.getOriginale().getAbsolutePath())));
 
         //begin feature:0001827
@@ -147 +158 @@
             String originaleBase64 = base64.encode(Tools.getBytesFromFile(fichierAEnvoyer));
             Document reponseOriginale = (sessionManager.executeReturnDocument("pwg.images.addChunk", "data",
-                    originaleBase64, "type", "file", "position", String.valueOf(i), "original_sum", Tools
-                            .getMD5Checksum(image.getOriginale().getAbsolutePath())));
+                    originaleBase64, "type", "file", "position", String.valueOf(i), "original_sum",
+                    Tools.getMD5Checksum(image.getOriginale().getAbsolutePath())));
             if (!Tools.checkOk(reponseOriginale)) {
                 echec = true;
@@ -157 +168 @@
 
         //add the image in the database and get the result of the webservice
-        Document reponseAjout = (sessionManager.executeReturnDocument("pwg.images.add", "file_sum", Tools
-                .getMD5Checksum(image.getOriginale().getAbsolutePath()), "thumbnail_sum", Tools.getMD5Checksum(image
-                .getThumbnail().getCanonicalPath()), "position", "1", "original_sum", Tools.getMD5Checksum(image
-                .getOriginale().getAbsolutePath()), "categories", String.valueOf(image.getIdCategory()), "name", image
-                .getName(), "author", sessionManager.getLogin(), "level", image.getPrivacyLevel()));
+        Document reponseAjout = (sessionManager.executeReturnDocument("pwg.images.add", "file_sum",
+                Tools.getMD5Checksum(image.getOriginale().getAbsolutePath()), "thumbnail_sum",
+                Tools.getMD5Checksum(image.getThumbnail().getCanonicalPath()), "position", "1", "original_sum",
+                Tools.getMD5Checksum(image.getOriginale().getAbsolutePath()), "categories",
+                String.valueOf(image.getIdCategory()), "name", image.getName(), "author", sessionManager.getLogin(),
+                "level", image.getPrivacyLevel()));
         LOG.debug("Response add : " + Tools.documentToString(reponseAjout));
         //      System.out.println(Main.sessionManager.executerReturnString("pwg.images.add", "file_sum", Outil
@@ -189 +201 @@
      */
     public boolean addTags(Integer imageId, String tagId) throws IOException, ProxyAuthenticationException {
-        Document doc = sessionManager.executeReturnDocument(MethodsEnum.SET_INFO.getLabel(), "image_id", String
-                .valueOf(imageId), "tag_ids", tagId);
+        Document doc = sessionManager.executeReturnDocument(MethodsEnum.SET_INFO.getLabel(), "image_id",
+                String.valueOf(imageId), "tag_ids", tagId);
         try {
             return Tools.checkOk(doc);
@@ -260 +272 @@
     }
 
+    public void addSimple(File file, Integer category, String title) throws IOException {
+        HttpPost httpMethod = new HttpPost(((SessionManagerImpl) sessionManager).getUrl());
+
+        //      nameValuePairs.add(new BasicNameValuePair("method", "pwg.images.addSimple"));
+        //      for (int i = 0; i < parametres.length; i += 2) {
+        //          nameValuePairs.add(new BasicNameValuePair(parametres[i], parametres[i + 1]));
+        //      }
+        //      method.setEntity(new UrlEncodedFormEntity(nameValuePairs));
+
+        if (file != null) {
+            MultipartEntity multipartEntity = new MultipartEntity();
+
+            //          String string = nameValuePairs.toString();
+            // dirty fix to remove the enclosing entity{}
+            //          String substring = string.substring(string.indexOf("{"),
+            //                          string.lastIndexOf("}") + 1);
+            multipartEntity.addPart("method", new StringBody("pwg.images.addSimple"));
+            multipartEntity.addPart("category", new StringBody(category.toString()));
+            multipartEntity.addPart("name", new StringBody(title));
+
+            //          StringBody contentBody = new StringBody(substring,
+            //                          Charset.forName("UTF-8"));
+            //          multipartEntity.addPart("entity", contentBody);
+            FileBody fileBody = new FileBody(file);
+            multipartEntity.addPart("image", fileBody);
+            ((HttpPost) httpMethod).setEntity(multipartEntity);
+        }
+
+        //      httpMethod.setHeader(X_GALLERY_REQUEST_METHOD, requestMethod);
+        HttpResponse response = ((SessionManagerImpl) sessionManager).getClient().execute(httpMethod);
+        int responseStatusCode = response.getStatusLine().getStatusCode();
+
+        switch (responseStatusCode) {
+        case HttpURLConnection.HTTP_CREATED:
+            break;
+        case HttpURLConnection.HTTP_OK:
+            break;
+        case HttpURLConnection.HTTP_BAD_REQUEST:
+            throw new IOException("status code was : " + responseStatusCode);
+        case HttpURLConnection.HTTP_FORBIDDEN:
+            throw new IOException("status code was : " + responseStatusCode);
+        case HttpURLConnection.HTTP_NOT_FOUND:
+            throw new IOException("status code was : " + responseStatusCode);
+        default:
+            throw new IOException("status code was : " + responseStatusCode);
+        }
+
+        HttpEntity resultEntity = response.getEntity();
+        BufferedHttpEntity responseEntity = new BufferedHttpEntity(resultEntity);
+
+        BufferedReader reader = new BufferedReader(new InputStreamReader(responseEntity.getContent()));
+        String line;
+        StringBuilder sb = new StringBuilder();
+        try {
+            while ((line = reader.readLine()) != null) {
+                sb.append(line);
+                sb.append("\n");
+            }
+        } finally {
+            reader.close();
+        }
+        String stringResult = sb.toString();
+
+    }
+
     public SessionManager getSessionManager() {
         return sessionManager;
@@ -267 +344 @@
         this.sessionManager = sessionManager;
     }
-
 }