Changeset 1046 for opsi/server/opsi-tools-dass-it/usr/bin

Timestamp:

Aug 6, 2012, 5:13:08 PM (12 years ago)

Author:

joergs

Message:

initiale Tests auf json-rpc basis

File:

• opsi/server/opsi-tools-dass-it/usr/bin/opsi-client-copy.py (modified) (1 diff)

opsi/server/opsi-tools-dass-it/usr/bin/opsi-client-copy.py

@@ -1 +1 @@
 #!/usr/bin/env python
 
-# get client properties for bacula
+# Skript erstellen, dass ein OPSI-Rechner-Eintrag kopiert.
+# D.h. die Produkte, Anforderung.
+# Ggf. optional Stand und ggf. Versionsnummer
+# Ggf. optional ProductProperties
 
-import subprocess
-import json
+                #self.command("opsi-admin -d method host_createOpsiClient "+ \
+                        #computername + " null " + "\\'"+description+"\\'" + \
+                        #" \\'created by dassadmin\\' " + mac_address + " " + \
+                        #ip_address)
+                #method host_createOpsiClient id *opsiHostKey *description *notes *hardwareAddress *ipAddress *inventoryNumber *oneTimePassword *created *lastSeen
+                #self.command("opsi-admin -d method configState_create clientconfig.depot.id " + \
+                        #computername + " " + depotName)                        
+
+import jsonrpc
 from pprint import pprint
 
-opsi={
-    'server': "https://degdepot2.joergs:4447/rpc",
-    'username': "joergs",
-    'password': "linuxlinux",
-    }
+UrlJsonRpc="https://joergs:linuxlinux@opsi4.joergs.dass-it:4447/rpc"
 
-# "-d"
-opsiCallPrefix=[ "opsi-admin",  "-a", opsi['server'], "-u", opsi['username'], "-p", opsi['password'] ]
-
-opsiCallClientsWithBacula=[ "method", "productOnClient_getObjects", "[]", '{"productId":"bacula", "installationStatus": "installed"}']
-
-opsiCallClientBaculaProperties=[ "method", "getProductProperties_hash", "bacula" ]
+class OpsiRpc:
+    def __init__(self, urlJsonRpc=UrlJsonRpc):
+        self.urlJsonRpc=urlJsonRpc
+        self.rpcProxy=jsonrpc.ServiceProxy(self.urlJsonRpc)
+        
+    def dump(self):
+        print self.urlJsonRpc
+        print self.rpcProxy.getClientIds_list()
+        
+    def copyClient( self, src, dst, hardwareAddress, ipAddress ):
+    
+        #method host_createOpsiClient id *opsiHostKey *description *notes *hardwareAddress *ipAddress *inventoryNumber *oneTimePassword *created *lastSeen
+        id=dst
+        opsiHostKey=None
+        description=""
+        notes="copy of " + src
+        self.rpcProxy.host_createOpsiClient( id, opsiHostKey, description, notes, hardwareAddress, ipAddress )
+        
+    def productOnClient( self, client ):
+        pprint( self.rpcProxy.productOnClient_getObjects( [], { 'clientId': client } ) )
 
 
-def write_client_conf( client, properties ):
-    #Client {
-    #Name = ting-fd
-    #Address = ting.dass-it
-    #FDPort = 9102
-    #Catalog = MyCatalog
-    #Password = "D5w2V5w6B8a9H5Z"
-    #File Retention = 6 months
-    #Job Retention = 6 months
-    #AutoPrune = yes
-    #}
-    params = [ "FDPort", "Catalog", "FileRetention", "JobRetention", "AutoPrune" ]
-    print "Client {"
-    print "  Name     =", properties['filedaemon_full_name']
-    print "  Address  =", client['clientId']
-    # ipAddress: method host_getObjects [] '{"id":client['clientId']}'
-    #print "  # Address =", ipAddress
-    print "  Password =", properties['filedaemon_full_password']
-    for i in params:
-        try:
-            print " " + i + " = " + properties[i.lower()]
-        except KeyError:
-            print "  # " + i + " = "
-    print "}"
-    print
+
+if __name__ == '__main__':
+    opsi=OpsiRpc()
+    #opsi.dump()
+    opsi.copyClient( "test1.joergs.dass-it.opsi", "testnew1.joergs.dass-it.opsi", "00:00:00:00:01:01", "192.168.0.1" )
+    opsi.productOnClient( "opsiwin1.joergs.dass-it.opsi" )
+    opsi.dump()
+    print "end"
     
-    
-
-
-def write_job_conf( client, properties ):
-    #Job {
-    #FileSet = "tingfileset"
-    #Name = "ting"
-    #Client = ting-fd
-    #JobDefs = "LaptopJob"
-    ## Write Bootstrap = "/var/lib/bacula/ting.bsr"
-    #}
-    params = [ "Fileset", "JobDefs" ]
-    print "Job {"
-    print "  Name    =", client['clientId'] + "-job"
-    print "  Client  =", properties['filedaemon_full_name']
-    for i in params:
-        print " ",
-        try:
-            if not properties[i.lower()]:
-                print "#",
-            print i + " = " + properties[i.lower()]
-        except KeyError:
-            print "# " + i + " = "
-    print "}"
-    print
-
-    
-
-#
-# main
-#
-
-try:
-    clientsWithBacula=json.loads( subprocess.check_output( opsiCallPrefix + opsiCallClientsWithBacula ) )
-except subprocess.CalledProcessError:
-    print "failed"
-    exit( 1 )
-
-pprint( clientsWithBacula )
-        
-for client in clientsWithBacula:
-    clientId = client['clientId']
-    print clientId
-    
-    try:
-        clientBaculaProperties=json.loads( subprocess.check_output( opsiCallPrefix + opsiCallClientBaculaProperties + [ client['clientId'] ] ) )
-    except subprocess.CalledProcessError:
-        print "failed"
-        exit( 1 )
-        
-    pprint( clientBaculaProperties )
-    write_client_conf( client, clientBaculaProperties )
-    write_job_conf( client, clientBaculaProperties )