feat(web): introduce SQL Notebook feature

api/v1.yaml

@@ -805,6 +805,171 @@ paths:
               schema:
                 $ref: "#/components/schemas/MetricMatrix"
 
+  /collab/notebooks:
+    get:
+      summary: List collaborative notebooks
+      description: Retrieve a list of collaborative notebooks
+      operationId: listCollabNotebooks
+      security:
+        - BearerAuth: []
+      responses:
+        "200":
+          description: Successfully retrieved collaborative notebook list
+          content:
+            application/json:
+              schema:
+                type: array
+                items:
+                  $ref: "#/components/schemas/CollabNotebook"
+    post:
+      summary: Create a collaborative notebook
+      description: Create a new collaborative notebook
+      operationId: createCollabNotebook
+      security:
+        - BearerAuth: []
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: "#/components/schemas/CollabNotebookCreateRequest"
+      responses:
+        "201":
+          description: Successfully created collaborative notebook
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/CollabNotebook"
+
+  /collab/notebooks/{notebookID}:
+    get:
+      summary: Get collaborative notebook details
+      description: Retrieve details of a specific collaborative notebook
+      operationId: getCollabNotebook
+      security:
+        - BearerAuth: []
+      parameters:
+        - name: notebookID
+          in: path
+          required: true
+          schema:
+            type: string
+      responses:
+        "200":
+          description: Successfully retrieved collaborative notebook
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/CollabNotebook"
+
+    put:
+      summary: Update a collaborative notebook
+      description: Update details of a specific collaborative notebook
+      operationId: updateCollabNotebook
+      security:
+        - BearerAuth: []
+      parameters:
+        - name: notebookID
+          in: path
+          required: true
+          schema:
+            type: string
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: "#/components/schemas/CollabNotebook"
+      responses:
+        "200":
+          description: Successfully upd-ated collaborative notebook
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/CollabNotebook"
+
+    delete:
+      summary: Delete a collaborative notebook
+      description: Permanently delete a collaborative notebook
+      operationId: deleteCollabNotebook
+      security:
+        - BearerAuth: []
+      parameters:
+        - name: notebookID
+          in: path
+          required: true
+          schema:
+            type: string
+      responses:
+        "204":
+          description: Notebook deleted successfully
+        "403":
+          description: Operation not permitted
+        "404":
+          description: Notebook not found
+  /collab/notebooks/{notebookID}/transfer:
+    post:
+      summary: Transfer collaborative notebook scope
+      description: Move a collaborative notebook between personal and organization scopes.
+      operationId: transferCollabNotebook
+      security:
+        - BearerAuth: []
+      parameters:
+        - name: notebookID
+          in: path
+          required: true
+          schema:
+            type: string
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: "#/components/schemas/CollabNotebookTransferRequest"
+      responses:
+        "200":
+          description: Successfully transferred collaborative notebook
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/CollabNotebook"
+        "400":
+          description: Invalid transfer request
+        "403":
+          description: Operation not permitted
+        "404":
+          description: Notebook not found
+
+  /collab/notebooks/{notebookID}/snapshot:
+    put:
+      summary: Upload a collaborative notebook snapshot
+      description: Persist the latest Yjs snapshot for a collaborative notebook.
+      operationId: uploadCollabNotebookSnapshot
+      security:
+        - BearerAuth: []
+      parameters:
+        - name: notebookID
+          in: path
+          required: true
+          schema:
+            type: string
+          description: Unique identifier of the collaborative notebook.
+      requestBody:
+        required: true
+        content:
+          application/octet-stream:
+            schema:
+              type: string
+              format: binary
+            examples:
+              snapshot:
+                summary: Encoded Yjs snapshot payload
+                value: ""
+      responses:
+        "204":
+          description: Snapshot stored successfully.
+
+
 components:
   securitySchemes:
     BearerAuth:
@@ -1648,6 +1813,65 @@ components:
           type: integer
           format: int32
 
+    CollabNotebook:
+      type: object
+      required: [notebookID, title, createdAt, updatedAt]
+      properties:
+        notebookID:
+          type: string
+          description: Unique identifier of the collaborative notebook
+        title:
+          type: string
+          description: Title of the collaborative notebook
+        scope:
+          type: string
+          enum: [personal, organization]
+          description: Ownership scope of the notebook
+        organizationID:
+          type: integer
+          format: int32
+          description: Organization that currently owns the notebook
+        ownerUserID:
+          type: integer
+          format: int32
+          description: User that owns the notebook when scope is personal
+        createdByUserID:
+          type: integer
+          format: int32
+          description: User that originally created the notebook
+        createdAt:
+          type: string
+          format: date-time
+          description: Creation timestamp
+        updatedAt:
+          type: string
+          format: date-time
+          description: Last update timestamp
+
+    CollabNotebookCreateRequest:
+      type: object
+      required: [title]
+      properties:
+        title:
+          type: string
+          description: Title of the collaborative notebook
+        scope:
+          type: string
+          enum: [personal, organization]
+          description: Ownership scope of the notebook; defaults to personal when omitted
+
+    CollabNotebookTransferRequest:
+      type: object
+      required: [targetScope]
+      properties:
+        targetScope:
+          type: string
+          enum: [personal, organization]
+          description: Desired ownership scope
+        ownerUserID:
+          type: integer
+          format: int32
+          description: Target owner when moving to personal scope; defaults to the caller
     PromdumpOpt:
       type: object
       required: [endpoint, start, end, step, query, gzip, parts, memoryRatio]

dev/anclax.yaml

@@ -3,7 +3,8 @@ externals:
   wire: v0.6.0
   sqlc: v1.29.0
   mockgen: v0.5.0
-  anclax: v0.6.6
+  # Align with go.mod: dev-v0.7 resolves to v0.6.16 pseudo-version
+  anclax: dev-v0.7
 
 oapi-codegen:
   path: api/v1.yaml
@@ -46,3 +47,5 @@ mockgen:
     - source: pkg/conn/http/http.go
       destination: pkg/conn/http/mock/http_mock_gen.go
       package: mock
+
+anclaxdef: dev/anclax

dev/anclax/sql/migrations/0001_init.down.sql

@@ -0,0 +1,7 @@
+BEGIN;
+
+DROP TABLE IF EXISTS anclax.users;
+DROP TABLE IF EXISTS anclax.keys;
+DROP TABLE IF EXISTS anclax.opaque_tokens;
+
+COMMIT;

dev/anclax/sql/migrations/0001_init.up.sql

@@ -0,0 +1,120 @@
+BEGIN;
+
+CREATE SCHEMA IF NOT EXISTS anclax;
+
+CREATE TABLE IF NOT EXISTS anclax.orgs (
+    id         SERIAL      PRIMARY KEY,
+    name       TEXT        NOT NULL,
+    tz         TEXT        NOT NULL DEFAULT 'Asia/Shanghai',
+    created_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS anclax.users (
+    id              SERIAL      PRIMARY KEY,
+    name            TEXT        NOT NULL,
+    password_hash   TEXT        NOT NULL,
+    password_salt   TEXT        NOT NULL,
+    created_at      TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at      TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    deleted_at      TIMESTAMPTZ
+);
+
+CREATE TABLE IF NOT EXISTS anclax.user_default_orgs (
+    user_id    INTEGER NOT NULL REFERENCES anclax.users(id) ON UPDATE CASCADE ON DELETE CASCADE,
+    org_id     INTEGER NOT NULL REFERENCES anclax.orgs(id) ON UPDATE CASCADE ON DELETE CASCADE,
+    created_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (user_id)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.org_users (
+    org_id     INTEGER NOT NULL REFERENCES anclax.orgs(id) ON UPDATE CASCADE ON DELETE CASCADE,
+    user_id    INTEGER NOT NULL REFERENCES anclax.users(id) ON UPDATE CASCADE ON DELETE CASCADE,
+    created_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (org_id, user_id)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.org_owners (
+    org_id     INTEGER NOT NULL REFERENCES anclax.orgs(id)  ON UPDATE CASCADE ON DELETE CASCADE,
+    user_id    INTEGER NOT NULL REFERENCES anclax.users(id) ON UPDATE CASCADE,
+    created_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (org_id)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.opaque_keys (
+    id              BIGSERIAL   PRIMARY KEY,
+    key             BYTEA       NOT NULL,
+    user_id         INT         NOT NULL REFERENCES anclax.users(id) ON DELETE CASCADE ON UPDATE CASCADE,
+    created_at      TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at      TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS anclax.access_key_pairs (
+    access_key      VARCHAR(20) NOT NULL,
+    secret_key      VARCHAR(40) NOT NULL,
+    created_at      TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at      TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (access_key)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.access_rules (
+    name        VARCHAR(255) NOT NULL,
+    description TEXT         NOT NULL,
+    created_at  TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at  TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (name)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.roles (
+    id          SERIAL PRIMARY KEY,
+    org_id      INTEGER      NOT NULL REFERENCES anclax.orgs(id) ON UPDATE CASCADE,
+    name        VARCHAR(255) NOT NULL,
+    description TEXT         NOT NULL,
+    created_at  TIMESTAMPTZ  DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at  TIMESTAMPTZ  DEFAULT CURRENT_TIMESTAMP NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS anclax.role_access_rules (
+    role_id          INTEGER NOT NULL,
+    access_rule_name VARCHAR(255) NOT NULL REFERENCES anclax.access_rules(name) ON UPDATE CASCADE,
+    created_at       TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at       TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (role_id, access_rule_name)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.users_roles (
+    user_id    INTEGER NOT NULL,
+    role_id    INTEGER NOT NULL,
+    created_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    updated_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    PRIMARY KEY (user_id, role_id)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.tasks (
+    id          SERIAL PRIMARY KEY,
+    attributes  JSONB NOT NULL,
+    spec        JSONB NOT NULL,
+    status      VARCHAR(255) NOT NULL,
+    unique_tag  VARCHAR(255), -- for unique task
+    started_at  TIMESTAMPTZ,
+    created_at  TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updated_at  TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    UNIQUE (unique_tag)
+);
+
+CREATE TABLE IF NOT EXISTS anclax.events (
+    id         SERIAL PRIMARY KEY,
+    spec       JSONB NOT NULL,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
+);
+
+COMMIT;

dev/anclax/sql/migrations/0002_retry_count.down.sql

@@ -0,0 +1,6 @@
+BEGIN;
+
+ALTER TABLE anclax.tasks DROP COLUMN attempts;
+
+COMMIT;
+

dev/anclax/sql/migrations/0002_retry_count.up.sql

@@ -0,0 +1,7 @@
+BEGIN;
+
+ALTER TABLE anclax.tasks ADD COLUMN attempts INTEGER NOT NULL DEFAULT 0;
+
+UPDATE anclax.tasks SET attributes = jsonb_set(attributes, '{retryPolicy, maxAttempts}', '-1') WHERE (attributes->'retryPolicy'->'always_retry_on_failure')::BOOLEAN;
+
+COMMIT;