Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 388e24a8df | |||
| b5ef107f9c | |||
| 21a01e9412 | |||
| 77e2610fe8 | |||
| 2c48c75387 | |||
| e04a44cdcf | |||
| b6c8a158af | |||
| 5f0f8f3396 | |||
| 24fb3a8b62 | |||
| 89432e608b |
@@ -1,68 +0,0 @@
|
|||||||
name: Build and Publish APK Package
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
tags:
|
|
||||||
- 'v*'
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build-apk:
|
|
||||||
runs-on:
|
|
||||||
- ubuntu-24.04
|
|
||||||
container:
|
|
||||||
image: alpine:latest
|
|
||||||
strategy:
|
|
||||||
matrix:
|
|
||||||
include:
|
|
||||||
- goarch: amd64
|
|
||||||
pkgarch: x86_64
|
|
||||||
- goarch: arm64
|
|
||||||
pkgarch: aarch64
|
|
||||||
steps:
|
|
||||||
- name: Install build dependencies
|
|
||||||
run: |
|
|
||||||
apk update
|
|
||||||
apk add --no-cache git nodejs go abuild curl sudo build-base
|
|
||||||
|
|
||||||
- name: Checkout repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
|
|
||||||
- name: Create build user
|
|
||||||
run: |
|
|
||||||
adduser -D -G abuild build
|
|
||||||
echo "build ALL=(ALL) NOPASSWD:ALL" >> /etc/sudoers
|
|
||||||
chown -R build:abuild .
|
|
||||||
|
|
||||||
- name: Configure git safe directory
|
|
||||||
run: git config --global --add safe.directory "$PWD"
|
|
||||||
|
|
||||||
- name: Setup abuild for package signing
|
|
||||||
run: |
|
|
||||||
su build -c "abuild-keygen -a -n"
|
|
||||||
cp /home/build/.abuild/*.pub /etc/apk/keys/
|
|
||||||
|
|
||||||
- name: Prepare source
|
|
||||||
run: |
|
|
||||||
pkgver=$(echo "${{ github.ref_name }}" | sed 's/^v//')
|
|
||||||
pkgname="axolotl"
|
|
||||||
|
|
||||||
sed -i "s/pkgver=.*/pkgver=$pkgver/" packaging/alpine/APKBUILD
|
|
||||||
sed -i "s/^arch=.*/arch=\"${{ matrix.pkgarch }}\"/" packaging/alpine/APKBUILD
|
|
||||||
|
|
||||||
git archive --format=tar.gz --prefix="$pkgname-$pkgver/" -o "packaging/alpine/$pkgname-$pkgver.tar.gz" HEAD
|
|
||||||
|
|
||||||
sed -i "s|source=.*|source=\"\$pkgname-\$pkgver.tar.gz\"|" packaging/alpine/APKBUILD
|
|
||||||
chown -R build:abuild .
|
|
||||||
|
|
||||||
- name: Generate checksums
|
|
||||||
run: su build -c "cd $PWD/packaging/alpine && abuild checksum"
|
|
||||||
|
|
||||||
- name: Build package
|
|
||||||
run: su build -c "cd $PWD/packaging/alpine && GOARCH=${{ matrix.goarch }} CARCH=${{ matrix.pkgarch }} abuild -r"
|
|
||||||
|
|
||||||
- name: Publish to Gitea Registry
|
|
||||||
run: |
|
|
||||||
apk_file=$(find ~build/packages -name "*.apk" -type f | head -1)
|
|
||||||
curl --fail-with-body \
|
|
||||||
--user "${{ github.repository_owner }}:${{ secrets.ACCESS_TOKEN }}" \
|
|
||||||
--upload-file "$apk_file" \
|
|
||||||
"${{ github.server_url }}/api/packages/${{ github.repository_owner }}/alpine/edge/main"
|
|
||||||
@@ -1,15 +1,91 @@
|
|||||||
name: Build and Push Docker Container
|
name: Build and Publish Docker Image
|
||||||
on:
|
on:
|
||||||
push:
|
push:
|
||||||
tags:
|
tags:
|
||||||
- 'v*'
|
- 'v*'
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
build-and-push:
|
build-apk:
|
||||||
|
runs-on:
|
||||||
|
- ubuntu-24.04
|
||||||
|
container:
|
||||||
|
image: alpine:latest
|
||||||
|
strategy:
|
||||||
|
matrix:
|
||||||
|
include:
|
||||||
|
- goarch: amd64
|
||||||
|
pkgarch: x86_64
|
||||||
|
- goarch: arm64
|
||||||
|
pkgarch: aarch64
|
||||||
|
steps:
|
||||||
|
- name: Install build dependencies
|
||||||
|
run: |
|
||||||
|
apk update
|
||||||
|
apk add --no-cache git nodejs go abuild curl sudo build-base
|
||||||
|
|
||||||
|
- name: Checkout repository
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
|
- name: Create build user
|
||||||
|
run: |
|
||||||
|
adduser -D -G abuild build
|
||||||
|
echo "build ALL=(ALL) NOPASSWD:ALL" >> /etc/sudoers
|
||||||
|
chown -R build:abuild .
|
||||||
|
|
||||||
|
- name: Configure git safe directory
|
||||||
|
run: git config --global --add safe.directory "$PWD"
|
||||||
|
|
||||||
|
- name: Setup abuild for package signing
|
||||||
|
run: |
|
||||||
|
su build -c "abuild-keygen -a -n"
|
||||||
|
cp /home/build/.abuild/*.pub /etc/apk/keys/
|
||||||
|
|
||||||
|
- name: Prepare source
|
||||||
|
run: |
|
||||||
|
pkgver=$(echo "${{ github.ref_name }}" | sed 's/^v//')
|
||||||
|
pkgname="axolotl"
|
||||||
|
|
||||||
|
sed -i "s/pkgver=.*/pkgver=$pkgver/" packaging/alpine/APKBUILD
|
||||||
|
sed -i "s/^arch=.*/arch=\"${{ matrix.pkgarch }}\"/" packaging/alpine/APKBUILD
|
||||||
|
|
||||||
|
git archive --format=tar.gz --prefix="$pkgname-$pkgver/" -o "packaging/alpine/$pkgname-$pkgver.tar.gz" HEAD
|
||||||
|
|
||||||
|
sed -i "s|source=.*|source=\"\$pkgname-\$pkgver.tar.gz\"|" packaging/alpine/APKBUILD
|
||||||
|
chown -R build:abuild .
|
||||||
|
|
||||||
|
- name: Generate checksums
|
||||||
|
run: su build -c "cd $PWD/packaging/alpine && abuild checksum"
|
||||||
|
|
||||||
|
- name: Build package
|
||||||
|
run: su build -c "cd $PWD/packaging/alpine && GOARCH=${{ matrix.goarch }} CARCH=${{ matrix.pkgarch }} abuild -r"
|
||||||
|
|
||||||
|
- name: Publish to Gitea Registry
|
||||||
|
run: |
|
||||||
|
apk_file=$(find ~build/packages -name "*.apk" -type f | head -1)
|
||||||
|
curl --fail-with-body \
|
||||||
|
--user "${{ github.repository_owner }}:${{ secrets.ACCESS_TOKEN }}" \
|
||||||
|
--upload-file "$apk_file" \
|
||||||
|
"${{ github.server_url }}/api/packages/${{ github.repository_owner }}/alpine/edge/main"
|
||||||
|
|
||||||
|
build-and-push-docker:
|
||||||
runs-on:
|
runs-on:
|
||||||
- ubuntu-24.04
|
- ubuntu-24.04
|
||||||
steps:
|
steps:
|
||||||
- name: Login to Docker Hub
|
- name: Checkout repository
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
|
- name: Set up Go
|
||||||
|
uses: actions/setup-go@v5
|
||||||
|
with:
|
||||||
|
go-version-file: src/go.mod
|
||||||
|
|
||||||
|
- name: Cross-compile binaries
|
||||||
|
run: |
|
||||||
|
cd src
|
||||||
|
CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -ldflags="-s -w" -trimpath -o ../out/amd64/ax .
|
||||||
|
CGO_ENABLED=0 GOOS=linux GOARCH=arm64 go build -ldflags="-s -w" -trimpath -o ../out/arm64/ax .
|
||||||
|
|
||||||
|
- name: Login to Docker Registry
|
||||||
uses: docker/login-action@v3
|
uses: docker/login-action@v3
|
||||||
with:
|
with:
|
||||||
registry: g.eliaskohout.de
|
registry: g.eliaskohout.de
|
||||||
@@ -25,6 +101,7 @@ jobs:
|
|||||||
- name: Build and push
|
- name: Build and push
|
||||||
uses: docker/build-push-action@v6
|
uses: docker/build-push-action@v6
|
||||||
with:
|
with:
|
||||||
|
context: .
|
||||||
push: true
|
push: true
|
||||||
platforms: linux/amd64,linux/arm64
|
platforms: linux/amd64,linux/arm64
|
||||||
tags: "g.eliaskohout.de/eliaskohout/axolotl-server:${{gitea.ref_name}},g.eliaskohout.de/eliaskohout/axolotl-server:latest"
|
tags: "g.eliaskohout.de/eliaskohout/axolotl-server:${{gitea.ref_name}},g.eliaskohout.de/eliaskohout/axolotl-server:latest"
|
||||||
|
|||||||
+4
-18
@@ -1,25 +1,11 @@
|
|||||||
FROM golang:1.24-alpine AS builder
|
|
||||||
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
ENV GOTOOLCHAIN=auto
|
|
||||||
|
|
||||||
COPY src/go.mod src/go.sum ./
|
|
||||||
RUN go mod download
|
|
||||||
|
|
||||||
COPY src/ ./
|
|
||||||
|
|
||||||
RUN CGO_ENABLED=0 GOOS=$TARGETOS GOARCH=$TARGETARCH \
|
|
||||||
go build -ldflags="-s -w" -trimpath -o /ax .
|
|
||||||
|
|
||||||
FROM alpine:latest
|
FROM alpine:latest
|
||||||
|
|
||||||
|
ARG TARGETARCH
|
||||||
|
|
||||||
RUN apk --no-cache add ca-certificates
|
RUN apk --no-cache add ca-certificates
|
||||||
|
|
||||||
|
COPY out/${TARGETARCH}/ax /usr/local/bin/ax
|
||||||
|
|
||||||
WORKDIR /data
|
WORKDIR /data
|
||||||
|
|
||||||
COPY --from=builder /ax /usr/local/bin/ax
|
|
||||||
|
|
||||||
EXPOSE 7000
|
EXPOSE 7000
|
||||||
|
|
||||||
ENTRYPOINT ["ax", "serve"]
|
ENTRYPOINT ["ax", "serve"]
|
||||||
|
|||||||
@@ -1,266 +1,52 @@
|
|||||||
# Axolotl
|
# Axolotl
|
||||||
|
|
||||||
CLI-native lightweight issue tracker for you and your agents. A SQLite-based
|
CLI-native issue tracker for you and your agents. Single binary, SQLite-backed, a few lines of Go.
|
||||||
single portable binary, built from ~1300 lines of Go code.
|
|
||||||
|
|
||||||
## Features
|
## Install
|
||||||
|
|
||||||
- **Issues with dependencies** - blocks, subtask, related relations
|
**Alpine Linux** (apk):
|
||||||
- **Tagging system** - flexible tags with `_key::value` property pattern
|
Download from the Gitea package registry. Have a look
|
||||||
- **Namespacing** - organize issues by project or team
|
[here](https://g.eliaskohout.de/eliaskohout/-/packages/alpine/axolotl/).
|
||||||
- **Due dates** - track deadlines
|
|
||||||
- **Thread-safe** - WAL mode for concurrent access
|
|
||||||
- **Multiuser support** - @mentions and assignments, inbox per user
|
|
||||||
- **JSON output** - all commands support `--json` for agent integration
|
|
||||||
- **Alias system** - define custom command shortcuts with argument expansion
|
|
||||||
- **Single binary** - no dependencies, portable `.ax.db` file
|
|
||||||
|
|
||||||
## Installation
|
**Arch Linux** (pacman):
|
||||||
|
Download from the Gitea package registry. Have a look
|
||||||
|
[here](https://g.eliaskohout.de/eliaskohout/-/packages/arch/axolotl/).
|
||||||
|
|
||||||
|
**From source:**
|
||||||
```bash
|
```bash
|
||||||
go build -o ax .
|
go build -o ax ./src
|
||||||
```
|
```
|
||||||
|
|
||||||
|
**Docker (server mode):**
|
||||||
|
```bash
|
||||||
|
docker run -v ./data:/data g.eliaskohout.de/eliaskohout/axolotl-server:latest
|
||||||
|
```
|
||||||
|
|
||||||
|
Packages are built automatically on every version tag for `linux/amd64` and `linux/arm64`.
|
||||||
|
|
||||||
## Quick Start
|
## Quick Start
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
# Initialize a new database
|
ax init . # create .ax.db in current dir
|
||||||
ax init .
|
ax add "Fix login bug" --prio high # create an issue
|
||||||
|
ax list --status open # list open issues
|
||||||
# Create an issue
|
ax show abc12 # show issue details
|
||||||
ax add "Implement feature X" --tag backend --prio high
|
ax update abc12 --status done # close issue
|
||||||
|
ax inbox # your @mention inbox
|
||||||
# Create with relations
|
|
||||||
ax add "Fix bug in auth" --rel blocks:abc12
|
|
||||||
|
|
||||||
# List open issues
|
|
||||||
ax list --status open
|
|
||||||
|
|
||||||
# Show issue details
|
|
||||||
ax show abc12
|
|
||||||
|
|
||||||
# Update an issue
|
|
||||||
ax update abc12 --status done
|
|
||||||
|
|
||||||
# View your inbox
|
|
||||||
ax inbox
|
|
||||||
|
|
||||||
# Define an alias
|
|
||||||
ax alias mywork "list --namespace myproject --status open" --desc "My project tasks"
|
|
||||||
```
|
```
|
||||||
|
|
||||||
## Commands
|
## Key Features
|
||||||
|
|
||||||
### `ax init [path]`
|
- **Graph relations** — `blocks`, `subtask`, `related`, `assignee`
|
||||||
|
- **Namespaces** — organize issues by project or team
|
||||||
|
- **Permissions** — per-node access control (`can_read`, `can_write`, `has_ownership`)
|
||||||
|
- **Aliases** — custom shortcuts with `$me`, `$1`, `$@` expansion
|
||||||
|
- **JSON output** — `--json` flag on all commands for agent integration
|
||||||
|
- **Multiuser** — `@mention` auto-creates inbox entries; `AX_USER` to switch users
|
||||||
|
- **Server mode** — HTTP JSON API with optional OIDC authentication (`ax serve` / `ax login`)
|
||||||
|
- **Portable** — single `.ax.db` file, no server required
|
||||||
|
|
||||||
Create a new `.ax.db` database in the specified directory (default: current).
|
For full command reference and examples, see [USAGE.md](USAGE.md).
|
||||||
|
|
||||||
### `ax add <title> [flags]`
|
|
||||||
|
|
||||||
Create a new node.
|
|
||||||
|
|
||||||
| Flag | Description |
|
|
||||||
|------|-------------|
|
|
||||||
| `--type` | Node type: `issue` (default), `note`, `user`, `namespace` |
|
|
||||||
| `--status` | Status: `open` (default), `done` |
|
|
||||||
| `--prio` | Priority: `high`, `medium`, `low` |
|
|
||||||
| `--namespace` | Namespace (default: current user) |
|
|
||||||
| `--tag` | Add tag (repeatable) |
|
|
||||||
| `--due` | Due date |
|
|
||||||
| `--content` | Content/body text |
|
|
||||||
| `--rel` | Add relation `type:id` (repeatable) |
|
|
||||||
|
|
||||||
### `ax update <id> [flags]`
|
|
||||||
|
|
||||||
Update a node.
|
|
||||||
|
|
||||||
| Flag | Description |
|
|
||||||
|------|-------------|
|
|
||||||
| `--title` | New title |
|
|
||||||
| `--status` | New status |
|
|
||||||
| `--prio` | New priority |
|
|
||||||
| `--type` | New type |
|
|
||||||
| `--namespace` | New namespace |
|
|
||||||
| `--assignee` | New assignee |
|
|
||||||
| `--due` | New due date |
|
|
||||||
| `--clear-due` | Clear due date |
|
|
||||||
| `--content` | New content |
|
|
||||||
| `--tag` | Add tag (repeatable) |
|
|
||||||
| `--tag-remove` | Remove tag (repeatable) |
|
|
||||||
| `--rel` | Add relation `type:id` (repeatable) |
|
|
||||||
| `--rel-remove` | Remove relation `type:id` (repeatable) |
|
|
||||||
|
|
||||||
### `ax show <id>`
|
|
||||||
|
|
||||||
Display node details.
|
|
||||||
|
|
||||||
### `ax list [flags]`
|
|
||||||
|
|
||||||
Query and list nodes.
|
|
||||||
|
|
||||||
| Flag | Description |
|
|
||||||
|------|-------------|
|
|
||||||
| `--type` | Filter by type |
|
|
||||||
| `--status` | Filter by status |
|
|
||||||
| `--prio` | Filter by priority |
|
|
||||||
| `--namespace` | Filter by namespace |
|
|
||||||
| `--tag` | Filter by tag (repeatable) |
|
|
||||||
| `--assignee` | Filter by assignee |
|
|
||||||
| `--mention` | Filter by mention |
|
|
||||||
|
|
||||||
### `ax edit <id>`
|
|
||||||
|
|
||||||
Open node content in `$EDITOR`.
|
|
||||||
|
|
||||||
### `ax del <id> [-f|--force]`
|
|
||||||
|
|
||||||
Delete a node. Prompts for confirmation unless `--force`.
|
|
||||||
|
|
||||||
### `ax alias [name] [command] [flags]`
|
|
||||||
|
|
||||||
Manage aliases.
|
|
||||||
|
|
||||||
```bash
|
|
||||||
ax alias # list all aliases
|
|
||||||
ax alias mywork "list --tag work" # create alias
|
|
||||||
ax alias mywork # show alias command
|
|
||||||
ax alias mywork "list --tag work2" # update alias
|
|
||||||
ax alias del mywork # delete alias
|
|
||||||
```
|
|
||||||
|
|
||||||
**Default aliases:**
|
|
||||||
|
|
||||||
| Alias | Command | Description |
|
|
||||||
|-------|---------|-------------|
|
|
||||||
| `mine` | `list --assignee $me --type issue --status open` | Show open issues assigned to you |
|
|
||||||
| `due` | `list --type issue --status open` | Show open issues |
|
|
||||||
| `inbox` | `list --mention $me` | Show your inbox |
|
|
||||||
|
|
||||||
**Alias argument expansion:**
|
|
||||||
|
|
||||||
| Variable | Expands to |
|
|
||||||
|----------|------------|
|
|
||||||
| `$me` | Current username |
|
|
||||||
| `$@` | All arguments |
|
|
||||||
| `$1`, `$2`, ... | Positional arguments |
|
|
||||||
|
|
||||||
```bash
|
|
||||||
# Create alias with argument expansion
|
|
||||||
ax alias find "list --tag $1 --status $2"
|
|
||||||
ax find backend open # expands to: list --tag backend --status open
|
|
||||||
```
|
|
||||||
|
|
||||||
## Relations
|
|
||||||
|
|
||||||
Relations connect nodes together:
|
|
||||||
|
|
||||||
| Type | Meaning | Behavior |
|
|
||||||
|------|---------|----------|
|
|
||||||
| `blocks` | A blocks B — B can't close until A is done | Enforced on status=done |
|
|
||||||
| `subtask` | A is a subtask of B | |
|
|
||||||
| `related` | A is related to B | |
|
|
||||||
| `assignee` | A is assigned to user | Single-value; set via `--assignee` flag |
|
|
||||||
| `in_namespace` | A belongs to namespace | Single-value; set via `--namespace` flag |
|
|
||||||
|
|
||||||
```bash
|
|
||||||
# Block an issue (B can't close until A is done)
|
|
||||||
ax update A --rel blocks:B
|
|
||||||
|
|
||||||
# Assign to user
|
|
||||||
ax update abc12 --assignee alice
|
|
||||||
|
|
||||||
# Create subtask
|
|
||||||
ax update abc12 --rel subtask:parent12
|
|
||||||
```
|
|
||||||
|
|
||||||
## Tags and Properties
|
|
||||||
|
|
||||||
Tags are flexible labels. Tags with pattern `_key::value` are properties:
|
|
||||||
|
|
||||||
```bash
|
|
||||||
# Regular tag
|
|
||||||
ax add "Task" --tag backend
|
|
||||||
|
|
||||||
# Property tags (set via flags)
|
|
||||||
ax add "Task" --type issue --status open --prio high
|
|
||||||
# Equivalent to: --tag _type::issue --tag _status::open --tag _prio::high
|
|
||||||
```
|
|
||||||
|
|
||||||
**Built-in properties:**
|
|
||||||
|
|
||||||
| Property | Values | Required |
|
|
||||||
|----------|--------|----------|
|
|
||||||
| `_type` | `issue`, `note`, `user`, `namespace` | Yes (default: `issue`) |
|
|
||||||
| `_status` | `open`, `done` | No |
|
|
||||||
| `_prio` | `high`, `medium`, `low` | No |
|
|
||||||
|
|
||||||
## Mentions and Inbox
|
|
||||||
|
|
||||||
Use `@username` in title or content to automatically add to user's inbox:
|
|
||||||
|
|
||||||
```bash
|
|
||||||
ax add "Review PR @alice" --content "@bob please check"
|
|
||||||
# Both alice and bob get this in their inbox
|
|
||||||
```
|
|
||||||
|
|
||||||
View inbox:
|
|
||||||
```bash
|
|
||||||
ax inbox # your inbox
|
|
||||||
AX_USER=alice ax inbox # alice's inbox
|
|
||||||
```
|
|
||||||
|
|
||||||
## JSON Output
|
|
||||||
|
|
||||||
All commands support `--json` for machine-readable output:
|
|
||||||
|
|
||||||
```bash
|
|
||||||
ax list --status open --json
|
|
||||||
ax show abc12 --json
|
|
||||||
```
|
|
||||||
|
|
||||||
Example output:
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"id": "abc12",
|
|
||||||
"title": "Implement feature",
|
|
||||||
"content": "Description here",
|
|
||||||
"created_at": "2026-03-25T10:00:00Z",
|
|
||||||
"updated_at": "2026-03-25T10:00:00Z",
|
|
||||||
"tags": ["_type::issue", "_status::open", "backend"],
|
|
||||||
"relations": {
|
|
||||||
"blocks": ["def34"]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
## Configuration
|
|
||||||
|
|
||||||
`ax` stores user configuration in a JSON file. It searches for `.axconfig` in the
|
|
||||||
current directory and parent directories (like git finds `.git`), falling back to
|
|
||||||
`~/.config/ax/config.json`.
|
|
||||||
|
|
||||||
**Config file format:**
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"user": "alice",
|
|
||||||
"aliases": [
|
|
||||||
{"name": "mywork", "command": "list --namespace myproject", "description": "My tasks"}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
## Database Location
|
|
||||||
|
|
||||||
`ax` searches for `.ax.db` in the current directory and parent directories,
|
|
||||||
similar to how git finds `.git`. This allows you to run commands from any
|
|
||||||
subdirectory.
|
|
||||||
|
|
||||||
## Environment Variables
|
|
||||||
|
|
||||||
| Variable | Description |
|
|
||||||
|----------|-------------|
|
|
||||||
| `AX_USER` | Override current username |
|
|
||||||
| `EDITOR` | Editor for `ax edit` (default: `vi`) |
|
|
||||||
|
|
||||||
## License
|
## License
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,194 @@
|
|||||||
|
# Axolotl Usage Reference
|
||||||
|
|
||||||
|
## Commands
|
||||||
|
|
||||||
|
### `ax init [path]`
|
||||||
|
Create a new `.ax.db` in the specified directory (default: current).
|
||||||
|
|
||||||
|
### `ax add <title> [flags]`
|
||||||
|
| Flag | Description |
|
||||||
|
|------|-------------|
|
||||||
|
| `--type` | `issue` (default), `note`, `user`, `namespace` |
|
||||||
|
| `--status` | `open` (default), `done` |
|
||||||
|
| `--prio` | `high`, `medium`, `low` |
|
||||||
|
| `--namespace` | Namespace (default: current user) |
|
||||||
|
| `--tag` | Add tag (repeatable) |
|
||||||
|
| `--due` | Due date |
|
||||||
|
| `--content` | Body text |
|
||||||
|
| `--rel` | Relation `type:id` (repeatable) |
|
||||||
|
|
||||||
|
### `ax update <id> [flags]`
|
||||||
|
| Flag | Description |
|
||||||
|
|------|-------------|
|
||||||
|
| `--title` | New title |
|
||||||
|
| `--status` | New status |
|
||||||
|
| `--prio` | New priority |
|
||||||
|
| `--type` | New type |
|
||||||
|
| `--namespace` | Transfer to namespace |
|
||||||
|
| `--assignee` | Assign to user |
|
||||||
|
| `--due` / `--clear-due` | Set or clear due date |
|
||||||
|
| `--content` | New body text |
|
||||||
|
| `--tag` / `--tag-remove` | Add or remove tag |
|
||||||
|
| `--rel` / `--rel-remove` | Add or remove relation `type:id` |
|
||||||
|
|
||||||
|
### `ax show <id>`
|
||||||
|
Display node details.
|
||||||
|
|
||||||
|
### `ax list [flags]`
|
||||||
|
| Flag | Description |
|
||||||
|
|------|-------------|
|
||||||
|
| `--type` | Filter by type |
|
||||||
|
| `--status` | Filter by status |
|
||||||
|
| `--prio` | Filter by priority |
|
||||||
|
| `--namespace` | Filter by namespace |
|
||||||
|
| `--tag` | Filter by tag (repeatable) |
|
||||||
|
| `--assignee` | Filter by assignee |
|
||||||
|
| `--mention` | Filter by mention |
|
||||||
|
|
||||||
|
### `ax edit <id>`
|
||||||
|
Open node content in `$EDITOR`.
|
||||||
|
|
||||||
|
### `ax del <id> [-f]`
|
||||||
|
Delete a node. Prompts for confirmation unless `--force`.
|
||||||
|
|
||||||
|
### `ax alias [name] [command]`
|
||||||
|
```bash
|
||||||
|
ax alias # list all aliases
|
||||||
|
ax alias mywork "list --tag work" # create/update alias
|
||||||
|
ax alias del mywork # delete alias
|
||||||
|
```
|
||||||
|
|
||||||
|
**Built-in aliases:** `mine`, `due`, `inbox`
|
||||||
|
|
||||||
|
**Argument expansion:** `$me` → current user, `$@` → all args, `$1`/`$2`/… → positional
|
||||||
|
|
||||||
|
## Relations
|
||||||
|
|
||||||
|
| Type | Description |
|
||||||
|
|------|-------------|
|
||||||
|
| `blocks` | Prevents target from closing until this is done |
|
||||||
|
| `subtask` | Marks as subtask of target |
|
||||||
|
| `related` | General association |
|
||||||
|
| `assignee` | Assigns to a user (single-value) |
|
||||||
|
|
||||||
|
```bash
|
||||||
|
ax update A --rel blocks:B # A blocks B
|
||||||
|
ax update abc12 --assignee alice # assign to alice
|
||||||
|
```
|
||||||
|
|
||||||
|
## Tags and Properties
|
||||||
|
|
||||||
|
Tags follow the `_key::value` pattern for properties:
|
||||||
|
|
||||||
|
| Property | Values |
|
||||||
|
|----------|--------|
|
||||||
|
| `_type` | `issue`, `note`, `user`, `namespace` |
|
||||||
|
| `_status` | `open`, `done` |
|
||||||
|
| `_prio` | `high`, `medium`, `low` |
|
||||||
|
|
||||||
|
## Mentions and Inbox
|
||||||
|
|
||||||
|
Use `@username` in title or content to add to a user's inbox:
|
||||||
|
```bash
|
||||||
|
ax add "Review PR @alice" # alice gets an inbox entry
|
||||||
|
ax inbox # your inbox
|
||||||
|
AX_USER=alice ax inbox # alice's inbox
|
||||||
|
```
|
||||||
|
|
||||||
|
## JSON Output
|
||||||
|
|
||||||
|
All commands support `--json`:
|
||||||
|
```bash
|
||||||
|
ax list --status open --json
|
||||||
|
ax show abc12 --json
|
||||||
|
```
|
||||||
|
|
||||||
|
## Configuration
|
||||||
|
|
||||||
|
`ax` searches upward from CWD for `.axconfig`, falling back to `~/.config/ax/config.json`.
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"user": "alice",
|
||||||
|
"aliases": [
|
||||||
|
{"name": "mywork", "command": "list --namespace myproject", "description": "My tasks"}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
## Server Mode
|
||||||
|
|
||||||
|
`ax` can run as a shared HTTP JSON API server:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
ax serve # starts server on configured host:port (default: 0.0.0.0:7000)
|
||||||
|
```
|
||||||
|
|
||||||
|
The server exposes the same operations (add, list, show, update, delete) over HTTP. Clients connect by setting `remote.host` / `remote.port` in their config — the CLI then transparently routes calls to the server instead of a local database.
|
||||||
|
|
||||||
|
### OIDC Authentication
|
||||||
|
|
||||||
|
The server supports OIDC for authentication. Configure in `.axconfig`:
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"serve": { "host": "0.0.0.0", "port": 7000 },
|
||||||
|
"oidc": {
|
||||||
|
"issuer": "https://your-idp.example.com",
|
||||||
|
"client_id": "axolotl",
|
||||||
|
"client_secret": "secret",
|
||||||
|
"public_url": "https://ax.example.com",
|
||||||
|
"user_claim": "preferred_username"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
Client login:
|
||||||
|
```bash
|
||||||
|
ax login # opens browser for OIDC flow, saves session token
|
||||||
|
```
|
||||||
|
|
||||||
|
Without OIDC configured, the server accepts an `X-Ax-User` header for the username (development/trusted networks only).
|
||||||
|
|
||||||
|
### Docker
|
||||||
|
|
||||||
|
```bash
|
||||||
|
docker run -v ./data:/data g.eliaskohout.de/eliaskohout/axolotl-server:latest
|
||||||
|
```
|
||||||
|
|
||||||
|
The image runs `ax serve` and exposes port 7000. Mount a volume at `/data` to persist the database.
|
||||||
|
|
||||||
|
## Permission Model
|
||||||
|
|
||||||
|
Every node has per-node access control. Permissions are transitive via BFS from the requesting user's own node.
|
||||||
|
|
||||||
|
| Level | Relation | Grants |
|
||||||
|
|-------|----------|--------|
|
||||||
|
| 1 | `can_read` | Read / show / list |
|
||||||
|
| 2 | `can_create_rel` | Create relations pointing to this node |
|
||||||
|
| 3 | `can_write` | Update title, content, tags |
|
||||||
|
| 4 | `has_ownership` | Full control including delete and granting access |
|
||||||
|
|
||||||
|
- Creators automatically get `has_ownership` on nodes they create.
|
||||||
|
- Namespace nodes own regular nodes within them; users own their namespaces.
|
||||||
|
- Deleting an owner cascades to all nodes it owns.
|
||||||
|
- User nodes and namespace nodes are globally readable.
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Grant bob read access to a node
|
||||||
|
ax update <bob-user-id> --rel can_read:<node-id>
|
||||||
|
|
||||||
|
# Grant bob write access
|
||||||
|
ax update <bob-user-id> --rel can_write:<node-id>
|
||||||
|
```
|
||||||
|
|
||||||
|
## Environment Variables
|
||||||
|
|
||||||
|
| Variable | Description |
|
||||||
|
|----------|-------------|
|
||||||
|
| `AX_USER` | Override current username |
|
||||||
|
| `EDITOR` | Editor for `ax edit` (default: `vi`) |
|
||||||
|
|
||||||
|
## Database Location
|
||||||
|
|
||||||
|
`ax` searches for `.ax.db` upward from CWD (like git finds `.git`), so commands work from any subdirectory.
|
||||||
+1
-1
@@ -43,7 +43,7 @@ var addCmd = &cobra.Command{
|
|||||||
input.Rels = append(input.Rels, service.RelInput{Type: models.RelType("_prio::" + cPrio), Target: ""})
|
input.Rels = append(input.Rels, service.RelInput{Type: models.RelType("_prio::" + cPrio), Target: ""})
|
||||||
}
|
}
|
||||||
if cNamespace != "" {
|
if cNamespace != "" {
|
||||||
input.Rels = append(input.Rels, service.RelInput{Type: models.RelInNamespace, Target: cNamespace})
|
input.Namespace = cNamespace
|
||||||
}
|
}
|
||||||
if cAssignee != "" {
|
if cAssignee != "" {
|
||||||
input.Rels = append(input.Rels, service.RelInput{Type: models.RelAssignee, Target: cAssignee})
|
input.Rels = append(input.Rels, service.RelInput{Type: models.RelAssignee, Target: cAssignee})
|
||||||
|
|||||||
+1
-1
@@ -46,7 +46,7 @@ var listCmd = &cobra.Command{
|
|||||||
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelType("_type::" + lType), Target: ""})
|
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelType("_type::" + lType), Target: ""})
|
||||||
}
|
}
|
||||||
if lNamespace != "" {
|
if lNamespace != "" {
|
||||||
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelInNamespace, Target: lNamespace})
|
filter.Namespace = lNamespace
|
||||||
}
|
}
|
||||||
if lAssignee != "" {
|
if lAssignee != "" {
|
||||||
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelAssignee, Target: lAssignee})
|
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelAssignee, Target: lAssignee})
|
||||||
|
|||||||
+47
-2
@@ -22,6 +22,48 @@ var loginCmd = &cobra.Command{
|
|||||||
}
|
}
|
||||||
base := fmt.Sprintf("http://%s:%d", rc.Host, rc.Port)
|
base := fmt.Sprintf("http://%s:%d", rc.Host, rc.Port)
|
||||||
|
|
||||||
|
sessionID := tryDeviceFlow(base)
|
||||||
|
if sessionID == "" {
|
||||||
|
sessionID = tryCallbackFlow(base)
|
||||||
|
}
|
||||||
|
|
||||||
|
pollForToken(base, sessionID)
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
// tryDeviceFlow attempts the device authorization flow. Returns a session ID
|
||||||
|
// on success, or "" if the server does not support it.
|
||||||
|
func tryDeviceFlow(base string) string {
|
||||||
|
resp, err := http.Post(base+"/auth/device/start", "application/json", nil)
|
||||||
|
if err != nil {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
defer resp.Body.Close()
|
||||||
|
if resp.StatusCode != http.StatusOK {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
var start struct {
|
||||||
|
SessionID string `json:"session_id"`
|
||||||
|
UserCode string `json:"user_code"`
|
||||||
|
VerificationURI string `json:"verification_uri"`
|
||||||
|
VerificationURIComplete string `json:"verification_uri_complete"`
|
||||||
|
}
|
||||||
|
json.NewDecoder(resp.Body).Decode(&start)
|
||||||
|
if start.SessionID == "" {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
uri := start.VerificationURI
|
||||||
|
if start.VerificationURIComplete != "" {
|
||||||
|
uri = start.VerificationURIComplete
|
||||||
|
}
|
||||||
|
fmt.Printf("To sign in, open this URL in any browser:\n\n %s\n\nThen enter this code: %s\n\nWaiting for authentication...\n", uri, start.UserCode)
|
||||||
|
return start.SessionID
|
||||||
|
}
|
||||||
|
|
||||||
|
// tryCallbackFlow initiates the traditional callback-based OIDC flow.
|
||||||
|
// Exits the process on failure.
|
||||||
|
func tryCallbackFlow(base string) string {
|
||||||
resp, err := http.Post(base+"/auth/start", "application/json", nil)
|
resp, err := http.Post(base+"/auth/start", "application/json", nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Fprintf(os.Stderr, "failed to contact server: %v\n", err)
|
fmt.Fprintf(os.Stderr, "failed to contact server: %v\n", err)
|
||||||
@@ -40,12 +82,16 @@ var loginCmd = &cobra.Command{
|
|||||||
}
|
}
|
||||||
|
|
||||||
fmt.Printf("Open this URL in your browser:\n\n %s\n\nWaiting for login...\n", start.URL)
|
fmt.Printf("Open this URL in your browser:\n\n %s\n\nWaiting for login...\n", start.URL)
|
||||||
|
return start.SessionID
|
||||||
|
}
|
||||||
|
|
||||||
|
// pollForToken polls the server until the login completes or times out.
|
||||||
|
func pollForToken(base, sessionID string) {
|
||||||
deadline := time.Now().Add(5 * time.Minute)
|
deadline := time.Now().Add(5 * time.Minute)
|
||||||
for time.Now().Before(deadline) {
|
for time.Now().Before(deadline) {
|
||||||
time.Sleep(2 * time.Second)
|
time.Sleep(2 * time.Second)
|
||||||
|
|
||||||
resp, err := http.Get(fmt.Sprintf("%s/auth/poll?session_id=%s", base, start.SessionID))
|
resp, err := http.Get(fmt.Sprintf("%s/auth/poll?session_id=%s", base, sessionID))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
@@ -82,7 +128,6 @@ var loginCmd = &cobra.Command{
|
|||||||
|
|
||||||
fmt.Fprintln(os.Stderr, "login timed out")
|
fmt.Fprintln(os.Stderr, "login timed out")
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
},
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
|
|||||||
+2
-14
@@ -49,7 +49,7 @@ var (
|
|||||||
"low": {" ", "low", cDim},
|
"low": {" ", "low", cDim},
|
||||||
"": {" ", "n/a", cDim},
|
"": {" ", "n/a", cDim},
|
||||||
}
|
}
|
||||||
relIcons = map[string]string{"blocks": "\uf068", "subtask": "\uf0da", "related": "\uf0c1", "assignee": "\uf007", "in_namespace": "\uf07b"}
|
relIcons = map[string]string{"blocks": "\uf068", "subtask": "\uf0da", "related": "\uf0c1", "assignee": "\uf007"}
|
||||||
prioRanks = map[string]int{"high": 3, "medium": 2, "low": 1}
|
prioRanks = map[string]int{"high": 3, "medium": 2, "low": 1}
|
||||||
statusRanks = map[string]int{"open": 2, "": 1, "done": 0}
|
statusRanks = map[string]int{"open": 2, "": 1, "done": 0}
|
||||||
)
|
)
|
||||||
@@ -94,24 +94,12 @@ func PrintNodes(w io.Writer, svc service.NodeService, nodes []*models.Node, json
|
|||||||
})
|
})
|
||||||
|
|
||||||
for _, n := range nodes {
|
for _, n := range nodes {
|
||||||
n_rels := n.Relations
|
fmt.Fprintf(w, " %s %s %s %s %s %s",
|
||||||
ns_rel_node_ids := n_rels[string(models.RelInNamespace)]
|
|
||||||
ns_rel_node_titles := make([]string, 0, len(ns_rel_node_ids))
|
|
||||||
for _, id := range ns_rel_node_ids {
|
|
||||||
ns_rel_node, err := svc.GetByID(id)
|
|
||||||
if err != nil {
|
|
||||||
ns_rel_node_titles = append(ns_rel_node_titles, id)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
ns_rel_node_titles = append(ns_rel_node_titles, ns_rel_node.Title)
|
|
||||||
}
|
|
||||||
fmt.Fprintf(w, " %s %s %s %s %s %s %s",
|
|
||||||
cDim.Sprint(n.ID),
|
cDim.Sprint(n.ID),
|
||||||
render(prioRM, n.GetProperty("prio"), true),
|
render(prioRM, n.GetProperty("prio"), true),
|
||||||
render(statusRM, n.GetProperty("status"), true),
|
render(statusRM, n.GetProperty("status"), true),
|
||||||
render(typeRM, n.GetProperty("type"), true),
|
render(typeRM, n.GetProperty("type"), true),
|
||||||
cTitle.Sprint(truncate(n.Title, 80)),
|
cTitle.Sprint(truncate(n.Title, 80)),
|
||||||
cDim.Sprint("["+strings.Join(ns_rel_node_titles, ",")+"]"),
|
|
||||||
dueDateShort(n.DueDate),
|
dueDateShort(n.DueDate),
|
||||||
)
|
)
|
||||||
tags := n.GetDisplayTags()
|
tags := n.GetDisplayTags()
|
||||||
|
|||||||
+1
-1
@@ -61,7 +61,7 @@ var updateCmd = &cobra.Command{
|
|||||||
input.AddRels = append(input.AddRels, service.RelInput{Type: models.RelType("_prio::" + uPrio), Target: ""})
|
input.AddRels = append(input.AddRels, service.RelInput{Type: models.RelType("_prio::" + uPrio), Target: ""})
|
||||||
}
|
}
|
||||||
if cmd.Flags().Changed("namespace") {
|
if cmd.Flags().Changed("namespace") {
|
||||||
input.AddRels = append(input.AddRels, service.RelInput{Type: models.RelInNamespace, Target: uNamespace})
|
input.Namespace = &uNamespace
|
||||||
}
|
}
|
||||||
if cmd.Flags().Changed("assignee") {
|
if cmd.Flags().Changed("assignee") {
|
||||||
input.AddRels = append(input.AddRels, service.RelInput{Type: models.RelAssignee, Target: uAssignee})
|
input.AddRels = append(input.AddRels, service.RelInput{Type: models.RelAssignee, Target: uAssignee})
|
||||||
|
|||||||
@@ -33,9 +33,6 @@ func TestCRUD(t *testing.T) {
|
|||||||
if len(n.Relations["created"]) == 0 {
|
if len(n.Relations["created"]) == 0 {
|
||||||
t.Error("expected created relation to be set")
|
t.Error("expected created relation to be set")
|
||||||
}
|
}
|
||||||
if len(n.Relations["in_namespace"]) == 0 {
|
|
||||||
t.Error("expected in_namespace relation to be set")
|
|
||||||
}
|
|
||||||
if n.CreatedAt == "" || n.UpdatedAt == "" {
|
if n.CreatedAt == "" || n.UpdatedAt == "" {
|
||||||
t.Error("expected timestamps to be set")
|
t.Error("expected timestamps to be set")
|
||||||
}
|
}
|
||||||
@@ -73,9 +70,6 @@ func TestCRUD(t *testing.T) {
|
|||||||
if n.Content != "some body" {
|
if n.Content != "some body" {
|
||||||
t.Errorf("content: want %q, got %q", "some body", n.Content)
|
t.Errorf("content: want %q, got %q", "some body", n.Content)
|
||||||
}
|
}
|
||||||
if len(n.Relations["in_namespace"]) == 0 {
|
|
||||||
t.Error("expected in_namespace relation")
|
|
||||||
}
|
|
||||||
if len(n.Relations["assignee"]) == 0 {
|
if len(n.Relations["assignee"]) == 0 {
|
||||||
t.Error("expected assignee relation")
|
t.Error("expected assignee relation")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -168,10 +168,6 @@ func TestNamespaceExplicitCreate(t *testing.T) {
|
|||||||
|
|
||||||
nsNode := env.parseNode(env.mustAx("add", "myworkspace", "--type", "namespace", "--json"))
|
nsNode := env.parseNode(env.mustAx("add", "myworkspace", "--type", "namespace", "--json"))
|
||||||
|
|
||||||
if !nsNode.HasRelation("in_namespace", nsNode.ID) {
|
|
||||||
t.Errorf("expected namespace to have in_namespace pointing to itself, got relations: %v", nsNode.Relations)
|
|
||||||
}
|
|
||||||
|
|
||||||
users := env.parseNodes(env.mustAx("list", "--type", "user", "--json"))
|
users := env.parseNodes(env.mustAx("list", "--type", "user", "--json"))
|
||||||
var userNode *NodeResponse
|
var userNode *NodeResponse
|
||||||
for i := range users {
|
for i := range users {
|
||||||
|
|||||||
+1
-1
@@ -89,7 +89,7 @@ func (n *Node) AddRelation(relType RelType, target string) {
|
|||||||
if n.Relations == nil {
|
if n.Relations == nil {
|
||||||
n.Relations = make(map[string][]string)
|
n.Relations = make(map[string][]string)
|
||||||
}
|
}
|
||||||
if relType == RelAssignee || relType == RelCreated || relType == RelInNamespace {
|
if relType == RelAssignee || relType == RelCreated {
|
||||||
n.Relations[string(relType)] = []string{target}
|
n.Relations[string(relType)] = []string{target}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -13,7 +13,6 @@ const (
|
|||||||
RelRelated RelType = "related"
|
RelRelated RelType = "related"
|
||||||
RelCreated RelType = "created"
|
RelCreated RelType = "created"
|
||||||
RelAssignee RelType = "assignee"
|
RelAssignee RelType = "assignee"
|
||||||
RelInNamespace RelType = "in_namespace"
|
|
||||||
RelMentions RelType = "mentions"
|
RelMentions RelType = "mentions"
|
||||||
|
|
||||||
// Permission rels (subject → object). Levels are inclusive and transitive.
|
// Permission rels (subject → object). Levels are inclusive and transitive.
|
||||||
|
|||||||
+118
-8
@@ -23,16 +23,26 @@ type pendingLogin struct {
|
|||||||
serverToken string // set by callback when complete; empty while pending
|
serverToken string // set by callback when complete; empty while pending
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// pendingDeviceLogin tracks an in-progress device authorization flow.
|
||||||
|
type pendingDeviceLogin struct {
|
||||||
|
created time.Time
|
||||||
|
serverToken string // set when device token exchange completes
|
||||||
|
username string // set when device token exchange completes
|
||||||
|
err string // set if the flow fails
|
||||||
|
}
|
||||||
|
|
||||||
// authHandler owns the OIDC provider connection, the pending login store,
|
// authHandler owns the OIDC provider connection, the pending login store,
|
||||||
// and the active server-side session map.
|
// and the active server-side session map.
|
||||||
type authHandler struct {
|
type authHandler struct {
|
||||||
mu sync.Mutex
|
mu sync.Mutex
|
||||||
pending map[string]*pendingLogin // loginID → pending state
|
pending map[string]*pendingLogin // loginID → pending state
|
||||||
|
pendingDevice map[string]*pendingDeviceLogin // loginID → pending device state
|
||||||
sessions map[string]string // serverToken → username
|
sessions map[string]string // serverToken → username
|
||||||
|
|
||||||
cfg store.OIDCConfig
|
cfg store.OIDCConfig
|
||||||
provider *oidc.Provider
|
provider *oidc.Provider
|
||||||
oauth2 oauth2.Config
|
oauth2 oauth2.Config
|
||||||
|
deviceFlowAvailable bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func newAuthHandler(cfg store.OIDCConfig) (*authHandler, error) {
|
func newAuthHandler(cfg store.OIDCConfig) (*authHandler, error) {
|
||||||
@@ -43,18 +53,21 @@ func newAuthHandler(cfg store.OIDCConfig) (*authHandler, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("OIDC provider: %w", err)
|
return nil, fmt.Errorf("OIDC provider: %w", err)
|
||||||
}
|
}
|
||||||
|
endpoint := provider.Endpoint()
|
||||||
h := &authHandler{
|
h := &authHandler{
|
||||||
pending: make(map[string]*pendingLogin),
|
pending: make(map[string]*pendingLogin),
|
||||||
|
pendingDevice: make(map[string]*pendingDeviceLogin),
|
||||||
sessions: make(map[string]string),
|
sessions: make(map[string]string),
|
||||||
cfg: cfg,
|
cfg: cfg,
|
||||||
provider: provider,
|
provider: provider,
|
||||||
oauth2: oauth2.Config{
|
oauth2: oauth2.Config{
|
||||||
ClientID: cfg.ClientID,
|
ClientID: cfg.ClientID,
|
||||||
ClientSecret: cfg.ClientSecret,
|
ClientSecret: cfg.ClientSecret,
|
||||||
Endpoint: provider.Endpoint(),
|
Endpoint: endpoint,
|
||||||
RedirectURL: cfg.PublicURL + "/auth/callback",
|
RedirectURL: cfg.PublicURL + "/auth/callback",
|
||||||
Scopes: []string{oidc.ScopeOpenID, "profile", "email", "offline_access"},
|
Scopes: []string{oidc.ScopeOpenID, "profile", "email", "offline_access"},
|
||||||
},
|
},
|
||||||
|
deviceFlowAvailable: endpoint.DeviceAuthURL != "",
|
||||||
}
|
}
|
||||||
go h.cleanup()
|
go h.cleanup()
|
||||||
return h, nil
|
return h, nil
|
||||||
@@ -68,6 +81,11 @@ func (h *authHandler) cleanup() {
|
|||||||
delete(h.pending, id)
|
delete(h.pending, id)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
for id, p := range h.pendingDevice {
|
||||||
|
if time.Since(p.created) > 15*time.Minute {
|
||||||
|
delete(h.pendingDevice, id)
|
||||||
|
}
|
||||||
|
}
|
||||||
h.mu.Unlock()
|
h.mu.Unlock()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -148,6 +166,71 @@ func (h *authHandler) callback(w http.ResponseWriter, r *http.Request) {
|
|||||||
fmt.Fprintln(w, "Login successful! You can close this tab.")
|
fmt.Fprintln(w, "Login successful! You can close this tab.")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// POST /auth/device/start → {session_id, user_code, verification_uri, verification_uri_complete}
|
||||||
|
func (h *authHandler) deviceStart(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if !h.deviceFlowAvailable {
|
||||||
|
writeError(w, http.StatusNotFound, "device flow not supported by OIDC provider")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
da, err := h.oauth2.DeviceAuth(r.Context(),
|
||||||
|
oauth2.SetAuthURLParam("client_secret", h.cfg.ClientSecret),
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
writeError(w, http.StatusBadGateway, "device authorization request failed: "+err.Error())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
loginID := randomToken(16)
|
||||||
|
|
||||||
|
h.mu.Lock()
|
||||||
|
h.pendingDevice[loginID] = &pendingDeviceLogin{created: time.Now()}
|
||||||
|
h.mu.Unlock()
|
||||||
|
|
||||||
|
// Exchange device code for token in the background.
|
||||||
|
go func() {
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 15*time.Minute)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
token, err := h.oauth2.DeviceAccessToken(ctx, da)
|
||||||
|
if err != nil {
|
||||||
|
h.mu.Lock()
|
||||||
|
if p := h.pendingDevice[loginID]; p != nil {
|
||||||
|
p.err = err.Error()
|
||||||
|
}
|
||||||
|
h.mu.Unlock()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
username, err := h.extractUsername(ctx, token)
|
||||||
|
if err != nil {
|
||||||
|
h.mu.Lock()
|
||||||
|
if p := h.pendingDevice[loginID]; p != nil {
|
||||||
|
p.err = "failed to identify user: " + err.Error()
|
||||||
|
}
|
||||||
|
h.mu.Unlock()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
serverToken := randomToken(32)
|
||||||
|
|
||||||
|
h.mu.Lock()
|
||||||
|
h.sessions[serverToken] = username
|
||||||
|
if p := h.pendingDevice[loginID]; p != nil {
|
||||||
|
p.serverToken = serverToken
|
||||||
|
p.username = username
|
||||||
|
}
|
||||||
|
h.mu.Unlock()
|
||||||
|
}()
|
||||||
|
|
||||||
|
writeJSON(w, map[string]string{
|
||||||
|
"session_id": loginID,
|
||||||
|
"user_code": da.UserCode,
|
||||||
|
"verification_uri": da.VerificationURI,
|
||||||
|
"verification_uri_complete": da.VerificationURIComplete,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
// GET /auth/poll?session_id=...
|
// GET /auth/poll?session_id=...
|
||||||
// Returns 202 while pending, 200 {token, username} when done, 404 if expired.
|
// Returns 202 while pending, 200 {token, username} when done, 404 if expired.
|
||||||
func (h *authHandler) poll(w http.ResponseWriter, r *http.Request) {
|
func (h *authHandler) poll(w http.ResponseWriter, r *http.Request) {
|
||||||
@@ -157,15 +240,12 @@ func (h *authHandler) poll(w http.ResponseWriter, r *http.Request) {
|
|||||||
p := h.pending[loginID]
|
p := h.pending[loginID]
|
||||||
h.mu.Unlock()
|
h.mu.Unlock()
|
||||||
|
|
||||||
if p == nil {
|
// Check callback-based flow first.
|
||||||
writeError(w, http.StatusNotFound, "session not found or expired")
|
if p != nil {
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
h.mu.Lock()
|
h.mu.Lock()
|
||||||
serverToken := p.serverToken
|
serverToken := p.serverToken
|
||||||
if serverToken != "" {
|
if serverToken != "" {
|
||||||
delete(h.pending, loginID) // consume once delivered
|
delete(h.pending, loginID)
|
||||||
}
|
}
|
||||||
h.mu.Unlock()
|
h.mu.Unlock()
|
||||||
|
|
||||||
@@ -173,9 +253,39 @@ func (h *authHandler) poll(w http.ResponseWriter, r *http.Request) {
|
|||||||
w.WriteHeader(http.StatusAccepted)
|
w.WriteHeader(http.StatusAccepted)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
username := h.lookupSession(serverToken)
|
username := h.lookupSession(serverToken)
|
||||||
writeJSON(w, map[string]string{"token": serverToken, "username": username})
|
writeJSON(w, map[string]string{"token": serverToken, "username": username})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check device flow.
|
||||||
|
h.mu.Lock()
|
||||||
|
dp := h.pendingDevice[loginID]
|
||||||
|
h.mu.Unlock()
|
||||||
|
|
||||||
|
if dp == nil {
|
||||||
|
writeError(w, http.StatusNotFound, "session not found or expired")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
h.mu.Lock()
|
||||||
|
serverToken := dp.serverToken
|
||||||
|
errMsg := dp.err
|
||||||
|
if serverToken != "" || errMsg != "" {
|
||||||
|
delete(h.pendingDevice, loginID)
|
||||||
|
}
|
||||||
|
h.mu.Unlock()
|
||||||
|
|
||||||
|
if errMsg != "" {
|
||||||
|
writeError(w, http.StatusGone, errMsg)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if serverToken == "" {
|
||||||
|
w.WriteHeader(http.StatusAccepted)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
writeJSON(w, map[string]string{"token": serverToken, "username": dp.username})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *authHandler) extractUsername(ctx context.Context, token *oauth2.Token) (string, error) {
|
func (h *authHandler) extractUsername(ctx context.Context, token *oauth2.Token) (string, error) {
|
||||||
|
|||||||
+2
-1
@@ -30,6 +30,7 @@ func New(newSvc func(user string) (service.NodeService, error), oidcCfg *store.O
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
mux.HandleFunc("POST /auth/start", ah.start)
|
mux.HandleFunc("POST /auth/start", ah.start)
|
||||||
|
mux.HandleFunc("POST /auth/device/start", ah.deviceStart)
|
||||||
mux.HandleFunc("GET /auth/callback", ah.callback)
|
mux.HandleFunc("GET /auth/callback", ah.callback)
|
||||||
mux.HandleFunc("GET /auth/poll", ah.poll)
|
mux.HandleFunc("GET /auth/poll", ah.poll)
|
||||||
return withSessionAuth(ah, mux), nil
|
return withSessionAuth(ah, mux), nil
|
||||||
@@ -77,7 +78,7 @@ func (s *server) listNodes(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if v := q.Get("namespace"); v != "" {
|
if v := q.Get("namespace"); v != "" {
|
||||||
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelInNamespace, Target: v})
|
filter.Namespace = v
|
||||||
}
|
}
|
||||||
if v := q.Get("assignee"); v != "" {
|
if v := q.Get("assignee"); v != "" {
|
||||||
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelAssignee, Target: v})
|
filter.Rels = append(filter.Rels, service.RelInput{Type: models.RelAssignee, Target: v})
|
||||||
|
|||||||
@@ -72,6 +72,9 @@ func (c *apiClient) GetByID(id string) (*models.Node, error) {
|
|||||||
|
|
||||||
func (c *apiClient) List(filter ListFilter) ([]*models.Node, error) {
|
func (c *apiClient) List(filter ListFilter) ([]*models.Node, error) {
|
||||||
q := url.Values{}
|
q := url.Values{}
|
||||||
|
if filter.Namespace != "" {
|
||||||
|
q.Set("namespace", filter.Namespace)
|
||||||
|
}
|
||||||
for _, r := range filter.Rels {
|
for _, r := range filter.Rels {
|
||||||
if r.Target == "" {
|
if r.Target == "" {
|
||||||
q.Add("rel", string(r.Type))
|
q.Add("rel", string(r.Type))
|
||||||
|
|||||||
@@ -37,17 +37,20 @@ type AddInput struct {
|
|||||||
Title string
|
Title string
|
||||||
Content string
|
Content string
|
||||||
DueDate string
|
DueDate string
|
||||||
|
Namespace string // namespace name or ID; defaults to the user's personal namespace
|
||||||
Rels []RelInput
|
Rels []RelInput
|
||||||
}
|
}
|
||||||
|
|
||||||
// UpdateInput describes changes to apply to an existing node.
|
// UpdateInput describes changes to apply to an existing node.
|
||||||
// AddRels and RemoveRels accept both tag rels (Target == "") and edge rels.
|
// AddRels and RemoveRels accept both tag rels (Target == "") and edge rels.
|
||||||
// Setting _status::done in AddRels is rejected when the node has open blockers.
|
// Setting _status::done in AddRels is rejected when the node has open blockers.
|
||||||
// Adding assignee or in_namespace rels replaces the previous single target.
|
// Adding an assignee rel replaces the previous single target.
|
||||||
|
// Setting Namespace transfers ownership from the current namespace to the new one.
|
||||||
type UpdateInput struct {
|
type UpdateInput struct {
|
||||||
Title *string
|
Title *string
|
||||||
Content *string
|
Content *string
|
||||||
DueDate *string // nil = no change; pointer to "" = clear due date
|
DueDate *string // nil = no change; pointer to "" = clear due date
|
||||||
|
Namespace *string // nil = no change; namespace name or ID to move node into
|
||||||
AddRels []RelInput
|
AddRels []RelInput
|
||||||
RemoveRels []RelInput
|
RemoveRels []RelInput
|
||||||
}
|
}
|
||||||
@@ -56,6 +59,7 @@ type UpdateInput struct {
|
|||||||
// Tag filters (Target == "") match by rel_name prefix.
|
// Tag filters (Target == "") match by rel_name prefix.
|
||||||
// Edge filters (Target != "") are resolved to node IDs.
|
// Edge filters (Target != "") are resolved to node IDs.
|
||||||
type ListFilter struct {
|
type ListFilter struct {
|
||||||
|
Namespace string // when non-empty, only return nodes owned by this namespace
|
||||||
Rels []RelInput
|
Rels []RelInput
|
||||||
HasDueDate bool // when true, only return nodes that have a due date set
|
HasDueDate bool // when true, only return nodes that have a due date set
|
||||||
DueWithin *int // when non-nil, only return nodes due within this many days (includes overdue)
|
DueWithin *int // when non-nil, only return nodes due within this many days (includes overdue)
|
||||||
|
|||||||
@@ -75,7 +75,7 @@ const (
|
|||||||
// namespaces are globally readable and any node can reference them.
|
// namespaces are globally readable and any node can reference them.
|
||||||
func isReferenceRel(t models.RelType) bool {
|
func isReferenceRel(t models.RelType) bool {
|
||||||
switch t {
|
switch t {
|
||||||
case models.RelAssignee, models.RelCreated, models.RelMentions, models.RelInNamespace:
|
case models.RelAssignee, models.RelCreated, models.RelMentions:
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
return false
|
return false
|
||||||
@@ -208,6 +208,28 @@ func (s *nodeServiceImpl) GetByID(id string) (*models.Node, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *nodeServiceImpl) List(filter ListFilter) ([]*models.Node, error) {
|
func (s *nodeServiceImpl) List(filter ListFilter) ([]*models.Node, error) {
|
||||||
|
// Resolve namespace filter to owned node IDs.
|
||||||
|
var nsOwnedIDs map[string]bool
|
||||||
|
if filter.Namespace != "" {
|
||||||
|
nsID, _ := s.resolveIDByNameAndType(s.store, filter.Namespace, "namespace")
|
||||||
|
if nsID == "" {
|
||||||
|
if exists, _ := s.store.NodeExists(filter.Namespace); exists {
|
||||||
|
nsID = filter.Namespace
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if nsID == "" {
|
||||||
|
return nil, nil // namespace not found
|
||||||
|
}
|
||||||
|
nsNode, err := s.store.GetNode(nsID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
nsOwnedIDs = make(map[string]bool)
|
||||||
|
for _, ownedID := range nsNode.Relations[string(models.RelHasOwnership)] {
|
||||||
|
nsOwnedIDs[ownedID] = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var storeFilters []*models.Rel
|
var storeFilters []*models.Rel
|
||||||
for _, ri := range filter.Rels {
|
for _, ri := range filter.Rels {
|
||||||
if ri.Target == "" {
|
if ri.Target == "" {
|
||||||
@@ -230,9 +252,13 @@ func (s *nodeServiceImpl) List(filter ListFilter) ([]*models.Node, error) {
|
|||||||
}
|
}
|
||||||
var result []*models.Node
|
var result []*models.Node
|
||||||
for _, n := range nodes {
|
for _, n := range nodes {
|
||||||
if pc.canRead(n.ID) {
|
if !pc.canRead(n.ID) {
|
||||||
result = append(result, n)
|
continue
|
||||||
}
|
}
|
||||||
|
if nsOwnedIDs != nil && !nsOwnedIDs[n.ID] {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
result = append(result, n)
|
||||||
}
|
}
|
||||||
|
|
||||||
if filter.HasDueDate || filter.DueWithin != nil {
|
if filter.HasDueDate || filter.DueWithin != nil {
|
||||||
@@ -323,13 +349,6 @@ func (s *nodeServiceImpl) Add(input AddInput) (*models.Node, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
hasNamespace := false
|
|
||||||
for _, ri := range input.Rels {
|
|
||||||
if ri.Type == models.RelInNamespace && ri.Target != "" {
|
|
||||||
hasNamespace = true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
dueDate, err := parseDueDate(input.DueDate)
|
dueDate, err := parseDueDate(input.DueDate)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -364,9 +383,8 @@ func (s *nodeServiceImpl) Add(input AddInput) (*models.Node, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Edge rels. Track the namespace the node is placed in for ownership.
|
// Edge rels.
|
||||||
hasCreated := false
|
hasCreated := false
|
||||||
var actualNsID string
|
|
||||||
for _, ri := range input.Rels {
|
for _, ri := range input.Rels {
|
||||||
if ri.Target == "" {
|
if ri.Target == "" {
|
||||||
continue // already stored as tag
|
continue // already stored as tag
|
||||||
@@ -378,9 +396,6 @@ func (s *nodeServiceImpl) Add(input AddInput) (*models.Node, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if ri.Type == models.RelInNamespace {
|
|
||||||
actualNsID = resolved
|
|
||||||
}
|
|
||||||
if ri.Type == models.RelHasOwnership {
|
if ri.Type == models.RelHasOwnership {
|
||||||
// Ownership transfer: remove existing owner of the target.
|
// Ownership transfer: remove existing owner of the target.
|
||||||
existingOwners, _ := st.FindNodes([]*models.Rel{{Type: models.RelHasOwnership, Target: resolved}})
|
existingOwners, _ := st.FindNodes([]*models.Rel{{Type: models.RelHasOwnership, Target: resolved}})
|
||||||
@@ -393,18 +408,6 @@ func (s *nodeServiceImpl) Add(input AddInput) (*models.Node, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Default namespace.
|
|
||||||
if !hasNamespace {
|
|
||||||
nsID, err := s.resolveNamespaceRef(st, s.userID)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
if err := st.AddRel(id, string(models.RelInNamespace), nsID); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
actualNsID = nsID
|
|
||||||
}
|
|
||||||
|
|
||||||
// Default created.
|
// Default created.
|
||||||
if !hasCreated {
|
if !hasCreated {
|
||||||
userID, err := s.resolveUserRef(st, s.userID)
|
userID, err := s.resolveUserRef(st, s.userID)
|
||||||
@@ -417,39 +420,30 @@ func (s *nodeServiceImpl) Add(input AddInput) (*models.Node, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Grant ownership of the new node.
|
// Grant ownership of the new node.
|
||||||
// Namespace nodes are owned by their creator. All other nodes are owned
|
// Namespace nodes are owned by their creator (user node).
|
||||||
// by the namespace they belong to — the user retains transitive ownership
|
// All other nodes are owned by the namespace they belong to — the user
|
||||||
// through the namespace's own ownership chain (e.g. user→owns→default-ns→owns→node).
|
// retains transitive ownership through the namespace's own ownership chain
|
||||||
|
// (e.g. user→has_ownership→default-ns→has_ownership→node).
|
||||||
creatorID, err := s.resolveUserRef(st, s.userID)
|
creatorID, err := s.resolveUserRef(st, s.userID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
ownerID := creatorID
|
ownerID := creatorID
|
||||||
if tmp.GetProperty("type") != "namespace" && actualNsID != "" {
|
if tmp.GetProperty("type") != "namespace" {
|
||||||
ownerID = actualNsID
|
nsRef := input.Namespace
|
||||||
|
if nsRef == "" {
|
||||||
|
nsRef = s.userID
|
||||||
|
}
|
||||||
|
nsID, err := s.resolveNamespaceRef(st, nsRef)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
ownerID = nsID
|
||||||
}
|
}
|
||||||
if err := st.AddRel(ownerID, string(models.RelHasOwnership), id); err != nil {
|
if err := st.AddRel(ownerID, string(models.RelHasOwnership), id); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Namespace bootstrap: when creating a namespace node directly, apply the
|
|
||||||
// same setup as ensureNamespace — self in_namespace and creator ownership.
|
|
||||||
if tmp.GetProperty("type") == "namespace" {
|
|
||||||
if !hasNamespace {
|
|
||||||
// Replace the default namespace rel (user's ns) with self-reference.
|
|
||||||
userNsID, _ := s.resolveIDByNameAndType(st, s.userID, "namespace")
|
|
||||||
if userNsID != "" {
|
|
||||||
if err := st.RemoveRel(id, string(models.RelInNamespace), userNsID); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if err := st.AddRel(id, string(models.RelInNamespace), id); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// Creator already gets ownership via the block above; nothing more to do.
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -470,8 +464,8 @@ func (s *nodeServiceImpl) Update(id string, input UpdateInput) (*models.Node, er
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Field/tag changes and rel removals require can_write on the node.
|
// Field/tag changes, rel removals, and namespace change require can_write on the node.
|
||||||
needsWrite := input.Title != nil || input.Content != nil || input.DueDate != nil
|
needsWrite := input.Title != nil || input.Content != nil || input.DueDate != nil || input.Namespace != nil
|
||||||
for _, ri := range input.AddRels {
|
for _, ri := range input.AddRels {
|
||||||
if ri.Target == "" {
|
if ri.Target == "" {
|
||||||
needsWrite = true
|
needsWrite = true
|
||||||
@@ -619,7 +613,7 @@ func (s *nodeServiceImpl) Update(id string, input UpdateInput) (*models.Node, er
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
// Single-value relations replace the previous target.
|
// Single-value relations replace the previous target.
|
||||||
if ri.Type == models.RelAssignee || ri.Type == models.RelInNamespace {
|
if ri.Type == models.RelAssignee {
|
||||||
for _, oldTgt := range currentRels[string(ri.Type)] {
|
for _, oldTgt := range currentRels[string(ri.Type)] {
|
||||||
if err := st.RemoveRel(id, string(ri.Type), oldTgt); err != nil {
|
if err := st.RemoveRel(id, string(ri.Type), oldTgt); err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -651,6 +645,24 @@ func (s *nodeServiceImpl) Update(id string, input UpdateInput) (*models.Node, er
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Namespace change: transfer ownership from the current namespace to the new one.
|
||||||
|
if input.Namespace != nil {
|
||||||
|
newNsID, err := s.resolveNamespaceRef(st, *input.Namespace)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
// Remove ownership from any current namespace owner.
|
||||||
|
currentOwners, _ := st.FindNodes([]*models.Rel{{Type: models.RelHasOwnership, Target: id}})
|
||||||
|
for _, owner := range currentOwners {
|
||||||
|
if owner.GetProperty("type") == "namespace" {
|
||||||
|
st.RemoveRel(owner.ID, string(models.RelHasOwnership), id) //nolint:errcheck
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if err := st.AddRel(newNsID, string(models.RelHasOwnership), id); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -770,8 +782,6 @@ func (s *nodeServiceImpl) resolveRelTarget(st store.GraphStore, ri RelInput) (st
|
|||||||
switch ri.Type {
|
switch ri.Type {
|
||||||
case models.RelAssignee, models.RelCreated, models.RelMentions:
|
case models.RelAssignee, models.RelCreated, models.RelMentions:
|
||||||
return s.resolveUserRef(st, ri.Target)
|
return s.resolveUserRef(st, ri.Target)
|
||||||
case models.RelInNamespace:
|
|
||||||
return s.resolveNamespaceRef(st, ri.Target)
|
|
||||||
default:
|
default:
|
||||||
// Permission rels and all other edge rels expect raw node IDs.
|
// Permission rels and all other edge rels expect raw node IDs.
|
||||||
return ri.Target, nil
|
return ri.Target, nil
|
||||||
@@ -788,8 +798,6 @@ func (s *nodeServiceImpl) lookupRelTarget(relType models.RelType, target string)
|
|||||||
switch relType {
|
switch relType {
|
||||||
case models.RelAssignee, models.RelCreated, models.RelMentions:
|
case models.RelAssignee, models.RelCreated, models.RelMentions:
|
||||||
nodeType = "user"
|
nodeType = "user"
|
||||||
case models.RelInNamespace:
|
|
||||||
nodeType = "namespace"
|
|
||||||
default:
|
default:
|
||||||
// Permission rels and other edge rels use raw node IDs.
|
// Permission rels and other edge rels use raw node IDs.
|
||||||
return "", false
|
return "", false
|
||||||
@@ -843,9 +851,6 @@ func (s *nodeServiceImpl) ensureGlobalNamespace(st store.GraphStore) (string, er
|
|||||||
if err := st.AddRel(id, "_type::namespace", ""); err != nil {
|
if err := st.AddRel(id, "_type::namespace", ""); err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
if err := st.AddRel(id, string(models.RelInNamespace), id); err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
// Self-owned so no single user controls it.
|
// Self-owned so no single user controls it.
|
||||||
if err := st.AddRel(id, string(models.RelHasOwnership), id); err != nil {
|
if err := st.AddRel(id, string(models.RelHasOwnership), id); err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
@@ -916,9 +921,6 @@ func (s *nodeServiceImpl) ensureNamespace(st store.GraphStore, name string) (str
|
|||||||
if err := st.AddRel(id, "_type::namespace", ""); err != nil {
|
if err := st.AddRel(id, "_type::namespace", ""); err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
if err := st.AddRel(id, string(models.RelInNamespace), id); err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
userID, err := s.resolveUserRef(st, s.userID)
|
userID, err := s.resolveUserRef(st, s.userID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
|
|||||||
@@ -74,31 +74,20 @@ func FindAndOpenSQLiteStore() (GraphStore, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// FindOrInitSQLiteStore is like FindAndOpenSQLiteStore but intended for server
|
// FindOrInitSQLiteStore is like FindAndOpenSQLiteStore but intended for server
|
||||||
// mode: if no .ax.db is found it creates and initialises one in the current
|
// mode: if no database is found it creates and initialises one in the
|
||||||
// working directory instead of returning an error.
|
// ~/.local/share/ax/ directory instead of returning an error.
|
||||||
func FindOrInitSQLiteStore() (GraphStore, error) {
|
func FindOrInitSQLiteStore() (GraphStore, error) {
|
||||||
dir, err := filepath.Abs(".")
|
dataRoot, err := FindDataRoot(".local", "share")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("failed to find data dir: %w", err)
|
||||||
|
}
|
||||||
|
dbPath := filepath.Join(dataRoot, "ax.db")
|
||||||
|
if _, err := os.Stat(dbPath); err != nil {
|
||||||
|
if err := InitSQLiteStore(dbPath); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
for {
|
|
||||||
dbpath := filepath.Join(dir, ".ax.db")
|
|
||||||
if _, err := os.Stat(dbpath); err == nil {
|
|
||||||
return NewSQLiteStore(dbpath)
|
|
||||||
}
|
}
|
||||||
if parent := filepath.Dir(dir); parent == dir {
|
return NewSQLiteStore(dbPath)
|
||||||
break
|
|
||||||
} else {
|
|
||||||
dir = parent
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// Not found — create and initialise in CWD.
|
|
||||||
cwd, _ := filepath.Abs(".")
|
|
||||||
dbpath := filepath.Join(cwd, ".ax.db")
|
|
||||||
if err := InitSQLiteStore(dbpath); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return NewSQLiteStore(dbpath)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewSQLiteStore opens a SQLite database at the given path, runs a one-time
|
// NewSQLiteStore opens a SQLite database at the given path, runs a one-time
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ func LoadSession() (*Session, error) {
|
|||||||
data, err := os.ReadFile(path)
|
data, err := os.ReadFile(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if os.IsNotExist(err) {
|
if os.IsNotExist(err) {
|
||||||
return nil, nil
|
return &Session{path: path}, nil
|
||||||
}
|
}
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user