Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
93cd6f2056 | ||
|
|
c5011d03e7 | ||
|
|
90890186c0 | ||
|
|
962c205d1d | ||
|
|
1bd346ce20 | ||
|
|
c0dd211ee5 | ||
|
|
cbdf5538aa | ||
|
|
f3e6fc8fa6 |
@@ -13,19 +13,28 @@ clicking an item copies it back to the clipboard.
|
|||||||
`NSStatusItem Preferred Position Prompt`). Left click toggles the panel,
|
`NSStatusItem Preferred Position Prompt`). Left click toggles the panel,
|
||||||
right click shows the menu (accessibility state, launch at login, open data
|
right click shows the menu (accessibility state, launch at login, open data
|
||||||
folder, quit). Contains the single-instance guard and `LoginItem`
|
folder, quit). Contains the single-instance guard and `LoginItem`
|
||||||
(`SMAppService`).
|
(`SMAppService`). Also sets `NSApp.mainMenu` with Hide Panel (Cmd+W) and Quit
|
||||||
|
(Cmd+Q) — an accessory app shows no menu bar, but the main menu still
|
||||||
|
services key equivalents, which is the only way to quit from the keyboard
|
||||||
|
while the panel has focus. `applicationShouldHandleReopen` shows the panel so
|
||||||
|
launching an already-running app does something. Supports `--sync-check` and
|
||||||
|
`--diag` (writes the status item's frame and permission state to
|
||||||
|
`/tmp/prompt-diag.txt`, then exits).
|
||||||
- `Sources/Prompt/Store.swift` — `@MainActor` `ObservableObject` singleton.
|
- `Sources/Prompt/Store.swift` — `@MainActor` `ObservableObject` singleton.
|
||||||
Data model: `Section` → `[PromptItem]`, item content is
|
Data model: `Section` → `[PromptItem]`, item content is
|
||||||
`.text(String)` or `.image(String)` (filename). Persists to
|
`.text(String)` or `.image(String)` (filename). Persists to
|
||||||
`~/Library/Application Support/Prompt/store.json`; images are PNG files in
|
`~/Library/Application Support/Prompt/store.json`; images are PNG files in
|
||||||
`Images/` next to it, cached in an `NSCache`. Owns all mutations (add,
|
`Images/` next to it, cached in an `NSCache`. Owns all mutations (add,
|
||||||
toggle done, edit, delete, move, merge, clear done) and clipboard writes
|
toggle done, edit, delete, move, merge, clear done) and clipboard writes
|
||||||
(`copy`, `copyAsList`). Saves on every mutation.
|
(`copy`, `copyAsList` for numbered output, `copyAsLines` for plain newlines;
|
||||||
|
both text modes skip image items). Saves on every mutation.
|
||||||
- `Sources/Prompt/PanelView.swift` — the panel UI. Header (section switcher,
|
- `Sources/Prompt/PanelView.swift` — the panel UI. Header (section switcher,
|
||||||
search, add photos, close), item list, composer. Composer `# Name` creates/
|
search, add photos, close), item list, composer. Composer `# Name` creates/
|
||||||
switches sections. Click = copy; Cmd+click = multi-select; right-click =
|
switches sections. Click = copy; Cmd+click toggles multi-select, Shift+click
|
||||||
context menu (Copy, Copy as List, Done, Edit, Open, Merge, Move To, Delete).
|
selects a range, and a selection bar offers Copy as List / Copy as Lines;
|
||||||
Drop target for images/files.
|
right-click = context menu (Copy, Copy as List, Copy as Lines, Done, Edit,
|
||||||
|
Open, Merge, Move To, Delete). Esc clears the selection before it hides the
|
||||||
|
panel. Drop target for images/files.
|
||||||
- `Sources/Prompt/PanelController.swift` — owns the floating `NSPanel`
|
- `Sources/Prompt/PanelController.swift` — owns the floating `NSPanel`
|
||||||
(`.nonactivatingPanel`, `.floating`, right-edge docked, frame autosaved as
|
(`.nonactivatingPanel`, `.floating`, right-edge docked, frame autosaved as
|
||||||
`PromptPanel`), the Cmd+V image-paste monitor, and `EditWindowController`
|
`PromptPanel`), the Cmd+V image-paste monitor, and `EditWindowController`
|
||||||
@@ -40,8 +49,16 @@ clicking an item copies it back to the clipboard.
|
|||||||
a global queue); only the store append hops back to main.
|
a global queue); only the store append hops back to main.
|
||||||
- `Sources/Prompt/SyncService.swift` — optional sync client. Holds the group
|
- `Sources/Prompt/SyncService.swift` — optional sync client. Holds the group
|
||||||
code and server URL in `UserDefaults` (`sync.code`, `sync.serverURL`,
|
code and server URL in `UserDefaults` (`sync.code`, `sync.serverURL`,
|
||||||
`sync.version`), pushes the whole store as JSON, and polls every 5s.
|
`sync.version`). The URL defaults to `SyncService.defaultServerURL`
|
||||||
|
(`https://prompt.tzgyn.dev`); nothing is sent anywhere until a code exists,
|
||||||
|
because polling only runs when one is set. Pushes the whole store as JSON and
|
||||||
|
polls every 5s.
|
||||||
- `Server/main.go` — the Go sync backend (single file, `net/http` + `lib/pq`).
|
- `Server/main.go` — the Go sync backend (single file, `net/http` + `lib/pq`).
|
||||||
|
Also ships `Server/Dockerfile` (static binary on distroless) and
|
||||||
|
`Server/README.md` (self-hosting). Logs one line per request, creates its
|
||||||
|
schema on startup, shuts down gracefully on SIGTERM so a redeploy cannot cut
|
||||||
|
off a push, and supports `-healthcheck` (pings local `/healthz`) so the
|
||||||
|
shell-less image needs no curl for its Docker `HEALTHCHECK`.
|
||||||
|
|
||||||
## Sync protocol
|
## Sync protocol
|
||||||
|
|
||||||
@@ -53,6 +70,7 @@ payload as opaque `JSONB`; it never parses note contents.
|
|||||||
| --- | --- |
|
| --- | --- |
|
||||||
| `POST /api/codes` | Generates a unique code and inserts an empty group |
|
| `POST /api/codes` | Generates a unique code and inserts an empty group |
|
||||||
| `GET /api/sync/{code}` | `{"version":N,"updatedAt":…,"data":{…}\|null}`, 404 if unknown |
|
| `GET /api/sync/{code}` | `{"version":N,"updatedAt":…,"data":{…}\|null}`, 404 if unknown |
|
||||||
|
| `GET /api/sync/{code}/version` | `{"version":N}` — the cheap poll |
|
||||||
| `PUT /api/sync/{code}` | Upserts the payload, returns the incremented version |
|
| `PUT /api/sync/{code}` | Upserts the payload, returns the incremented version |
|
||||||
| `GET /healthz` | Liveness |
|
| `GET /healthz` | Liveness |
|
||||||
|
|
||||||
@@ -60,6 +78,9 @@ Client rules:
|
|||||||
|
|
||||||
- Payload = `{sections, activeSectionID, images}`, where `images` maps a
|
- Payload = `{sections, activeSectionID, images}`, where `images` maps a
|
||||||
filename to base64 PNG so photos travel with the notes.
|
filename to base64 PNG so photos travel with the notes.
|
||||||
|
- Polling is two-step: `GET /version` every 5s (tiny) and the full payload only
|
||||||
|
when the version moved. Fetching the payload unconditionally would re-download
|
||||||
|
every base64 photo every 5 seconds.
|
||||||
- Version counter is server-owned; the client stores the last version it saw
|
- Version counter is server-owned; the client stores the last version it saw
|
||||||
in `sync.version` and only applies a remote payload when `remote.version >
|
in `sync.version` and only applies a remote payload when `remote.version >
|
||||||
lastVersion`.
|
lastVersion`.
|
||||||
@@ -135,10 +156,19 @@ brew upgrade --cask prompt
|
|||||||
|
|
||||||
## Gotchas
|
## Gotchas
|
||||||
|
|
||||||
|
- **Setting `NSApp.mainMenu` replaces SwiftUI's default menu.** SwiftUI installs
|
||||||
|
a menu containing the standard Edit items, and AppKit routes Cmd+C/V/X/A/Z
|
||||||
|
through those items — so a hand-built menu with only Hide/Quit silently
|
||||||
|
breaks pasting, copying and select-all in the composer. `setupMainMenu()`
|
||||||
|
therefore rebuilds an Edit menu with `undo:`/`redo:`/`cut:`/`copy:`/`paste:`/
|
||||||
|
`selectAll:` (nil targets, so they travel the responder chain to the field
|
||||||
|
editor). `Prompt --diag` dumps the menu so this can be checked without a
|
||||||
|
keyboard.
|
||||||
- **Never bind bare keys as `.keyboardShortcut` in the panel** (Space, Delete,
|
- **Never bind bare keys as `.keyboardShortcut` in the panel** (Space, Delete,
|
||||||
plain Cmd+C). SwiftUI key equivalents are matched before text input and
|
plain Cmd+C). SwiftUI key equivalents are matched before text input and
|
||||||
would steal characters from the composer TextField. Only Cmd-modified
|
would steal characters from the composer TextField. Only Cmd-modified
|
||||||
shortcuts that TextFields don't use are bound (Cmd+F/K/N, Shift+Cmd+C).
|
shortcuts that TextFields don't use are bound (Cmd+F/K/N, Shift+Cmd+C,
|
||||||
|
Option+Cmd+C).
|
||||||
This is why Copy has no in-panel shortcut: click-to-copy is the primary
|
This is why Copy has no in-panel shortcut: click-to-copy is the primary
|
||||||
gesture, matching Copper's intent.
|
gesture, matching Copper's intent.
|
||||||
- The panel is a `.nonactivatingPanel`; its `canBecomeKey` override is what
|
- The panel is a `.nonactivatingPanel`; its `canBecomeKey` override is what
|
||||||
@@ -155,7 +185,10 @@ brew upgrade --cask prompt
|
|||||||
the main thread (the hotkey handler already dispatches to a global queue).
|
the main thread (the hotkey handler already dispatches to a global queue).
|
||||||
- The double-Shift tap needs Accessibility; without it the event tap silently
|
- The double-Shift tap needs Accessibility; without it the event tap silently
|
||||||
fails and only the Carbon fallbacks work. The panel banner and the status
|
fails and only the Carbon fallbacks work. The panel banner and the status
|
||||||
menu both surface the permission state.
|
menu both surface the permission state, and `AppDelegate` shows a launch
|
||||||
|
alert when it is missing — otherwise a user who hides the panel is locked out
|
||||||
|
(no hotkey, no Dock icon) and reports it as "the app won't come back". Check
|
||||||
|
with `Prompt --diag` (`accessibility: false` is the tell).
|
||||||
- `Info.plist` sets `NSAllowsArbitraryLoads` because the sync server URL is
|
- `Info.plist` sets `NSAllowsArbitraryLoads` because the sync server URL is
|
||||||
user-supplied and is often plain HTTP (LAN address, self-hosted box). ATS
|
user-supplied and is often plain HTTP (LAN address, self-hosted box). ATS
|
||||||
would otherwise block it with a confusing error.
|
would otherwise block it with a confusing error.
|
||||||
|
|||||||
@@ -7,9 +7,13 @@ to your work. Click anything to copy it back to your clipboard.
|
|||||||
- **Click to copy** — text notes go back as text, photos go back as images.
|
- **Click to copy** — text notes go back as text, photos go back as images.
|
||||||
- **Capture from anywhere** — select text in any app and tap **Left Shift twice**.
|
- **Capture from anywhere** — select text in any app and tap **Left Shift twice**.
|
||||||
- **Photos** — paste (Cmd+V), drag & drop, or add via the photo button.
|
- **Photos** — paste (Cmd+V), drag & drop, or add via the photo button.
|
||||||
- **Sections** — type `# Name` in the composer; Cmd+K switches sections.
|
- **Workspaces** — type `# Name` in the composer, or use "New Workspace" in
|
||||||
- **Copy as List** — Cmd+click to multi-select, right-click → Copy as List
|
the Cmd+K switcher (which opens a name modal); Cmd+K switches, and the
|
||||||
(or Shift+Cmd+C) for a numbered list ready to paste into a chat.
|
up/down arrows in the switcher reorder them. (The code and the saved JSON
|
||||||
|
still call these `sections` so existing data keeps working.)
|
||||||
|
- **Copy as List / Copy as Lines** — Cmd+click to multi-select (Shift+click for
|
||||||
|
a range), then copy the selection as a numbered list or as plain
|
||||||
|
newline-separated text, from the selection bar or the right-click menu.
|
||||||
- **Merge Notes, Mark as Done, Edit, Move To** — right-click any item.
|
- **Merge Notes, Mark as Done, Edit, Move To** — right-click any item.
|
||||||
- **Search** — Cmd+F searches across all sections.
|
- **Search** — Cmd+F searches across all sections.
|
||||||
- **Sync (optional)** — generate an 8-digit code (`1234-5678`) on one Mac and
|
- **Sync (optional)** — generate an 8-digit code (`1234-5678`) on one Mac and
|
||||||
@@ -24,18 +28,21 @@ to your work. Click anything to copy it back to your clipboard.
|
|||||||
| --- | --- |
|
| --- | --- |
|
||||||
| Capture current selection | Left Shift ×2 (or Cmd+Shift+C) |
|
| Capture current selection | Left Shift ×2 (or Cmd+Shift+C) |
|
||||||
| Show/hide panel | Right Shift ×2 (or Cmd+Shift+Space) |
|
| Show/hide panel | Right Shift ×2 (or Cmd+Shift+Space) |
|
||||||
| Switch/create section | Cmd+K |
|
| Switch/create workspace | Cmd+K |
|
||||||
| Search | Cmd+F |
|
| Search | Cmd+F |
|
||||||
| Focus composer | Cmd+N |
|
| Focus composer | Cmd+N |
|
||||||
| Sync settings | Cmd+, |
|
| Sync settings | Cmd+, |
|
||||||
| Copy selection as numbered list | Shift+Cmd+C |
|
| Copy selection as numbered list | Shift+Cmd+C |
|
||||||
|
| Copy selection as plain lines | Option+Cmd+C |
|
||||||
|
| Clear selection | Esc |
|
||||||
| Close panel | Esc |
|
| Close panel | Esc |
|
||||||
|
|
||||||
Double-Shift gestures require **Accessibility access** (Prompt reads the
|
Double-Shift gestures require **Accessibility access** (Prompt reads the
|
||||||
selection by simulating Cmd+C, then restores your clipboard untouched). The
|
selection by simulating Cmd+C, then restores your clipboard untouched). Until
|
||||||
Cmd+Shift fallbacks work without it. Bare keys like Space and Cmd+C are
|
it is granted, use Cmd+Shift+Space and Cmd+Shift+C, or click the menu bar icon
|
||||||
deliberately not bound inside the panel so they never conflict with typing in
|
— and launching the app again always brings the panel back. Bare keys like
|
||||||
the composer.
|
Space and Cmd+C are deliberately not bound inside the panel so they never
|
||||||
|
conflict with typing in the composer.
|
||||||
|
|
||||||
## Install
|
## Install
|
||||||
|
|
||||||
@@ -58,17 +65,24 @@ PROMPT_SYNC_DATABASE_URL="postgres://localhost:5432/prompt_sync?sslmode=disable"
|
|||||||
go run . # listens on :8080
|
go run . # listens on :8080
|
||||||
```
|
```
|
||||||
|
|
||||||
Then in the panel: click the sync icon, set the server URL (e.g.
|
Or build the Docker image (`docker build -t prompt-sync Server/`) and point it
|
||||||
`http://192.168.1.10:8080` or an HTTPS host), and either **Generate Code** on
|
at your own Postgres — see [Server/README.md](Server/README.md) for that and for
|
||||||
the first Mac or paste the code into **Join** on the other.
|
deploying to a host.
|
||||||
|
|
||||||
|
Then in the panel: click the sync icon (or Cmd+,), confirm the server URL, and
|
||||||
|
either **Generate Code** on the first Mac or paste the code into **Join** on the
|
||||||
|
other.
|
||||||
|
|
||||||
Notes:
|
Notes:
|
||||||
|
|
||||||
- Both Macs must be able to reach the server. A LAN address or a Tailscale
|
- Sync defaults to `https://prompt.tzgyn.dev`; change it in the sync panel to
|
||||||
hostname works; `localhost` only works if the server runs on the same Mac.
|
point at your own server. Both Macs must be able to reach it — a LAN address
|
||||||
|
or a Tailscale hostname works, and `localhost` only works if the server runs
|
||||||
|
on the same Mac. See [Server/README.md](Server/README.md) to deploy it.
|
||||||
- Joining a group that already has notes replaces what's on that Mac.
|
- Joining a group that already has notes replaces what's on that Mac.
|
||||||
- The app polls every 5 seconds and pushes 1.5s after a change; last write
|
- The app polls every 5 seconds (a tiny version check) and pushes 1.5s after a
|
||||||
wins. Changes that came from the server are not echoed back.
|
change; last write wins, and changes that came from the server are not echoed
|
||||||
|
back.
|
||||||
- Verify sync from a terminal with `Prompt --sync-check`.
|
- Verify sync from a terminal with `Prompt --sync-check`.
|
||||||
|
|
||||||
## Build from source
|
## Build from source
|
||||||
|
|||||||
@@ -0,0 +1,4 @@
|
|||||||
|
.git
|
||||||
|
prompt-sync
|
||||||
|
prompt-sync-*
|
||||||
|
*.md
|
||||||
@@ -0,0 +1,27 @@
|
|||||||
|
# Build stage: the server is pure Go (lib/pq is pure Go), so CGO is off and the
|
||||||
|
# result is a static binary that runs on a shell-less base image.
|
||||||
|
FROM golang:1.26-alpine AS build
|
||||||
|
|
||||||
|
WORKDIR /src
|
||||||
|
COPY go.mod go.sum ./
|
||||||
|
RUN go mod download
|
||||||
|
COPY *.go ./
|
||||||
|
|
||||||
|
ARG TARGETOS
|
||||||
|
ARG TARGETARCH
|
||||||
|
RUN CGO_ENABLED=0 GOOS=${TARGETOS:-linux} GOARCH=${TARGETARCH} \
|
||||||
|
go build -trimpath -ldflags="-s -w" -o /prompt-sync .
|
||||||
|
|
||||||
|
# Runtime stage: distroless has no shell, so the binary does its own
|
||||||
|
# healthcheck (see -healthcheck in main.go). Runs as non-root.
|
||||||
|
FROM gcr.io/distroless/static-debian12:nonroot
|
||||||
|
|
||||||
|
COPY --from=build /prompt-sync /prompt-sync
|
||||||
|
|
||||||
|
ENV PROMPT_SYNC_ADDR=:8080
|
||||||
|
EXPOSE 8080
|
||||||
|
|
||||||
|
HEALTHCHECK --interval=30s --timeout=3s --start-period=5s --retries=3 \
|
||||||
|
CMD ["/prompt-sync", "-healthcheck"]
|
||||||
|
|
||||||
|
ENTRYPOINT ["/prompt-sync"]
|
||||||
@@ -0,0 +1,116 @@
|
|||||||
|
# Prompt sync server
|
||||||
|
|
||||||
|
Small Go service that stores one JSON blob per sync group, keyed by an 8-digit
|
||||||
|
code (`1234-5678`). There is no authentication: the code is the shared secret,
|
||||||
|
so anyone who knows it can read and overwrite that group. It is meant to be
|
||||||
|
self-hosted for personal use, not exposed as a public service.
|
||||||
|
|
||||||
|
## Requirements
|
||||||
|
|
||||||
|
- Postgres (any recent version; developed against 18)
|
||||||
|
- A host both Macs can reach — a VPS, a home server, or a Tailscale node
|
||||||
|
|
||||||
|
## Run it
|
||||||
|
|
||||||
|
```bash
|
||||||
|
createdb prompt_sync
|
||||||
|
cd Server
|
||||||
|
PROMPT_SYNC_DATABASE_URL="postgres://localhost:5432/prompt_sync?sslmode=disable" \
|
||||||
|
go run . # or: go build -o prompt-sync . && ./prompt-sync
|
||||||
|
```
|
||||||
|
|
||||||
|
| Env var | Default |
|
||||||
|
| --- | --- |
|
||||||
|
| `PROMPT_SYNC_ADDR` | `:8080` |
|
||||||
|
| `PROMPT_SYNC_DATABASE_URL` | `postgres://localhost:5432/prompt_sync?sslmode=disable` |
|
||||||
|
|
||||||
|
The schema is created on startup. Every request is logged as
|
||||||
|
`METHOD PATH STATUS DURATION`; SIGTERM/SIGINT shut down gracefully so an
|
||||||
|
in-flight push is not cut off mid-write. If the database is not reachable yet
|
||||||
|
it retries five times, 2s apart, before giving up.
|
||||||
|
|
||||||
|
> **`sslmode` matters.** lib/pq defaults to `sslmode=require`, so a connection
|
||||||
|
> string copied from a host that runs Postgres *without* TLS (Coolify's
|
||||||
|
> internal Postgres, a plain `docker run postgres`, Homebrew) fails with
|
||||||
|
> `pq: SSL is not enabled on the server`. Append `?sslmode=disable` in that
|
||||||
|
> case — the server prints exactly that hint when it hits this.
|
||||||
|
|
||||||
|
## Deploying with Coolify
|
||||||
|
|
||||||
|
Use a Dockerfile application pointed at this repo with base directory `Server/`
|
||||||
|
(so Coolify builds `Server/Dockerfile`), expose port `8080`, and set:
|
||||||
|
|
||||||
|
| Variable | Value |
|
||||||
|
| --- | --- |
|
||||||
|
| `PROMPT_SYNC_DATABASE_URL` | your Postgres URL **plus `?sslmode=disable`** |
|
||||||
|
| `PROMPT_SYNC_ADDR` | `:8080` (this is already the default) |
|
||||||
|
|
||||||
|
Coolify detects the `HEALTHCHECK` in the Dockerfile and runs
|
||||||
|
`prompt-sync -healthcheck` with its 5s start period, so the container only goes
|
||||||
|
live once `/healthz` answers. It also logs a generic warning that a healthcheck
|
||||||
|
needs `curl` or `wget` — that does not apply here, the binary does its own
|
||||||
|
check, so there is no reason to add either to the image (it is distroless and
|
||||||
|
has no shell).
|
||||||
|
|
||||||
|
## Run with Docker
|
||||||
|
|
||||||
|
The image is a static binary on `distroless` (non-root, no shell), so its
|
||||||
|
`HEALTHCHECK` calls `prompt-sync -healthcheck`, which pings the local
|
||||||
|
`/healthz` — no curl needed in the image. That is what `docker ps` reports as
|
||||||
|
the container health.
|
||||||
|
|
||||||
|
```bash
|
||||||
|
docker build -t prompt-sync Server/
|
||||||
|
docker run -d --name prompt-sync -p 8080:8080 \
|
||||||
|
-e PROMPT_SYNC_DATABASE_URL="postgres://user:pass@host:5432/prompt_sync?sslmode=disable" \
|
||||||
|
prompt-sync
|
||||||
|
|
||||||
|
docker logs -f prompt-sync # request log
|
||||||
|
```
|
||||||
|
|
||||||
|
Postgres stays outside the container; the server only needs a URL. If Postgres
|
||||||
|
runs on the Docker host itself, `host` is `host.docker.internal` on macOS and
|
||||||
|
Windows, or the host's LAN address on Linux (`--network host` also works).
|
||||||
|
|
||||||
|
## Deploy to a host
|
||||||
|
|
||||||
|
Build for the host's architecture and ship the image, or build it on the host
|
||||||
|
itself (a `git clone` plus `docker build` is usually simplest):
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# build on the Mac for a linux/arm64 host, then copy it over
|
||||||
|
docker build --platform linux/arm64 -t prompt-sync Server/
|
||||||
|
docker save prompt-sync | gzip > prompt-sync.tar.gz
|
||||||
|
scp prompt-sync.tar.gz <host>:
|
||||||
|
ssh <host> 'gunzip -c prompt-sync.tar.gz | docker load'
|
||||||
|
|
||||||
|
ssh <host> 'docker run -d --name prompt-sync --restart unless-stopped \
|
||||||
|
-p 8080:8080 \
|
||||||
|
-e PROMPT_SYNC_DATABASE_URL="postgres://user:pass@db-host:5432/prompt_sync?sslmode=disable" \
|
||||||
|
prompt-sync'
|
||||||
|
```
|
||||||
|
|
||||||
|
Put it behind TLS if it is reachable from the internet — the code is the only
|
||||||
|
secret, and it travels in the URL path. Both plain HTTP and HTTPS work from the
|
||||||
|
app; an HTTP URL is often fine over a LAN or Tailscale.
|
||||||
|
|
||||||
|
## Endpoints
|
||||||
|
|
||||||
|
| Method | Path | Behaviour |
|
||||||
|
| --- | --- | --- |
|
||||||
|
| `POST` | `/api/codes` | Generates a unique code, inserts an empty group |
|
||||||
|
| `GET` | `/api/sync/{code}` | `{"version":N,"updatedAt":…,"data":{…}\|null}`, 404 if unknown |
|
||||||
|
| `GET` | `/api/sync/{code}/version` | `{"version":N}` — cheap poll used by the app |
|
||||||
|
| `PUT` | `/api/sync/{code}` | Upserts the payload, returns the incremented version |
|
||||||
|
| `GET` | `/healthz` | Liveness (200) |
|
||||||
|
|
||||||
|
Payloads are opaque `JSONB`; the server never parses note contents. Bodies are
|
||||||
|
capped at 50 MB, which is generous enough for base64 photos.
|
||||||
|
|
||||||
|
## Backups
|
||||||
|
|
||||||
|
The whole state is one table, so `pg_dump prompt_sync` is a complete backup:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
pg_dump prompt_sync | gzip > prompt_sync-$(date +%F).sql.gz
|
||||||
|
```
|
||||||
+135
-6
@@ -6,6 +6,7 @@
|
|||||||
//
|
//
|
||||||
// POST /api/codes -> {"code":"1234-5678"} (create group)
|
// POST /api/codes -> {"code":"1234-5678"} (create group)
|
||||||
// GET /api/sync/{code} -> {"version":N,"data":{...}} (404 if unknown)
|
// GET /api/sync/{code} -> {"version":N,"data":{...}} (404 if unknown)
|
||||||
|
// GET /api/sync/{code}/version -> {"version":N} (cheap poll)
|
||||||
// PUT /api/sync/{code} -> {"version":N+1} (upsert payload)
|
// PUT /api/sync/{code} -> {"version":N+1} (upsert payload)
|
||||||
// GET /healthz -> 200
|
// GET /healthz -> 200
|
||||||
//
|
//
|
||||||
@@ -16,6 +17,7 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"crypto/rand"
|
"crypto/rand"
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
@@ -23,7 +25,10 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
|
"os/signal"
|
||||||
"regexp"
|
"regexp"
|
||||||
|
"strings"
|
||||||
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
_ "github.com/lib/pq"
|
_ "github.com/lib/pq"
|
||||||
@@ -44,6 +49,13 @@ type Server struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
// -healthcheck pings the local /healthz and exits non-zero on failure. It
|
||||||
|
// exists so the container image can run on a shell-less base (distroless),
|
||||||
|
// where there is no wget or curl for a HEALTHCHECK to use.
|
||||||
|
if len(os.Args) > 1 && os.Args[1] == "-healthcheck" {
|
||||||
|
os.Exit(healthcheck())
|
||||||
|
}
|
||||||
|
|
||||||
dsn := os.Getenv("PROMPT_SYNC_DATABASE_URL")
|
dsn := os.Getenv("PROMPT_SYNC_DATABASE_URL")
|
||||||
if dsn == "" {
|
if dsn == "" {
|
||||||
dsn = "postgres://localhost:5432/prompt_sync?sslmode=disable"
|
dsn = "postgres://localhost:5432/prompt_sync?sslmode=disable"
|
||||||
@@ -53,14 +65,11 @@ func main() {
|
|||||||
addr = ":8080"
|
addr = ":8080"
|
||||||
}
|
}
|
||||||
|
|
||||||
db, err := sql.Open("postgres", dsn)
|
db, err := openDatabase(dsn)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("open database: %v", err)
|
log.Fatalf("connect to database: %v%s", err, hintFor(err))
|
||||||
}
|
}
|
||||||
defer db.Close()
|
defer db.Close()
|
||||||
if err := db.Ping(); err != nil {
|
|
||||||
log.Fatalf("connect to database: %v", err)
|
|
||||||
}
|
|
||||||
if _, err := db.Exec(schema); err != nil {
|
if _, err := db.Exec(schema); err != nil {
|
||||||
log.Fatalf("ensure schema: %v", err)
|
log.Fatalf("ensure schema: %v", err)
|
||||||
}
|
}
|
||||||
@@ -69,13 +78,112 @@ func main() {
|
|||||||
mux := http.NewServeMux()
|
mux := http.NewServeMux()
|
||||||
mux.HandleFunc("POST /api/codes", s.createCode)
|
mux.HandleFunc("POST /api/codes", s.createCode)
|
||||||
mux.HandleFunc("GET /api/sync/{code}", s.getSync)
|
mux.HandleFunc("GET /api/sync/{code}", s.getSync)
|
||||||
|
mux.HandleFunc("GET /api/sync/{code}/version", s.getVersion)
|
||||||
mux.HandleFunc("PUT /api/sync/{code}", s.putSync)
|
mux.HandleFunc("PUT /api/sync/{code}", s.putSync)
|
||||||
mux.HandleFunc("GET /healthz", func(w http.ResponseWriter, _ *http.Request) {
|
mux.HandleFunc("GET /healthz", func(w http.ResponseWriter, _ *http.Request) {
|
||||||
w.WriteHeader(http.StatusOK)
|
w.WriteHeader(http.StatusOK)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
server := &http.Server{
|
||||||
|
Addr: addr,
|
||||||
|
Handler: withLogging(mux),
|
||||||
|
ReadHeaderTimeout: 10 * time.Second,
|
||||||
|
}
|
||||||
|
|
||||||
|
// Shut down cleanly so a redeploy (systemd restart, container stop) never
|
||||||
|
// cuts off an in-flight push and leaves a client thinking it failed.
|
||||||
|
stop := make(chan os.Signal, 1)
|
||||||
|
signal.Notify(stop, os.Interrupt, syscall.SIGTERM)
|
||||||
|
go func() {
|
||||||
|
<-stop
|
||||||
|
log.Println("shutting down")
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
_ = server.Shutdown(ctx)
|
||||||
|
}()
|
||||||
|
|
||||||
log.Printf("prompt-sync listening on %s", addr)
|
log.Printf("prompt-sync listening on %s", addr)
|
||||||
log.Fatal(http.ListenAndServe(addr, mux))
|
if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
|
||||||
|
log.Fatalf("serve: %v", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// openDatabase connects, retrying briefly so a deploy is not marked unhealthy
|
||||||
|
// just because Postgres was still starting up.
|
||||||
|
func openDatabase(dsn string) (*sql.DB, error) {
|
||||||
|
db, err := sql.Open("postgres", dsn)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
var lastErr error
|
||||||
|
for attempt := 1; attempt <= 5; attempt++ {
|
||||||
|
if lastErr = db.Ping(); lastErr == nil {
|
||||||
|
return db, nil
|
||||||
|
}
|
||||||
|
if attempt < 5 {
|
||||||
|
log.Printf("database not ready (attempt %d/5): %v", attempt, lastErr)
|
||||||
|
time.Sleep(2 * time.Second)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
db.Close()
|
||||||
|
return nil, lastErr
|
||||||
|
}
|
||||||
|
|
||||||
|
// hintFor turns the most common connection failure into something actionable.
|
||||||
|
// lib/pq defaults to sslmode=require, so any DSN copied from a host that runs
|
||||||
|
// Postgres without TLS (Coolify's internal Postgres, docker-compose, Homebrew)
|
||||||
|
// fails with a bare "SSL is not enabled on the server".
|
||||||
|
func hintFor(err error) string {
|
||||||
|
if !strings.Contains(err.Error(), "SSL is not enabled") {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
return "\n\nhint: lib/pq defaults to sslmode=require, but that Postgres has TLS off." +
|
||||||
|
"\n Append ?sslmode=disable to PROMPT_SYNC_DATABASE_URL" +
|
||||||
|
"\n (e.g. postgres://user:pass@host:5432/prompt_sync?sslmode=disable)."
|
||||||
|
}
|
||||||
|
|
||||||
|
// healthcheck returns 0 when the local /healthz answers 200.
|
||||||
|
func healthcheck() int {
|
||||||
|
addr := os.Getenv("PROMPT_SYNC_ADDR")
|
||||||
|
if addr == "" {
|
||||||
|
addr = ":8080"
|
||||||
|
}
|
||||||
|
if strings.HasPrefix(addr, ":") {
|
||||||
|
addr = "127.0.0.1" + addr
|
||||||
|
}
|
||||||
|
client := &http.Client{Timeout: 3 * time.Second}
|
||||||
|
response, err := client.Get("http://" + addr + "/healthz")
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("healthcheck: %v", err)
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
defer response.Body.Close()
|
||||||
|
if response.StatusCode != http.StatusOK {
|
||||||
|
log.Printf("healthcheck: unexpected status %d", response.StatusCode)
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|
||||||
|
// withLogging keeps a one-line trail of method, path, status and duration so a
|
||||||
|
// self-hosted deployment can be debugged from journalctl or docker logs.
|
||||||
|
func withLogging(next http.Handler) http.Handler {
|
||||||
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
started := time.Now()
|
||||||
|
recorder := &statusRecorder{ResponseWriter: w, status: http.StatusOK}
|
||||||
|
next.ServeHTTP(recorder, r)
|
||||||
|
log.Printf("%s %s %d %s", r.Method, r.URL.Path, recorder.status, time.Since(started).Round(time.Millisecond))
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
type statusRecorder struct {
|
||||||
|
http.ResponseWriter
|
||||||
|
status int
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *statusRecorder) WriteHeader(status int) {
|
||||||
|
r.status = status
|
||||||
|
r.ResponseWriter.WriteHeader(status)
|
||||||
}
|
}
|
||||||
|
|
||||||
// createCode generates a unique 8-digit code, formats it as 1234-5678, and
|
// createCode generates a unique 8-digit code, formats it as 1234-5678, and
|
||||||
@@ -136,6 +244,27 @@ func (s *Server) getSync(w http.ResponseWriter, r *http.Request) {
|
|||||||
version, updatedAt.UTC().Format(time.RFC3339), data)
|
version, updatedAt.UTC().Format(time.RFC3339), data)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// getVersion is the cheap poll: clients ask for the version every few seconds
|
||||||
|
// and only download the payload (which can carry base64 images) when it moved.
|
||||||
|
func (s *Server) getVersion(w http.ResponseWriter, r *http.Request) {
|
||||||
|
code := r.PathValue("code")
|
||||||
|
if !codePattern.MatchString(code) {
|
||||||
|
writeError(w, http.StatusBadRequest, "code must look like 1234-5678")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
var version int64
|
||||||
|
err := s.db.QueryRow(`SELECT version FROM sync_groups WHERE code = $1`, code).Scan(&version)
|
||||||
|
if err == sql.ErrNoRows {
|
||||||
|
writeError(w, http.StatusNotFound, "unknown code")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusInternalServerError, "database error")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
writeJSON(w, http.StatusOK, map[string]int64{"version": version})
|
||||||
|
}
|
||||||
|
|
||||||
func (s *Server) putSync(w http.ResponseWriter, r *http.Request) {
|
func (s *Server) putSync(w http.ResponseWriter, r *http.Request) {
|
||||||
code := r.PathValue("code")
|
code := r.PathValue("code")
|
||||||
if !codePattern.MatchString(code) {
|
if !codePattern.MatchString(code) {
|
||||||
|
|||||||
@@ -27,6 +27,19 @@ final class AppDelegate: NSObject, NSApplicationDelegate {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// --diag reports where the status item landed. On a notched Mac a
|
||||||
|
// brand-new item can be placed under the notch and be unclickable,
|
||||||
|
// which locks the user out once the panel is hidden.
|
||||||
|
if CommandLine.arguments.contains("--diag") {
|
||||||
|
setupStatusItem()
|
||||||
|
setupMainMenu()
|
||||||
|
DispatchQueue.main.asyncAfter(deadline: .now() + 1.0) {
|
||||||
|
self.writeDiagnostics()
|
||||||
|
NSApp.terminate(nil)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
// Single instance: stale copies keep their hotkeys alive after an
|
// Single instance: stale copies keep their hotkeys alive after an
|
||||||
// update and eat the events meant for the new instance.
|
// update and eat the events meant for the new instance.
|
||||||
let myPid = ProcessInfo.processInfo.processIdentifier
|
let myPid = ProcessInfo.processInfo.processIdentifier
|
||||||
@@ -47,6 +60,8 @@ final class AppDelegate: NSObject, NSApplicationDelegate {
|
|||||||
HotkeyManager.shared.start()
|
HotkeyManager.shared.start()
|
||||||
|
|
||||||
setupStatusItem()
|
setupStatusItem()
|
||||||
|
setupMainMenu()
|
||||||
|
promptForAccessibilityIfNeeded()
|
||||||
|
|
||||||
// Show the panel on launch so the app is discoverable (it has no Dock
|
// Show the panel on launch so the app is discoverable (it has no Dock
|
||||||
// icon and the menu bar icon can be hard to spot on a full bar).
|
// icon and the menu bar icon can be hard to spot on a full bar).
|
||||||
@@ -56,6 +71,119 @@ final class AppDelegate: NSObject, NSApplicationDelegate {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Without Accessibility the Shift-Shift gestures fail silently, so the
|
||||||
|
/// panel can be hidden with no obvious way back. Say so on launch and
|
||||||
|
/// point at the shortcut that works without the permission.
|
||||||
|
private func promptForAccessibilityIfNeeded() {
|
||||||
|
guard !AXIsProcessTrusted() else { return }
|
||||||
|
let alert = NSAlert()
|
||||||
|
alert.messageText = "Prompt needs Accessibility access"
|
||||||
|
alert.informativeText = """
|
||||||
|
Capturing with Shift-Shift (and showing the panel with right Shift twice) \
|
||||||
|
only works with Accessibility access.
|
||||||
|
|
||||||
|
Until it is granted, use Cmd+Shift+Space to show or hide the panel and \
|
||||||
|
Cmd+Shift+C to capture, or click the menu bar icon.
|
||||||
|
"""
|
||||||
|
alert.addButton(withTitle: "Open Settings")
|
||||||
|
alert.addButton(withTitle: "Later")
|
||||||
|
if alert.runModal() == .alertFirstButtonReturn {
|
||||||
|
let options = [kAXTrustedCheckOptionPrompt.takeUnretainedValue(): true] as CFDictionary
|
||||||
|
_ = AXIsProcessTrustedWithOptions(options)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// A launched-again app must reveal itself. Without this, `open` (or
|
||||||
|
/// clicking it in Finder/Spotlight) hits the running instance, which does
|
||||||
|
/// nothing, so the app looks like it never started.
|
||||||
|
@MainActor
|
||||||
|
func applicationShouldHandleReopen(_ sender: NSApplication, hasVisibleWindows flag: Bool) -> Bool {
|
||||||
|
PanelController.shared.show()
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
@MainActor
|
||||||
|
func applicationShouldTerminate(_ sender: NSApplication) -> NSApplication.TerminateReply {
|
||||||
|
// Stop the poll timer, any queued push, the event tap and the Carbon
|
||||||
|
// hotkeys so termination cannot be held up by a live callback.
|
||||||
|
SyncService.shared.stop()
|
||||||
|
HotkeyManager.shared.stop()
|
||||||
|
return .terminateNow
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Accessory apps have no visible menu bar, but the main menu still
|
||||||
|
/// services key equivalents — this is what makes Cmd+Q and Cmd+W work
|
||||||
|
/// while the panel has focus.
|
||||||
|
///
|
||||||
|
/// The Edit menu is not decoration: AppKit routes Cmd+C/V/X/A/Z through
|
||||||
|
/// these items, so a minimal main menu silently breaks pasting and
|
||||||
|
/// selecting in the composer.
|
||||||
|
private func setupMainMenu() {
|
||||||
|
let mainMenu = NSMenu()
|
||||||
|
|
||||||
|
let appMenuItem = NSMenuItem()
|
||||||
|
mainMenu.addItem(appMenuItem)
|
||||||
|
let appMenu = NSMenu(title: "Prompt")
|
||||||
|
appMenuItem.submenu = appMenu
|
||||||
|
|
||||||
|
let hide = NSMenuItem(title: "Hide Panel", action: #selector(hidePanel), keyEquivalent: "w")
|
||||||
|
hide.target = self
|
||||||
|
appMenu.addItem(hide)
|
||||||
|
appMenu.addItem(.separator())
|
||||||
|
let quit = NSMenuItem(title: "Quit Prompt", action: #selector(quit), keyEquivalent: "q")
|
||||||
|
quit.target = self
|
||||||
|
appMenu.addItem(quit)
|
||||||
|
|
||||||
|
let editMenuItem = NSMenuItem()
|
||||||
|
mainMenu.addItem(editMenuItem)
|
||||||
|
let editMenu = NSMenu(title: "Edit")
|
||||||
|
editMenuItem.submenu = editMenu
|
||||||
|
|
||||||
|
editMenu.addItem(withTitle: "Undo", action: Selector(("undo:")), keyEquivalent: "z")
|
||||||
|
let redo = editMenu.addItem(withTitle: "Redo", action: Selector(("redo:")), keyEquivalent: "z")
|
||||||
|
redo.keyEquivalentModifierMask = [.command, .shift]
|
||||||
|
editMenu.addItem(.separator())
|
||||||
|
editMenu.addItem(withTitle: "Cut", action: #selector(NSText.cut(_:)), keyEquivalent: "x")
|
||||||
|
editMenu.addItem(withTitle: "Copy", action: #selector(NSText.copy(_:)), keyEquivalent: "c")
|
||||||
|
editMenu.addItem(withTitle: "Paste", action: #selector(NSText.paste(_:)), keyEquivalent: "v")
|
||||||
|
editMenu.addItem(withTitle: "Select All", action: #selector(NSText.selectAll(_:)), keyEquivalent: "a")
|
||||||
|
|
||||||
|
NSApp.mainMenu = mainMenu
|
||||||
|
}
|
||||||
|
|
||||||
|
@MainActor @objc private func hidePanel() {
|
||||||
|
PanelController.shared.hide()
|
||||||
|
}
|
||||||
|
|
||||||
|
@MainActor
|
||||||
|
private func writeDiagnostics() {
|
||||||
|
var lines = ["Prompt diagnostics", "accessibility: \(AXIsProcessTrusted())"]
|
||||||
|
if let window = statusItem?.button?.window {
|
||||||
|
lines.append("status item frame: \(window.frame)")
|
||||||
|
if let screen = window.screen ?? NSScreen.main {
|
||||||
|
lines.append("screen: \(screen.frame) visible: \(screen.visibleFrame)")
|
||||||
|
lines.append("notch inset: \(screen.safeAreaInsets)")
|
||||||
|
let underNotch = window.frame.maxX > screen.frame.maxX - screen.safeAreaInsets.right
|
||||||
|
lines.append("under the notch: \(underNotch)")
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
lines.append("status item has no window (not in the menu bar)")
|
||||||
|
}
|
||||||
|
lines.append("preferred position: \(UserDefaults.standard.object(forKey: "NSStatusItem Preferred Position Prompt") ?? "unset")")
|
||||||
|
lines.append("main menu:")
|
||||||
|
for item in NSApp.mainMenu?.items ?? [] {
|
||||||
|
lines.append(" \(item.submenu?.title ?? item.title)")
|
||||||
|
for entry in item.submenu?.items ?? [] {
|
||||||
|
guard !entry.isSeparatorItem else { continue }
|
||||||
|
let action = entry.action.map(NSStringFromSelector) ?? "-"
|
||||||
|
lines.append(" \(entry.title) [\(entry.keyEquivalentModifierMask.rawValue)] \(action)")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
try? lines.joined(separator: "\n").write(
|
||||||
|
to: URL(fileURLWithPath: "/tmp/prompt-diag.txt"), atomically: true, encoding: .utf8
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
private func setupStatusItem() {
|
private func setupStatusItem() {
|
||||||
let item = NSStatusBar.system.statusItem(withLength: NSStatusItem.squareLength)
|
let item = NSStatusBar.system.statusItem(withLength: NSStatusItem.squareLength)
|
||||||
item.autosaveName = "Prompt"
|
item.autosaveName = "Prompt"
|
||||||
|
|||||||
@@ -34,6 +34,22 @@ final class HotkeyManager {
|
|||||||
registerFallbackHotkeys()
|
registerFallbackHotkeys()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func stop() {
|
||||||
|
if let tap = eventTap {
|
||||||
|
CGEvent.tapEnable(tap: tap, enable: false)
|
||||||
|
CFMachPortInvalidate(tap)
|
||||||
|
}
|
||||||
|
if let source = runLoopSource {
|
||||||
|
CFRunLoopRemoveSource(CFRunLoopGetMain(), source, .commonModes)
|
||||||
|
}
|
||||||
|
for ref in hotKeyRefs {
|
||||||
|
if let ref { UnregisterEventHotKey(ref) }
|
||||||
|
}
|
||||||
|
hotKeyRefs.removeAll()
|
||||||
|
eventTap = nil
|
||||||
|
runLoopSource = nil
|
||||||
|
}
|
||||||
|
|
||||||
// MARK: - Double-Shift event tap
|
// MARK: - Double-Shift event tap
|
||||||
|
|
||||||
private func startEventTap() {
|
private func startEventTap() {
|
||||||
|
|||||||
@@ -31,12 +31,14 @@ final class PanelController: NSObject {
|
|||||||
}
|
}
|
||||||
NSApp.activate(ignoringOtherApps: true)
|
NSApp.activate(ignoringOtherApps: true)
|
||||||
panel.makeKeyAndOrderFront(nil)
|
panel.makeKeyAndOrderFront(nil)
|
||||||
|
NSLog("Prompt: panel shown")
|
||||||
NotificationCenter.default.post(name: .promptPanelDidShow, object: nil)
|
NotificationCenter.default.post(name: .promptPanelDidShow, object: nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
func hide() {
|
func hide() {
|
||||||
panel?.orderOut(nil)
|
panel?.orderOut(nil)
|
||||||
NSApp.deactivate()
|
NSApp.deactivate()
|
||||||
|
NSLog("Prompt: panel hidden (app keeps running for the Shift-Shift hotkeys)")
|
||||||
}
|
}
|
||||||
|
|
||||||
private func makePanel() -> KeyablePanel {
|
private func makePanel() -> KeyablePanel {
|
||||||
|
|||||||
+192
-42
@@ -10,13 +10,16 @@ struct PanelView: View {
|
|||||||
@State private var search = ""
|
@State private var search = ""
|
||||||
@State private var showSearch = false
|
@State private var showSearch = false
|
||||||
@State private var showSectionSwitcher = false
|
@State private var showSectionSwitcher = false
|
||||||
|
@State private var showNewWorkspace = false
|
||||||
|
@State private var newWorkspaceName = ""
|
||||||
@State private var showSync = false
|
@State private var showSync = false
|
||||||
@State private var joinCode = ""
|
@State private var joinCode = ""
|
||||||
@State private var selection = Set<UUID>()
|
@State private var selection = Set<UUID>()
|
||||||
|
@State private var lastSelectedID: UUID?
|
||||||
@State private var copiedID: UUID?
|
@State private var copiedID: UUID?
|
||||||
@State private var accessibilityGranted = AXIsProcessTrusted()
|
@State private var accessibilityGranted = AXIsProcessTrusted()
|
||||||
|
|
||||||
private enum Field: Hashable { case composer, search }
|
private enum Field: Hashable { case composer, search, newWorkspace }
|
||||||
@FocusState private var focusedField: Field?
|
@FocusState private var focusedField: Field?
|
||||||
|
|
||||||
var body: some View {
|
var body: some View {
|
||||||
@@ -31,12 +34,16 @@ struct PanelView: View {
|
|||||||
Divider()
|
Divider()
|
||||||
content
|
content
|
||||||
Divider()
|
Divider()
|
||||||
|
if !selection.isEmpty {
|
||||||
|
selectionBar
|
||||||
|
}
|
||||||
composerField
|
composerField
|
||||||
}
|
}
|
||||||
.frame(minWidth: 300)
|
.frame(minWidth: 300)
|
||||||
.background(shortcutButtons)
|
.background(shortcutButtons)
|
||||||
.overlay(sectionSwitcher)
|
.overlay(sectionSwitcher)
|
||||||
.overlay(syncOverlay)
|
.overlay(syncOverlay)
|
||||||
|
.overlay(newWorkspaceModal)
|
||||||
.onDrop(of: [UTType.image.identifier, UTType.fileURL.identifier], isTargeted: nil, perform: handleDrop)
|
.onDrop(of: [UTType.image.identifier, UTType.fileURL.identifier], isTargeted: nil, perform: handleDrop)
|
||||||
.onReceive(NotificationCenter.default.publisher(for: .promptPanelDidShow)) { _ in
|
.onReceive(NotificationCenter.default.publisher(for: .promptPanelDidShow)) { _ in
|
||||||
focusedField = .composer
|
focusedField = .composer
|
||||||
@@ -62,7 +69,7 @@ struct PanelView: View {
|
|||||||
.foregroundStyle(.secondary)
|
.foregroundStyle(.secondary)
|
||||||
}
|
}
|
||||||
.buttonStyle(.plain)
|
.buttonStyle(.plain)
|
||||||
.help("Switch section (Cmd+K)")
|
.help("Switch workspace (Cmd+K)")
|
||||||
|
|
||||||
Spacer()
|
Spacer()
|
||||||
|
|
||||||
@@ -76,7 +83,8 @@ struct PanelView: View {
|
|||||||
Button { addPhotos() } label: { Image(systemName: "photo.on.rectangle.angled") }
|
Button { addPhotos() } label: { Image(systemName: "photo.on.rectangle.angled") }
|
||||||
.buttonStyle(.plain).foregroundStyle(.secondary).help("Add photos")
|
.buttonStyle(.plain).foregroundStyle(.secondary).help("Add photos")
|
||||||
Button { PanelController.shared.hide() } label: { Image(systemName: "xmark") }
|
Button { PanelController.shared.hide() } label: { Image(systemName: "xmark") }
|
||||||
.buttonStyle(.plain).foregroundStyle(.secondary).help("Close (Esc)")
|
.buttonStyle(.plain).foregroundStyle(.secondary)
|
||||||
|
.help("Hide the panel (Cmd+W) — Prompt keeps running so Shift-Shift capture still works. Quit from the menu bar icon or Cmd+Q.")
|
||||||
}
|
}
|
||||||
.padding(.horizontal, 12)
|
.padding(.horizontal, 12)
|
||||||
.padding(.vertical, 10)
|
.padding(.vertical, 10)
|
||||||
@@ -86,8 +94,13 @@ struct PanelView: View {
|
|||||||
HStack(spacing: 8) {
|
HStack(spacing: 8) {
|
||||||
Image(systemName: "exclamationmark.triangle.fill")
|
Image(systemName: "exclamationmark.triangle.fill")
|
||||||
.foregroundStyle(.yellow)
|
.foregroundStyle(.yellow)
|
||||||
Text("Shift-tap capture needs Accessibility access.")
|
VStack(alignment: .leading, spacing: 2) {
|
||||||
.font(.caption)
|
Text("Shift-tap capture needs Accessibility access.")
|
||||||
|
.font(.caption)
|
||||||
|
Text("Meanwhile: Cmd+Shift+Space toggles this panel.")
|
||||||
|
.font(.caption2)
|
||||||
|
.foregroundStyle(.secondary)
|
||||||
|
}
|
||||||
Spacer()
|
Spacer()
|
||||||
Button("Grant…") {
|
Button("Grant…") {
|
||||||
let options = [kAXTrustedCheckOptionPrompt.takeUnretainedValue(): true] as CFDictionary
|
let options = [kAXTrustedCheckOptionPrompt.takeUnretainedValue(): true] as CFDictionary
|
||||||
@@ -103,7 +116,7 @@ struct PanelView: View {
|
|||||||
private var searchField: some View {
|
private var searchField: some View {
|
||||||
HStack(spacing: 8) {
|
HStack(spacing: 8) {
|
||||||
Image(systemName: "magnifyingglass").foregroundStyle(.secondary)
|
Image(systemName: "magnifyingglass").foregroundStyle(.secondary)
|
||||||
TextField("Search all sections", text: $search)
|
TextField("Search all workspaces", text: $search)
|
||||||
.textFieldStyle(.plain)
|
.textFieldStyle(.plain)
|
||||||
.focused($focusedField, equals: .search)
|
.focused($focusedField, equals: .search)
|
||||||
.onExitCommand {
|
.onExitCommand {
|
||||||
@@ -217,6 +230,7 @@ struct PanelView: View {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
.buttonStyle(.plain)
|
.buttonStyle(.plain)
|
||||||
|
.help("Click to copy · Cmd+click to select several · Shift+click for a range · right-click for more")
|
||||||
.contextMenu { contextMenu(for: item) }
|
.contextMenu { contextMenu(for: item) }
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -256,7 +270,11 @@ struct PanelView: View {
|
|||||||
Button("Copy") { copy(item) }
|
Button("Copy") { copy(item) }
|
||||||
Button("Copy as List") {
|
Button("Copy as List") {
|
||||||
store.copyAsList(ids: effectiveIDs(for: item))
|
store.copyAsList(ids: effectiveIDs(for: item))
|
||||||
flashCopied(item)
|
flashCopied(item.id)
|
||||||
|
}
|
||||||
|
Button("Copy as Lines") {
|
||||||
|
store.copyAsLines(ids: effectiveIDs(for: item))
|
||||||
|
flashCopied(item.id)
|
||||||
}
|
}
|
||||||
Divider()
|
Divider()
|
||||||
Button(item.done ? "Mark as Not Done" : "Mark as Done") { store.toggleDone(item.id) }
|
Button(item.done ? "Mark as Not Done" : "Mark as Done") { store.toggleDone(item.id) }
|
||||||
@@ -273,7 +291,7 @@ struct PanelView: View {
|
|||||||
if selection.count > 1, selection.contains(item.id) {
|
if selection.count > 1, selection.contains(item.id) {
|
||||||
Button("Merge Notes") {
|
Button("Merge Notes") {
|
||||||
store.merge(ids: selection)
|
store.merge(ids: selection)
|
||||||
selection.removeAll()
|
clearSelection()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Menu("Move To") {
|
Menu("Move To") {
|
||||||
@@ -300,39 +318,57 @@ struct PanelView: View {
|
|||||||
}
|
}
|
||||||
.frame(maxWidth: .infinity, maxHeight: .infinity)
|
.frame(maxWidth: .infinity, maxHeight: .infinity)
|
||||||
VStack(spacing: 0) {
|
VStack(spacing: 0) {
|
||||||
ForEach(store.sections) { section in
|
ForEach(Array(store.sections.enumerated()), id: \.element.id) { index, section in
|
||||||
Button {
|
HStack(spacing: 6) {
|
||||||
|
Text(section.name)
|
||||||
|
.font(.callout)
|
||||||
|
Spacer()
|
||||||
|
Text("\(section.items.count)")
|
||||||
|
.font(.caption)
|
||||||
|
.foregroundStyle(.tertiary)
|
||||||
|
if section.id == store.activeSection.id {
|
||||||
|
Image(systemName: "checkmark")
|
||||||
|
.font(.caption)
|
||||||
|
.foregroundStyle(Color.accentColor)
|
||||||
|
}
|
||||||
|
// Reorder the workspace list; the boundary rows are
|
||||||
|
// disabled rather than hidden so the list does not jump.
|
||||||
|
HStack(spacing: 0) {
|
||||||
|
Button {
|
||||||
|
store.moveSection(section.id, by: -1)
|
||||||
|
} label: {
|
||||||
|
Image(systemName: "chevron.up")
|
||||||
|
}
|
||||||
|
.disabled(index == 0)
|
||||||
|
Button {
|
||||||
|
store.moveSection(section.id, by: 1)
|
||||||
|
} label: {
|
||||||
|
Image(systemName: "chevron.down")
|
||||||
|
}
|
||||||
|
.disabled(index == store.sections.count - 1)
|
||||||
|
}
|
||||||
|
.buttonStyle(.plain)
|
||||||
|
.font(.system(size: 9, weight: .bold))
|
||||||
|
.foregroundStyle(.tertiary)
|
||||||
|
}
|
||||||
|
.padding(.horizontal, 14)
|
||||||
|
.padding(.vertical, 8)
|
||||||
|
.contentShape(Rectangle())
|
||||||
|
.onTapGesture {
|
||||||
store.activeSectionID = section.id
|
store.activeSectionID = section.id
|
||||||
showSectionSwitcher = false
|
showSectionSwitcher = false
|
||||||
} label: {
|
|
||||||
HStack {
|
|
||||||
Text(section.name)
|
|
||||||
.font(.callout)
|
|
||||||
Spacer()
|
|
||||||
Text("\(section.items.count)")
|
|
||||||
.font(.caption)
|
|
||||||
.foregroundStyle(.tertiary)
|
|
||||||
if section.id == store.activeSection.id {
|
|
||||||
Image(systemName: "checkmark")
|
|
||||||
.font(.caption)
|
|
||||||
.foregroundStyle(Color.accentColor)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
.padding(.horizontal, 14)
|
|
||||||
.padding(.vertical, 8)
|
|
||||||
.contentShape(Rectangle())
|
|
||||||
}
|
}
|
||||||
.buttonStyle(.plain)
|
|
||||||
}
|
}
|
||||||
Divider()
|
Divider()
|
||||||
Button {
|
Button {
|
||||||
composer = "# "
|
|
||||||
showSectionSwitcher = false
|
showSectionSwitcher = false
|
||||||
focusedField = .composer
|
newWorkspaceName = ""
|
||||||
|
showNewWorkspace = true
|
||||||
|
focusedField = .newWorkspace
|
||||||
} label: {
|
} label: {
|
||||||
HStack {
|
HStack {
|
||||||
Image(systemName: "plus")
|
Image(systemName: "plus")
|
||||||
Text("New Section")
|
Text("New Workspace")
|
||||||
Spacer()
|
Spacer()
|
||||||
}
|
}
|
||||||
.padding(.horizontal, 14)
|
.padding(.horizontal, 14)
|
||||||
@@ -450,6 +486,96 @@ struct PanelView: View {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// MARK: - New workspace
|
||||||
|
|
||||||
|
@ViewBuilder
|
||||||
|
private var newWorkspaceModal: some View {
|
||||||
|
if showNewWorkspace {
|
||||||
|
ZStack {
|
||||||
|
Color.black.opacity(0.25)
|
||||||
|
.onTapGesture { dismissNewWorkspace() }
|
||||||
|
VStack(alignment: .leading, spacing: 12) {
|
||||||
|
Text("New Workspace")
|
||||||
|
.font(.headline)
|
||||||
|
TextField("Name", text: $newWorkspaceName)
|
||||||
|
.textFieldStyle(.roundedBorder)
|
||||||
|
.focused($focusedField, equals: .newWorkspace)
|
||||||
|
.onSubmit(createWorkspace)
|
||||||
|
.onExitCommand { dismissNewWorkspace() }
|
||||||
|
HStack {
|
||||||
|
Spacer()
|
||||||
|
Button("Cancel") { dismissNewWorkspace() }
|
||||||
|
Button("Create") { createWorkspace() }
|
||||||
|
.keyboardShortcut(.defaultAction)
|
||||||
|
.disabled(newWorkspaceName.trimmingCharacters(in: .whitespaces).isEmpty)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
.padding(16)
|
||||||
|
.frame(width: 260)
|
||||||
|
.background(.regularMaterial)
|
||||||
|
.cornerRadius(12)
|
||||||
|
.shadow(radius: 18)
|
||||||
|
}
|
||||||
|
.transition(.opacity)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private func createWorkspace() {
|
||||||
|
let name = newWorkspaceName.trimmingCharacters(in: .whitespacesAndNewlines)
|
||||||
|
guard !name.isEmpty else { return }
|
||||||
|
store.createSection(named: name)
|
||||||
|
dismissNewWorkspace()
|
||||||
|
}
|
||||||
|
|
||||||
|
private func dismissNewWorkspace() {
|
||||||
|
showNewWorkspace = false
|
||||||
|
newWorkspaceName = ""
|
||||||
|
focusedField = .composer
|
||||||
|
}
|
||||||
|
|
||||||
|
// MARK: - Selection
|
||||||
|
|
||||||
|
private var selectionBar: some View {
|
||||||
|
HStack(spacing: 12) {
|
||||||
|
Text("\(selection.count) selected")
|
||||||
|
.font(.caption)
|
||||||
|
.foregroundStyle(.secondary)
|
||||||
|
Spacer()
|
||||||
|
Button("Copy as List") { copySelection(asList: true) }
|
||||||
|
.font(.caption)
|
||||||
|
.buttonStyle(.plain)
|
||||||
|
.foregroundStyle(Color.accentColor)
|
||||||
|
Button("Copy as Lines") { copySelection(asList: false) }
|
||||||
|
.font(.caption)
|
||||||
|
.buttonStyle(.plain)
|
||||||
|
.foregroundStyle(Color.accentColor)
|
||||||
|
Button { clearSelection() } label: {
|
||||||
|
Image(systemName: "xmark.circle.fill")
|
||||||
|
}
|
||||||
|
.buttonStyle(.plain)
|
||||||
|
.foregroundStyle(.tertiary)
|
||||||
|
.help("Clear selection (Esc)")
|
||||||
|
}
|
||||||
|
.padding(.horizontal, 12)
|
||||||
|
.padding(.vertical, 6)
|
||||||
|
.background(Color.accentColor.opacity(0.12))
|
||||||
|
}
|
||||||
|
|
||||||
|
private func copySelection(asList: Bool) {
|
||||||
|
guard !selection.isEmpty else { return }
|
||||||
|
if asList {
|
||||||
|
store.copyAsList(ids: selection)
|
||||||
|
} else {
|
||||||
|
store.copyAsLines(ids: selection)
|
||||||
|
}
|
||||||
|
if let id = selection.first { flashCopied(id) }
|
||||||
|
}
|
||||||
|
|
||||||
|
private func clearSelection() {
|
||||||
|
selection.removeAll()
|
||||||
|
lastSelectedID = nil
|
||||||
|
}
|
||||||
|
|
||||||
// MARK: - Composer
|
// MARK: - Composer
|
||||||
|
|
||||||
private var composerField: some View {
|
private var composerField: some View {
|
||||||
@@ -458,7 +584,15 @@ struct PanelView: View {
|
|||||||
.textFieldStyle(.plain)
|
.textFieldStyle(.plain)
|
||||||
.focused($focusedField, equals: .composer)
|
.focused($focusedField, equals: .composer)
|
||||||
.onSubmit(submit)
|
.onSubmit(submit)
|
||||||
.onExitCommand { PanelController.shared.hide() }
|
.onExitCommand {
|
||||||
|
// Esc clears a selection first, and only hides the panel
|
||||||
|
// once there is nothing selected.
|
||||||
|
if selection.isEmpty {
|
||||||
|
PanelController.shared.hide()
|
||||||
|
} else {
|
||||||
|
clearSelection()
|
||||||
|
}
|
||||||
|
}
|
||||||
if !composer.isEmpty {
|
if !composer.isEmpty {
|
||||||
Button(action: submit) { Image(systemName: "arrow.up.circle.fill") }
|
Button(action: submit) { Image(systemName: "arrow.up.circle.fill") }
|
||||||
.buttonStyle(.plain)
|
.buttonStyle(.plain)
|
||||||
@@ -500,11 +634,13 @@ struct PanelView: View {
|
|||||||
}
|
}
|
||||||
.keyboardShortcut(",", modifiers: .command)
|
.keyboardShortcut(",", modifiers: .command)
|
||||||
Button("") {
|
Button("") {
|
||||||
guard !selection.isEmpty else { return }
|
copySelection(asList: true)
|
||||||
store.copyAsList(ids: selection)
|
|
||||||
if let id = selection.first { flashCopied(PromptItem(id: id, content: .text(""))) }
|
|
||||||
}
|
}
|
||||||
.keyboardShortcut("c", modifiers: [.command, .shift])
|
.keyboardShortcut("c", modifiers: [.command, .shift])
|
||||||
|
Button("") {
|
||||||
|
copySelection(asList: false)
|
||||||
|
}
|
||||||
|
.keyboardShortcut("c", modifiers: [.command, .option])
|
||||||
}
|
}
|
||||||
.opacity(0)
|
.opacity(0)
|
||||||
.frame(width: 0, height: 0)
|
.frame(width: 0, height: 0)
|
||||||
@@ -514,26 +650,40 @@ struct PanelView: View {
|
|||||||
// MARK: - Actions
|
// MARK: - Actions
|
||||||
|
|
||||||
private func handleClick(_ item: PromptItem) {
|
private func handleClick(_ item: PromptItem) {
|
||||||
if NSApp.currentEvent?.modifierFlags.contains(.command) == true {
|
let modifiers = NSApp.currentEvent?.modifierFlags ?? []
|
||||||
|
if modifiers.contains(.command) {
|
||||||
if selection.contains(item.id) {
|
if selection.contains(item.id) {
|
||||||
selection.remove(item.id)
|
selection.remove(item.id)
|
||||||
} else {
|
} else {
|
||||||
selection.insert(item.id)
|
selection.insert(item.id)
|
||||||
}
|
}
|
||||||
|
lastSelectedID = item.id
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if modifiers.contains(.shift), let anchor = lastSelectedID, anchor != item.id {
|
||||||
|
selectRange(from: anchor, to: item.id)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
copy(item)
|
copy(item)
|
||||||
}
|
}
|
||||||
|
|
||||||
private func copy(_ item: PromptItem) {
|
private func selectRange(from anchor: UUID, to target: UUID) {
|
||||||
store.copy(item)
|
let ids = displayedItems.map(\.item.id)
|
||||||
flashCopied(item)
|
guard let start = ids.firstIndex(of: anchor), let end = ids.firstIndex(of: target) else { return }
|
||||||
|
let range = start <= end ? start...end : end...start
|
||||||
|
selection = Set(ids[range])
|
||||||
|
lastSelectedID = target
|
||||||
}
|
}
|
||||||
|
|
||||||
private func flashCopied(_ item: PromptItem) {
|
private func copy(_ item: PromptItem) {
|
||||||
withAnimation { copiedID = item.id }
|
store.copy(item)
|
||||||
|
flashCopied(item.id)
|
||||||
|
}
|
||||||
|
|
||||||
|
private func flashCopied(_ id: UUID) {
|
||||||
|
withAnimation { copiedID = id }
|
||||||
DispatchQueue.main.asyncAfter(deadline: .now() + 1.2) {
|
DispatchQueue.main.asyncAfter(deadline: .now() + 1.2) {
|
||||||
if copiedID == item.id {
|
if copiedID == id {
|
||||||
withAnimation { copiedID = nil }
|
withAnimation { copiedID = nil }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+47
-13
@@ -38,11 +38,17 @@ final class Store: ObservableObject {
|
|||||||
private let storeFile: URL
|
private let storeFile: URL
|
||||||
private let imageCache = NSCache<NSString, NSImage>()
|
private let imageCache = NSCache<NSString, NSImage>()
|
||||||
|
|
||||||
init() {
|
/// `directory` is injectable so the store can be exercised against a
|
||||||
let appSupport = FileManager.default.urls(for: .applicationSupportDirectory, in: .userDomainMask)[0]
|
/// scratch folder instead of the user's real data.
|
||||||
directory = appSupport.appendingPathComponent("Prompt", isDirectory: true)
|
init(directory: URL? = nil) {
|
||||||
imagesDirectory = directory.appendingPathComponent("Images", isDirectory: true)
|
if let directory {
|
||||||
storeFile = directory.appendingPathComponent("store.json")
|
self.directory = directory
|
||||||
|
} else {
|
||||||
|
let appSupport = FileManager.default.urls(for: .applicationSupportDirectory, in: .userDomainMask)[0]
|
||||||
|
self.directory = appSupport.appendingPathComponent("Prompt", isDirectory: true)
|
||||||
|
}
|
||||||
|
imagesDirectory = self.directory.appendingPathComponent("Images", isDirectory: true)
|
||||||
|
storeFile = self.directory.appendingPathComponent("store.json")
|
||||||
|
|
||||||
try? FileManager.default.createDirectory(at: imagesDirectory, withIntermediateDirectories: true)
|
try? FileManager.default.createDirectory(at: imagesDirectory, withIntermediateDirectories: true)
|
||||||
load()
|
load()
|
||||||
@@ -130,6 +136,18 @@ final class Store: ObservableObject {
|
|||||||
return section
|
return section
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Reorders a workspace within the list. The UI calls these "workspaces";
|
||||||
|
/// the model and the persisted JSON keep the original `sections` naming so
|
||||||
|
/// existing stores and sync payloads keep working.
|
||||||
|
func moveSection(_ id: UUID, by offset: Int) {
|
||||||
|
guard let index = sections.firstIndex(where: { $0.id == id }) else { return }
|
||||||
|
let target = index + offset
|
||||||
|
guard sections.indices.contains(target) else { return }
|
||||||
|
let section = sections.remove(at: index)
|
||||||
|
sections.insert(section, at: target)
|
||||||
|
save()
|
||||||
|
}
|
||||||
|
|
||||||
// MARK: - Items
|
// MARK: - Items
|
||||||
|
|
||||||
@discardableResult
|
@discardableResult
|
||||||
@@ -269,18 +287,34 @@ final class Store: ObservableObject {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func copyAsList(ids: Set<UUID>) {
|
func copyAsList(ids: Set<UUID>) {
|
||||||
let items = sections.flatMap(\.items)
|
let texts = selectedTexts(ids: ids)
|
||||||
.filter { ids.contains($0.id) }
|
|
||||||
.sorted { $0.createdAt < $1.createdAt }
|
|
||||||
let texts = items.compactMap { item -> String? in
|
|
||||||
if case .text(let text) = item.content { return text }
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
guard !texts.isEmpty else { return }
|
guard !texts.isEmpty else { return }
|
||||||
let list = texts.enumerated().map { "\($0.offset + 1). \($0.element)" }.joined(separator: "\n")
|
let list = texts.enumerated().map { "\($0.offset + 1). \($0.element)" }.joined(separator: "\n")
|
||||||
|
writeToPasteboard(list)
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Same selection as `copyAsList`, but joined with plain newlines so it
|
||||||
|
/// drops into a prompt without numbering.
|
||||||
|
func copyAsLines(ids: Set<UUID>) {
|
||||||
|
let texts = selectedTexts(ids: ids)
|
||||||
|
guard !texts.isEmpty else { return }
|
||||||
|
writeToPasteboard(texts.joined(separator: "\n"))
|
||||||
|
}
|
||||||
|
|
||||||
|
private func selectedTexts(ids: Set<UUID>) -> [String] {
|
||||||
|
sections.flatMap(\.items)
|
||||||
|
.filter { ids.contains($0.id) }
|
||||||
|
.sorted { $0.createdAt < $1.createdAt }
|
||||||
|
.compactMap { item in
|
||||||
|
if case .text(let text) = item.content { return text }
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private func writeToPasteboard(_ string: String) {
|
||||||
let pasteboard = NSPasteboard.general
|
let pasteboard = NSPasteboard.general
|
||||||
pasteboard.clearContents()
|
pasteboard.clearContents()
|
||||||
pasteboard.setString(list, forType: .string)
|
pasteboard.setString(string, forType: .string)
|
||||||
}
|
}
|
||||||
|
|
||||||
// MARK: - Images
|
// MARK: - Images
|
||||||
|
|||||||
@@ -39,6 +39,9 @@ final class SyncService: ObservableObject {
|
|||||||
private static let urlKey = "sync.serverURL"
|
private static let urlKey = "sync.serverURL"
|
||||||
private static let versionKey = "sync.version"
|
private static let versionKey = "sync.version"
|
||||||
|
|
||||||
|
/// Where sync points unless the user overrides it in the sync panel.
|
||||||
|
static let defaultServerURL = "https://prompt.tzgyn.dev"
|
||||||
|
|
||||||
private var lastVersion: Int64 {
|
private var lastVersion: Int64 {
|
||||||
get { Int64(defaults.integer(forKey: Self.versionKey)) }
|
get { Int64(defaults.integer(forKey: Self.versionKey)) }
|
||||||
set { defaults.set(newValue, forKey: Self.versionKey) }
|
set { defaults.set(newValue, forKey: Self.versionKey) }
|
||||||
@@ -54,7 +57,7 @@ final class SyncService: ObservableObject {
|
|||||||
|
|
||||||
private init() {
|
private init() {
|
||||||
code = defaults.string(forKey: Self.codeKey)
|
code = defaults.string(forKey: Self.codeKey)
|
||||||
serverURL = defaults.string(forKey: Self.urlKey) ?? "http://localhost:8080"
|
serverURL = defaults.string(forKey: Self.urlKey) ?? Self.defaultServerURL
|
||||||
}
|
}
|
||||||
|
|
||||||
func start() {
|
func start() {
|
||||||
@@ -64,6 +67,14 @@ final class SyncService: ObservableObject {
|
|||||||
restartPolling()
|
restartPolling()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func stop() {
|
||||||
|
pollTimer?.invalidate()
|
||||||
|
pollTimer = nil
|
||||||
|
pushWork?.cancel()
|
||||||
|
pushWork = nil
|
||||||
|
Store.shared.onDidChange = nil
|
||||||
|
}
|
||||||
|
|
||||||
// MARK: - Group membership
|
// MARK: - Group membership
|
||||||
|
|
||||||
func generateCode() {
|
func generateCode() {
|
||||||
@@ -181,22 +192,34 @@ final class SyncService: ObservableObject {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private func poll() {
|
private func poll() {
|
||||||
guard !isSyncing, let code, let url = endpoint("/api/sync/\(code)") else { return }
|
guard !isSyncing, let code, let versionURL = endpoint("/api/sync/\(code)/version") else { return }
|
||||||
Task {
|
Task {
|
||||||
do {
|
do {
|
||||||
let (data, response) = try await URLSession.shared.data(from: url)
|
// Cheap poll first: the full payload can be megabytes of
|
||||||
if (response as? HTTPURLResponse)?.statusCode == 404 {
|
// base64 images, so only download it when the version moved.
|
||||||
|
let (versionData, versionResponse) = try await URLSession.shared.data(from: versionURL)
|
||||||
|
if (versionResponse as? HTTPURLResponse)?.statusCode == 404 {
|
||||||
lastError = "Sync group no longer exists on the server"
|
lastError = "Sync group no longer exists on the server"
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
guard let http = response as? HTTPURLResponse, http.statusCode == 200 else {
|
guard let versionHTTP = versionResponse as? HTTPURLResponse, versionHTTP.statusCode == 200 else {
|
||||||
syncLog("poll HTTP \((response as? HTTPURLResponse)?.statusCode ?? -1)")
|
syncLog("poll HTTP \((versionResponse as? HTTPURLResponse)?.statusCode ?? -1)")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
let remoteVersion = try JSONDecoder().decode([String: Int64].self, from: versionData)["version"] ?? 0
|
||||||
|
guard remoteVersion > lastVersion else {
|
||||||
|
lastError = nil
|
||||||
|
return
|
||||||
|
}
|
||||||
|
syncLog("poll remote v\(remoteVersion) local v\(lastVersion) — fetching payload")
|
||||||
|
guard let payloadURL = endpoint("/api/sync/\(code)") else { return }
|
||||||
|
let (data, response) = try await URLSession.shared.data(from: payloadURL)
|
||||||
|
guard let http = response as? HTTPURLResponse, http.statusCode == 200 else { return }
|
||||||
let remote = try JSONDecoder().decode(SyncGetResponse.self, from: data)
|
let remote = try JSONDecoder().decode(SyncGetResponse.self, from: data)
|
||||||
syncLog("poll remote v\(remote.version) local v\(lastVersion)")
|
if let payload = remote.data {
|
||||||
if remote.version > lastVersion, let payload = remote.data {
|
|
||||||
apply(payload, version: remote.version)
|
apply(payload, version: remote.version)
|
||||||
|
} else {
|
||||||
|
lastVersion = remote.version
|
||||||
}
|
}
|
||||||
lastError = nil
|
lastError = nil
|
||||||
} catch {
|
} catch {
|
||||||
|
|||||||
Reference in New Issue
Block a user