LETS GOOOOOOOOOOOOOOOOOOOOOOOOO

backend/app/pipeline/ingest.py

@@ -578,30 +578,35 @@ def store_entries(
 def ingest_source(db: Session, source: Source, job: Job, max_posts: int) -> dict:
     source.sync_status = "syncing"
     update_job(db, job, status="running", progress=0.02, message="Contacting your feed")
+    # Fetch one past the plan cap so we can tell the user their archive holds more than was indexed.
+    fetch_limit = max_posts + 1
 
     if source.feed_url.startswith(SITE_PREFIX):
         update_job(db, job, message="Mapping your site")
         entries = crawl_site(
-            source.feed_url.removeprefix(SITE_PREFIX), max_posts,
+            source.feed_url.removeprefix(SITE_PREFIX), fetch_limit,
             on_found=lambda n: update_job(db, job, progress=0.05, message=f"Found {n} pages, reading them"),
             on_post=lambda done, total: update_job(db, job, progress=0.05 + 0.05 * done / total,
                                                    message=f"Read {done} of {total} pages"),
         )
         title = None
     else:
-        title, entries = fetch_feed(source.feed_url, max_posts)
+        title, entries = fetch_feed(source.feed_url, fetch_limit)
     source.title = source.title or title
-    if source.platform == "substack" and len(entries) < max_posts:
+    if source.platform == "substack" and len(entries) < fetch_limit:
         site = f"{urlparse(source.feed_url).scheme}://{urlparse(source.feed_url).netloc}"
         update_job(db, job, progress=0.05, message="Reading your Substack archive")
         try:
             entries += fetch_substack_archive(
-                site, {e.url for e in entries}, max_posts,
+                site, {e.url for e in entries}, fetch_limit,
                 on_page=lambda n: update_job(db, job, message=f"Found {len(entries) + n} posts in the archive"),
             )
         except (httpx.HTTPError, ValueError):
             log.warning("substack archive fetch failed for %s", site, exc_info=True)
 
+    capped = len(entries) > max_posts
+    entries = entries[:max_posts]
+
     def progress(done: int, total: int, post_title: str) -> None:
         update_job(db, job, progress=0.1 + 0.8 * done / total, message=f"{post_title[:80]} is in orbit")
 
@@ -612,7 +617,8 @@ def ingest_source(db: Session, source: Source, job: Job, max_posts: int) -> dict
     source.sync_error = None
     source.last_synced_at = datetime.now(UTC)
     db.commit()
-    return {"indexed": indexed, "skipped": skipped, "found": len(entries), "changed": [str(i) for i in changed]}
+    return {"indexed": indexed, "skipped": skipped, "found": len(entries), "limit": max_posts, "capped": capped,
+            "changed": [str(i) for i in changed]}
 
 
 def entry_from_upload(filename: str, content_type: str, data: bytes) -> FeedEntry:

backend/app/services/tts.py

@@ -289,6 +289,29 @@ def clone_voice(name: str, samples: list[tuple[str, bytes, str]], *, remove_back
     return resp.json()["voice_id"]
 
 
+def design_voice(description: str) -> list[dict]:
+    """Voice Design: three short previews of a new voice from a text description.
+    Each preview's generated_voice_id is temporary until saved with create_designed_voice."""
+    data = _request("POST", "/text-to-voice/design", attempts=2, timeout=90,
+                    json={"voice_description": description[:1000], "auto_generate_text": True}).json()
+    return [
+        {"generated_voice_id": p["generated_voice_id"], "audio": base64.b64decode(p["audio_base_64"]),
+         "seconds": p.get("duration_secs")}
+        for p in data.get("previews", []) if p.get("generated_voice_id") and p.get("audio_base_64")
+    ]
+
+
+def create_designed_voice(name: str, description: str, generated_voice_id: str) -> str:
+    """Turns a Voice Design preview into a permanent voice on the account."""
+    resp = _request("POST", "/text-to-voice/create-voice-from-preview", attempts=2, timeout=30, json={
+        "voice_name": name[:100],
+        "voice_description": (description or name)[:1000],
+        "generated_voice_id": generated_voice_id,
+        "labels": {"source": "notestack"},
+    })
+    return resp.json()["voice_id"]
+
+
 def delete_voice(voice_id: str) -> None:
     _request("DELETE", f"/voices/{voice_id}", attempts=2, timeout=30)
 

backend/app/worker.py

@@ -91,6 +91,8 @@ def handle_ingest(db: Session, job: Job):
             raise PermanentJobError(str(exc)) from exc
         raise
     _after_import(db, job, source.workspace_id, result.get("changed", []))
+    if result.get("capped"):
+        return Done(result, f"First {result['limit']} posts in orbit: your plan's limit. Upgrade to index the rest")
     return Done(result, f"All posts in orbit: {result['indexed']} new or updated")
 
 

frontend/src/pages/Welcome.tsx

@@ -1,16 +1,25 @@
 import { useEffect, useRef, useState, type FormEvent } from "react";
 import { Link, Navigate, useNavigate } from "react-router-dom";
-import { docsApi, notebooksApi, sourcesApi } from "../api/endpoints";
+import { docsApi, jobsApi, notebooksApi, sourcesApi } from "../api/endpoints";
 import type { Job, Source } from "../api/types";
 import Logo from "../components/Logo";
 import SkyCanvas from "../components/SkyCanvas";
-import { errorMessage, JobProgress } from "../components/ui";
+import { errorMessage, JobProgress, Tabs } from "../components/ui";
 import { useAuth } from "../hooks/useAuth";
 import { useJob } from "../hooks/useJob";
 import { PENDING_SOURCE_KEY } from "./Landing";
 
 type Step = "connect" | "indexing" | "goal" | "ready";
 type Goal = "ask" | "audio" | "launch";
+type Mode = "feed" | "url" | "file";
+
+const MODES: { id: Mode; label: string }[] = [
+  { id: "feed", label: "Blog or newsletter" },
+  { id: "url", label: "One article" },
+  { id: "file", label: "Upload files" },
+];
+
+const FILE_ACCEPT = ".md,.markdown,.txt,.html,.htm,.pdf,text/markdown,text/plain,text/html,application/pdf";
 
 const EXAMPLES = ["yourblog.com", "yourname.substack.com", "medium.com/@you"];
 
@@ -40,11 +49,25 @@ function takePending(): string {
   }
 }
 
-/** First run: connect a blog, watch it index, pick what to do first, land somewhere useful. */
+/** Resolves once every job has finished, so a multi-file upload only counts as indexed when all files are in. */
+async function waitForJobs(ids: string[]): Promise<void> {
+  let pending = ids;
+  while (pending.length) {
+    const jobs = await Promise.all(pending.map((id) => jobsApi.get(id).catch(() => null)));
+    pending = pending.filter((_, i) => jobs[i] && jobs[i]!.status !== "done" && jobs[i]!.status !== "failed");
+    if (pending.length) await new Promise((r) => setTimeout(r, 1500));
+  }
+}
+
+/** First run: connect a blog, import an article or upload files, watch it index, pick what to do first, land somewhere useful. */
 export default function Welcome() {
   const { user, loading } = useAuth();
   const navigate = useNavigate();
   const [step, setStep] = useState<Step>("connect");
+  const [mode, setMode] = useState<Mode>("feed");
+  const [files, setFiles] = useState<File[]>([]);
+  const [dragging, setDragging] = useState(false);
+  const earlierJobs = useRef<string[]>([]);
   const [url, setUrl] = useState(takePending);
   const [busy, setBusy] = useState(false);
   const [error, setError] = useState<string | null>(null);
@@ -56,27 +79,57 @@ export default function Welcome() {
 
   const live = useJob(job, async (j) => {
     if (j.status !== "done") return;
+    await waitForJobs(earlierJobs.current);
     const list = await docsApi.list({ limit: 1 });
     setPosts(list.total);
     setStep((s) => (s === "indexing" ? "goal" : s === "goal" ? "goal" : "ready"));
   });
 
-  const connect = async (value: string) => {
+  const connect = async (value: string, as: Mode = "feed") => {
     if (!value.trim()) return;
     setBusy(true);
     setError(null);
     try {
-      const res = await sourcesApi.connect(value.trim());
+      const res = as === "url" ? await sourcesApi.importUrl(value.trim()) : await sourcesApi.connect(value.trim());
+      earlierJobs.current = [];
       setSource(res.source);
       setJob(res.job);
       setStep("indexing");
     } catch (e) {
-      setError(errorMessage(e, "We could not reach that address."));
+      setError(errorMessage(e, as === "url" ? "We could not import that page." : "We could not reach that address."));
     } finally {
       setBusy(false);
     }
   };
 
+  const upload = async () => {
+    if (!files.length) return;
+    setBusy(true);
+    setError(null);
+    try {
+      // One import job per file: the last drives the progress bar, the rest are awaited before moving on.
+      const jobs: Job[] = [];
+      let res: Awaited<ReturnType<typeof sourcesApi.importFile>> | null = null;
+      for (const f of files) {
+        res = await sourcesApi.importFile(f);
+        jobs.push(res.job);
+      }
+      earlierJobs.current = jobs.slice(0, -1).map((j) => j.id);
+      setSource(res!.source);
+      setJob(res!.job);
+      setStep("indexing");
+    } catch (e) {
+      setError(errorMessage(e, "That upload did not go through."));
+    } finally {
+      setBusy(false);
+    }
+  };
+
+  const addFiles = (list: FileList | null) => {
+    const picked = Array.from(list ?? []);
+    if (picked.length) setFiles((cur) => [...cur, ...picked.filter((f) => !cur.some((c) => c.name === f.name && c.size === f.size))]);
+  };
+
   // A URL pasted on the landing page starts connecting straight away.
   useEffect(() => {
     if (url && !autoStarted.current && user) {
@@ -91,6 +144,9 @@ export default function Welcome() {
 
   const indexingDone = live?.status === "done";
   const indexingFailed = live?.status === "failed";
+  // The ingest job reports when the plan's post cap cut the archive short.
+  const capped = live?.result?.capped === true;
+  const capLimit = Number(live?.result?.limit ?? posts);
   const first = (user.name ?? user.email).split(/[ @]/)[0];
 
   const finish = async (chosen: Goal | null) => {
@@ -109,7 +165,8 @@ export default function Welcome() {
 
   const submit = (e: FormEvent) => {
     e.preventDefault();
-    void connect(url);
+    if (mode === "file") void upload();
+    else void connect(url, mode);
   };
 
   const stepIndex = { connect: 0, indexing: 1, goal: 2, ready: 3 }[step];
@@ -136,40 +193,93 @@ export default function Welcome() {
         {step === "connect" && (
           <section className="card welcome-card">
             <p className="eyebrow">Welcome aboard, {first}</p>
-            <h1>Where do you publish?</h1>
-            <p className="muted">
-              Paste any blog, newsletter or site: Substack, Ghost, WordPress, Medium or anything with a feed. We find the feed, pull in your archive and turn it into a research notebook you can
-              question, hear and launch from.
+            <h1>Where does your writing live?</h1>
+            <p className="muted">Bring it in however suits you. We turn it into a research notebook you can question, hear and launch from.</p>
+            <Tabs<Mode>
+              tabs={MODES}
+              value={mode}
+              onChange={(m) => {
+                setMode(m);
+                setError(null);
+              }}
+            />
+            <p className="muted small">
+              {mode === "feed" && "Substack, Ghost, WordPress, Medium or anything with a feed. We find the feed, pull in your archive and keep it in sync."}
+              {mode === "url" && "Any single article on the web. Add more later from Sources."}
+              {mode === "file" && "Markdown, text, HTML or PDF: drafts, exports and posts that never had a feed. Add as many as you like."}
             </p>
             <form onSubmit={submit} className="welcome-form">
-              <input
-                className="input"
-                autoFocus
-                placeholder="yourblog.com"
-                value={url}
-                onChange={(e) => setUrl(e.target.value)}
-                aria-label="Blog, newsletter or site address"
-              />
-              <button className="btn btn-primary" disabled={busy || !url.trim()}>
-                {busy ? "Finding your feed..." : "Connect"}
+              {mode === "file" ? (
+                <label
+                  className={`welcome-drop${dragging ? " over" : ""}`}
+                  onDragOver={(e) => {
+                    e.preventDefault();
+                    setDragging(true);
+                  }}
+                  onDragLeave={() => setDragging(false)}
+                  onDrop={(e) => {
+                    e.preventDefault();
+                    setDragging(false);
+                    addFiles(e.dataTransfer.files);
+                  }}
+                >
+                  <input
+                    type="file"
+                    multiple
+                    accept={FILE_ACCEPT}
+                    onChange={(e) => {
+                      addFiles(e.target.files);
+                      e.target.value = "";
+                    }}
+                    aria-label="Files to upload"
+                  />
+                  <strong>Drop files here or click to choose</strong>
+                  <span className="mono muted small">.md · .txt · .html · .pdf</span>
+                </label>
+              ) : (
+                <input
+                  key={mode}
+                  className="input"
+                  autoFocus
+                  placeholder={mode === "feed" ? "yourblog.com" : "https://example.com/my-essay"}
+                  value={url}
+                  onChange={(e) => setUrl(e.target.value)}
+                  aria-label={mode === "feed" ? "Blog, newsletter or site address" : "Article URL"}
+                />
+              )}
+              {mode === "file" && files.length > 0 && (
+                <ul className="welcome-files mono small">
+                  {files.map((f) => (
+                    <li key={`${f.name}-${f.size}`}>
+                      <span>{f.name}</span>
+                      <button type="button" className="link-btn small" onClick={() => setFiles(files.filter((x) => x !== f))} aria-label={`Remove ${f.name}`}>
+                        Remove
+                      </button>
+                    </li>
+                  ))}
+                </ul>
+              )}
+              <button className="btn btn-primary" disabled={busy || (mode === "file" ? !files.length : !url.trim())}>
+                {mode === "feed" && (busy ? "Finding your feed..." : "Connect")}
+                {mode === "url" && (busy ? "Importing..." : "Import")}
+                {mode === "file" && (busy ? "Uploading..." : files.length === 1 ? "Upload 1 file" : `Upload ${files.length || ""} files`.replace("  ", " "))}
               </button>
             </form>
-            <div className="welcome-examples mono muted">
-              Try:{" "}
-              {EXAMPLES.map((ex) => (
-                <button key={ex} type="button" className="chip" onClick={() => setUrl(ex)}>
-                  {ex}
-                </button>
-              ))}
-            </div>
+            {mode === "feed" && (
+              <div className="welcome-examples mono muted">
+                Try:{" "}
+                {EXAMPLES.map((ex) => (
+                  <button key={ex} type="button" className="chip" onClick={() => setUrl(ex)}>
+                    {ex}
+                  </button>
+                ))}
+              </div>
+            )}
             {error && (
               <p className="error-text" role="alert">
                 {error}
               </p>
             )}
-            <p className="muted small">
-              Writing in markdown or no feed? <Link to="/app/sources">Upload markdown, text, HTML or PDF files, or import single pages</Link> instead.
-            </p>
           </section>
         )}
 
@@ -181,7 +291,7 @@ export default function Welcome() {
             {indexingFailed ? (
               <div className="row">
                 <button className="btn btn-primary" onClick={() => setStep("connect")}>
-                  Try another address
+                  Try again
                 </button>
                 <Link className="btn" to="/app/sources">
                   Import posts another way
@@ -200,8 +310,26 @@ export default function Welcome() {
 
         {step === "goal" && (
           <section className="card welcome-card">
-            <p className="eyebrow">{indexingDone ? `${posts} posts indexed` : "Still indexing in the background"}</p>
+            <p className="eyebrow">{indexingDone ? (capped ? `${posts} posts indexed, free plan limit` : `${posts} posts indexed`) : "Still indexing in the background"}</p>
             <h1>What should we launch first?</h1>
+            {capped && (
+              <div className="welcome-cap">
+                <div>
+                  <strong>Your free plan indexed your newest {capLimit} posts</strong>
+                  <p className="muted small">Your archive has more. Upgrade to bring every post into orbit, so answers, audio and Launch Kits draw on all of it.</p>
+                </div>
+                <button
+                  type="button"
+                  className="btn btn-small"
+                  onClick={() => {
+                    markOnboarded();
+                    navigate("/app?upgrade=1", { replace: true });
+                  }}
+                >
+                  Index everything
+                </button>
+              </div>
+            )}
             <div className="goal-grid">
               {GOALS.map((g) => (
                 <button key={g.id} type="button" className={`goal${goal === g.id ? " on" : ""}`} onClick={() => setGoal(g.id)} aria-pressed={goal === g.id}>
@@ -224,6 +352,24 @@ export default function Welcome() {
             <p className="eyebrow">Pre-flight check complete</p>
             <h1>{indexingDone ? `${posts} posts are in orbit` : "Almost there"}</h1>
             {!indexingDone && live && <JobProgress job={live} />}
+            {capped && (
+              <div className="welcome-cap">
+                <div>
+                  <strong>Your free plan indexed your newest {capLimit} posts</strong>
+                  <p className="muted small">Your archive has more. Upgrade to bring every post into orbit, so answers, audio and Launch Kits draw on all of it.</p>
+                </div>
+                <button
+                  type="button"
+                  className="btn btn-small"
+                  onClick={() => {
+                    markOnboarded();
+                    navigate("/app?upgrade=1", { replace: true });
+                  }}
+                >
+                  Index everything
+                </button>
+              </div>
+            )}
             <p className="muted">
               {goal === "ask" && "We will put your whole archive in a notebook so you can start asking right away."}
               {goal === "audio" && "We will put your archive in a notebook with the audio studio ready."}

frontend/src/styles/pages.css

@@ -1464,6 +1464,68 @@ select.input option {
   padding: 0 28px;
 }
 
+.welcome-drop {
+  flex: 1 1 100%;
+  display: grid;
+  place-items: center;
+  gap: 4px;
+  padding: 28px 16px;
+  border: 1px dashed var(--line-strong);
+  border-radius: var(--radius-sm);
+  text-align: center;
+  cursor: pointer;
+  transition: border-color 0.2s, background 0.2s;
+}
+
+.welcome-drop:hover,
+.welcome-drop.over,
+.welcome-drop:focus-within {
+  border-color: var(--blue);
+  background: var(--blue-05);
+}
+
+.welcome-drop input {
+  position: absolute;
+  width: 1px;
+  height: 1px;
+  opacity: 0;
+}
+
+.welcome-files {
+  flex: 1 1 100%;
+  list-style: none;
+  margin: 0;
+  padding: 0;
+  display: grid;
+  gap: 4px;
+}
+
+.welcome-files li {
+  display: flex;
+  justify-content: space-between;
+  gap: 12px;
+  padding: 6px 10px;
+  border: 1px solid var(--line);
+  border-radius: var(--radius-sm);
+  overflow-wrap: anywhere;
+}
+
+.welcome-cap {
+  display: flex;
+  flex-wrap: wrap;
+  align-items: center;
+  justify-content: space-between;
+  gap: 12px;
+  padding: 14px 16px;
+  border: 1px solid var(--blue-35);
+  border-radius: var(--radius-sm);
+  background: var(--blue-05);
+}
+
+.welcome-cap p {
+  margin: 4px 0 0;
+}
+
 .welcome-examples {
   display: flex;
   flex-wrap: wrap;