test file upload

Author: shemogumbe

src/msgraph_core/models/large_file_upload_create_session.py

@@ -6,7 +6,7 @@
 from kiota_abstractions.store.backing_store_factory_singleton import BackingStoreFactorySingleton
 
 
-class LargeFileUploadCreateSessionBody(Parsable, AdditionalDataHolder, BackedModel):
+class LargeFileUploadCreateSession(Parsable, AdditionalDataHolder, BackedModel):
 
     def __init__(self):
         self.backing_store = BackingStoreFactorySingleton.get_instance().create_backing_store()

src/msgraph_core/models/page_result.py

@@ -9,9 +9,9 @@
 Classes:
     PageResult: Represents a page of items in a paged response.
 """
+from __future__ import annotations
 from typing import Any, List, Optional
 from dataclasses import dataclass
-from __future__ import annotations
 
 from kiota_abstractions.serialization.parsable import Parsable  # type: ignore
 from kiota_abstractions.serialization.serialization_writer \

src/msgraph_core/tasks/__init__.py

@@ -1 +1,2 @@
 from .page_iterator import PageIterator
+from .large_file_upload import LargeFileUploadTask

src/msgraph_core/tasks/large_file_upload.py

@@ -18,7 +18,7 @@ def __init__(
         self,
         upload_session: Parsable,
         request_adapter: RequestAdapter,
-        stream: BytesIO,
+        stream: BytesIO,  # counter check this
         max_chunk_size: int = 4 * 1024 * 1024
     ):
         self.upload_session = upload_session
@@ -36,16 +36,13 @@ def __init__(
     def get_upload_session(self) -> Parsable:
         return self.upload_session
 
-    def get_adapter(self) -> RequestAdapter:
-        return self.request_adapter
-
     def create_upload_session(
         self,
         request_body: LargeFileUploadSession,
         model: LargeFileUploadCreateSession,
     ) -> Future:
         request_info = RequestInformation()
-        request_info.url = ""
+        request_info.url = request_info.url  # check the URL
         request_info.http_method = Method.POST
         request_info.set_content_from_parsable(
             self.request_adapter, 'application/json', request_body
@@ -54,6 +51,9 @@ def create_upload_session(
 
         return self.request_adapter.send_async(request_info, LargeFileUploadSession, {})
 
+    def get_adapter(self) -> RequestAdapter:
+        return self.request_adapter
+
     def get_chunks(self) -> int:
         return self.chunks
 
@@ -80,7 +80,7 @@ def upload_session_expired(self, upload_session: Optional[Parsable] = None) -> b
         return False
 
     async def upload(self, after_chunk_upload: Optional[Callable] = None) -> Future:
-        # Rewinds to take care of failures.
+        # Rewind to take care of failures.
         self.stream.seek(0)
         if self.upload_session_expired(self.upload_session):
             raise RuntimeError('The upload session is expired.')
@@ -90,7 +90,6 @@ async def upload(self, after_chunk_upload: Optional[Callable] = None) -> Future:
             self.stream, 0, max(0, min(self.max_chunk_size - 1, self.file_size - 1))
         )
         process_next = session
-        # determine the range uploaded
         # includes when resuming existing upload sessions.
         range_parts = self.next_range[0].split("-") if self.next_range else ['0', '0']
         end = min(int(range_parts[0]) + self.max_chunk_size - 1, self.file_size)
@@ -250,5 +249,5 @@ def get_validated_upload_url(self, upload_session: Parsable) -> str:
     def get_next_range(self) -> Optional[str]:
         return self.next_range
 
-    def get_next_range(self) -> Optional[str]:
-        return self.next_range
+    def get_file_size(self) -> int:
+        return self.file_size