Add ability to report if bonob is registered

This commit is contained in:
simojenki
2021-01-30 23:02:58 +11:00
parent 494e36092d
commit ad09a88de8
5 changed files with 170 additions and 46 deletions

View File

@@ -1,20 +1,23 @@
import express, { Express } from "express"; import express, { Express } from "express";
import * as Eta from "eta"; import * as Eta from "eta";
import { Sonos, servicesFrom } from "./sonos"; import { Sonos, servicesFrom, registrationStatus } from "./sonos";
function server(sonos: Sonos): Express { function server(sonos: Sonos): Express {
const app = express(); const app = express();
app.use(express.static("./web/public"));
app.use(express.static("./web/public"));
app.engine("eta", Eta.renderFile); app.engine("eta", Eta.renderFile);
app.set("view engine", "eta"); app.set("view engine", "eta");
app.set("views", "./web/views"); app.set("views", "./web/views");
app.get("/", (_, res) => { app.get("/", (_, res) => {
sonos.devices().then(devices => { sonos.devices().then(devices => {
const services = servicesFrom(devices)
res.render("index", { res.render("index", {
devices, devices,
services: servicesFrom(devices), services,
registration: registrationStatus(services)
}) })
}) })
}); });

View File

@@ -16,6 +16,13 @@ export type Service = {
id: number; id: number;
}; };
export type BonobRegistrationStatus = 'registered' | 'not-registered'
export const BONOB_SERVICE: Service = {
name: "bonob",
id: 245
}
export interface Sonos { export interface Sonos {
devices: () => Promise<Device[]>; devices: () => Promise<Device[]>;
} }
@@ -34,6 +41,14 @@ export const servicesFrom = (devices: Device[]) =>
"name" "name"
); );
export const registrationStatus = (services: Service[]): BonobRegistrationStatus => {
if(services.find(s => s.id == BONOB_SERVICE.id) != undefined) {
return "registered"
} else {
return "not-registered"
}
}
export const asDevice = (sonosDevice: SonosDevice): Promise<Device> => export const asDevice = (sonosDevice: SonosDevice): Promise<Device> =>
sonosDevice.MusicServicesService.ListAndParseAvailableServices().then( sonosDevice.MusicServicesService.ListAndParseAvailableServices().then(
(services) => ({ (services) => ({

View File

@@ -1,6 +1,6 @@
import request from "supertest"; import request from "supertest";
import makeServer from "../src/server"; import makeServer from "../src/server";
import { SONOS_DISABLED, Sonos, Device } from "../src/sonos"; import { SONOS_DISABLED, Sonos, Device, BONOB_SERVICE } from "../src/sonos";
describe("index", () => { describe("index", () => {
describe("when sonos integration is disabled", () => { describe("when sonos integration is disabled", () => {
@@ -16,42 +16,41 @@ describe("index", () => {
}); });
}); });
const device1 : Device = { describe("when there are 2 devices and bonob is not registered", () => {
name: "device1", const device1 : Device = {
group: "group1", name: "device1",
ip: "172.0.0.1", group: "group1",
port: 4301, ip: "172.0.0.1",
services: [ port: 4301,
{ services: [
name: "s1", {
id: 1, name: "s1",
}, id: 1,
{ },
name: "s2", {
id: 2, name: "s2",
}, id: 2,
], },
}; ],
};
const device2: Device = { const device2: Device = {
name: "device2", name: "device2",
group: "group2", group: "group2",
ip: "172.0.0.2", ip: "172.0.0.2",
port: 4302, port: 4302,
services: [ services: [
{ {
name: "s3", name: "s3",
id: 3, id: 3,
}, },
{ {
name: "s4", name: "s4",
id: 4, id: 4,
}, },
], ],
} }
describe("when sonos integration is enabled", () => {
const fakeSonos: Sonos = { const fakeSonos: Sonos = {
devices: () =>Promise.resolve([device1, device2]), devices: () =>Promise.resolve([device1, device2]),
}; };
@@ -70,7 +69,9 @@ describe("index", () => {
/device2\s+\(172.0.0.2:4302\)/ /device2\s+\(172.0.0.2:4302\)/
); );
}); });
});
describe("services", () => {
it("should contain a list of services returned from sonos", async () => { it("should contain a list of services returned from sonos", async () => {
const res = await request(server).get("/").send(); const res = await request(server).get("/").send();
@@ -82,5 +83,69 @@ describe("index", () => {
expect(res.text).toMatch(/s4\s+\(4\)/); expect(res.text).toMatch(/s4\s+\(4\)/);
}); });
}); });
describe("registration status", () => {
it("should be not-registered", async () => {
const res = await request(server).get("/").send();
expect(res.status).toEqual(200);
expect(res.text).toMatch(
/Not registered/
);
})
});
});
describe("when there are 2 devices and bonob is registered", () => {
const device1 : Device = {
name: "device1",
group: "group1",
ip: "172.0.0.1",
port: 4301,
services: [
{
name: "s1",
id: 1,
},
{
name: "s2",
id: 2,
},
BONOB_SERVICE
],
};
const device2: Device = {
name: "device2",
group: "group2",
ip: "172.0.0.2",
port: 4302,
services: [
{
name: "s1",
id: 1,
},
{
name: "s4",
id: 4,
},
BONOB_SERVICE
],
}
const fakeSonos: Sonos = {
devices: () =>Promise.resolve([device1, device2]),
};
const server = makeServer(fakeSonos);
describe("registration status", () => {
it("should be registered", async () => {
const res = await request(server).get("/").send();
expect(res.status).toEqual(200);
expect(res.text).toMatch(
/Registered/
);
})
});
}); });
}); });

View File

@@ -1,12 +1,19 @@
import { SonosManager, SonosDevice } from "@svrooij/sonos"; import { SonosManager, SonosDevice } from "@svrooij/sonos";
import { MusicServicesService } from "@svrooij/sonos/lib/services"; import { MusicServicesService } from "@svrooij/sonos/lib/services";
import { shuffle } from 'underscore'; import { shuffle } from "underscore";
jest.mock("@svrooij/sonos"); jest.mock("@svrooij/sonos");
import { AMAZON_MUSIC, APPLE_MUSIC, AUDIBLE } from "./music_services"; import { AMAZON_MUSIC, APPLE_MUSIC, AUDIBLE } from "./music_services";
import sonos, { SONOS_DISABLED, asDevice, Device, servicesFrom } from "../src/sonos"; import sonos, {
SONOS_DISABLED,
asDevice,
Device,
servicesFrom,
registrationStatus,
BONOB_SERVICE,
} from "../src/sonos";
const mockSonosManagerConstructor = <jest.Mock<SonosManager>>SonosManager; const mockSonosManagerConstructor = <jest.Mock<SonosManager>>SonosManager;
@@ -15,6 +22,28 @@ describe("sonos", () => {
mockSonosManagerConstructor.mockClear(); mockSonosManagerConstructor.mockClear();
}); });
describe("bonobRegistrationStatus", () => {
describe("when bonob is registered", () => {
it("should return 'registered'", () => {
expect(
registrationStatus([
{ id: 1, name: "not bonob" },
BONOB_SERVICE,
{ id: 2, name: "also not bonob" },
])
).toBe("registered");
});
});
describe("when bonob is not registered", () => {
it("should return not-registered", () => {
expect(registrationStatus([{ id: 1, name: "not bonob" }])).toBe(
"not-registered"
);
});
});
});
describe("asDevice", () => { describe("asDevice", () => {
it("should convert", async () => { it("should convert", async () => {
const musicServicesService = { const musicServicesService = {
@@ -71,12 +100,19 @@ describe("sonos", () => {
const service4 = { id: 4, name: "A" }; const service4 = { id: 4, name: "A" };
const d1 = someDevice({ services: shuffle([service1, service2]) }); const d1 = someDevice({ services: shuffle([service1, service2]) });
const d2 = someDevice({ services: shuffle([service1, service2, service3]) }); const d2 = someDevice({
services: shuffle([service1, service2, service3]),
});
const d3 = someDevice({ services: shuffle([service4]) }); const d3 = someDevice({ services: shuffle([service4]) });
const devices: Device[] = [d1, d2, d3]; const devices: Device[] = [d1, d2, d3];
expect(servicesFrom(devices)).toEqual([service4, service2, service3, service1]) expect(servicesFrom(devices)).toEqual([
service4,
service2,
service3,
service1,
]);
}); });
}); });

View File

@@ -2,6 +2,11 @@
<div id="content"> <div id="content">
<h1>bonob</h1> <h1>bonob</h1>
<% if(it.registration == "registered") { %>
<h2 class="registered">Registered</h2>
<% } else if(it.registration == "not-registered") { %>
<h2 class="not-registered">Not registered</h2>
<% } %>
<h2>Devices</h2> <h2>Devices</h2>
<ul> <ul>
<% it.devices.forEach(function(d){ %> <% it.devices.forEach(function(d){ %>