summaryrefslogtreecommitdiffstats
path: root/authz-core/src/main/java/com/att/cssa/rserv/Route.java
blob: 0a8cffe03ba01bc35872a016c52b81d241c4b6cb (plain)
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
/*******************************************************************************
 * ============LICENSE_START====================================================
 * * org.onap.aai
 * * ===========================================================================
 * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
 * * Copyright © 2017 Amdocs
 * * ===========================================================================
 * * 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 is a trademark and service mark of AT&T Intellectual Property.
 * *
 ******************************************************************************/
package com.att.cssa.rserv;

import java.io.IOException;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.att.inno.env.Env;
import com.att.inno.env.TimeTaken;
import com.att.inno.env.Trans;

public class Route<TRANS extends Trans> {
	public final String auditText;
	public final HttpMethods meth;
	public final String path;
	
	private Match match;
	// package on purpose
	private final TypedCode<TRANS> content;
	private final boolean isGet;
	
	public Route(HttpMethods meth, String path) {
		this.path = path;
		auditText = meth.name() + ' ' + path;
		this.meth = meth; // Note: Using Spark def for now.
		isGet = meth.compareTo(HttpMethods.GET) == 0;
		match = new Match(path);
		content = new TypedCode<TRANS>();
	}
	
	public void add(HttpCode<TRANS,?> code, String ... others) {
		code.match = match;
		content.add(code, others);
	}
	
//	public void add(HttpCode<TRANS,?> code, Class<?> cls, String version, String ... others) {
//		code.match = match;
//		content.add(code, cls, version, others);
//	}
//
	public HttpCode<TRANS,?> getCode(TRANS trans, HttpServletRequest req, HttpServletResponse resp) throws IOException, ServletException {
		// Type is associated with Accept for GET (since it is what is being returned
		// We associate the rest with ContentType.
		// FYI, thought about this a long time before implementing this way.
		String compare;
//		String special[]; // todo, expose Charset (in special) to outside
		if(isGet) {
			compare = req.getHeader("Accept"); // Accept is used for read, as we want to agree on what caller is ready to handle
		} else {
			compare = req.getContentType(); // Content type used to declare what data is being created, updated or deleted (might be used for key)
		}

		Pair<String, Pair<HttpCode<TRANS, ?>, List<Pair<String, Object>>>> hl = content.prep(trans, compare);
		if(hl==null) {
			resp.setStatus(406); // NOT_ACCEPTABLE
		} else {
			if(isGet) { // Set Content Type to expected content
				if("*".equals(hl.x) || "*/*".equals(hl.x)) {// if wild-card, then choose first kind of type
					resp.setContentType(content.first());
				} else {
					resp.setContentType(hl.x);
				}
			}
			return hl.y.x;
		}
		return null;
	}
	
	public Route<TRANS> matches(String method, String path) {
		return meth.name().equalsIgnoreCase(method) && match.match(path)?this:null;
	}
	
	public TimeTaken start(Trans trans, String auditText, HttpCode<TRANS,?> code, String type) {
		StringBuilder sb = new StringBuilder(auditText);
		sb.append(", ");
		sb.append(code.desc());
		sb.append(", Content: ");
		sb.append(type);
		return trans.start(sb.toString(), Env.SUB);
	}

	// Package on purpose.. for "find/Create" routes only
	boolean resolvesTo(HttpMethods hm, String p) {
		return(path.equals(p) && hm.equals(meth));
	}
	
	public String toString() {
		return auditText + ' ' + content; 
	}

	public String report(HttpCode<TRANS, ?> code) {
		StringBuilder sb = new StringBuilder();
		sb.append(auditText);
		sb.append(' ');
		content.relatedTo(code, sb);
		return sb.toString();
	}

	public RouteReport api() {
		RouteReport tr = new RouteReport();
		tr.meth = meth;
		tr.path = path;
		content.api(tr);
		return tr;
	}


	/**
	 * contentRelatedTo (For reporting) list routes that will end up at a specific Code
	 * @return
	 */
	public String contentRelatedTo(HttpCode<TRANS, ?> code) {
		StringBuilder sb = new StringBuilder(path);
		sb.append(' ');
		content.relatedTo(code, sb);
		return sb.toString();
	}
}