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
131 lines
4.4 KiB
Python
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
|