ALM/Jira
07. Workflow PostFunc
삽질의 달인
2020. 1. 15. 14:39
이번에는 생성한 이슈타입에 할당한 Customized 된 Workflow 에
후처리 함수를 등록하는 방법에 대해 알아보자.
Interface
먼저 아래와 같이 Jira settings -> Issues -> Workflows 메뉴로 들어간다.
 |
 |
 |
그러면 아래와 같이 생성한 이슈와 연결된 Workflow 가 나타나는데 Edit 버튼을 눌러 해당 Workflow 로 들어간다.
그리고 후처리 함수가 실행될 Workflow 의 Transition 을 선택한다.
그리고 Add post function 버튼을 눌러 스크립트를 추가한 화면이다.
Script
스크립트 러너에 작성되는 스크립트는 보통 외부 시스템과 통신하기 위해 사용되는데
이중 먼저 Condition 항목으로 특정 조건에서만 해당 post function 이 동작하도록 할 수 있다.
그리고 Code 부분에 Condition 이 통과 되었을 때 실행할 코드를 넣으면 된다.
Sample
아래는 CloudBees Flow 와 연동하기 위해 사용한 코드들이다.
Run Condition
|
((Map) issue.fields.issuetype)?.name == 'EFDevelopment'
|
Run Script
|
import javax.net.ssl.*
import java.security.cert.X509Certificate
import java.security.cert.CertificateException
def sslIgnore() {
def trustAllCerts = [
new X509TrustManager() {
public X509Certificate[] getAcceptedIssuers() {
return null
}
public void checkServerTrusted(X509Certificate[] certs, String authType) throws CertificateException {
}
public void checkClientTrusted(X509Certificate[] certs, String authType) throws CertificateException {
}
}
] as TrustManager[]
def nullHostnameVerifier = [
verify: { hostname, session -> true }
] as HostnameVerifier
SSLContext sc = SSLContext.getInstance("SSL")
sc.init(null, trustAllCerts, new java.security.SecureRandom())
HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory())
HttpsURLConnection.setDefaultHostnameVerifier(nullHostnameVerifier)
Authenticator.setDefault (new Authenticator() {
protected PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication ("admin", "changeme".toCharArray());
}
});
}
HttpURLConnection sendGetRequest(String request)
{
URL url = new URL(request);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
connection.setUseCaches(false);
connection.setConnectTimeout(5000);
connection.setDoInput(true);
connection.setDoOutput(true);
connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
connection.connect();
return connection;
}
HttpURLConnection sendPostRequest(String request, String params)
{
byte[] postData = params.getBytes("UTF-8");
int postDataLength = postData.length;
URL url = new URL(request);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("POST");
connection.setConnectTimeout(5000);
connection.setUseCaches(false);
connection.setDoInput(true);
connection.setDoOutput(true);
connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
connection.setRequestProperty( "Content-Length", Integer.toString( postDataLength ));
DataOutputStream wr = new DataOutputStream(connection.getOutputStream());
wr.write( postData );
connection.connect();
return connection;
}
def getProcedure (String serverName) {
HttpURLConnection connection = sendGetRequest("https://${serverName}/rest/v1.0/projects");
if (connection.responseCode == 200 || connection.responseCode == 201) {
BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream()));
StringBuilder sb = new StringBuilder();
String line;
while ((line = br.readLine()) != null) {
sb.append(line+"\n");
}
br.close();
connection.disconnect();
return sb.toString();
} else {
connection.disconnect();
return "Failed"
}
}
def runProcedure (String serverName, String projectName, String procedureName, String acutalParams=null) {
if(acutalParams == null ||acutalParams == "") {
def params= "{\"projectName\": \"$projectName\", \"procedureName\": \"$procedureName\"}"
HttpURLConnection connection = sendPostRequest("https://${serverName}/rest/v1.0/jobs?request=runProcedure",params);
if (connection.responseCode == 200 || connection.responseCode == 201) {
return "Success"
} else {
return "Fail"
}
} else {
def params= "{ \"projectName\": \"$projectName\", \"procedureName\": \"$procedureName\", \"body\": { \"parameters\": { \"actualParameter\": [$acutalParams] } } }"
HttpURLConnection connection = sendPostRequest("https://${serverName}/rest/v1.0/jobs?request=runProcedure",params);
if (connection.responseCode == 200 || connection.responseCode == 201) {
return "Success"
} else {
return "Fail"
}
}
}
def issueKey = issue.key
def comment = 'EF Build started - https://35.190.226.246/commander/link/projectDetails/projects/CO_DEMO/?filterName0=projectsPageSearch&filterDepth=1&tabGroup=workflowsHeader&s=Projects'
def efProject = 'customfield_10033'
def efProcedure = 'customfield_10034'
def efServer = 'customfield_10036'
def efActual = 'customfield_10037'
def efProjectValue = ''
def efProcedureValue = ''
def efServerValue = ''
def efActualValue = ''
def result = post("/rest/api/2/issue/${issueKey}/comment")
.header('Content-Type', 'application/json')
.body([
body: comment
])
.asString()
result = get("/rest/api/2/issue/${issueKey}?fields=${efServer}")
.header('Content-Type', 'application/json')
.asObject(Map)
if (result.status == 200) {
efServerValue = result.body.fields[efServer]
} else {
return "Error retrieving issue ${result}"
}
result = get("/rest/api/2/issue/${issueKey}?fields=${efProject}")
.header('Content-Type', 'application/json')
.asObject(Map)
if (result.status == 200) {
efProjectValue = result.body.fields[efProject]
} else {
return "Error retrieving issue ${result}"
}
result = get("/rest/api/2/issue/${issueKey}?fields=${efProcedure}")
.header('Content-Type', 'application/json')
.asObject(Map)
if (result.status == 200) {
efProcedureValue = result.body.fields[efProcedure]
} else {
return "Error retrieving issue ${result}"
}
result = get("/rest/api/2/issue/${issueKey}?fields=${efActual}")
.header('Content-Type', 'application/json')
.asObject(Map)
if (result.status == 200) {
efActualValue = result.body.fields[efActual]
} else {
return "Error retrieving issue ${result}"
}
sslIgnore();
runProcedure("${efServerValue}","${efProjectValue}","${efProcedureValue}");
|