|
# Conversion of pysmb code to smbprotocol |
|
# Original code at |
|
# https://github.com/miketeo/pysmb/blob/76dc1708007fdcdd9d96a3703910938b84691704/python3/smb/base.py#L413-L548 |
|
# |
|
import binascii |
|
import uuid |
|
import pprint |
|
import struct |
|
|
|
from smbprotocol.connection import Connection |
|
from smbprotocol.open import ( |
|
CreateDisposition, |
|
CreateOptions, |
|
FilePipePrinterAccessMask, |
|
ImpersonationLevel, |
|
Open, |
|
RequestedOplockLevel, |
|
ShareAccess, |
|
) |
|
from smbprotocol.session import Session |
|
from smbprotocol.tree import TreeConnect |
|
|
|
# Replace these with your values. |
|
server = '10.10.10.10' |
|
user = 'test-user' |
|
password = 'test-pass' |
|
|
|
|
|
######################## |
|
|
|
conn = Connection( |
|
uuid.uuid4(), |
|
server, |
|
445, |
|
require_signing=True, |
|
) |
|
conn.connect() |
|
|
|
session = Session( |
|
conn, |
|
user, |
|
password, |
|
require_encryption=True, |
|
) |
|
session.connect() |
|
|
|
|
|
tree = TreeConnect(session, f'\\\\{server}\\IPC$') |
|
tree.connect(require_secure_negotiate=True) |
|
handler = Open(tree, 'srvsvc') |
|
handler.create( |
|
file_attributes=0, |
|
desired_access=( |
|
FilePipePrinterAccessMask.FILE_READ_DATA | |
|
FilePipePrinterAccessMask.FILE_WRITE_DATA |
|
), |
|
share_access=( |
|
ShareAccess.FILE_SHARE_READ | |
|
ShareAccess.FILE_SHARE_WRITE |
|
), |
|
impersonation_level=ImpersonationLevel.Impersonation, |
|
create_options=CreateOptions.FILE_NON_DIRECTORY_FILE, |
|
create_disposition=CreateDisposition.FILE_OPEN, |
|
) |
|
|
|
call_id = 1 |
|
list_shares_init = data_bytes = \ |
|
binascii.unhexlify(b"""05 00 0b 03 10 00 00 00 74 00 00 00""".replace(b' ', b'')) + \ |
|
struct.pack('<I', call_id) + \ |
|
binascii.unhexlify(b""" |
|
b8 10 b8 10 00 00 00 00 02 00 00 00 00 00 01 00 |
|
c8 4f 32 4b 70 16 d3 01 12 78 5a 47 bf 6e e1 88 |
|
03 00 00 00 04 5d 88 8a eb 1c c9 11 9f e8 08 00 |
|
2b 10 48 60 02 00 00 00 01 00 01 00 c8 4f 32 4b |
|
70 16 d3 01 12 78 5a 47 bf 6e e1 88 03 00 00 00 |
|
2c 1c b7 6c 12 98 40 45 03 00 00 00 00 00 00 00 |
|
01 00 00 00 |
|
""".replace(b' ', b'').replace(b'\n', b'')) |
|
|
|
handler.write(list_shares_init) |
|
list_share_response = handler.read(0, 1000) |
|
|
|
|
|
call_id = 2 |
|
remote_name = f'\\\\{server}' |
|
server_len = len(remote_name) + 1 |
|
server_bytes_len = server_len * 2 |
|
if server_len % 2 != 0: |
|
padding = b'\0\0' |
|
server_bytes_len += 2 |
|
list_shares_request = binascii.unhexlify(b"""05 00 00 03 10 00 00 00""".replace(b' ', b'')) + \ |
|
struct.pack('<HHI', 72+server_bytes_len, 0, call_id) + \ |
|
binascii.unhexlify(b"""4c 00 00 00 00 00 0f 00 00 00 02 00""".replace(b' ', b'')) + \ |
|
struct.pack('<III', server_len, 0, server_len) + \ |
|
(remote_name + '\0').encode('UTF-16LE') + padding + \ |
|
binascii.unhexlify(b""" |
|
01 00 00 00 01 00 00 00 04 00 02 00 00 00 00 00 |
|
00 00 00 00 ff ff ff ff 08 00 02 00 00 00 00 00 |
|
""".replace(b' ', b'').replace(b'\n', b'')) |
|
handler.write(list_shares_request) |
|
data_bytes = handler.read(0, 1000) |
|
|
|
|
|
shares_count = struct.unpack('<I', data_bytes[36:40])[0] |
|
results = [] # A list of SharedDevice instances |
|
offset = 36 + 12 # You need to study the byte stream to understand the meaning of these constants |
|
for i in range(0, shares_count): |
|
results.append({ |
|
'type': struct.unpack('<I', data_bytes[offset+4:offset+8])[0]}) |
|
offset += 12 |
|
|
|
for i in range(0, shares_count): |
|
max_length, _, length = struct.unpack('<III', data_bytes[offset:offset+12]) |
|
offset += 12 |
|
results[i]['name'] = data_bytes[offset:offset+length*2-2].decode('UTF-16LE') |
|
|
|
if length % 2 != 0: |
|
offset += (length * 2 + 2) |
|
else: |
|
offset += (length * 2) |
|
|
|
max_length, _, length = struct.unpack('<III', data_bytes[offset:offset+12]) |
|
offset += 12 |
|
results[i]['comments'] = data_bytes[offset:offset+length*2-2].decode('UTF-16LE') |
|
|
|
if length % 2 != 0: |
|
offset += (length * 2 + 2) |
|
else: |
|
offset += (length * 2) |
|
|
|
|
|
pprint.pp(results) |
|
handler.close() |
I am getting the following error in line 101
data_bytes = handler.read(0, 1000)Error:
ValueError: Enum value 16 does not exist in enum type <class 'smbprotocol.exceptions.ErrorContextId'>Any sugestion on how to make this work?
Regards
-ed