Changeset 1087 for opsi

Timestamp:

Aug 29, 2012, 6:01:10 PM (12 years ago)

Author:

slederer

Message:

letzte Änderung rückgängig

File:

• opsi/server/dass-opsi-tools/usr/bin/opsiclient (modified) (1 diff)

opsi/server/dass-opsi-tools/usr/bin/opsiclient

@@ -26 +26 @@
                         
 import argparse
+import jsonrpc
 from pprint import pprint
-from opsirpc import OpsiRpc
 
 UrlJsonRpc="https://<username>:<password>@opsi:4447/rpc"
 
 HelpEpilog="WARNING: python-json-rpc is known to have problems with HTTP proxies. In case of problems, make sure, the environment variables http_proxy and/or https_proxy are *not* set."
+
+class OpsiRpc:
+
+    UrlJsonRpcDefault="https://opsi:4447/rpc"
+    
+    ProductAttributesCopy = ['actionRequest','actionResult','installationStatus','packageVersion','productVersion']
+    
+    def __init__(self, urlJsonRpc = UrlJsonRpcDefault, debug=False ):
+        self.debug=debug
+        self.urlJsonRpc=urlJsonRpc
+        self.rpc=jsonrpc.ServiceProxy(self.urlJsonRpc)
+        
+    def dump(self):
+        print self.urlJsonRpc
+        print self.rpc.getClientIds_list()
+
+    def list(self):
+        return self.rpc.getClientIds_list()
+        
+    def exists(self, src):
+        return len( self.rpc.host_getObjects( [], {"id":src} ) ) == 1
+        
+    def info(self, src):
+        if not self.exists( src ):
+            print "failed: opsi client", src, "does not exist"
+            return False
+        print src + ":"
+        host = self.rpc.host_getHashes( [], {"id":src} )[0]
+        print "  IP:", host["ipAddress"]
+        print "  MAC:", host["hardwareAddress"]
+        print "  inventory:", host["inventoryNumber"]
+        print "  last seen:", host["lastSeen"]
+        print "  notes:", host["notes"]
+        
+        print "  products:"
+        products = self.getProductOnClient( src, [] )
+        for i in products:
+            print "    " + i['productId'] + ":"
+            print "      " + i['installationStatus'], "(",
+            if i['actionRequest']:
+                print i['actionRequest'],
+                if i['actionProgress']:
+                    print i['actionProgress'],
+            print ")"
+            print "      ",
+            pprint( i, indent=8 )
+        return True
+
+    def clean(self, src):
+        if not self.exists( src ):
+            return False
+        products = self.rpc.productOnClient_getObjects( [], { 'clientId': src } )
+        self.rpc.productOnClient_deleteObjects( products )
+        if self.debug:
+            pprint( self.getProductOnClient( src ) )
+        return True
+        
+    def createClient(self, name, opsiHostKey, description, notes, hardwareAddress, ipAddress):
+        self.rpc.host_createOpsiClient( name, opsiHostKey, description, notes, hardwareAddress, ipAddress )
+
+    def clientSetDepot(self, name, depot):
+        self.rpc.configState_create( "clientconfig.depot.id", name, depot )        
+
+    def copyClient( self, src, dst, ipAddress = None, hardwareAddress = None, depot = None, description = "" ):
+    
+        print "create/update", dst, "from template", src + ":",
+        obj = {
+          "id" : dst,
+          "type" : "OpsiClient",
+          "notes" : "copy of " + src,
+          "description" : description,
+          #"inventoryNumber" : "",
+        }
+        if hardwareAddress:
+            obj['hardwareAddress'] = hardwareAddress
+        if ipAddress:
+            obj['ipAddress'] = ipAddress
+
+        if self.exists( dst ):
+            self.rpc.host_updateObject(obj)
+        else:
+            self.rpc.host_insertObject(obj)
+            
+        if depot:
+            self.clientSetDepot(dst,depot)
+            
+        if self.debug:
+            pprint( self.getProductOnClient( src ) )
+        self.copyProductOnClient( src, dst )
+        # TODO: 
+        #  copy product properties:
+        #  opsiCallClientBaculaProperties=[ "method", "getProductProperties_hash", "bacula" ]
+        print "done"
+        return True
+
+        
+    def getProductOnClient( self, client, attributes = ProductAttributesCopy ):
+        #pprint( self.rpc.productOnClient_getObjects( [], { 'clientId': client } ) )
+        #pprint( self.rpc.productOnClient_getHashes( attributes, { 'clientId': client } ) )
+        return self.rpc.productOnClient_getHashes( [], { 'clientId': client } )
+        
+    def copyProductOnClient( self, src, dst, attributes = ProductAttributesCopy ):
+        products = self.rpc.productOnClient_getHashes( attributes, { 'clientId': src } )
+        for i in products:
+            if self.debug: 
+                print i['productId']
+                pprint( i )
+            i['clientId'] = dst
+            self.rpc.productOnClient_createObjects( i )
+        if self.debug:
+            pprint( self.getProductOnClient( dst ) )
+        
+
 
 if __name__ == '__main__':