martin/doorman
1
0
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects Releases Wiki Activity

change homeassistant container to use new ddb

Browse Source
This commit is contained in:
Martin Dimitrov 2025-05-31 21:47:52 -07:00
parent ca2cd5286f
commit aeefd6f5d3
1 changed files with 14 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
packages/doorman-homeassistant/src/index.ts
View File

@ -1,8 +1,10 @@
import { serve } from "bun"; import { serve } from "bun";
import { Hono } from "hono"; import { Hono } from "hono";
import { prettyJSON } from "hono/pretty-json"; import { prettyJSON } from "hono/pretty-json";
import { createDDBClient, getDoorConfigCommand, getLockStatusCommand, isLockOpen } from "../../doorman-api/src/utils/ddb"; import { createDynaBridgeClient } from "../../doorman-api/src/utils/ddb";
import { DoorStatus } from "../../doorman-api/src/types/DoorStatus"; import { DoorStatus } from "../../doorman-api/src/types/DoorStatus";
import { getLockStatusID, isLockOpen } from "../../doorman-api/src/schema/LockStatus";
import { getDoorConfigID } from "../../doorman-api/src/schema/DoorConfig";
const app = new Hono(); const app = new Hono();
@ -15,28 +17,23 @@ app.get("/api/door/info", async (c) => {
err: "Must specify a door", err: "Must specify a door",
}, 400); }, 400);
} }
const db = createDynaBridgeClient(Bun.env as any);
const client = createDDBClient(Bun.env as any); const config = await db.entities.doorConfig.findById(getDoorConfigID(door));
const config = await client.send(getDoorConfigCommand(door));
if (!config.Item) { if (!config) {
return c.json({ return c.json({
err: "This buzzer is not registered properly", err: "This buzzer is not registered properly",
}, 404); }, 404);
} }
return await client.send(getLockStatusCommand(door))
.then(async (lock) => { const lock = await db.entities.lockStatus.findById(getLockStatusID(door));
const status = isLockOpen(lock) ? DoorStatus.OPEN: "CLOSED"; const status = isLockOpen(lock) ? DoorStatus.OPEN: "CLOSED";
return c.json({ return c.json({
id: door, id: door,
status, status,
}); });
}).catch((e) => {
console.log(e);
return c.json({
err: e,
}, 500);
});
}); });
serve({ serve({