This commit is contained in:
Sebastian Seedorf
2020-12-06 19:49:16 +01:00
parent e9e169ff49
commit c4f849072f
23 changed files with 648 additions and 546 deletions

View File

@@ -0,0 +1,4 @@
package de.sebse.fuplanner.services.fulogin;
public class UserLoginResult {
}

View File

@@ -1,5 +1,6 @@
package de.sebse.fuplanner.services.kvv; package de.sebse.fuplanner.services.kvv;
public class Constants { public class Constants {
public static final String KVV_SERVER_URL = "https://mycampus.imp.fu-berlin.de/"; public static final String WB_SERVER_URL = "https://mycampus.imp.fu-berlin.de/";
public static final String BB_SERVER_URL = "https://lms.fu-berlin.de/";
} }

View File

@@ -13,7 +13,7 @@ import org.jetbrains.annotations.NotNull;
import java.util.HashMap; import java.util.HashMap;
import de.sebse.fuplanner.services.kvv.types.LoginTokenBB; import de.sebse.fuplanner.services.kvv.types.LoginTokenBB;
import de.sebse.fuplanner.services.kvv.types.LoginTokenKVV; import de.sebse.fuplanner.services.kvv.types.LoginTokenWB;
import de.sebse.fuplanner.tools.CustomAccountManager; import de.sebse.fuplanner.tools.CustomAccountManager;
public class KVV extends Service { public class KVV extends Service {
@@ -36,7 +36,7 @@ public class KVV extends Service {
} }
@Override @Override
public void onLogin(LoginTokenKVV tokenKVV, LoginTokenBB tokenBB, boolean isOnlyRefresh) { public void onLogin(LoginTokenWB tokenKVV, LoginTokenBB tokenBB, boolean isOnlyRefresh) {
for (KVVListener listener : mListeners.values()) for (KVVListener listener : mListeners.values())
listener.onLogin(tokenKVV, tokenBB, isOnlyRefresh); listener.onLogin(tokenKVV, tokenBB, isOnlyRefresh);
} }

View File

@@ -3,12 +3,12 @@ package de.sebse.fuplanner.services.kvv;
import com.android.volley.NetworkResponse; import com.android.volley.NetworkResponse;
import de.sebse.fuplanner.services.kvv.types.LoginTokenBB; import de.sebse.fuplanner.services.kvv.types.LoginTokenBB;
import de.sebse.fuplanner.services.kvv.types.LoginTokenKVV; import de.sebse.fuplanner.services.kvv.types.LoginTokenWB;
import de.sebse.fuplanner.services.kvv.types.Modules; import de.sebse.fuplanner.services.kvv.types.Modules;
import de.sebse.fuplanner.tools.CustomAccountManager; import de.sebse.fuplanner.tools.CustomAccountManager;
public interface KVVListener { public interface KVVListener {
default void onLogin(LoginTokenKVV tokenKVV, LoginTokenBB tokenBB, boolean isOnlyRefresh) {} default void onLogin(LoginTokenWB tokenKVV, LoginTokenBB tokenBB, boolean isOnlyRefresh) {}
default void onLogout() {} default void onLogout() {}

View File

@@ -10,9 +10,9 @@ import de.sebse.fuplanner.R;
import de.sebse.fuplanner.services.fulogin.AccountGeneral; import de.sebse.fuplanner.services.fulogin.AccountGeneral;
import de.sebse.fuplanner.services.kvv.sync.BBLogin; import de.sebse.fuplanner.services.kvv.sync.BBLogin;
import de.sebse.fuplanner.services.kvv.sync.FULogin; import de.sebse.fuplanner.services.kvv.sync.FULogin;
import de.sebse.fuplanner.services.kvv.sync.KVVLogin; import de.sebse.fuplanner.services.kvv.sync.WBLogin;
import de.sebse.fuplanner.services.kvv.types.LoginTokenBB; import de.sebse.fuplanner.services.kvv.types.LoginTokenBB;
import de.sebse.fuplanner.services.kvv.types.LoginTokenKVV; import de.sebse.fuplanner.services.kvv.types.LoginTokenWB;
import de.sebse.fuplanner.tools.CustomAccountManager; import de.sebse.fuplanner.tools.CustomAccountManager;
import de.sebse.fuplanner.tools.NetworkCallbackCollector; import de.sebse.fuplanner.tools.NetworkCallbackCollector;
import de.sebse.fuplanner.tools.Preferences; import de.sebse.fuplanner.tools.Preferences;
@@ -31,10 +31,10 @@ public class Login {
private final KVVListener mListener; private final KVVListener mListener;
private Context context; private Context context;
@Nullable private LoginTokenKVV mTokenKVV; @Nullable private LoginTokenWB mTokenKVV;
@Nullable private LoginTokenBB mTokenBB; @Nullable private LoginTokenBB mTokenBB;
private boolean mLoginPending = false; private boolean mLoginPending = false;
private final NetworkCallbackCollector<Pair<LoginTokenKVV, LoginTokenBB>> mRefreshCallbacks = new NetworkCallbackCollector<>(); private final NetworkCallbackCollector<Pair<LoginTokenWB, LoginTokenBB>> mRefreshCallbacks = new NetworkCallbackCollector<>();
private final NetworkCallbackCollector<Integer> mRestoreCallbacks = new NetworkCallbackCollector<>(); private final NetworkCallbackCollector<Integer> mRestoreCallbacks = new NetworkCallbackCollector<>();
Login(KVVListener listener, Context context) { Login(KVVListener listener, Context context) {
@@ -53,7 +53,7 @@ public class Login {
return; return;
} }
mLoginPending = true; mLoginPending = true;
LoginTokenKVV.load(mListener.getAccountManager(), tokenKVV -> { LoginTokenWB.load(mListener.getAccountManager(), tokenKVV -> {
LoginTokenBB.load(mListener.getAccountManager(), tokenBB -> { LoginTokenBB.load(mListener.getAccountManager(), tokenBB -> {
boolean result = setToken(tokenKVV, tokenBB); boolean result = setToken(tokenKVV, tokenBB);
mLoginPending = false; mLoginPending = false;
@@ -69,7 +69,7 @@ public class Login {
} }
public void isOfflineStoredAvailable(BooleanInterface callback) { public void isOfflineStoredAvailable(BooleanInterface callback) {
LoginTokenKVV.load(mListener.getAccountManager(), tokenKVV -> { LoginTokenWB.load(mListener.getAccountManager(), tokenKVV -> {
LoginTokenBB.load(mListener.getAccountManager(), tokenBB -> { LoginTokenBB.load(mListener.getAccountManager(), tokenBB -> {
callback.run(tokenKVV != null && tokenBB != null); callback.run(tokenKVV != null && tokenBB != null);
}, e -> callback.run(false)); }, e -> callback.run(false));
@@ -103,7 +103,7 @@ public class Login {
return isLoggedIn(); return isLoggedIn();
} }
void testLoginToken(@NotNull NetworkCallback<Pair<LoginTokenKVV, LoginTokenBB>> callback, @NotNull NetworkErrorCallback errorCallback) { void testLoginToken(@NotNull NetworkCallback<Pair<LoginTokenWB, LoginTokenBB>> callback, @NotNull NetworkErrorCallback errorCallback) {
if (mTokenKVV == null) { if (mTokenKVV == null) {
errorCallback.onError(new NetworkError(100173, -1, "Not logged in!")); errorCallback.onError(new NetworkError(100173, -1, "Not logged in!"));
return; return;
@@ -115,16 +115,16 @@ public class Login {
testLoginToken(mTokenKVV, mTokenBB, callback, errorCallback); testLoginToken(mTokenKVV, mTokenBB, callback, errorCallback);
} }
private void testLoginToken(@NotNull LoginTokenKVV tokenKVV, @NotNull LoginTokenBB tokenBB, @NotNull NetworkCallback<Pair<LoginTokenKVV, LoginTokenBB>> callback, @NotNull NetworkErrorCallback errorCallback) { private void testLoginToken(@NotNull LoginTokenWB tokenKVV, @NotNull LoginTokenBB tokenBB, @NotNull NetworkCallback<Pair<LoginTokenWB, LoginTokenBB>> callback, @NotNull NetworkErrorCallback errorCallback) {
FULogin mFULogin = new FULogin(getContext()); FULogin mFULogin = new FULogin(getContext());
new KVVLogin(getContext(), mFULogin).testLoginToken(tokenKVV, tokenKVV1 -> { new WBLogin(getContext(), mFULogin).testLoginToken(tokenKVV, tokenKVV1 -> {
new BBLogin(getContext(), mFULogin).testLoginToken(tokenBB, tokenBB1 -> { new BBLogin(getContext(), mFULogin).testLoginToken(tokenBB, tokenBB1 -> {
callback.onResponse(new Pair<>(tokenKVV1, tokenBB1)); callback.onResponse(new Pair<>(tokenKVV1, tokenBB1));
}, errorCallback); }, errorCallback);
}, errorCallback); }, errorCallback);
} }
@Nullable public LoginTokenKVV getLoginTokenKVV() { @Nullable public LoginTokenWB getLoginTokenKVV() {
return mTokenKVV; return mTokenKVV;
} }
@@ -132,7 +132,7 @@ public class Login {
return mTokenBB; return mTokenBB;
} }
void refreshLogin(NetworkCallback<Pair<LoginTokenKVV, LoginTokenBB>> success, NetworkErrorCallback error, int flags) { void refreshLogin(NetworkCallback<Pair<LoginTokenWB, LoginTokenBB>> success, NetworkErrorCallback error, int flags) {
boolean isFirst = mRefreshCallbacks.isEmpty(); boolean isFirst = mRefreshCallbacks.isEmpty();
mRefreshCallbacks.add(success, error); mRefreshCallbacks.add(success, error);
if (!isFirst) if (!isFirst)
@@ -140,10 +140,10 @@ public class Login {
refreshLoginRunner(success, error, flags); refreshLoginRunner(success, error, flags);
} }
private void refreshLoginRunner(NetworkCallback<Pair<LoginTokenKVV, LoginTokenBB>> success, NetworkErrorCallback error, int flags) { private void refreshLoginRunner(NetworkCallback<Pair<LoginTokenWB, LoginTokenBB>> success, NetworkErrorCallback error, int flags) {
CustomAccountManager manager = mListener.getAccountManager(); CustomAccountManager manager = mListener.getAccountManager();
if ((flags & LOGOUT_KVV) == LOGOUT_KVV) { if ((flags & LOGOUT_KVV) == LOGOUT_KVV) {
manager.doInvalidateToken(AccountGeneral.ACCOUNT_TYPE, AccountGeneral.AUTHTOKEN_TYPE_KVV, ignored -> { manager.doInvalidateToken(AccountGeneral.ACCOUNT_TYPE, AccountGeneral.AUTHTOKEN_TYPE_WB, ignored -> {
refreshLoginRunner(success, error, flags & ~LOGOUT_KVV); refreshLoginRunner(success, error, flags & ~LOGOUT_KVV);
}); });
} else if ((flags & LOGOUT_BB) == LOGOUT_BB) { } else if ((flags & LOGOUT_BB) == LOGOUT_BB) {
@@ -178,7 +178,7 @@ public class Login {
} }
} }
private boolean setToken(@Nullable LoginTokenKVV tokenKVV, @Nullable LoginTokenBB tokenBB) { private boolean setToken(@Nullable LoginTokenWB tokenKVV, @Nullable LoginTokenBB tokenBB) {
if (tokenKVV == null || tokenBB == null) if (tokenKVV == null || tokenBB == null)
return false; return false;
boolean isOnlyRefresh = mTokenKVV != null; boolean isOnlyRefresh = mTokenKVV != null;

View File

@@ -39,7 +39,7 @@ public class ModulesAnnouncements extends PartModules<ArrayList<Announcement>> {
errorCallback.onError(new NetworkError(101204, 500, "Currently running in offline mode!")); errorCallback.onError(new NetworkError(101204, 500, "Currently running in offline mode!"));
return; return;
} }
super.get(String.format(Constants.KVV_SERVER_URL+"direct/announcement/site/%s.json?n=999999&d=999999999&_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> { super.get(String.format(Constants.WB_SERVER_URL +"direct/announcement/site/%s.json?n=999999&d=999999999&_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(101201, 403, "No announcements retrieved!")); errorCallback.onError(new NetworkError(101201, 403, "No announcements retrieved!"));

View File

@@ -39,7 +39,7 @@ public class ModulesAssignments extends PartModules<AssignmentList> {
errorCallback.onError(new NetworkError(101304, 500, "Currently running in offline mode!")); errorCallback.onError(new NetworkError(101304, 500, "Currently running in offline mode!"));
return; return;
} }
get(String.format(Constants.KVV_SERVER_URL+"direct/assignment/site/%s.json?_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> { get(String.format(Constants.WB_SERVER_URL +"direct/assignment/site/%s.json?_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(101301, 403, "No assignments retrieved!")); errorCallback.onError(new NetworkError(101301, 403, "No assignments retrieved!"));

View File

@@ -46,7 +46,7 @@ public class ModulesEvents extends PartModules<EventList> {
errorCallback.onError(new NetworkError(101404, 500, "Currently running in offline mode!")); errorCallback.onError(new NetworkError(101404, 500, "Currently running in offline mode!"));
return; return;
} }
get(String.format(Constants.KVV_SERVER_URL+"direct/calendar/site/%s.json?detailed=true&_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> { get(String.format(Constants.WB_SERVER_URL +"direct/calendar/site/%s.json?detailed=true&_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(101401, 403, "No events retrieved!")); errorCallback.onError(new NetworkError(101401, 403, "No events retrieved!"));

View File

@@ -6,8 +6,6 @@ import org.json.JSONArray;
import org.json.JSONException; import org.json.JSONException;
import org.json.JSONObject; import org.json.JSONObject;
import java.util.ArrayList;
import de.sebse.fuplanner.services.kvv.types.Grade; import de.sebse.fuplanner.services.kvv.types.Grade;
import de.sebse.fuplanner.services.kvv.types.Gradebook; import de.sebse.fuplanner.services.kvv.types.Gradebook;
import de.sebse.fuplanner.services.kvv.types.Modules; import de.sebse.fuplanner.services.kvv.types.Modules;
@@ -39,7 +37,7 @@ public class ModulesGradebook extends PartModules<Gradebook> {
errorCallback.onError(new NetworkError(101504, 500, "Currently running in offline mode!")); errorCallback.onError(new NetworkError(101504, 500, "Currently running in offline mode!"));
return; return;
} }
super.get(String.format(Constants.KVV_SERVER_URL+"direct/gradebook/site/%s.json", ID), mLogin.getLoginTokenKVV().getCookies(), response -> { super.get(String.format(Constants.WB_SERVER_URL +"direct/gradebook/site/%s.json", ID), mLogin.getLoginTokenKVV().getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(101501, 403, "No gradebook retrieved!")); errorCallback.onError(new NetworkError(101501, 403, "No gradebook retrieved!"));

View File

@@ -194,7 +194,7 @@ public class ModulesList extends HTTPService {
callback.onResponse(modules); callback.onResponse(modules);
return; return;
} }
get(Constants.KVV_SERVER_URL+"direct/membership.json?_validateSession=", mLogin.getLoginTokenKVV().getCookies(), response -> { get(Constants.WB_SERVER_URL +"direct/membership.json?_validateSession=", mLogin.getLoginTokenKVV().getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(101111, 403, "No membership list retrieved!")); errorCallback.onError(new NetworkError(101111, 403, "No membership list retrieved!"));
@@ -226,7 +226,7 @@ public class ModulesList extends HTTPService {
if (--latch[0] == 0) successCallback.onResponse(modules); if (--latch[0] == 0) successCallback.onResponse(modules);
continue; continue;
} }
get(String.format(Constants.KVV_SERVER_URL+"direct/site/%s.json?_validateSession=", courseId), mLogin.getLoginTokenKVV().getCookies(), response1 -> { get(String.format(Constants.WB_SERVER_URL +"direct/site/%s.json?_validateSession=", courseId), mLogin.getLoginTokenKVV().getCookies(), response1 -> {
String body1 = response1.getParsed(); String body1 = response1.getParsed();
if (body1 == null) { if (body1 == null) {
errorCallback.onError(new NetworkError(101113, 403, "No site retrieved!")); errorCallback.onError(new NetworkError(101113, 403, "No site retrieved!"));

View File

@@ -4,8 +4,6 @@ import android.content.Context;
import android.os.Build; import android.os.Build;
import android.os.Environment; import android.os.Environment;
import androidx.core.content.ContextCompat;
import org.json.JSONArray; import org.json.JSONArray;
import org.json.JSONException; import org.json.JSONException;
import org.json.JSONObject; import org.json.JSONObject;
@@ -49,7 +47,7 @@ public class ModulesResources extends PartModules<ArrayList<Resource>> {
errorCallback.onError(new NetworkError(101604, 500, "Currently running in offline mode!")); errorCallback.onError(new NetworkError(101604, 500, "Currently running in offline mode!"));
return; return;
} }
get(String.format(Constants.KVV_SERVER_URL+"direct/content/site/%s.json?_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> { get(String.format(Constants.WB_SERVER_URL +"direct/content/site/%s.json?_validateSession=", ID), mLogin.getLoginTokenKVV().getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(101601, 403, "No resources retrieved!")); errorCallback.onError(new NetworkError(101601, 403, "No resources retrieved!"));

View File

@@ -1,6 +1,7 @@
package de.sebse.fuplanner.services.kvv.sync; package de.sebse.fuplanner.services.kvv.sync;
import android.content.Context; import android.content.Context;
import android.os.Bundle;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.json.JSONException; import org.json.JSONException;
@@ -16,147 +17,133 @@ import de.sebse.fuplanner.tools.network.NetworkCallback;
import de.sebse.fuplanner.tools.network.NetworkError; import de.sebse.fuplanner.tools.network.NetworkError;
import de.sebse.fuplanner.tools.network.NetworkErrorCallback; import de.sebse.fuplanner.tools.network.NetworkErrorCallback;
public class BBLogin extends HTTPService { import static de.sebse.fuplanner.services.kvv.Constants.BB_SERVER_URL;
private final FULogin mFULogin;
private long lastHash; public class BBLogin extends LoginRoutine<LoginTokenBB> {
private long lastSync; private FULogin fuLogin;
private static final long MAX_CACHE_TIME = 1000 * 60; // 1 minute
public BBLogin(Context context, FULogin fuLogin) { public BBLogin(Context context, FULogin fuLogin) {
super(context); super(context);
this.mFULogin = fuLogin; this.fuLogin = fuLogin;
} }
public void testLoginToken(@NotNull LoginTokenBB token, @NotNull NetworkCallback<LoginTokenBB> callback, @NotNull NetworkErrorCallback errorCallback) { @Override
if (token.hashCode() == lastHash && lastSync + MAX_CACHE_TIME > System.currentTimeMillis() && token.getStudentId() != null) { public void doesAccountExists(@NotNull String username, @NotNull NetworkCallback<Boolean> callback, @NotNull NetworkErrorCallback error) {
callback.onResponse(token); callback.onResponse(true);
return; }
}
get(String.format("https://lms.fu-berlin.de/learn/api/public/v1/users/?userName=%s", token.getUsername()), token.getCookies(), response -> { @Override
protected LoginTokenBB createUnavailableToken() {
return new LoginTokenBB();
}
@Override
protected void checkToken(@NotNull LoginTokenBB token, @NotNull NetworkCallback<Bundle> bundleCallback, @NotNull NetworkErrorCallback error) {
get(String.format(BB_SERVER_URL + "learn/api/public/v1/users/?userName=%s", token.getUsername()), token.getCookies(), response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body == null) { if (body == null) {
errorCallback.onError(new NetworkError(100272, 403, "Testing login failed!")); error.onError(new NetworkError(100272, 403, "Testing BB login failed!"));
return; return;
} }
try { try {
JSONObject json = new JSONObject(body); JSONObject json = new JSONObject(body);
json = json.getJSONArray("results").getJSONObject(0); json = json.getJSONArray("results").getJSONObject(0);
String id = json.getString("id"); Bundle bundle = new Bundle();
String studentId = json.getString("studentId"); bundle.putString("id", json.getString("id"));
token.setAdditionals(id, studentId); bundle.putString("studentId", json.getString("studentId"));
lastSync = System.currentTimeMillis(); bundleCallback.onResponse(bundle);
lastHash = token.hashCode();
callback.onResponse(token);
} catch (JSONException e) { } catch (JSONException e) {
errorCallback.onError(new NetworkError(100271, 403, "Cannot parse profile!")); error.onError(new NetworkError(100271, 403, "Cannot parse BB profile!"));
} }
}, error -> errorCallback.onError(new NetworkError(100270, error.networkResponse.statusCode, "Testing login failed!"))); }, err -> error.onError(new NetworkError(100270, err.networkResponse.statusCode, "Testing BB login failed!")));
} }
@Override
public void createLoginToken(@NotNull String username, @NotNull String password, @NotNull NetworkCallback<LoginTokenBB> callback, @NotNull NetworkErrorCallback error) {
getSAMLLocation(samlLocation -> {
fuLogin.fulogin(samlLocation, username, password, samlResponse -> {
startShibSession(samlResponse, shibSessionKey -> {
String shibsessionKey = shibSessionKey.getString("shibsessionKey");
String shibsessionName = shibSessionKey.getString("shibsessionName");
startSession(shibsessionKey, shibsessionName, sessionCookies -> {
Bundle bundle = new Bundle();
bundle.putString("username", username);
bundle.putAll(sessionCookies);
LoginTokenBB tokenBB = new LoginTokenBB(bundle);
testToken(tokenBB, callback, error);
public void doLogin(String username, String password, NetworkCallback<LoginTokenBB> callback, NetworkErrorCallback error) {
step1(success1 -> {
String samlLocation = success1.get("Location");
mFULogin.fulogin(samlLocation, username, password, samlResponse -> {
step5(samlResponse, success5 -> {
String shibsessionKey = success5.get("shibsessionKey");
String shibsessionName = success5.get("shibsessionName");
step6(shibsessionKey, shibsessionName, success6 -> {
String s_session_id = success6.get("s_session_id");
String session_id = success6.get("session_id");
LoginTokenBB token = new LoginTokenBB(username, s_session_id, session_id);
callback.onResponse(token);
}, error); }, error);
}, error); }, error);
}, error); }, error);
}, error); }, error);
} }
/* /*
1= GET https://lms.fu-berlin.de/lms-apps/login/sso/index.php 1= GET https://lms.fu-berlin.de/lms-apps/login/sso/index.php
-> Location-Header: https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?SAMLResponse=[SAMLResponse]&RelayState=[RelayState] -> Location-Header: https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?SAMLResponse=[SAMLResponse]&RelayState=[RelayState]
*/ */
private void step1(final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) { private void getSAMLLocation(final NetworkCallback<String> callback, final NetworkErrorCallback errorCallback) {
get("https://lms.fu-berlin.de/lms-apps/login/sso/index.php", null, response -> { get(BB_SERVER_URL + "lms-apps/login/sso/index.php", null, response -> {
String location = response.getHeaders().get("Location"); String location = response.getHeaders().get("Location");
if (location==null) { if (location == null) {
errorCallback.onError(new NetworkError(100211, -1, "Error on getting SAML request!")); errorCallback.onError(new NetworkError(100211, -1, "Error on getting BB SAML request!"));
return; return;
} }
HashMap<String, String> object = new HashMap<>(); callback.onResponse(location);
object.put("Location", location); }, error -> errorCallback.onError(new NetworkError(100210, error.networkResponse.statusCode, "Error on getting BB SAML request!")));
callback.onResponse(object);
}, error -> errorCallback.onError(new NetworkError(100210, error.networkResponse.statusCode, "Error on getting SAML request!")));
} }
/* /*
5= POST https://lms.fu-berlin.de/Shibboleth.sso/SAML2/POST 5= POST https://lms.fu-berlin.de/Shibboleth.sso/SAML2/POST
+ Body: SAMLResponse=[SAML-RESPONSE] + Body: SAMLResponse=[SAML-RESPONSE]
+ Header: Content-Type: application/x-www-form-urlencoded + Header: Content-Type: application/x-www-form-urlencoded
-> Set-Cookie: _shibsession_[SESS-NR]: [SESS-VALUE] -> Set-Cookie: _shibsession_[SESS-NR]: [SESS-VALUE]
*/ */
private void step5(String SAMLResponse, final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) { private void startShibSession(String samlResponse, final NetworkCallback<Bundle> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> body = new HashMap<>(); HashMap<String, String> body = new HashMap<>();
body.put("SAMLResponse", SAMLResponse); body.put("SAMLResponse", samlResponse);
post("https://lms.fu-berlin.de/Shibboleth.sso/SAML2/POST", null, body, response -> { post(BB_SERVER_URL + "Shibboleth.sso/SAML2/POST", null, body, response -> {
String cookies = response.getHeaders().get("Set-Cookie"); String cookies = response.getHeaders().get("Set-Cookie");
if (cookies ==null) { if (cookies ==null) {
errorCallback.onError(new NetworkError(100251, -1, "Error on starting KVV session!")); errorCallback.onError(new NetworkError(100251, -1, "Error on starting BB session!"));
return; return;
} }
HashMap<String, String> object = new HashMap<>();
Pattern pattern = Pattern.compile("(_shibsession_[0-9a-f]+)=([^;]+);"); Pattern pattern = Pattern.compile("(_shibsession_[0-9a-f]+)=([^;]+);");
Matcher matcher = pattern.matcher(cookies); Matcher matcher = pattern.matcher(cookies);
if (!matcher.find()) { if (!matcher.find()) {
errorCallback.onError(new NetworkError(100252, -1, "Error on starting KVV session!")); errorCallback.onError(new NetworkError(100252, -1, "Error on starting BB session!"));
} }
object.put("shibsessionKey", matcher.group(1));
object.put("shibsessionName", matcher.group(2));
callback.onResponse(object); Bundle bundle = new Bundle();
}, error -> errorCallback.onError(new NetworkError(100250, error.networkResponse.statusCode, "Error on starting KVV session!"))); bundle.putString("shibsessionKey", matcher.group(1));
bundle.putString("shibsessionName", matcher.group(2));
callback.onResponse(bundle);
}, error -> errorCallback.onError(new NetworkError(100250, error.networkResponse.statusCode, "Error on starting BB session!")));
} }
/* /*
6= https://lms.fu-berlin.de/webapps/bb-auth-provider-shibboleth-bb_bb60/execute/shibbolethLogin?returnUrl=https://lms.fu-berlin.de/webapps/portal/execute/defaultTab&authProviderId=_3_1 6= https://lms.fu-berlin.de/webapps/bb-auth-provider-shibboleth-bb_bb60/execute/shibbolethLogin?returnUrl=https://lms.fu-berlin.de/webapps/portal/execute/defaultTab&authProviderId=_3_1
+ Cookie: _shibsession_[SESS-NR]: [SESS-VALUE] + Cookie: _shibsession_[SESS-NR]: [SESS-VALUE]
-> Set-Cookie: JSESSIONID: [JSESSION-KVV] -> Set-Cookie: JSESSIONID: [JSESSION-KVV]
*/ */
private void step6(String shibsessionKey, String shibsessionName, final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) { private void startSession(String shibsessionKey, String shibsessionName, final NetworkCallback<Bundle> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> cookies = new HashMap<>(); HashMap<String, String> cookies = new HashMap<>();
cookies.put(shibsessionKey, shibsessionName); cookies.put(shibsessionKey, shibsessionName);
get("https://lms.fu-berlin.de/webapps/bb-auth-provider-shibboleth-bb_bb60/execute/shibbolethLogin?returnUrl=https://lms.fu-berlin.de/webapps/portal/execute/defaultTab&authProviderId=_3_1", cookies, response -> { get(BB_SERVER_URL + "webapps/bb-auth-provider-shibboleth-bb_bb60/execute/shibbolethLogin?returnUrl=https://lms.fu-berlin.de/webapps/portal/execute/defaultTab&authProviderId=_3_1", cookies, response -> {
String cookies1 = response.getHeaders().get("Set-Cookie"); String cookiesSet = response.getHeaders().get("Set-Cookie");
if (cookies1 ==null) { if (cookiesSet == null) {
errorCallback.onError(new NetworkError(100261, -1, "Cannot finish login process!")); errorCallback.onError(new NetworkError(100261, -1, "Cannot finish BB login process!"));
return; return;
} }
HashMap<String, String> object;
try { try {
object = getCookie(cookies1, new String[]{"session_id", "s_session_id"}); Bundle bundle = getCookie(cookiesSet, new String[]{"session_id", "s_session_id"});
callback.onResponse(bundle);
} catch (NoSuchFieldException e) { } catch (NoSuchFieldException e) {
errorCallback.onError(new NetworkError(100262, -1, "Cannot finish login process!")); errorCallback.onError(new NetworkError(100262, -1, "Cannot finish BB login process!"));
return;
} }
callback.onResponse(object); }, error -> errorCallback.onError(new NetworkError(100260, error.networkResponse.statusCode, "Cannot finish BB login process!")));
}, error -> errorCallback.onError(new NetworkError(100260, error.networkResponse.statusCode, "Cannot finish login process!")));
} }
} }

View File

@@ -1,12 +1,16 @@
package de.sebse.fuplanner.services.kvv.sync; package de.sebse.fuplanner.services.kvv.sync;
import android.content.Context; import android.content.Context;
import android.os.Bundle;
import java.util.HashMap; import java.util.HashMap;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; import java.util.regex.Pattern;
import androidx.annotation.Nullable; import androidx.annotation.Nullable;
import org.jetbrains.annotations.NotNull;
import de.sebse.fuplanner.R; import de.sebse.fuplanner.R;
import de.sebse.fuplanner.tools.Preferences; import de.sebse.fuplanner.tools.Preferences;
import de.sebse.fuplanner.tools.network.HTTPService; import de.sebse.fuplanner.tools.network.HTTPService;
@@ -19,20 +23,20 @@ public class FULogin extends HTTPService {
super(context); super(context);
} }
public void fulogin(String requestURI, String username, String password, final NetworkCallback<String> callback, final NetworkErrorCallback errorCallback) { public void fulogin(String samlRequestUri, String username, String password, final NetworkCallback<String> callback, final NetworkErrorCallback errorCallback) {
String old_shib_idp_session = Preferences.getString(getContext(), R.string.pref_shib_idp_session); String old_shib_idp_session = Preferences.getString(getContext(), R.string.pref_shib_idp_session);
step2(requestURI, old_shib_idp_session, success2 -> { startSamlRequest(samlRequestUri, old_shib_idp_session, samlRequest -> {
String samlResp = success2.get("SAMLResponse"); if (samlRequest.containsKey("SAMLResponse")) {
if (samlResp != null) { callback.onResponse(samlRequest.getString("SAMLResponse", ""));
callback.onResponse(samlResp);
return; return;
} }
String fuJSESSIONID = success2.get("JSESSIONID");
step3(fuJSESSIONID, success3 -> { String JSESSIONID = samlRequest.getString("JSESSIONID");
step4(username, password, fuJSESSIONID, success4 -> { openLoginForm(JSESSIONID, success -> {
String shib_idp_session = success4.get("shib_idp_session"); finishLogin(username, password, JSESSIONID, samlResp -> {
String shib_idp_session = samlResp.getString("shib_idp_session");
Preferences.setString(getContext(), R.string.pref_shib_idp_session, shib_idp_session); Preferences.setString(getContext(), R.string.pref_shib_idp_session, shib_idp_session);
String samlResponse = success4.get("SAMLResponse"); String samlResponse = samlResp.getString("SAMLResponse");
if (samlResponse != null) if (samlResponse != null)
callback.onResponse(samlResponse); callback.onResponse(samlResponse);
else else
@@ -47,24 +51,24 @@ public class FULogin extends HTTPService {
-> Set-Cookie: JSESSIONID=[JSESSION-FU] -> Set-Cookie: JSESSIONID=[JSESSION-FU]
-> Location: /idp-fub/profile/SAML2/Redirect/SSO?execution=e1s1 -> Location: /idp-fub/profile/SAML2/Redirect/SSO?execution=e1s1
*/ */
private void step2(String url, @Nullable String shib_idp_session, final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) { private void startSamlRequest(String samlRequestUri, @Nullable String shib_idp_session, final NetworkCallback<Bundle> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> cookiesReq = null; HashMap<String, String> cookiesReq = null;
if (shib_idp_session != null) { if (shib_idp_session != null) {
cookiesReq = new HashMap<>(); cookiesReq = new HashMap<>();
cookiesReq.put("shib_idp_session", shib_idp_session); cookiesReq.put("shib_idp_session", shib_idp_session);
} }
get(url, cookiesReq, response -> { get(samlRequestUri, cookiesReq, response -> {
String body = response.getParsed(); String body = response.getParsed();
if (body != null) { if (body != null) {
Pattern pattern = Pattern.compile("name=\"SAMLResponse\" value=\"([0-9a-zA-Z+]+=*)"); Pattern pattern = Pattern.compile("name=\"SAMLResponse\" value=\"([0-9a-zA-Z+]+=*)");
Matcher matcher = pattern.matcher(body); Matcher matcher = pattern.matcher(body);
if (!matcher.find()) { if (!matcher.find()) {
errorCallback.onError(new NetworkError(100344, -1, "Error on getting SAML response!")); errorCallback.onError(new NetworkError(100344, -1, "Error on getting FU SAML response!"));
return; return;
} }
HashMap<String, String> object = new HashMap<>(); Bundle bundle = new Bundle();
object.put("SAMLResponse", matcher.group(1)); bundle.putString("SAMLResponse", matcher.group(1));
callback.onResponse(object); callback.onResponse(bundle);
return; return;
} }
String cookies = response.getHeaders().get("Set-Cookie"); String cookies = response.getHeaders().get("Set-Cookie");
@@ -72,14 +76,12 @@ public class FULogin extends HTTPService {
errorCallback.onError(new NetworkError(100321, -1, "Error on starting FU session!")); errorCallback.onError(new NetworkError(100321, -1, "Error on starting FU session!"));
return; return;
} }
HashMap<String, String> object;
try { try {
object = getCookie(cookies, new String[]{"JSESSIONID"}); Bundle bundle = getCookie(cookies, new String[]{"JSESSIONID"});
callback.onResponse(bundle);
} catch (NoSuchFieldException e) { } catch (NoSuchFieldException e) {
errorCallback.onError(new NetworkError(100322, -1, "Error on starting FU session!")); errorCallback.onError(new NetworkError(100322, -1, "Error on starting FU session!"));
return;
} }
callback.onResponse(object);
}, error -> errorCallback.onError(new NetworkError(100320, error.networkResponse.statusCode, "Error on starting FU session!"))); }, error -> errorCallback.onError(new NetworkError(100320, error.networkResponse.statusCode, "Error on starting FU session!")));
} }
@@ -87,12 +89,12 @@ public class FULogin extends HTTPService {
3= GET [Location-Header 2] 3= GET [Location-Header 2]
+ Cookie: JSESSIONID=[JSESSION-FU] + Cookie: JSESSIONID=[JSESSION-FU]
*/ */
private void step3(String JSESSIONID_FU, final NetworkCallback<Boolean> callback, final NetworkErrorCallback errorCallback) { private void openLoginForm(String JSESSIONID_FU, final NetworkCallback<Boolean> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> cookies = new HashMap<>(); HashMap<String, String> cookies = new HashMap<>();
cookies.put("JSESSIONID", JSESSIONID_FU); cookies.put("JSESSIONID", JSESSIONID_FU);
head("https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?execution=e1s1", cookies, response -> { head("https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?execution=e1s1", cookies, response -> {
callback.onResponse(true); callback.onResponse(true);
}, error -> errorCallback.onError(new NetworkError(100330, error.networkResponse.statusCode, "Error starting login page!"))); }, error -> errorCallback.onError(new NetworkError(100330, error.networkResponse.statusCode, "Error starting FU login page!")));
} }
/* /*
@@ -104,28 +106,28 @@ public class FULogin extends HTTPService {
-> Set-Cookie: shib_idp_session=[SHIB-IDP-SESSION] -> Set-Cookie: shib_idp_session=[SHIB-IDP-SESSION]
-> Body SAMLResponse-Input-value -> Body SAMLResponse-Input-value
*/ */
private void step4(String username, String password, String JSESSIONID_FU, final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) { private void finishLogin(String username, String password, String JSESSIONID_FU, final NetworkCallback<Bundle> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> cookies = new HashMap<>(); HashMap<String, String> cookiesReq = new HashMap<>();
cookies.put("JSESSIONID", JSESSIONID_FU); cookiesReq.put("JSESSIONID", JSESSIONID_FU);
HashMap<String, String> body = new HashMap<>(); HashMap<String, String> body = new HashMap<>();
body.put("j_username", username); body.put("j_username", username);
body.put("j_password", password); body.put("j_password", password);
body.put("_eventId_proceed", ""); body.put("_eventId_proceed", "");
post("https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?execution=e1s1", cookies, body, response -> { post("https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?execution=e1s1", cookiesReq, body, response -> {
String content = response.getParsed(); String content = response.getParsed();
if (content == null) { if (content == null) {
errorCallback.onError(new NetworkError(100343, -1, "Error on getting SAML response!")); errorCallback.onError(new NetworkError(100343, -1, "Error on getting FU SAML response!"));
return; return;
} }
String cookies1 = response.getHeaders().get("Set-Cookie"); String cookies = response.getHeaders().get("Set-Cookie");
if (cookies1 ==null) { if (cookies == null) {
errorCallback.onError(new NetworkError(100341, -1, "Error on logging in to FU Identity Server!")); errorCallback.onError(new NetworkError(100341, -1, "Error on logging in to FU Identity Server!"));
return; return;
} }
HashMap<String, String> object; Bundle bundle;
try { try {
object = getCookie(cookies1, new String[]{"shib_idp_session"}); bundle = getCookie(cookies, new String[]{"shib_idp_session"});
} catch (NoSuchFieldException e) { } catch (NoSuchFieldException e) {
errorCallback.onError(new NetworkError(100342, -1, "Error on logging in to FU Identity Server!")); errorCallback.onError(new NetworkError(100342, -1, "Error on logging in to FU Identity Server!"));
return; return;
@@ -136,8 +138,8 @@ public class FULogin extends HTTPService {
errorCallback.onError(new NetworkError(100344, -1, "Error on getting SAML response!")); errorCallback.onError(new NetworkError(100344, -1, "Error on getting SAML response!"));
return; return;
} }
object.put("SAMLResponse", matcher.group(1)); bundle.putString("SAMLResponse", matcher.group(1));
callback.onResponse(object); callback.onResponse(bundle);
}, error -> errorCallback.onError(new NetworkError(100345, error.networkResponse.statusCode, "Error on logging in to FU Identity Server!"))); }, error -> errorCallback.onError(new NetworkError(100345, error.networkResponse.statusCode, "Error on logging in to FU Identity Server!")));
} }
} }

View File

@@ -1,176 +0,0 @@
package de.sebse.fuplanner.services.kvv.sync;
import android.content.Context;
import org.jetbrains.annotations.NotNull;
import org.json.JSONException;
import org.json.JSONObject;
import java.util.HashMap;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import de.sebse.fuplanner.services.kvv.Constants;
import de.sebse.fuplanner.services.kvv.types.LoginTokenKVV;
import de.sebse.fuplanner.tools.network.HTTPService;
import de.sebse.fuplanner.tools.network.NetworkCallback;
import de.sebse.fuplanner.tools.network.NetworkError;
import de.sebse.fuplanner.tools.network.NetworkErrorCallback;
public class KVVLogin extends HTTPService {
private final FULogin mFULogin;
private long lastHash;
private long lastSync;
private static final long MAX_CACHE_TIME = 1000 * 60; // 1 minute
public static final String KVV_SERVER_URL = Constants.KVV_SERVER_URL;
public KVVLogin(Context context, FULogin fuLogin) {
super(context);
this.mFULogin = fuLogin;
}
public void testLoginToken(@NotNull LoginTokenKVV token, @NotNull NetworkCallback<LoginTokenKVV> callback, @NotNull NetworkErrorCallback errorCallback) {
if (token.hashCode() == lastHash && lastSync + MAX_CACHE_TIME > System.currentTimeMillis() && token.getFullName() != null) {
callback.onResponse(token);
return;
}
get(String.format(KVV_SERVER_URL+"direct/profile/%s.json", token.getUsername()), token.getCookies(), response -> {
String body = response.getParsed();
if (body == null) {
errorCallback.onError(new NetworkError(100172, 403, "Testing login failed!"));
return;
}
try {
JSONObject json = new JSONObject(body);
String displayName = json.getString("displayName");
String email = json.getString("email");
token.setAdditionals(displayName, email);
lastSync = System.currentTimeMillis();
lastHash = token.hashCode();
callback.onResponse(token);
} catch (JSONException e) {
errorCallback.onError(new NetworkError(100171, 403, "Cannot parse profile!"));
}
}, error -> errorCallback.onError(new NetworkError(100170, error.networkResponse.statusCode, "Testing login failed!")));
}
public void doLogin(String username, String password, NetworkCallback<LoginTokenKVV> callback, NetworkErrorCallback error) {
step0(username, success -> {
step1(success1 -> {
String samlLocation = success1.get("Location");
mFULogin.fulogin(samlLocation, username, password, samlResponse -> {
step5(samlResponse, success5 -> {
String shibsessionKey = success5.get("shibsessionKey");
String shibsessionName = success5.get("shibsessionName");
step6(shibsessionKey, shibsessionName, success6 -> {
String kvvJSESSIONID = success6.get("JSESSIONID");
LoginTokenKVV token = new LoginTokenKVV(username, kvvJSESSIONID);
callback.onResponse(token);
}, error);
}, error);
}, error);
}, error);
}, error);
}
private void step0(String username, final NetworkCallback<Boolean> callback, final NetworkErrorCallback errorCallback) {
get(String.format(KVV_SERVER_URL+"direct/profile/%s", username), null, result -> {
callback.onResponse(true);
}, error -> {
if (error.networkResponse.statusCode == 500) {
errorCallback.onError(new NetworkError(100101, error.networkResponse.statusCode, "KVV not available!"));
} else {
callback.onResponse(true);
}
});
}
/*
1= GET https://mycampus.imp.fu-berlin.de/Shibboleth.sso/Login?entityID=https://identity.fu-berlin.de/idp-fub
-> Location-Header: https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?SAMLResponse=[SAMLResponse]&RelayState=[RelayState]
*/
private void step1(final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) {
get(KVV_SERVER_URL+"Shibboleth.sso/Login?entityID=https://identity.fu-berlin.de/idp-fub", null, response -> {
String location = response.getHeaders().get("Location");
if (location==null) {
errorCallback.onError(new NetworkError(100111, -1, "Error on getting SAML request!"));
return;
}
HashMap<String, String> object = new HashMap<>();
object.put("Location", location);
callback.onResponse(object);
}, error -> errorCallback.onError(new NetworkError(100110, error.networkResponse.statusCode, "Error on getting SAML request!")));
}
/*
5= POST https://mycampus.imp.fu-berlin.de/Shibboleth.sso/SAML2/POST
+ Body: SAMLResponse=[SAML-RESPONSE]
+ Header: Content-Type: application/x-www-form-urlencoded
-> Set-Cookie: _shibsession_[SESS-NR]: [SESS-VALUE]
*/
private void step5(String SAMLResponse, final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> body = new HashMap<>();
body.put("SAMLResponse", SAMLResponse);
post(KVV_SERVER_URL+"Shibboleth.sso/SAML2/POST", null, body, response -> {
String cookies = response.getHeaders().get("Set-Cookie");
if (cookies ==null) {
errorCallback.onError(new NetworkError(100151, -1, "Error on starting KVV session!"));
return;
}
HashMap<String, String> object = new HashMap<>();
Pattern pattern = Pattern.compile("(_shibsession_[0-9a-f]+)=([^;]+);");
Matcher matcher = pattern.matcher(cookies);
if (!matcher.find()) {
errorCallback.onError(new NetworkError(100152, -1, "Error on starting KVV session!"));
}
object.put("shibsessionKey", matcher.group(1));
object.put("shibsessionName", matcher.group(2));
callback.onResponse(object);
}, error -> errorCallback.onError(new NetworkError(100150, error.networkResponse.statusCode, "Error on starting KVV session!")));
}
/*
6= https://mycampus.imp.fu-berlin.de/sakai-login-tool/container
+ Cookie: _shibsession_[SESS-NR]: [SESS-VALUE]
-> Set-Cookie: JSESSIONID: [JSESSION-KVV]
*/
private void step6(String shibsessionKey, String shibsessionName, final NetworkCallback<HashMap<String, String>> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> cookies = new HashMap<>();
cookies.put(shibsessionKey, shibsessionName);
get(KVV_SERVER_URL+"sakai-login-tool/container", cookies, response -> {
String cookies1 = response.getHeaders().get("Set-Cookie");
if (cookies1 ==null) {
errorCallback.onError(new NetworkError(100161, -1, "Cannot finish login process!"));
return;
}
HashMap<String, String> object;
try {
object = getCookie(cookies1, new String[]{"JSESSIONID"});
} catch (NoSuchFieldException e) {
errorCallback.onError(new NetworkError(100162, -1, "Cannot finish login process!"));
return;
}
callback.onResponse(object);
}, error -> errorCallback.onError(new NetworkError(100160, error.networkResponse.statusCode, "Cannot finish login process!")));
}
}

View File

@@ -0,0 +1,55 @@
package de.sebse.fuplanner.services.kvv.sync;
import android.content.Context;
import android.os.Bundle;
import org.jetbrains.annotations.NotNull;
import de.sebse.fuplanner.services.kvv.types.LoginToken;
import de.sebse.fuplanner.tools.network.HTTPService;
import de.sebse.fuplanner.tools.network.NetworkCallback;
import de.sebse.fuplanner.tools.network.NetworkErrorCallback;
public abstract class LoginRoutine<T extends LoginToken> extends HTTPService {
private long lastHash;
private long lastSync;
private static final long MAX_CACHE_TIME = 1000 * 60; // 1 minute
public LoginRoutine(Context context) {
super(context);
}
public final void testToken(@NotNull T token, @NotNull NetworkCallback<T> callback, @NotNull NetworkErrorCallback error) {
if (token.hashCode() == lastHash && lastSync + MAX_CACHE_TIME > System.currentTimeMillis() && token.hasAdditionals()) {
callback.onResponse(token);
return;
}
checkToken(token, (bundle) -> {
token.setAdditionals(bundle);
lastSync = System.currentTimeMillis();
lastHash = token.hashCode();
callback.onResponse(token);
}, error);
}
public abstract void doesAccountExists(@NotNull String username, @NotNull NetworkCallback<Boolean> callback, @NotNull NetworkErrorCallback error);
protected abstract void checkToken(@NotNull T token, @NotNull NetworkCallback<Bundle> bundleCallback, @NotNull NetworkErrorCallback error);
public final void login(@NotNull String username, @NotNull String password, @NotNull NetworkCallback<T> callback, @NotNull NetworkErrorCallback error) {
doesAccountExists(username, success -> {
if (success) {
createLoginToken(username, password, callback, error);
return;
} else {
callback.onResponse(createUnavailableToken());
return;
}
}, error);
}
protected abstract void createLoginToken(@NotNull String username, @NotNull String password, @NotNull NetworkCallback<T> callback, @NotNull NetworkErrorCallback error);
protected abstract T createUnavailableToken();
}

View File

@@ -0,0 +1,158 @@
package de.sebse.fuplanner.services.kvv.sync;
import android.content.Context;
import android.os.Bundle;
import org.jetbrains.annotations.NotNull;
import org.json.JSONException;
import org.json.JSONObject;
import java.util.HashMap;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import de.sebse.fuplanner.services.kvv.types.LoginTokenWB;
import de.sebse.fuplanner.tools.network.NetworkCallback;
import de.sebse.fuplanner.tools.network.NetworkError;
import de.sebse.fuplanner.tools.network.NetworkErrorCallback;
import static de.sebse.fuplanner.services.kvv.Constants.WB_SERVER_URL;
public class WBLogin extends LoginRoutine<LoginTokenWB> {
private final FULogin fuLogin;
public WBLogin(Context context, FULogin fuLogin) {
super(context);
this.fuLogin = fuLogin;
}
@Override
public void doesAccountExists(@NotNull String username, @NotNull NetworkCallback<Boolean> callback, @NotNull NetworkErrorCallback error) {
callback.onResponse(true);
get(String.format(WB_SERVER_URL + "direct/profile/%s.json", username), null, response -> {
callback.onResponse(true);
}, err -> {
if (err.networkResponse.statusCode == 403) {
callback.onResponse(true);
} else {
callback.onResponse(false);
}
});
}
@Override
protected LoginTokenWB createUnavailableToken() {
return new LoginTokenWB();
}
@Override
protected void checkToken(@NotNull LoginTokenWB token, @NotNull NetworkCallback<Bundle> bundleCallback, @NotNull NetworkErrorCallback error) {
get(String.format(WB_SERVER_URL + "direct/profile/%s.json", token.getUsername()), token.getCookies(), response -> {
String body = response.getParsed();
if (body == null) {
error.onError(new NetworkError(100172, 403, "Testing WB login failed!"));
return;
}
try {
JSONObject json = new JSONObject(body);
Bundle bundle = new Bundle();
bundle.putString("fullName", json.getString("displayName"));
bundle.putString("email", json.getString("email"));
bundleCallback.onResponse(bundle);
} catch (JSONException e) {
error.onError(new NetworkError(100171, 403, "Cannot parse WB profile!"));
}
}, err -> error.onError(new NetworkError(100170, err.networkResponse.statusCode, "Testing WB login failed!")));
}
@Override
public void createLoginToken(@NotNull String username, @NotNull String password, @NotNull NetworkCallback<LoginTokenWB> callback, @NotNull NetworkErrorCallback error) {
getSAMLLocation(samlLocation -> {
fuLogin.fulogin(samlLocation, username, password, samlResponse -> {
startShibSession(samlResponse, shibSessionKey -> {
String shibsessionKey = shibSessionKey.getString("shibsessionKey");
String shibsessionName = shibSessionKey.getString("shibsessionName");
startSession(shibsessionKey, shibsessionName, sessionCookies -> {
Bundle bundle = new Bundle();
bundle.putString("username", username);
bundle.putAll(sessionCookies);
LoginTokenWB tokenWB = new LoginTokenWB(bundle);
testToken(tokenWB, callback, error);
}, error);
}, error);
}, error);
}, error);
}
/*
1= GET https://mycampus.imp.fu-berlin.de/Shibboleth.sso/Login?entityID=https://identity.fu-berlin.de/idp-fub
-> Location-Header: https://identity.fu-berlin.de/idp-fub/profile/SAML2/Redirect/SSO?SAMLResponse=[SAMLResponse]&RelayState=[RelayState]
*/
private void getSAMLLocation(final NetworkCallback<String> callback, final NetworkErrorCallback errorCallback) {
get(WB_SERVER_URL + "Shibboleth.sso/Login?entityID=https://identity.fu-berlin.de/idp-fub", null, response -> {
String location = response.getHeaders().get("Location");
if (location == null) {
errorCallback.onError(new NetworkError(100111, -1, "Error on getting WB SAML request!"));
return;
}
callback.onResponse(location);
}, error -> errorCallback.onError(new NetworkError(100110, error.networkResponse.statusCode, "Error on getting WB SAML request!")));
}
/*
5= POST https://mycampus.imp.fu-berlin.de/Shibboleth.sso/SAML2/POST
+ Body: SAMLResponse=[SAML-RESPONSE]
+ Header: Content-Type: application/x-www-form-urlencoded
-> Set-Cookie: _shibsession_[SESS-NR]: [SESS-VALUE]
*/
private void startShibSession(String samlResponse, final NetworkCallback<Bundle> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> body = new HashMap<>();
body.put("SAMLResponse", samlResponse);
post(WB_SERVER_URL + "Shibboleth.sso/SAML2/POST", null, body, response -> {
String cookies = response.getHeaders().get("Set-Cookie");
if (cookies ==null) {
errorCallback.onError(new NetworkError(100151, -1, "Error on starting WB session!"));
return;
}
Pattern pattern = Pattern.compile("(_shibsession_[0-9a-f]+)=([^;]+);");
Matcher matcher = pattern.matcher(cookies);
if (!matcher.find()) {
errorCallback.onError(new NetworkError(100152, -1, "Error on starting WB session!"));
}
Bundle bundle = new Bundle();
bundle.putString("shibsessionKey", matcher.group(1));
bundle.putString("shibsessionName", matcher.group(2));
callback.onResponse(bundle);
}, error -> errorCallback.onError(new NetworkError(100150, error.networkResponse.statusCode, "Error on starting WB session!")));
}
/*
6= https://mycampus.imp.fu-berlin.de/sakai-login-tool/container
+ Cookie: _shibsession_[SESS-NR]: [SESS-VALUE]
-> Set-Cookie: JSESSIONID: [JSESSION-KVV]
*/
private void startSession(String shibsessionKey, String shibsessionName, final NetworkCallback<Bundle> callback, final NetworkErrorCallback errorCallback) {
HashMap<String, String> cookies = new HashMap<>();
cookies.put(shibsessionKey, shibsessionName);
get(WB_SERVER_URL + "sakai-login-tool/container", cookies, response -> {
String cookies1 = response.getHeaders().get("Set-Cookie");
if (cookies1 ==null) {
errorCallback.onError(new NetworkError(100161, -1, "Cannot finish WB login process!"));
return;
}
try {
Bundle bundle = getCookie(cookies1, new String[]{"JSESSIONID"});
callback.onResponse(bundle);
} catch (NoSuchFieldException e) {
errorCallback.onError(new NetworkError(100162, -1, "Cannot finish WB login process!"));
}
}, error -> errorCallback.onError(new NetworkError(100160, error.networkResponse.statusCode, "Cannot finish WB login process!")));
}
}

View File

@@ -0,0 +1,123 @@
package de.sebse.fuplanner.services.kvv.types;
import android.os.Bundle;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import org.json.JSONException;
import org.json.JSONObject;
import java.util.HashMap;
import java.util.Objects;
import de.sebse.fuplanner.services.fulogin.AccountGeneral;
import de.sebse.fuplanner.tools.CustomAccountManager;
public abstract class LoginToken {
private boolean isExpanded = false;
private boolean isAvailable = false;
LoginToken(@NotNull CustomAccountManager manager, @NotNull LoginTokenInterface callback, @NotNull CustomAccountManager.ExceptionInterface errorCallback) {
if (!manager.hasAccounts(AccountGeneral.ACCOUNT_TYPE)) {
callback.run(null);
return;
}
manager.getTokenByType(AccountGeneral.ACCOUNT_TYPE, AccountGeneral.AUTHTOKEN_TYPE_BLACKBOARD, tokenString -> {
if (tokenString == null) {
callback.run(null);
return;
}
fromString(tokenString);
callback.run(this);
}, errorCallback);
}
LoginToken() {
super();
}
LoginToken(Bundle bundle) {
super();
init(bundle);
}
protected abstract String getAccountType();
protected void init(Bundle bundle) {
isAvailable = true;
}
public void setAdditionals(Bundle bundle) {
isExpanded = true;
isAvailable = true;
}
public final boolean hasAdditionals() {
return isExpanded;
}
public void setUnavailable() {
isExpanded = false;
isAvailable = false;
}
public final void unsetAdditionals() {
isExpanded = false;
}
public final void fromString(String jsonString) {
try {
JSONObject json = new JSONObject(jsonString);
this.isAvailable = json.getBoolean("isAvailable");
this.isExpanded = json.getBoolean("isExpanded");
jsonToObject(json);
} catch (JSONException e) {
e.printStackTrace();
}
}
@NotNull
public final String toString() {
JSONObject json = null;
try {
json = objectToJson();
json.put("isAvailable", isAvailable);
json.put("isExpanded", isExpanded);
} catch (JSONException e) {
e.printStackTrace();
}
if (json != null) {
return json.toString();
}
return "";
}
protected abstract void jsonToObject(JSONObject json) throws JSONException;
protected abstract JSONObject objectToJson() throws JSONException;
public abstract HashMap<String, String> getCookies();
public final String getCookieString() {
StringBuilder result = new StringBuilder();
HashMap<String, String> cookies = this.getCookies();
for (String header: cookies.keySet()) {
result.append(header).append("=").append(cookies.get(header)).append(";");
}
return result.substring(0, result.length()-1);
}
public final boolean isExpanded() {
return isExpanded;
}
public final boolean isAvailable() {
return isAvailable;
}
public interface LoginTokenInterface {
void run(LoginToken token);
}
public abstract boolean isOtherUser(String user);
}

View File

@@ -1,7 +1,10 @@
package de.sebse.fuplanner.services.kvv.types; package de.sebse.fuplanner.services.kvv.types;
import android.os.Bundle;
import com.google.android.gms.common.internal.Objects; import com.google.android.gms.common.internal.Objects;
import org.jetbrains.annotations.NotNull;
import org.json.JSONException; import org.json.JSONException;
import org.json.JSONObject; import org.json.JSONObject;
@@ -16,66 +19,59 @@ import de.sebse.fuplanner.tools.CustomAccountManager;
* Created by sebastian on 29.10.17. * Created by sebastian on 29.10.17.
*/ */
public class LoginTokenBB { public class LoginTokenBB extends LoginToken {
private final String s_session_id; private String s_session_id;
private final String session_id; private String session_id;
private final String username; private String username;
private boolean isAvailable = true;
@Nullable private String id; @Nullable private String id;
@Nullable private String studentId; @Nullable private String studentId;
public LoginTokenBB(String username, String s_session_id, String session_id) { public LoginTokenBB() {
this.username = username; super();
this.s_session_id = s_session_id;
this.session_id = session_id;
} }
public static void load(CustomAccountManager manager, LoginTokenInterface callback, CustomAccountManager.ExceptionInterface errorCallback) { public LoginTokenBB(Bundle bundle) {
if (!manager.hasAccounts(AccountGeneral.ACCOUNT_TYPE)) { super(bundle);
callback.run(null);
return;
}
manager.getTokenByType(AccountGeneral.ACCOUNT_TYPE, AccountGeneral.AUTHTOKEN_TYPE_BLACKBOARD, tokenString -> {
if (tokenString == null) {
callback.run(null);
return;
}
callback.run(LoginTokenBB.fromJsonString(tokenString));
}, errorCallback);
} }
public static boolean hasAccounts(CustomAccountManager manager) { @Override
return manager.hasAccounts(AccountGeneral.ACCOUNT_TYPE); protected void init(Bundle bundle) {
super.init(bundle);
this.username = bundle.getString("username");
this.s_session_id = bundle.getString("s_session_id");
this.session_id = bundle.getString("session_id");
} }
public void delete(CustomAccountManager manager) { @Override
manager.deleteAccount(AccountGeneral.ACCOUNT_TYPE); protected String getAccountType() {
return AccountGeneral.AUTHTOKEN_TYPE_BLACKBOARD;
} }
public void setAdditionals(String id, String studentId) { @Override
this.id = id; public void setAdditionals(Bundle bundle) {
this.studentId = studentId; super.setAdditionals(bundle);
this.isAvailable = true; this.id = bundle.getString("id");
this.studentId = bundle.getString("studentId");
} }
public void setNotAvailable() { @Override
public void setUnavailable() {
super.setUnavailable();
this.id = null; this.id = null;
this.studentId = null; this.studentId = null;
this.isAvailable = false;
}
public boolean isAvailable() {
return isAvailable;
} }
@NotNull
public String getUsername() { public String getUsername() {
return username; return username;
} }
private String getSessionId() { @NotNull
public String getSessionId() {
return session_id; return session_id;
} }
@NotNull
public String getSSessionId() { public String getSSessionId() {
return s_session_id; return s_session_id;
} }
@@ -90,6 +86,7 @@ public class LoginTokenBB {
return studentId; return studentId;
} }
@Override
public HashMap<String, String> getCookies() { public HashMap<String, String> getCookies() {
HashMap<String, String> cookies = new HashMap<>(); HashMap<String, String> cookies = new HashMap<>();
cookies.put("session_id", getSessionId()); cookies.put("session_id", getSessionId());
@@ -97,55 +94,40 @@ public class LoginTokenBB {
return cookies; return cookies;
} }
@Override
public boolean isOtherUser(String username) { public boolean isOtherUser(String username) {
return !this.getUsername().equals(username); return !this.getUsername().equals(username);
} }
@NonNull
@Override @Override
public String toString() { protected JSONObject objectToJson() throws JSONException {
StringBuilder result = new StringBuilder();
HashMap<String, String> cookies = this.getCookies();
for (String header: cookies.keySet()) {
result.append(header).append("=").append(cookies.get(header)).append(";");
}
return result.substring(0, result.length()-1);
}
public String toJsonString() {
JSONObject json = new JSONObject(); JSONObject json = new JSONObject();
try { if (isAvailable()) {
json.put("s_session_id", s_session_id); json.put("s_session_id", s_session_id);
json.put("session_id", session_id); json.put("session_id", session_id);
json.put("username", username); json.put("username", username);
}
if (isExpanded()) {
json.put("id", id); json.put("id", id);
json.put("studentId", studentId); json.put("studentId", studentId);
json.put("isAvailable", isAvailable);
} catch (JSONException e) {
return null;
} }
return json.toString(); return json;
} }
private static LoginTokenBB fromJsonString(String tokenString) { @Override
try { protected void jsonToObject(JSONObject json) throws JSONException {
JSONObject json = new JSONObject(tokenString); if (isAvailable()) {
LoginTokenBB token = new LoginTokenBB( Bundle bundle = new Bundle();
json.getString("username"), bundle.putString("username", json.getString("username"));
json.getString("s_session_id"), bundle.putString("s_session_id", json.getString("s_session_id"));
json.getString("session_id")); bundle.putString("session_id", json.getString("session_id"));
if (!json.isNull("id")) init(bundle);
token.setAdditionals( }
json.getString("id"), if (isExpanded()) {
json.getString("studentId") Bundle bundle = new Bundle();
); bundle.putString("id", json.getString("id"));
if (!json.optBoolean("isAvailable", true)) { bundle.putString("studentId", json.getString("studentId"));
token.setNotAvailable(); setAdditionals(bundle);
}
return token;
} catch (JSONException e) {
e.printStackTrace();
return null;
} }
} }
@@ -153,8 +135,4 @@ public class LoginTokenBB {
public int hashCode() { public int hashCode() {
return Objects.hashCode(s_session_id, session_id, username, id, studentId); return Objects.hashCode(s_session_id, session_id, username, id, studentId);
} }
public interface LoginTokenInterface {
void run(LoginTokenBB token);
}
} }

View File

@@ -1,152 +0,0 @@
package de.sebse.fuplanner.services.kvv.types;
import com.google.android.gms.common.internal.Objects;
import org.json.JSONException;
import org.json.JSONObject;
import java.util.HashMap;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import de.sebse.fuplanner.services.fulogin.AccountGeneral;
import de.sebse.fuplanner.tools.CustomAccountManager;
/**
* Created by sebastian on 29.10.17.
*/
public class LoginTokenKVV {
private final String username;
private final String JSESSIONID;
private boolean isAvailable = true;
@Nullable private String fullName;
@Nullable private String email;
public LoginTokenKVV(String username, String JSESSIONID) {
this.username = username;
this.JSESSIONID = JSESSIONID;
}
public static void load(CustomAccountManager manager, LoginTokenInterface callback, CustomAccountManager.ExceptionInterface errorCallback) {
if (!manager.hasAccounts(AccountGeneral.ACCOUNT_TYPE)) {
callback.run(null);
return;
}
manager.getTokenByType(AccountGeneral.ACCOUNT_TYPE, AccountGeneral.AUTHTOKEN_TYPE_KVV, tokenString -> {
if (tokenString == null) {
callback.run(null);
return;
}
callback.run(LoginTokenKVV.fromJsonString(tokenString));
}, errorCallback);
}
public static boolean hasAccounts(CustomAccountManager manager) {
return manager.hasAccounts(AccountGeneral.ACCOUNT_TYPE);
}
public void delete(CustomAccountManager manager) {
manager.deleteAccount(AccountGeneral.ACCOUNT_TYPE);
}
public void setAdditionals(String fullName, String email) {
this.fullName = fullName;
this.email = email;
this.isAvailable = true;
}
public void setNotAvailable() {
this.fullName = null;
this.email = null;
this.isAvailable = false;
}
public boolean isAvailable() {
return isAvailable;
}
public String getUsername() {
return username;
}
private String getJSESSIONID() {
return JSESSIONID;
}
@Nullable
public String getFullName() {
return fullName;
}
@Nullable
public String getEmail() {
return email;
}
public HashMap<String, String> getCookies() {
HashMap<String, String> cookies = new HashMap<>();
cookies.put("JSESSIONID", getJSESSIONID());
cookies.put("pasystem_timezone_ok", "true");
return cookies;
}
public boolean isOtherUser(String username) {
return !this.getUsername().equals(username);
}
@NonNull
@Override
public String toString() {
StringBuilder result = new StringBuilder();
HashMap<String, String> cookies = this.getCookies();
for (String header: cookies.keySet()) {
result.append(header).append("=").append(cookies.get(header)).append(";");
}
return result.substring(0, result.length()-1);
}
public String toJsonString() {
JSONObject json = new JSONObject();
try {
json.put("username", username);
json.put("JSESSIONID", JSESSIONID);
json.put("fullName", fullName);
json.put("email", email);
json.put("isAvailable", isAvailable);
} catch (JSONException e) {
return null;
}
return json.toString();
}
private static LoginTokenKVV fromJsonString(String tokenString) {
try {
JSONObject json = new JSONObject(tokenString);
LoginTokenKVV token = new LoginTokenKVV(
json.getString("username"),
json.getString("JSESSIONID"));
if (!json.isNull("fullName"))
token.setAdditionals(
json.getString("fullName"),
json.getString("email")
);
if (!json.optBoolean("isAvailable", true)) {
token.setNotAvailable();
}
return token;
} catch (JSONException e) {
e.printStackTrace();
return null;
}
}
@Override
public int hashCode() {
return Objects.hashCode(username, JSESSIONID, fullName, email);
}
public interface LoginTokenInterface {
void run(LoginTokenKVV token);
}
}

View File

@@ -0,0 +1,126 @@
package de.sebse.fuplanner.services.kvv.types;
import android.os.Bundle;
import com.google.android.gms.common.internal.Objects;
import org.json.JSONException;
import org.json.JSONObject;
import java.util.HashMap;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import de.sebse.fuplanner.services.fulogin.AccountGeneral;
import de.sebse.fuplanner.tools.CustomAccountManager;
/**
* Created by sebastian on 29.10.17.
*/
public class LoginTokenWB extends LoginToken {
private String username;
private String JSESSIONID;
@Nullable private String fullName;
@Nullable private String email;
public LoginTokenWB() {
super();
}
public LoginTokenWB(Bundle bundle) {
super(bundle);
}
@Override
protected void init(Bundle bundle) {
super.init(bundle);
this.username = bundle.getString("username");
this.JSESSIONID = bundle.getString("JSESSIONID");
}
@Override
protected String getAccountType() {
return AccountGeneral.AUTHTOKEN_TYPE_WB;
}
@Override
public void setAdditionals(Bundle bundle) {
super.setAdditionals(bundle);
this.fullName = bundle.getString("fullName");
this.email = bundle.getString("email");
}
@Override
public void setUnavailable() {
super.setUnavailable();
this.fullName = null;
this.email = null;
}
public String getUsername() {
return username;
}
private String getJSESSIONID() {
return JSESSIONID;
}
@Nullable
public String getFullName() {
return fullName;
}
@Nullable
public String getEmail() {
return email;
}
@Override
public HashMap<String, String> getCookies() {
HashMap<String, String> cookies = new HashMap<>();
cookies.put("JSESSIONID", getJSESSIONID());
cookies.put("pasystem_timezone_ok", "true");
return cookies;
}
@Override
public boolean isOtherUser(String username) {
return !this.getUsername().equals(username);
}
@Override
protected JSONObject objectToJson() throws JSONException {
JSONObject json = new JSONObject();
if (isAvailable()) {
json.put("username", username);
json.put("JSESSIONID", JSESSIONID);
}
if (isExpanded()) {
json.put("fullName", fullName);
json.put("email", email);
}
return json;
}
@Override
protected void jsonToObject(JSONObject json) throws JSONException {
if (isAvailable()) {
Bundle bundle = new Bundle();
bundle.putString("username", json.getString("username"));
bundle.putString("JSESSIONID", json.getString("JSESSIONID"));
init(bundle);
}
if (isExpanded()) {
Bundle bundle = new Bundle();
bundle.putString("fullName", json.getString("fullName"));
bundle.putString("email", json.getString("email"));
setAdditionals(bundle);
}
}
@Override
public int hashCode() {
return Objects.hashCode(username, JSESSIONID, fullName, email);
}
}