blob: 255f791925b8dbc206c5af0153b5c6a376e51d80 (
plain) (
blame)
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
|
/****************************************************************************
* Copyright (c) 2014 Composent, Inc.
*
* This program and the accompanying materials are made
* available under the terms of the Eclipse Public License 2.0
* which is available at https://www.eclipse.org/legal/epl-2.0/
*
* Contributors: Scott Lewis - initial API and implementation
*
* SPDX-License-Identifier: EPL-2.0
*****************************************************************************/
package com.mycorp.examples.timeservice.consumer.ds.generic.auth;
import java.util.HashMap;
import java.util.Map;
import org.eclipse.ecf.core.ContainerTypeDescription;
import org.eclipse.ecf.core.IContainer;
import org.eclipse.ecf.core.identity.ID;
import org.eclipse.ecf.core.security.IConnectContext;
import org.eclipse.ecf.core.security.IConnectInitiatorPolicy;
import org.eclipse.ecf.core.sharedobject.ISharedObjectContainerClient;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.ConsumerContainerSelector;
import org.eclipse.ecf.osgi.services.remoteserviceadmin.SelectContainerException;
import org.eclipse.ecf.remoteservice.IRemoteServiceContainer;
public class GenericAuthConsumerContainerSelector extends
ConsumerContainerSelector {
public GenericAuthConsumerContainerSelector() {
super(true);
}
@Override
protected IRemoteServiceContainer createContainer(
ContainerTypeDescription containerTypeDescription,
String containerTypeDescriptionName,
@SuppressWarnings("rawtypes") Map properties)
throws SelectContainerException {
IRemoteServiceContainer result = super.createContainer(
containerTypeDescription, containerTypeDescriptionName,
properties);
ISharedObjectContainerClient client = (ISharedObjectContainerClient) result
.getContainer().getAdapter(ISharedObjectContainerClient.class);
if (client != null) {
client.setConnectInitiatorPolicy(new IConnectInitiatorPolicy() {
public void refresh() {
}
public Object createConnectData(IContainer container,
ID targetID, IConnectContext context) {
// This is called when the client.connect method
// is called. Here is our chance to send credentials
// to the server.
return getConnectData();
}
public int getConnectTimeout() {
return 30000;
}
});
}
return result;
}
@SuppressWarnings({ "rawtypes", "unchecked" })
Object getConnectData() {
Map results = new HashMap();
// Get system properties values, if present
String username = System.getProperty("myUsername");
if (username != null) {
results.put("username",username);
String password = System.getProperty("myPassword");
if (password != null)
results.put("password",password);
}
if (results.size() > 0)
return results;
return null;
}
}
|
