Files
wehub-resource-sync bcbd1bdb22
Integ / changes (push) Has been skipped
Pre-commit / pre-commit (push) Failing after 1s
CLI exit codes / changes (push) Has been skipped
Test (Install) / changes (push) Has been skipped
Test (Python) / changes (push) Has been skipped
Test (TypeScript) / changes (push) Has been skipped
CLI exit codes / cli-gate (push) Has been cancelled
Test (Install) / test-install-gate (push) Has been cancelled
Integ / integ-gate (push) Has been cancelled
Test (Python) / test-python-gate (push) Has been cancelled
Test (TypeScript) / test-typescript-gate (push) Has been cancelled
Test (Install) / python-minimal (3.12) (push) Has been cancelled
Test (Install) / python-minimal (3.11) (push) Has been cancelled
Test (Install) / python-extra (agno, mirage.agents.agno) (push) Has been cancelled
Test (Install) / python-extra (chroma, mirage.resource.chroma) (push) Has been cancelled
Test (Install) / python-extra (pdf, mirage.core.filetype.pdf) (push) Has been cancelled
Integ / integ (push) Has been cancelled
Integ / integ-database (push) Has been cancelled
Integ / integ-database-ts (push) Has been cancelled
Integ / integ-data (push) Has been cancelled
Integ / integ-ssh (push) Has been cancelled
Integ / integ-ssh-ts (push) Has been cancelled
Test (Python) / audit (push) Has been cancelled
Test (TypeScript) / test (push) Has been cancelled
Test (TypeScript) / python-fs-shim (push) Has been cancelled
CLI exit codes / Python CLI (push) Has been cancelled
CLI exit codes / TypeScript CLI (push) Has been cancelled
CLI exit codes / Cross-language snapshot interop (push) Has been cancelled
Test (Python) / test (push) Has been cancelled
Test (Python) / import-isolation (deepagents, openai, mirage.agents.openai_agents) (push) Has been cancelled
Test (Python) / import-isolation (deepagents, pydantic-ai, mirage.agents.pydantic_ai) (push) Has been cancelled
Integ / integ-ts (push) Has been cancelled
Integ / integ-fuse (push) Has been cancelled
Test (Install) / python-extra (databricks, mirage.resource.databricks_volume) (push) Has been cancelled
Test (Install) / python-extra (deepagents, mirage.agents.langchain) (push) Has been cancelled
Test (Install) / python-extra (email, mirage.resource.email) (push) Has been cancelled
Test (Install) / python-extra (fuse, mirage.fuse.mount) (push) Has been cancelled
Test (Install) / python-extra (hdf5, mirage.core.filetype.hdf5) (push) Has been cancelled
Test (Install) / python-extra (hf, mirage.resource.hf_buckets) (push) Has been cancelled
Test (Install) / python-extra (lancedb, mirage.resource.lancedb) (push) Has been cancelled
Test (Install) / python-extra (langfuse, mirage.resource.langfuse) (push) Has been cancelled
Test (Install) / python-extra (mongodb, mirage.resource.mongodb) (push) Has been cancelled
Test (Install) / python-extra (nextcloud, mirage.resource.nextcloud) (push) Has been cancelled
Test (Install) / python-extra (openai, mirage.agents.openai_agents) (push) Has been cancelled
Test (Install) / python-extra (openhands, mirage.agents.openhands, 3.12) (push) Has been cancelled
Test (Install) / python-extra (parquet, mirage.core.filetype.parquet) (push) Has been cancelled
Test (Install) / python-extra (postgres, mirage.resource.postgres) (push) Has been cancelled
Test (Install) / python-extra (pydantic-ai, mirage.agents.pydantic_ai) (push) Has been cancelled
Test (Install) / python-extra (qdrant, mirage.resource.qdrant) (push) Has been cancelled
Test (Install) / python-extra (redis, mirage.resource.redis) (push) Has been cancelled
Test (Install) / python-extra (s3, mirage.resource.s3) (push) Has been cancelled
Test (Install) / python-extra (ssh, mirage.resource.ssh) (push) Has been cancelled
Test (Install) / ts-minimal (push) Has been cancelled
chore: import upstream snapshot with attribution
2026-07-13 12:30:44 +08:00

131 lines
4.4 KiB
Python

import pytest
from aioresponses import aioresponses
from mirage.accessor.onedrive import OneDriveAccessor, OneDriveConfig
from mirage.cache.index import RAMIndexCacheStore
from mirage.core.onedrive.readdir import readdir
from mirage.core.onedrive.stat import stat
from mirage.types import FileType, PathSpec
from mirage.utils.key_prefix import mount_key
def _accessor(**kw) -> OneDriveAccessor:
return OneDriveAccessor(OneDriveConfig(access_token="tok", **kw))
_FILE_URL = ("https://graph.microsoft.com/v1.0/me/drive"
"/root:/Docs/report.docx")
_DIR_URL = "https://graph.microsoft.com/v1.0/me/drive/root:/Docs"
@pytest.mark.asyncio
async def test_stat_root_is_directory():
result = await stat(_accessor(), PathSpec.from_str_path("/"))
assert result.type == FileType.DIRECTORY
@pytest.mark.asyncio
async def test_stat_file_carries_size_and_ctag_fingerprint():
with aioresponses() as m:
m.get(_FILE_URL,
payload={
"id": "01ITEM",
"name": "report.docx",
"size": 1234,
"lastModifiedDateTime": "2026-05-01T10:00:00Z",
"cTag": "ctag-abc",
"eTag": "etag-xyz",
"file": {
"mimeType": "application/vnd.openxml"
},
})
result = await stat(_accessor(),
PathSpec.from_str_path("/Docs/report.docx"))
assert result.name == "report.docx"
assert result.size == 1234
assert result.fingerprint == "ctag-abc"
assert result.extra["id"] == "01ITEM"
@pytest.mark.asyncio
async def test_stat_folder_is_directory():
with aioresponses() as m:
m.get(_DIR_URL,
payload={
"id": "01FOLDER",
"name": "Docs",
"size": 4096,
"lastModifiedDateTime": "2026-05-01T10:00:00Z",
"folder": {
"childCount": 2
},
})
result = await stat(_accessor(), PathSpec.from_str_path("/Docs"))
assert result.type == FileType.DIRECTORY
assert result.name == "Docs"
assert result.size == 4096
assert result.modified == "2026-05-01T10:00:00Z"
@pytest.mark.asyncio
async def test_stat_missing_raises_file_not_found():
with aioresponses() as m:
m.get(_FILE_URL,
status=404,
payload={"error": {
"code": "itemNotFound",
"message": "no"
}})
with pytest.raises(FileNotFoundError) as exc:
await stat(
_accessor(),
PathSpec.from_str_path(
"/od/Docs/report.docx",
mount_key("/od/Docs/report.docx", "/od")))
assert str(exc.value) == "/od/Docs/report.docx"
@pytest.mark.asyncio
async def test_stat_from_index_returns_modified():
index = RAMIndexCacheStore()
with aioresponses() as m:
m.get("https://graph.microsoft.com/v1.0/me/drive/root/children",
payload={
"value": [{
"id": "1",
"name": "notes.txt",
"size": 42,
"file": {},
"lastModifiedDateTime": "2026-06-19T09:28:00Z",
}]
})
await readdir(_accessor(), PathSpec.from_str_path("/"), index)
result = await stat(_accessor(), PathSpec.from_str_path("/notes.txt"),
index)
assert result.name == "notes.txt"
assert result.size == 42
assert result.modified == "2026-06-19T09:28:00Z"
@pytest.mark.asyncio
async def test_stat_from_index_folder_returns_modified():
index = RAMIndexCacheStore()
with aioresponses() as m:
m.get("https://graph.microsoft.com/v1.0/me/drive/root/children",
payload={
"value": [{
"id": "2",
"name": "Docs",
"folder": {
"childCount": 5
},
"size": 9000,
"lastModifiedDateTime": "2026-05-28T02:10:00Z",
}]
})
await readdir(_accessor(), PathSpec.from_str_path("/"), index)
result = await stat(_accessor(), PathSpec.from_str_path("/Docs"), index)
assert result.type == FileType.DIRECTORY
assert result.modified == "2026-05-28T02:10:00Z"
assert result.size == 9000