Add support for complex and simple JSON attribute mappings.

Matthew Swift

23.39.2012 5d8774080700c97c4f290818e4b5aa42a209740b

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
/*
 * The contents of this file are subject to the terms of the Common Development and
 * Distribution License (the License). You may not use this file except in compliance with the
 * License.
 *
 * You can obtain a copy of the License at legal/CDDLv1.0.txt. See the License for the
 * specific language governing permission and limitations under the License.
 *
 * When distributing Covered Software, include this CDDL Header Notice in each file and include
 * the License file at legal/CDDLv1.0.txt. If applicable, add the following below the CDDL
 * Header, with the fields enclosed by brackets [] replaced by your own identifying
 * information: "Portions Copyrighted [year] [name of copyright owner]".
 *
 * Copyright © 2012 ForgeRock AS. All rights reserved.
 */
 
package org.forgerock.opendj.rest2ldap;
 
import org.forgerock.json.resource.restlet.JsonResourceRestlet;
import org.forgerock.opendj.ldap.ConnectionFactory;
import org.forgerock.opendj.ldap.Connections;
import org.forgerock.opendj.ldap.DN;
import org.forgerock.opendj.ldap.LDAPConnectionFactory;
import org.forgerock.opendj.ldap.requests.Requests;
import org.forgerock.resource.framework.JsonResourceProvider;
import org.forgerock.resource.framework.impl.ResourceInvoker;
import org.restlet.Application;
import org.restlet.Component;
import org.restlet.Restlet;
import org.restlet.data.Protocol;
import org.restlet.routing.Router;
import org.restlet.routing.Template;
 
/**
 * Example
 */
public class Example {
 
    private Application application = new Application();
    private final Router router = new Router();
 
    private void bindJsonResource(JsonResourceProvider resource, String path) {
        Restlet restlet = new JsonResourceRestlet(resource);
        restlet.setContext(application.getContext());
        router.attach(path, restlet, Template.MODE_EQUALS);
        router.attach(path + (path.equals("/") ? "" : "/"), restlet, Template.MODE_STARTS_WITH);
    }
 
    public void start() throws Exception {
        // All LDAP resources will use this connection factory.
        ConnectionFactory factory =
                Connections.newAuthenticatedConnectionFactory(new LDAPConnectionFactory(
                        "localhost", 1389), Requests.newSimpleBindRequest("cn=directory manager",
                        "password".toCharArray()));
 
        // Create two entry containers whose members reference each other.
        EntryContainer userContainer =
                new EntryContainer(DN.valueOf("ou=people,dc=example,dc=com"), factory);
        EntryContainer groupContainer =
                new EntryContainer(DN.valueOf("ou=groups,dc=example,dc=com"), factory);
 
        // Create user resource.
        AttributeMapper userMapper =
                new CompositeAttributeMapper().addMapper(
                        new DefaultAttributeMapper().includeAttribute("uid", "isMemberOf",
                                "modifyTimestamp")).addMapper(
                        new ComplexAttributeMapper("name", new DefaultAttributeMapper()
                                .includeAttribute("cn", "sn", "givenName"))).addMapper(
                        new ComplexAttributeMapper("contactInformation",
                                new CompositeAttributeMapper().addMapper(
                                        new SimpleAttributeMapper("telephoneNumber")).addMapper(
                                        new SimpleAttributeMapper("emailAddress", "mail"))));
        LDAPResource userResource = new LDAPResource(userContainer, userMapper);
        ResourceInvoker userResourceInvoker = new ResourceInvoker();
        userResourceInvoker.resource = userResource; // FIXME: Yuk!
        bindJsonResource(userResourceInvoker, "/users");
 
        // Create group resource.
        AttributeMapper groupMapper =
                new DefaultAttributeMapper().includeAttribute("cn", "ou", "description",
                        "uniquemember");
        LDAPResource groupResource = new LDAPResource(groupContainer, groupMapper);
        ResourceInvoker groupResourceInvoker = new ResourceInvoker();
        groupResourceInvoker.resource = groupResource; // FIXME: Yuk!
        bindJsonResource(groupResourceInvoker, "/groups");
 
        // Configure and start the application.
        application.getTunnelService().setQueryTunnel(false);
        application.setInboundRoot(router);
        Component component = new Component();
        component.getServers().add(Protocol.HTTP, 8080);
        component.getDefaultHost().attach("", application);
        component.start();
    }
 
    public static void main(String[] args) throws Exception {
        Example instance = new Example();
        instance.start();
    }
}