test

Author: sxci

AndroidManifest.xml

@@ -18,7 +18,13 @@
         <activity android:name=".demo.MyResumableActivity"
                   android:theme="@android:style/Theme.Light.NoTitleBar"
                   android:label="@string/app_name_resumable">
-
         </activity>
+        
+        <uses-library android:name="android.test.runner" />
     </application>
+    
+    <uses-permission android:name="android.permission.RUN_INSTRUMENTATION" />
+	<instrumentation android:name="android.test.InstrumentationTestRunner" 
+	    android:targetPackage="com.qiniu"
+		android:label="Test for sdk"/>
 </manifest>

src/test/com/qiniu/test/UploadTest.java

@@ -0,0 +1,191 @@
+package com.qiniu.test;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.UUID;
+
+import junit.framework.Assert;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import com.qiniu.auth.JSONObjectRet;
+import com.qiniu.io.IO;
+import com.qiniu.resumableio.ResumableIO;
+
+import android.content.Context;
+import android.net.Uri;
+import android.test.AndroidTestCase;
+import android.test.suitebuilder.annotation.MediumTest;
+import android.test.suitebuilder.annotation.SmallTest;
+import android.util.Log;
+
+public class UploadTest extends AndroidTestCase {
+	private String uptoken = "acmKu7Hie1OQ3t31bAovR6JORFX72MMpTicc2xje:n6I4SuMAxBgZ6o3qh8z1bMWqKow=:eyJzY29wZSI6ImFhYTUiLCJyZXR1cm5Cb2R5Ijoie1wiaGFzaFwiOlwiJChldGFnKVwiLFwia2V5XCI6XCIkKGtleSlcIixcImZuYW1lXCI6XCIgJChmbmFtZSkgXCIsXCJmc2l6ZVwiOlwiJChmc2l6ZSlcIixcImF2aW5mb1wiOlwiJChhdmluZm8pXCIsXCJ4OnRlc3RfbmFtZVwiOlwiJCh4OnRlc3RfbmFtZSlcIixcIm5vbnh0ZXN05Lit5paHX25hbWVcIjpcIiQobm9ueHRlc3TkuK3mlodfbmFtZSlcIn0iLCJkZWFkbGluZSI6MTQzMjg2ODA3NH0=";
+	
+	private File file;
+	
+	private boolean uploading;
+	private boolean success;
+	private JSONObjectRet jsonRet;
+	private JSONObject resp;
+	private Exception e;
+	
+	private Context context;
+	private Uri uri;
+	private com.qiniu.io.PutExtra extra;
+	private String key = IO.UNDEFINED_KEY;
+	
+	private com.qiniu.resumableio.PutExtra rextra;
+
+	public void setUp() throws Exception {
+		key = UUID.randomUUID().toString();
+		uploading = true;
+		success = false;
+		
+		extra = new com.qiniu.io.PutExtra();
+		extra.params = new HashMap<String, String>();
+		extra.params.put("x:a", "测试中文信息");
+		
+		rextra = new com.qiniu.resumableio.PutExtra();
+		rextra.params = new HashMap<String, String>();
+		rextra.params.put("x:a", "测试中文信息");
+		
+		context = this.getContext();
+		jsonRet = new JSONObjectRet() {
+			@Override
+			public void onProcess(long current, long total) {
+				Log.d("UploadTest", current + "/" + total);
+				// Assert.assertEquals(file.length(), total); // 内部实现原因，可能不相等
+			}
+
+			@Override
+			public void onSuccess(JSONObject res) {
+				uploading = false;
+				success = true;
+				resp = res;
+				Log.d("UploadTest", "上传成功!  " + resp.toString());
+			}
+
+			@Override
+			public void onFailure(Exception ex) {
+				uploading = false;
+				success = false;
+				e = ex;
+				Log.d("UploadTest", "上传失败!  " + ex.getMessage());
+			}
+		};
+	}
+
+
+	public void tearDown() throws Exception {
+		if(file != null){
+			file.delete();
+		}
+	}
+
+	@SmallTest
+	public void testS() throws IOException, JSONException {
+		file = createFile(0.2, ".test");
+		uri = Uri.fromFile(file);
+		IO.putFile(context, uptoken, key, uri, extra, jsonRet);
+		sleepLimit(60);
+		successCheck();
+	}
+	
+	@MediumTest
+	public void testM() throws IOException, JSONException {
+		file = createFile(4, ".test");
+		uri = Uri.fromFile(file);
+		IO.putFile(context, uptoken, key, uri, extra, jsonRet);
+		sleepLimit(60 * 5);
+		successCheck();
+	}
+	
+	@SmallTest
+	public void testRS() throws IOException, JSONException {
+		file = createFile(0.2, ".test");
+		uri = Uri.fromFile(file);
+		ResumableIO.putFile(context, uptoken, key, uri, rextra, jsonRet);
+		sleepLimit(60);
+		successCheck();
+	}
+	
+	@MediumTest
+	public void testRM() throws IOException, JSONException {
+		file = createFile(4, ".test");
+		uri = Uri.fromFile(file);
+		ResumableIO.putFile(context, uptoken, key, uri, rextra, jsonRet);
+		sleepLimit(60 * 5);
+		successCheck();
+	}
+	
+	@MediumTest
+	public void testRL() throws IOException, JSONException {
+		file = createFile(8.6, ".test");
+		uri = Uri.fromFile(file);
+		ResumableIO.putFile(context, uptoken, key, uri, rextra, jsonRet);
+		sleepLimit(60 * 5);
+		successCheck();
+	}
+	
+
+	private void successCheck() throws JSONException{
+		Assert.assertTrue(success);
+		Assert.assertNotNull(resp.optString("hash"));
+		Assert.assertEquals(file.length(), resp.getLong("fsize"));
+	}
+	
+	private void sleepLimit(int limit){
+		int t = 5;
+		while(uploading && t < limit){
+			try {
+				t += 5;
+				Thread.sleep(1000 * 5);
+			} catch (InterruptedException e) {
+
+			}
+		}
+	}
+	
+	private File createFile(double fileSize, String suf) throws IOException {
+		FileOutputStream fos = null;
+		try{
+			long size = (long)(1024 * 1024 * fileSize);
+			File f = File.createTempFile("qiniu_", suf);
+			f.createNewFile();
+			fos = new FileOutputStream(f);
+			byte [] b = getByte();
+			long s = 0;
+			while(s < size){
+				int l = (int)Math.min(b.length, size - s);
+				fos.write(b, 0, l);
+				s += l;
+			}
+			fos.flush();
+			return f;
+		}finally{
+			if(fos != null){
+				try {
+					fos.close();
+				} catch (IOException e) {
+					e.printStackTrace();
+				}
+			}
+		}
+	}
+
+	private byte[] getByte(){
+		byte [] b = new byte[1024 * 4];
+		b[0] = 'A';
+		for(int i=1; i < 1024 * 4 ; i++){
+			b[i] = 'b';
+		}
+		b[1024 * 4 - 2] = '\r';
+		b[1024 * 4 - 1] = '\n';
+		return b;
+	}
+
+}