2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
20 package org.onap.dmaap.dbcapi.testframework;
22 import org.onap.dmaap.dbcapi.model.*;
23 import org.onap.dmaap.dbcapi.util.RandomInteger;
25 public class DmaapObjectFactory {
28 * we use localhost for most references so that connection attempts will resolve and not retry
29 * but still we expect that requests will fail.
31 private static final String fmt = "%24s: %s%n";
32 private static final String dmaap_name = "onap-ut";
33 private static final String dmaap_ver = "1";
34 private static final String dmaap_topic_root = "org.onap.dmaap";
35 private static final String dmaap_dr = "https://localhost:8443";
36 private static final String dmaap_log_url = "http://localhost:8080/log";
37 private static final String dmaap_mm_topic = "org.onap.dmaap.dcae.MM_AGENT_TOPIC";
38 private static final String central_loc = "SanFrancisco";
39 private static final String central_layer = "central-cloud";
40 private static final String central_clli = "SFCAL19240";
41 private static final String central_zone = "osaz01";
42 private static final String central_subnet = "10.10.10.0/24";
43 private static final String central_cluster_fqdn = "localhost";
44 private static final String pub_role = "org.onap.vnfapp.publisher";
45 private static final String sub_role = "org.onap.vnfapp.subscriber";
46 private static final String edge_loc = "Atlanta";
47 private static final String edge_layer = "edge-cloud";
48 private static final String edge_clli = "ATLGA10245";
49 private static final String edge_zone = "osaz02";
50 private static final String edge_subnet = "10.10.20.0/24";
51 private static final String edge_cluster_fqdn = "localhost";
52 private static final String[]hosts = { "host1", "host2", "host3" };
53 private static final String port = "3904";
54 private static final String prot = "http";
56 public Dmaap genDmaap() {
57 return new Dmaap.DmaapBuilder().setVer(dmaap_ver).setTnr(dmaap_topic_root).setDn(dmaap_name).setDpu(dmaap_dr).setLu(dmaap_log_url).setBat(dmaap_mm_topic).setNk("nk").setAko("ako").createDmaap();
60 public DcaeLocation genDcaeLocation( String layer ) {
61 if ( layer.contains( "edge" ) ) {
62 return new DcaeLocation( edge_clli, edge_layer, edge_loc, edge_zone, edge_subnet );
64 return new DcaeLocation( central_clli, central_layer, central_loc, central_zone, central_subnet );
68 public MR_Cluster genMR_Cluster( String layer ) {
69 if ( layer.contains( "edge" ) ) {
70 return new MR_Cluster( edge_loc, edge_cluster_fqdn, prot, port );
72 return new MR_Cluster( central_loc, central_cluster_fqdn, prot, port );
75 public Topic genSimpleTopic( String tname ) {
76 Topic t = new Topic();
77 t.setTopicName( tname );
78 t.setFqtnStyle( FqtnType.Validator("none") );
79 t.setTopicDescription( "a simple Topic named " + tname );
81 t.setFqtn(t.genFqtn());
85 public MR_Client genMR_Client( String l, String f, String r, String[] a ) {
86 if ( l.contains( "edge" ) ) {
87 return new MR_Client( edge_loc, f, r, a );
89 return new MR_Client( central_loc, f, r, a );
92 public MR_Client genPublisher( String layer, String fqtn ) {
93 String[] actions = { "pub", "view" };
94 return genMR_Client( layer, fqtn, pub_role, actions );
96 public MR_Client genSubscriber( String layer, String fqtn ) {
97 String[] actions = { "sub", "view" };
98 return genMR_Client( layer, fqtn, sub_role, actions );
101 public DR_Sub genDrSub( String l, String feed ) {
103 String up = "secretW0rd";
104 String du = "sub.server.onap.org:8443/deliver/here";
105 String lu = "https://drps.onap.org:8443/sublog/123";
108 if ( l.contains( "edge" ) ) {
109 return new DR_Sub( edge_loc, un, up, feed, du, lu, u100 );
111 return new DR_Sub( central_loc, un, up, feed, du, lu, u100 );
114 public DR_Node genDR_Node( String l ) {
115 String version = "1.0.1";
116 RandomInteger ri = new RandomInteger( 1000 );
118 String fqdn = String.format( "drns%d.onap.org", i );
119 String host = String.format( "host%d.onap.org", i );
121 if ( l.contains( "edge" ) ) {
122 return new DR_Node( fqdn, edge_loc, host, version );
124 return new DR_Node( fqdn, central_loc, host, version );