Compare commits
30 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 6b8ce54231 | |||
| 1cf6e3e4d3 | |||
| 708a4abba7 | |||
| 93d01bc39d | |||
| 8c145ae274 | |||
| a5a0616941 | |||
| 75136ee6bd | |||
| 332ee26de2 | |||
| 5b72ded2d5 | |||
| 4e55c1e4aa | |||
| 3900073086 | |||
| 7ac46e1d2e | |||
| 37d4f37206 | |||
| eb7a544a0c | |||
| 2272fac26f | |||
| 96e132c2fb | |||
| f85b6301dd | |||
| d096627b28 | |||
| 672ca10ffe | |||
| 417104605f | |||
| 0bcf13800e | |||
| dbc9328bf5 | |||
| ed23999c50 | |||
| 30c9e9e308 | |||
| 748d308672 | |||
| 3e33ee4d61 | |||
| 074d48f536 | |||
| eb11011017 | |||
| 04267593fb | |||
| 558bc9e034 |
|
Before Width: | Height: | Size: 110 KiB After Width: | Height: | Size: 286 KiB |
@@ -19,3 +19,6 @@ docs/
|
|||||||
# OS
|
# OS
|
||||||
.DS_Store
|
.DS_Store
|
||||||
Thumbs.db
|
Thumbs.db
|
||||||
|
|
||||||
|
# Worktrees
|
||||||
|
.worktrees/
|
||||||
|
|||||||
@@ -1,82 +1,124 @@
|
|||||||
# toknd — Auth Broker
|
# toknd — The Minimal Token Broker
|
||||||
|
|
||||||

|

|
||||||
|
|
||||||
**toknd** is a minimal, centralized authentication and token broker. Built with **Bun**, **Hono**, and **Redis**, it serves as a middleware layer that manages OAuth2 providers, token persistence, and automatic refreshes, allowing your applications to focus on their core logic.
|
Building integrations is fun until you have to manage the tokens. Suddenly, you're writing cron jobs to handle refresh cycles, dealing with expired sessions in the middle of background tasks, and copying OAuth secrets manually across multiple microservices.
|
||||||
|
|
||||||
|
If you are building AI agents that need to take actions in the real world, the absolute last thing you want is your LLM trying to debug an OAuth redirect flow.
|
||||||
|
|
||||||
|
**toknd** is a minimal, centralized authentication and auth token broker and middleware with **native multi-tenancy**. Built with **Bun**, **Hono**, and **Redis**, it acts as a secure "wallet" that sits between your applications and the external APIs they need to access.
|
||||||
|
|
||||||
|
You just need to authenticate once. toknd manages the lifecycle of the tokens forever, securely isolated by tenant.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Why does this exist?
|
||||||
|
|
||||||
|
There are massive enterprise identity brokers (like Auth0 or Dex), and then there are reverse proxies (like oauth2-proxy). **toknd** is built to bridge the gap while remaining minimal and open-source. It provides the lightweight, developer-friendly infrastructure of a proxy, but with the specific "Token Vault" and **Multi-Tenancy** capabilities required for modern AI and microservice architectures—without the bloat, vendor lock-in, or SaaS costs.
|
||||||
|
|
||||||
|
## Use-Cases
|
||||||
|
- **Multi-Tenant SaaS Platforms:** If you are building a platform where *your* users need to connect their own GitHub or Google accounts, toknd handles the isolation. Use a unique `tenantId` for each of your customers to keep their credentials safe and separate.
|
||||||
|
- **The Ultimate AI Agent Wallet:** Equip your autonomous agents with a secure keychain. When your agent needs to hit a service backed by oauth, like GitHub or Notion API, it just asks toknd for a token. It gets a short-lived Bearer token instantly, keeping your permanent secrets completely isolated from dynamic AI environments.
|
||||||
|
- **Set It and Forget It:** toknd handles automated background refreshes. Your data ingestion pipelines, RAG syncs, and headless integration workers will never stall out due to a `401 Unauthorized` error again.
|
||||||
|
- **Microservice Centralization:** Stop implementing OAuth in every new service. Centralize your credentials so your microservices only need one internal API key to request valid access tokens for any configured provider.
|
||||||
|
- **Secure Secret Isolation:** OAuth client IDs, secrets, and long-lived refresh tokens stay locked inside toknd's Redis vault, drastically reducing your attack surface. All you need to do is secure the store.
|
||||||
|
|
||||||
## Features
|
## Features
|
||||||
|
|
||||||
- Centralized management for multiple OAuth2 providers (Google, Trakt, GitHub, etc.).
|
- **Native Multi-Tenancy:** Isolate tokens for unlimited users/tenants using a single instance.
|
||||||
- Automatic token refreshes.
|
- **Drop-in Infrastructure:** Deploys in seconds via Docker (or Podman) Compose or just a simple Bun script.
|
||||||
- Secure and isolated API access via API key authentication.
|
- **Centralized Provider Management:** Native support for managing multiple OAuth2 providers (Google, GitHub, Trakt, etc.).
|
||||||
- Web-based dashboard for configuration management.
|
- **API Key Security:** Isolated and secure access to the broker via master API keys. Each instance can use its own key for isolation.
|
||||||
- Docker Compose support for simplified deployment.
|
- **Web Dashboard:** Built-in clean ad modern UI for managing provider configurations and viewing live token statuses.
|
||||||
- High performance and low-latency powered by Bun and Redis.
|
- **Blisteringly Fast:** Powered by Bun and Redis for ultra-low latency token retrieval.
|
||||||
|
|
||||||
## Tech Stack
|
## Tech Stack
|
||||||
|
|
||||||
- **Runtime**: [Bun](https://bun.sh/)
|
- **Runtime**: [Bun](https://bun.sh/)
|
||||||
- **Web Framework**: [Hono](https://hono.dev/)
|
- **Web Framework**: [Hono](https://hono.dev/)
|
||||||
- **Data Store**: Redis
|
- **Data Store**: [Redis](https://redis.io/)
|
||||||
- **Styling**: Tailwind CSS & DaisyUI
|
- **Styling**: [Tailwind CSS](https://tailwindcss.com/) & [DaisyUI](https://daisyui.com/)
|
||||||
- **Schema & Validation**: Zod
|
- **Schema & Validation**: [Zod](https://zod.dev/)
|
||||||
|
- **Docs**: [Scalar](https://github.com/scalar/scalar)
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
## Getting Started
|
## Getting Started
|
||||||
|
|
||||||
toknd can be deployed either as a containerized service or self-hosted directly on your hardware.
|
toknd is designed to be too easy to set-up. You can deploy it as a containerized service or host it directly on bare metal.
|
||||||
|
|
||||||
### 1. Environment Setup
|
### 1. Environment Setup
|
||||||
Clone the repository and create your environment file:
|
Clone the repository and set up your environment:
|
||||||
```bash
|
```bash
|
||||||
|
git clone https://git.ramvignesh.dev/toknd_auth.git
|
||||||
|
cd toknd
|
||||||
cp .env.example .env
|
cp .env.example .env
|
||||||
```
|
```
|
||||||
Define a strong `API_KEY` and ensure `REDIS_URL` points to a valid Redis instance.
|
Open `.env`, define your own strong `API_KEY`, and map the ports (optional)
|
||||||
|
|
||||||
### 2. Choose Deployment Method
|
### 2. Choose Deployment Method
|
||||||
|
|
||||||
#### Option A: Containerized (Recommended)
|
#### Option A: Docker Compose (Recommended)
|
||||||
This is the easiest way to get up and running, as it bundles the application and a Redis instance together.
|
The easiest way to get up and running. This spins up both toknd and a dedicated Redis instance.
|
||||||
|
|
||||||
- **Development (with Hot-Reload)**:
|
|
||||||
```bash
|
|
||||||
podman compose up --build
|
|
||||||
```
|
|
||||||
- **Production**:
|
- **Production**:
|
||||||
```bash
|
```bash
|
||||||
docker compose up -d --build
|
docker compose up -d --build
|
||||||
|
(or)
|
||||||
|
podman compose up -d --build
|
||||||
```
|
```
|
||||||
|
|
||||||
#### Option B: Self-Hosting (Bare Metal)
|
|
||||||
Ideal for lightweight deployments or custom environments where you already have Bun and Redis.
|
#### Option B: Bare Metal
|
||||||
|
If you already have Bun and Redis running in your environment.
|
||||||
|
|
||||||
1. **Install Dependencies**:
|
1. **Install Dependencies**:
|
||||||
```bash
|
```bash
|
||||||
bun install
|
bun install
|
||||||
```
|
```
|
||||||
2. **Start the Server**:
|
2. **Start the Server**:
|
||||||
- **Development**: `bun run dev` (with hot-reload)
|
|
||||||
- **Production**: `bun run start`
|
- **Production**: `bun run start`
|
||||||
*Note: Ensure your Redis server is running and accessible via the `REDIS_URL` in your `.env`.*
|
- **Development**: `bun run dev`
|
||||||
|
|
||||||
|
*Note: Make sure your Redis server is running and accessible via the `HOST` and `PORT` in your `.env`.*
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## API Reference
|
## Usage & API Reference
|
||||||
|
|
||||||
toknd provides a built-in **Scalar API Reference** that allows you to explore and test all endpoints directly from your browser.
|
toknd provides a built-in **Scalar API Reference** so you can explore and test endpoints right from your browser.
|
||||||
|
|
||||||
- **Interactive UI**: [http://localhost:3000/api](http://localhost:3000/api) (or `/docs`)
|
- **Interactive UI**: [http://localhost:3000/api](http://localhost:3000/api) (or `/docs`)
|
||||||
- **OpenAPI Spec (JSON)**: [http://localhost:3000/doc](http://localhost:3000/doc)
|
- **OpenAPI Spec**: [http://localhost:3000/doc](http://localhost:3000/doc)
|
||||||
|
|
||||||
All protected endpoints require a Bearer token in the `Authorization` header:
|
### Multi-Tenancy & The Golden Rule
|
||||||
`Authorization: Bearer <your_master_api_key>`
|
All protected endpoints require your master API key and a **Tenant ID** for isolation:
|
||||||
|
|
||||||
### Core Concepts
|
1. **Authentication:** Use your API key in the `Authorization` header.
|
||||||
- **Token Brokerage**: Automated access token retrieval and background refreshes for all configured providers.
|
2. **Isolation:** Pass your unique tenant identifier in the `X-Tenant-ID` header.
|
||||||
- **Provider Management**: Register and manage OAuth2 providers via the Dashboard or the configuration API.
|
|
||||||
|
|
||||||
## Dashboard
|
```http
|
||||||
Access the **toknd** dashboard at:
|
Authorization: Bearer <your_master_api_key>
|
||||||
`http://localhost:3000/app`
|
X-Tenant-ID: <unique_user_or_org_id>
|
||||||
|
```
|
||||||
|
|
||||||
The dashboard allows you to manage provider configurations, view live token statuses, and manually trigger refreshes. Authenticate using your **Master API Key**.
|
### Starting an OAuth Flow
|
||||||
|
To connect a new account for a specific tenant, redirect the user to:
|
||||||
|
`http://localhost:3000/v1/auth/{provider}/login?tenantId={your_tenant_id}`
|
||||||
|
|
||||||
|
### The Dashboard
|
||||||
|
REST API too complicated to use? No problem!
|
||||||
|
You absolutely don't have to manage everything via curl. Access the web dashboard to configure providers, trigger manual refreshes, and monitor token health:
|
||||||
|
**`http://localhost:3000/app`**
|
||||||
|
|
||||||
|
*(Authenticate using your Master API Key).*
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
|
## Contributing
|
||||||
|
|
||||||
|
This is an open-source passion project built to solve a real headache in modern application architecture. Pull requests, issues, and feature requests (especially for new built-in OAuth providers!) are highly encouraged.
|
||||||
|
|
||||||
|
## License
|
||||||
|
|
||||||
|
MIT
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ services:
|
|||||||
- REDIS_HOST=redis
|
- REDIS_HOST=redis
|
||||||
- REDIS_PORT=6379
|
- REDIS_PORT=6379
|
||||||
- API_KEY=${API_KEY}
|
- API_KEY=${API_KEY}
|
||||||
|
- APP_PORT=3000
|
||||||
depends_on:
|
depends_on:
|
||||||
- redis
|
- redis
|
||||||
|
|
||||||
|
|||||||
|
After Width: | Height: | Size: 21 KiB |
|
After Width: | Height: | Size: 77 KiB |
|
After Width: | Height: | Size: 19 KiB |
|
After Width: | Height: | Size: 745 B |
|
After Width: | Height: | Size: 2.0 KiB |
|
After Width: | Height: | Size: 15 KiB |
@@ -0,0 +1,19 @@
|
|||||||
|
{
|
||||||
|
"name": "toknd_auth_broker",
|
||||||
|
"short_name": "toknd",
|
||||||
|
"icons": [
|
||||||
|
{
|
||||||
|
"src": "/android-chrome-192x192.png",
|
||||||
|
"sizes": "192x192",
|
||||||
|
"type": "image/png"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"src": "/android-chrome-512x512.png",
|
||||||
|
"sizes": "512x512",
|
||||||
|
"type": "image/png"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"theme_color": "#bdff00",
|
||||||
|
"background_color": "#000",
|
||||||
|
"display": "standalone"
|
||||||
|
}
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
import { API_VERSION, APP_VERSION } from "./version";
|
||||||
|
|
||||||
|
export { API_VERSION, APP_VERSION };
|
||||||
|
export const API_PREFIX = `/api/${API_VERSION}`;
|
||||||
|
export const AUTH_PREFIX = `/${API_VERSION}/auth`;
|
||||||
|
export const DOCS_PREFIX = `/docs/${API_VERSION}`;
|
||||||
@@ -40,4 +40,13 @@ export class ConfigManager {
|
|||||||
|
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async deleteProviderConfig(provider: string): Promise<void> {
|
||||||
|
await this.redis.del(`config:${provider}`);
|
||||||
|
// Also clean up tokens across all tenants
|
||||||
|
const tokenKeys = await this.redis.keys(`tenant:*:provider:${provider}:*`);
|
||||||
|
if (tokenKeys.length > 0) {
|
||||||
|
await this.redis.del(...tokenKeys);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,38 +7,38 @@ export class TokenManager {
|
|||||||
private provider: OAuthProvider,
|
private provider: OAuthProvider,
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
async getAccessToken(providerName: string): Promise<string | null> {
|
async getAccessToken(tenantId: string, providerName: string): Promise<string | null> {
|
||||||
const accessKey = `provider:${providerName}:access_token`;
|
const accessKey = `tenant:${tenantId}:provider:${providerName}:access_token`;
|
||||||
const cached = await this.redis.get(accessKey);
|
const cached = await this.redis.get(accessKey);
|
||||||
if (cached) return cached;
|
if (cached) return cached;
|
||||||
|
|
||||||
const refreshKey = `provider:${providerName}:refresh_token`;
|
const refreshKey = `tenant:${tenantId}:provider:${providerName}:refresh_token`;
|
||||||
const refreshToken = await this.redis.get(refreshKey);
|
const refreshToken = await this.redis.get(refreshKey);
|
||||||
if (!refreshToken) return null;
|
if (!refreshToken) return null;
|
||||||
|
|
||||||
const tokens = await this.provider.refreshToken(refreshToken);
|
const tokens = await this.provider.refreshToken(refreshToken);
|
||||||
await this.saveTokens(providerName, tokens);
|
await this.saveTokens(tenantId, providerName, tokens);
|
||||||
return tokens.accessToken;
|
return tokens.accessToken;
|
||||||
}
|
}
|
||||||
|
|
||||||
async refreshAccessToken(providerName: string): Promise<string | null> {
|
async refreshAccessToken(tenantId: string, providerName: string): Promise<string | null> {
|
||||||
const refreshKey = `provider:${providerName}:refresh_token`;
|
const refreshKey = `tenant:${tenantId}:provider:${providerName}:refresh_token`;
|
||||||
const refreshToken = await this.redis.get(refreshKey);
|
const refreshToken = await this.redis.get(refreshKey);
|
||||||
if (!refreshToken) return null;
|
if (!refreshToken) return null;
|
||||||
|
|
||||||
const tokens = await this.provider.refreshToken(refreshToken);
|
const tokens = await this.provider.refreshToken(refreshToken);
|
||||||
await this.saveTokens(providerName, tokens);
|
await this.saveTokens(tenantId, providerName, tokens);
|
||||||
return tokens.accessToken;
|
return tokens.accessToken;
|
||||||
}
|
}
|
||||||
|
|
||||||
async saveTokens(providerName: string, tokens: TokenResponse) {
|
async saveTokens(tenantId: string, providerName: string, tokens: TokenResponse) {
|
||||||
|
const baseKey = `tenant:${tenantId}:provider:${providerName}`;
|
||||||
|
await this.redis.set(`${baseKey}:access_token`, tokens.accessToken, "EX", tokens.expiresIn);
|
||||||
|
await this.redis.set(`${baseKey}:refresh_token`, tokens.refreshToken);
|
||||||
|
await this.redis.set(`${baseKey}:last_updated`, new Date().toISOString());
|
||||||
await this.redis.set(
|
await this.redis.set(
|
||||||
`provider:${providerName}:access_token`,
|
`${baseKey}:expires_at`,
|
||||||
tokens.accessToken,
|
new Date(Date.now() + tokens.expiresIn * 1000).toISOString(),
|
||||||
"EX",
|
|
||||||
tokens.expiresIn,
|
|
||||||
);
|
);
|
||||||
await this.redis.set(`provider:${providerName}:refresh_token`, tokens.refreshToken);
|
|
||||||
await this.redis.set(`provider:${providerName}:last_updated`, new Date().toISOString());
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,7 +4,9 @@ import { serveStatic } from "hono/bun";
|
|||||||
import { logger } from "hono/logger";
|
import { logger } from "hono/logger";
|
||||||
import { prettyJSON } from "hono/pretty-json";
|
import { prettyJSON } from "hono/pretty-json";
|
||||||
import { config } from "./config";
|
import { config } from "./config";
|
||||||
|
import { API_PREFIX, AUTH_PREFIX, DOCS_PREFIX } from "./constants";
|
||||||
import { redis } from "./core/RedisClient";
|
import { redis } from "./core/RedisClient";
|
||||||
|
import { openApiSpec, securityScheme, tenantIdScheme } from "./openapi";
|
||||||
import { apiRoutes } from "./routes/api";
|
import { apiRoutes } from "./routes/api";
|
||||||
import { authRoutes } from "./routes/auth";
|
import { authRoutes } from "./routes/auth";
|
||||||
import { configRoutes } from "./routes/config";
|
import { configRoutes } from "./routes/config";
|
||||||
@@ -13,39 +15,32 @@ import { dashboardRoutes } from "./routes/dashboard";
|
|||||||
const app = new OpenAPIHono({ strict: false });
|
const app = new OpenAPIHono({ strict: false });
|
||||||
|
|
||||||
// OpenAPI specs
|
// OpenAPI specs
|
||||||
app.doc("/doc", {
|
app.doc(`${DOCS_PREFIX}/openapi.json`, openApiSpec);
|
||||||
openapi: "3.0.0",
|
app.openAPIRegistry.registerComponent("securitySchemes", "API_KEY", securityScheme);
|
||||||
info: {
|
app.openAPIRegistry.registerComponent("securitySchemes", "TENANT_ID", tenantIdScheme);
|
||||||
version: "1.0.0",
|
|
||||||
title: "toknd — Auth Broker API",
|
|
||||||
description: "Centralized token management and OAuth2 broker service.",
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
app.openAPIRegistry.registerComponent("securitySchemes", "API_KEY", {
|
|
||||||
type: "http",
|
|
||||||
scheme: "bearer",
|
|
||||||
});
|
|
||||||
|
|
||||||
// Scalar API Reference
|
// Scalar API Reference
|
||||||
app.get(
|
app.get(
|
||||||
"/api",
|
DOCS_PREFIX,
|
||||||
Scalar({
|
Scalar({
|
||||||
theme: "solarized",
|
theme: "solarized",
|
||||||
url: "/doc",
|
url: `${DOCS_PREFIX}/openapi.json`,
|
||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
app.get("/docs", (c) => c.redirect("/api"));
|
app.get("/docs", (c) => c.redirect(DOCS_PREFIX));
|
||||||
|
app.get("/api", (c) => c.redirect(DOCS_PREFIX));
|
||||||
|
|
||||||
app.use("*", logger());
|
app.use("*", logger());
|
||||||
app.use("*", prettyJSON());
|
app.use("*", prettyJSON());
|
||||||
|
|
||||||
app.get("/", (c) => c.redirect("/app"));
|
app.get("/", (c) => c.redirect("/app"));
|
||||||
|
|
||||||
|
app.get("/favicon.ico", serveStatic({ path: "./public/favicon.ico" }));
|
||||||
|
app.use("/static/*", serveStatic({ root: "./public" }));
|
||||||
app.get("/app/dashboard.js", serveStatic({ path: "./src/views/dashboard.js" }));
|
app.get("/app/dashboard.js", serveStatic({ path: "./src/views/dashboard.js" }));
|
||||||
app.route("/auth", authRoutes);
|
app.route(AUTH_PREFIX, authRoutes);
|
||||||
app.route("/api/config", configRoutes);
|
app.route(`${API_PREFIX}/config`, configRoutes);
|
||||||
app.route("/api", apiRoutes);
|
app.route(API_PREFIX, apiRoutes);
|
||||||
app.route("/app", dashboardRoutes);
|
app.route("/app", dashboardRoutes);
|
||||||
|
|
||||||
app.notFound((c) => {
|
app.notFound((c) => {
|
||||||
|
|||||||
@@ -1,14 +1,22 @@
|
|||||||
import type { Context, Next } from "hono";
|
import type { Context, Next } from "hono";
|
||||||
|
import { getCookie } from "hono/cookie";
|
||||||
import { config } from "../config";
|
import { config } from "../config";
|
||||||
|
|
||||||
export const authMiddleware = async (c: Context, next: Next) => {
|
export const authMiddleware = async (c: Context, next: Next) => {
|
||||||
const authHeader = c.req.header("Authorization");
|
const authHeader = c.req.header("Authorization");
|
||||||
|
const cookieToken = getCookie(c, "toknd_api_key");
|
||||||
|
|
||||||
if (!authHeader?.startsWith("Bearer ")) {
|
let token: string | undefined;
|
||||||
return c.json({ error: "Missing or invalid authorization header" }, 401);
|
|
||||||
|
if (authHeader?.startsWith("Bearer ")) {
|
||||||
|
token = authHeader.split(" ")[1];
|
||||||
|
} else if (cookieToken) {
|
||||||
|
token = cookieToken;
|
||||||
}
|
}
|
||||||
|
|
||||||
const token = authHeader.split(" ")[1];
|
if (!token) {
|
||||||
|
return c.json({ error: "Missing or invalid authorization" }, 401);
|
||||||
|
}
|
||||||
|
|
||||||
if (token !== config.API_KEY) {
|
if (token !== config.API_KEY) {
|
||||||
return c.json({ error: "Invalid API key" }, 403);
|
return c.json({ error: "Invalid API key" }, 403);
|
||||||
|
|||||||
@@ -0,0 +1,38 @@
|
|||||||
|
import { API_VERSION, APP_VERSION } from "./constants";
|
||||||
|
|
||||||
|
export const openApiSpec = {
|
||||||
|
openapi: "3.0.0",
|
||||||
|
info: {
|
||||||
|
version: `${API_VERSION}.${APP_VERSION}`,
|
||||||
|
title: "toknd Auth Broker API",
|
||||||
|
description:
|
||||||
|
"A high-performance OAuth2 broker and token management service with multi-tenancy support. Designed to centralize provider configurations and automate token lifecycle management across distributed systems, securely isolated by Tenant IDs.",
|
||||||
|
},
|
||||||
|
tags: [
|
||||||
|
{
|
||||||
|
name: "Tokens",
|
||||||
|
description: "Endpoint operations for accessing and force-refreshing active provider tokens.",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Management",
|
||||||
|
description: "Administrative operations for provider lifecycle and configuration.",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Auth (Internal)",
|
||||||
|
description: "System-level OAuth2 handshake and callback processing.",
|
||||||
|
},
|
||||||
|
],
|
||||||
|
security: [{ API_KEY: [], TENANT_ID: [] }],
|
||||||
|
};
|
||||||
|
|
||||||
|
export const securityScheme = {
|
||||||
|
type: "http",
|
||||||
|
scheme: "bearer",
|
||||||
|
} as const;
|
||||||
|
|
||||||
|
export const tenantIdScheme = {
|
||||||
|
type: "apiKey",
|
||||||
|
in: "header",
|
||||||
|
name: "X-Tenant-ID",
|
||||||
|
description: "The unique identifier for the tenant (user or organization).",
|
||||||
|
} as const;
|
||||||
@@ -15,6 +15,10 @@ const StatusResponseSchema = z
|
|||||||
accessToken: z.string().nullable(),
|
accessToken: z.string().nullable(),
|
||||||
refreshToken: z.string().nullable(),
|
refreshToken: z.string().nullable(),
|
||||||
lastUpdated: z.string().nullable(),
|
lastUpdated: z.string().nullable(),
|
||||||
|
expiresAt: z.string().nullable().openapi({
|
||||||
|
example: "2026-05-12T10:00:00.000Z",
|
||||||
|
description: "ISO timestamp of when the access token expires",
|
||||||
|
}),
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
.openapi("StatusResponse");
|
.openapi("StatusResponse");
|
||||||
@@ -32,6 +36,10 @@ const RefreshResponseSchema = z
|
|||||||
accessToken: z.string().nullable(),
|
accessToken: z.string().nullable(),
|
||||||
refreshToken: z.string().nullable(),
|
refreshToken: z.string().nullable(),
|
||||||
lastUpdated: z.string().nullable(),
|
lastUpdated: z.string().nullable(),
|
||||||
|
expiresAt: z.string().nullable().openapi({
|
||||||
|
example: "2026-05-12T10:00:00.000Z",
|
||||||
|
description: "ISO timestamp of when the access token expires",
|
||||||
|
}),
|
||||||
}),
|
}),
|
||||||
})
|
})
|
||||||
.openapi("RefreshResponse");
|
.openapi("RefreshResponse");
|
||||||
@@ -46,7 +54,13 @@ const ErrorSchema = z
|
|||||||
const statusRoute = createRoute({
|
const statusRoute = createRoute({
|
||||||
method: "get",
|
method: "get",
|
||||||
path: "/status",
|
path: "/status",
|
||||||
security: [{ API_KEY: [] }],
|
security: [{ API_KEY: [], TENANT_ID: [] }],
|
||||||
|
tags: ["Tokens"],
|
||||||
|
request: {
|
||||||
|
headers: z.object({
|
||||||
|
"x-tenant-id": z.string().openapi({ example: "my-tenant" }),
|
||||||
|
}),
|
||||||
|
},
|
||||||
responses: {
|
responses: {
|
||||||
200: {
|
200: {
|
||||||
content: { "application/json": { schema: StatusResponseSchema } },
|
content: { "application/json": { schema: StatusResponseSchema } },
|
||||||
@@ -58,11 +72,15 @@ const statusRoute = createRoute({
|
|||||||
const tokenRoute = createRoute({
|
const tokenRoute = createRoute({
|
||||||
method: "get",
|
method: "get",
|
||||||
path: "/token/{provider}",
|
path: "/token/{provider}",
|
||||||
security: [{ API_KEY: [] }],
|
security: [{ API_KEY: [], TENANT_ID: [] }],
|
||||||
|
tags: ["Tokens"],
|
||||||
request: {
|
request: {
|
||||||
params: z.object({
|
params: z.object({
|
||||||
provider: z.string().openapi({ example: "trakt" }),
|
provider: z.string().openapi({ example: "trakt" }),
|
||||||
}),
|
}),
|
||||||
|
headers: z.object({
|
||||||
|
"x-tenant-id": z.string().openapi({ example: "my-tenant" }),
|
||||||
|
}),
|
||||||
},
|
},
|
||||||
responses: {
|
responses: {
|
||||||
200: {
|
200: {
|
||||||
@@ -79,11 +97,15 @@ const tokenRoute = createRoute({
|
|||||||
const refreshRoute = createRoute({
|
const refreshRoute = createRoute({
|
||||||
method: "post",
|
method: "post",
|
||||||
path: "/refresh/{provider}",
|
path: "/refresh/{provider}",
|
||||||
security: [{ API_KEY: [] }],
|
security: [{ API_KEY: [], TENANT_ID: [] }],
|
||||||
|
tags: ["Tokens"],
|
||||||
request: {
|
request: {
|
||||||
params: z.object({
|
params: z.object({
|
||||||
provider: z.string().openapi({ example: "trakt" }),
|
provider: z.string().openapi({ example: "trakt" }),
|
||||||
}),
|
}),
|
||||||
|
headers: z.object({
|
||||||
|
"x-tenant-id": z.string().openapi({ example: "my-tenant" }),
|
||||||
|
}),
|
||||||
},
|
},
|
||||||
responses: {
|
responses: {
|
||||||
200: {
|
200: {
|
||||||
@@ -101,15 +123,18 @@ const refreshRoute = createRoute({
|
|||||||
apiRoutes.use("*", authMiddleware);
|
apiRoutes.use("*", authMiddleware);
|
||||||
|
|
||||||
apiRoutes.openapi(statusRoute, async (c) => {
|
apiRoutes.openapi(statusRoute, async (c) => {
|
||||||
|
const tenantId = c.req.valid("header")["x-tenant-id"];
|
||||||
const configManager = new ConfigManager(redis);
|
const configManager = new ConfigManager(redis);
|
||||||
const providers = await configManager.getAllProviders();
|
const providers = await configManager.getAllProviders();
|
||||||
const status: z.infer<typeof StatusResponseSchema> = {};
|
const status: z.infer<typeof StatusResponseSchema> = {};
|
||||||
|
|
||||||
for (const provider of Object.keys(providers)) {
|
for (const provider of Object.keys(providers)) {
|
||||||
const accessToken = await redis.get(`provider:${provider}:access_token`);
|
const baseKey = `tenant:${tenantId}:provider:${provider}`;
|
||||||
const refreshToken = await redis.get(`provider:${provider}:refresh_token`);
|
const accessToken = await redis.get(`${baseKey}:access_token`);
|
||||||
const lastUpdated = await redis.get(`provider:${provider}:last_updated`);
|
const refreshToken = await redis.get(`${baseKey}:refresh_token`);
|
||||||
status[provider] = { accessToken, refreshToken, lastUpdated };
|
const lastUpdated = await redis.get(`${baseKey}:last_updated`);
|
||||||
|
const expiresAt = await redis.get(`${baseKey}:expires_at`);
|
||||||
|
status[provider] = { accessToken, refreshToken, lastUpdated, expiresAt };
|
||||||
}
|
}
|
||||||
|
|
||||||
return c.json(status, 200);
|
return c.json(status, 200);
|
||||||
@@ -117,6 +142,7 @@ apiRoutes.openapi(statusRoute, async (c) => {
|
|||||||
|
|
||||||
apiRoutes.openapi(tokenRoute, async (c) => {
|
apiRoutes.openapi(tokenRoute, async (c) => {
|
||||||
const providerName = c.req.valid("param").provider;
|
const providerName = c.req.valid("param").provider;
|
||||||
|
const tenantId = c.req.valid("header")["x-tenant-id"];
|
||||||
const configManager = new ConfigManager(redis);
|
const configManager = new ConfigManager(redis);
|
||||||
const providerConfig = await configManager.getProviderConfig(providerName);
|
const providerConfig = await configManager.getProviderConfig(providerName);
|
||||||
|
|
||||||
@@ -127,7 +153,7 @@ apiRoutes.openapi(tokenRoute, async (c) => {
|
|||||||
const provider = new GenericProvider(providerName, providerConfig);
|
const provider = new GenericProvider(providerName, providerConfig);
|
||||||
const tokenManager = new TokenManager(redis, provider);
|
const tokenManager = new TokenManager(redis, provider);
|
||||||
|
|
||||||
const accessToken = await tokenManager.getAccessToken(providerName);
|
const accessToken = await tokenManager.getAccessToken(tenantId, providerName);
|
||||||
if (!accessToken) {
|
if (!accessToken) {
|
||||||
return c.json({ error: "No tokens found for provider" }, 404);
|
return c.json({ error: "No tokens found for provider" }, 404);
|
||||||
}
|
}
|
||||||
@@ -136,6 +162,7 @@ apiRoutes.openapi(tokenRoute, async (c) => {
|
|||||||
|
|
||||||
apiRoutes.openapi(refreshRoute, async (c) => {
|
apiRoutes.openapi(refreshRoute, async (c) => {
|
||||||
const providerName = c.req.valid("param").provider;
|
const providerName = c.req.valid("param").provider;
|
||||||
|
const tenantId = c.req.valid("header")["x-tenant-id"];
|
||||||
const configManager = new ConfigManager(redis);
|
const configManager = new ConfigManager(redis);
|
||||||
const providerConfig = await configManager.getProviderConfig(providerName);
|
const providerConfig = await configManager.getProviderConfig(providerName);
|
||||||
|
|
||||||
@@ -146,15 +173,17 @@ apiRoutes.openapi(refreshRoute, async (c) => {
|
|||||||
const provider = new GenericProvider(providerName, providerConfig);
|
const provider = new GenericProvider(providerName, providerConfig);
|
||||||
const tokenManager = new TokenManager(redis, provider);
|
const tokenManager = new TokenManager(redis, provider);
|
||||||
|
|
||||||
await tokenManager.refreshAccessToken(providerName);
|
await tokenManager.refreshAccessToken(tenantId, providerName);
|
||||||
const accessToken = await redis.get(`provider:${providerName}:access_token`);
|
const baseKey = `tenant:${tenantId}:provider:${providerName}`;
|
||||||
const refreshToken = await redis.get(`provider:${providerName}:refresh_token`);
|
const accessToken = await redis.get(`${baseKey}:access_token`);
|
||||||
const lastUpdated = await redis.get(`provider:${providerName}:last_updated`);
|
const refreshToken = await redis.get(`${baseKey}:refresh_token`);
|
||||||
|
const lastUpdated = await redis.get(`${baseKey}:last_updated`);
|
||||||
|
const expiresAt = await redis.get(`${baseKey}:expires_at`);
|
||||||
|
|
||||||
return c.json(
|
return c.json(
|
||||||
{
|
{
|
||||||
success: true,
|
success: true,
|
||||||
status: { accessToken, refreshToken, lastUpdated },
|
status: { accessToken, refreshToken, lastUpdated, expiresAt },
|
||||||
},
|
},
|
||||||
200,
|
200,
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -17,10 +17,15 @@ const AuthErrorResponse = z
|
|||||||
const loginRoute = createRoute({
|
const loginRoute = createRoute({
|
||||||
method: "get",
|
method: "get",
|
||||||
path: "/{provider}/login",
|
path: "/{provider}/login",
|
||||||
|
tags: ["Auth (Internal)"],
|
||||||
|
summary: "Start OAuth2 flow (Managed by System)",
|
||||||
request: {
|
request: {
|
||||||
params: z.object({
|
params: z.object({
|
||||||
provider: z.string().openapi({ example: "trakt" }),
|
provider: z.string().openapi({ example: "trakt" }),
|
||||||
}),
|
}),
|
||||||
|
query: z.object({
|
||||||
|
tenantId: z.string().openapi({ example: "my-tenant" }),
|
||||||
|
}),
|
||||||
},
|
},
|
||||||
responses: {
|
responses: {
|
||||||
302: {
|
302: {
|
||||||
@@ -36,18 +41,17 @@ const loginRoute = createRoute({
|
|||||||
const callbackRoute = createRoute({
|
const callbackRoute = createRoute({
|
||||||
method: "get",
|
method: "get",
|
||||||
path: "/callback",
|
path: "/callback",
|
||||||
|
tags: ["Auth (Internal)"],
|
||||||
|
summary: "OAuth2 callback handler (Managed by System)",
|
||||||
request: {
|
request: {
|
||||||
query: z.object({
|
query: z.object({
|
||||||
state: z
|
state: z.string().openapi({ description: "Composite state: tenantId:providerName" }),
|
||||||
.string()
|
|
||||||
.openapi({ description: "The provider name (passed as state during login)" }),
|
|
||||||
code: z.string().openapi({ description: "The authorization code from the provider" }),
|
code: z.string().openapi({ description: "The authorization code from the provider" }),
|
||||||
}),
|
}),
|
||||||
},
|
},
|
||||||
responses: {
|
responses: {
|
||||||
200: {
|
302: {
|
||||||
description: "Success page indicating successful token exchange",
|
description: "Redirect to success page",
|
||||||
content: { "text/html": { schema: { type: "string" } } },
|
|
||||||
},
|
},
|
||||||
400: {
|
400: {
|
||||||
content: { "application/json": { schema: AuthErrorResponse } },
|
content: { "application/json": { schema: AuthErrorResponse } },
|
||||||
@@ -67,6 +71,7 @@ const callbackRoute = createRoute({
|
|||||||
// Implementations
|
// Implementations
|
||||||
authRoutes.openapi(loginRoute, async (c) => {
|
authRoutes.openapi(loginRoute, async (c) => {
|
||||||
const providerName = c.req.valid("param").provider;
|
const providerName = c.req.valid("param").provider;
|
||||||
|
const tenantId = c.req.valid("query").tenantId;
|
||||||
const configManager = new ConfigManager(redis);
|
const configManager = new ConfigManager(redis);
|
||||||
const providerConfig = await configManager.getProviderConfig(providerName);
|
const providerConfig = await configManager.getProviderConfig(providerName);
|
||||||
|
|
||||||
@@ -84,11 +89,27 @@ authRoutes.openapi(loginRoute, async (c) => {
|
|||||||
const url = new URL(c.req.url);
|
const url = new URL(c.req.url);
|
||||||
const redirectUri = providerConfig.redirectUri || `${url.origin}/auth/callback`;
|
const redirectUri = providerConfig.redirectUri || `${url.origin}/auth/callback`;
|
||||||
|
|
||||||
return c.redirect(provider.getAuthUrl(providerName, redirectUri));
|
// Pass both tenantId and providerName in state
|
||||||
|
const state = `${tenantId}:${providerName}`;
|
||||||
|
return c.redirect(provider.getAuthUrl(state, redirectUri));
|
||||||
});
|
});
|
||||||
|
|
||||||
authRoutes.openapi(callbackRoute, async (c) => {
|
authRoutes.openapi(callbackRoute, async (c) => {
|
||||||
const { state: providerName, code } = c.req.valid("query");
|
const { state, code } = c.req.valid("query");
|
||||||
|
|
||||||
|
// state is expected to be "tenantId:providerName"
|
||||||
|
const parts = state.split(":");
|
||||||
|
if (parts.length !== 2) {
|
||||||
|
return c.json(
|
||||||
|
{
|
||||||
|
error: "Invalid State",
|
||||||
|
message: "The state parameter is invalid.",
|
||||||
|
},
|
||||||
|
400,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const [tenantId, providerName] = parts;
|
||||||
|
|
||||||
const configManager = new ConfigManager(redis);
|
const configManager = new ConfigManager(redis);
|
||||||
const providerConfig = await configManager.getProviderConfig(providerName);
|
const providerConfig = await configManager.getProviderConfig(providerName);
|
||||||
@@ -111,9 +132,9 @@ authRoutes.openapi(callbackRoute, async (c) => {
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
const tokens = await provider.exchangeCode(code, redirectUri);
|
const tokens = await provider.exchangeCode(code, redirectUri);
|
||||||
await tokenManager.saveTokens(providerName, tokens);
|
await tokenManager.saveTokens(tenantId, providerName, tokens);
|
||||||
|
|
||||||
return c.redirect(`/app/success?provider=${providerName}`);
|
return c.redirect(`/app/success?provider=${providerName}&tenantId=${tenantId}`);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
const errorMessage = error instanceof Error ? error.message : "An unexpected error occurred.";
|
const errorMessage = error instanceof Error ? error.message : "An unexpected error occurred.";
|
||||||
console.error(`[OAuth Error] ${errorMessage}`);
|
console.error(`[OAuth Error] ${errorMessage}`);
|
||||||
|
|||||||
@@ -38,6 +38,7 @@ const listConfigRoute = createRoute({
|
|||||||
method: "get",
|
method: "get",
|
||||||
path: "/",
|
path: "/",
|
||||||
security: [{ API_KEY: [] }],
|
security: [{ API_KEY: [] }],
|
||||||
|
tags: ["Management"],
|
||||||
responses: {
|
responses: {
|
||||||
200: {
|
200: {
|
||||||
content: { "application/json": { schema: AllProvidersResponse } },
|
content: { "application/json": { schema: AllProvidersResponse } },
|
||||||
@@ -50,6 +51,7 @@ const setConfigRoute = createRoute({
|
|||||||
method: "post",
|
method: "post",
|
||||||
path: "/{provider}",
|
path: "/{provider}",
|
||||||
security: [{ API_KEY: [] }],
|
security: [{ API_KEY: [] }],
|
||||||
|
tags: ["Management"],
|
||||||
request: {
|
request: {
|
||||||
params: z.object({
|
params: z.object({
|
||||||
provider: z.string().openapi({ example: "trakt" }),
|
provider: z.string().openapi({ example: "trakt" }),
|
||||||
@@ -70,6 +72,24 @@ const setConfigRoute = createRoute({
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const deleteConfigRoute = createRoute({
|
||||||
|
method: "delete",
|
||||||
|
path: "/{provider}",
|
||||||
|
security: [{ API_KEY: [] }],
|
||||||
|
tags: ["Management"],
|
||||||
|
request: {
|
||||||
|
params: z.object({
|
||||||
|
provider: z.string().openapi({ example: "trakt" }),
|
||||||
|
}),
|
||||||
|
},
|
||||||
|
responses: {
|
||||||
|
200: {
|
||||||
|
content: { "application/json": { schema: SuccessMessage } },
|
||||||
|
description: "Delete a provider configuration and its tokens",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
// Implementations
|
// Implementations
|
||||||
configRoutes.use("*", authMiddleware);
|
configRoutes.use("*", authMiddleware);
|
||||||
|
|
||||||
@@ -88,4 +108,12 @@ configRoutes.openapi(setConfigRoute, async (c) => {
|
|||||||
return c.json({ message: `Config for ${provider} saved successfully` }, 200);
|
return c.json({ message: `Config for ${provider} saved successfully` }, 200);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
configRoutes.openapi(deleteConfigRoute, async (c) => {
|
||||||
|
const provider = c.req.valid("param").provider;
|
||||||
|
const configManager = new ConfigManager(redis);
|
||||||
|
|
||||||
|
await configManager.deleteProviderConfig(provider);
|
||||||
|
return c.json({ message: `Config for ${provider} deleted successfully` }, 200);
|
||||||
|
});
|
||||||
|
|
||||||
export { configRoutes };
|
export { configRoutes };
|
||||||
|
|||||||
@@ -1,11 +1,14 @@
|
|||||||
/** @jsxImportSource hono/jsx */
|
/** @jsxImportSource hono/jsx */
|
||||||
import { Hono } from "hono";
|
import { Hono } from "hono";
|
||||||
|
import { deleteCookie, getCookie, setCookie } from "hono/cookie";
|
||||||
import { html } from "hono/html";
|
import { html } from "hono/html";
|
||||||
import type { Child } from "hono/jsx";
|
import type { Child } from "hono/jsx";
|
||||||
|
import { config } from "../config";
|
||||||
|
import { API_PREFIX, API_VERSION, APP_VERSION, AUTH_PREFIX, DOCS_PREFIX } from "../constants";
|
||||||
|
|
||||||
const dashboardRoutes = new Hono({ strict: false });
|
const dashboardRoutes = new Hono({ strict: false });
|
||||||
|
|
||||||
export const Layout = (props: { title: string; children: Child }) => (
|
export const Layout = (props: { title: string; children: Child; isUnlocked?: boolean }) => (
|
||||||
<>
|
<>
|
||||||
{html`<!DOCTYPE html>`}
|
{html`<!DOCTYPE html>`}
|
||||||
<html lang="en" data-theme="abyss">
|
<html lang="en" data-theme="abyss">
|
||||||
@@ -13,6 +16,7 @@ export const Layout = (props: { title: string; children: Child }) => (
|
|||||||
<meta charset="UTF-8" />
|
<meta charset="UTF-8" />
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
||||||
<title>{props.title}</title>
|
<title>{props.title}</title>
|
||||||
|
<link rel="icon" type="image/png" href="/favicon.ico" />
|
||||||
<link href="https://cdn.jsdelivr.net/npm/daisyui@5" rel="stylesheet" type="text/css" />
|
<link href="https://cdn.jsdelivr.net/npm/daisyui@5" rel="stylesheet" type="text/css" />
|
||||||
<script src="https://cdn.jsdelivr.net/npm/@tailwindcss/browser@4"></script>
|
<script src="https://cdn.jsdelivr.net/npm/@tailwindcss/browser@4"></script>
|
||||||
<link
|
<link
|
||||||
@@ -32,12 +36,22 @@ export const Layout = (props: { title: string; children: Child }) => (
|
|||||||
.font-mono {
|
.font-mono {
|
||||||
font-family: "DM Mono", monospace;
|
font-family: "DM Mono", monospace;
|
||||||
}
|
}
|
||||||
|
.text-xxs {
|
||||||
|
font-size: 10px;
|
||||||
|
}
|
||||||
`}
|
`}
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
<body
|
<body
|
||||||
class="bg-base-200/50 min-h-screen font-['DM_Sans',sans-serif] antialiased text-base-content tracking-tight"
|
class="bg-base-200/50 min-h-screen font-['DM_Sans',sans-serif] antialiased text-base-content tracking-tight"
|
||||||
x-data="dashboard"
|
x-data={`dashboard({
|
||||||
|
initialIsUnlocked: ${props.isUnlocked || false},
|
||||||
|
apiVersion: '${API_VERSION}',
|
||||||
|
appVersion: '${APP_VERSION}',
|
||||||
|
apiPrefix: '${API_PREFIX}',
|
||||||
|
authPrefix: '${AUTH_PREFIX}',
|
||||||
|
docsPrefix: '${DOCS_PREFIX}'
|
||||||
|
})`}
|
||||||
>
|
>
|
||||||
{props.children}
|
{props.children}
|
||||||
<script src="/app/dashboard.js"></script>
|
<script src="/app/dashboard.js"></script>
|
||||||
@@ -47,389 +61,557 @@ export const Layout = (props: { title: string; children: Child }) => (
|
|||||||
</>
|
</>
|
||||||
);
|
);
|
||||||
|
|
||||||
export const Dashboard = () => (
|
export const Dashboard = (props: { isUnlocked: boolean }) => (
|
||||||
<Layout title="toknd — Auth Broker Dashboard">
|
<Layout title="toknd — Auth Broker Dashboard" isUnlocked={props.isUnlocked}>
|
||||||
<div class="navbar bg-base-100 shadow-sm px-4 md:px-8 border-b border-base-300">
|
<div class="flex flex-col min-h-screen">
|
||||||
<div class="flex-1">
|
<div class="navbar bg-base-100 shadow-sm px-4 md:px-8 border-b border-base-300 relative z-50">
|
||||||
<div class="flex items-center gap-2">
|
<div class="flex-1 flex items-center gap-6">
|
||||||
<div class="w-8 h-8 bg-primary rounded-lg flex items-center justify-center text-primary-content font-semibold text-lg">
|
<div class="flex items-center gap-2">
|
||||||
<i class="ph-duotone ph-fingerprint"></i>
|
<div class="w-8 h-8 bg-primary rounded-lg flex items-center justify-center text-primary-content font-semibold text-lg">
|
||||||
</div>
|
<i class="ph-duotone ph-fingerprint"></i>
|
||||||
<div class="text-xl font-semibold tracking-tight">
|
|
||||||
toknd <span class="text-xs font-normal opacity-50 ml-1">auth broker</span>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
<div class="flex-none hidden sm:flex">
|
|
||||||
<div class="join border border-base-200/50 bg-base-200/50 rounded-xl overflow-hidden focus-within:border-primary transition-colors">
|
|
||||||
<div class="join-item flex items-center px-4 bg-base-200">
|
|
||||||
<i class="ph-duotone ph-key text-secondary text-lg"></i>
|
|
||||||
</div>
|
|
||||||
<div class="relative flex-1" x-data="{ show: false }">
|
|
||||||
<input
|
|
||||||
x-bind:type="show ? 'text' : 'password'"
|
|
||||||
id="apiKey"
|
|
||||||
name="apiKey"
|
|
||||||
x-model="apiKey"
|
|
||||||
aria-label="Master API Key"
|
|
||||||
placeholder="API_KEY"
|
|
||||||
class="input join-item input-sm bg-transparent border-none focus:outline-none w-48 lg:w-64 text-xs pr-10 font-mono"
|
|
||||||
/>
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
x-on:click="show = !show"
|
|
||||||
class="absolute right-2 top-1/2 -translate-y-1/2 btn btn-ghost btn-xs btn-square"
|
|
||||||
>
|
|
||||||
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-base opacity-50' : 'ph-duotone ph-eye text-base opacity-50'"></i>
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
<button
|
|
||||||
x-on:click="unlock()"
|
|
||||||
type="submit"
|
|
||||||
class="btn btn-primary btn-sm join-item px-6"
|
|
||||||
x-bind:disabled="loading"
|
|
||||||
>
|
|
||||||
<i class="ph-duotone ph-lock-key-open text-lg" x-show="!loading"></i>
|
|
||||||
<span class="loading loading-spinner loading-xs" x-show="loading"></span>
|
|
||||||
<span class="ml-1 hidden md:inline" x-text="loading ? 'Unlocking...' : 'Unlock'"></span>
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="container mx-auto p-4 md:p-8 max-w-7xl">
|
|
||||||
<div class="grid grid-cols-1 lg:grid-cols-12 gap-6 md:gap-8">
|
|
||||||
<div class="card bg-base-100 shadow-xl border border-base-300 lg:col-span-4 self-start">
|
|
||||||
<div class="card-body p-6">
|
|
||||||
<div class="flex items-center gap-2 mb-4">
|
|
||||||
<div class="w-2 h-6 bg-primary rounded-full"></div>
|
|
||||||
<h2 class="card-title text-xl font-semibold">Configure Provider</h2>
|
|
||||||
</div>
|
</div>
|
||||||
|
<div class="text-xl font-semibold tracking-tight">
|
||||||
|
toknd <span class="text-xs font-normal opacity-50 ml-1">auth broker</span>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
<form x-on:submit="saveConfig" class="space-y-4">
|
<div class="flex-none lg:hidden">
|
||||||
<div class="form-control">
|
<label for="mobile-menu" class="btn btn-square btn-ghost">
|
||||||
<label htmlFor="providerName" class="label py-1">
|
<i class="ph-duotone ph-chart-donut text-3xl"></i>
|
||||||
<span class="label-text flex items-center gap-2">
|
</label>
|
||||||
Provider ID
|
</div>
|
||||||
<span class="tooltip tooltip-top" data-tip="Internal name for this service.">
|
|
||||||
<i class="ph ph-info opacity-50 cursor-help"></i>
|
|
||||||
</span>
|
|
||||||
</span>
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="text"
|
|
||||||
id="providerName"
|
|
||||||
x-model="form.providerName"
|
|
||||||
placeholder="e.g. trakt"
|
|
||||||
required
|
|
||||||
class="input input-bordered w-full focus:input-primary"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="divider text-xs opacity-50 my-2 uppercase tracking-widest">
|
<input type="checkbox" id="mobile-menu" class="peer hidden" />
|
||||||
Credentials
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="form-control">
|
<div class="fixed inset-y-0 right-0 w-80 bg-base-100 border-l border-base-300 shadow-2xl p-6 flex flex-col gap-6 transform translate-x-full peer-checked:translate-x-0 transition-transform z-50 lg:static lg:flex-none lg:w-auto lg:bg-transparent lg:border-none lg:shadow-none lg:p-0 lg:flex-row lg:items-center lg:gap-4 lg:translate-x-0 lg:z-auto">
|
||||||
<label htmlFor="clientId" class="label py-1">
|
<div class="flex justify-end lg:hidden">
|
||||||
<span class="label-text">Client ID</span>
|
<label for="mobile-menu" class="btn btn-ghost btn-square">
|
||||||
</label>
|
<i class="ph-bold ph-circle-dashed text-2xl"></i>
|
||||||
<input
|
</label>
|
||||||
type="text"
|
</div>
|
||||||
id="clientId"
|
|
||||||
x-model="form.clientId"
|
<a
|
||||||
placeholder="OAuth client id"
|
href={DOCS_PREFIX}
|
||||||
required
|
target="_blank"
|
||||||
class="input input-bordered w-full focus:input-primary"
|
class="btn btn-ghost justify-start lg:justify-center lg:btn-sm text-base-content/60 hover:text-primary gap-3 lg:gap-2 w-full lg:w-auto px-3"
|
||||||
/>
|
rel="noopener"
|
||||||
</div>
|
>
|
||||||
<div class="form-control" x-data="{ show: false }">
|
<i class="ph-duotone ph-book-open text-lg"></i>
|
||||||
<label htmlFor="clientSecret" class="label py-1">
|
<span class="font-bold uppercase tracking-widest">
|
||||||
<span class="label-text">Client Secret</span>
|
API Reference
|
||||||
</label>
|
<sup class="text-xxs opacity-50 ml-0.5">
|
||||||
<div class="relative">
|
{API_VERSION}.{APP_VERSION}
|
||||||
|
</sup>
|
||||||
|
</span>
|
||||||
|
</a>
|
||||||
|
|
||||||
|
<div class="divider my-0 opacity-50 lg:hidden"></div>
|
||||||
|
|
||||||
|
<template x-if="!isUnlocked">
|
||||||
|
<div class="flex flex-col lg:flex-row gap-4 items-start lg:items-center w-full lg:w-auto">
|
||||||
|
<div class="join border border-base-200/50 bg-base-200/50 rounded-xl overflow-hidden focus-within:border-primary transition-colors w-full lg:w-auto">
|
||||||
|
<div class="join-item flex items-center px-4 bg-base-200">
|
||||||
|
<i class="ph-duotone ph-key text-secondary text-lg"></i>
|
||||||
|
</div>
|
||||||
|
<div class="relative flex-1" x-data="{ show: false }">
|
||||||
<input
|
<input
|
||||||
x-bind:type="show ? 'text' : 'password'"
|
x-bind:type="show ? 'text' : 'password'"
|
||||||
id="clientSecret"
|
id="apiKey"
|
||||||
x-model="form.clientSecret"
|
name="apiKey"
|
||||||
placeholder="OAuth client secret"
|
x-model="apiKey"
|
||||||
required
|
aria-label="Master API Key"
|
||||||
class="input input-bordered w-full focus:input-primary pr-12"
|
placeholder="API_KEY"
|
||||||
|
class="input join-item input-sm bg-transparent border-none focus:outline-none w-full lg:w-64 text-xs pr-10 font-mono"
|
||||||
/>
|
/>
|
||||||
<button
|
<button
|
||||||
type="button"
|
type="button"
|
||||||
x-on:click="show = !show"
|
x-on:click="show = !show"
|
||||||
class="absolute right-3 top-1/2 -translate-y-1/2 btn btn-ghost btn-xs btn-square"
|
class="absolute right-2 top-1/2 -translate-y-1/2 btn btn-ghost btn-xs btn-square"
|
||||||
>
|
>
|
||||||
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-lg opacity-40' : 'ph-duotone ph-eye text-lg opacity-40'"></i>
|
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-base opacity-50' : 'ph-duotone ph-eye text-base opacity-50'"></i>
|
||||||
</button>
|
</button>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="divider text-xs opacity-50 my-2 uppercase tracking-widest">Endpoints</div>
|
|
||||||
|
|
||||||
<div class="form-control">
|
|
||||||
<label htmlFor="authUrl" class="label py-1">
|
|
||||||
<span class="label-text">Auth URL</span>
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="url"
|
|
||||||
id="authUrl"
|
|
||||||
x-model="form.authUrl"
|
|
||||||
placeholder="https://trakt.tv/oauth/authorize"
|
|
||||||
required
|
|
||||||
class="input input-bordered w-full focus:input-primary"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
<div class="form-control">
|
|
||||||
<label htmlFor="tokenUrl" class="label py-1">
|
|
||||||
<span class="label-text">Token URL</span>
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="url"
|
|
||||||
id="tokenUrl"
|
|
||||||
x-model="form.tokenUrl"
|
|
||||||
placeholder="https://api.trakt.tv/oauth/token"
|
|
||||||
required
|
|
||||||
class="input input-bordered w-full focus:input-primary"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
<div class="form-control">
|
|
||||||
<label htmlFor="redirectUri" class="label py-1">
|
|
||||||
<span class="label-text">Redirect URI</span>
|
|
||||||
</label>
|
|
||||||
<div class="relative group">
|
|
||||||
<input
|
|
||||||
type="url"
|
|
||||||
id="redirectUri"
|
|
||||||
x-bind:value="getRedirectUri()"
|
|
||||||
readonly
|
|
||||||
class="input input-bordered w-full pr-12 focus:outline-none cursor-default opacity-80"
|
|
||||||
/>
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
x-on:click="copyToClipboard(getRedirectUri())"
|
|
||||||
class="btn btn-ghost btn-xs absolute right-2 top-1/2 -translate-y-1/2 text-base-content/40 hover:text-primary transition-colors"
|
|
||||||
>
|
|
||||||
<i class="ph-duotone ph-copy text-lg"></i>
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
<div class="label py-0.5">
|
|
||||||
<span class="label-text-alt opacity-40 italic text-xs">
|
|
||||||
Must match provider's callback URL
|
|
||||||
</span>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
<div class="form-control">
|
|
||||||
<label htmlFor="scope" class="label py-1">
|
|
||||||
<span class="label-text">Scope</span>
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="text"
|
|
||||||
id="scope"
|
|
||||||
x-model="form.scope"
|
|
||||||
placeholder="public"
|
|
||||||
class="input input-bordered w-full focus:input-primary"
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="card-actions pt-4">
|
|
||||||
<button
|
<button
|
||||||
|
x-on:click="unlock(); document.getElementById('mobile-menu').checked = false;"
|
||||||
type="submit"
|
type="submit"
|
||||||
class="btn btn-primary w-full shadow-md"
|
class="btn btn-primary btn-sm join-item px-6"
|
||||||
x-bind:disabled="loading"
|
x-bind:disabled="loading"
|
||||||
>
|
>
|
||||||
<i class="ph ph-plus-bold mr-1"></i>
|
<i class="ph-duotone ph-lock-key-open text-lg" x-show="!loading"></i>
|
||||||
Save Configuration
|
<span class="loading loading-spinner loading-xs" x-show="loading"></span>
|
||||||
|
<span
|
||||||
|
class="ml-1 hidden lg:inline"
|
||||||
|
x-text="loading ? 'Unlocking...' : 'Unlock'"
|
||||||
|
></span>
|
||||||
</button>
|
</button>
|
||||||
</div>
|
</div>
|
||||||
</form>
|
</div>
|
||||||
</div>
|
</template>
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="card bg-base-100 shadow-xl border border-base-300 lg:col-span-8 overflow-hidden">
|
<template x-if="isUnlocked">
|
||||||
<div class="card-body p-0">
|
<div class="flex flex-col lg:flex-row items-start lg:items-center gap-4 w-full lg:w-auto">
|
||||||
<div class="p-6 pb-4 flex justify-between items-center bg-base-100">
|
<form
|
||||||
<div class="flex items-center gap-2">
|
class="join border border-base-200/50 bg-base-200/50 rounded-xl overflow-hidden focus-within:border-primary transition-colors w-full lg:w-auto"
|
||||||
<div class="w-2 h-6 bg-primary rounded-full"></div>
|
x-on:submit="$event.preventDefault(); if(isTenantLocked) { isTenantLocked = false; } else { isTenantLocked = true; fetchProviders(); document.getElementById('mobile-menu').checked = false; }"
|
||||||
<h2 class="card-title text-xl font-semibold">Provider Registry</h2>
|
|
||||||
</div>
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
x-on:click="fetchProviders()"
|
|
||||||
class="btn btn-sm btn-base"
|
|
||||||
x-bind:disabled="!isUnlocked || loading"
|
|
||||||
>
|
>
|
||||||
<i x-bind:class="loading ? 'ph ph-arrows-clockwise animate-spin mr-1' : 'ph ph-arrows-clockwise mr-1'"></i>
|
<div class="join-item flex items-center px-4 bg-base-300 opacity-70">
|
||||||
Refresh List
|
<i class="ph-duotone ph-identification-badge text-xl text-primary"></i>
|
||||||
|
</div>
|
||||||
|
<input
|
||||||
|
type="text"
|
||||||
|
x-model="tenantId"
|
||||||
|
x-bind:readonly="isTenantLocked"
|
||||||
|
placeholder="Tenant ID"
|
||||||
|
class="input join-item input-sm bg-transparent border-none focus:outline-none flex-1 lg:flex-none lg:w-48 text-xs font-mono transition-opacity"
|
||||||
|
x-bind:class="isTenantLocked ? 'opacity-60 cursor-default' : ''"
|
||||||
|
/>
|
||||||
|
<button
|
||||||
|
type="submit"
|
||||||
|
class="btn btn-sm join-item px-4"
|
||||||
|
x-bind:class="isTenantLocked ? 'btn-neutral' : 'btn-secondary'"
|
||||||
|
x-bind:title="isTenantLocked ? 'Edit Tenant ID' : 'Apply Tenant ID'"
|
||||||
|
>
|
||||||
|
<i
|
||||||
|
class="text-lg"
|
||||||
|
x-bind:class="isTenantLocked ? 'ph-thin ph-pencil-simple' : 'ph-bold ph-check'"
|
||||||
|
></i>
|
||||||
|
</button>
|
||||||
|
</form>
|
||||||
|
|
||||||
|
<button
|
||||||
|
x-on:click="logout(); document.getElementById('mobile-menu').checked = false;"
|
||||||
|
type="button"
|
||||||
|
class="btn btn-ghost text-error hover:bg-error/10 gap-2 w-full lg:w-auto lg:btn-sm px-4 justify-start lg:justify-center"
|
||||||
|
x-bind:disabled="loading"
|
||||||
|
>
|
||||||
|
<i class="ph-bold ph-power text-lg"></i>
|
||||||
|
<span class="font-bold uppercase tracking-wider text-xs">Logout</span>
|
||||||
</button>
|
</button>
|
||||||
</div>
|
</div>
|
||||||
|
</template>
|
||||||
|
</div>
|
||||||
|
<div
|
||||||
|
class="fixed inset-0 bg-black/50 z-40 hidden peer-checked:block lg:hidden"
|
||||||
|
></div>
|
||||||
|
</div>
|
||||||
|
|
||||||
<div class="relative min-h-[400px]">
|
<div class="container mx-auto p-4 md:p-8 max-w-7xl">
|
||||||
<div
|
<div class="grid grid-cols-1 lg:grid-cols-12 gap-6 md:gap-8">
|
||||||
x-show="loading && providers.length > 0"
|
<div class="card bg-base-100 shadow-xl border border-base-300 lg:col-span-4 self-start">
|
||||||
class="absolute inset-0 bg-base-100/50 backdrop-blur-md z-10 flex items-center justify-center"
|
<div class="card-body p-6">
|
||||||
>
|
<div class="flex items-center gap-2 mb-4">
|
||||||
<span class="loading loading-spinner loading-lg text-primary"></span>
|
<i class="ph-duotone ph-shield-plus text-2xl text-primary mb-1"></i>
|
||||||
|
<div class="w-1 h-6 bg-primary/50 rounded-full"></div>
|
||||||
|
<h2 class="card-title text-xl font-semibold">Configure Provider</h2>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div x-show="!isUnlocked" class="p-20 text-center opacity-30">
|
<form x-on:submit="saveConfig" class="space-y-4">
|
||||||
<div class="flex flex-col items-center gap-3">
|
<div class="form-control">
|
||||||
<i class="ph ph-lock-key text-6xl"></i>
|
<label htmlFor="providerName" class="label py-1">
|
||||||
<p class="font-medium">Enter Master API Key to access registry</p>
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Provider ID
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="Internal name for this service. This will define your login URL (e.g. /auth/trakt/login)."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<input
|
||||||
|
type="text"
|
||||||
|
id="providerName"
|
||||||
|
x-model="form.providerName"
|
||||||
|
placeholder="e.g. trakt"
|
||||||
|
required
|
||||||
|
class="input input-bordered w-full focus:input-primary"
|
||||||
|
/>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
|
||||||
|
|
||||||
<div
|
<div class="divider text-xs opacity-50 my-2 uppercase tracking-widest">
|
||||||
x-show="isUnlocked && providers.length === 0 && !loading"
|
Credentials
|
||||||
class="p-20 text-center opacity-30"
|
|
||||||
>
|
|
||||||
<div class="flex flex-col items-center gap-3">
|
|
||||||
<i class="ph ph-folder-open text-6xl"></i>
|
|
||||||
<p class="font-medium">No providers configured yet</p>
|
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
|
<div class="form-control">
|
||||||
|
<label htmlFor="clientId" class="label py-1">
|
||||||
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Client ID
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="Found in the 'API' or 'Developer' section of the provider. Sometimes called 'App ID' or 'Consumer Key'."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help text-xs"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<input
|
||||||
|
type="text"
|
||||||
|
id="clientId"
|
||||||
|
x-model="form.clientId"
|
||||||
|
placeholder="OAuth client id"
|
||||||
|
required
|
||||||
|
class="input input-bordered w-full focus:input-primary"
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
<div class="form-control" x-data="{ show: false }">
|
||||||
|
<label htmlFor="clientSecret" class="label py-1">
|
||||||
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Client Secret
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="Found next to the Client ID. This is your private key—never share it or put it in client-side code."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help text-xs"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<div class="relative">
|
||||||
|
<input
|
||||||
|
x-bind:type="show ? 'text' : 'password'"
|
||||||
|
id="clientSecret"
|
||||||
|
x-model="form.clientSecret"
|
||||||
|
placeholder="OAuth client secret"
|
||||||
|
required
|
||||||
|
class="input input-bordered w-full focus:input-primary pr-12"
|
||||||
|
/>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="show = !show"
|
||||||
|
class="absolute right-3 top-1/2 -translate-y-1/2 btn btn-ghost btn-xs btn-square"
|
||||||
|
>
|
||||||
|
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-lg opacity-40' : 'ph-duotone ph-eye text-lg opacity-40'"></i>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="divider text-xs opacity-50 my-2 uppercase tracking-widest">
|
||||||
|
Endpoints
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="form-control">
|
||||||
|
<label htmlFor="authUrl" class="label py-1">
|
||||||
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Auth URL
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="The page where users click 'Authorize'. Usually found in OAuth2 docs under 'Endpoints' or 'Authorize'."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help text-xs"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<input
|
||||||
|
type="url"
|
||||||
|
id="authUrl"
|
||||||
|
x-model="form.authUrl"
|
||||||
|
placeholder="https://trakt.tv/oauth/authorize"
|
||||||
|
required
|
||||||
|
class="input input-bordered w-full focus:input-primary"
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
<div class="form-control">
|
||||||
|
<label htmlFor="tokenUrl" class="label py-1">
|
||||||
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Token URL
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="The background API used to trade the code for a token. Usually ends in '/token' or '/access_token'."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help text-xs"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<input
|
||||||
|
type="url"
|
||||||
|
id="tokenUrl"
|
||||||
|
x-model="form.tokenUrl"
|
||||||
|
placeholder="https://api.trakt.tv/oauth/token"
|
||||||
|
required
|
||||||
|
class="input input-bordered w-full focus:input-primary"
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
<div class="form-control">
|
||||||
|
<label htmlFor="redirectUri" class="label py-1">
|
||||||
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Redirect URI
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="The provider will redirect the code to this URI. Copy this URL and paste it into the 'Redirect URI' or 'Callback URL' field in your OAuth provider's settings."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help text-xs"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<div class="relative group">
|
||||||
|
<input
|
||||||
|
type="url"
|
||||||
|
id="redirectUri"
|
||||||
|
x-bind:value="getRedirectUri()"
|
||||||
|
readonly
|
||||||
|
class="input input-bordered w-full pr-12 focus:outline-none cursor-default opacity-80"
|
||||||
|
/>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="copyToClipboard(getRedirectUri())"
|
||||||
|
class="btn btn-ghost btn-xs absolute right-2 top-1/2 -translate-y-1/2 text-base-content/40 hover:text-primary transition-colors"
|
||||||
|
>
|
||||||
|
<i class="ph-duotone ph-copy text-lg"></i>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
<div class="label py-0.5">
|
||||||
|
<span class="label-text-alt opacity-40 italic text-xs">
|
||||||
|
Must match provider's callback URL
|
||||||
|
</span>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div class="form-control">
|
||||||
|
<label htmlFor="scope" class="label py-1">
|
||||||
|
<span class="label-text flex items-center gap-2">
|
||||||
|
Scope
|
||||||
|
<span
|
||||||
|
class="tooltip tooltip-top before:text-left"
|
||||||
|
data-tip="Determines what data you're allowed to access. Multiple scopes are usually space-separated."
|
||||||
|
>
|
||||||
|
<i class="ph ph-info opacity-50 cursor-help text-xs"></i>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</label>
|
||||||
|
<input
|
||||||
|
type="text"
|
||||||
|
id="scope"
|
||||||
|
x-model="form.scope"
|
||||||
|
placeholder="public"
|
||||||
|
class="input input-bordered w-full focus:input-primary"
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="card-actions pt-4">
|
||||||
|
<button
|
||||||
|
type="submit"
|
||||||
|
class="btn btn-primary w-full shadow-md"
|
||||||
|
x-bind:disabled="loading"
|
||||||
|
>
|
||||||
|
<i class="ph ph-plus-bold mr-1"></i>
|
||||||
|
Save Configuration
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</form>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="card bg-base-100 shadow-xl border border-base-300 lg:col-span-8 overflow-hidden">
|
||||||
|
<div class="card-body p-0">
|
||||||
|
<div class="p-6 pb-4 flex justify-between items-center bg-base-100">
|
||||||
|
<div class="flex items-center gap-2">
|
||||||
|
<i class="ph-duotone ph-shipping-container text-2xl text-primary"></i>
|
||||||
|
<div class="w-1 h-6 bg-primary/50 rounded-full"></div>
|
||||||
|
<h2 class="card-title text-xl font-semibold">Provider Registry</h2>
|
||||||
|
</div>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="fetchProviders()"
|
||||||
|
class="btn btn-sm btn-neutral"
|
||||||
|
x-bind:disabled="!isUnlocked || loading"
|
||||||
|
>
|
||||||
|
<i x-bind:class="loading ? 'ph ph-arrows-clockwise animate-spin mr-1' : 'ph ph-arrows-clockwise mr-1'"></i>
|
||||||
|
Refresh List
|
||||||
|
</button>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div
|
<div class="relative min-h-[400px]">
|
||||||
x-show="isUnlocked && providers.length > 0"
|
<div
|
||||||
class="p-6 grid grid-cols-1 md:grid-cols-2 gap-4"
|
x-show="loading && providers.length > 0"
|
||||||
>
|
class="absolute inset-0 bg-base-100/50 backdrop-blur-md z-10 flex items-center justify-center"
|
||||||
<template x-for="provider in providers" x-bind:key="provider.name">
|
>
|
||||||
<div class="card bg-base-200/50 border border-base-300 shadow-sm hover:shadow-md transition-all group">
|
<span class="loading loading-spinner loading-lg text-primary"></span>
|
||||||
<div class="card-body p-5">
|
</div>
|
||||||
<div class="flex flex-col mb-4">
|
|
||||||
<span
|
|
||||||
x-text="provider.name"
|
|
||||||
class="text-lg font-black text-base-content/90 uppercase"
|
|
||||||
></span>
|
|
||||||
<span
|
|
||||||
x-text="provider.config.clientId"
|
|
||||||
x-bind:title="provider.config.clientId"
|
|
||||||
class="text-xs opacity-40 truncate font-mono"
|
|
||||||
></span>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="space-y-4">
|
<div x-show="!isUnlocked" class="p-20 text-center opacity-30">
|
||||||
<div x-data="{ show: false }">
|
<div class="flex flex-col items-center gap-3">
|
||||||
<div class="text-xs uppercase font-semibold opacity-30 block mb-1">
|
<i class="ph ph-lock-key text-6xl"></i>
|
||||||
Access Token
|
<p class="font-medium">Enter Master API Key to access registry</p>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div
|
||||||
|
x-show="isUnlocked && providers.length === 0 && !loading"
|
||||||
|
class="p-20 text-center opacity-30"
|
||||||
|
>
|
||||||
|
<div class="flex flex-col items-center gap-3">
|
||||||
|
<i class="ph ph-folder-open text-6xl"></i>
|
||||||
|
<p class="font-medium">No providers configured yet</p>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div
|
||||||
|
x-show="isUnlocked && providers.length > 0"
|
||||||
|
class="p-6 grid grid-cols-1 md:grid-cols-2 gap-4"
|
||||||
|
>
|
||||||
|
<template x-for="provider in providers" x-bind:key="provider.name">
|
||||||
|
<div class="card bg-base-200/50 border border-base-300 shadow-sm hover:shadow-md transition-all group">
|
||||||
|
<div class="card-body p-5">
|
||||||
|
<div class="flex flex-col mb-4">
|
||||||
|
<div class="flex justify-between items-start">
|
||||||
|
<span
|
||||||
|
x-text="provider.name"
|
||||||
|
class="text-lg font-black text-base-content/90 uppercase"
|
||||||
|
></span>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="deleteProvider(provider.name)"
|
||||||
|
class="btn btn-error btn-xs mt-1 opacity-0 group-hover:opacity-40 transition-all duration-300"
|
||||||
|
title="Delete Provider"
|
||||||
|
>
|
||||||
|
<i class="ph-bold ph-trash text-lg"></i>
|
||||||
|
</button>
|
||||||
</div>
|
</div>
|
||||||
<div
|
<span
|
||||||
x-show="provider.status.accessToken"
|
x-text="provider.config.clientId"
|
||||||
class="flex items-center gap-2 bg-base-100 rounded border border-base-300 p-1 pl-3"
|
x-bind:title="provider.config.clientId"
|
||||||
>
|
class="text-xs opacity-40 truncate font-mono"
|
||||||
<input
|
></span>
|
||||||
x-bind:type="show ? 'text' : 'password'"
|
</div>
|
||||||
x-bind:value="provider.status.accessToken"
|
|
||||||
readonly
|
<div class="space-y-4">
|
||||||
class="bg-transparent border-none outline-none shadow-none focus:ring-0 text-xs flex-1 min-w-0 font-mono"
|
<div x-data="{ show: false }">
|
||||||
/>
|
<div class="text-xs uppercase font-semibold opacity-30 block mb-1">
|
||||||
<div class="flex gap-1">
|
Access Token
|
||||||
<button
|
</div>
|
||||||
type="button"
|
<div
|
||||||
x-on:click="show = !show"
|
x-show="provider.status.accessToken"
|
||||||
class="btn btn-ghost btn-xs btn-square"
|
class="flex items-center gap-2 bg-base-100 rounded border border-base-300 p-1 pl-3"
|
||||||
>
|
>
|
||||||
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-base opacity-50' : 'ph-duotone ph-eye text-base opacity-50'"></i>
|
<input
|
||||||
</button>
|
x-bind:type="show ? 'text' : 'password'"
|
||||||
<button
|
x-bind:value="provider.status.accessToken"
|
||||||
type="button"
|
readonly
|
||||||
x-on:click="copyToClipboard(provider.status.accessToken)"
|
class="bg-transparent border-none outline-none shadow-none focus:ring-0 text-xs flex-1 min-w-0 font-mono"
|
||||||
class="btn btn-ghost btn-xs btn-square"
|
/>
|
||||||
>
|
<div class="flex gap-1">
|
||||||
<i class="ph-duotone ph-copy-simple text-base opacity-50"></i>
|
<button
|
||||||
</button>
|
type="button"
|
||||||
|
x-on:click="show = !show"
|
||||||
|
class="btn btn-ghost btn-xs btn-square"
|
||||||
|
>
|
||||||
|
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-base opacity-50' : 'ph-duotone ph-eye text-base opacity-50'"></i>
|
||||||
|
</button>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="copyToClipboard(provider.status.accessToken)"
|
||||||
|
class="btn btn-ghost btn-xs btn-square"
|
||||||
|
>
|
||||||
|
<i class="ph-duotone ph-copy-simple text-base opacity-50"></i>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div
|
||||||
|
x-show="!provider.status.accessToken"
|
||||||
|
class="h-8 flex items-center px-3 bg-base-300/30 rounded text-xs italic opacity-40"
|
||||||
|
>
|
||||||
|
Not Authenticated
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
<div
|
|
||||||
x-show="!provider.status.accessToken"
|
|
||||||
class="h-8 flex items-center px-3 bg-base-300/30 rounded text-xs italic opacity-40"
|
|
||||||
>
|
|
||||||
Not Authenticated
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div x-data="{ show: false }">
|
<div x-data="{ show: false }">
|
||||||
<div class="text-xs uppercase font-semibold opacity-30 block mb-1">
|
<div class="text-xs uppercase font-semibold opacity-30 block mb-1">
|
||||||
Refresh Token
|
Refresh Token
|
||||||
</div>
|
</div>
|
||||||
<div
|
<div
|
||||||
x-show="provider.status.refreshToken"
|
x-show="provider.status.refreshToken"
|
||||||
class="flex items-center gap-2 bg-base-100 rounded border border-base-300 p-1 pl-3"
|
class="flex items-center gap-2 bg-base-100 rounded border border-base-300 p-1 pl-3"
|
||||||
>
|
>
|
||||||
<input
|
<input
|
||||||
x-bind:type="show ? 'text' : 'password'"
|
x-bind:type="show ? 'text' : 'password'"
|
||||||
x-bind:value="provider.status.refreshToken"
|
x-bind:value="provider.status.refreshToken"
|
||||||
readonly
|
readonly
|
||||||
class="bg-transparent border-none outline-none shadow-none focus:ring-0 text-xs flex-1 min-w-0 font-mono"
|
class="bg-transparent border-none outline-none shadow-none focus:ring-0 text-xs flex-1 min-w-0 font-mono"
|
||||||
/>
|
/>
|
||||||
<div class="flex gap-1">
|
<div class="flex gap-1">
|
||||||
<button
|
<button
|
||||||
type="button"
|
type="button"
|
||||||
x-on:click="show = !show"
|
x-on:click="show = !show"
|
||||||
class="btn btn-ghost btn-xs btn-square"
|
class="btn btn-ghost btn-xs btn-square"
|
||||||
>
|
>
|
||||||
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-base opacity-50' : 'ph-duotone ph-eye text-base opacity-50'"></i>
|
<i x-bind:class="show ? 'ph-duotone ph-eye-slash text-base opacity-50' : 'ph-duotone ph-eye text-base opacity-50'"></i>
|
||||||
</button>
|
</button>
|
||||||
<button
|
<button
|
||||||
type="button"
|
type="button"
|
||||||
x-on:click="copyToClipboard(provider.status.refreshToken)"
|
x-on:click="copyToClipboard(provider.status.refreshToken)"
|
||||||
class="btn btn-ghost btn-xs btn-square"
|
class="btn btn-ghost btn-xs btn-square"
|
||||||
>
|
>
|
||||||
<i class="ph-duotone ph-copy-simple text-base opacity-50"></i>
|
<i class="ph-duotone ph-copy-simple text-base opacity-50"></i>
|
||||||
</button>
|
</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div
|
||||||
|
x-show="!provider.status.refreshToken"
|
||||||
|
class="h-8 flex items-center px-3 bg-base-300/30 rounded text-xs italic opacity-40"
|
||||||
|
>
|
||||||
|
Not Authenticated
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
<div
|
|
||||||
x-show="!provider.status.refreshToken"
|
|
||||||
class="h-8 flex items-center px-3 bg-base-300/30 rounded text-xs italic opacity-40"
|
|
||||||
>
|
|
||||||
Not Authenticated
|
|
||||||
</div>
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="divider my-3 opacity-10"></div>
|
<div class="divider my-3 opacity-10"></div>
|
||||||
<div class="flex justify-between items-center mb-4">
|
<div
|
||||||
<span class="text-xs font-semibold opacity-30 uppercase">Last Updated</span>
|
x-show="provider.status.accessToken"
|
||||||
<span
|
class="grid grid-cols-2 gap-4 mb-5"
|
||||||
x-text="formatTime(provider.status.lastUpdated)"
|
|
||||||
class="text-xs font-medium opacity-60"
|
|
||||||
></span>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="flex flex-col gap-2">
|
|
||||||
<div class="grid grid-cols-2 gap-2">
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
x-on:click="window.open('/auth/' + provider.name + '/login', '_blank')"
|
|
||||||
class="btn btn-primary btn-sm"
|
|
||||||
>
|
|
||||||
<i class="ph-bold ph-link"></i> Connect
|
|
||||||
</button>
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
x-on:click="editProvider(provider)"
|
|
||||||
class="btn btn-secondary btn-sm"
|
|
||||||
>
|
|
||||||
<i class="ph-bold ph-pencil-simple"></i> Edit
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
x-on:click="forceRefresh(provider.name)"
|
|
||||||
class="btn btn-base w-full"
|
|
||||||
x-bind:disabled="loading"
|
|
||||||
>
|
>
|
||||||
<i class="ph-bold ph-arrows-clockwise text-base mr-1"></i>
|
<div class="p-1 flex flex-col gap-0.5">
|
||||||
<span class="text-xs uppercase font-bold tracking-widest">
|
<span class="text-xxs font-bold opacity-20 uppercase tracking-wide">
|
||||||
Refresh Tokens
|
Last Updated
|
||||||
</span>
|
</span>
|
||||||
</button>
|
<span
|
||||||
|
x-text="formatTime(provider.status.lastUpdated)"
|
||||||
|
class="text-xs text-secondary/75 font-bold font-mono tracking-wider opacity-60"
|
||||||
|
></span>
|
||||||
|
</div>
|
||||||
|
<div class="p-1 flex flex-col gap-0.5 items-end text-right">
|
||||||
|
<span class="text-xxs font-bold opacity-20 uppercase tracking-widest">
|
||||||
|
Expires In
|
||||||
|
</span>
|
||||||
|
<span
|
||||||
|
x-text="formatExpiry(provider.status.expiresAt)"
|
||||||
|
x-bind:class="isExpired(provider.status.expiresAt) ? 'text-error' : 'text-primary'"
|
||||||
|
class="text-xs font-bold font-mono tracking-wide"
|
||||||
|
></span>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="flex flex-col gap-2">
|
||||||
|
<div class="grid grid-cols-2 gap-2">
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click={`window.open('${AUTH_PREFIX}/' + provider.name + '/login?tenantId=' + encodeURIComponent(tenantId), '_blank')`}
|
||||||
|
class="btn btn-primary btn-sm"
|
||||||
|
>
|
||||||
|
<i class="ph-bold ph-link"></i> Connect
|
||||||
|
</button>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="editProvider(provider)"
|
||||||
|
class="btn btn-neutral btn-sm"
|
||||||
|
>
|
||||||
|
<i class="ph-bold ph-pencil-simple"></i> Edit
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
x-on:click="forceRefresh(provider.name)"
|
||||||
|
class="btn btn-secondary w-full"
|
||||||
|
x-bind:disabled="loading || !provider.status.accessToken"
|
||||||
|
>
|
||||||
|
<i class="ph-bold ph-arrows-clockwise text-base mr-1"></i>
|
||||||
|
<span class="text-xs uppercase font-bold tracking-widest">
|
||||||
|
Refresh Tokens
|
||||||
|
</span>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</template>
|
||||||
</template>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
@@ -484,7 +666,28 @@ export const Success = (props: { provider: string }) => (
|
|||||||
);
|
);
|
||||||
|
|
||||||
dashboardRoutes.get("/", async (c) => {
|
dashboardRoutes.get("/", async (c) => {
|
||||||
return c.html(<Dashboard />);
|
const isUnlocked = getCookie(c, "toknd_api_key") === config.API_KEY;
|
||||||
|
return c.html(<Dashboard isUnlocked={isUnlocked} />);
|
||||||
|
});
|
||||||
|
|
||||||
|
dashboardRoutes.post("/unlock", async (c) => {
|
||||||
|
const { apiKey } = await c.req.json();
|
||||||
|
if (apiKey !== config.API_KEY) {
|
||||||
|
return c.json({ error: "Invalid API Key" }, 401);
|
||||||
|
}
|
||||||
|
setCookie(c, "toknd_api_key", apiKey, {
|
||||||
|
httpOnly: true,
|
||||||
|
secure: true,
|
||||||
|
sameSite: "Strict",
|
||||||
|
path: "/",
|
||||||
|
maxAge: 60 * 60 * 24 * 7, // 1 week
|
||||||
|
});
|
||||||
|
return c.json({ success: true });
|
||||||
|
});
|
||||||
|
|
||||||
|
dashboardRoutes.post("/logout", async (c) => {
|
||||||
|
deleteCookie(c, "toknd_api_key", { path: "/" });
|
||||||
|
return c.json({ success: true });
|
||||||
});
|
});
|
||||||
|
|
||||||
dashboardRoutes.get("/success", async (c) => {
|
dashboardRoutes.get("/success", async (c) => {
|
||||||
|
|||||||
@@ -0,0 +1,2 @@
|
|||||||
|
export const API_VERSION = "v1";
|
||||||
|
export const APP_VERSION = "1.1";
|
||||||
@@ -1,4 +1,12 @@
|
|||||||
document.addEventListener("alpine:init", () => {
|
document.addEventListener("alpine:init", () => {
|
||||||
|
const formatDate = (date) => {
|
||||||
|
return date.toLocaleDateString("en-US", {
|
||||||
|
month: "short",
|
||||||
|
day: "2-digit",
|
||||||
|
year: "numeric",
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
const formatTime = (timestamp) => {
|
const formatTime = (timestamp) => {
|
||||||
if (!timestamp) return "Never";
|
if (!timestamp) return "Never";
|
||||||
const date = new Date(timestamp);
|
const date = new Date(timestamp);
|
||||||
@@ -7,161 +15,267 @@ document.addEventListener("alpine:init", () => {
|
|||||||
if (diff < 60) return "Just now";
|
if (diff < 60) return "Just now";
|
||||||
if (diff < 3600) return `${Math.floor(diff / 60)}m ago`;
|
if (diff < 3600) return `${Math.floor(diff / 60)}m ago`;
|
||||||
if (diff < 86400) return `${Math.floor(diff / 3600)}h ago`;
|
if (diff < 86400) return `${Math.floor(diff / 3600)}h ago`;
|
||||||
return date.toLocaleDateString();
|
return formatDate(date);
|
||||||
};
|
};
|
||||||
|
|
||||||
window.Alpine.data("dashboard", () => ({
|
const formatExpiry = (timestamp) => {
|
||||||
apiKey: localStorage.getItem("toknd_api_key") || "",
|
if (!timestamp) return "Expired";
|
||||||
isUnlocked: false,
|
const date = new Date(timestamp);
|
||||||
loading: false,
|
const diff = Math.floor((date - Date.now()) / 1000);
|
||||||
providers: [],
|
|
||||||
form: {
|
|
||||||
providerName: "",
|
|
||||||
clientId: "",
|
|
||||||
clientSecret: "",
|
|
||||||
authUrl: "",
|
|
||||||
tokenUrl: "",
|
|
||||||
scope: "public",
|
|
||||||
},
|
|
||||||
notification: {
|
|
||||||
show: false,
|
|
||||||
message: "",
|
|
||||||
type: "success",
|
|
||||||
},
|
|
||||||
|
|
||||||
init() {
|
if (diff <= 0) return "Expired";
|
||||||
if (this.apiKey) {
|
if (diff < 60) return `${diff}s`;
|
||||||
this.unlock();
|
if (diff < 3600) return `${Math.floor(diff / 60)}m`;
|
||||||
}
|
if (diff < 86400) return `${Math.floor(diff / 3600)}h`;
|
||||||
},
|
return `${formatDate(date)}`;
|
||||||
|
};
|
||||||
|
|
||||||
async unlock() {
|
window.Alpine.data(
|
||||||
if (!this.apiKey) return;
|
"dashboard",
|
||||||
this.loading = true;
|
({ initialIsUnlocked, apiPrefix, authPrefix, docsPrefix, apiVersion, appVersion }) => ({
|
||||||
try {
|
apiKey: "",
|
||||||
localStorage.setItem("toknd_api_key", this.apiKey);
|
tenantId: localStorage.getItem("toknd_tenant_id") || "default",
|
||||||
await this.fetchProviders();
|
isTenantLocked: !!localStorage.getItem("toknd_tenant_id"),
|
||||||
this.isUnlocked = true;
|
isUnlocked: initialIsUnlocked,
|
||||||
} catch (err) {
|
apiPrefix,
|
||||||
this.showNotification(`Failed to unlock: ${err.message}. Check your API Key`, "error");
|
authPrefix,
|
||||||
localStorage.removeItem("toknd_api_key");
|
docsPrefix,
|
||||||
this.isUnlocked = false;
|
apiVersion,
|
||||||
this.apiKey = "";
|
appVersion,
|
||||||
} finally {
|
loading: false,
|
||||||
this.loading = false;
|
providers: [],
|
||||||
}
|
form: {
|
||||||
},
|
providerName: "",
|
||||||
|
clientId: "",
|
||||||
|
clientSecret: "",
|
||||||
|
authUrl: "",
|
||||||
|
tokenUrl: "",
|
||||||
|
scope: "public",
|
||||||
|
},
|
||||||
|
notification: {
|
||||||
|
show: false,
|
||||||
|
message: "",
|
||||||
|
type: "success",
|
||||||
|
},
|
||||||
|
|
||||||
async fetchProviders() {
|
init() {
|
||||||
this.loading = true;
|
this.$watch("tenantId", (val) => {
|
||||||
try {
|
localStorage.setItem("toknd_tenant_id", val);
|
||||||
const [configRes, statusRes] = await Promise.all([
|
});
|
||||||
fetch("/api/config", { headers: { Authorization: `Bearer ${this.apiKey}` } }),
|
if (this.isUnlocked) {
|
||||||
fetch("/api/status", { headers: { Authorization: `Bearer ${this.apiKey}` } }),
|
this.fetchProviders();
|
||||||
]);
|
}
|
||||||
|
},
|
||||||
|
|
||||||
if (!configRes.ok || !statusRes.ok) throw new Error("Unauthorized");
|
async unlock() {
|
||||||
|
if (!this.apiKey) return;
|
||||||
|
this.loading = true;
|
||||||
|
try {
|
||||||
|
const res = await fetch("/app/unlock", {
|
||||||
|
method: "POST",
|
||||||
|
headers: { "Content-Type": "application/json" },
|
||||||
|
body: JSON.stringify({ apiKey: this.apiKey }),
|
||||||
|
});
|
||||||
|
|
||||||
const config = await configRes.json();
|
if (!res.ok) throw new Error("Invalid API Key");
|
||||||
const status = await statusRes.json();
|
|
||||||
|
|
||||||
this.providers = Object.entries(config).map(([name, cfg]) => ({
|
this.isUnlocked = true;
|
||||||
|
await this.fetchProviders();
|
||||||
|
this.apiKey = ""; // Clear after success
|
||||||
|
} catch (err) {
|
||||||
|
this.showNotification(err.message, "error");
|
||||||
|
this.isUnlocked = false;
|
||||||
|
} finally {
|
||||||
|
this.loading = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
async logout() {
|
||||||
|
this.loading = true;
|
||||||
|
try {
|
||||||
|
await fetch("/app/logout", { method: "POST" });
|
||||||
|
this.isUnlocked = false;
|
||||||
|
this.providers = [];
|
||||||
|
this.showNotification("Logged out successfully");
|
||||||
|
} catch (err) {
|
||||||
|
this.showNotification(`Logout failed: ${err.message}`, "error");
|
||||||
|
} finally {
|
||||||
|
this.loading = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
async fetchProviders() {
|
||||||
|
this.loading = true;
|
||||||
|
try {
|
||||||
|
const [configRes, statusRes] = await Promise.all([
|
||||||
|
fetch(`${this.apiPrefix}/config`),
|
||||||
|
fetch(`${this.apiPrefix}/status`, {
|
||||||
|
headers: { "x-tenant-id": this.tenantId },
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
|
||||||
|
if (configRes.status === 401 || statusRes.status === 401) {
|
||||||
|
return this.handleSessionExpired();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!configRes.ok || !statusRes.ok) throw new Error("Failed to fetch data");
|
||||||
|
|
||||||
|
const [config, status] = await Promise.all([configRes.json(), statusRes.json()]);
|
||||||
|
this.providers = this.mapProviders(config, status);
|
||||||
|
} catch (err) {
|
||||||
|
this.showNotification(err.message, "error");
|
||||||
|
} finally {
|
||||||
|
this.loading = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
mapProviders(config, status) {
|
||||||
|
return Object.entries(config).map(([name, cfg]) => ({
|
||||||
name,
|
name,
|
||||||
config: cfg,
|
config: cfg,
|
||||||
status: status[name] || { accessToken: null, refreshToken: null, lastUpdated: null },
|
status: status[name] || {
|
||||||
}));
|
accessToken: null,
|
||||||
} catch (err) {
|
refreshToken: null,
|
||||||
this.showNotification(err.message, "error");
|
lastUpdated: null,
|
||||||
throw err;
|
expiresAt: null,
|
||||||
} finally {
|
|
||||||
this.loading = false;
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
async saveConfig(event) {
|
|
||||||
if (event) event.preventDefault();
|
|
||||||
this.loading = true;
|
|
||||||
try {
|
|
||||||
const res = await fetch(`/api/config/${this.form.providerName}`, {
|
|
||||||
method: "POST",
|
|
||||||
headers: {
|
|
||||||
"Content-Type": "application/json",
|
|
||||||
Authorization: `Bearer ${this.apiKey}`,
|
|
||||||
},
|
},
|
||||||
body: JSON.stringify(this.form),
|
}));
|
||||||
});
|
},
|
||||||
|
|
||||||
if (!res.ok) throw new Error("Failed to save");
|
handleSessionExpired() {
|
||||||
|
this.isUnlocked = false;
|
||||||
|
this.providers = [];
|
||||||
|
this.showNotification("Session expired", "error");
|
||||||
|
},
|
||||||
|
|
||||||
this.showNotification("Saved successfully");
|
async saveConfig() {
|
||||||
await this.fetchProviders();
|
this.loading = true;
|
||||||
|
try {
|
||||||
|
const res = await fetch(`${this.apiPrefix}/config/${this.form.providerName}`, {
|
||||||
|
method: "POST",
|
||||||
|
headers: { "Content-Type": "application/json" },
|
||||||
|
body: JSON.stringify(this.form),
|
||||||
|
});
|
||||||
|
|
||||||
|
if (res.status === 401) {
|
||||||
|
this.isUnlocked = false;
|
||||||
|
throw new Error("Session expired");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!res.ok) throw new Error("Failed to save");
|
||||||
|
|
||||||
|
this.showNotification("Saved successfully");
|
||||||
|
await this.fetchProviders();
|
||||||
|
|
||||||
|
this.form = {
|
||||||
|
providerName: "",
|
||||||
|
clientId: "",
|
||||||
|
clientSecret: "",
|
||||||
|
authUrl: "",
|
||||||
|
tokenUrl: "",
|
||||||
|
scope: "public",
|
||||||
|
};
|
||||||
|
} catch (err) {
|
||||||
|
this.showNotification(err.message, "error");
|
||||||
|
} finally {
|
||||||
|
this.loading = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
async forceRefresh(name) {
|
||||||
|
this.loading = true;
|
||||||
|
try {
|
||||||
|
const res = await fetch(`${this.apiPrefix}/refresh/${name}`, {
|
||||||
|
method: "POST",
|
||||||
|
headers: { "x-tenant-id": this.tenantId },
|
||||||
|
});
|
||||||
|
|
||||||
|
if (res.status === 401) {
|
||||||
|
return this.handleSessionExpired();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!res.ok) throw new Error("Refresh failed");
|
||||||
|
|
||||||
|
this.showNotification(`Refreshed ${name}`);
|
||||||
|
await this.fetchProviders();
|
||||||
|
} catch (err) {
|
||||||
|
this.showNotification(err.message, "error");
|
||||||
|
} finally {
|
||||||
|
this.loading = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
async deleteProvider(name) {
|
||||||
|
if (
|
||||||
|
!confirm(
|
||||||
|
`Are you sure you want to delete ${name}? This will also remove all associated tokens.`,
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return;
|
||||||
|
|
||||||
|
this.loading = true;
|
||||||
|
try {
|
||||||
|
const res = await fetch(`${this.apiPrefix}/config/${name}`, {
|
||||||
|
method: "DELETE",
|
||||||
|
});
|
||||||
|
|
||||||
|
if (res.status === 401) {
|
||||||
|
return this.handleSessionExpired();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!res.ok) throw new Error("Delete failed");
|
||||||
|
|
||||||
|
this.showNotification(`Deleted ${name}`);
|
||||||
|
await this.fetchProviders();
|
||||||
|
} catch (err) {
|
||||||
|
this.showNotification(err.message, "error");
|
||||||
|
} finally {
|
||||||
|
this.loading = false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
editProvider(provider) {
|
||||||
this.form = {
|
this.form = {
|
||||||
providerName: "",
|
providerName: provider.name,
|
||||||
clientId: "",
|
clientId: provider.config.clientId,
|
||||||
clientSecret: "",
|
clientSecret: provider.config.clientSecret,
|
||||||
authUrl: "",
|
authUrl: provider.config.authUrl,
|
||||||
tokenUrl: "",
|
tokenUrl: provider.config.tokenUrl,
|
||||||
scope: "public",
|
scope: provider.config.scope,
|
||||||
};
|
};
|
||||||
} catch (err) {
|
window.scrollTo({ top: 0, behavior: "smooth" });
|
||||||
this.showNotification(err.message, "error");
|
},
|
||||||
} finally {
|
|
||||||
this.loading = false;
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
async forceRefresh(name) {
|
getRedirectUri() {
|
||||||
this.loading = true;
|
return `${window.location.origin}${this.authPrefix}/${this.form.providerName || "{provider}"}/callback`;
|
||||||
try {
|
},
|
||||||
const res = await fetch(`/api/refresh/${name}`, {
|
|
||||||
method: "POST",
|
copyToClipboard(text) {
|
||||||
headers: { Authorization: `Bearer ${this.apiKey}` },
|
if (!text) return;
|
||||||
|
navigator.clipboard.writeText(text).then(() => {
|
||||||
|
this.showNotification("Copied");
|
||||||
});
|
});
|
||||||
|
},
|
||||||
|
|
||||||
if (!res.ok) throw new Error("Refresh failed");
|
showNotification(message, type = "success") {
|
||||||
|
this.notification = { show: true, message, type };
|
||||||
|
setTimeout(() => {
|
||||||
|
this.notification.show = false;
|
||||||
|
}, 3000);
|
||||||
|
},
|
||||||
|
|
||||||
this.showNotification(`Refreshed ${name}`);
|
formatTime(timestamp) {
|
||||||
await this.fetchProviders();
|
return formatTime(timestamp);
|
||||||
} catch (err) {
|
},
|
||||||
this.showNotification(err.message, "error");
|
|
||||||
} finally {
|
|
||||||
this.loading = false;
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
editProvider(provider) {
|
formatExpiry(timestamp) {
|
||||||
this.form = {
|
return formatExpiry(timestamp);
|
||||||
providerName: provider.name,
|
},
|
||||||
clientId: provider.config.clientId,
|
|
||||||
clientSecret: provider.config.clientSecret,
|
|
||||||
authUrl: provider.config.authUrl,
|
|
||||||
tokenUrl: provider.config.tokenUrl,
|
|
||||||
scope: provider.config.scope,
|
|
||||||
};
|
|
||||||
window.scrollTo({ top: 0, behavior: "smooth" });
|
|
||||||
},
|
|
||||||
|
|
||||||
getRedirectUri() {
|
isExpired(timestamp) {
|
||||||
return `${window.location.origin}/auth/${this.form.providerName || "{provider}"}/callback`;
|
if (!timestamp) return true;
|
||||||
},
|
return new Date(timestamp) < new Date();
|
||||||
|
},
|
||||||
copyToClipboard(text) {
|
}),
|
||||||
if (!text) return;
|
);
|
||||||
navigator.clipboard.writeText(text).then(() => {
|
|
||||||
this.showNotification("Copied");
|
|
||||||
});
|
|
||||||
},
|
|
||||||
|
|
||||||
showNotification(message, type = "success") {
|
|
||||||
this.notification = { show: true, message, type };
|
|
||||||
setTimeout(() => {
|
|
||||||
this.notification.show = false;
|
|
||||||
}, 3000);
|
|
||||||
},
|
|
||||||
|
|
||||||
formatTime(timestamp) {
|
|
||||||
return formatTime(timestamp);
|
|
||||||
},
|
|
||||||
}));
|
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,18 +1,17 @@
|
|||||||
// @ts-nocheck
|
|
||||||
import { describe, expect, it, mock } from "bun:test";
|
import { describe, expect, it, mock } from "bun:test";
|
||||||
import { ConfigManager } from "../../src/core/ConfigManager";
|
import { ConfigManager } from "../../src/core/ConfigManager";
|
||||||
|
|
||||||
describe("ConfigManager", () => {
|
describe("ConfigManager", () => {
|
||||||
it("should save and retrieve provider configuration", async () => {
|
it("should save and retrieve provider configuration", async () => {
|
||||||
const storage = {};
|
const storage: Record<string, string> = {};
|
||||||
const redis = {
|
const redis = {
|
||||||
set: mock((key, val) => {
|
set: mock((key: string, val: string) => {
|
||||||
storage[key] = val;
|
storage[key] = val;
|
||||||
return Promise.resolve();
|
return Promise.resolve();
|
||||||
}),
|
}),
|
||||||
get: mock((key) => Promise.resolve(storage[key] || null)),
|
get: mock((key: string) => Promise.resolve(storage[key] || null)),
|
||||||
};
|
};
|
||||||
const manager = new ConfigManager(redis);
|
const manager = new ConfigManager(redis as any);
|
||||||
const traktConfig = {
|
const traktConfig = {
|
||||||
clientId: "trakt-client-id",
|
clientId: "trakt-client-id",
|
||||||
clientSecret: "trakt-client-secret",
|
clientSecret: "trakt-client-secret",
|
||||||
@@ -24,14 +23,14 @@ describe("ConfigManager", () => {
|
|||||||
await manager.setProviderConfig("trakt", traktConfig);
|
await manager.setProviderConfig("trakt", traktConfig);
|
||||||
const retrieved = await manager.getProviderConfig("trakt");
|
const retrieved = await manager.getProviderConfig("trakt");
|
||||||
|
|
||||||
expect(retrieved).toEqual(traktConfig);
|
expect(retrieved).toEqual(traktConfig as any);
|
||||||
expect(redis.set).toHaveBeenCalled();
|
expect(redis.set).toHaveBeenCalled();
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return all providers", async () => {
|
it("should return all providers", async () => {
|
||||||
const redis = {
|
const redis = {
|
||||||
keys: mock(() => Promise.resolve(["config:trakt", "config:github"])),
|
keys: mock(() => Promise.resolve(["config:trakt", "config:github"])),
|
||||||
get: mock((key) =>
|
get: mock((key: string) =>
|
||||||
Promise.resolve(
|
Promise.resolve(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
clientId: `${key}-id`,
|
clientId: `${key}-id`,
|
||||||
@@ -43,7 +42,7 @@ describe("ConfigManager", () => {
|
|||||||
),
|
),
|
||||||
),
|
),
|
||||||
};
|
};
|
||||||
const manager = new ConfigManager(redis);
|
const manager = new ConfigManager(redis as any);
|
||||||
|
|
||||||
const providers = await manager.getAllProviders();
|
const providers = await manager.getAllProviders();
|
||||||
|
|
||||||
@@ -53,10 +52,32 @@ describe("ConfigManager", () => {
|
|||||||
|
|
||||||
it("should return null for non-existent provider", async () => {
|
it("should return null for non-existent provider", async () => {
|
||||||
const redis = { get: mock(() => Promise.resolve(null)) };
|
const redis = { get: mock(() => Promise.resolve(null)) };
|
||||||
const manager = new ConfigManager(redis);
|
const manager = new ConfigManager(redis as any);
|
||||||
|
|
||||||
const config = await manager.getProviderConfig("missing-provider");
|
const config = await manager.getProviderConfig("missing-provider");
|
||||||
|
|
||||||
expect(config).toBeNull();
|
expect(config).toBeNull();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("should delete provider configuration and all tenant tokens", async () => {
|
||||||
|
const redis = {
|
||||||
|
del: mock(() => Promise.resolve()),
|
||||||
|
keys: mock(() =>
|
||||||
|
Promise.resolve([
|
||||||
|
"tenant:1:provider:trakt:access_token",
|
||||||
|
"tenant:2:provider:trakt:access_token",
|
||||||
|
]),
|
||||||
|
),
|
||||||
|
};
|
||||||
|
const manager = new ConfigManager(redis as any);
|
||||||
|
|
||||||
|
await manager.deleteProviderConfig("trakt");
|
||||||
|
|
||||||
|
expect(redis.del).toHaveBeenCalledWith("config:trakt");
|
||||||
|
expect(redis.keys).toHaveBeenCalledWith("tenant:*:provider:trakt:*");
|
||||||
|
expect(redis.del).toHaveBeenCalledWith(
|
||||||
|
"tenant:1:provider:trakt:access_token",
|
||||||
|
"tenant:2:provider:trakt:access_token",
|
||||||
|
);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,15 +1,17 @@
|
|||||||
// @ts-nocheck
|
|
||||||
import { describe, expect, it, mock } from "bun:test";
|
import { describe, expect, it, mock } from "bun:test";
|
||||||
import { TokenManager } from "../../src/core/TokenManager";
|
import { TokenManager } from "../../src/core/TokenManager";
|
||||||
|
|
||||||
describe("TokenManager", () => {
|
describe("TokenManager", () => {
|
||||||
|
const tenantId = "test-tenant";
|
||||||
|
|
||||||
it("should return token from redis if available", async () => {
|
it("should return token from redis if available", async () => {
|
||||||
const redis = { get: mock(() => Promise.resolve("active-access-token")) };
|
const redis = { get: mock(() => Promise.resolve("active-access-token")) };
|
||||||
const manager = new TokenManager(redis, {});
|
const manager = new TokenManager(redis as any, {} as any);
|
||||||
|
|
||||||
const token = await manager.getAccessToken("trakt");
|
const token = await manager.getAccessToken(tenantId, "trakt");
|
||||||
|
|
||||||
expect(token).toBe("active-access-token");
|
expect(token).toBe("active-access-token");
|
||||||
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:access_token`);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should refresh token if access token is missing but refresh token exists", async () => {
|
it("should refresh token if access token is missing but refresh token exists", async () => {
|
||||||
@@ -26,19 +28,26 @@ describe("TokenManager", () => {
|
|||||||
}),
|
}),
|
||||||
),
|
),
|
||||||
};
|
};
|
||||||
const manager = new TokenManager(redis, provider);
|
const manager = new TokenManager(redis as any, provider as any);
|
||||||
|
|
||||||
const token = await manager.getAccessToken("trakt");
|
const token = await manager.getAccessToken(tenantId, "trakt");
|
||||||
|
|
||||||
expect(token).toBe("newly-refreshed-access-token");
|
expect(token).toBe("newly-refreshed-access-token");
|
||||||
expect(redis.set).toHaveBeenCalled();
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:access_token`);
|
||||||
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:refresh_token`);
|
||||||
|
expect(redis.set).toHaveBeenCalledWith(
|
||||||
|
`tenant:${tenantId}:provider:trakt:access_token`,
|
||||||
|
"newly-refreshed-access-token",
|
||||||
|
"EX",
|
||||||
|
3600,
|
||||||
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return null if no tokens are found", async () => {
|
it("should return null if no tokens are found", async () => {
|
||||||
const redis = { get: mock(() => Promise.resolve(null)) };
|
const redis = { get: mock(() => Promise.resolve(null)) };
|
||||||
const manager = new TokenManager(redis, {});
|
const manager = new TokenManager(redis as any, {} as any);
|
||||||
|
|
||||||
const token = await manager.getAccessToken("trakt");
|
const token = await manager.getAccessToken(tenantId, "trakt");
|
||||||
|
|
||||||
expect(token).toBeNull();
|
expect(token).toBeNull();
|
||||||
});
|
});
|
||||||
@@ -57,19 +66,26 @@ describe("TokenManager", () => {
|
|||||||
}),
|
}),
|
||||||
),
|
),
|
||||||
};
|
};
|
||||||
const manager = new TokenManager(redis, provider);
|
const manager = new TokenManager(redis as any, provider as any);
|
||||||
|
|
||||||
const token = await manager.refreshAccessToken("trakt");
|
const token = await manager.refreshAccessToken(tenantId, "trakt");
|
||||||
|
|
||||||
expect(token).toBe("manually-refreshed-access-token");
|
expect(token).toBe("manually-refreshed-access-token");
|
||||||
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:refresh_token`);
|
||||||
expect(provider.refreshToken).toHaveBeenCalledWith("existing-refresh-token");
|
expect(provider.refreshToken).toHaveBeenCalledWith("existing-refresh-token");
|
||||||
|
expect(redis.set).toHaveBeenCalledWith(
|
||||||
|
`tenant:${tenantId}:provider:trakt:access_token`,
|
||||||
|
"manually-refreshed-access-token",
|
||||||
|
"EX",
|
||||||
|
3600,
|
||||||
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return null in refreshAccessToken if no refresh token is found", async () => {
|
it("should return null in refreshAccessToken if no refresh token is found", async () => {
|
||||||
const redis = { get: mock(() => Promise.resolve(null)) };
|
const redis = { get: mock(() => Promise.resolve(null)) };
|
||||||
const manager = new TokenManager(redis, {});
|
const manager = new TokenManager(redis as any, {} as any);
|
||||||
|
|
||||||
const token = await manager.refreshAccessToken("trakt");
|
const token = await manager.refreshAccessToken(tenantId, "trakt");
|
||||||
|
|
||||||
expect(token).toBeNull();
|
expect(token).toBeNull();
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,16 +1,9 @@
|
|||||||
// @ts-nocheck
|
import { describe, expect, it, spyOn } from "bun:test";
|
||||||
import { afterEach, describe, expect, it, mock, spyOn } from "bun:test";
|
import { API_PREFIX } from "../../src/constants";
|
||||||
import { redis } from "../../src/core/RedisClient";
|
import { redis } from "../../src/core/RedisClient";
|
||||||
import { app } from "../../src/index";
|
import { app } from "../../src/index";
|
||||||
|
|
||||||
describe("API Integration", () => {
|
describe("API Integration", () => {
|
||||||
afterEach(() => {
|
|
||||||
mock.restore();
|
|
||||||
redis.get.mockImplementation(() => Promise.resolve(null));
|
|
||||||
redis.set.mockImplementation(() => Promise.resolve());
|
|
||||||
redis.keys.mockImplementation(() => Promise.resolve([]));
|
|
||||||
});
|
|
||||||
|
|
||||||
const mockTraktConfig = JSON.stringify({
|
const mockTraktConfig = JSON.stringify({
|
||||||
clientId: "trakt-client-id",
|
clientId: "trakt-client-id",
|
||||||
clientSecret: "trakt-client-secret",
|
clientSecret: "trakt-client-secret",
|
||||||
@@ -19,12 +12,14 @@ describe("API Integration", () => {
|
|||||||
scope: "public",
|
scope: "public",
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const tenantId = "test-tenant";
|
||||||
|
|
||||||
it("should return 401 if API Key is missing", async () => {
|
it("should return 401 if API Key is missing", async () => {
|
||||||
const res = await app.request("/api/status");
|
const res = await app.request(`${API_PREFIX}/status`);
|
||||||
|
|
||||||
expect(res.status).toBe(401);
|
expect(res.status).toBe(401);
|
||||||
const body = await res.json();
|
const body = await res.json();
|
||||||
expect(body).toEqual({ error: "Missing or invalid authorization header" });
|
expect(body).toEqual({ error: "Missing or invalid authorization" });
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return 200 for health check (no auth needed)", async () => {
|
it("should return 200 for health check (no auth needed)", async () => {
|
||||||
@@ -36,7 +31,7 @@ describe("API Integration", () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it("should return 503 for health check if redis is down", async () => {
|
it("should return 503 for health check if redis is down", async () => {
|
||||||
redis.status = "connecting";
|
(redis as any).status = "connecting";
|
||||||
|
|
||||||
const res = await app.request("/health");
|
const res = await app.request("/health");
|
||||||
const body = await res.json();
|
const body = await res.json();
|
||||||
@@ -46,18 +41,31 @@ describe("API Integration", () => {
|
|||||||
expect(body.redis).toBe("connecting");
|
expect(body.redis).toBe("connecting");
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return 200 for status with valid API Key", async () => {
|
it("should return 400 if X-Tenant-ID is missing", async () => {
|
||||||
redis.keys.mockReturnValue(Promise.resolve(["config:trakt"]));
|
const res = await app.request(`${API_PREFIX}/status`, {
|
||||||
redis.get.mockImplementation((key) => {
|
headers: {
|
||||||
|
Authorization: "Bearer test-api-key",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(res.status).toBe(400);
|
||||||
|
});
|
||||||
|
|
||||||
|
it("should return 200 for status with valid API Key and X-Tenant-ID", async () => {
|
||||||
|
(redis.keys as any).mockReturnValue(Promise.resolve(["config:trakt"]));
|
||||||
|
(redis.get as any).mockImplementation((key) => {
|
||||||
if (key.includes("config")) return Promise.resolve(mockTraktConfig);
|
if (key.includes("config")) return Promise.resolve(mockTraktConfig);
|
||||||
if (key.includes("access_token")) return Promise.resolve("current-access-token");
|
if (key.includes(`tenant:${tenantId}:provider:trakt:access_token`))
|
||||||
if (key.includes("refresh_token")) return Promise.resolve("current-refresh-token");
|
return Promise.resolve("current-access-token");
|
||||||
|
if (key.includes(`tenant:${tenantId}:provider:trakt:refresh_token`))
|
||||||
|
return Promise.resolve("current-refresh-token");
|
||||||
return Promise.resolve(null);
|
return Promise.resolve(null);
|
||||||
});
|
});
|
||||||
|
|
||||||
const res = await app.request("/api/status", {
|
const res = await app.request(`${API_PREFIX}/status`, {
|
||||||
headers: {
|
headers: {
|
||||||
Authorization: "Bearer test-api-key",
|
Authorization: "Bearer test-api-key",
|
||||||
|
"X-Tenant-ID": tenantId,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -65,57 +73,35 @@ describe("API Integration", () => {
|
|||||||
const body = await res.json();
|
const body = await res.json();
|
||||||
expect(body.trakt).toBeDefined();
|
expect(body.trakt).toBeDefined();
|
||||||
expect(body.trakt.accessToken).toBe("current-access-token");
|
expect(body.trakt.accessToken).toBe("current-access-token");
|
||||||
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:access_token`);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return 404 for unknown provider token", async () => {
|
it("should return token for a configured provider with X-Tenant-ID", async () => {
|
||||||
const res = await app.request("/api/token/unconfigured-provider", {
|
(redis.get as any).mockImplementation((key) => {
|
||||||
headers: {
|
|
||||||
Authorization: "Bearer test-api-key",
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(res.status).toBe(404);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("should return token for a configured provider", async () => {
|
|
||||||
redis.get.mockImplementation((key) => {
|
|
||||||
if (key.includes("config:trakt")) return Promise.resolve(mockTraktConfig);
|
if (key.includes("config:trakt")) return Promise.resolve(mockTraktConfig);
|
||||||
if (key.includes("access_token")) return Promise.resolve("trakt-active-token");
|
if (key.includes(`tenant:${tenantId}:provider:trakt:access_token`))
|
||||||
|
return Promise.resolve("trakt-active-token");
|
||||||
return Promise.resolve(null);
|
return Promise.resolve(null);
|
||||||
});
|
});
|
||||||
|
|
||||||
const res = await app.request("/api/token/trakt", {
|
const res = await app.request(`${API_PREFIX}/token/trakt`, {
|
||||||
headers: {
|
headers: {
|
||||||
Authorization: "Bearer test-api-key",
|
Authorization: "Bearer test-api-key",
|
||||||
|
"X-Tenant-ID": tenantId,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
expect(res.status).toBe(200);
|
expect(res.status).toBe(200);
|
||||||
const body = await res.json();
|
const body = await res.json();
|
||||||
expect(body.access_token).toBe("trakt-active-token");
|
expect(body.access_token).toBe("trakt-active-token");
|
||||||
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:access_token`);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return 404 if no access token is in redis for a valid provider", async () => {
|
it("should successfully refresh a token with X-Tenant-ID", async () => {
|
||||||
redis.get.mockImplementation((key) => {
|
(redis.get as any).mockImplementation((key) => {
|
||||||
if (key.includes("config:trakt")) return Promise.resolve(mockTraktConfig);
|
if (key.includes("config:trakt")) return Promise.resolve(mockTraktConfig);
|
||||||
return Promise.resolve(null);
|
if (key.includes(`tenant:${tenantId}:provider:trakt:refresh_token`))
|
||||||
});
|
return Promise.resolve("old-refresh-token");
|
||||||
|
|
||||||
const res = await app.request("/api/token/trakt", {
|
|
||||||
headers: {
|
|
||||||
Authorization: "Bearer test-api-key",
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(res.status).toBe(404);
|
|
||||||
const body = await res.json();
|
|
||||||
expect(body.error).toContain("No tokens found");
|
|
||||||
});
|
|
||||||
|
|
||||||
it("should successfully refresh a token", async () => {
|
|
||||||
redis.get.mockImplementation((key) => {
|
|
||||||
if (key.includes("config:trakt")) return Promise.resolve(mockTraktConfig);
|
|
||||||
if (key.includes("refresh_token")) return Promise.resolve("old-refresh-token");
|
|
||||||
return Promise.resolve("new-access-token-from-refresh");
|
return Promise.resolve("new-access-token-from-refresh");
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -128,13 +114,14 @@ describe("API Integration", () => {
|
|||||||
refresh_token: "new-refresh-token-from-fetch",
|
refresh_token: "new-refresh-token-from-fetch",
|
||||||
expires_in: 3600,
|
expires_in: 3600,
|
||||||
}),
|
}),
|
||||||
}),
|
} as any),
|
||||||
);
|
);
|
||||||
|
|
||||||
const res = await app.request("/api/refresh/trakt", {
|
const res = await app.request(`${API_PREFIX}/refresh/trakt`, {
|
||||||
method: "POST",
|
method: "POST",
|
||||||
headers: {
|
headers: {
|
||||||
Authorization: "Bearer test-api-key",
|
Authorization: "Bearer test-api-key",
|
||||||
|
"X-Tenant-ID": tenantId,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -142,5 +129,6 @@ describe("API Integration", () => {
|
|||||||
const body = await res.json();
|
const body = await res.json();
|
||||||
expect(body.success).toBe(true);
|
expect(body.success).toBe(true);
|
||||||
expect(body.status.accessToken).toBe("new-access-token-from-refresh");
|
expect(body.status.accessToken).toBe("new-access-token-from-refresh");
|
||||||
|
expect(redis.get).toHaveBeenCalledWith(`tenant:${tenantId}:provider:trakt:refresh_token`);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,14 +1,9 @@
|
|||||||
// @ts-nocheck
|
import { describe, expect, it, spyOn } from "bun:test";
|
||||||
import { afterEach, describe, expect, it, mock, spyOn } from "bun:test";
|
import { AUTH_PREFIX } from "../../src/constants";
|
||||||
import { redis } from "../../src/core/RedisClient";
|
import { redis } from "../../src/core/RedisClient";
|
||||||
import { app } from "../../src/index";
|
import { app } from "../../src/index";
|
||||||
|
|
||||||
describe("Auth Integration", () => {
|
describe("Auth Integration", () => {
|
||||||
afterEach(() => {
|
|
||||||
mock.restore();
|
|
||||||
redis.get.mockImplementation(() => Promise.resolve(null));
|
|
||||||
});
|
|
||||||
|
|
||||||
const mockProviderConfig = JSON.stringify({
|
const mockProviderConfig = JSON.stringify({
|
||||||
clientId: "trakt-client-id",
|
clientId: "trakt-client-id",
|
||||||
clientSecret: "trakt-client-secret",
|
clientSecret: "trakt-client-secret",
|
||||||
@@ -17,21 +12,25 @@ describe("Auth Integration", () => {
|
|||||||
scope: "public",
|
scope: "public",
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should redirect to provider login", async () => {
|
const tenantId = "test-tenant";
|
||||||
redis.get.mockImplementation((key) => {
|
|
||||||
|
it("should redirect to provider login with tenantId in state", async () => {
|
||||||
|
(redis.get as any).mockImplementation((key: string) => {
|
||||||
if (key.includes("config:trakt")) return Promise.resolve(mockProviderConfig);
|
if (key.includes("config:trakt")) return Promise.resolve(mockProviderConfig);
|
||||||
return Promise.resolve(null);
|
return Promise.resolve(null);
|
||||||
});
|
});
|
||||||
|
|
||||||
const res = await app.request("/auth/trakt/login");
|
const res = await app.request(`${AUTH_PREFIX}/trakt/login?tenantId=${tenantId}`);
|
||||||
|
|
||||||
expect(res.status).toBe(302);
|
expect(res.status).toBe(302);
|
||||||
expect(res.headers.get("Location")).toContain("trakt.tv/oauth/authorize");
|
const location = res.headers.get("Location") || "";
|
||||||
expect(res.headers.get("Location")).toContain("client_id=trakt-client-id");
|
expect(location).toContain("trakt.tv/oauth/authorize");
|
||||||
|
expect(location).toContain("client_id=trakt-client-id");
|
||||||
|
expect(location).toContain(`state=${encodeURIComponent(`${tenantId}:trakt`)}`);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should handle callback and exchange code", async () => {
|
it("should handle callback and exchange code using tenantId from state", async () => {
|
||||||
redis.get.mockImplementation((key) => {
|
(redis.get as any).mockImplementation((key: string) => {
|
||||||
if (key.includes("config:trakt")) return Promise.resolve(mockProviderConfig);
|
if (key.includes("config:trakt")) return Promise.resolve(mockProviderConfig);
|
||||||
return Promise.resolve(null);
|
return Promise.resolve(null);
|
||||||
});
|
});
|
||||||
@@ -45,25 +44,32 @@ describe("Auth Integration", () => {
|
|||||||
refresh_token: "exchange-refresh-token",
|
refresh_token: "exchange-refresh-token",
|
||||||
expires_in: 3600,
|
expires_in: 3600,
|
||||||
}),
|
}),
|
||||||
}),
|
} as any),
|
||||||
);
|
);
|
||||||
|
|
||||||
const res = await app.request("/auth/callback?state=trakt&code=temporary-auth-code");
|
const res = await app.request(
|
||||||
|
`${AUTH_PREFIX}/callback?state=${tenantId}:trakt&code=temporary-auth-code`,
|
||||||
|
);
|
||||||
|
|
||||||
expect(res.status).toBe(302);
|
expect(res.status).toBe(302);
|
||||||
expect(res.headers.get("Location")).toBe("/app/success?provider=trakt");
|
expect(res.headers.get("Location")).toBe(`/app/success?provider=trakt&tenantId=${tenantId}`);
|
||||||
expect(redis.set).toHaveBeenCalled();
|
expect(redis.set).toHaveBeenCalledWith(
|
||||||
|
`tenant:${tenantId}:provider:trakt:access_token`,
|
||||||
|
"exchange-access-token",
|
||||||
|
"EX",
|
||||||
|
3600,
|
||||||
|
);
|
||||||
expect(fetchSpy).toHaveBeenCalled();
|
expect(fetchSpy).toHaveBeenCalled();
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return 404 if provider not configured during login", async () => {
|
it("should return 404 if provider not configured during login", async () => {
|
||||||
const res = await app.request("/auth/unknown-provider/login");
|
const res = await app.request(`${AUTH_PREFIX}/unknown-provider/login?tenantId=${tenantId}`);
|
||||||
|
|
||||||
expect(res.status).toBe(404);
|
expect(res.status).toBe(404);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("should return 400 if callback is missing state or code", async () => {
|
it("should return 400 if callback is missing state or code", async () => {
|
||||||
const res = await app.request("/auth/callback?code=some-code");
|
const res = await app.request(`${AUTH_PREFIX}/callback?code=some-code`);
|
||||||
|
|
||||||
expect(res.status).toBe(400);
|
expect(res.status).toBe(400);
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,19 +1,12 @@
|
|||||||
// @ts-nocheck
|
import { describe, expect, it } from "bun:test";
|
||||||
import { afterEach, describe, expect, it, mock } from "bun:test";
|
import { API_PREFIX } from "../../src/constants";
|
||||||
import { redis } from "../../src/core/RedisClient";
|
import { redis } from "../../src/core/RedisClient";
|
||||||
import { app } from "../../src/index";
|
import { app } from "../../src/index";
|
||||||
|
|
||||||
describe("Config Integration", () => {
|
describe("Config Integration", () => {
|
||||||
afterEach(() => {
|
|
||||||
mock.restore();
|
|
||||||
redis.get.mockImplementation(() => Promise.resolve(null));
|
|
||||||
redis.set.mockImplementation(() => Promise.resolve());
|
|
||||||
redis.keys.mockImplementation(() => Promise.resolve([]));
|
|
||||||
});
|
|
||||||
|
|
||||||
it("should list all configured providers", async () => {
|
it("should list all configured providers", async () => {
|
||||||
redis.keys.mockReturnValue(Promise.resolve(["config:trakt"]));
|
(redis.keys as any).mockReturnValue(Promise.resolve(["config:trakt"]));
|
||||||
redis.get.mockImplementation(() =>
|
(redis.get as any).mockImplementation(() =>
|
||||||
Promise.resolve(
|
Promise.resolve(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
clientId: "trakt-client-id",
|
clientId: "trakt-client-id",
|
||||||
@@ -25,7 +18,7 @@ describe("Config Integration", () => {
|
|||||||
),
|
),
|
||||||
);
|
);
|
||||||
|
|
||||||
const res = await app.request("/api/config", {
|
const res = await app.request(`${API_PREFIX}/config`, {
|
||||||
headers: {
|
headers: {
|
||||||
Authorization: "Bearer test-api-key",
|
Authorization: "Bearer test-api-key",
|
||||||
},
|
},
|
||||||
@@ -46,7 +39,7 @@ describe("Config Integration", () => {
|
|||||||
scope: "user:email",
|
scope: "user:email",
|
||||||
};
|
};
|
||||||
|
|
||||||
const res = await app.request("/api/config/github", {
|
const res = await app.request(`${API_PREFIX}/config/github`, {
|
||||||
method: "POST",
|
method: "POST",
|
||||||
headers: {
|
headers: {
|
||||||
Authorization: "Bearer test-api-key",
|
Authorization: "Bearer test-api-key",
|
||||||
@@ -67,7 +60,7 @@ describe("Config Integration", () => {
|
|||||||
clientId: "missing-other-required-fields",
|
clientId: "missing-other-required-fields",
|
||||||
};
|
};
|
||||||
|
|
||||||
const res = await app.request("/api/config/invalid", {
|
const res = await app.request(`${API_PREFIX}/config/invalid`, {
|
||||||
method: "POST",
|
method: "POST",
|
||||||
headers: {
|
headers: {
|
||||||
Authorization: "Bearer test-api-key",
|
Authorization: "Bearer test-api-key",
|
||||||
@@ -78,4 +71,19 @@ describe("Config Integration", () => {
|
|||||||
|
|
||||||
expect(res.status).toBe(400);
|
expect(res.status).toBe(400);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("should delete a provider configuration and clean up all tenant tokens", async () => {
|
||||||
|
(redis.keys as any).mockReturnValue(Promise.resolve(["tenant:1:provider:trakt:token"]));
|
||||||
|
const res = await app.request(`${API_PREFIX}/config/trakt`, {
|
||||||
|
method: "DELETE",
|
||||||
|
headers: {
|
||||||
|
Authorization: "Bearer test-api-key",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(res.status).toBe(200);
|
||||||
|
expect(redis.del).toHaveBeenCalledWith("config:trakt");
|
||||||
|
expect(redis.keys).toHaveBeenCalledWith("tenant:*:provider:trakt:*");
|
||||||
|
expect(redis.del).toHaveBeenCalledWith("tenant:1:provider:trakt:token");
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
// @ts-nocheck
|
|
||||||
import { describe, expect, it } from "bun:test";
|
import { describe, expect, it } from "bun:test";
|
||||||
|
import { API_PREFIX } from "../../src/constants";
|
||||||
import { redis } from "../../src/core/RedisClient";
|
import { redis } from "../../src/core/RedisClient";
|
||||||
import { app } from "../../src/index";
|
import { app } from "../../src/index";
|
||||||
|
|
||||||
@@ -22,16 +22,40 @@ describe("Dashboard & Common Integration", () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it("should return 500 for internal errors", async () => {
|
it("should return 500 for internal errors", async () => {
|
||||||
redis.keys.mockImplementationOnce(() => {
|
(redis.keys as any).mockImplementationOnce(() => {
|
||||||
throw new Error("Redis Crash");
|
throw new Error("Redis Crash");
|
||||||
});
|
});
|
||||||
|
|
||||||
const res = await app.request("/api/status", {
|
const res = await app.request(`${API_PREFIX}/status`, {
|
||||||
headers: { Authorization: "Bearer test-api-key" },
|
headers: {
|
||||||
|
Authorization: "Bearer test-api-key",
|
||||||
|
"X-Tenant-ID": "test-tenant",
|
||||||
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
expect(res.status).toBe(500);
|
expect(res.status).toBe(500);
|
||||||
const body = await res.json();
|
const body = await res.json();
|
||||||
expect(body.error).toBe("Internal Server Error");
|
expect(body.error).toBe("Internal Server Error");
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("should set a cookie on successful unlock", async () => {
|
||||||
|
const res = await app.request("/app/unlock", {
|
||||||
|
method: "POST",
|
||||||
|
headers: { "Content-Type": "application/json" },
|
||||||
|
body: JSON.stringify({ apiKey: "test-api-key" }),
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(res.status).toBe(200);
|
||||||
|
expect(res.headers.get("Set-Cookie")).toContain("toknd_api_key=test-api-key");
|
||||||
|
expect(res.headers.get("Set-Cookie")).toContain("HttpOnly");
|
||||||
|
});
|
||||||
|
|
||||||
|
it("should clear the cookie on logout", async () => {
|
||||||
|
const res = await app.request("/app/logout", {
|
||||||
|
method: "POST",
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(res.status).toBe(200);
|
||||||
|
expect(res.headers.get("Set-Cookie")).toContain("toknd_api_key=;");
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -1,18 +1,38 @@
|
|||||||
import { mock } from "bun:test";
|
// @ts-nocheck
|
||||||
|
|
||||||
// Global test setup to stub environment variables
|
|
||||||
process.env.API_KEY = "test-api-key";
|
process.env.API_KEY = "test-api-key";
|
||||||
process.env.REDIS_HOST = "localhost";
|
process.env.REDIS_HOST = "localhost";
|
||||||
process.env.REDIS_PORT = "6379";
|
process.env.REDIS_PORT = "6379";
|
||||||
process.env.APP_PORT = "3000";
|
process.env.APP_PORT = "3000";
|
||||||
|
|
||||||
|
import { afterEach, mock } from "bun:test";
|
||||||
|
|
||||||
|
// Global config mock
|
||||||
|
mock.module("../src/config", () => ({
|
||||||
|
config: {
|
||||||
|
API_KEY: "test-api-key",
|
||||||
|
REDIS_HOST: "localhost",
|
||||||
|
REDIS_PORT: 6379,
|
||||||
|
APP_PORT: "3000",
|
||||||
|
},
|
||||||
|
}));
|
||||||
|
|
||||||
// Global Redis mock
|
// Global Redis mock
|
||||||
mock.module("../src/core/RedisClient", () => ({
|
mock.module("../src/core/RedisClient", () => ({
|
||||||
redis: {
|
redis: {
|
||||||
status: "ready",
|
status: "ready",
|
||||||
get: mock(() => Promise.resolve(null)),
|
get: mock(() => Promise.resolve(null)),
|
||||||
set: mock(() => Promise.resolve()),
|
set: mock(() => Promise.resolve()),
|
||||||
|
del: mock(() => Promise.resolve(1)),
|
||||||
keys: mock(() => Promise.resolve([])),
|
keys: mock(() => Promise.resolve([])),
|
||||||
on: mock(() => {}),
|
on: mock(() => {}),
|
||||||
},
|
},
|
||||||
}));
|
}));
|
||||||
|
|
||||||
|
afterEach(async () => {
|
||||||
|
const { redis } = await import("../src/core/RedisClient");
|
||||||
|
mock.restore();
|
||||||
|
redis.get.mockImplementation(() => Promise.resolve(null));
|
||||||
|
redis.set.mockImplementation(() => Promise.resolve());
|
||||||
|
redis.del.mockImplementation(() => Promise.resolve(1));
|
||||||
|
redis.keys.mockImplementation(() => Promise.resolve([]));
|
||||||
|
});
|
||||||
|
|||||||