mirror of
https://github.com/Permissionless-Software-Foundation/psf-bch-api.git
synced 2026-09-22 09:02:01 -07:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
300ef91aa1 | ||
|
|
a37cad7138 | ||
|
|
58ff8ef650 | ||
|
|
6a100d243a | ||
|
|
67b141fc03 | ||
|
|
5d77880a0e | ||
|
|
3950560989 | ||
|
|
aade1c58f5 | ||
|
|
2bbec7bc05 | ||
|
|
cff0e89b0d | ||
|
|
03caa3cd67 | ||
|
|
6c8d512d1a | ||
|
|
cc78aad785 | ||
|
|
91f99405c1 | ||
|
|
a959416b10 | ||
|
|
562a196998 | ||
|
|
e006a7ad86 | ||
|
|
f36cd2a8aa | ||
|
|
8b2cf64f1b | ||
|
|
95ae06fada | ||
|
|
188dc939b3 | ||
|
|
7d566beea3 | ||
|
|
6c42f47e15 | ||
|
|
d19a9e64cd | ||
|
|
7c96d72f7b | ||
|
|
7f1770ab70 | ||
|
|
b25f55ce6a |
@@ -16,6 +16,9 @@ LOCAL_RESTURL=http://localhost:5942/v6
|
|||||||
|
|
||||||
# END INFRASTRUCTURE SETUP
|
# END INFRASTRUCTURE SETUP
|
||||||
|
|
||||||
|
# Public base URL for apiDoc HTML (optional; used by Docker entrypoint before `npm run docs`).
|
||||||
|
#APIDOC_URL=https://api.example.com
|
||||||
|
|
||||||
|
|
||||||
# START ACCESS CONTROL
|
# START ACCESS CONTROL
|
||||||
|
|
||||||
@@ -23,6 +26,8 @@ PORT=5942
|
|||||||
|
|
||||||
# x402 payments required to access this API?
|
# x402 payments required to access this API?
|
||||||
X402_ENABLED=true
|
X402_ENABLED=true
|
||||||
|
# Also gates discovery endpoints:
|
||||||
|
# /.well-known/x402, /openapi.json, /swagger.json, /llms.txt, /.well-known/agent.json
|
||||||
SERVER_BCH_ADDRESS=bitcoincash:qqlrzp23w08434twmvr4fxw672whkjy0py26r63g3d
|
SERVER_BCH_ADDRESS=bitcoincash:qqlrzp23w08434twmvr4fxw672whkjy0py26r63g3d
|
||||||
FACILITATOR_URL=http://localhost:4345/facilitator
|
FACILITATOR_URL=http://localhost:4345/facilitator
|
||||||
X402_PRICE_SAT=200
|
X402_PRICE_SAT=200
|
||||||
@@ -33,3 +38,7 @@ BASIC_AUTH_TOKEN=some-random-token
|
|||||||
|
|
||||||
# END ACCESS CONTROL
|
# END ACCESS CONTROL
|
||||||
|
|
||||||
|
# PSF token liquidity price proxy (GET /v6/price/psf). Off by default.
|
||||||
|
#PSF_LIQUIDITY_PROXY_ENABLED=true
|
||||||
|
#PSF_LIQUIDITY_URL=http://192.168.0.126:5000
|
||||||
|
|
||||||
|
|||||||
@@ -1,30 +1,265 @@
|
|||||||
# psf-bch-api
|
# psf-bch-api
|
||||||
|
|
||||||
This is a REST API for communicating with Bitcoin Cash infrastructure. It replaces [bch-api](https://github.com/Permissionless-Software-Foundation/bch-api), and it implements [x402-bch protocol](https://github.com/x402-bch/x402-bch) to handle payments to access the API.
|
[](https://github.com/Permissionless-Software-Foundation/psf-bch-api/blob/master/LICENSE.md)
|
||||||
|
[](https://github.com/feross/standard)
|
||||||
|
|
||||||
|
This is a REST API server for communicating with Bitcoin Cash (BCH) blockchain infrastructure. It is written in node.js JavaScript using the [Express.js](https://expressjs.com/) framework and follows the [Clean Architecture](https://blog.cleancoder.com/uncle-bob/2012/08/13/the-clean-architecture.html) design pattern. It replaces the legacy [bch-api](https://github.com/Permissionless-Software-Foundation/bch-api) and implements the [x402-bch protocol](https://github.com/x402-bch/x402-bch) for optional per-call payments.
|
||||||
|
|
||||||
|
psf-bch-api is the heart of the [Cash Stack](https://cashstack.info), a full software stack for building blockchain-based applications. It creates a single web2 REST API interface that abstracts away the complexity of the underlying blockchain infrastructure, so that application developers can interact with the blockchain through simple HTTP calls.
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
psf-bch-api depends on three pieces of back end infrastructure:
|
||||||
|
|
||||||
|
- **[BCHN Full Node](https://cashstack.info/docs/back-end/bchn-full-node)** - the base blockchain node that validates transactions and blocks.
|
||||||
|
- **[Fulcrum Indexer](https://cashstack.info/docs/back-end/fulcrum-indexer)** - an address indexer that tracks balances, transaction histories, and UTXOs.
|
||||||
|
- **[SLP Token Indexer](https://cashstack.info/docs/back-end/slp-indexer/slp-indexer-software)** - tracks all SLP tokens on the blockchain.
|
||||||
|
|
||||||
|
Front-end applications interact with psf-bch-api through libraries such as [bch-js](https://github.com/Permissionless-Software-Foundation/bch-js) or [bch-consumer](https://www.npmjs.com/package/bch-consumer).
|
||||||
|
|
||||||
|
High-level documentation about the full Cash Stack is available at [CashStack.info](https://cashstack.info). Interactive API reference documentation is served by the running server at its root URL (e.g. `http://localhost:5942/`), and a live version can be found at [bch.fullstack.cash](https://bch.fullstack.cash/).
|
||||||
|
|
||||||
|
## The .env File
|
||||||
|
|
||||||
|
All runtime configuration is driven by a `.env` file in the project root. An example is provided at `.env-example`. To get started:
|
||||||
|
|
||||||
|
`cp .env-example .env`
|
||||||
|
|
||||||
|
Then edit `.env` to match your environment. The file is organized into two sections:
|
||||||
|
|
||||||
|
### Infrastructure Setup
|
||||||
|
|
||||||
|
These variables tell psf-bch-api where to find the back end services it depends on:
|
||||||
|
|
||||||
|
- `RPC_BASEURL` - URL of the BCHN full node JSON-RPC interface. Default: `http://127.0.0.1:8332`
|
||||||
|
- `RPC_USERNAME` - RPC username for the full node.
|
||||||
|
- `RPC_PASSWORD` - RPC password for the full node.
|
||||||
|
- `FULCRUM_API` - URL of the Fulcrum indexer REST API.
|
||||||
|
- `SLP_INDEXER_API` - URL of the SLP Token Indexer REST API.
|
||||||
|
- `LOCAL_RESTURL` - The REST API URL used internally for wallet operations. Default: `http://127.0.0.1:5942/v6/`
|
||||||
|
|
||||||
|
### Access Control Settings
|
||||||
|
|
||||||
|
These variables control who can access the API and how they pay for it. The three access-control use cases are described in detail in the [Access Control](#access-control) section below.
|
||||||
|
|
||||||
|
- `PORT` - Port the server listens on. Default: `5942`
|
||||||
|
- `X402_ENABLED` - Enable x402-bch per-call payment middleware. Default: `true`
|
||||||
|
- `SERVER_BCH_ADDRESS` - BCH address that receives x402 payments. Default: `bitcoincash:qqsrke9lh257tqen99dkyy2emh4uty0vky9y0z0lsr`
|
||||||
|
- `FACILITATOR_URL` - URL of the x402-bch facilitator service. Default: `http://localhost:4345/facilitator`
|
||||||
|
- `X402_PRICE_SAT` - Price in satoshis charged per API call via x402. Default: `200`
|
||||||
|
- `USE_BASIC_AUTH` - Enable Bearer token authentication middleware. Default: `false`
|
||||||
|
- `BASIC_AUTH_TOKEN` - The expected Bearer token value.
|
||||||
|
|
||||||
|
## Access Control
|
||||||
|
|
||||||
|
psf-bch-api supports three major access-control configurations. Which one you choose depends on your deployment scenario. The behavior is controlled entirely by the `X402_ENABLED` and `USE_BASIC_AUTH` environment variables.
|
||||||
|
|
||||||
|
### 1. No Rate Limits (Open Access)
|
||||||
|
|
||||||
|
Set both access-control flags to `false`:
|
||||||
|
|
||||||
|
```
|
||||||
|
X402_ENABLED=false
|
||||||
|
USE_BASIC_AUTH=false
|
||||||
|
```
|
||||||
|
|
||||||
|
All API endpoints are publicly accessible without any authentication or payment. This is the simplest configuration, ideal for **local development** or **private, trusted networks** where access control is handled at the network level (e.g. behind a firewall or VPN).
|
||||||
|
|
||||||
|
### 2. Bearer Token Authentication
|
||||||
|
|
||||||
|
Set `USE_BASIC_AUTH=true` and `X402_ENABLED=false`:
|
||||||
|
|
||||||
|
```
|
||||||
|
X402_ENABLED=false
|
||||||
|
USE_BASIC_AUTH=true
|
||||||
|
BASIC_AUTH_TOKEN=my-secret-token
|
||||||
|
```
|
||||||
|
|
||||||
|
Every API request (except `/health` and `/`) must include an `Authorization` header with a valid Bearer token:
|
||||||
|
|
||||||
|
```
|
||||||
|
Authorization: Bearer my-secret-token
|
||||||
|
```
|
||||||
|
|
||||||
|
Requests without a valid token receive an HTTP `401 Unauthorized` response. This is the best option when you want to **restrict access to a known set of users or services** (e.g. an organization's internal apps) without requiring cryptocurrency payments.
|
||||||
|
|
||||||
|
### 3. x402-bch Per-Call Payments
|
||||||
|
|
||||||
|
Set `X402_ENABLED=true`:
|
||||||
|
|
||||||
|
```
|
||||||
|
X402_ENABLED=true
|
||||||
|
SERVER_BCH_ADDRESS=bitcoincash:qqlrzp23w08434twmvr4fxw672whkjy0py26r63g3d
|
||||||
|
FACILITATOR_URL=http://localhost:4345/facilitator
|
||||||
|
X402_PRICE_SAT=200
|
||||||
|
```
|
||||||
|
|
||||||
|
Every API call under the `/v6` prefix requires a BCH micro-payment. When a request arrives without a valid `X-PAYMENT` header, the server responds with HTTP `402 Payment Required` and includes the payment details. Client libraries that support the x402-bch protocol (like [bch-js](https://github.com/Permissionless-Software-Foundation/bch-js)) can handle payments automatically.
|
||||||
|
|
||||||
|
This is the right choice for **public, monetized APIs** where you want to charge per call.
|
||||||
|
|
||||||
|
When `X402_ENABLED=true`, the server also exposes machine-discovery endpoints:
|
||||||
|
|
||||||
|
- `/.well-known/x402` - x402-bch v2 payment discovery manifest
|
||||||
|
- `/openapi.json` - OpenAPI 3 projection generated from apiDoc annotations
|
||||||
|
- `/swagger.json` - Swagger 2.0 compatibility projection
|
||||||
|
- `/llms.txt` - LLM-oriented markdown index of service metadata
|
||||||
|
- `/.well-known/agent.json` - draft agent manifest describing API actions
|
||||||
|
|
||||||
|
When `X402_ENABLED=false`, these discovery endpoints return `404`.
|
||||||
|
|
||||||
|
#### Combined: x402 + Bearer Token
|
||||||
|
|
||||||
|
You can enable both at the same time:
|
||||||
|
|
||||||
|
```
|
||||||
|
X402_ENABLED=true
|
||||||
|
USE_BASIC_AUTH=true
|
||||||
|
BASIC_AUTH_TOKEN=my-secret-token
|
||||||
|
```
|
||||||
|
|
||||||
|
In this mode, requests that present a valid Bearer token bypass the x402 payment requirement. All other requests must pay. This allows you to give **free access to trusted clients** (via the Bearer token) while still **monetizing public access** via x402.
|
||||||
|
|
||||||
|
## Development
|
||||||
|
|
||||||
|
This is a standard node.js project. To set up a development environment:
|
||||||
|
|
||||||
|
1. Clone the repository:
|
||||||
|
|
||||||
|
`git clone https://github.com/Permissionless-Software-Foundation/psf-bch-api && cd psf-bch-api`
|
||||||
|
|
||||||
|
2. Install dependencies:
|
||||||
|
|
||||||
|
`npm install`
|
||||||
|
|
||||||
|
3. Create your configuration file:
|
||||||
|
|
||||||
|
`cp .env-example .env`
|
||||||
|
|
||||||
|
4. Edit `.env` to point to your back end infrastructure (full node, Fulcrum, SLP indexer). For local development you will likely want to disable access control:
|
||||||
|
|
||||||
|
```
|
||||||
|
X402_ENABLED=false
|
||||||
|
USE_BASIC_AUTH=false
|
||||||
|
```
|
||||||
|
|
||||||
|
5. Start the server:
|
||||||
|
|
||||||
|
`npm start`
|
||||||
|
|
||||||
|
The server will start on port `5942` by default (or whatever you set in `PORT`). API documentation is available at `http://localhost:5942/`.
|
||||||
|
|
||||||
|
### Generating API Docs
|
||||||
|
|
||||||
|
The API reference documentation is generated by [apiDoc](https://apidocjs.com/) from inline annotations in the source code. To regenerate:
|
||||||
|
|
||||||
|
`npm run docs`
|
||||||
|
|
||||||
|
The output is written to the `docs/` directory and served by the running server at its root URL.
|
||||||
|
|
||||||
|
To regenerate API docs plus discovery artifacts (`openapi.json`, `swagger.json`, `llms.txt`, and `agent.json` payload source):
|
||||||
|
|
||||||
|
`npm run docs:all`
|
||||||
|
|
||||||
|
This runs apiDoc first, then generates `docs/discovery-artifacts.json` from the same annotation source.
|
||||||
|
|
||||||
|
A live version can be found at [bch.fullstack.cash](https://bch.fullstack.cash/).
|
||||||
|
|
||||||
|
## Production (Docker)
|
||||||
|
|
||||||
|
A Docker setup is provided in the `production/docker/` directory for production deployments. The target OS is Ubuntu Linux.
|
||||||
|
|
||||||
|
1. Install [Docker and Docker Compose](https://docs.docker.com/engine/install/ubuntu/).
|
||||||
|
|
||||||
|
2. Navigate to the Docker directory:
|
||||||
|
|
||||||
|
`cd production/docker`
|
||||||
|
|
||||||
|
3. Create and configure the `.env` file. An example is provided:
|
||||||
|
|
||||||
|
`cp .env-example .env`
|
||||||
|
|
||||||
|
Edit `.env` to match your production infrastructure. Note that inside a Docker container, `localhost` refers to the container itself. Use `172.17.0.1` (the default Docker bridge gateway) to reach services running on the host machine:
|
||||||
|
|
||||||
|
```
|
||||||
|
RPC_BASEURL=http://172.17.0.1:8332
|
||||||
|
FULCRUM_API=http://172.17.0.1:3001/v1
|
||||||
|
SLP_INDEXER_API=http://172.17.0.1:5010
|
||||||
|
```
|
||||||
|
|
||||||
|
Set `APIDOC_URL` to the public base URL for your deployment (for example `https://api.example.com` or your subdomain). The container entrypoint applies this value to `apidoc.json` and the `apidoc` section of `package.json`, then runs `npm run docs` before starting the server so generated HTML matches each instance. The compose file mounts `./.env` to `/home/safeuser/psf-bch-api/.env` so it matches `dotenv.config()` in the app.
|
||||||
|
|
||||||
|
4. Build the Docker image:
|
||||||
|
|
||||||
|
`docker-compose build --no-cache`
|
||||||
|
|
||||||
|
5. Start the container:
|
||||||
|
|
||||||
|
`docker-compose up -d`
|
||||||
|
|
||||||
|
The container maps host port `5942` to container port `5942`. The `.env` file is mounted into the container as a volume, so you can update configuration without rebuilding.
|
||||||
|
|
||||||
|
To view logs:
|
||||||
|
|
||||||
|
`docker logs -f psf-bch-api`
|
||||||
|
|
||||||
|
To stop the container:
|
||||||
|
|
||||||
|
`docker-compose down`
|
||||||
|
|
||||||
|
A helper script `cleanup-images.sh` is provided to remove dangling Docker images after rebuilds.
|
||||||
|
|
||||||
|
## Testing
|
||||||
|
|
||||||
|
The project includes both unit tests and integration tests. Tests use [Mocha](https://mochajs.org/) as the test runner, [Chai](https://www.chaijs.com/) for assertions, and [Sinon](https://sinonjs.org/) for mocking. Code coverage is provided by [c8](https://github.com/bcoe/c8).
|
||||||
|
|
||||||
|
### Unit Tests
|
||||||
|
|
||||||
|
Unit tests are located in `test/unit/` and cover adapters, controllers, and use cases. They do not require any running infrastructure. To run:
|
||||||
|
|
||||||
|
`npm test`
|
||||||
|
|
||||||
|
This will first lint the code with [Standard](https://standardjs.com/), then execute all unit tests with code coverage.
|
||||||
|
|
||||||
|
To generate an HTML coverage report:
|
||||||
|
|
||||||
|
`npm run coverage`
|
||||||
|
|
||||||
|
The report is written to the `coverage/` directory.
|
||||||
|
|
||||||
|
### Integration Tests
|
||||||
|
|
||||||
|
Integration tests are located in `test/integration/` and require the back end infrastructure (full node, Fulcrum, SLP indexer) to be running. To run:
|
||||||
|
|
||||||
|
`npm run test:integration`
|
||||||
|
|
||||||
|
Integration tests have a 25-second timeout per test to accommodate network calls.
|
||||||
|
|
||||||
|
## Configuration Reference
|
||||||
|
|
||||||
|
All configuration values are read from environment variables (via the `.env` file). The complete list:
|
||||||
|
|
||||||
|
- `PORT` - Server listen port. Default: `5942`
|
||||||
|
- `NODE_ENV` - Environment (`development` or `production`). Default: `development`
|
||||||
|
- `API_PREFIX` - URL prefix for all REST endpoints. Default: `/v6`
|
||||||
|
- `LOG_LEVEL` - Winston logging level. Default: `info`
|
||||||
|
- `RPC_BASEURL` - Full node JSON-RPC URL. Default: `http://127.0.0.1:8332`
|
||||||
|
- `RPC_USERNAME` - Full node RPC username.
|
||||||
|
- `RPC_PASSWORD` - Full node RPC password.
|
||||||
|
- `RPC_TIMEOUT_MS` - Full node RPC request timeout in ms. Default: `15000`
|
||||||
|
- `FULCRUM_API` - Fulcrum indexer REST API URL.
|
||||||
|
- `FULCRUM_TIMEOUT_MS` - Fulcrum API request timeout in ms. Default: `15000`
|
||||||
|
- `SLP_INDEXER_API` - SLP Token Indexer REST API URL.
|
||||||
|
- `SLP_INDEXER_TIMEOUT_MS` - SLP Indexer API request timeout in ms. Default: `15000`
|
||||||
|
- `LOCAL_RESTURL` - Internal REST URL for wallet operations. Default: `http://127.0.0.1:5942/v6/`
|
||||||
|
- `IPFS_GATEWAY` - IPFS gateway hostname. Default: `p2wdb-gateway-678.fullstack.cash`
|
||||||
|
- `X402_ENABLED` - Enable x402-bch payment middleware. Default: `true`
|
||||||
|
- `SERVER_BCH_ADDRESS` - BCH address for x402 payments. Default: `bitcoincash:qqsrke9lh257tqen99dkyy2emh4uty0vky9y0z0lsr`
|
||||||
|
- `FACILITATOR_URL` - x402-bch facilitator service URL. Default: `http://localhost:4345/facilitator`
|
||||||
|
- `X402_PRICE_SAT` - Satoshis charged per API call via x402. Default: `200`
|
||||||
|
- `USE_BASIC_AUTH` - Enable Bearer token authentication. Default: `false`
|
||||||
|
- `BASIC_AUTH_TOKEN` - Expected Bearer token value.
|
||||||
|
|
||||||
## License
|
## License
|
||||||
|
|
||||||
[MIT](./LICENSE.md)
|
[MIT](./LICENSE.md)
|
||||||
|
|
||||||
## x402-bch Payments
|
|
||||||
|
|
||||||
All REST endpoints exposed under the `/v6` prefix are protected by the [`x402-bch-express`](https://www.npmjs.com/package/x402-bch-express) middleware. Each API call requires a BCH payment authorization for **200 satoshis**. The middleware advertises payment requirements via HTTP 402 responses and validates incoming `X-PAYMENT` headers with a configured Facilitator.
|
|
||||||
|
|
||||||
### Configuration
|
|
||||||
|
|
||||||
Environment variables control the payment flow:
|
|
||||||
|
|
||||||
- `X402_ENABLED` — set to `false` (case-insensitive) to disable the middleware. Defaults to enabled.
|
|
||||||
- `SERVER_BCH_ADDRESS` — BCH cash address that receives funding transactions. Defaults to `bitcoincash:qqlrzp23w08434twmvr4fxw672whkjy0py26r63g3d`.
|
|
||||||
- `FACILITATOR_URL` — Root URL of the facilitator service (e.g., `http://localhost:4345/facilitator`).
|
|
||||||
- `X402_PRICE_SAT` — Optional; override the satoshi price per call (defaults to `200`).
|
|
||||||
|
|
||||||
When `X402_ENABLED=false`, the server continues to operate without payment headers for local development or trusted deployments.
|
|
||||||
|
|
||||||
### Manual Verification
|
|
||||||
|
|
||||||
1. Start or point to an `x402-bch` facilitator service (the example facilitator listens at `http://localhost:4345/facilitator`).
|
|
||||||
2. Run the API server with the default configuration: `npm start`.
|
|
||||||
3. Call a protected endpoint without an `X-PAYMENT` header, e.g. `curl -i http://localhost:5942/v6/full-node/control/getNetworkInfo`. The server will respond with HTTP `402` and include payment requirements.
|
|
||||||
4. Restart the server with `X402_ENABLED=false npm start` to confirm that the same request now bypasses the middleware (useful for local development without payments).
|
|
||||||
|
|
||||||
|
|||||||
Binary file not shown.
|
After Width: | Height: | Size: 25 KiB |
+13
-1
@@ -17,6 +17,7 @@ import Controllers from '../src/controllers/index.js'
|
|||||||
import wlogger from '../src/adapters/wlogger.js'
|
import wlogger from '../src/adapters/wlogger.js'
|
||||||
import { buildX402Routes, getX402Settings, getBasicAuthSettings } from '../src/config/x402.js'
|
import { buildX402Routes, getX402Settings, getBasicAuthSettings } from '../src/config/x402.js'
|
||||||
import { basicAuthMiddleware } from '../src/middleware/basic-auth.js'
|
import { basicAuthMiddleware } from '../src/middleware/basic-auth.js'
|
||||||
|
import DiscoveryRouter from '../src/controllers/discovery/router.js'
|
||||||
|
|
||||||
// Load environment variables
|
// Load environment variables
|
||||||
dotenv.config()
|
dotenv.config()
|
||||||
@@ -59,6 +60,7 @@ class Server {
|
|||||||
try {
|
try {
|
||||||
// Create an Express instance.
|
// Create an Express instance.
|
||||||
const app = express()
|
const app = express()
|
||||||
|
app.set('trust proxy', true)
|
||||||
|
|
||||||
const x402Settings = getX402Settings()
|
const x402Settings = getX402Settings()
|
||||||
const basicAuthSettings = getBasicAuthSettings()
|
const basicAuthSettings = getBasicAuthSettings()
|
||||||
@@ -183,7 +185,10 @@ class Server {
|
|||||||
|
|
||||||
// Request logging middleware
|
// Request logging middleware
|
||||||
app.use((req, res, next) => {
|
app.use((req, res, next) => {
|
||||||
wlogger.info(`${req.method} ${req.path}`)
|
wlogger.info(`${req.method} ${req.path}`, {
|
||||||
|
client_ip: req.ip,
|
||||||
|
remote_address: req.socket?.remoteAddress || null
|
||||||
|
})
|
||||||
next()
|
next()
|
||||||
})
|
})
|
||||||
|
|
||||||
@@ -212,6 +217,8 @@ class Server {
|
|||||||
|
|
||||||
// Attach REST API controllers to the app.
|
// Attach REST API controllers to the app.
|
||||||
this.controllers.attachRESTControllers(app)
|
this.controllers.attachRESTControllers(app)
|
||||||
|
const discoveryRouter = new DiscoveryRouter()
|
||||||
|
discoveryRouter.attach(app)
|
||||||
|
|
||||||
// Initialize any other controller libraries.
|
// Initialize any other controller libraries.
|
||||||
this.controllers.initControllers()
|
this.controllers.initControllers()
|
||||||
@@ -246,6 +253,11 @@ class Server {
|
|||||||
wlogger.info(`Server started on port ${this.config.port}`)
|
wlogger.info(`Server started on port ${this.config.port}`)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
// Explicit timeout settings reduce stale keep-alive socket reuse races.
|
||||||
|
this.server.keepAliveTimeout = this.config.serverKeepAliveTimeoutMs
|
||||||
|
this.server.headersTimeout = this.config.serverHeadersTimeoutMs
|
||||||
|
this.server.requestTimeout = this.config.serverRequestTimeoutMs
|
||||||
|
|
||||||
this.server.on('error', (err) => {
|
this.server.on('error', (err) => {
|
||||||
console.error('Server error:', err)
|
console.error('Server error:', err)
|
||||||
wlogger.error('Server error:', err)
|
wlogger.error('Server error:', err)
|
||||||
|
|||||||
@@ -0,0 +1,21 @@
|
|||||||
|
# 2026-03-16 Update Log
|
||||||
|
|
||||||
|
## Summary
|
||||||
|
|
||||||
|
Reduced noisy error logging for common SLP transaction misses in the `/v6/slp/txid` path.
|
||||||
|
|
||||||
|
## Changes Made
|
||||||
|
|
||||||
|
- Updated `src/use-cases/slp-use-cases.js` in `getTxid()`:
|
||||||
|
- Added a guard for expected missing-record errors (`404` + `Key not found in database`).
|
||||||
|
- Skips `wlogger.error()` for that specific, common case.
|
||||||
|
- Still rethrows the error so API response behavior is unchanged.
|
||||||
|
- Updated `src/controllers/rest-api/slp/controller.js` in `handleError()`:
|
||||||
|
- Added the same guard to suppress duplicate error-level logs for the same expected case.
|
||||||
|
- Keeps normal error logging for all other errors.
|
||||||
|
|
||||||
|
## Outcome
|
||||||
|
|
||||||
|
- The common "Key not found in database" case no longer pollutes error logs.
|
||||||
|
- Unexpected failures continue to be logged at error level.
|
||||||
|
- Client-facing status and error message behavior remains unchanged.
|
||||||
@@ -0,0 +1,76 @@
|
|||||||
|
# 2026-03-17 Update Log
|
||||||
|
|
||||||
|
## Summary
|
||||||
|
|
||||||
|
Enhanced REST request logging to capture client network identity in Winston logs, enabled proxy-aware IP resolution, and reduced Fulcrum error-log noise for expected missing-transaction requests.
|
||||||
|
|
||||||
|
## Changes Made
|
||||||
|
|
||||||
|
- Updated `bin/server.js`:
|
||||||
|
- Set Express proxy handling with `app.set('trust proxy', true)`.
|
||||||
|
- Kept the current Winston request message format (`"${req.method} ${req.path}"`).
|
||||||
|
- Added structured Winston metadata fields to request logs:
|
||||||
|
- `client_ip` from `req.ip`
|
||||||
|
- `remote_address` from `req.socket.remoteAddress`
|
||||||
|
- Updated `src/adapters/fulcrum-api.js`:
|
||||||
|
- Added parsing helpers to normalize Fulcrum error messages from multiple response shapes.
|
||||||
|
- Mapped common daemon missing-TX error (`No such mempool or blockchain transaction`) to:
|
||||||
|
- status `404`
|
||||||
|
- message `Transaction not found`
|
||||||
|
- Updated `src/use-cases/fulcrum-use-cases.js`:
|
||||||
|
- Removed duplicate error logging in `getTransactionDetails()` and now rethrows adapter errors without a second error-level log.
|
||||||
|
- Updated `src/controllers/rest-api/fulcrum/controller.js`:
|
||||||
|
- Added TXID validation (`64`-character hex) for `GET /v6/fulcrum/tx/data/:txid`.
|
||||||
|
- Updated `handleError()` logging policy:
|
||||||
|
- `Transaction not found` (`404`) logs at `info`
|
||||||
|
- other `4xx` logs at `warn`
|
||||||
|
- `5xx` logs at `error`
|
||||||
|
|
||||||
|
## Useful Fields Available for REST Request Logging
|
||||||
|
|
||||||
|
- Routing and request basics:
|
||||||
|
- `method` (`req.method`)
|
||||||
|
- `path` (`req.path`)
|
||||||
|
- `original_url` (`req.originalUrl`)
|
||||||
|
- `query` (`req.query`)
|
||||||
|
- Client network identity:
|
||||||
|
- `client_ip` (`req.ip`)
|
||||||
|
- `forwarded_ips` (`req.ips`, when behind one or more proxies)
|
||||||
|
- `remote_address` (`req.socket.remoteAddress`)
|
||||||
|
- HTTP and transport:
|
||||||
|
- `protocol` (`req.protocol`)
|
||||||
|
- `secure` (`req.secure`)
|
||||||
|
- `http_version` (`req.httpVersion`)
|
||||||
|
- `host` (`req.get('host')`)
|
||||||
|
- `origin` (`req.get('origin')`)
|
||||||
|
- `referer` (`req.get('referer')`)
|
||||||
|
- `user_agent` (`req.get('user-agent')`)
|
||||||
|
- Request/response performance and size:
|
||||||
|
- `status_code` (`res.statusCode`, from `res.on('finish')`)
|
||||||
|
- `duration_ms` (elapsed time between request start and response finish)
|
||||||
|
- `request_size_bytes` (`req.get('content-length')`)
|
||||||
|
- `response_size_bytes` (`res.getHeader('content-length')`)
|
||||||
|
- App-specific request context in this codebase:
|
||||||
|
- `basic_auth_valid` (`req.locals.basicAuthValid`)
|
||||||
|
- x402 decision/bypass status (derived from middleware path and config)
|
||||||
|
|
||||||
|
## Already Logging
|
||||||
|
|
||||||
|
- In Winston request logs:
|
||||||
|
- `message` with method + path (for example `GET /v6/full-node/blockchain/getBlockCount`)
|
||||||
|
- `client_ip`
|
||||||
|
- `remote_address`
|
||||||
|
- `timestamp` (from Winston timestamp formatter)
|
||||||
|
- `level`
|
||||||
|
- In console endpoint logs:
|
||||||
|
- Request line with method, path, and `req.ip`
|
||||||
|
- Response line with method, path, and final `res.statusCode`
|
||||||
|
|
||||||
|
## Outcome
|
||||||
|
|
||||||
|
- Request logs now preserve existing behavior while adding IP attribution fields.
|
||||||
|
- `trust proxy` ensures `req.ip` is proxy-aware when the server is deployed behind a reverse proxy.
|
||||||
|
- The project now has a documented list of high-value request fields for future logging expansion.
|
||||||
|
- Fulcrum missing-transaction lookups now return cleaner API semantics (`404 Transaction not found`).
|
||||||
|
- Duplicate error logs for a single missing TX lookup were removed.
|
||||||
|
- Invalid TXIDs are rejected early with a `400` validation error.
|
||||||
@@ -0,0 +1,72 @@
|
|||||||
|
# 2026-04-01 Update Log
|
||||||
|
|
||||||
|
## Summary
|
||||||
|
|
||||||
|
Added x402-gated discovery endpoints for agent/tool self-discovery, built a docs-derived artifact pipeline from apiDoc annotations, and documented the new flow and behavior.
|
||||||
|
|
||||||
|
## Changes Made
|
||||||
|
|
||||||
|
- Added new discovery controller/router:
|
||||||
|
- `src/controllers/discovery/controller.js`
|
||||||
|
- `src/controllers/discovery/router.js`
|
||||||
|
- Added five root-path discovery endpoints:
|
||||||
|
- `GET /.well-known/x402`
|
||||||
|
- `GET /openapi.json`
|
||||||
|
- `GET /swagger.json`
|
||||||
|
- `GET /llms.txt`
|
||||||
|
- `GET /.well-known/agent.json`
|
||||||
|
- Added x402-enabled gating:
|
||||||
|
- All five endpoints now return `404` when `X402_ENABLED=false`.
|
||||||
|
- When enabled, payloads are returned with x402-bch v2-oriented metadata.
|
||||||
|
- Added apiDoc-derived document builder:
|
||||||
|
- `src/discovery/build-documents.js`
|
||||||
|
- Parses `@api` annotations and builds OpenAPI, Swagger, llms, and agent documents.
|
||||||
|
- Uses `docs/discovery-artifacts.json` if present, otherwise builds in-process.
|
||||||
|
- Added artifact generation script:
|
||||||
|
- `scripts/build-discovery-artifacts.js`
|
||||||
|
- Writes `docs/discovery-artifacts.json`
|
||||||
|
- Updated npm scripts in `package.json`:
|
||||||
|
- `docs:discovery`
|
||||||
|
- `docs:all` (runs `docs` then `docs:discovery`)
|
||||||
|
- Wired discovery routes into server bootstrap:
|
||||||
|
- `bin/server.js`
|
||||||
|
- Added tests:
|
||||||
|
- `test/unit/controllers/discovery-controller-unit.js`
|
||||||
|
- `test/unit/controllers/discovery-router-unit.js`
|
||||||
|
- `test/unit/controllers/discovery-documents-unit.js`
|
||||||
|
- Updated docs/config examples:
|
||||||
|
- `README.md` (discovery endpoints + docs workflow)
|
||||||
|
- `.env-example` (x402 gating note for discovery endpoints)
|
||||||
|
|
||||||
|
## Why This Was Changed
|
||||||
|
|
||||||
|
- Endpoint probes for discovery paths are common from API tooling and AI agents.
|
||||||
|
- Serving structured discovery metadata improves machine interoperability for:
|
||||||
|
- API clients and SDK tooling (`openapi.json`, `swagger.json`)
|
||||||
|
- LLM retrieval workflows (`llms.txt`)
|
||||||
|
- Agent capability discovery (`agent.json`)
|
||||||
|
- x402 payment discovery (`/.well-known/x402`)
|
||||||
|
- Gating by `X402_ENABLED` keeps discovery aligned with monetization mode and avoids advertising payment surfaces when x402 is disabled.
|
||||||
|
|
||||||
|
## Validation Notes
|
||||||
|
|
||||||
|
- Lint passed.
|
||||||
|
- New discovery-focused unit tests passed.
|
||||||
|
- Full `npm test` run showed one pre-existing timeout failure in `test/unit/use-cases/price-use-cases-unit.js` unrelated to discovery endpoint changes.
|
||||||
|
|
||||||
|
## References
|
||||||
|
|
||||||
|
- Local protocol spec:
|
||||||
|
- `../x402-bch/specs/x402-bch-specification-v2.2.md`
|
||||||
|
- OpenAPI Specification:
|
||||||
|
- https://spec.openapis.org/oas/latest.html
|
||||||
|
- Swagger / OpenAPI 2.0:
|
||||||
|
- https://swagger.io/specification/v2/
|
||||||
|
- llms.txt proposal:
|
||||||
|
- https://www.llmstxt.org/index.html
|
||||||
|
- Agent manifest draft reference:
|
||||||
|
- https://agentwebprotocol.org/spec
|
||||||
|
- x402 HTTP 402 background:
|
||||||
|
- https://docs.x402.org/core-concepts/http-402
|
||||||
|
- x402 DNS discovery draft:
|
||||||
|
- https://www.ietf.org/archive/id/draft-jeftovic-x402-dns-discovery-00.html
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
# 2026-04-02 Update Log
|
||||||
|
|
||||||
|
## Summary
|
||||||
|
|
||||||
|
Docker deployments now run `npm run docs` at container start via an entrypoint script, and optionally apply `APIDOC_URL` from the environment so apiDoc HTML matches each deployment subdomain or public URL.
|
||||||
|
|
||||||
|
## Changes Made
|
||||||
|
|
||||||
|
- Added `scripts/patch-apidoc-from-env.js` to set `apidoc.json` and `package.json` `apidoc.url` from `APIDOC_URL` (dotenv loads the project `.env`, same path as `bin/server.js`).
|
||||||
|
- Added `production/docker/entrypoint.sh` to run the patch script, `npm run docs`, then `exec npm start`.
|
||||||
|
- Updated `production/docker/Dockerfile` to remove build-time `npm run docs`, copy the entrypoint and patch script from the build context, and use `ENTRYPOINT` for the shell script.
|
||||||
|
- Updated `production/docker/docker-compose.yml` to use build `context: ../..` and `dockerfile: production/docker/Dockerfile` so COPY paths resolve from the repository root.
|
||||||
|
- Compose mounts `./.env` at `/home/safeuser/psf-bch-api/.env` so the app and entrypoint share one file (not `/home/safeuser/.env`).
|
||||||
|
- Documented `APIDOC_URL` in `.env-example`, `production/docker/.env-example`, and `README.md` (Production Docker section).
|
||||||
|
|
||||||
|
## Outcome
|
||||||
|
|
||||||
|
- Operators can set `APIDOC_URL` in the mounted `.env` (for example `https://api.example.com`) per instance without rebuilding the image for each subdomain.
|
||||||
|
- The HTML apiDoc bundle is regenerated on every container start so it stays aligned with the configured URL.
|
||||||
Generated
+9
-9
@@ -9,12 +9,12 @@
|
|||||||
"version": "7.0.0",
|
"version": "7.0.0",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@psf/bch-js": "7.1.11",
|
"@psf/bch-js": "7.1.14",
|
||||||
"axios": "1.7.7",
|
"axios": "1.7.7",
|
||||||
"cors": "2.8.5",
|
"cors": "2.8.5",
|
||||||
"dotenv": "16.3.1",
|
"dotenv": "16.3.1",
|
||||||
"express": "5.1.0",
|
"express": "5.1.0",
|
||||||
"minimal-slp-wallet": "7.1.4",
|
"minimal-slp-wallet": "7.1.5",
|
||||||
"psffpp": "1.2.1",
|
"psffpp": "1.2.1",
|
||||||
"slp-token-media": "1.2.10",
|
"slp-token-media": "1.2.10",
|
||||||
"winston": "3.11.0",
|
"winston": "3.11.0",
|
||||||
@@ -858,9 +858,9 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/@psf/bch-js": {
|
"node_modules/@psf/bch-js": {
|
||||||
"version": "7.1.11",
|
"version": "7.1.14",
|
||||||
"resolved": "https://registry.npmjs.org/@psf/bch-js/-/bch-js-7.1.11.tgz",
|
"resolved": "https://registry.npmjs.org/@psf/bch-js/-/bch-js-7.1.14.tgz",
|
||||||
"integrity": "sha512-gDJCaY2aG8EtUWcR9D4tbiyM1BkHd7gkuO7NRaLpwdbSrnU51lyPr69mjQLKOcVlL+aXdJsOjL5pm15t4zq18w==",
|
"integrity": "sha512-B/NXuxSoOHgMR0tHyY8qpXN3VDATeBhd6qhasJsiEjb22IGIjsXsdJ0oZR2DLnn/1UA+94+XJNyVz2UlcaqEpw==",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@chris.troutner/bip32-utils": "1.0.5",
|
"@chris.troutner/bip32-utils": "1.0.5",
|
||||||
@@ -6475,13 +6475,13 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/minimal-slp-wallet": {
|
"node_modules/minimal-slp-wallet": {
|
||||||
"version": "7.1.4",
|
"version": "7.1.5",
|
||||||
"resolved": "https://registry.npmjs.org/minimal-slp-wallet/-/minimal-slp-wallet-7.1.4.tgz",
|
"resolved": "https://registry.npmjs.org/minimal-slp-wallet/-/minimal-slp-wallet-7.1.5.tgz",
|
||||||
"integrity": "sha512-oHPDu+dUyAT8YOyKvb6JGZYIoalXAEHvcAUby7OgL3D/5R+cR21FTjpqpp7BJp+NFcGRANohnLAqpP2vt6tgFA==",
|
"integrity": "sha512-dROdawFZJZLvyTRndJi987S+z0cOG9k6coyyTAfkaaQftP+UayjUyjKeQlJVrKAPgIzxhk6EoZKD6AtoGjwQrw==",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@chris.troutner/retry-queue": "1.0.11",
|
"@chris.troutner/retry-queue": "1.0.11",
|
||||||
"@psf/bch-js": "7.1.11",
|
"@psf/bch-js": "7.1.14",
|
||||||
"bch-consumer": "1.6.2",
|
"bch-consumer": "1.6.2",
|
||||||
"bch-donation": "1.1.2",
|
"bch-donation": "1.1.2",
|
||||||
"crypto-js": "4.0.0"
|
"crypto-js": "4.0.0"
|
||||||
|
|||||||
+4
-2
@@ -6,6 +6,8 @@
|
|||||||
"scripts": {
|
"scripts": {
|
||||||
"start": "node bin/server.js",
|
"start": "node bin/server.js",
|
||||||
"docs": "./node_modules/.bin/apidoc -i src/ -o docs",
|
"docs": "./node_modules/.bin/apidoc -i src/ -o docs",
|
||||||
|
"docs:discovery": "node scripts/build-discovery-artifacts.js",
|
||||||
|
"docs:all": "npm run docs && npm run docs:discovery",
|
||||||
"lint": "standard --env mocha --fix",
|
"lint": "standard --env mocha --fix",
|
||||||
"test": "npm run lint && TEST=unit c8 mocha 'test/unit/**/*.js' --exit",
|
"test": "npm run lint && TEST=unit c8 mocha 'test/unit/**/*.js' --exit",
|
||||||
"test:integration": "mocha --timeout 25000 'test/integration/**/*.js' --exit",
|
"test:integration": "mocha --timeout 25000 'test/integration/**/*.js' --exit",
|
||||||
@@ -15,12 +17,12 @@
|
|||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"description": "REST API proxy to Bitcoin Cash infrastructure",
|
"description": "REST API proxy to Bitcoin Cash infrastructure",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@psf/bch-js": "7.1.11",
|
"@psf/bch-js": "7.1.14",
|
||||||
"axios": "1.7.7",
|
"axios": "1.7.7",
|
||||||
"cors": "2.8.5",
|
"cors": "2.8.5",
|
||||||
"dotenv": "16.3.1",
|
"dotenv": "16.3.1",
|
||||||
"express": "5.1.0",
|
"express": "5.1.0",
|
||||||
"minimal-slp-wallet": "7.1.4",
|
"minimal-slp-wallet": "7.1.5",
|
||||||
"psffpp": "1.2.1",
|
"psffpp": "1.2.1",
|
||||||
"slp-token-media": "1.2.10",
|
"slp-token-media": "1.2.10",
|
||||||
"winston": "3.11.0",
|
"winston": "3.11.0",
|
||||||
|
|||||||
@@ -0,0 +1 @@
|
|||||||
|
|
||||||
@@ -9,13 +9,17 @@ RPC_PASSWORD=password
|
|||||||
FULCRUM_API=http://172.17.0.1:3001/v1
|
FULCRUM_API=http://172.17.0.1:3001/v1
|
||||||
|
|
||||||
# SLP Indexer
|
# SLP Indexer
|
||||||
SLP_INDEXER_API=http://172.17.0.1:5010
|
SLP_INDEXER_API=http://172.17.0.1:5020
|
||||||
|
|
||||||
# REST API URL for wallet operations
|
# REST API URL for wallet operations
|
||||||
LOCAL_RESTURL=http://172.17.0.1:5942/v6
|
LOCAL_RESTURL=http://172.17.0.1:5942/v6
|
||||||
|
|
||||||
# END INFRASTRUCTURE SETUP
|
# END INFRASTRUCTURE SETUP
|
||||||
|
|
||||||
|
# Public base URL for apiDoc HTML (set per deployment / subdomain).
|
||||||
|
# Applied at container start before `npm run docs`. Example: https://api.example.com
|
||||||
|
#APIDOC_URL=https://api.example.com
|
||||||
|
|
||||||
|
|
||||||
# START ACCESS CONTROL
|
# START ACCESS CONTROL
|
||||||
|
|
||||||
@@ -35,3 +39,7 @@ USE_BASIC_AUTH=false
|
|||||||
|
|
||||||
# END ACCESS CONTROL
|
# END ACCESS CONTROL
|
||||||
|
|
||||||
|
# PSF token liquidity price proxy (GET /v6/price/psf). Off by default.
|
||||||
|
#PSF_LIQUIDITY_PROXY_ENABLED=true
|
||||||
|
#PSF_LIQUIDITY_URL=http://192.168.0.126:5000
|
||||||
|
|
||||||
|
|||||||
@@ -57,13 +57,15 @@ RUN git checkout ct-unstable
|
|||||||
RUN npm install
|
RUN npm install
|
||||||
RUN npm install minimal-slp-wallet
|
RUN npm install minimal-slp-wallet
|
||||||
|
|
||||||
# Generate the API docs
|
# Runtime entrypoint + apidoc URL patch (see production/docker/entrypoint.sh).
|
||||||
RUN npm run docs
|
# API docs are generated at container start so APIDOC_URL can be set per deployment.
|
||||||
|
COPY production/docker/entrypoint.sh /home/safeuser/psf-bch-api/entrypoint.sh
|
||||||
|
COPY scripts/patch-apidoc-from-env.js /home/safeuser/psf-bch-api/scripts/patch-apidoc-from-env.js
|
||||||
|
RUN chmod +x /home/safeuser/psf-bch-api/entrypoint.sh
|
||||||
|
|
||||||
COPY .env .env
|
# Runtime `.env` is provided by docker-compose (mount at psf-bch-api/.env), not baked into the image.
|
||||||
|
|
||||||
|
ENTRYPOINT ["/home/safeuser/psf-bch-api/entrypoint.sh"]
|
||||||
CMD ["npm", "start"]
|
|
||||||
|
|
||||||
# Used to debug the container.
|
# Used to debug the container.
|
||||||
#COPY temp.js temp.js
|
#COPY temp.js temp.js
|
||||||
|
|||||||
@@ -2,7 +2,9 @@
|
|||||||
|
|
||||||
services:
|
services:
|
||||||
psf-bch-api:
|
psf-bch-api:
|
||||||
build: .
|
build:
|
||||||
|
context: ../..
|
||||||
|
dockerfile: production/docker/Dockerfile
|
||||||
container_name: psf-bch-api
|
container_name: psf-bch-api
|
||||||
logging:
|
logging:
|
||||||
driver: 'json-file'
|
driver: 'json-file'
|
||||||
@@ -16,5 +18,7 @@ services:
|
|||||||
- '5942:5942' # <host port>:<container port>
|
- '5942:5942' # <host port>:<container port>
|
||||||
volumes:
|
volumes:
|
||||||
#- ./start-rest2nostr.sh:/home/safeuser/REST2NOSTR/start-rest2nostr.sh
|
#- ./start-rest2nostr.sh:/home/safeuser/REST2NOSTR/start-rest2nostr.sh
|
||||||
- ./.env:/home/safeuser/.env
|
- ./.env:/home/safeuser/psf-bch-api/.env
|
||||||
|
- ../data:/home/safeuser/psf-bch-api/production/data
|
||||||
|
- ../data/logs:/home/safeuser/psf-bch-api/logs
|
||||||
restart: always
|
restart: always
|
||||||
@@ -0,0 +1,10 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
set -euo pipefail
|
||||||
|
|
||||||
|
cd /home/safeuser/psf-bch-api
|
||||||
|
|
||||||
|
node scripts/patch-apidoc-from-env.js
|
||||||
|
|
||||||
|
npm run docs
|
||||||
|
|
||||||
|
exec npm start
|
||||||
@@ -0,0 +1,21 @@
|
|||||||
|
/*
|
||||||
|
Build discovery endpoint artifacts from apiDoc source annotations.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import { mkdirSync, writeFileSync } from 'fs'
|
||||||
|
import { dirname, resolve } from 'path'
|
||||||
|
|
||||||
|
import { buildDiscoveryDocuments } from '../src/discovery/build-documents.js'
|
||||||
|
|
||||||
|
function main () {
|
||||||
|
const outputPath = resolve(process.cwd(), 'docs/discovery-artifacts.json')
|
||||||
|
const docs = buildDiscoveryDocuments()
|
||||||
|
|
||||||
|
mkdirSync(dirname(outputPath), { recursive: true })
|
||||||
|
writeFileSync(outputPath, `${JSON.stringify(docs, null, 2)}\n`)
|
||||||
|
|
||||||
|
// eslint-disable-next-line no-console
|
||||||
|
console.log(`Wrote discovery artifacts to ${outputPath}`)
|
||||||
|
}
|
||||||
|
|
||||||
|
main()
|
||||||
@@ -0,0 +1,41 @@
|
|||||||
|
/*
|
||||||
|
Applies APIDOC_URL from the environment to apidoc.json and package.json (apidoc.url).
|
||||||
|
Loads dotenv from the project root `.env` (same file as `dotenv.config()` in bin/server.js).
|
||||||
|
Exits without changes when APIDOC_URL is unset or empty.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import dotenv from 'dotenv'
|
||||||
|
import { readFileSync, writeFileSync } from 'fs'
|
||||||
|
import { dirname, resolve } from 'path'
|
||||||
|
import { fileURLToPath } from 'url'
|
||||||
|
|
||||||
|
const __dirname = dirname(fileURLToPath(import.meta.url))
|
||||||
|
const root = resolve(__dirname, '..')
|
||||||
|
|
||||||
|
dotenv.config({ path: resolve(root, '.env') })
|
||||||
|
|
||||||
|
const url = process.env.APIDOC_URL
|
||||||
|
if (url === undefined || url === null || String(url).trim() === '') {
|
||||||
|
process.exit(0)
|
||||||
|
}
|
||||||
|
|
||||||
|
const normalized = String(url).trim()
|
||||||
|
|
||||||
|
function patchApidocJson () {
|
||||||
|
const path = resolve(root, 'apidoc.json')
|
||||||
|
const data = JSON.parse(readFileSync(path, 'utf8'))
|
||||||
|
data.url = normalized
|
||||||
|
data.sampleUrl = normalized
|
||||||
|
writeFileSync(path, `${JSON.stringify(data, null, 2)}\n`)
|
||||||
|
}
|
||||||
|
|
||||||
|
function patchPackageJson () {
|
||||||
|
const path = resolve(root, 'package.json')
|
||||||
|
const data = JSON.parse(readFileSync(path, 'utf8'))
|
||||||
|
if (!data.apidoc) data.apidoc = {}
|
||||||
|
data.apidoc.url = normalized
|
||||||
|
writeFileSync(path, `${JSON.stringify(data, null, 2)}\n`)
|
||||||
|
}
|
||||||
|
|
||||||
|
patchApidocJson()
|
||||||
|
patchPackageJson()
|
||||||
@@ -65,17 +65,28 @@ class FulcrumAPIAdapter {
|
|||||||
// Attempt to extract error message from response data
|
// Attempt to extract error message from response data
|
||||||
if (err.response && err.response.data) {
|
if (err.response && err.response.data) {
|
||||||
const data = err.response.data
|
const data = err.response.data
|
||||||
|
const status = err.response.status || 400
|
||||||
|
const message = this._extractErrorMessage(data)
|
||||||
|
|
||||||
|
if (this._isCommonMissingTxError(message)) {
|
||||||
|
return this._formatError('Transaction not found', 404)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (message) {
|
||||||
|
return this._formatError(message, status)
|
||||||
|
}
|
||||||
|
|
||||||
// Handle structured error responses
|
// Handle structured error responses
|
||||||
if (data.error) {
|
if (data.error) {
|
||||||
return this._formatError(data.error, err.response.status || 400)
|
return this._formatError(data.error, status)
|
||||||
}
|
}
|
||||||
// Handle string error messages
|
// Handle string error messages
|
||||||
if (typeof data === 'string') {
|
if (typeof data === 'string') {
|
||||||
return this._formatError(data, err.response.status || 400)
|
return this._formatError(data, status)
|
||||||
}
|
}
|
||||||
// Handle object responses that might contain error info
|
// Handle object responses that might contain error info
|
||||||
if (typeof data === 'object' && data.message) {
|
if (typeof data === 'object' && data.message) {
|
||||||
return this._formatError(data.message, err.response.status || 400)
|
return this._formatError(data.message, status)
|
||||||
}
|
}
|
||||||
// Fallback to returning the status
|
// Fallback to returning the status
|
||||||
return this._formatError('Fulcrum API error', err.response.status || 500)
|
return this._formatError('Fulcrum API error', err.response.status || 500)
|
||||||
@@ -119,6 +130,25 @@ class FulcrumAPIAdapter {
|
|||||||
status: status || 500
|
status: status || 500
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
_extractErrorMessage (data) {
|
||||||
|
if (!data) return ''
|
||||||
|
|
||||||
|
if (typeof data === 'string') return data
|
||||||
|
|
||||||
|
if (typeof data === 'object') {
|
||||||
|
if (typeof data.error === 'string') return data.error
|
||||||
|
if (data.error && typeof data.error === 'object' && data.error.message) return data.error.message
|
||||||
|
if (data.message) return data.message
|
||||||
|
}
|
||||||
|
|
||||||
|
return ''
|
||||||
|
}
|
||||||
|
|
||||||
|
_isCommonMissingTxError (message = '') {
|
||||||
|
return typeof message === 'string' &&
|
||||||
|
message.includes('No such mempool or blockchain transaction')
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export default FulcrumAPIAdapter
|
export default FulcrumAPIAdapter
|
||||||
|
|||||||
@@ -39,6 +39,7 @@ class FullNodeRPCAdapter {
|
|||||||
|
|
||||||
async call (method, params = [], requestId) {
|
async call (method, params = [], requestId) {
|
||||||
const id = requestId || `${this.requestIdPrefix}-${method}`
|
const id = requestId || `${this.requestIdPrefix}-${method}`
|
||||||
|
console.log('full-node-rpc.js/call(): this.http.defaults.baseURL: ', this.http.defaults.baseURL)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const response = await this.http.post('', {
|
const response = await this.http.post('', {
|
||||||
|
|||||||
Vendored
+20
@@ -43,10 +43,28 @@ const basicAuthDefaults = {
|
|||||||
token: process.env.BASIC_AUTH_TOKEN || ''
|
token: process.env.BASIC_AUTH_TOKEN || ''
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const psfLiquidityUrlEnv = process.env.PSF_LIQUIDITY_URL
|
||||||
|
const psfLiquidityProxyBaseUrl =
|
||||||
|
psfLiquidityUrlEnv !== undefined &&
|
||||||
|
psfLiquidityUrlEnv !== null &&
|
||||||
|
String(psfLiquidityUrlEnv).trim() !== ''
|
||||||
|
? String(psfLiquidityUrlEnv).trim().replace(/\/$/, '')
|
||||||
|
: 'http://192.168.0.126:5000'
|
||||||
|
|
||||||
|
const psfLiquidityProxyDefaults = {
|
||||||
|
enabled: normalizeBoolean(process.env.PSF_LIQUIDITY_PROXY_ENABLED, false),
|
||||||
|
baseUrl: psfLiquidityProxyBaseUrl
|
||||||
|
}
|
||||||
|
|
||||||
export default {
|
export default {
|
||||||
// Server port
|
// Server port
|
||||||
port: parseInt(process.env.PORT, 10) || 5942,
|
port: parseInt(process.env.PORT, 10) || 5942,
|
||||||
|
|
||||||
|
// HTTP server connection lifecycle configuration.
|
||||||
|
serverKeepAliveTimeoutMs: Number(process.env.SERVER_KEEPALIVE_TIMEOUT_MS || 3000),
|
||||||
|
serverHeadersTimeoutMs: Number(process.env.SERVER_HEADERS_TIMEOUT_MS || 65000),
|
||||||
|
serverRequestTimeoutMs: Number(process.env.SERVER_REQUEST_TIMEOUT_MS || 120000),
|
||||||
|
|
||||||
// Environment
|
// Environment
|
||||||
env: process.env.NODE_ENV || 'development',
|
env: process.env.NODE_ENV || 'development',
|
||||||
|
|
||||||
@@ -87,6 +105,8 @@ export default {
|
|||||||
|
|
||||||
basicAuth: basicAuthDefaults,
|
basicAuth: basicAuthDefaults,
|
||||||
|
|
||||||
|
psfLiquidityProxy: psfLiquidityProxyDefaults,
|
||||||
|
|
||||||
// Version
|
// Version
|
||||||
version
|
version
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,152 @@
|
|||||||
|
/*
|
||||||
|
Controller for discovery and machine-readable metadata endpoints.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import config from '../../config/index.js'
|
||||||
|
import { getX402Settings } from '../../config/x402.js'
|
||||||
|
import { getDiscoveryDocuments } from '../../discovery/build-documents.js'
|
||||||
|
|
||||||
|
const BCH_MAINNET_CAIP2 = 'bip122:000000000000000000651ef99cb9fcbe'
|
||||||
|
const BCH_NATIVE_ASSET = '0x0000000000000000000000000000000000000001'
|
||||||
|
const X402_TIMEOUT_SECONDS = 60
|
||||||
|
|
||||||
|
class DiscoveryController {
|
||||||
|
constructor (localConfig = {}) {
|
||||||
|
this.getX402Settings = localConfig.getX402Settings || getX402Settings
|
||||||
|
this.getDiscoveryDocuments = localConfig.getDiscoveryDocuments || getDiscoveryDocuments
|
||||||
|
this.apiPrefix = localConfig.apiPrefix || config.apiPrefix
|
||||||
|
|
||||||
|
this.x402Manifest = this.x402Manifest.bind(this)
|
||||||
|
this.openapi = this.openapi.bind(this)
|
||||||
|
this.swagger = this.swagger.bind(this)
|
||||||
|
this.llmsTxt = this.llmsTxt.bind(this)
|
||||||
|
this.agentManifest = this.agentManifest.bind(this)
|
||||||
|
this.respondNotFoundWhenDisabled = this.respondNotFoundWhenDisabled.bind(this)
|
||||||
|
this.sendText = this.sendText.bind(this)
|
||||||
|
}
|
||||||
|
|
||||||
|
respondNotFoundWhenDisabled (res) {
|
||||||
|
const { enabled } = this.getX402Settings()
|
||||||
|
if (enabled) return false
|
||||||
|
|
||||||
|
res.status(404).json({
|
||||||
|
error: 'Not found'
|
||||||
|
})
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @api {get} /.well-known/x402 x402-bch resource discovery
|
||||||
|
* @apiName X402Discovery
|
||||||
|
* @apiGroup Discovery
|
||||||
|
* @apiDescription Returns x402-bch v2 resource and payment requirement metadata.
|
||||||
|
*/
|
||||||
|
x402Manifest (req, res) {
|
||||||
|
if (this.respondNotFoundWhenDisabled(res)) return
|
||||||
|
|
||||||
|
const x402 = this.getX402Settings()
|
||||||
|
const apiPrefix = this.apiPrefix || '/v6'
|
||||||
|
const prefixWithSlash = apiPrefix.startsWith('/') ? apiPrefix : `/${apiPrefix}`
|
||||||
|
|
||||||
|
const payload = {
|
||||||
|
x402Version: 2,
|
||||||
|
network: BCH_MAINNET_CAIP2,
|
||||||
|
facilitator: {
|
||||||
|
url: x402.facilitatorUrl
|
||||||
|
},
|
||||||
|
resources: [
|
||||||
|
{
|
||||||
|
resource: `${prefixWithSlash}/*`,
|
||||||
|
type: 'http',
|
||||||
|
x402Version: 2,
|
||||||
|
accepts: [
|
||||||
|
{
|
||||||
|
scheme: 'utxo',
|
||||||
|
network: BCH_MAINNET_CAIP2,
|
||||||
|
amount: String(x402.priceSat),
|
||||||
|
description: `Access to protected psf-bch-api resources (${x402.priceSat} satoshis)`,
|
||||||
|
mimeType: 'application/json',
|
||||||
|
payTo: x402.serverAddress,
|
||||||
|
maxTimeoutSeconds: X402_TIMEOUT_SECONDS,
|
||||||
|
asset: BCH_NATIVE_ASSET,
|
||||||
|
extra: {}
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
return res.status(200).json(payload)
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @api {get} /openapi.json OpenAPI discovery document
|
||||||
|
* @apiName OpenApiDiscovery
|
||||||
|
* @apiGroup Discovery
|
||||||
|
* @apiDescription Returns an OpenAPI document generated from apiDoc annotations.
|
||||||
|
*/
|
||||||
|
openapi (req, res) {
|
||||||
|
if (this.respondNotFoundWhenDisabled(res)) return
|
||||||
|
|
||||||
|
const docs = this.getDiscoveryDocuments()
|
||||||
|
return res.status(200).json(docs.openapi)
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @api {get} /swagger.json Swagger discovery document
|
||||||
|
* @apiName SwaggerDiscovery
|
||||||
|
* @apiGroup Discovery
|
||||||
|
* @apiDescription Returns a Swagger 2.0 compatibility document generated from apiDoc annotations.
|
||||||
|
*/
|
||||||
|
swagger (req, res) {
|
||||||
|
if (this.respondNotFoundWhenDisabled(res)) return
|
||||||
|
|
||||||
|
const docs = this.getDiscoveryDocuments()
|
||||||
|
return res.status(200).json(docs.swagger)
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @api {get} /llms.txt LLM discovery file
|
||||||
|
* @apiName LlmsDiscovery
|
||||||
|
* @apiGroup Discovery
|
||||||
|
* @apiDescription Returns an llms.txt markdown index for AI tooling discovery.
|
||||||
|
*/
|
||||||
|
llmsTxt (req, res) {
|
||||||
|
if (this.respondNotFoundWhenDisabled(res)) return
|
||||||
|
|
||||||
|
const docs = this.getDiscoveryDocuments()
|
||||||
|
return this.sendText(res, docs.llms)
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @api {get} /.well-known/agent.json Agent manifest
|
||||||
|
* @apiName AgentManifestDiscovery
|
||||||
|
* @apiGroup Discovery
|
||||||
|
* @apiDescription Returns a draft agent manifest describing API capabilities.
|
||||||
|
*/
|
||||||
|
agentManifest (req, res) {
|
||||||
|
if (this.respondNotFoundWhenDisabled(res)) return
|
||||||
|
|
||||||
|
const docs = this.getDiscoveryDocuments()
|
||||||
|
return res.status(200).json(docs.agent)
|
||||||
|
}
|
||||||
|
|
||||||
|
sendText (res, text) {
|
||||||
|
res.status(200)
|
||||||
|
res.setHeader('Content-Type', 'text/plain; charset=utf-8')
|
||||||
|
|
||||||
|
if (typeof res.send === 'function') {
|
||||||
|
return res.send(text)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (typeof res.write === 'function') {
|
||||||
|
res.write(text)
|
||||||
|
}
|
||||||
|
if (typeof res.end === 'function') {
|
||||||
|
res.end()
|
||||||
|
}
|
||||||
|
return res
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export default DiscoveryController
|
||||||
@@ -0,0 +1,30 @@
|
|||||||
|
/*
|
||||||
|
Router for discovery and machine-readable metadata endpoints.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import express from 'express'
|
||||||
|
import DiscoveryController from './controller.js'
|
||||||
|
|
||||||
|
class DiscoveryRouter {
|
||||||
|
constructor (localConfig = {}) {
|
||||||
|
this.controller = localConfig.controller || new DiscoveryController()
|
||||||
|
this.router = express.Router()
|
||||||
|
this.attach = this.attach.bind(this)
|
||||||
|
}
|
||||||
|
|
||||||
|
attach (app) {
|
||||||
|
if (!app) {
|
||||||
|
throw new Error('Must pass app object when attaching DiscoveryRouter.')
|
||||||
|
}
|
||||||
|
|
||||||
|
this.router.get('/.well-known/x402', this.controller.x402Manifest)
|
||||||
|
this.router.get('/openapi.json', this.controller.openapi)
|
||||||
|
this.router.get('/swagger.json', this.controller.swagger)
|
||||||
|
this.router.get('/llms.txt', this.controller.llmsTxt)
|
||||||
|
this.router.get('/.well-known/agent.json', this.controller.agentManifest)
|
||||||
|
|
||||||
|
app.use(this.router)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export default DiscoveryRouter
|
||||||
@@ -87,6 +87,16 @@ class FulcrumRESTController {
|
|||||||
return cashAddr
|
return cashAddr
|
||||||
}
|
}
|
||||||
|
|
||||||
|
_isValidTxid (txid) {
|
||||||
|
return typeof txid === 'string' && /^[a-fA-F0-9]{64}$/.test(txid)
|
||||||
|
}
|
||||||
|
|
||||||
|
_isCommonMissingTxError (err) {
|
||||||
|
return err?.status === 404 &&
|
||||||
|
typeof err?.message === 'string' &&
|
||||||
|
err.message.includes('Transaction not found')
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @api {get} /v6/fulcrum/balance/:address Get balance for a single address
|
* @api {get} /v6/fulcrum/balance/:address Get balance for a single address
|
||||||
* @apiName GetBalance
|
* @apiName GetBalance
|
||||||
@@ -239,10 +249,10 @@ class FulcrumRESTController {
|
|||||||
try {
|
try {
|
||||||
const txid = req.params.txid
|
const txid = req.params.txid
|
||||||
|
|
||||||
if (typeof txid !== 'string') {
|
if (!this._isValidTxid(txid)) {
|
||||||
return res.status(400).json({
|
return res.status(400).json({
|
||||||
success: false,
|
success: false,
|
||||||
error: 'txid must be a string'
|
error: 'txid must be a 64-character hex string'
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -575,9 +585,17 @@ class FulcrumRESTController {
|
|||||||
}
|
}
|
||||||
|
|
||||||
handleError (err, res) {
|
handleError (err, res) {
|
||||||
wlogger.error('Error in FulcrumRESTController:', err)
|
|
||||||
|
|
||||||
const status = err.status || 500
|
const status = err.status || 500
|
||||||
|
const isCommonMissingTxError = this._isCommonMissingTxError(err)
|
||||||
|
|
||||||
|
if (isCommonMissingTxError) {
|
||||||
|
wlogger.info(`Fulcrum transaction not found: ${err.message}`)
|
||||||
|
} else if (status >= 500) {
|
||||||
|
wlogger.error('Error in FulcrumRESTController:', err)
|
||||||
|
} else {
|
||||||
|
wlogger.warn(`Fulcrum client error (${status}): ${err.message}`)
|
||||||
|
}
|
||||||
|
|
||||||
const message = err.message || 'Internal server error'
|
const message = err.message || 'Internal server error'
|
||||||
|
|
||||||
return res.status(status).json({ error: message })
|
return res.status(status).json({ error: message })
|
||||||
|
|||||||
@@ -26,6 +26,7 @@ class PriceRESTController {
|
|||||||
this.root = this.root.bind(this)
|
this.root = this.root.bind(this)
|
||||||
this.getBCHUSD = this.getBCHUSD.bind(this)
|
this.getBCHUSD = this.getBCHUSD.bind(this)
|
||||||
this.getPsffppWritePrice = this.getPsffppWritePrice.bind(this)
|
this.getPsffppWritePrice = this.getPsffppWritePrice.bind(this)
|
||||||
|
this.getPsfLiquidityPrice = this.getPsfLiquidityPrice.bind(this)
|
||||||
this.handleError = this.handleError.bind(this)
|
this.handleError = this.handleError.bind(this)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -83,6 +84,30 @@ class PriceRESTController {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @api {get} /v6/price/psf PSF token liquidity spot price (proxied)
|
||||||
|
* @apiName GetPsfLiquidityPrice
|
||||||
|
* @apiGroup Price
|
||||||
|
* @apiDescription Proxies GET /price from the PSF token liquidity app when
|
||||||
|
* `PSF_LIQUIDITY_PROXY_ENABLED` is true. Returns 503 when the proxy is disabled.
|
||||||
|
*
|
||||||
|
* @apiExample Example usage:
|
||||||
|
* curl -X GET "https://api.fullstack.cash/v6/price/psf" -H "accept: application/json"
|
||||||
|
*
|
||||||
|
* @apiSuccess {Number} usdPerBCH USD price per 1 BCH
|
||||||
|
* @apiSuccess {Number} bchBalance BCH balance (liquidity app)
|
||||||
|
* @apiSuccess {Number} tokenBalance Effective PSF token balance
|
||||||
|
* @apiSuccess {Number} usdPerToken USD price per 1 PSF token
|
||||||
|
*/
|
||||||
|
async getPsfLiquidityPrice (req, res) {
|
||||||
|
try {
|
||||||
|
const payload = await this.priceUseCases.getPsfLiquidityPrice()
|
||||||
|
return res.status(200).json(payload)
|
||||||
|
} catch (err) {
|
||||||
|
return this.handleError(err, res)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
handleError (err, res) {
|
handleError (err, res) {
|
||||||
wlogger.error('Error in PriceRESTController:', err)
|
wlogger.error('Error in PriceRESTController:', err)
|
||||||
|
|
||||||
|
|||||||
@@ -44,6 +44,7 @@ class PriceRouter {
|
|||||||
this.router.get('/', this.priceController.root)
|
this.router.get('/', this.priceController.root)
|
||||||
this.router.get('/bchusd', this.priceController.getBCHUSD)
|
this.router.get('/bchusd', this.priceController.getBCHUSD)
|
||||||
this.router.get('/psffpp', this.priceController.getPsffppWritePrice)
|
this.router.get('/psffpp', this.priceController.getPsffppWritePrice)
|
||||||
|
this.router.get('/psf', this.priceController.getPsfLiquidityPrice)
|
||||||
|
|
||||||
app.use(this.baseUrl, this.router)
|
app.use(this.baseUrl, this.router)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -208,7 +208,14 @@ class SlpRESTController {
|
|||||||
}
|
}
|
||||||
|
|
||||||
handleError (err, res) {
|
handleError (err, res) {
|
||||||
wlogger.error('Error in SlpRESTController:', err)
|
const isCommonMissingTxError =
|
||||||
|
err?.status === 404 &&
|
||||||
|
typeof err?.message === 'string' &&
|
||||||
|
err.message.includes('Key not found in database')
|
||||||
|
|
||||||
|
if (!isCommonMissingTxError) {
|
||||||
|
wlogger.error('Error in SlpRESTController:', err)
|
||||||
|
}
|
||||||
|
|
||||||
const status = err.status || 500
|
const status = err.status || 500
|
||||||
const message = err.message || 'Internal server error'
|
const message = err.message || 'Internal server error'
|
||||||
|
|||||||
@@ -0,0 +1,223 @@
|
|||||||
|
/*
|
||||||
|
Build and cache discovery documents from apiDoc-style annotations.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import { readFileSync, existsSync, readdirSync } from 'fs'
|
||||||
|
import { resolve } from 'path'
|
||||||
|
|
||||||
|
import config from '../config/index.js'
|
||||||
|
import { getX402Settings } from '../config/x402.js'
|
||||||
|
|
||||||
|
const BCH_MAINNET_CAIP2 = 'bip122:000000000000000000651ef99cb9fcbe'
|
||||||
|
const X402_SPEC_VERSION = 2
|
||||||
|
|
||||||
|
let cachedDocs = null
|
||||||
|
|
||||||
|
function parseApiAnnotations () {
|
||||||
|
const srcRoot = resolve(process.cwd(), 'src/controllers/rest-api')
|
||||||
|
const entries = []
|
||||||
|
const files = walkJsFiles(srcRoot)
|
||||||
|
|
||||||
|
for (const file of files) {
|
||||||
|
const text = readFileSync(file, 'utf8')
|
||||||
|
const blocks = text.match(/\/\*\*[\s\S]*?\*\//g) || []
|
||||||
|
|
||||||
|
for (const block of blocks) {
|
||||||
|
const endpoint = parseBlock(block)
|
||||||
|
if (endpoint) entries.push(endpoint)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return entries
|
||||||
|
}
|
||||||
|
|
||||||
|
function parseBlock (block) {
|
||||||
|
const methodMatch = block.match(/@api\s+\{([^}]+)\}\s+(\S+)\s+([^\n\r*]+)/)
|
||||||
|
if (!methodMatch) return null
|
||||||
|
|
||||||
|
const method = methodMatch[1].trim().toUpperCase()
|
||||||
|
const path = methodMatch[2].trim()
|
||||||
|
const summary = methodMatch[3].trim()
|
||||||
|
|
||||||
|
const groupMatch = block.match(/@apiGroup\s+([^\n\r*]+)/)
|
||||||
|
const descriptionMatch = block.match(/@apiDescription\s+([^\n\r*][\s\S]*?)(?=\n\s*\*\s*@api|\n\s*\*\/)/)
|
||||||
|
const apiNameMatch = block.match(/@apiName\s+([^\n\r*]+)/)
|
||||||
|
|
||||||
|
return {
|
||||||
|
method,
|
||||||
|
path,
|
||||||
|
summary,
|
||||||
|
group: groupMatch ? groupMatch[1].trim() : 'General',
|
||||||
|
operationId: apiNameMatch ? apiNameMatch[1].trim() : `${method.toLowerCase()}_${path.replace(/[^\w]/g, '_')}`,
|
||||||
|
description: descriptionMatch
|
||||||
|
? descriptionMatch[1].replace(/\n\s*\*\s?/g, ' ').trim()
|
||||||
|
: summary
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function walkJsFiles (dir) {
|
||||||
|
const output = []
|
||||||
|
|
||||||
|
for (const item of readdirSync(dir, { withFileTypes: true })) {
|
||||||
|
const fullPath = resolve(dir, item.name)
|
||||||
|
if (item.isDirectory()) {
|
||||||
|
output.push(...walkJsFiles(fullPath))
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
if (item.isFile() && fullPath.endsWith('.js')) output.push(fullPath)
|
||||||
|
}
|
||||||
|
|
||||||
|
return output
|
||||||
|
}
|
||||||
|
|
||||||
|
function normalizePaths (endpoints) {
|
||||||
|
const paths = {}
|
||||||
|
|
||||||
|
for (const endpoint of endpoints) {
|
||||||
|
if (!paths[endpoint.path]) paths[endpoint.path] = {}
|
||||||
|
|
||||||
|
const op = {
|
||||||
|
tags: [endpoint.group],
|
||||||
|
summary: endpoint.summary,
|
||||||
|
description: endpoint.description,
|
||||||
|
operationId: endpoint.operationId,
|
||||||
|
responses: {
|
||||||
|
200: {
|
||||||
|
description: 'Successful response'
|
||||||
|
},
|
||||||
|
402: {
|
||||||
|
description: 'Payment required when x402 is enabled'
|
||||||
|
}
|
||||||
|
},
|
||||||
|
'x-payment-model': 'x402-bch-v2'
|
||||||
|
}
|
||||||
|
|
||||||
|
paths[endpoint.path][endpoint.method.toLowerCase()] = op
|
||||||
|
}
|
||||||
|
|
||||||
|
return paths
|
||||||
|
}
|
||||||
|
|
||||||
|
function buildOpenApi (paths) {
|
||||||
|
return {
|
||||||
|
openapi: '3.0.3',
|
||||||
|
info: {
|
||||||
|
title: 'psf-bch-api',
|
||||||
|
version: config.version,
|
||||||
|
description: 'OpenAPI projection generated from apiDoc annotations'
|
||||||
|
},
|
||||||
|
servers: [
|
||||||
|
{
|
||||||
|
url: '/'
|
||||||
|
}
|
||||||
|
],
|
||||||
|
paths
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function buildSwagger (paths) {
|
||||||
|
return {
|
||||||
|
swagger: '2.0',
|
||||||
|
info: {
|
||||||
|
title: 'psf-bch-api',
|
||||||
|
version: config.version,
|
||||||
|
description: 'Swagger projection generated from apiDoc annotations'
|
||||||
|
},
|
||||||
|
basePath: '/',
|
||||||
|
schemes: ['https', 'http'],
|
||||||
|
paths
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function buildLlms (endpoints) {
|
||||||
|
const lines = [
|
||||||
|
'# psf-bch-api',
|
||||||
|
'',
|
||||||
|
'> REST API proxy to Bitcoin Cash infrastructure with optional x402-bch monetized access.',
|
||||||
|
'',
|
||||||
|
'## Discovery',
|
||||||
|
'- [OpenAPI document](/openapi.json): OpenAPI 3 projection generated from apiDoc annotations.',
|
||||||
|
'- [Swagger document](/swagger.json): Swagger 2.0 compatibility projection.',
|
||||||
|
'- [x402 manifest](/.well-known/x402): x402-bch v2 payment requirement discovery.',
|
||||||
|
'- [Agent manifest](/.well-known/agent.json): draft agent capability surface.',
|
||||||
|
'',
|
||||||
|
'## API Groups'
|
||||||
|
]
|
||||||
|
|
||||||
|
const seen = new Set()
|
||||||
|
for (const endpoint of endpoints) {
|
||||||
|
if (seen.has(endpoint.group)) continue
|
||||||
|
seen.add(endpoint.group)
|
||||||
|
lines.push(`- ${endpoint.group}`)
|
||||||
|
}
|
||||||
|
|
||||||
|
lines.push('', '## Optional', '- [Human docs](/): apiDoc HTML documentation root.')
|
||||||
|
return lines.join('\n')
|
||||||
|
}
|
||||||
|
|
||||||
|
function buildAgent (endpoints) {
|
||||||
|
const x402 = getX402Settings()
|
||||||
|
const actions = endpoints.map(endpoint => ({
|
||||||
|
id: endpoint.operationId,
|
||||||
|
description: endpoint.summary,
|
||||||
|
auth_required: true,
|
||||||
|
endpoint: endpoint.path,
|
||||||
|
method: endpoint.method
|
||||||
|
}))
|
||||||
|
|
||||||
|
return {
|
||||||
|
awp_version: '0.1',
|
||||||
|
domain: 'localhost',
|
||||||
|
intent: 'Programmatic BCH blockchain API access',
|
||||||
|
capabilities: {
|
||||||
|
batch_actions: false,
|
||||||
|
streaming: false
|
||||||
|
},
|
||||||
|
auth: {
|
||||||
|
type: 'x402-bch-v2',
|
||||||
|
required_for: actions.map(a => a.id),
|
||||||
|
pricing: {
|
||||||
|
amountSat: String(x402.priceSat),
|
||||||
|
payTo: x402.serverAddress,
|
||||||
|
network: BCH_MAINNET_CAIP2,
|
||||||
|
x402Version: X402_SPEC_VERSION
|
||||||
|
}
|
||||||
|
},
|
||||||
|
actions
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export function buildDiscoveryDocuments () {
|
||||||
|
const endpoints = parseApiAnnotations()
|
||||||
|
const paths = normalizePaths(endpoints)
|
||||||
|
|
||||||
|
return {
|
||||||
|
openapi: buildOpenApi(paths),
|
||||||
|
swagger: buildSwagger(paths),
|
||||||
|
llms: buildLlms(endpoints),
|
||||||
|
agent: buildAgent(endpoints)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export function getDiscoveryDocuments () {
|
||||||
|
if (cachedDocs) return cachedDocs
|
||||||
|
|
||||||
|
const artifactPath = resolve(process.cwd(), 'docs/discovery-artifacts.json')
|
||||||
|
if (existsSync(artifactPath)) {
|
||||||
|
try {
|
||||||
|
cachedDocs = JSON.parse(readFileSync(artifactPath, 'utf8'))
|
||||||
|
return cachedDocs
|
||||||
|
} catch {
|
||||||
|
cachedDocs = buildDiscoveryDocuments()
|
||||||
|
return cachedDocs
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
cachedDocs = buildDiscoveryDocuments()
|
||||||
|
return cachedDocs
|
||||||
|
}
|
||||||
|
|
||||||
|
export function resetDiscoveryDocumentCache () {
|
||||||
|
cachedDocs = null
|
||||||
|
}
|
||||||
@@ -62,14 +62,9 @@ class FulcrumUseCases {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async getTransactionDetails ({ txid }) {
|
async getTransactionDetails ({ txid }) {
|
||||||
try {
|
const response = await this.fulcrum.get(`electrumx/tx/data/${txid}`)
|
||||||
const response = await this.fulcrum.get(`electrumx/tx/data/${txid}`)
|
// console.log(`getTransactionDetails() TXID ${txid}: ${JSON.stringify(response, null, 2)}`)
|
||||||
// console.log(`getTransactionDetails() TXID ${txid}: ${JSON.stringify(response, null, 2)}`)
|
return response
|
||||||
return response
|
|
||||||
} catch (err) {
|
|
||||||
wlogger.error('Error in FulcrumUseCases.getTransactionDetails()', err)
|
|
||||||
throw err
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async getTransactionDetailsBulk ({ txids, verbose }) {
|
async getTransactionDetailsBulk ({ txids, verbose }) {
|
||||||
@@ -146,10 +141,13 @@ class FulcrumUseCases {
|
|||||||
if (response.transactions && Array.isArray(response.transactions)) {
|
if (response.transactions && Array.isArray(response.transactions)) {
|
||||||
// Use bearer token from request if provided, otherwise use the default bchjs instance
|
// Use bearer token from request if provided, otherwise use the default bchjs instance
|
||||||
let bchjsInstance = this.bchjs
|
let bchjsInstance = this.bchjs
|
||||||
console.log('getTransactionsBulk() bearerToken: ', bearerToken)
|
|
||||||
|
// console.log('getTransactionsBulk() bearerToken: ', bearerToken)
|
||||||
if (bearerToken) {
|
if (bearerToken) {
|
||||||
// Create a temporary bchjs instance with the bearer token from the request
|
// Create a temporary bchjs instance with the bearer token from the request
|
||||||
const restURL = process.env.RESTURL || process.env.REST_URL || process.env.LOCAL_RESTURL || config.restURL
|
const restURL = config.restURL
|
||||||
|
|
||||||
|
// console.log('getTransactionsBulk() restURL: ', restURL)
|
||||||
bchjsInstance = new BCHJS({
|
bchjsInstance = new BCHJS({
|
||||||
restURL,
|
restURL,
|
||||||
bearerToken
|
bearerToken
|
||||||
|
|||||||
@@ -28,6 +28,13 @@ class PriceUseCases {
|
|||||||
|
|
||||||
// Allow axios to be injected for testing
|
// Allow axios to be injected for testing
|
||||||
this.axios = localConfig.axios || axios
|
this.axios = localConfig.axios || axios
|
||||||
|
|
||||||
|
this.psfLiquidityPriceKeys = [
|
||||||
|
'usdPerBCH',
|
||||||
|
'bchBalance',
|
||||||
|
'tokenBalance',
|
||||||
|
'usdPerToken'
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -78,6 +85,56 @@ class PriceUseCases {
|
|||||||
throw err
|
throw err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Proxies PSF token liquidity spot price from the token-liquidity app (GET /price).
|
||||||
|
* @returns {Promise<Object>} usdPerBCH, bchBalance, tokenBalance, usdPerToken
|
||||||
|
*/
|
||||||
|
async getPsfLiquidityPrice () {
|
||||||
|
try {
|
||||||
|
const proxy = this.config.psfLiquidityProxy
|
||||||
|
if (!proxy || !proxy.enabled) {
|
||||||
|
const err = new Error('PSF liquidity price proxy is disabled')
|
||||||
|
err.status = 503
|
||||||
|
throw err
|
||||||
|
}
|
||||||
|
|
||||||
|
const baseUrl = String(proxy.baseUrl).replace(/\/$/, '')
|
||||||
|
const fullUrl = `${baseUrl}/price`
|
||||||
|
|
||||||
|
const opt = {
|
||||||
|
method: 'get',
|
||||||
|
url: fullUrl,
|
||||||
|
timeout: 15000
|
||||||
|
}
|
||||||
|
|
||||||
|
const response = await this.axios.request(opt)
|
||||||
|
const data = response.data
|
||||||
|
|
||||||
|
if (
|
||||||
|
!data ||
|
||||||
|
typeof data !== 'object' ||
|
||||||
|
Array.isArray(data) ||
|
||||||
|
!this.psfLiquidityPriceKeys.every(
|
||||||
|
(k) => typeof data[k] === 'number' && !Number.isNaN(data[k])
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
const err = new Error('Invalid response from PSF liquidity price service')
|
||||||
|
err.status = 502
|
||||||
|
throw err
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
usdPerBCH: data.usdPerBCH,
|
||||||
|
bchBalance: data.bchBalance,
|
||||||
|
tokenBalance: data.tokenBalance,
|
||||||
|
usdPerToken: data.usdPerToken
|
||||||
|
}
|
||||||
|
} catch (err) {
|
||||||
|
wlogger.error('Error in PriceUseCases.getPsfLiquidityPrice()', err)
|
||||||
|
throw err
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export default PriceUseCases
|
export default PriceUseCases
|
||||||
|
|||||||
@@ -98,7 +98,14 @@ class SlpUseCases {
|
|||||||
try {
|
try {
|
||||||
return await this.slpIndexer.post('slp/tx/', { txid })
|
return await this.slpIndexer.post('slp/tx/', { txid })
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
wlogger.error('Error in SlpUseCases.getTxid()', err)
|
const isCommonMissingTxError =
|
||||||
|
err?.status === 404 &&
|
||||||
|
typeof err?.message === 'string' &&
|
||||||
|
err.message.includes('Key not found in database')
|
||||||
|
|
||||||
|
if (!isCommonMissingTxError) {
|
||||||
|
wlogger.error('Error in SlpUseCases.getTxid()', err)
|
||||||
|
}
|
||||||
throw err
|
throw err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -26,6 +26,9 @@ describe('#full-node-rpc.js', () => {
|
|||||||
beforeEach(() => {
|
beforeEach(() => {
|
||||||
sandbox = sinon.createSandbox()
|
sandbox = sinon.createSandbox()
|
||||||
mockAxiosInstance = {
|
mockAxiosInstance = {
|
||||||
|
defaults: {
|
||||||
|
baseURL: baseConfig.fullNode.rpcBaseUrl
|
||||||
|
},
|
||||||
post: sandbox.stub()
|
post: sandbox.stub()
|
||||||
}
|
}
|
||||||
axiosCreateStub = sandbox.stub(axios, 'create').returns(mockAxiosInstance)
|
axiosCreateStub = sandbox.stub(axios, 'create').returns(mockAxiosInstance)
|
||||||
|
|||||||
@@ -0,0 +1,106 @@
|
|||||||
|
/*
|
||||||
|
Unit tests for DiscoveryController.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import { assert } from 'chai'
|
||||||
|
|
||||||
|
import DiscoveryController from '../../../src/controllers/discovery/controller.js'
|
||||||
|
import { createMockRequest, createMockResponse } from '../mocks/controller-mocks.js'
|
||||||
|
|
||||||
|
describe('#discovery-controller.js', () => {
|
||||||
|
const makeController = ({ enabled = true } = {}) => {
|
||||||
|
return new DiscoveryController({
|
||||||
|
apiPrefix: '/v6',
|
||||||
|
getX402Settings: () => ({
|
||||||
|
enabled,
|
||||||
|
facilitatorUrl: 'http://localhost:4345/facilitator',
|
||||||
|
serverAddress: 'bitcoincash:qtestaddress',
|
||||||
|
priceSat: 200
|
||||||
|
}),
|
||||||
|
getDiscoveryDocuments: () => ({
|
||||||
|
openapi: { openapi: '3.0.3', paths: { '/v6/price/bchusd': {} } },
|
||||||
|
swagger: { swagger: '2.0', paths: { '/v6/price/bchusd': {} } },
|
||||||
|
llms: '# psf-bch-api',
|
||||||
|
agent: { awp_version: '0.1', actions: [] }
|
||||||
|
})
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
describe('x402 disabled gating', () => {
|
||||||
|
it('should return 404 for all discovery endpoints when x402 disabled', async () => {
|
||||||
|
const uut = makeController({ enabled: false })
|
||||||
|
const req = createMockRequest()
|
||||||
|
|
||||||
|
const handlers = [
|
||||||
|
uut.x402Manifest,
|
||||||
|
uut.openapi,
|
||||||
|
uut.swagger,
|
||||||
|
uut.llmsTxt,
|
||||||
|
uut.agentManifest
|
||||||
|
]
|
||||||
|
|
||||||
|
for (const handler of handlers) {
|
||||||
|
const res = createMockResponse()
|
||||||
|
await handler(req, res)
|
||||||
|
assert.equal(res.statusValue, 404)
|
||||||
|
assert.deepEqual(res.jsonData, { error: 'Not found' })
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
describe('x402 enabled responses', () => {
|
||||||
|
it('should return x402 manifest schema fields', async () => {
|
||||||
|
const uut = makeController({ enabled: true })
|
||||||
|
const req = createMockRequest()
|
||||||
|
const res = createMockResponse()
|
||||||
|
|
||||||
|
await uut.x402Manifest(req, res)
|
||||||
|
|
||||||
|
assert.equal(res.statusValue, 200)
|
||||||
|
assert.equal(res.jsonData.x402Version, 2)
|
||||||
|
assert.isArray(res.jsonData.resources)
|
||||||
|
assert.equal(res.jsonData.resources[0].accepts[0].scheme, 'utxo')
|
||||||
|
assert.equal(res.jsonData.resources[0].accepts[0].amount, '200')
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should return openapi and swagger docs', async () => {
|
||||||
|
const uut = makeController({ enabled: true })
|
||||||
|
const req = createMockRequest()
|
||||||
|
|
||||||
|
const openapiRes = createMockResponse()
|
||||||
|
await uut.openapi(req, openapiRes)
|
||||||
|
assert.equal(openapiRes.statusValue, 200)
|
||||||
|
assert.equal(openapiRes.jsonData.openapi, '3.0.3')
|
||||||
|
|
||||||
|
const swaggerRes = createMockResponse()
|
||||||
|
await uut.swagger(req, swaggerRes)
|
||||||
|
assert.equal(swaggerRes.statusValue, 200)
|
||||||
|
assert.equal(swaggerRes.jsonData.swagger, '2.0')
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should return llms.txt as text/plain', async () => {
|
||||||
|
const uut = makeController({ enabled: true })
|
||||||
|
const req = createMockRequest()
|
||||||
|
const res = createMockResponse()
|
||||||
|
|
||||||
|
await uut.llmsTxt(req, res)
|
||||||
|
|
||||||
|
assert.equal(res.statusValue, 200)
|
||||||
|
assert.equal(res.headers['Content-Type'], 'text/plain; charset=utf-8')
|
||||||
|
assert.equal(res.writeData[0], '# psf-bch-api')
|
||||||
|
assert.isTrue(res.endCalled)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should return agent manifest json', async () => {
|
||||||
|
const uut = makeController({ enabled: true })
|
||||||
|
const req = createMockRequest()
|
||||||
|
const res = createMockResponse()
|
||||||
|
|
||||||
|
await uut.agentManifest(req, res)
|
||||||
|
|
||||||
|
assert.equal(res.statusValue, 200)
|
||||||
|
assert.equal(res.jsonData.awp_version, '0.1')
|
||||||
|
assert.isArray(res.jsonData.actions)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
||||||
@@ -0,0 +1,25 @@
|
|||||||
|
/*
|
||||||
|
Unit tests for discovery document builder.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import { assert } from 'chai'
|
||||||
|
|
||||||
|
import { buildDiscoveryDocuments } from '../../../src/discovery/build-documents.js'
|
||||||
|
|
||||||
|
describe('#discovery-build-documents.js', () => {
|
||||||
|
it('should build openapi and swagger documents with v6 paths', () => {
|
||||||
|
const docs = buildDiscoveryDocuments()
|
||||||
|
|
||||||
|
assert.property(docs, 'openapi')
|
||||||
|
assert.property(docs, 'swagger')
|
||||||
|
assert.property(docs, 'llms')
|
||||||
|
assert.property(docs, 'agent')
|
||||||
|
|
||||||
|
assert.isString(docs.openapi.openapi)
|
||||||
|
assert.equal(docs.swagger.swagger, '2.0')
|
||||||
|
assert.isAbove(Object.keys(docs.openapi.paths).length, 0)
|
||||||
|
|
||||||
|
const hasV6Path = Object.keys(docs.openapi.paths).some(path => path.startsWith('/v6/'))
|
||||||
|
assert.isTrue(hasV6Path)
|
||||||
|
})
|
||||||
|
})
|
||||||
@@ -0,0 +1,43 @@
|
|||||||
|
/*
|
||||||
|
Unit tests for DiscoveryRouter.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import { assert } from 'chai'
|
||||||
|
|
||||||
|
import DiscoveryRouter from '../../../src/controllers/discovery/router.js'
|
||||||
|
|
||||||
|
describe('#discovery-router.js', () => {
|
||||||
|
it('should require app object in attach()', () => {
|
||||||
|
const uut = new DiscoveryRouter()
|
||||||
|
assert.throws(() => uut.attach(), /Must pass app object/)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should register all discovery routes', () => {
|
||||||
|
const calls = []
|
||||||
|
const app = {
|
||||||
|
use: () => {}
|
||||||
|
}
|
||||||
|
|
||||||
|
const mockRouter = {
|
||||||
|
get: (path, handler) => calls.push({ path, handler })
|
||||||
|
}
|
||||||
|
|
||||||
|
const mockController = {
|
||||||
|
x402Manifest: () => {},
|
||||||
|
openapi: () => {},
|
||||||
|
swagger: () => {},
|
||||||
|
llmsTxt: () => {},
|
||||||
|
agentManifest: () => {}
|
||||||
|
}
|
||||||
|
|
||||||
|
const uut = new DiscoveryRouter({ controller: mockController })
|
||||||
|
uut.router = mockRouter
|
||||||
|
uut.attach(app)
|
||||||
|
|
||||||
|
assert.equal(calls.length, 5)
|
||||||
|
assert.deepEqual(
|
||||||
|
calls.map(x => x.path),
|
||||||
|
['/.well-known/x402', '/openapi.json', '/swagger.json', '/llms.txt', '/.well-known/agent.json']
|
||||||
|
)
|
||||||
|
})
|
||||||
|
})
|
||||||
@@ -20,7 +20,13 @@ describe('#price-controller.js', () => {
|
|||||||
mockUseCases = {
|
mockUseCases = {
|
||||||
price: {
|
price: {
|
||||||
getBCHUSD: sandbox.stub().resolves(250.5),
|
getBCHUSD: sandbox.stub().resolves(250.5),
|
||||||
getPsffppWritePrice: sandbox.stub().resolves(0.08335233)
|
getPsffppWritePrice: sandbox.stub().resolves(0.08335233),
|
||||||
|
getPsfLiquidityPrice: sandbox.stub().resolves({
|
||||||
|
usdPerBCH: 483.1,
|
||||||
|
bchBalance: 25.65337297,
|
||||||
|
tokenBalance: 39590.96686314,
|
||||||
|
usdPerToken: 0.50532753
|
||||||
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -113,4 +119,35 @@ describe('#price-controller.js', () => {
|
|||||||
assert.deepEqual(res.jsonData, { error: 'PSFFPP failure' })
|
assert.deepEqual(res.jsonData, { error: 'PSFFPP failure' })
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
|
describe('#getPsfLiquidityPrice()', () => {
|
||||||
|
it('should return PSF liquidity price payload on success', async () => {
|
||||||
|
const req = createMockRequest()
|
||||||
|
const res = createMockResponse()
|
||||||
|
|
||||||
|
await uut.getPsfLiquidityPrice(req, res)
|
||||||
|
|
||||||
|
assert.equal(res.statusValue, 200)
|
||||||
|
assert.deepEqual(res.jsonData, {
|
||||||
|
usdPerBCH: 483.1,
|
||||||
|
bchBalance: 25.65337297,
|
||||||
|
tokenBalance: 39590.96686314,
|
||||||
|
usdPerToken: 0.50532753
|
||||||
|
})
|
||||||
|
assert.isTrue(mockUseCases.price.getPsfLiquidityPrice.calledOnce)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should handle errors via handleError', async () => {
|
||||||
|
const error = new Error('proxy off')
|
||||||
|
error.status = 503
|
||||||
|
mockUseCases.price.getPsfLiquidityPrice.rejects(error)
|
||||||
|
const req = createMockRequest()
|
||||||
|
const res = createMockResponse()
|
||||||
|
|
||||||
|
await uut.getPsfLiquidityPrice(req, res)
|
||||||
|
|
||||||
|
assert.equal(res.statusValue, 503)
|
||||||
|
assert.deepEqual(res.jsonData, { error: 'proxy off' })
|
||||||
|
})
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -83,6 +83,102 @@ describe('#price-use-cases.js', () => {
|
|||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
|
describe('#getPsfLiquidityPrice()', () => {
|
||||||
|
const validBody = {
|
||||||
|
usdPerBCH: 483.1,
|
||||||
|
bchBalance: 25.65337297,
|
||||||
|
tokenBalance: 39590.96686314,
|
||||||
|
usdPerToken: 0.50532753
|
||||||
|
}
|
||||||
|
|
||||||
|
it('should reject with 503 when proxy config is missing', async () => {
|
||||||
|
try {
|
||||||
|
await uut.getPsfLiquidityPrice()
|
||||||
|
assert.fail('Should have thrown an error')
|
||||||
|
} catch (err) {
|
||||||
|
assert.equal(err.status, 503)
|
||||||
|
assert.include(err.message, 'disabled')
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should reject with 503 when proxy is disabled', async () => {
|
||||||
|
mockConfig.psfLiquidityProxy = {
|
||||||
|
enabled: false,
|
||||||
|
baseUrl: 'http://192.168.0.126:5000'
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
await uut.getPsfLiquidityPrice()
|
||||||
|
assert.fail('Should have thrown an error')
|
||||||
|
} catch (err) {
|
||||||
|
assert.equal(err.status, 503)
|
||||||
|
assert.include(err.message, 'disabled')
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should return payload when enabled and upstream returns valid JSON', async () => {
|
||||||
|
mockConfig.psfLiquidityProxy = {
|
||||||
|
enabled: true,
|
||||||
|
baseUrl: 'http://192.168.0.126:5000'
|
||||||
|
}
|
||||||
|
mockAxios.request.resolves({ data: { ...validBody } })
|
||||||
|
|
||||||
|
const result = await uut.getPsfLiquidityPrice()
|
||||||
|
|
||||||
|
assert.deepEqual(result, validBody)
|
||||||
|
assert.isTrue(mockAxios.request.calledOnce)
|
||||||
|
const callArgs = mockAxios.request.getCall(0).args[0]
|
||||||
|
assert.equal(callArgs.method, 'get')
|
||||||
|
assert.equal(callArgs.url, 'http://192.168.0.126:5000/price')
|
||||||
|
assert.equal(callArgs.timeout, 15000)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should normalize base URL trailing slash before /price', async () => {
|
||||||
|
mockConfig.psfLiquidityProxy = {
|
||||||
|
enabled: true,
|
||||||
|
baseUrl: 'http://example.com:5000/'
|
||||||
|
}
|
||||||
|
mockAxios.request.resolves({ data: { ...validBody } })
|
||||||
|
|
||||||
|
await uut.getPsfLiquidityPrice()
|
||||||
|
|
||||||
|
const callArgs = mockAxios.request.getCall(0).args[0]
|
||||||
|
assert.equal(callArgs.url, 'http://example.com:5000/price')
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should reject with 502 when upstream body is invalid', async () => {
|
||||||
|
mockConfig.psfLiquidityProxy = {
|
||||||
|
enabled: true,
|
||||||
|
baseUrl: 'http://192.168.0.126:5000'
|
||||||
|
}
|
||||||
|
mockAxios.request.resolves({ data: { usdPerBCH: 'not-a-number' } })
|
||||||
|
|
||||||
|
try {
|
||||||
|
await uut.getPsfLiquidityPrice()
|
||||||
|
assert.fail('Should have thrown an error')
|
||||||
|
} catch (err) {
|
||||||
|
assert.equal(err.status, 502)
|
||||||
|
assert.include(err.message, 'Invalid response')
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should propagate axios errors', async () => {
|
||||||
|
mockConfig.psfLiquidityProxy = {
|
||||||
|
enabled: true,
|
||||||
|
baseUrl: 'http://192.168.0.126:5000'
|
||||||
|
}
|
||||||
|
const error = new Error('network down')
|
||||||
|
mockAxios.request.rejects(error)
|
||||||
|
|
||||||
|
try {
|
||||||
|
await uut.getPsfLiquidityPrice()
|
||||||
|
assert.fail('Should have thrown an error')
|
||||||
|
} catch (err) {
|
||||||
|
assert.equal(err.message, 'network down')
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
describe('#getPsffppWritePrice()', () => {
|
describe('#getPsffppWritePrice()', () => {
|
||||||
it('should handle errors properly', async () => {
|
it('should handle errors properly', async () => {
|
||||||
// Note: Full unit testing of getPsffppWritePrice is difficult due to dynamic imports
|
// Note: Full unit testing of getPsffppWritePrice is difficult due to dynamic imports
|
||||||
|
|||||||
Reference in New Issue
Block a user