89 lines
2.8 KiB
Java
89 lines
2.8 KiB
Java
package com.github.dfa.diaspora_android.task;
|
|
|
|
import android.content.Context;
|
|
import android.os.AsyncTask;
|
|
import android.util.Log;
|
|
import android.webkit.CookieManager;
|
|
|
|
import com.github.dfa.diaspora_android.App;
|
|
import com.github.dfa.diaspora_android.data.PodUserProfile;
|
|
|
|
import java.io.BufferedReader;
|
|
import java.io.IOException;
|
|
import java.io.InputStream;
|
|
import java.io.InputStreamReader;
|
|
import java.net.URL;
|
|
|
|
import javax.net.ssl.HttpsURLConnection;
|
|
|
|
import info.guardianproject.netcipher.NetCipher;
|
|
|
|
/**
|
|
* AsyncTask to fetch a users profile
|
|
* Created by Gregor Santner (gsantner) on 30.03.16.
|
|
*/
|
|
public class ProfileFetchTask extends AsyncTask<Void, Void, Void> {
|
|
// Code for getting the profile async without any UI/WebView
|
|
// TODO: This is an early version,needs to be converted to Service
|
|
|
|
final App app;
|
|
final Context context;
|
|
|
|
public ProfileFetchTask(final App app) {
|
|
this.context = app.getApplicationContext();
|
|
this.app = app;
|
|
}
|
|
|
|
|
|
@Override
|
|
protected Void doInBackground(Void... params) {
|
|
String extractedProfileData = null;
|
|
final CookieManager cookieManager = app.getCookieManager();
|
|
String cookies = cookieManager.getCookie("https://" + app.getSettings().getPodDomain());
|
|
Log.d(App.TAG, cookies);
|
|
|
|
HttpsURLConnection connection;
|
|
InputStream inStream;
|
|
try {
|
|
URL url = new URL("https://" + app.getSettings().getPodDomain() + "/stream");
|
|
connection = NetCipher.getHttpsURLConnection(url);
|
|
connection.setReadTimeout(10000);
|
|
connection.setConnectTimeout(15000);
|
|
connection.setRequestMethod("GET");
|
|
if (cookies != null) {
|
|
connection.setRequestProperty("Cookie", cookies);
|
|
}
|
|
connection.connect();
|
|
|
|
inStream = connection.getInputStream();
|
|
BufferedReader br = new BufferedReader(new InputStreamReader(inStream));
|
|
String line;
|
|
final String TARGET_TAG = "window.gon={};gon.user=";
|
|
while ((line = br.readLine()) != null && !line.startsWith("<body")) {
|
|
if (line.startsWith(TARGET_TAG)) {
|
|
extractedProfileData = line.substring(TARGET_TAG.length());
|
|
break;
|
|
}
|
|
}
|
|
|
|
try{
|
|
br.close();
|
|
inStream.close();
|
|
} catch (IOException e){/*Nothing*/}
|
|
|
|
connection.disconnect();
|
|
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
|
|
|
|
if (extractedProfileData != null) {
|
|
PodUserProfile profile = new PodUserProfile(app);
|
|
profile.parseJson(extractedProfileData);
|
|
Log.d(App.TAG, "Extracted new_messages (service):" + profile.getUnreadMessagesCount());
|
|
}
|
|
|
|
return null;
|
|
}
|
|
} |