+++ /dev/null
- #!/usr/bin/python
-
-#commented out relevant decessions , will be removed later
-
-
-from samba import credentials
-from samba.dcerpc import (
- srvsvc,
- security,
- lsa,
- )
-
-from sambagtk.sam import (
- User, Group,
- )
-
-from sambagtk.dialogs import (
- AboutDialog,
- )
-
-import os.path
-
-#from coherence.extern.log.log import level
-
-class srvsvcPipeManager(object) :
-
- def __init__(self, server_address, transport_type, username, password):
- """ Initialize the pipe handling the srvsvc calls """
- creds = credentials.Credentials()
- if (username.count("\\") > 0):
- creds.set_domain(username.split("\\")[0])
- creds.set_username(username.split("\\")[1])
- elif (username.count("@") > 0):
- creds.set_domain(username.split("@")[1])
- creds.set_username(username.split("@")[0])
- else:
- creds.set_domain("")
- creds.set_username(username)
- creds.set_workstation("")
- creds.set_password(password)
-
- #binding = "ncacn_np:%s" # srvsvc allows only named pipes tcp/upd not allowed
- # How ever it worked in python console on localhost. Needs testing
-
- binding = ["ncacn_np:%s", "ncacn_ip_tcp:%s", "ncalrpc:%s"][transport_type]
- self.pipe = srvsvc.srvsvc(binding % (server_address), credentials = creds)
-
- # set up some basic parameters unique to the connection
-
- self.server_unc = '\\'+server_address
- self.server_info_basic = self.pipe.NetSrvGetInfo(self.server_unc,102) # basic user info object of type 102
-
- self.tod = self.pipe.NetRemoteTOD(self.server_unc)
- self.conn_info=self.pipe.Net()
- # both the above types are standard types as define in the SRVS specification
- ### Now init various default values
-
- self.resume_handle_conn = 0x00000000
- self.resume_handle_share = 0x00000000
- self.resume_handle = 0x00000000 #for general purposes where servers ignore this but it exists in the calls
- self.max_buffer = -1
-
- # Initialise various cache lists :
- # The idea is to use locally available share list and related conveiniece lists
- # This should reduce the queries and improve performance
- # The share list will be locally maintained any via the get_share_local_cache
-
- self.islocal=0 # set to one if connect is to localhost
- self.conn_list = []
- self.share_list = []
- self.share_names_list = []
- self.share_types_list = []
- self.disks_list = self.get_list_disks()
-
-
-
-
-
- def close(self):
- pass
- # apparently there's no .Close() method for this pipe
-
-#conn enum is not supported yet DO Not Use
-# def get_connections(self,level= 1,max_buffer=self.max_buffer,path= self.server_info_basic.path):
-# self.conn_list = []
-# info_ctr = srvsvc.NetConnInfoCtr()
-# info_ctr.level = level #
-# (no_ent,info_ctr,resume_handle) = self.pipe.NetConnEnum(server_unc,path,info_ctr,max_buffer,self.resume_handle_conn)
-# for i in info_ctr.ctr.array :
-# self.conn_list.append(i)
-
-
-
-
- @staticmethod
- def translate_types(stype):
- """ Translates SType dependinf on type.
-
- If string is provided it gives the corresponding srvsvc.STYPE integer.
- If Integer value is input it returns the corresponding STYPE string.
- Additionally it also generates the comments.
-
- Usage :
- S.translate_types(stype)-> (stype_converted,comments)
-
- """
- stype_table = (
- ( 'STYPE_DEVICE',srvsvc.STYPE_DEVICE,' Device Share '),
- ( 'STYPE_DEVICE_HIDDEN',srvsvc.STYPE_DEVICE_HIDDEN,' Hidden Device '),
- ( 'STYPE_DEVICE_TEMPORARY',srvsvc.STYPE_DEVICE_TEMPORARY,' Temporary Device '),
- ( 'STYPE_DISKTREE',srvsvc.STYPE_DISKTREE,' Disktree Share '),
- ( 'STYPE_DISKTREE_HIDDEN',srvsvc.STYPE_DISKTREE_HIDDEN,' Hidden Disktree Share '),
- ( 'STYPE_DISKTREE_TEMPORARY',srvsvc.STYPE_DISKTREE_TEMPORARY,' Temporary Disktree Share '),
- #( 'STYPE_HIDDEN',srvsvc.STYPE_HIDDEN,' Hidden Share '),
- ( 'STYPE_IPC',srvsvc.STYPE_IPC,' IPC Pipe '),
- ( 'STYPE_IPC_HIDDEN',srvsvc.STYPE_IPC_HIDDEN,' Hidden IPC Pipe '),
- ( 'STYPE_IPC_TEMPORARY',srvsvc.STYPE_IPC_TEMPORARY,' Temporary IPC Pipe '),
- ( 'STYPE_PRINTQ',srvsvc.STYPE_PRINTQ,' Print Queue '),
- ( 'STYPE_PRINTQ_HIDDEN',srvsvc.STYPE_PRINTQ_HIDDEN,' Hidden Print Que '),
- ( 'STYPE_PRINTQ_TEMPORARY',srvsvc.STYPE_PRINTQ_TEMPORARY,' Temporary Print Que'),
- #( 'STYPE_TEMPORARY',srvsvc.STYPE_TEMPORARY,' Temporary Share ')
- )
- if isinstance(stype,str) :
- for i in stype_table :
- if i[0] == stype:
- stype_int,stype_comm = i[1],i[2]
- return stype_int,stype_comm
- else :
- raise KeyError
- if isinstance(stype,int) :
- for i in stype_table :
- if i[1] == stype:
- stype_str,stype_comm = i[0],i[2]
- return stype_str,stype_comm
- else :
- raise KeyError
-
-
-
-
- @staticmethod
- def fix_path_format(path= "",islocal= 0):
- """ Fixes and checks the given path to make it in tthe correct format
-
- Convert the unix path to relavant Info Struct path for samba share object
- It also checks for validity of path if it is local.
- To be used for distktree (Files not IPC etc) type shares.
- Usage :
- S.fix_path_format(path= "",islocal= 0) -> path
-
- """
- if self.islocal == 1:
- if os.path.exists(path):
- path = os.path.realpath(path) # gets canonical path
- else :
- raise OSError
-
- if path.startswith('/'):
- path = path.replace('/','\\')
- path = "C:"+path
- path = unicode(path)
- elif path.startswith('C:'):
- path = unicode(path)
- else:
- raise KeyError
- return path
-
-
-
- def modify_share(self,name= "",comment= "",max_users= 0xFFFFFFFF,password= "",path= "",permissions= None,sd_buf=None,islocal= 0):
- """ Modifies share 502 object.
-
- Usage:
- S.modify_share(self,name= "",comment= "",max_users= 0xFFFFFFFF,password= "",path= "",permissions= None,sd_buf=None,islocal= 0) -> parm_error
-
- """
-
- # FIXME sd_buf needs to be fixed
- name = unicode(name)
- share = self.get_share_info_rpc(name)
-
- if comment != "" :
- share.comment = comment
- share.max_users= max_users
- share.current_users = 0
- share.password = password
- share.path = self.fix_path_format(path,islocal)
- share.permissions = None
- share.sd_buf = security #### FIXME
- parm_error = 0x00000000
- parm_error = self.pipe.NetShareSetInfo(self.server_unc,name, 502, share, parm_error)
- return parm_error
-
-
-
- def list_shares(self) :
- """ Gets a list of all active shares and update the share and share_name list.
-
- Usage:
- S.list_shares() -> None
- """
- self.share_list = []
- self.share_names_list = []
- self.share_types_list = []
- info_ctr = srvsvc.NetShareInfoCtr()
- info_ctr.level = 502
- (info_ctr, totalentries, resume_handle) = self.pipe.NetShareEnumAll(self.server_unc, info_ctr, self.max_buffer,self.resume_handle_share)
- self.share_list = info_ctr.ctr.array
- for i in self.share_list :
- self.share_names_list.append(i.name)
- self.share_types_list.append(i.type)
-
-
-
- def add_share(self,name= "",stype= ""):
- # Uses the default 502 share info
- """Adds a share with a given name and type
- This uses a share info 502 object.
- Should be followed by modify_share to complete the addition of the share.
-
- Usage :
- S.add_share(self,name= "",stype= "") -> parm_error
-
- """
- share = srvsvc.NetShareInfo502()
- name = unicode(name)
- share.name = name
- share.type,share.comment = translate_types(stype)
- parm_error = 0x00000000
- parm_error = self.pipe.NetShareAdd(self.server_unc, 502, share, parm_error)
- return parm_error
-
-
-
- def get_share_info_local(self,name= ""):
- """ Gets share info for a share with a particular name from local cache lists.
-
- Usage:
- S.get_share_info_local(self,name= "") -> sahre_info (502 type)
- """
- name = unicode(name)
- for i in self.share_names_list :
- if name == i :
- return share_list[i.index()]
-
-
-
- def get_share_info_rpc(self,name= ""):
- """
- Gets share info for a share with a particular name from the rpc server.
-
- Usage:
- S.get_share_info_local(self,name= "") -> sahre_info (502 type)
- """
- name = unicode(name)
- info = self.pipe.NetShareGetInfo(self.server_unc, name, 502)
- return info
-
-
-
- def delete_share (self,name= ""):
- """ Delete a share with the given name.
-
- Usage:
- S.delete_share (self,name= "") -> Boolean indicating success or faliure ,[error object]
- """
- reserved = None
- name = unicode(name)
- self.pipe.NetShareDel(self.server_unc, name, reserved)
-
-
-
-
- # NOT supported yet :(
- def remove_persistance (self,name= ""):
- """ Removes persistance of a share .
-
- Usage:
-
- """
- reserved = None # to figure out what type python accepts maybee int or str
- name = unicode(name)
- self.pipe.NetShareDelSticky(self.server_unc, name, reserved)
-
-
-
- def get_share_type (self,name= ""):
- """
- Returns type of share code (uses local cache for now as the rpc server in samba4 does not support it yet
-
- Usage:
- S.update_tod()
- """
- name = unicode(name)
- for i in self.share_names_list :
- if name == i :
- stype =share_types_list[i.index()]
- else:
- raise KeyError
- return stype
-
-
-
-
- def update_tod(self):
- """
- Updates Time and date (TOD) Info of the pipe object.
-
- Usage:
- update_tod() -> None
- """
- self.tod = self.pipe.NetRemoteTOD(self.server_unc)
-
-
-
-
- def get_list_disks(self):
- """
- Returns a list of disks on the system , in samaba rpc server these are hard coded .
- Refreshes Disk list of the pipe object.
-
- Usage:
- S.get_list_disks()-> None
- """
- disk_info = srvsvc.NetDiskInfo()
- self.disks_list = []
- (disk_info, totalentries, self.resume_handle) = self.pipe.NetDiskEnum(self.server_unc,0, disk_info, 26, self.resume_handle)
- for i in disk_info.disks :
- if i != "" : # disk lists returns a blank entry not of consequence to the program
- self.disks_list.append(i)
-
-
-
- @staticmethod
- def get_platform_string(platform_id):
- """
- Returns OS type string and description.
-
- Usage:
- S.get_platform_string(platform_id)-> platform_id_string,comment
- """
- os_dict = {
- srvsvc.PLATFORM_ID_DOS:['PLATFORM_ID_DOS',' DOS'],
- srvsvc.PLATFORM_ID_OS2 :['PLATFORM_ID_OS2',' OS2'],
- srvsvc.PLATFORM_ID_NT :['PLATFORM_ID_NT',' Windows NT or a newer'],
- srvsvc.PLATFORM_ID_NT :['PLATFORM_ID_OSF',' OSF/1'],
- srvsvc.PLATFORM_ID_VMS :['PLATFORM_ID_VMS',' VMS']
- }
- typestring,comment = os_dict[platform_id]
- return typestring,comment
-
-
-
-
- def get_file_security(self,secdesc,sharename= "",filepath= ""):
- """
- Returns a security of a file .
- Filepath must be full path relative to basepath of share's path.
-
- Usage:
- s.get_file_security(self,secdesc,sharename= "",filepath= "")-> sd_buf
- """
- sharename=unicode(sharename)
- sd_buf = self.pipe.NetGetFileSecurity(self.server_unc,share, filename, secdesc) #FIXME secdesc
- return sd_buf
-
-
-
-
- def set_file_security (self,secdesc,sd_buf,sharename= "",filepath= ""):
- """
- Returns a security of a file .
- Filepath must be full path relative to basepath of share's path.
-
- Usage:
- S.set_file_security (self,secdesc,sd_buf,sharename= "",filepath= "") -> Boolean succes,[error]
- """
- sharename=unicode(sharename)
- self.pipe.NetSetFileSecurity(self.server_unc,share, filename, secdesc,sd_buf) #FIXME secdesc,sd_buf
-
git.samba.org / samba-gtk.git / commitdiff