1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
|
import binascii
import serial
from stat import S_IRUSR, S_IWUSR, S_IXUSR, S_IRGRP, S_IXGRP, S_IROTH, S_IXOTH, S_IFDIR, S_IFREG
import struct
from AESession import AESession
import AEMultipart
###################################
#
# All paths are without leading /
# All paths are in Amiga charset.
#
###################################
# Command 0x01
# Cancel a running operation.
#
def cancel(session):
session.sendMsg(1, b'')
# Command 0x64
# List a directory.
#
def dir_list(session, path):
print("AECmds.dir_list: " + path)
session.sendMsg(0x64, path + b'\x00\x01')
dirlist = AEMultipart.recv(session)
# TODO: Check for None returned, meaning that the path doesn't exist.
# Actually, what can we return then?
# None is not iterable, and [] indicates an empty directory.
close(session)
# Parse dirlist
(numents,) = struct.unpack('!L', dirlist[0:4])
dirlist = dirlist[4:]
kids = {}
#kids['.'] = (dict(st_mode=(S_IFDIR | 0o755), st_nlink=2), {})
#kids['..'] = (dict(st_mode=(S_IFDIR | 0o755), st_nlink=2), {})
while numents > 0:
assert len(dirlist) > 29
(entlen, size, used, type, attrs, mdays, mmins, mticks, type2) = struct.unpack('!LLLHHLLLB', dirlist[0:29])
# entlen - Size of this entry in the list, in bytes
# size - Size of file.
# For drives, total space.
# used - 0 for files and folders.
# For drives, space used.
# type - ?
# attrs - Amiga attributes
# mdays - Last modification in days since 1978-01-01
# mmins - Last modification in minutes since mdays
# mticks - Last modification in ticks (1/50 sec) since mmins
# type2 - 0: Volume
# - 1: Volume
# - 2: Directory
# - 3: File
# - 4: ROM
# - 5: ADF
# - 6: HDF
assert entlen <= len(dirlist)
name = dirlist[29:entlen].split(b'\x00')[0].decode(encoding="iso8859-1")
dirlist = dirlist[entlen:]
numents -= 1
st = {}
st = {}
st['st_mode'] = 0
#if attrs & 0x40: st['st_mode'] |= Script
#if attrs & 0x20: st['st_mode'] |= Pure
#if attrs & 0x10: st['st_mode'] |= Archive
if not attrs & 0x08: st['st_mode'] |= S_IRUSR | S_IRGRP | S_IROTH # Read
if not attrs & 0x04: st['st_mode'] |= S_IWUSR # Write
if not attrs & 0x02: st['st_mode'] |= S_IXUSR | S_IXGRP | S_IXOTH # Execute
#if not attrs & 0x01: st['st_mode'] |= Delete
# Check for directory
if type & 0x8000:
st['st_mode'] |= S_IFDIR
else:
st['st_mode'] |= S_IFREG
st['st_nlink'] = 1
st['st_size'] = size
st['st_mtime'] = (2922*24*60*60) # Amiga epoch starts 1978-01-01
st['st_mtime'] += (mdays*24*60*60) # Days since 1978-01-01
st['st_mtime'] += (mmins*60) # Minutes
st['st_mtime'] += (mticks/50) # Ticks of 1/50 sec
st['st_blksize'] = session.packetsize - 4
# TODO: Convert time zone.
# Amiga time seems to be local time, we currently treat it as UTC.
kids[name] = (st, None)
return kids
# Command 0x65
# Read a file.
#
def file_read_start(session, path):
print("AECmds.file_read_start: " + path)
# Request file
session.sendMsg(0x65, path + b'\x00')
# Get file response header
(filelen, pktsize) = AEMultipart.recvHeader(session)
# TODO: Check for None returned, meaning that the path doesn't exist.
# This may not be necessary in case FUSE always issues a getattr()
# beforehand.
return filelen
def file_read_next(session):
(blockOffset, blockData) = AEMultipart.recvBlock(session)
if (blockData == None):
blen = None
else:
blen = len(blockData)
print("AECmds.file_read_next: " + str(blen) + ' @ ' + str(blockOffset))
return (blockOffset, blockData)
# Command 0x66
# Write a complete file and set its attributes and time.
#
def file_write(session, path, amigaattrs, unixtime, filebody):
print('AECmds.file_write: ' + path + ' -- ' + str(len(filebody)))
filelen = len(filebody)
_utime = unixtime - (2922*24*60*60) # Amiga epoch starts 1978-01-01
mdays = int(_utime / (24*60*60)) # Days since 1978-01-01
_utime -= mdays * (24*60*60)
mmins = int(_utime / 60) # Minutes
_utime -= mmins * 60
mticks = _utime * 50 # Ticks of 1/50 sec
filetype = 3 # Regular file
data = struct.pack('!LLLLLLLB',
29 + len(path) + 6, # Length of this message, really
filelen,
0,
amigaattrs,
mdays,
mmins,
mticks,
filetype)
data += path
data += b'\0\0\0\0\0\0' # No idea what this is for
session.sendMsg(0x66, data)
# TODO: Handle target FS full
# TODO: Handle permission denied on target FS
AEMultipart.send(session, filebody)
close(session)
# Command 0x67
# Delete a path.
# Can be a file or folder, and will be deleted recursively.
#
def delete(session, path):
print("AECmds.delete: " + path)
session.sendMsg(0x67, path + b'\x00')
(type, _) = session.recvMsg()
close(session)
# type == 0 means the file was deleted successfully
return (type == 0)
# Command 0x68
# Rename a file, leaving it in the same folder.
#
def rename(session, path, new_name):
print("AECmds.rename: " + path + ' - ' + new_name)
session.sendMsg(0x68, path + b'\x00' + new_name + b'\x00')
(type, _) = session.recvMsg()
if type != 0:
print("AECmds.rename: Response type " + str(type))
close(session)
# Assume that type == 0 means the file was renamed successfully
return (type == 0)
# Command 0x69
# Move a file from a folder to a different one, keeping its name.
#
def move(session, path, new_parent):
print("AECmds.move: " + path + ' - ' + new_parent)
session.sendMsg(0x69, path + b'\x00' + new_parent + b'\x00\xc9')
(type, _) = session.recvMsg()
if type != 0:
print("AECmds.move: Response type " + str(type))
close(session)
# Assume that type == 0 means the file was moved successfully
return (type == 0)
# Command 0x6a
# Copy a file.
#
def copy(session, path, new_parent):
print("AECmds.copy: " + path + ' - ' + new_parent)
session.sendMsg(0x6a, path + b'\x00' + new_parent + b'\x00\xc9')
(type, _) = session.recvMsg()
if type != 0:
print("AECmds.copy: Response type " + str(type))
close(session)
# Assume that type == 0 means the file was copied successfully
return (type == 0)
# Command 0x6b
# Set attributes and comment.
#
def setattr(session, amigaattrs, path, comment):
print("AECmds.setattr: " + str(amigaattrs) + ' - ' + path + ' - ' + comment)
data = struct.pack('!L', amigaattrs)
data += path + b'\x00'
data += comment + b'\x00'
data += struct.pack('!L', 0)
session.sendMsg(0x6b, data)
(type, _) = session.recvMsg()
if type != 0:
print("AECmds.setattr: Response type " + str(type))
close(session)
# Assume that type == 0 means the file was copied successfully
return (type == 0)
# Command 0x6c
# Request (?)
#
# Command 0x6d
# Finish a running operation.
#
def close(session):
print('AECmds.close')
session.sendMsg(0x6d, b'')
(type, data) = session.recvMsg()
assert type == 0x0a
if data != b'\0\0\0\0\0':
print('AECmds.close: data == ' + binascii.hexlify(data))
# Format of data returned:
# Byte 0: ?
# Byte 1: ?
# Byte 2: ?
# Byte 3: 00 - No error
# 06 - File no longer exists
# 1c - Timed out waiting for host to request next read block
# Byte 4: Path in case of error 06.
# Empty (null-terminated) otherwise?
# Null-terminated string.
#assert data == b'\0\0\0\0\0'
# Command 0x6e
# Format a disk.
#
# Command 0x6f
# Create a new folder and matching .info file.
# This folder will be named "Unnamed1".
#
|