chore: commit pending changes

Author: vgrem

examples/onedrive/excel/read_table.py

@@ -18,7 +18,7 @@
 client = GraphClient(tenant=test_tenant).with_username_and_password(test_client_id, test_username, test_password)
 
 # Find an Excel file
-items = client.me.drive.search("*.xlsx").execute_query()
+items = client.me.drive.search("xlsx").execute_query()
 if len(items) == 0:
     sys.exit("No Excel files found. Upload one first.")
 

examples/onedrive/files/analytics.py

@@ -1,15 +1,7 @@
 """
-File analytics — view activity stats, get activities by time interval,
-and check item views/modifications over time.
+File analytics — view activity stats and access patterns.
 
-Shows who accessed a file, when, and how often. Useful for adoption
-tracking, content governance, and understanding which files are
-most actively used in a drive.
-
-Requires delegated permission ``Files.Read`` and ``Analytics.Read``.
-
-https://learn.microsoft.com/en-us/graph/api/itemanalytics-get
-https://learn.microsoft.com/en-us/graph/api/driveitem-getactivitiesbyinterval
+Requires delegated permissions Files.Read and Analytics.Read.
 """
 
 from datetime import datetime, timedelta, timezone
@@ -21,74 +13,31 @@
 def main():
     client = GraphClient(tenant=test_tenant).with_client_secret(test_client_id, test_client_secret)
 
-    drive = client.me.drive
-
-    # -- Step 1: pick a file to analyse (most recent) --
-    items = drive.root.children.top(20).get().execute_query()
-    files = [i for i in items if i.is_file]
-
+    drive = client.sites.get_by_path("/sites/project").drive
+    files = [i for i in drive.root.children.top(20).get().execute_query() if i.is_file]
     if not files:
-        print("No files found in OneDrive root. Creating a test file...")
-        drive.root.upload("analytics_test.txt", b"Analytics test content.").execute_query()
-        files = drive.root.children.top(20).get().execute_query()
-        files = [i for i in files if i.is_file]
+        print("No files found.")
+        return
 
     target = files[0]
-    print(f"Analysing: {target.name}  (size: {target.size or 0} bytes)\n")
-
-    # -- Step 2: get analytics for the item --
-    try:
-        analytics = target.analytics.get().execute_query()
-        if analytics:
-            print("Item analytics:")
-            if hasattr(analytics, "all_time") and analytics.all_time:
-                a = analytics.all_time
-                print(f"  All time: {a.access_count or 0} accesses, {a.view_count or 0} views")
-                print(f"            {a.share_count or 0} shares, {a.download_count or 0} downloads")
-            if hasattr(analytics, "last_seven_days") and analytics.last_seven_days:
-                l7 = analytics.last_seven_days
-                print(f"  Last 7d : {l7.access_count or 0} accesses, {l7.view_count or 0} views")
-        else:
-            print("  (analytics returned no data — may need Analytics.Read permission)")
-    except Exception as e:
-        print(f"  (analytics not available: {e})")
-
-    # -- Step 3: get activity by interval (last 30 days) --
-    now = datetime.now(timezone.utc)
-    start = now - timedelta(days=30)
-    end = now
-
-    print("\nActivity by day for the last 30 days:")
-    try:
-        activities = target.get_activities_by_interval(
-            start_dt=start,
-            end_dt=end,
-            interval="day",
-        ).execute_query()
-
-        print(f"  {len(activities)} days with activity")
-        for act in activities:
-            dt = act.start_date_time.strftime("%Y-%m-%d") if act.start_date_time else "?"
-            access = act.access_count or 0
-            act_view = act.view_count or 0
-            act_down = act.download_count or 0
-            act_share = act.share_count or 0
-            print(f"  {dt}  accesses={access:>3}  views={act_view:>3}  downloads={act_down:>3}  shares={act_share:>2}")
-    except Exception as e:
-        print(f"  (activity by interval not available: {e})")
-
-    # -- Step 4: item activity (who did what) --
-    print("\nRecent activities on this file:")
-    try:
-        activities_v2 = target.get_activities_by_interval(
-            start_dt=start,
-            end_dt=end,
-            interval="day",
-        ).execute_query()
-        if activities_v2:
-            print("  (see activity timeline above — details available via activity insight resources)")
-    except Exception as e:
-        print(f"  {e}")
+    print(f"File: {target.name}")
+
+    analytics = target.analytics.select(["allTime"]).get().execute_query()
+    if analytics.all_time:
+        a = analytics.all_time
+        print(f"  All time: {a.accessCount or 0} accesses, {a.viewCount or 0} views, {a.shareCount or 0} shares")
+    if analytics.last_seven_days:
+        l7 = analytics.last_seven_days
+        print(f"  Last 7d:  {l7.accessCount or 0} accesses, {l7.viewCount or 0} views")
+
+    activities = target.get_activities_by_interval(
+        start_dt=datetime.now(timezone.utc) - timedelta(days=30),
+        end_dt=datetime.now(timezone.utc),
+        interval="day",
+    ).execute_query()
+    print(f"\nActivity ({len(activities)} days with activity):")
+    for act in activities:
+        print(f"  {act.start_date_time.date()}  accesses={act.accessCount or 0}  views={act.viewCount or 0}")
 
 
 if __name__ == "__main__":

examples/onedrive/lists/manage.py

@@ -23,7 +23,7 @@
 
 # 1. Create a document library
 list_name = create_unique_name("ProjectAssets")
-lib = client.sites.root.lists.add(list_name, ListTemplateType.documentLibrary).execute_query()
+lib = client.sites.root.lists.add(list_name, ListTemplateType.genericList).execute_query()
 print(f"List created: {lib.display_name}")
 
 # 2. Add a text column
@@ -32,7 +32,7 @@
 
 # 3. Create an item with custom column value
 item = lib.items.add(Title="Q4 Report", Category="Finance").execute_query()
-print(f"  Item: {item.display_name} (id: {item.id})")
+print(f"  Item: {item.name} (id: {item.id})")
 
 # 4. Read items back
 items = lib.items.get().execute_query()

examples/onedrive/sites/get_site.py

@@ -11,7 +11,7 @@
 """
 
 from office365.graph_client import GraphClient
-from tests import test_client_id, test_password, test_tenant, test_username
+from tests import test_client_id, test_password, test_tenant, test_tenant_name, test_username
 
 client = GraphClient(tenant=test_tenant).with_username_and_password(test_client_id, test_username, test_password)
 
@@ -20,7 +20,7 @@
 print(f"Root site: {root.display_name}  ({root.web_url})")
 
 # 2. Get site by URL
-site = client.sites.get_by_url(f"https://{test_tenant}.sharepoint.com/sites/team").get().execute_query()
+site = client.sites.get_by_url(f"https://{test_tenant_name}.sharepoint.com/sites/project").get().execute_query()
 print(f"Team site: {site.display_name}  (id: {site.id})")
 
 # 3. Followed sites

generator/.checkpoints/SharePoint.xml.json

@@ -0,0 +1,7 @@
+# from office365.migration import (
+#    MigrationAssessor,
+#    TenantAssessor,
+#    MigrationEngine,
+#    Exporter,
+#    SyncEngine,
+# )

office365/migration/__init__.py

@@ -0,0 +1,81 @@
+"""
+office365.migration.base
+~~~~~~~~~~~~~~~~~~~~~~~~
+Shared types, enums, and the MigrationQuery base class.
+
+MigrationQuery extends ClientQuery so all migration operations
+plug into the existing deferred execution pipeline:
+    operation.execute_query()
+    operation.execute_query_retry()
+    operation.after_execute(callback)
+"""
+
+from __future__ import annotations
+
+from dataclasses import dataclass, field
+from enum import Enum
+
+# ── Enums ─────────────────────────────────────────────────────────────────────
+
+
+class ConflictResolution(str, Enum):
+    SKIP = "skip"
+    OVERWRITE = "overwrite"
+    RENAME = "rename"
+
+
+class MigrationMode(str, Enum):
+    FULL = "full"
+    INCREMENTAL = "incremental"
+    UPSERT = "upsert"
+
+
+class ExportFormat(str, Enum):
+    FILESYSTEM = "filesystem"
+    PARQUET = "parquet"
+    CSV = "csv"
+    JSON = "json"
+    DELTA = "delta"
+
+
+# ── Value types ───────────────────────────────────────────────────────────────
+
+
+@dataclass
+class MigrationItem:
+    """Unit of work flowing through the migration pipeline."""
+
+    source_path: str
+    dest_path: str
+    size_bytes: int = 0
+    item_type: str = "file"
+    status: str = "pending"
+    error: Exception | None = None
+
+
+@dataclass
+class MigrationStats:
+    total: int = 0
+    success: int = 0
+    skipped: int = 0
+    errors: int = 0
+    bytes_transferred: int = 0
+
+    def summary(self) -> str:
+        mb = self.bytes_transferred / 1024 / 1024
+        return (
+            f"Total: {self.total} | Success: {self.success} | "
+            f"Skipped: {self.skipped} | Errors: {self.errors} | "
+            f"Transferred: {mb:.1f}MB"
+        )
+
+
+@dataclass
+class MigrationOptions:
+    conflict_resolution: ConflictResolution = ConflictResolution.SKIP
+    preserve_timestamps: bool = True
+    preserve_permissions: bool = False
+    preserve_versions: bool = False
+    include_patterns: list[str] = field(default_factory=list)
+    exclude_patterns: list[str] = field(default_factory=list)
+    batch_size: int = 100

office365/migration/base.py

@@ -11,6 +11,10 @@ class ItemActionStat(ClientValue):
 
     actionCount: int | None = None
     actorCount: int | None = None
+    accessCount: int | None = None
+    viewCount: int | None = None
+    shareCount: int | None = None
+    downloadCount: int | None = None
 
     @property
     def entity_type_name(self) -> str:

office365/onedrive/analytics/item_action_stat.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 from datetime import datetime
-from typing import TYPE_CHECKING, Optional
+from typing import TYPE_CHECKING, Any, Optional, Self
 
 from office365.directory.permissions.identity_set import IdentitySet
 from office365.entity import Entity
@@ -103,6 +103,12 @@ def last_modified_date_time(self) -> datetime:
         """Gets the lastModifiedDateTime property"""
         return self.properties.get("lastModifiedDateTime", datetime.min)
 
+    def set_property(self, name: str, value: Any, persist_changes: bool = True) -> Self:
+        super().set_property(name, value, persist_changes)
+        if name == "parentReference":
+            pass
+        return self
+
     def get_property(self, name, default_value=None):
         if default_value is None:
             property_mapping = {

office365/onedrive/base_item.py

@@ -16,6 +16,7 @@
 from office365.runtime.paths.resource_path import ResourcePath
 from office365.runtime.queries.create_entity import CreateEntityQuery
 from office365.runtime.queries.function import FunctionQuery
+from office365.runtime.types.odata_property import odata
 
 
 class Drive(BaseItem):
@@ -95,6 +96,7 @@ def drive_type(self) -> Optional[str]:
         """
         return self.properties.get("driveType", None)
 
+    @odata(name="sharepointIds")
     @property
     def sharepoint_ids(self) -> SharePointIds:
         """Returns identifiers useful for SharePoint REST compatibility."""