Add a add package in project manager

add package funtion : GITPRJ,GITREV

Change-Id: I7da793fd1085cce68e861d8aa64eabbe444e1361

diff --git a/job_obs_project_manager.py b/job_obs_project_manager.py
index d2c661f..032db2f 100644 (file)
--- a/job_obs_project_manager.py
+++ b/job_obs_project_manager.py
@@ -38,6 +38,7 @@ from common.buildtrigger import trigger_info, trigger_next
 from common import runner
 from datetime import datetime
 from common.buildmonitor_extention import BuildMonitorExtention
+from common.upload_service import upload_obs_service, UploadError
 
 # set default char-set endcoding to utf-8
 reload(sys)
@@ -193,6 +194,21 @@ def obs_project_create_prj(build, prj, info=None, meta=None, config=None):
     except:
         raise LocalError("Unable to create project %s: %s" % (prj))
 
+def obs_project_add_pkg(build, prj, pkg, git_url, git_prj, git_rev):
+    """
+    obs project add package
+    """
+
+    if build.exists(prj) and not build.exists(prj, pkg):
+        try:
+            upload_obs_service(git_url, git_prj, "", \
+                  git_rev, prj, build, pkg)
+            return True
+        except:
+            raise LocalError("Unable to add %s pacakge in %s project" % (pkg, prj))
+    else:
+        raise LocalError("Warning: target project %s doesn't exist" % prj)
+
 def main():
 
     """
@@ -244,9 +260,18 @@ def main():
            obs_project_config(build, project, config)
         elif decision == 'create':
            obs_project_create(build, project, config)
+        elif decision == 'add':
+           git_url = 'ssh://%s:%s' % (os.getenv('GERRIT_HOSTNAME_EXTERNAL'),
+                                      os.getenv('GERRIT_SSHPORT'))
+           git_prj = os.getenv("GITPRJ")
+           git_rev = os.getenv("GITREV")
+           print "GITPRJ = ", git_prj
+           print "GITREV = ", git_rev
+           obs_project_add_pkg(build, project, package, \
+                               git_url, git_prj, git_rev)
         else:
-            print "%s decision is not defined" %(decision)
-            failures = "%s decision is not defined" %(decision)
+           print "%s decision is not defined" %(decision)
+           failures = "%s decision is not defined" %(decision)
     except LocalError, exc:
         failures = (str(exc))
     except ObsError, error: