Sending Changes to the users by email

Author: mkalioby

client/autodeploy_client/Client.py

@@ -125,4 +125,15 @@ def getCommitsDiff(self,workdir,commit,owner=''):
         for item in res.split("\n"):
             if item=="" or item=="Done" : continue
             result.append(item)
+        return result
+
+    def getChangeLog(self, workdir, since,to, owner=''):
+        if owner == '':
+            owner = Config.Owner
+        msg = Job.createGetChangeLog(owner, workdir,  self.scm,options={"since":since,"to":to})
+        res = self._send(msg)
+        result = []
+        for item in res.split("\n"):
+            if item == "" or item == "Done": continue
+            result.append(item)
         return result

client/autodeploy_client/ClientJob.py

@@ -150,6 +150,19 @@ def creategetCommitsDiffMessage(owner, workdir, commit, scm,options=None):
     f += '<workdir>%s</workdir>'%workdir
     f += '<commit>%s</commit>'%commit
 
+    if options:
+        f += '<options>'
+        for option in options.keys():
+            f += "<option name='%s'>%s</option>" % (option, options[option])
+
+        f += "</options>"
+    f += '</job>'
+    return f
+
+def createGetChangeLog(owner,workdir,scm,options=None):
+    sec = base64.encodestring(importKey().encrypt(owner + scm + "LIST-CHANGES", "")[0])
+    f = '<job  owner="%s" type="%s" sec="%s" scm="%s">\n' % (owner, "LIST-CHANGES", sec, scm)
+    f += '<workdir>%s</workdir>' % workdir
     if options:
         f += '<options>'
         for option in options.keys():

server/Config.cfg

@@ -1,4 +1,4 @@
 [Server]
 port: 4567
-publicKey: /home/mohamed/autoDeploy/autoDeploy/server/client.pub
+publicKey: /home/mohamed/AutoDeploy/server/client.pub
 

server/Request.py

@@ -173,4 +173,24 @@ def parseSwitchCommitJob(message):
 
 
 def parseGetCommitDiff(message):
-    return parseSwitchCommitJob(message)
+    return parseSwitchCommitJob(message)
+
+def parseGetChangeLog(message):
+    params = {}
+    optionsDict = {}
+    doc = xml.dom.minidom.parseString(message)
+    Job = doc.getElementsByTagName('job')[0]
+    scm = Job.getAttribute("scm")
+    workdir = getValue(Job, 'workdir')
+
+    requestType = Job.getAttribute('type')
+    owner = Job.getAttribute('owner')
+    options = (Job.getElementsByTagName('option'))
+    for option in options:
+        name = option.getAttribute("name")
+        optionsDict[name] = option.firstChild.nodeValue
+
+    print 'Recieved New Job from  ' + owner + '.....'
+    params = {"workdir": workdir, "owner": owner, "requestType": requestType,
+              "scm": scm, "options": optionsDict}
+    return params

server/autodeploy-server.py

@@ -143,6 +143,26 @@ def HandleClient(clientsock):
                 if job["scm"]=="git":
                     gclient=git.GIT(workdir=job["workdir"])
                     cmd=gclient.commit_diff_cmd(commit=job["commit"])
+
+            elif req["requestType"]=="LIST-CHANGES":
+                job = Request.parseGetChangeLog(msg)
+                if job["scm"] == "git":
+                    gclient = git.GIT(workdir=job["workdir"])
+                    cmd = gclient.get_changelog(since=job["options"]["since"], to=job["options"]["to"])
+                    result = []
+                    res = Common.run(cmd)
+                    print res
+                    if "ERR:" in res:
+                        Response.sendData(clientsock, res)
+                    else:
+                        for line in res.split("\n"):
+                            try:
+                                if line != "":
+                                    result.append(line.replace("*", "").strip())
+                            except:
+                                pass
+                        print result
+                        Response.sendData(clientsock, "\n".join(result))
             elif req["requestType"]=="DEPLOY":
                 print msg
                 job = Request.parseDeployJob(msg)

server/scm/Git.py

@@ -42,3 +42,6 @@ def switch_to_histroy_cmd(self,commit):
     def commit_diff_cmd(self,commit):
         Common.run(self.get_pull_cmd())
         return 'git rev-list %s..HEAD'%(commit)
+    def get_changelog(self,since,to):
+        return "cd %s;git shortlog %s..%s"%(self.workdir,since,to)
+

webapp/autoDeploy/autodeploy/api.py

@@ -31,6 +31,7 @@ def deploy(request):
     import Common
     server = Server.objects.get(name=request.session["deploy_server"])
     project = Project.objects.get(name=request.session["deploy_project"])
+    last_Deployment=Deployment_Server.objects.filter(server=server,project=project).latest()
     D= Deployment_Server()
     c = Client(str(project.repo_type), server.ip, server.port)
     D.project = project
@@ -60,14 +61,36 @@ def deploy(request):
             link="http://"+server.DNS+project.deployment_link
             print link
             if project.emailUsers!="" or project.emailUsers!=" ":
-#                for user in project.emailUsers.split(","):
-                 Common.send(project.emailUsers.replace(",",";"),"New version of %s deployed"%project.name,"Dear User,<br/> This is an automated notification that a new version of %s has been deployed at: %s"%(project.name,link),fromUser=None,cc="",bcc="",)
+                changes=c.getChangeLog(project.working_dir,since=last_Deployment.update_version,to=request.GET["commit"])
+                changes_text="<h3>Changes</h3><ul>"
+                found=False
+                for change in changes:
+                    if change.endswith(":"): continue
+                    changes_text+="<li>%s</li>"%change
+                    found=True
+                if found:
+                    changes_text+="</ul>"
+                else:
+                    changes_text=""
+                Common.send(project.emailUsers.replace(",",";"),"New version of %s deployed"%project.name,"Dear User,<br/> This is an automated notification that a new version of %s has been deployed at: %s<br/>%s"%(project.name,link,changes_text),fromUser=None,cc="",bcc="",)
 
             return HttpResponse(res+",,"+link)
         else:
             print "in else"
             link=project.deployment_link
             if project.emailUsers!="" or project.emailUsers!=" ":
-                Common.send(project.emailUsers.replace(",",";"),"New version of %s deployed"%project.name,"Dear User,<br/> This is an automated notification that a new version of %s has been deployed at: %s"%(project.name,link),fromUser=None,cc="",bcc="",)
+                changes=c.getChangeLog(project.working_dir,since=last_Deployment.update_version,to=request.GET["commit"])
+                changes_text="<h3>Changes</h3><ul>"
+                found=False
+                for change in changes:
+                    if change.endswith(":"): continue
+                    changes_text+="<li>%s</li>"%change
+                    found=True
+                if found:
+                    changes_text += "</ul>"
+                else:
+                    changes_text = ""
+
+                Common.send(project.emailUsers.replace(",",";"),"New version of %s deployed"%project.name,"Dear User,<br/> This is an automated notification that a new version of %s has been deployed at: %s.<br>%s"%(project.name,link,changes_text),fromUser=None,cc="",bcc="",)
             return HttpResponse(res+",,"+link)
     else: return  HttpResponse(res)

webapp/autoDeploy/autodeploy/models.py

@@ -55,6 +55,9 @@ class Deployment_Server(models.Model):
     project = models.ForeignKey(Project)
     server = models.ForeignKey(Server)
 
+    class Meta:
+        get_latest_by="id"
+
 class Plugins(models.Model):
     name=models.CharField(max_length=50)
     settings=models.TextField()