| #!/usr/bin/python |
| # |
| # |
| # 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. |
| # |
| # |
| |
| from xml.dom.minidom import Document |
| import httplib,sys,os,subprocess |
| import ConfigParser |
| |
| ##################################### |
| ##### Subversion configurations ##### |
| REPOS = sys.argv[1] |
| REV = sys.argv[2] |
| |
| # if the repository and the version number of the repository not empty. |
| if REPOS and REV: |
| # The path of revision.properties |
| CONFIG_PATH = "/home/ofbiz/ofbiz/hot-deploy/scrum/config/revision.properties" |
| openfile = open(CONFIG_PATH) |
| openfile.readline() |
| revision = ConfigParser.ConfigParser() |
| revision.readfp(openfile) |
| REVISION_URL = revision.get("config", "revision.url") |
| HOSTNAME = revision.get("config", "host.name") |
| HOSTPORT = revision.get("config", "host.port") |
| OFBIZ_WEBSERVICE_URL = revision.get("config", "ofbiz.webservice.url") |
| SVN_USER = revision.get("config", "svn.user") |
| SVN_PASSWORD = revision.get("config", "svn.password") |
| |
| print "HOSTNAME == >>>" + HOSTNAME |
| print "HOSTPORT == >>>" + HOSTPORT |
| print "OFBIZ_WEBSERVICE_URL == >>>" + OFBIZ_WEBSERVICE_URL |
| print "SVN_USER == >>>" + SVN_USER |
| print "SVN_PASSWORD == >>>" + SVN_PASSWORD |
| |
| try: |
| REPOS_INPUT = REPOS[ 0 : REPOS.rfind("svn/")] |
| if len(REPOS_INPUT) > 15: |
| REPOSITORY_ROOT = REPOS[ REPOS.rfind("svn/") + 4 : len(REPOS)] |
| REPOS = REPOS |
| else: |
| REPOSITORY_ROOT = REPOS[ REPOS.rfind("svn/repositories/") + 17 : len(REPOS)] |
| REPOS = REVISION_URL + REPOSITORY_ROOT |
| |
| SVN_INFO_URL = REPOSITORY_ROOT + "&revision=" + REV |
| |
| print "REPOS == >>>" + REPOS |
| print "SVN_INFO_URL == >>>" + SVN_INFO_URL |
| ##### Web service configurations ##### |
| ##################################### |
| ###### Find Task and User ###### |
| if SVN_USER and SVN_PASSWORD: |
| l = subprocess.Popen('svn log -r %s %s --username %s --password %s \n\n' % (REV, REPOS, SVN_USER, SVN_PASSWORD), shell=True, stdout=subprocess.PIPE, stdin=subprocess.PIPE, stderr=subprocess.STDOUT) |
| l.stdin.write('no\n') |
| l.stdin.write('t\n') |
| else: |
| l = subprocess.Popen('svn log -r %s %s \n\n' % (REV, REPOS), shell=True, stdout=subprocess.PIPE, stdin=subprocess.PIPE, stderr=subprocess.STDOUT) |
| l.stdin.write('clear\n') |
| log = l.communicate()[0] |
| logListInput = log.split('\n'); |
| if len(logListInput) > 7: |
| log = logListInput[17] |
| else: |
| logList = log.split('|'); |
| log = logList[3] |
| ### check taskId ### |
| count = 0 |
| taskId = '' |
| for index in range(len(log)): |
| letter = log[index] |
| if letter.isdigit(): |
| count = count + 1 |
| else: |
| count = 0 |
| if count == 5: |
| taskId = log[(index - 4) : index + 1] |
| break |
| ### check hours ### |
| hours =''; |
| checkCond = False; |
| hourData = log.lower(); |
| hourMes = hourData[ hourData.rfind("hrs:") + 4 : hourData.rfind("hrs:") + 8] |
| countHrs = len(hourMes); |
| firstchar = hourMes[0]; |
| for hrsIndex in xrange(countHrs,0,-1): |
| if firstchar.isdigit(): |
| hrsLetter = hourMes[hrsIndex-1]; |
| if hrsLetter.isdigit(): |
| checkCond = True; |
| else: |
| checkCond = False; |
| if checkCond: |
| hours = hourMes[0 : (hrsIndex)] |
| break |
| else: |
| break |
| ### check Description ### |
| if len(logListInput) > 7: |
| userlog = logListInput[15] |
| userlogList = userlog.split('|'); |
| user = userlogList[1] |
| logMes = logListInput[17] |
| if len(logMes) > 255: |
| logMes = logMes[0:255] |
| revisionDescription = logMes |
| else: |
| user = logList[1].strip() |
| removeIndex = log.find('----------') |
| if removeIndex != -1: |
| log = log[0 : removeIndex - 1] |
| if len(log) > 255: |
| log = log[0:255] |
| revisionDescription = log[9 : len(log) - 1] |
| |
| print "user == >>>" + user |
| print "taskId == >>>" + taskId |
| print "hours == >>>" + hours |
| print "revisionDescription == >>>" + revisionDescription |
| ###### Create the minidom document ###### |
| doc = Document() |
| soapenv = doc.createElement("soapenv:Envelope") |
| doc.appendChild(soapenv) |
| soapenv.setAttribute("xmlns:soapenv", "http://schemas.xmlsoap.org/soap/envelope/") |
| soapenv.setAttribute("xmlns:ser", OFBIZ_WEBSERVICE_URL) |
| |
| header = doc.createElement("soapenv:Header") |
| soapenv.appendChild(header) |
| |
| body = doc.createElement("soapenv:Body") |
| soapenv.appendChild(body) |
| |
| updateScrumRevision = doc.createElement("ser:updateScrumRevision") |
| body.appendChild(updateScrumRevision) |
| |
| mapMap = doc.createElement("map-Map") |
| updateScrumRevision.appendChild(mapMap) |
| |
| mapEntry = doc.createElement("ser:map-Entry") |
| mapKey = doc.createElement("ser:map-Key") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", "revisionNumber") |
| mapKey.appendChild(stdString) |
| mapEntry.appendChild(mapKey) |
| mapValue = doc.createElement("ser:map-Value") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", REV) |
| mapValue.appendChild(stdString) |
| mapEntry.appendChild(mapValue) |
| mapMap.appendChild(mapEntry) |
| |
| mapEntry = doc.createElement("ser:map-Entry") |
| mapKey = doc.createElement("ser:map-Key") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", "revisionLink") |
| mapKey.appendChild(stdString) |
| mapEntry.appendChild(mapKey) |
| mapValue = doc.createElement("ser:map-Value") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", SVN_INFO_URL) |
| mapValue.appendChild(stdString) |
| mapEntry.appendChild(mapValue) |
| mapMap.appendChild(mapEntry) |
| |
| mapEntry = doc.createElement("ser:map-Entry") |
| mapKey = doc.createElement("ser:map-Key") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", "revisionDescription") |
| mapKey.appendChild(stdString) |
| mapEntry.appendChild(mapKey) |
| mapValue = doc.createElement("ser:map-Value") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", revisionDescription) |
| mapValue.appendChild(stdString) |
| mapEntry.appendChild(mapValue) |
| mapMap.appendChild(mapEntry) |
| |
| mapEntry = doc.createElement("ser:map-Entry") |
| mapKey = doc.createElement("ser:map-Key") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", "taskId") |
| mapKey.appendChild(stdString) |
| mapEntry.appendChild(mapKey) |
| mapValue = doc.createElement("ser:map-Value") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", taskId) |
| mapValue.appendChild(stdString) |
| mapEntry.appendChild(mapValue) |
| mapMap.appendChild(mapEntry) |
| |
| mapEntry = doc.createElement("ser:map-Entry") |
| mapKey = doc.createElement("ser:map-Key") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", "hours") |
| mapKey.appendChild(stdString) |
| mapEntry.appendChild(mapKey) |
| mapValue = doc.createElement("ser:map-Value") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", hours) |
| mapValue.appendChild(stdString) |
| mapEntry.appendChild(mapValue) |
| mapMap.appendChild(mapEntry) |
| |
| mapEntry = doc.createElement("ser:map-Entry") |
| mapKey = doc.createElement("ser:map-Key") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", "user") |
| mapKey.appendChild(stdString) |
| mapEntry.appendChild(mapKey) |
| mapValue = doc.createElement("ser:map-Value") |
| stdString = doc.createElement("ser:std-String") |
| stdString.setAttribute("value", user) |
| mapValue.appendChild(stdString) |
| mapEntry.appendChild(mapValue) |
| mapMap.appendChild(mapEntry) |
| |
| soapMessage = doc.toprettyxml(indent=" "); |
| |
| ####### Call Webservice ####### |
| # Send request |
| webservice = httplib.HTTPConnection(HOSTNAME, HOSTPORT, timeout=10) |
| webservice.putrequest("POST", OFBIZ_WEBSERVICE_URL) |
| webservice.putheader("Host", HOSTNAME) |
| webservice.putheader("User-Agent", "Python post") |
| webservice.putheader("Content-type", "text/xml; charset=\"UTF-8\"") |
| webservice.putheader("Content-length", "%d" % len(soapMessage)) |
| webservice.putheader("SOAPAction", "\"\"") |
| webservice.endheaders() |
| webservice.send(soapMessage) |
| |
| # Get response |
| response = webservice.getresponse() |
| #print "reason: ", response.reason |
| webservice.close() |
| except Exception: |
| print >>sys.stderr, "File: {0}".format(sys.argv[0]) |
| error_info = sys.exc_info()[1] |
| sys.stderr.write("Exception :%s" % error_info) |
| sys.exit(1) |
| else: |
| print >>sys.stderr, "File: {0}".format(sys.argv[0]) |
| sys.stderr.write("<<<: Error: The repository and the version number of subversion can not be null :>>\n") |
| sys.exit(1) |
| |
| sys.exit(0) |
