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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
package org.openecomp.dcae.inventory;
/*
* ============LICENSE_START==========================================
* ===================================================================
* Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
* ===================================================================
* Licensed 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.
* ============LICENSE_END============================================
*
* ECOMP and OpenECOMP are trademarks
* and service marks of AT&T Intellectual Property.
*
*/
import org.openecomp.dcae.inventory.clients.DCAEControllerClient;
import org.openecomp.dcae.inventory.clients.DatabusControllerClient;
import org.openecomp.dcae.inventory.daos.InventoryDAOManager;
import org.openecomp.dcae.inventory.dbthings.StringListArgument;
import org.openecomp.dcae.inventory.exceptions.mappers.DCAEControllerConnectionExceptionMapper;
import org.openecomp.dcae.inventory.exceptions.mappers.DCAEControllerTimeoutExceptionMapper;
import org.openecomp.dcae.inventory.providers.NotFoundExceptionMapper;
import com.fasterxml.jackson.databind.module.SimpleModule;
import io.dropwizard.Application;
import io.dropwizard.client.JerseyClientBuilder;
import io.dropwizard.jdbi.DBIFactory;
import io.dropwizard.setup.Bootstrap;
import io.dropwizard.setup.Environment;
import io.swagger.api.DcaeServiceTypesApi;
import io.swagger.api.DcaeServicesApi;
import io.swagger.api.DcaeServicesGroupbyApi;
import io.swagger.api.factories.DcaeServicesApiServiceFactory;
import io.swagger.jaxrs.config.BeanConfig;
import io.swagger.jaxrs.listing.ApiListingResource;
import io.swagger.jaxrs.listing.SwaggerSerializers;
import io.swagger.models.Contact;
import io.swagger.models.Info;
import org.eclipse.jetty.servlets.CrossOriginFilter;
import org.glassfish.jersey.client.authentication.HttpAuthenticationFeature;
import org.skife.jdbi.v2.DBI;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.servlet.DispatcherType;
import javax.servlet.FilterRegistration;
import javax.ws.rs.client.Client;
import javax.ws.rs.core.Link;
import java.util.EnumSet;
/**
* Created by mhwang on 4/11/16.
*/
public class InventoryApplication extends Application<InventoryConfiguration> {
static final Logger LOG = LoggerFactory.getLogger(InventoryApplication.class);
public static void main(String[] args) throws Exception {
new InventoryApplication().run(args);
}
@Override
public String getName() {
return "dcae-inventory";
}
@Override
public void initialize(Bootstrap<InventoryConfiguration> bootstrap) {
// This Info object was lifted from the Swagger generated io.swagger.api.Bootstrap file. Although it was not generated
// correctly.
Info info = new Info().title("DCAE Inventory API").version("0.8.0")
.description("DCAE Inventory is a web service that provides the following:\n\n1. Real-time data on all DCAE services and their components\n2. Comprehensive details on available DCAE service types\n");
// Swagger/servlet/jax-rs magic!
BeanConfig beanConfig = new BeanConfig();
beanConfig.setInfo(info);
beanConfig.setResourcePackage("io.swagger.api");
beanConfig.setScan(true);
}
@Override
public void run(InventoryConfiguration configuration, Environment environment) {
LOG.info("Starting DCAE inventory application");
LOG.info(String.format("DB driver properties: %s", configuration.getDataSourceFactory().getProperties().toString()));
final DBIFactory factory = new DBIFactory();
final DBI jdbi = factory.build(environment, configuration.getDataSourceFactory(), "dcae-database");
jdbi.registerArgumentFactory(new StringListArgument());
InventoryDAOManager.getInstance().init(jdbi);
// Add filter for CORS support for DCAE dashboard
// http://jitterted.com/tidbits/2014/09/12/cors-for-dropwizard-0-7-x/
// https://gist.github.com/yunspace/07d80a9ac32901f1e149#file-dropwizardjettycrossoriginintegrationtest-java-L11
FilterRegistration.Dynamic filter = environment.servlets().addFilter("CORSFilter", CrossOriginFilter.class);
filter.addMappingForUrlPatterns(EnumSet.of(DispatcherType.REQUEST), false, "/*");
filter.setInitParameter(CrossOriginFilter.ALLOWED_ORIGINS_PARAM, "*");
filter.setInitParameter(CrossOriginFilter.ALLOWED_HEADERS_PARAM, "Content-Type,Authorization,X-Requested-With,Content-Length,Accept,Origin");
filter.setInitParameter(CrossOriginFilter.ALLOWED_METHODS_PARAM, "GET,PUT,POST,DELETE,OPTIONS");
filter.setInitParameter(CrossOriginFilter.ACCESS_CONTROL_ALLOW_ORIGIN_HEADER, "*");
// Want to serialize Link in a way we like
SimpleModule simpleModule = new SimpleModule();
simpleModule.addSerializer(Link.class, new LinkSerializer());
environment.getObjectMapper().registerModule(simpleModule);
// Setup DCAE controller client
// Used by the dcae-services API
final Client clientDCAEController = new JerseyClientBuilder(environment).using(configuration.getJerseyClientConfiguration())
.build("DCAEControllerClient");
HttpAuthenticationFeature feature = HttpAuthenticationFeature.basicBuilder().build();
clientDCAEController.register(feature);
final DCAEControllerClient dcaeControllerClient = new DCAEControllerClient(clientDCAEController, configuration.getDcaeControllerConnection());
DcaeServicesApiServiceFactory.setDcaeControllerClient(dcaeControllerClient);
// Setup Databus controller client
// Used by the dcae-services API
final Client clientDatabusController = new JerseyClientBuilder(environment).using(configuration.getJerseyClientConfiguration())
.build("DatabusControllerClient");
final DatabusControllerClient databusControllerClient = new DatabusControllerClient(clientDatabusController,
configuration.getDatabusControllerConnection());
DcaeServicesApiServiceFactory.setDatabusControllerClient(databusControllerClient);
environment.jersey().register(NotFoundExceptionMapper.class);
environment.jersey().register(DCAEControllerConnectionExceptionMapper.class);
environment.jersey().register(DCAEControllerTimeoutExceptionMapper.class);
environment.jersey().register(new DcaeServicesApi());
environment.jersey().register(new DcaeServiceTypesApi());
environment.jersey().register(new DcaeServicesGroupbyApi());
// https://github.com/swagger-api/swagger-core/wiki/Swagger-Core-Jersey-2.X-Project-Setup-1.5
environment.jersey().register(new ApiListingResource());
environment.jersey().register(new SwaggerSerializers());
}
}
|
