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
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.tuscany.sca.shell.jline;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import jline.SimpleCompletor;
import org.apache.tuscany.sca.assembly.Endpoint;
import org.apache.tuscany.sca.impl.NodeImpl;
import org.apache.tuscany.sca.runtime.DomainRegistry;
import org.apache.tuscany.sca.runtime.RuntimeComponent;
import org.apache.tuscany.sca.shell.Shell;
import org.oasisopen.sca.NoSuchServiceException;
/**
* A Completor for available service operations
*/
public class ServiceOperationCompletor extends SimpleCompletor {
private Shell shell;
private static final List<String> EXCLUDED_OPS = Arrays.asList(new String[] {"equals", "getClass",
"getInvocationHandler",
"getProxyClass", "hashCode",
"isProxyClass", "newProxyInstance",
"notify", "notifyAll", "toString",
"wait", "CGLIB$SET_STATIC_CALLBACKS",
"CGLIB$SET_THREAD_CALLBACKS",
"CGLIB$findMethodProxy",
"getCallback", "getCallbacks",
"newInstance", "setCallback",
"setCallbacks"});
public ServiceOperationCompletor(Shell shell) {
super("");
this.shell = shell;
}
@Override
public int complete(final String buffer, final int cursor, final List clist) {
String service = TShellCompletor.lastArg;
// DomainRegistry reg = ((NodeImpl)shell.getNode()).getEndpointRegistry();
// List<Endpoint> endpoints = reg.findEndpoint(service);
// if (endpoints.size() < 1) {
// return -1;
// }
// String serviceName = null;
// if (service.contains("/")) {
// int i = service.indexOf("/");
// if (i < service.length()-1) {
// serviceName = service.substring(i+1);
// }
// }
// Object proxy = ((RuntimeComponent)endpoints.get(0).getComponent()).getServiceReference(null, serviceName).getService();
try {
Object proxy = shell.getNode().getService(null, service);
Method[] ms = proxy.getClass().getMethods();
List<String> ops = new ArrayList<String>();
for (Method m : ms) {
if (!EXCLUDED_OPS.contains(m.getName())) {
ops.add(m.getName());
}
}
setCandidateStrings(ops.toArray(new String[ops.size()]));
} catch (NoSuchServiceException e) {
}
return super.complete(buffer, cursor, clist);
}
}
|
