Per-webhook timeout, watched-asset validation, structured error codes, ESLint CI step

.github/workflows/ci.yml

@@ -52,6 +52,10 @@ jobs:
             - name: Lint OpenAPI spec
               run: npx @redocly/cli lint openapi.yaml
 
+            - name: Lint source (ESLint)
+              run: npx eslint .
+              continue-on-error: true
+
             - name: Run tests
               run: npm test
 

eslint.config.js

@@ -0,0 +1,16 @@
+'use strict';
+
+// Minimal ESLint flat config (Issue #231) — a starting point for consistent
+// code style, not a full ruleset. Run with: npx eslint .
+module.exports = [
+  {
+    files: ['src/**/*.js'],
+    languageOptions: {
+      ecmaVersion: 2022,
+      sourceType: 'commonjs',
+    },
+    rules: {
+      'no-unused-vars': 'warn',
+    },
+  },
+];

src/middleware/errorHandler.js

@@ -25,7 +25,8 @@ function errorHandler(err, req, res, _next) {
     message = 'Request body is too large';
   } else if (err.status || err.statusCode) {
     status = err.status || err.statusCode;
-    code = 'FORBIDDEN';
+    const STATUS_CODES = { 400: 'VALIDATION_ERROR', 401: 'UNAUTHORIZED', 403: 'FORBIDDEN', 404: 'NOT_FOUND', 429: 'RATE_LIMITED' };
+    code = STATUS_CODES[status] || 'INTERNAL_ERROR';
     message = err.message || 'Request rejected';
   }
 

src/services/webhookDispatcher.js

@@ -89,10 +89,10 @@ function withDeliveryTrace(traceId, fn) {
   return requestContext.run({ requestId: traceId }, fn);
 }
 
-async function postOnce(url, headers, body) {
+async function postOnce(url, headers, body, timeoutMs) {
   return axios.post(url, body, {
     headers,
-    timeout: config.webhooks.timeoutMs,
+    timeout: timeoutMs ?? config.webhooks.timeoutMs,
     transformRequest: [(data) => data],
     validateStatus: () => true,
   });
@@ -136,7 +136,7 @@ async function attempt(deliveryId) {
     let networkError = null;
 
     try {
-      const res = await postOnce(webhook.url, headers, body);
+      const res = await postOnce(webhook.url, headers, body, webhook.timeoutMs);
       responseStatus = res.status;
     } catch (err) {
       networkError = err.message || 'network error';

src/validation/schemas.js

@@ -2,6 +2,7 @@
 
 const { z } = require('zod');
 const webhookEvents = require('../services/webhookEvents');
+const config = require('../config');
 
 const stellarPublicKeySchema = z
   .string()
@@ -99,7 +100,10 @@ const keyCreateBodySchema = z.object({
 });
 
 const alertCreateBodySchema = z.object({
-  asset: assetCodeSchema,
+  asset: assetCodeSchema.refine(
+    (code) => config.watchedAssets.length === 0 || config.watchedAssets.includes(code),
+    { message: 'Asset code is not in the list of watched Stellar assets' },
+  ),
   type: z.enum(['above', 'below', 'change_pct']),
   threshold_usd: z.number().positive(),
   webhook_url: httpUrlSchema,