Fine-tune the selected region animation JSON without editing raw data.
+badok
plain text
'); +}); \ No newline at end of file diff --git a/test/player-routes.test.js b/test/player-routes.test.js new file mode 100644 index 0000000..70768c5 --- /dev/null +++ b/test/player-routes.test.js @@ -0,0 +1,396 @@ +const test = require('node:test'); +const assert = require('node:assert/strict'); + +require('../src/common'); + +const { registerPlayerRoutes } = require('../src/player/routes'); + +function createAppAndHandlers() { + const handlers = {}; + const app = { + use() {}, + get(path, ...routeHandlers) { + handlers[path] = function (req, res) { + return new Promise((resolve, reject) => { + const runHandler = (index) => { + const handler = routeHandlers[index]; + if (!handler) { + resolve(); + return; + } + + let nextCalled = false; + const next = function () { + nextCalled = true; + return runHandler(index + 1); + }; + + let result; + try { + result = handler(req, res, next); + } catch (error) { + reject(error); + return; + } + + Promise.resolve(result).then(function (value) { + if (!nextCalled) { + resolve(value); + } + }, reject); + }; + + runHandler(0); + }); + }; + }, + post() {}, + put() {}, + delete() {} + }; + + return { app, handlers }; +} + +function createResponse() { + const headers = {}; + return { + headers, + statusCode: 200, + body: null, + ended: false, + set(name, value) { + headers[name] = value; + return this; + }, + status(code) { + this.statusCode = code; + return this; + }, + json(value) { + this.body = value; + return this; + }, + send(value) { + this.body = value; + return this; + }, + end() { + this.ended = true; + return this; + } + }; +} + +function createPlayerRouteOptions(overrides) { + return Object.assign({ + mediaDir: 'e:\\Projects Git\\pulse-signage\\media', + assetDir: 'e:\\Projects Git\\pulse-signage\\src\\player\\public', + playerRuntime: { broadcastAnnouncementRefresh() {}, snapshotConnections() { return []; } }, + playerPlaylistService: { async buildScreenPlaylist() { return { screen: { slug: 'test2' } }; } }, + rtmpStreamService: { + async getSessionStatus() { return { ready: false, live: false, session: {} }; }, + async getManifestFilePath() { return null; }, + async getSegmentFilePath() { return null; } + }, + playerIdentifier: '' + }, overrides); +} + +test('screen route falls back to offline rendering when playlist build fails', async () => { + const { app, handlers } = createAppAndHandlers(); + const renderCalls = []; + const originalConsoleError = console.error; + console.error = () => {}; + const pool = { + async query() { + return [[{ id: 1 }]]; + }, + async getConnection() { + return { + async beginTransaction() {}, + async query() {}, + async commit() {}, + async rollback() {}, + release() {} + }; + } + }; + const common = { + renderPlayerPage(slug, data) { + renderCalls.push({ slug, data }); + return data ? 'online' : 'offline'; + } + }; + + registerPlayerRoutes(app, { + app, + pool, + common, + ...createPlayerRouteOptions({ + playerPlaylistService: { + async buildScreenPlaylist() { + const error = new Error('db unavailable'); + error.code = 'ECONNREFUSED'; + throw error; + } + } + }) + }); + + const handler = handlers['/screen/:slug']; + assert.equal(typeof handler, 'function'); + + const res = createResponse(); + + try { + await handler({ params: { slug: 'test2' } }, res); + await new Promise((resolve) => setImmediate(resolve)); + + assert.equal(res.headers['X-Player-Offline'], '1'); + assert.equal(res.body, 'offline'); + assert.deepEqual(renderCalls, [ + { slug: 'test2', data: null } + ]); + } finally { + console.error = originalConsoleError; + } +}); + +test('screen route renders the shell when playlist data is missing', async () => { + const { app, handlers } = createAppAndHandlers(); + const renderCalls = []; + const pool = { + async query() { + return [[{ id: 1 }]]; + }, + async getConnection() { + return { + async beginTransaction() {}, + async query() {}, + async commit() {}, + async rollback() {}, + release() {} + }; + } + }; + const common = { + renderPlayerPage(slug, data) { + renderCalls.push({ slug, data }); + return '