p5(p0): Async file I/O in Sinch provider

api/admin_ui/src/App.tsx

@@ -832,7 +832,7 @@ function AppContent() {
               )}
               {toolsTab === 2 && <Logs client={client!} />}
               {toolsTab === 3 && <Plugins client={client!} readOnly={!hasTrait('role.admin')} />}
-              {toolsTab === 4 && <PluginMarketplace />}
+              {toolsTab === 4 && <PluginMarketplace client={client!} docsBase={uiConfig?.docs_base || adminConfig?.branding?.docs_base} />}
               {toolsTab === 5 && <ScriptsTests client={client!} docsBase={uiConfig?.docs_base || adminConfig?.branding?.docs_base} canSend={canSend} readOnly={!isAdmin} />}
               {toolsTab === 6 && (
                 <TunnelSettings

api/admin_ui/src/components/PluginMarketplace.tsx

@@ -1,15 +1,46 @@
-import React, { useState } from 'react';
-import { Box, Typography, TextField, InputAdornment, Grid, Card, CardContent } from '@mui/material';
+import React, { useEffect, useState } from 'react';
+import { Box, Typography, TextField, InputAdornment, Grid, Card, CardContent, Alert, CircularProgress } from '@mui/material';
 import SearchIcon from '@mui/icons-material/Search';
+import { AdminAPIClient } from '../api/client';
 
 /**
  * Minimal placeholder for the Admin Console Plugin Marketplace.
  * - Strict TypeScript compliant (no unused vars)
  * - Not wired into the App shell yet; safe to compile
  * - No provider name checks; trait‑gated wiring will come in later PRs
  */
-export default function PluginMarketplace(): JSX.Element {
+type Props = { client: AdminAPIClient; docsBase?: string };
+
+export default function PluginMarketplace({ client, docsBase }: Props): JSX.Element {
   const [query, setQuery] = useState('');
+  const [loading, setLoading] = useState(false);
+  const [plugins, setPlugins] = useState<Array<{ id: string; name?: string; description?: string }>>([]);
+  const [disabled, setDisabled] = useState(false);
+
+  useEffect(() => {
+    let cancelled = false;
+    const run = async () => {
+      setLoading(true);
+      try {
+        const res = await fetch(`${window.location.origin}/admin/marketplace/plugins`, {
+          headers: { 'X-API-Key': (client as any).apiKey || '' },
+        });
+        if (res.status === 404) {
+          if (!cancelled) setDisabled(true);
+          return;
+        }
+        if (!res.ok) throw new Error(`HTTP ${res.status}`);
+        const data = await res.json();
+        if (!cancelled) setPlugins(Array.isArray(data?.plugins) ? data.plugins : []);
+      } catch {
+        if (!cancelled) setDisabled(true);
+      } finally {
+        if (!cancelled) setLoading(false);
+      }
+    };
+    run();
+    return () => { cancelled = true; };
+  }, [client]);
 
   return (
     <Box sx={{ px: { xs: 1, sm: 2, md: 3 }, py: 2 }}>
@@ -32,19 +63,46 @@ export default function PluginMarketplace(): JSX.Element {
         sx={{ mb: 3 }}
       />
 
+      {disabled && (
+        <Alert severity="info" sx={{ mb: 2 }}>
+          Plugin Marketplace is disabled. Enable by setting <code>ADMIN_MARKETPLACE_ENABLED=true</code>.
+          {docsBase && (
+            <>
+              {' '}Learn more at <a href={`${docsBase}/admin/marketplace`} target="_blank" rel="noreferrer">docs</a>.
+            </>
+          )}
+        </Alert>
+      )}
+
+      {loading && <CircularProgress size={20} sx={{ mb: 2 }} />}
+
       <Grid container spacing={2}>
         {/* Empty state placeholder; results will be populated in later PRs */}
         <Grid item xs={12}>
           <Card variant="outlined">
             <CardContent>
-              <Typography color="text.secondary">
-                Marketplace results will appear here. Use traits to gate provider‑specific UI.
-              </Typography>
+              {plugins.length === 0 ? (
+                <Typography color="text.secondary">
+                  {disabled ? 'Marketplace is currently disabled.' : 'No plugins found.'}
+                </Typography>
+              ) : (
+                <>
+                  {plugins
+                    .filter(p => (query ? (p.name || '').toLowerCase().includes(query.toLowerCase()) : true))
+                    .map(p => (
+                      <Box key={p.id} sx={{ mb: 1 }}>
+                        <Typography variant="subtitle1">{p.name || p.id}</Typography>
+                        {p.description && (
+                          <Typography variant="body2" color="text.secondary">{p.description}</Typography>
+                        )}
+                      </Box>
+                    ))}
+                </>
+              )}
             </CardContent>
           </Card>
         </Grid>
       </Grid>
     </Box>
   );
 }
-

api/app/routers/admin_marketplace.py

@@ -37,3 +37,15 @@ def list_plugins():
     # Placeholder: will be populated via trait‑aware registry in later PRs
     return {"plugins": []}
 
+
+@router.post("/install")
+def install_plugin(payload: Dict[str, Any] | None = None):
+    """Remote install a plugin (disabled by default).
+
+    Gate with ADMIN_MARKETPLACE_REMOTE_INSTALL_ENABLED=false by default.
+    """
+    remote_enabled = os.getenv("ADMIN_MARKETPLACE_REMOTE_INSTALL_ENABLED", "false").lower() in {"1", "true", "yes"}
+    if not remote_enabled:
+      raise HTTPException(503, detail="Remote install disabled")
+    # Placeholder only; actual implementation will be added later
+    return {"ok": False, "message": "not_implemented"}

api/app/sinch_service.py

@@ -3,6 +3,7 @@
 import logging
 import os
 import time
+import anyio
 
 from .config import settings, reload_settings
 
@@ -80,7 +81,9 @@ async def upload_file(self, file_path: str) -> int:
             url = f"{base}/projects/{self.project_id}/files"
             try:
                 async with httpx.AsyncClient(timeout=60.0) as client:
-                    files = {"file": (os.path.basename(file_path), open(file_path, "rb"), "application/pdf")}
+                    async with await anyio.open_file(file_path, 'rb') as f:
+                        content = await f.read()
+                    files = {"file": (os.path.basename(file_path), content, "application/pdf")}
                     if self._use_oauth():
                         try:
                             token = await self.get_access_token()
@@ -154,20 +157,21 @@ async def send_fax_file(self, to_number: str, file_path: str) -> Dict[str, Any]:
                 to = f"+{digits}"
         url = f"{self.base_url}/projects/{self.project_id}/faxes"
         async with httpx.AsyncClient(timeout=60.0) as client:
-            # httpx expects a mapping of field name → (filename, fileobj, content_type)
+            # httpx expects a mapping of field name → (filename, bytes, content_type)
             # For the additional text field, pass as data not files
-            with open(file_path, "rb") as fh:
-                files = {"file": (os.path.basename(file_path), fh, "application/pdf")}
-                data = {"to": to}
-                if self._use_oauth():
-                    try:
-                        token = await self.get_access_token()
-                        resp = await client.post(url, files=files, data=data, headers={"Authorization": f"Bearer {token}"})
-                    except Exception as e:
-                        logger.warning("Sinch OAuth send_fax_file failed; falling back to Basic: %s", e)
-                        resp = await client.post(url, files=files, data=data, auth=self._basic_auth())
-                else:
+            async with await anyio.open_file(file_path, 'rb') as fh:
+                content = await fh.read()
+            files = {"file": (os.path.basename(file_path), content, "application/pdf")}
+            data = {"to": to}
+            if self._use_oauth():
+                try:
+                    token = await self.get_access_token()
+                    resp = await client.post(url, files=files, data=data, headers={"Authorization": f"Bearer {token}"})
+                except Exception as e:
+                    logger.warning("Sinch OAuth send_fax_file failed; falling back to Basic: %s", e)
                     resp = await client.post(url, files=files, data=data, auth=self._basic_auth())
+            else:
+                resp = await client.post(url, files=files, data=data, auth=self._basic_auth())
             if resp.status_code >= 400:
                 raise RuntimeError(f"Sinch create fax error {resp.status_code}: {resp.text}")
             return resp.json()