mattia/BiblioMxWeb
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Intent mechanic

Browse Source
This commit is contained in:
MatMasIt 2022-01-31 10:12:02 +01:00 committed by GitHub
parent 18ea8f5268
commit 0cdf4bb5be
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
windowsAgent/source/do.py
View File

@ -28,27 +28,30 @@ def upload(csvPath):
uid = str(uuid.uuid4()) uid = str(uuid.uuid4())
content_path = csvPath content_path = csvPath
content_size = os.stat(content_path).st_size content_size = os.stat(content_path).st_size
print(content_path, content_size) vprint(content_path, content_size)
file_object = open(content_path, "rb") file_object = open(content_path, "rb")
index = 0 index = 0
offset = 0 offset = 0
headers = {} headers = {}
headers['Authorization'] = auth
headers['X-Nonce'] = uid
headers['X-Intent'] ="W"
for chunk in read_in_chunks(file_object, 1024): for chunk in read_in_chunks(file_object, 1024):
offset = index + len(chunk) offset = index + len(chunk)
headers['Content-Range'] = 'bytes %s-%s/%s' % (index, offset - 1, content_size) headers['Content-Range'] = 'bytes %s-%s/%s' % (index, offset - 1, content_size)
headers['Authorization'] = auth
headers['X-Nonce'] = uid
index = offset index = offset
try: try:
file = {"file": chunk} file = {"file": chunk}
r = requests.post(serverUrl, files=file, headers=headers) r = requests.post(serverUrl, files=file, headers=headers)
print(r.text) vprint(r.text)
print("r: %s, Content-Range: %s" % (r, headers['Content-Range'])) vprint("r: %s, Content-Range: %s" % (r, headers['Content-Range']))
except Exception as e: except Exception as e:
print(e) print(e)
headers['X-Intent'] ="C"
request.post(serverUrl,data="Concludo, Presidente",headers)
if not storage.exists("lastUpdate"): if not storage.exists("lastUpdate"):
vprint("Last database update record has been initialized") vprint("Last database update record has been initialized")
storage.save("lastUpdate",0) storage.save("lastUpdate",0)
@ -83,7 +86,7 @@ while True:
storage.save("lastCSVUpdate",os.path.getmtime(csvPath)) storage.save("lastCSVUpdate",os.path.getmtime(csvPath))
vprint("Updating the last recorded time accordingly") vprint("Updating the last recorded time accordingly")
vprint("Beginning upload") vprint("Beginning upload")
upload(csvPath)#maybe check if export has been varied? upload(csvPath)
else: else:
storage.save("updateTick",i+1) storage.save("updateTick",i+1)