Changeset 1087 for opsi


Ignore:
Timestamp:
08/29/12 18:01:10 (8 years ago)
Author:
slederer
Message:

letzte Änderung rückgängig

File:
1 edited

Legend:

Unmodified
Added
Removed
  • opsi/server/dass-opsi-tools/usr/bin/opsiclient

    r1085 r1087  
    2626                       
    2727import argparse
     28import jsonrpc
    2829from pprint import pprint
    29 from opsirpc import OpsiRpc
    3030
    3131UrlJsonRpc="https://<username>:<password>@opsi:4447/rpc"
    3232
    3333HelpEpilog="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."
     34
     35class OpsiRpc:
     36
     37    UrlJsonRpcDefault="https://opsi:4447/rpc"
     38   
     39    ProductAttributesCopy = ['actionRequest','actionResult','installationStatus','packageVersion','productVersion']
     40   
     41    def __init__(self, urlJsonRpc = UrlJsonRpcDefault, debug=False ):
     42        self.debug=debug
     43        self.urlJsonRpc=urlJsonRpc
     44        self.rpc=jsonrpc.ServiceProxy(self.urlJsonRpc)
     45       
     46    def dump(self):
     47        print self.urlJsonRpc
     48        print self.rpc.getClientIds_list()
     49
     50    def list(self):
     51        return self.rpc.getClientIds_list()
     52       
     53    def exists(self, src):
     54        return len( self.rpc.host_getObjects( [], {"id":src} ) ) == 1
     55       
     56    def info(self, src):
     57        if not self.exists( src ):
     58            print "failed: opsi client", src, "does not exist"
     59            return False
     60        print src + ":"
     61        host = self.rpc.host_getHashes( [], {"id":src} )[0]
     62        print "  IP:", host["ipAddress"]
     63        print "  MAC:", host["hardwareAddress"]
     64        print "  inventory:", host["inventoryNumber"]
     65        print "  last seen:", host["lastSeen"]
     66        print "  notes:", host["notes"]
     67       
     68        print "  products:"
     69        products = self.getProductOnClient( src, [] )
     70        for i in products:
     71            print "    " + i['productId'] + ":"
     72            print "      " + i['installationStatus'], "(",
     73            if i['actionRequest']:
     74                print i['actionRequest'],
     75                if i['actionProgress']:
     76                    print i['actionProgress'],
     77            print ")"
     78            print "      ",
     79            pprint( i, indent=8 )
     80        return True
     81
     82    def clean(self, src):
     83        if not self.exists( src ):
     84            return False
     85        products = self.rpc.productOnClient_getObjects( [], { 'clientId': src } )
     86        self.rpc.productOnClient_deleteObjects( products )
     87        if self.debug:
     88            pprint( self.getProductOnClient( src ) )
     89        return True
     90       
     91    def createClient(self, name, opsiHostKey, description, notes, hardwareAddress, ipAddress):
     92        self.rpc.host_createOpsiClient( name, opsiHostKey, description, notes, hardwareAddress, ipAddress )
     93
     94    def clientSetDepot(self, name, depot):
     95        self.rpc.configState_create( "clientconfig.depot.id", name, depot )       
     96
     97    def copyClient( self, src, dst, ipAddress = None, hardwareAddress = None, depot = None, description = "" ):
     98   
     99        print "create/update", dst, "from template", src + ":",
     100        obj = {
     101          "id" : dst,
     102          "type" : "OpsiClient",
     103          "notes" : "copy of " + src,
     104          "description" : description,
     105          #"inventoryNumber" : "",
     106        }
     107        if hardwareAddress:
     108            obj['hardwareAddress'] = hardwareAddress
     109        if ipAddress:
     110            obj['ipAddress'] = ipAddress
     111
     112        if self.exists( dst ):
     113            self.rpc.host_updateObject(obj)
     114        else:
     115            self.rpc.host_insertObject(obj)
     116           
     117        if depot:
     118            self.clientSetDepot(dst,depot)
     119           
     120        if self.debug:
     121            pprint( self.getProductOnClient( src ) )
     122        self.copyProductOnClient( src, dst )
     123        # TODO:
     124        #  copy product properties:
     125        #  opsiCallClientBaculaProperties=[ "method", "getProductProperties_hash", "bacula" ]
     126        print "done"
     127        return True
     128
     129       
     130    def getProductOnClient( self, client, attributes = ProductAttributesCopy ):
     131        #pprint( self.rpc.productOnClient_getObjects( [], { 'clientId': client } ) )
     132        #pprint( self.rpc.productOnClient_getHashes( attributes, { 'clientId': client } ) )
     133        return self.rpc.productOnClient_getHashes( [], { 'clientId': client } )
     134       
     135    def copyProductOnClient( self, src, dst, attributes = ProductAttributesCopy ):
     136        products = self.rpc.productOnClient_getHashes( attributes, { 'clientId': src } )
     137        for i in products:
     138            if self.debug:
     139                print i['productId']
     140                pprint( i )
     141            i['clientId'] = dst
     142            self.rpc.productOnClient_createObjects( i )
     143        if self.debug:
     144            pprint( self.getProductOnClient( dst ) )
     145       
     146
    34147
    35148if __name__ == '__main__':
Note: See TracChangeset for help on using the changeset viewer.