|
22 | 22 | */
|
23 | 23 | package opengrok.auth.plugin;
|
24 | 24 |
|
| 25 | +import java.lang.reflect.Constructor; |
| 26 | +import java.lang.reflect.InvocationTargetException; |
25 | 27 | import java.util.Map;
|
| 28 | +import java.util.logging.Level; |
| 29 | +import java.util.logging.Logger; |
26 | 30 | import javax.servlet.http.HttpServletRequest;
|
27 |
| -import opengrok.auth.plugin.decoders.FakeOSSOHeaderDecoder; |
28 |
| -import opengrok.auth.plugin.decoders.OSSOHeaderDecoder; |
29 | 31 | import opengrok.auth.plugin.decoders.IUserDecoder;
|
30 | 32 | import opengrok.auth.plugin.entity.User;
|
31 | 33 | import org.opengrok.indexer.authorization.IAuthorizationPlugin;
|
|
39 | 41 | */
|
40 | 42 | public class UserPlugin implements IAuthorizationPlugin {
|
41 | 43 |
|
42 |
| - private static final String FAKE_PARAM = "fake"; |
| 44 | + private static final Logger LOGGER = Logger.getLogger(UserPlugin.class.getName()); |
| 45 | + |
| 46 | + private static final String DECODER_CLASS_PARAM = "decoder"; |
43 | 47 |
|
44 | 48 | public static final String REQUEST_ATTR = "opengrok-user-plugin-user";
|
45 | 49 |
|
46 |
| - private IUserDecoder decoder = new OSSOHeaderDecoder(); |
| 50 | + private IUserDecoder decoder; |
| 51 | + |
| 52 | + public UserPlugin() { |
| 53 | + } |
| 54 | + |
| 55 | + // for testing |
| 56 | + protected UserPlugin(IUserDecoder decoder) { |
| 57 | + this.decoder = decoder; |
| 58 | + } |
| 59 | + |
| 60 | + private IUserDecoder getDecoder(String name) throws ClassNotFoundException, NoSuchMethodException, |
| 61 | + IllegalAccessException, InvocationTargetException, InstantiationException { |
| 62 | + Class<?> clazz = Class.forName(name); |
| 63 | + Constructor<?> constructor = clazz.getConstructor(); |
| 64 | + Object instance = constructor.newInstance(); |
| 65 | + return (IUserDecoder)instance; |
| 66 | + } |
47 | 67 |
|
48 | 68 | @Override
|
49 | 69 | public void load(Map<String, Object> parameters) {
|
50 |
| - Boolean fake; |
| 70 | + String decoder_name; |
| 71 | + if ((decoder_name = (String) parameters.get(DECODER_CLASS_PARAM)) == null) { |
| 72 | + throw new NullPointerException(String.format("missing " + |
| 73 | + "parameter '%s' in %s configuration", |
| 74 | + DECODER_CLASS_PARAM, UserPlugin.class.getName())); |
| 75 | + } |
51 | 76 |
|
52 |
| - if ((fake = (Boolean) parameters.get(FAKE_PARAM)) != null |
53 |
| - && fake) { |
54 |
| - decoder = new FakeOSSOHeaderDecoder(); |
| 77 | + LOGGER.log(Level.INFO, "loading decoder: {0}", decoder_name); |
| 78 | + try { |
| 79 | + decoder = getDecoder(decoder_name); |
| 80 | + } catch (ClassNotFoundException|NoSuchMethodException|IllegalAccessException| |
| 81 | + InvocationTargetException|InstantiationException e) { |
| 82 | + throw new RuntimeException("cannot load decoder " + decoder_name, e); |
55 | 83 | }
|
56 | 84 | }
|
57 | 85 |
|
58 | 86 | @Override
|
59 | 87 | public void unload() {
|
60 | 88 | }
|
61 | 89 |
|
62 |
| - @Override |
63 |
| - public boolean isAllowed(HttpServletRequest request, Project project) { |
| 90 | + private User getUser(HttpServletRequest request) { |
64 | 91 | User user;
|
65 |
| - if ((user = (User) request.getAttribute(REQUEST_ATTR)) == null) { |
| 92 | + |
| 93 | + if ((user = (User)request.getAttribute(REQUEST_ATTR))==null) { |
66 | 94 | user = decoder.fromRequest(request);
|
67 | 95 | request.setAttribute(REQUEST_ATTR, user);
|
68 | 96 | }
|
69 |
| - return user != null; |
| 97 | + |
| 98 | + return user; |
| 99 | + } |
| 100 | + |
| 101 | + @Override |
| 102 | + public boolean isAllowed(HttpServletRequest request, Project project) { |
| 103 | + return getUser(request) != null; |
70 | 104 | }
|
71 | 105 |
|
72 | 106 | @Override
|
73 | 107 | public boolean isAllowed(HttpServletRequest request, Group group) {
|
74 |
| - User user; |
75 |
| - if ((user = (User) request.getAttribute(REQUEST_ATTR)) == null) { |
76 |
| - user = decoder.fromRequest(request); |
77 |
| - request.setAttribute(REQUEST_ATTR, user); |
78 |
| - } |
79 |
| - return user != null; |
| 108 | + return getUser(request) != null; |
80 | 109 | }
|
81 | 110 | }
|
0 commit comments