Compare commits

...

69 Commits

Author SHA1 Message Date
Darius
cd95b63174 1.7.1 2026-02-06 11:14:00 +01:00
Darius
17e6b75ec5 WebSocket improt 2026-02-06 11:13:55 +01:00
Darius
bb8014ccf3 1.7.0 2026-02-06 11:08:32 +01:00
Darius
ad9cf36e98 sse => ws 2026-02-06 11:08:26 +01:00
Darius
60bcd23f5b 1.6.4 2026-02-05 22:51:24 +01:00
Darius
c674d0fa72 1.6.3 2026-02-05 22:50:07 +01:00
Darius
c072f52a1a add seconds to API 2026-02-05 22:50:02 +01:00
Darius
ceadd4e5a2 1.6.2 2026-02-05 22:22:05 +01:00
Darius
b32006cf10 dont actually need that 2026-02-05 22:21:57 +01:00
Darius
0ab6194b43 1.6.1 2026-02-05 22:16:12 +01:00
Darius
46f359bb1e add LastPoll Type 2026-02-05 22:16:06 +01:00
Darius
9b852dc40c 1.6.0 2026-02-05 22:05:43 +01:00
Darius
a6d837f953 make clients of sse service observable 2026-02-05 22:05:35 +01:00
Darius
921882054d 1.5.5 2026-02-05 04:32:04 +01:00
Darius
cdd2fcb59e set => map 2026-02-05 04:31:54 +01:00
Darius
8daeed6b5f 1.5.4 2026-02-05 01:00:05 +01:00
Darius
6d05233a6e fix logger import 2026-02-05 00:59:56 +01:00
Darius
3dd61ab4e8 1.5.3 2026-02-05 00:47:31 +01:00
Darius
b7ea7bc552 dont need volume 2026-02-05 00:47:23 +01:00
Darius
d23c89c3c9 1.5.2 2026-02-05 00:31:13 +01:00
Darius
fd766a822c add homepage information type pt2 2026-02-05 00:31:08 +01:00
Darius
bf580c8a84 1.5.1 2026-02-05 00:27:11 +01:00
Darius
12fc98c925 add homepage information type 2026-02-05 00:26:47 +01:00
Darius
3b7ef0f3ee 1.5.0 2026-02-04 21:52:35 +01:00
Darius
ada7268062 sse typing 2026-02-04 21:52:32 +01:00
Darius
b55e1dd0a6 1.4.1 2026-02-03 22:20:11 +01:00
Darius
49f04ef82f dont make it more complicated than needed 2026-02-03 22:20:01 +01:00
Darius
862401fa9b forgot to build oops 2026-01-28 22:53:57 +01:00
Darius
20e94a7e0e 1.4.0 2026-01-28 22:51:15 +01:00
Darius
7f2b8ce5aa update tidal objects 2026-01-28 22:49:54 +01:00
Darius
14df9ae2cd 1.3.0 2025-11-24 01:37:03 +01:00
Darius
36f2535cf8 add timezone to timespan 2025-11-24 01:36:55 +01:00
Darius
3dfa3007bf 1.2.6 2025-11-23 02:52:00 +01:00
Darius
e80ff5fece Generic Commit; Most likely a fix or small feature 2025-11-23 02:51:54 +01:00
Darius
694d88bb72 1.2.5 2025-11-23 02:49:14 +01:00
Darius
9569477a26 Generic Commit; Most likely a fix or small feature 2025-11-23 02:49:06 +01:00
Darius
6574f8f672 1.2.4 2025-11-23 02:45:59 +01:00
Darius
ea6605f9dc Generic Commit; Most likely a fix or small feature 2025-11-23 02:45:54 +01:00
Darius
953afcbc84 1.2.3 2025-11-21 17:36:06 +01:00
Darius
1d4ade717a Generic Commit; Most likely a fix or small feature 2025-11-21 17:35:58 +01:00
Darius
25ff0b9903 1.2.2 2025-11-21 17:34:20 +01:00
Darius
2f8f3ea017 Generic Commit; Most likely a fix or small feature 2025-11-21 17:34:15 +01:00
Darius
c3f0fd84ac 1.2.1 2025-11-21 17:19:56 +01:00
Darius
64eb6fbf4e Generic Commit; Most likely a fix or small feature 2025-11-21 17:19:50 +01:00
Darius
50c951e0d3 1.2.0 2025-11-21 17:13:31 +01:00
Darius
6086c6dbcc Generic Commit; Most likely a fix or small feature 2025-11-21 17:13:20 +01:00
Darius
30b5c74c06 1.1.5 2025-11-21 17:11:18 +01:00
Darius
a835f220e2 Generic Commit; Most likely a fix or small feature 2025-11-21 17:11:14 +01:00
Darius
a35a3e7ecb 1.1.4 2025-11-21 16:24:14 +01:00
Darius
9b61909eab Generic Commit; Most likely a fix or small feature 2025-11-21 16:24:10 +01:00
Darius
a3689f4cd2 Generic Commit; Most likely a fix or small feature 2025-11-21 16:24:04 +01:00
Darius
bf7f3ee77c 1.1.3 2025-11-21 16:22:20 +01:00
Darius
d0e9f28c8c Generic Commit; Most likely a fix or small feature 2025-11-21 16:22:14 +01:00
Darius
5f9b97ca54 1.1.2 2025-11-21 16:07:03 +01:00
Darius
0103f73c39 Generic Commit; Most likely a fix or small feature 2025-11-21 16:07:01 +01:00
Darius
39d45c80b9 1.1.1 2025-11-21 15:57:56 +01:00
Darius
c415912a0a Generic Commit; Most likely a fix or small feature 2025-11-21 15:57:48 +01:00
Darius
868bf0dc53 1.1.0 2025-11-21 15:49:29 +01:00
Darius
94c10f13e9 add fastify service result type 2025-11-21 15:49:24 +01:00
Darius
9269eaaa88 1.0.14 2025-11-18 21:55:39 +01:00
Darius
07b067279e clean dist 2025-11-18 21:55:34 +01:00
Darius
7659fa0cf4 1.0.13 2025-11-18 21:46:54 +01:00
Darius
314ef5c2ff change to ES2022 2025-11-18 21:46:48 +01:00
Darius
9b02c09677 1.0.12 2025-11-18 19:35:04 +01:00
Darius
45f4ca4d63 Generic Commit; Most likely a fix or small feature 2025-11-18 19:35:01 +01:00
Darius
1aade62ddb 1.0.11 2025-11-18 01:16:00 +01:00
Darius
31a02625e8 Generic Commit; Most likely a fix or small feature 2025-11-18 01:15:56 +01:00
Darius
16c262f2c4 1.0.10 2025-11-18 01:10:22 +01:00
Darius
dfa93723ef Generic Commit; Most likely a fix or small feature 2025-11-18 01:10:18 +01:00
41 changed files with 508 additions and 300 deletions

22
dist/fastify.d.ts vendored Normal file
View File

@@ -0,0 +1,22 @@
import type { AxiosInstance } from "axios";
export type ServiceResult<T = unknown> = {
result: T;
successful: boolean;
};
export declare class API_Error {
error: string;
constructor(error: string);
}
export declare abstract class BaseClient {
private axiosInstance;
constructor(axiosInstance: AxiosInstance);
getAxios(): AxiosInstance;
}
export declare abstract class BaseService<T> {
private client;
constructor(client: T);
getClient(): T;
getSuccessfulResult<R = unknown>(result: R): ServiceResult<R>;
getErrorResult(error: string): ServiceResult<string>;
}
//# sourceMappingURL=fastify.d.ts.map

1
dist/fastify.d.ts.map vendored Normal file
View File

@@ -0,0 +1 @@
{"version":3,"file":"fastify.d.ts","sourceRoot":"","sources":["../src/fastify.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,OAAO,CAAC;AAE3C,MAAM,MAAM,aAAa,CAAC,CAAC,GAAG,OAAO,IAAI;IACvC,MAAM,EAAE,CAAC,CAAC;IACV,UAAU,EAAE,OAAO,CAAC;CACrB,CAAC;AAEF,qBAAa,SAAS;IACD,KAAK,EAAE,MAAM;gBAAb,KAAK,EAAE,MAAM;CACjC;AAED,8BAAsB,UAAU;IAC9B,OAAO,CAAC,aAAa,CAAgB;gBAEzB,aAAa,EAAE,aAAa;IAIxC,QAAQ,IAAI,aAAa;CAG1B;AAED,8BAAsB,WAAW,CAAC,CAAC;IACjC,OAAO,CAAC,MAAM,CAAI;gBAEN,MAAM,EAAE,CAAC;IAIrB,SAAS,IAAI,CAAC;IAId,mBAAmB,CAAC,CAAC,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC,GAAG,aAAa,CAAC,CAAC,CAAC;IAO7D,cAAc,CAAC,KAAK,EAAE,MAAM,GAAG,aAAa,CAAC,MAAM,CAAC;CAMrD"}

36
dist/fastify.js vendored Normal file
View File

@@ -0,0 +1,36 @@
export class API_Error {
error;
constructor(error) {
this.error = error;
}
}
export class BaseClient {
axiosInstance;
constructor(axiosInstance) {
this.axiosInstance = axiosInstance;
}
getAxios() {
return this.axiosInstance;
}
}
export class BaseService {
client;
constructor(client) {
this.client = client;
}
getClient() {
return this.client;
}
getSuccessfulResult(result) {
return {
result,
successful: true,
};
}
getErrorResult(error) {
return {
result: error,
successful: false,
};
}
}

View File

@@ -1,3 +1,4 @@
import type { TimeBetween } from "./timehelper";
export type HomeAssistantEntity = {
entity_id: string;
state: string;
@@ -19,13 +20,14 @@ export type HomeAssistantEntity = {
};
export interface HomeAssistantDeskPositionResult {
raw: HomeAssistantEntity;
asBoolean: boolean;
asText: () => string;
standingTime: number;
as_boolean: boolean;
as_text: () => string;
last_changed: TimeBetween;
}
export type API_HA_DeskPosition = {
position: string;
isStanding: boolean;
standingTime: string;
is_standing: boolean;
last_changed: string;
last_changed_seconds: number;
};
//# sourceMappingURL=homeassistant.d.ts.map

View File

@@ -1 +1 @@
{"version":3,"file":"homeassistant.d.ts","sourceRoot":"","sources":["../src/homeassistant.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,mBAAmB,GAAG;IAChC,SAAS,EAAE,MAAM,CAAC;IAClB,KAAK,EAAE,MAAM,CAAC;IACd,UAAU,EAAE;QACV,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,mBAAmB,CAAC,EAAE,MAAM,CAAC;QAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;QACd,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAC;KACxB,CAAC;IACF,YAAY,EAAE,MAAM,CAAC;IACrB,aAAa,EAAE,MAAM,CAAC;IACtB,YAAY,EAAE,MAAM,CAAC;IACrB,OAAO,EAAE;QACP,EAAE,EAAE,MAAM,CAAC;QACX,SAAS,EAAE,MAAM,GAAG,IAAI,CAAC;QACzB,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;KACxB,CAAC;CACH,CAAC;AAEF,MAAM,WAAW,+BAA+B;IAC9C,GAAG,EAAE,mBAAmB,CAAC;IACzB,SAAS,EAAE,OAAO,CAAC;IACnB,MAAM,EAAE,MAAM,MAAM,CAAC;IACrB,YAAY,EAAE,MAAM,CAAC;CACtB;AAED,MAAM,MAAM,mBAAmB,GAAG;IAChC,QAAQ,EAAE,MAAM,CAAC;IACjB,UAAU,EAAE,OAAO,CAAC;IACpB,YAAY,EAAE,MAAM,CAAC;CACtB,CAAC"}
{"version":3,"file":"homeassistant.d.ts","sourceRoot":"","sources":["../src/homeassistant.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,cAAc,CAAC;AAEhD,MAAM,MAAM,mBAAmB,GAAG;IACjC,SAAS,EAAE,MAAM,CAAC;IAClB,KAAK,EAAE,MAAM,CAAC;IACd,UAAU,EAAE;QACX,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,mBAAmB,CAAC,EAAE,MAAM,CAAC;QAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;QACd,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAC;KACvB,CAAC;IACF,YAAY,EAAE,MAAM,CAAC;IACrB,aAAa,EAAE,MAAM,CAAC;IACtB,YAAY,EAAE,MAAM,CAAC;IACrB,OAAO,EAAE;QACR,EAAE,EAAE,MAAM,CAAC;QACX,SAAS,EAAE,MAAM,GAAG,IAAI,CAAC;QACzB,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;KACvB,CAAC;CACF,CAAC;AAEF,MAAM,WAAW,+BAA+B;IAC/C,GAAG,EAAE,mBAAmB,CAAC;IACzB,UAAU,EAAE,OAAO,CAAC;IACpB,OAAO,EAAE,MAAM,MAAM,CAAC;IACtB,YAAY,EAAE,WAAW,CAAC;CAC1B;AAED,MAAM,MAAM,mBAAmB,GAAG;IACjC,QAAQ,EAAE,MAAM,CAAC;IACjB,WAAW,EAAE,OAAO,CAAC;IACrB,YAAY,EAAE,MAAM,CAAC;IACrB,oBAAoB,EAAE,MAAM,CAAC;CAC7B,CAAC"}

View File

@@ -1,2 +1 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
export {};

8
dist/homepage.d.ts vendored Normal file
View File

@@ -0,0 +1,8 @@
import { type API_HA_DeskPosition } from "./homeassistant";
import { type TidalGetCurrent } from "./tidal";
export type FullInformation = {
ha_desk_position: API_HA_DeskPosition | null;
ha_temp: string | null;
tidal_current: TidalGetCurrent | null;
};
//# sourceMappingURL=homepage.d.ts.map

1
dist/homepage.d.ts.map vendored Normal file
View File

@@ -0,0 +1 @@
{"version":3,"file":"homepage.d.ts","sourceRoot":"","sources":["../src/homepage.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,KAAK,mBAAmB,EAAE,MAAM,iBAAiB,CAAC;AAC3D,OAAO,EAAE,KAAK,eAAe,EAAE,MAAM,SAAS,CAAC;AAE/C,MAAM,MAAM,eAAe,GAAG;IAC7B,gBAAgB,EAAE,mBAAmB,GAAG,IAAI,CAAC;IAC7C,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;IACvB,aAAa,EAAE,eAAe,GAAG,IAAI,CAAC;CACtC,CAAC"}

1
dist/homepage.js vendored Normal file
View File

@@ -0,0 +1 @@
export {};

11
dist/index.d.ts vendored
View File

@@ -1,5 +1,8 @@
export * from "./homeassistant";
export * as Logger from "./logger";
export * from "./tidal";
export * as TimeHelper from "./timehelper";
export * from "./fastify.js";
export * from "./homeassistant.js";
export * from "./homepage.js";
export * from "./logger.js";
export * from "./ws.js";
export * from "./tidal.js";
export * from "./timehelper.js";
//# sourceMappingURL=index.d.ts.map

2
dist/index.d.ts.map vendored
View File

@@ -1 +1 @@
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,iBAAiB,CAAC;AAChC,OAAO,KAAK,MAAM,MAAM,UAAU,CAAC;AACnC,cAAc,SAAS,CAAC;AACxB,OAAO,KAAK,UAAU,MAAM,cAAc,CAAC"}
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,cAAc,CAAC;AAC7B,cAAc,oBAAoB,CAAC;AACnC,cAAc,eAAe,CAAC;AAC9B,cAAc,aAAa,CAAC;AAC5B,cAAc,SAAS,CAAC;AACxB,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC"}

50
dist/index.js vendored
View File

@@ -1,43 +1,7 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __exportStar = (this && this.__exportStar) || function(m, exports) {
for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
};
var __importStar = (this && this.__importStar) || (function () {
var ownKeys = function(o) {
ownKeys = Object.getOwnPropertyNames || function (o) {
var ar = [];
for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
return ar;
};
return ownKeys(o);
};
return function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
__setModuleDefault(result, mod);
return result;
};
})();
Object.defineProperty(exports, "__esModule", { value: true });
exports.TimeHelper = exports.Logger = void 0;
__exportStar(require("./homeassistant"), exports);
exports.Logger = __importStar(require("./logger"));
__exportStar(require("./tidal"), exports);
exports.TimeHelper = __importStar(require("./timehelper"));
export * from "./fastify.js";
export * from "./homeassistant.js";
export * from "./homepage.js";
export * from "./logger.js";
export * from "./ws.js";
export * from "./tidal.js";
export * from "./timehelper.js";

34
dist/logger.js vendored
View File

@@ -1,29 +1,19 @@
"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.logError = logError;
exports.logWarning = logWarning;
exports.logSuccess = logSuccess;
exports.logInfo = logInfo;
exports.printNetworkError = printNetworkError;
const axios_1 = __importDefault(require("axios"));
const chalk_1 = __importDefault(require("chalk"));
function logError(...args) {
console.error(chalk_1.default.red("ERROR:"), ...args);
import axios from "axios";
import chalk from "chalk";
export function logError(...args) {
console.error(chalk.red("ERROR:"), ...args);
}
function logWarning(...args) {
console.warn(chalk_1.default.yellow("WARNING:"), ...args);
export function logWarning(...args) {
console.warn(chalk.yellow("WARNING:"), ...args);
}
function logSuccess(...args) {
console.info(chalk_1.default.green("SUCCESS:"), ...args);
export function logSuccess(...args) {
console.info(chalk.green("SUCCESS:"), ...args);
}
function logInfo(...args) {
console.info(chalk_1.default.cyan("INFO:"), ...args);
export function logInfo(...args) {
console.info(chalk.cyan("INFO:"), ...args);
}
function printNetworkError(error) {
if (axios_1.default.isAxiosError(error)) {
export function printNetworkError(error) {
if (axios.isAxiosError(error)) {
logError("Axios error details:", {
message: error.message,
status: error.response?.status,

18
dist/tidal.d.ts vendored
View File

@@ -1,14 +1,26 @@
export type TidalSong = {
export type TidalGetCurrent = {
title: string;
artists: string;
artistsArray: string[];
album: string;
playingFrom: string;
status: "playing" | "paused";
url: string;
current: string;
currentInSeconds: number;
duration: string;
};
export type TidalVolume = {
durationInSeconds: number;
image: string;
icon: string;
localAlbumArt: string;
favorite: boolean;
trackId: string;
volume: number;
player: {
status: "playing" | "paused";
shuffle: boolean;
repeat: "all" | "single" | "none";
};
artist: string;
};
//# sourceMappingURL=tidal.d.ts.map

2
dist/tidal.d.ts.map vendored
View File

@@ -1 +1 @@
{"version":3,"file":"tidal.d.ts","sourceRoot":"","sources":["../src/tidal.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,SAAS,GAAG;IACtB,KAAK,EAAE,MAAM,CAAC;IACd,OAAO,EAAE,MAAM,CAAC;IAChB,KAAK,EAAE,MAAM,CAAC;IACd,WAAW,EAAE,MAAM,CAAC;IACpB,MAAM,EAAE,SAAS,GAAG,QAAQ,CAAC;IAC7B,GAAG,EAAE,MAAM,CAAC;IACZ,OAAO,EAAE,MAAM,CAAC;IAChB,QAAQ,EAAE,MAAM,CAAC;CAClB,CAAC;AAEF,MAAM,MAAM,WAAW,GAAG;IACxB,MAAM,EAAE,MAAM,CAAC;CAChB,CAAC"}
{"version":3,"file":"tidal.d.ts","sourceRoot":"","sources":["../src/tidal.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,eAAe,GAAG;IAC7B,KAAK,EAAE,MAAM,CAAC;IACd,OAAO,EAAE,MAAM,CAAC;IAChB,YAAY,EAAE,MAAM,EAAE,CAAC;IACvB,KAAK,EAAE,MAAM,CAAC;IACd,WAAW,EAAE,MAAM,CAAC;IACpB,MAAM,EAAE,SAAS,GAAG,QAAQ,CAAC;IAC7B,GAAG,EAAE,MAAM,CAAC;IACZ,OAAO,EAAE,MAAM,CAAC;IAChB,gBAAgB,EAAE,MAAM,CAAC;IACzB,QAAQ,EAAE,MAAM,CAAC;IACjB,iBAAiB,EAAE,MAAM,CAAC;IAC1B,KAAK,EAAE,MAAM,CAAC;IACd,IAAI,EAAE,MAAM,CAAC;IACb,aAAa,EAAE,MAAM,CAAC;IACtB,QAAQ,EAAE,OAAO,CAAC;IAClB,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,EAAE,MAAM,CAAC;IACf,MAAM,EAAE;QACP,MAAM,EAAE,SAAS,GAAG,QAAQ,CAAC;QAC7B,OAAO,EAAE,OAAO,CAAC;QACjB,MAAM,EAAE,KAAK,GAAG,QAAQ,GAAG,MAAM,CAAC;KAClC,CAAC;IACF,MAAM,EAAE,MAAM,CAAC;CACf,CAAC"}

3
dist/tidal.js vendored
View File

@@ -1,2 +1 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
export {};

View File

@@ -1,7 +1,8 @@
export declare class TimeSpan {
private start;
private end;
constructor(timeSpanStr: string);
private timeZone;
constructor(timeSpanStr: string, timeZone: string);
private parseTime;
contains(timestamp?: number): boolean;
}

View File

@@ -1 +1 @@
{"version":3,"file":"timehelper.d.ts","sourceRoot":"","sources":["../src/timehelper.ts"],"names":[],"mappings":"AAAA,qBAAa,QAAQ;IACnB,OAAO,CAAC,KAAK,CAAqC;IAClD,OAAO,CAAC,GAAG,CAAqC;gBAEpC,WAAW,EAAE,MAAM;IAM/B,OAAO,CAAC,SAAS;IAKjB,QAAQ,CAAC,SAAS,GAAE,MAAmB,GAAG,OAAO;CAgBlD;AAED,MAAM,WAAW,WAAW;IAC1B,OAAO,EAAE,MAAM,CAAC;IAChB,UAAU,EAAE,CAAC,cAAc,CAAC,EAAE,OAAO,KAAK,MAAM,CAAC;CAClD;AAED,wBAAgB,uBAAuB,CACrC,KAAK,EAAE,MAAM,EACb,GAAG,EAAE,MAAM,GACV,WAAW,CAOb;AAED,wBAAgB,iBAAiB,CAC/B,IAAI,EAAE,MAAM,EACZ,cAAc,GAAE,OAAe,GAC9B,MAAM,CAmBR"}
{"version":3,"file":"timehelper.d.ts","sourceRoot":"","sources":["../src/timehelper.ts"],"names":[],"mappings":"AAAA,qBAAa,QAAQ;IACnB,OAAO,CAAC,KAAK,CAAqC;IAClD,OAAO,CAAC,GAAG,CAAqC;IAChD,OAAO,CAAC,QAAQ,CAAC;gBAEL,WAAW,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM;IAOjD,OAAO,CAAC,SAAS;IAKjB,QAAQ,CAAC,SAAS,GAAE,MAAmB,GAAG,OAAO;CAqBlD;AAED,MAAM,WAAW,WAAW;IAC1B,OAAO,EAAE,MAAM,CAAC;IAChB,UAAU,EAAE,CAAC,cAAc,CAAC,EAAE,OAAO,KAAK,MAAM,CAAC;CAClD;AAED,wBAAgB,uBAAuB,CACrC,KAAK,EAAE,MAAM,EACb,GAAG,EAAE,MAAM,GACV,WAAW,CAOb;AAED,wBAAgB,iBAAiB,CAC/B,IAAI,EAAE,MAAM,EACZ,cAAc,GAAE,OAAe,GAC9B,MAAM,CAmBR"}

27
dist/timehelper.js vendored
View File

@@ -1,13 +1,12 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.TimeSpan = void 0;
exports.calculateSecondsBetween = calculateSecondsBetween;
exports.secondsToReadable = secondsToReadable;
class TimeSpan {
constructor(timeSpanStr) {
export class TimeSpan {
start;
end;
timeZone;
constructor(timeSpanStr, timeZone) {
const [startStr, endStr] = timeSpanStr.split("-");
this.start = this.parseTime(startStr);
this.end = this.parseTime(endStr);
this.timeZone = timeZone;
}
parseTime(timeStr) {
const [hours, minutes] = timeStr.split(":").map(Number);
@@ -15,8 +14,13 @@ class TimeSpan {
}
contains(timestamp = Date.now()) {
const date = new Date(timestamp);
const hours = date.getHours();
const minutes = date.getMinutes();
const berlinTimeStr = date.toLocaleString("de-DE", {
timeZone: this.timeZone, // "Europe/Berlin"
hour12: false,
hour: "2-digit",
minute: "2-digit",
});
const [hours, minutes] = berlinTimeStr.split(":").map(Number);
const currentMinutes = hours * 60 + minutes;
const startMinutes = this.start.hours * 60 + this.start.minutes;
const endMinutes = this.end.hours * 60 + this.end.minutes;
@@ -28,15 +32,14 @@ class TimeSpan {
}
}
}
exports.TimeSpan = TimeSpan;
function calculateSecondsBetween(start, end) {
export function calculateSecondsBetween(start, end) {
const seconds = Math.max(60, (end - start) / 1000);
return {
seconds,
toReadable: (roundToMinutes) => secondsToReadable(seconds, roundToMinutes),
};
}
function secondsToReadable(secs, roundToMinutes = false) {
export function secondsToReadable(secs, roundToMinutes = false) {
const totalSeconds = roundToMinutes ? Math.round(secs / 60) * 60 : secs;
var days = Math.floor(totalSeconds / (3600 * 24));
var hours = Math.floor((totalSeconds % (3600 * 24)) / 3600);

8
dist/timespan.d.ts vendored
View File

@@ -1,8 +0,0 @@
export declare class TimeSpan {
private start;
private end;
constructor(timeSpanStr: string);
private parseTime;
contains(timestamp?: number): boolean;
}
//# sourceMappingURL=timespan.d.ts.map

View File

@@ -1 +0,0 @@
{"version":3,"file":"timespan.d.ts","sourceRoot":"","sources":["../src/timespan.ts"],"names":[],"mappings":"AAAA,qBAAa,QAAQ;IACnB,OAAO,CAAC,KAAK,CAAqC;IAClD,OAAO,CAAC,GAAG,CAAqC;gBAEpC,WAAW,EAAE,MAAM;IAM/B,OAAO,CAAC,SAAS;IAKjB,QAAQ,CAAC,SAAS,GAAE,MAAmB,GAAG,OAAO;CAgBlD"}

29
dist/timespan.js vendored
View File

@@ -1,29 +0,0 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.TimeSpan = void 0;
class TimeSpan {
constructor(timeSpanStr) {
const [startStr, endStr] = timeSpanStr.split("-");
this.start = this.parseTime(startStr);
this.end = this.parseTime(endStr);
}
parseTime(timeStr) {
const [hours, minutes] = timeStr.split(":").map(Number);
return { hours, minutes };
}
contains(timestamp = Date.now()) {
const date = new Date(timestamp);
const hours = date.getHours();
const minutes = date.getMinutes();
const currentMinutes = hours * 60 + minutes;
const startMinutes = this.start.hours * 60 + this.start.minutes;
const endMinutes = this.end.hours * 60 + this.end.minutes;
if (startMinutes > endMinutes) {
return currentMinutes >= startMinutes || currentMinutes < endMinutes;
}
else {
return currentMinutes >= startMinutes && currentMinutes < endMinutes;
}
}
}
exports.TimeSpan = TimeSpan;

40
dist/types.d.ts vendored
View File

@@ -1,40 +0,0 @@
export interface User {
id: string;
email: string;
name: string;
createdAt: Date;
updatedAt: Date;
}
export interface UserProfile extends User {
bio?: string;
avatarUrl?: string;
}
export interface ApiResponse<T> {
success: boolean;
data?: T;
error?: string;
message?: string;
}
export interface PaginatedResponse<T> extends ApiResponse<T[]> {
page: number;
pageSize: number;
totalPages: number;
totalItems: number;
}
export type Nullable<T> = T | null;
export type Optional<T> = T | undefined;
export type ID = string | number;
export declare enum Status {
Active = "active",
Inactive = "inactive",
Pending = "pending",
Archived = "archived"
}
export declare enum HttpMethod {
GET = "GET",
POST = "POST",
PUT = "PUT",
PATCH = "PATCH",
DELETE = "DELETE"
}
//# sourceMappingURL=types.d.ts.map

1
dist/types.d.ts.map vendored
View File

@@ -1 +0,0 @@
{"version":3,"file":"types.d.ts","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":"AACA,MAAM,WAAW,IAAI;IACnB,EAAE,EAAE,MAAM,CAAC;IACX,KAAK,EAAE,MAAM,CAAC;IACd,IAAI,EAAE,MAAM,CAAC;IACb,SAAS,EAAE,IAAI,CAAC;IAChB,SAAS,EAAE,IAAI,CAAC;CACjB;AAED,MAAM,WAAW,WAAY,SAAQ,IAAI;IACvC,GAAG,CAAC,EAAE,MAAM,CAAC;IACb,SAAS,CAAC,EAAE,MAAM,CAAC;CACpB;AAGD,MAAM,WAAW,WAAW,CAAC,CAAC;IAC5B,OAAO,EAAE,OAAO,CAAC;IACjB,IAAI,CAAC,EAAE,CAAC,CAAC;IACT,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,OAAO,CAAC,EAAE,MAAM,CAAC;CAClB;AAED,MAAM,WAAW,iBAAiB,CAAC,CAAC,CAAE,SAAQ,WAAW,CAAC,CAAC,EAAE,CAAC;IAC5D,IAAI,EAAE,MAAM,CAAC;IACb,QAAQ,EAAE,MAAM,CAAC;IACjB,UAAU,EAAE,MAAM,CAAC;IACnB,UAAU,EAAE,MAAM,CAAC;CACpB;AAGD,MAAM,MAAM,QAAQ,CAAC,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC;AACnC,MAAM,MAAM,QAAQ,CAAC,CAAC,IAAI,CAAC,GAAG,SAAS,CAAC;AACxC,MAAM,MAAM,EAAE,GAAG,MAAM,GAAG,MAAM,CAAC;AAGjC,oBAAY,MAAM;IAChB,MAAM,WAAW;IACjB,QAAQ,aAAa;IACrB,OAAO,YAAY;IACnB,QAAQ,aAAa;CACtB;AAED,oBAAY,UAAU;IACpB,GAAG,QAAQ;IACX,IAAI,SAAS;IACb,GAAG,QAAQ;IACX,KAAK,UAAU;IACf,MAAM,WAAW;CAClB"}

19
dist/types.js vendored
View File

@@ -1,19 +0,0 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.HttpMethod = exports.Status = void 0;
// Status enums
var Status;
(function (Status) {
Status["Active"] = "active";
Status["Inactive"] = "inactive";
Status["Pending"] = "pending";
Status["Archived"] = "archived";
})(Status || (exports.Status = Status = {}));
var HttpMethod;
(function (HttpMethod) {
HttpMethod["GET"] = "GET";
HttpMethod["POST"] = "POST";
HttpMethod["PUT"] = "PUT";
HttpMethod["PATCH"] = "PATCH";
HttpMethod["DELETE"] = "DELETE";
})(HttpMethod || (exports.HttpMethod = HttpMethod = {}));

3
dist/utility.d.ts vendored
View File

@@ -1,3 +0,0 @@
export declare function secondsToReadable(secs: number, roundToMinutes?: boolean): string;
export declare function printNetworkError(error: unknown): void;
//# sourceMappingURL=utility.d.ts.map

View File

@@ -1 +0,0 @@
{"version":3,"file":"utility.d.ts","sourceRoot":"","sources":["../src/utility.ts"],"names":[],"mappings":"AAGA,wBAAgB,iBAAiB,CAC/B,IAAI,EAAE,MAAM,EACZ,cAAc,GAAE,OAAe,GAC9B,MAAM,CAmBR;AAED,wBAAgB,iBAAiB,CAAC,KAAK,EAAE,OAAO,QAY/C"}

35
dist/utility.js vendored
View File

@@ -1,35 +0,0 @@
"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.secondsToReadable = secondsToReadable;
exports.printNetworkError = printNetworkError;
const axios_1 = __importDefault(require("axios"));
const logger_1 = require("./logger");
function secondsToReadable(secs, roundToMinutes = false) {
const totalSeconds = roundToMinutes ? Math.round(secs / 60) * 60 : secs;
var days = Math.floor(totalSeconds / (3600 * 24));
var hours = Math.floor((totalSeconds % (3600 * 24)) / 3600);
var minutes = Math.floor((totalSeconds % 3600) / 60);
var seconds = Math.floor(totalSeconds % 60);
var dayDisplay = days > 0 ? days + (days === 1 ? " day, " : " days, ") : "";
var hourDisplay = hours > 0 ? hours + (hours === 1 ? " hour, " : " hours, ") : "";
var minuteDisplay = minutes > 0 ? minutes + (minutes === 1 ? " minute, " : " minutes, ") : "";
var secondDisplay = seconds > 0 ? seconds + (seconds === 1 ? " second" : " seconds") : "";
return (dayDisplay + hourDisplay + minuteDisplay + secondDisplay).replace(/,\s*$/, "");
}
function printNetworkError(error) {
if (axios_1.default.isAxiosError(error)) {
(0, logger_1.logError)("Axios error details:", {
message: error.message,
status: error.response?.status,
statusText: error.response?.statusText,
data: error.response?.data,
url: error.config?.url,
});
}
else {
(0, logger_1.logError)("Unexpected error:", error);
}
}

17
dist/ws.d.ts vendored Normal file
View File

@@ -0,0 +1,17 @@
import { WebSocket } from "ws";
export type WsEvent = {
type: string;
data?: unknown;
};
export type WsClientChangeCallback = (clients: number) => void;
export declare class WsService {
private clients;
private listeners;
onClientChange(callback: WsClientChangeCallback): () => void;
private emitClientChange;
addClient(ws: WebSocket): void;
removeClient(ws: WebSocket): void;
broadcast(message: WsEvent): void;
getClientCount(): number;
}
//# sourceMappingURL=ws.d.ts.map

1
dist/ws.d.ts.map vendored Normal file
View File

@@ -0,0 +1 @@
{"version":3,"file":"ws.d.ts","sourceRoot":"","sources":["../src/ws.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,SAAS,EAAE,MAAM,IAAI,CAAC;AAE/B,MAAM,MAAM,OAAO,GAAG;IACrB,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,CAAC,EAAE,OAAO,CAAC;CACf,CAAC;AAEF,MAAM,MAAM,sBAAsB,GAAG,CAAC,OAAO,EAAE,MAAM,KAAK,IAAI,CAAC;AAE/D,qBAAa,SAAS;IACrB,OAAO,CAAC,OAAO,CAA6B;IAC5C,OAAO,CAAC,SAAS,CAAgC;IAEjD,cAAc,CAAC,QAAQ,EAAE,sBAAsB,GAAG,MAAM,IAAI;IAO5D,OAAO,CAAC,gBAAgB;IAMxB,SAAS,CAAC,EAAE,EAAE,SAAS,GAAG,IAAI;IAM9B,YAAY,CAAC,EAAE,EAAE,SAAS,GAAG,IAAI;IAMjC,SAAS,CAAC,OAAO,EAAE,OAAO,GAAG,IAAI;IAMjC,cAAc,IAAI,MAAM;CAGxB"}

34
dist/ws.js vendored Normal file
View File

@@ -0,0 +1,34 @@
import { logInfo } from "./logger.js";
export class WsService {
clients = new Set();
listeners = [];
onClientChange(callback) {
this.listeners.push(callback);
return () => {
this.listeners = this.listeners.filter((cb) => cb !== callback);
};
}
emitClientChange() {
for (const callback of this.listeners) {
callback(this.clients.size);
}
}
addClient(ws) {
this.clients.add(ws);
logInfo(`Socket connected. Total clients: ${this.clients.size}`);
this.emitClientChange();
}
removeClient(ws) {
this.clients.delete(ws);
logInfo(`Socket disconnected. Total clients: ${this.clients.size}`);
this.emitClientChange();
}
broadcast(message) {
this.clients.forEach((socket) => {
socket.send(JSON.stringify(message));
});
}
getClientCount() {
return this.clients.size;
}
}

143
package-lock.json generated
View File

@@ -1,15 +1,17 @@
{
"name": "@dpu/shared",
"version": "1.0.9",
"version": "1.7.1",
"lockfileVersion": 3,
"requires": true,
"packages": {
"": {
"name": "@dpu/shared",
"version": "1.0.9",
"version": "1.7.1",
"dependencies": {
"@types/ws": "^8.18.1",
"axios": "^1.7.9",
"chalk": "^5.6.2"
"chalk": "^5.6.2",
"rimraf": "^6.1.0"
},
"devDependencies": {
"@types/node": "^24.10.1",
@@ -19,16 +21,45 @@
"typescript": ">=4.5.0"
}
},
"node_modules/@isaacs/balanced-match": {
"version": "4.0.1",
"resolved": "https://registry.npmjs.org/@isaacs/balanced-match/-/balanced-match-4.0.1.tgz",
"integrity": "sha512-yzMTt9lEb8Gv7zRioUilSglI0c0smZ9k5D65677DLWLtWJaXIS3CqcGyUFByYKlnUj6TkjLVs54fBl6+TiGQDQ==",
"license": "MIT",
"engines": {
"node": "20 || >=22"
}
},
"node_modules/@isaacs/brace-expansion": {
"version": "5.0.1",
"resolved": "https://registry.npmjs.org/@isaacs/brace-expansion/-/brace-expansion-5.0.1.tgz",
"integrity": "sha512-WMz71T1JS624nWj2n2fnYAuPovhv7EUhk69R6i9dsVyzxt5eM3bjwvgk9L+APE1TRscGysAVMANkB0jh0LQZrQ==",
"license": "MIT",
"dependencies": {
"@isaacs/balanced-match": "^4.0.1"
},
"engines": {
"node": "20 || >=22"
}
},
"node_modules/@types/node": {
"version": "24.10.1",
"resolved": "https://registry.npmjs.org/@types/node/-/node-24.10.1.tgz",
"integrity": "sha512-GNWcUTRBgIRJD5zj+Tq0fKOJ5XZajIiBroOF0yvj2bSU1WvNdYS/dn9UxwsujGW4JX06dnHyjV2y9rRaybH0iQ==",
"dev": true,
"version": "24.10.11",
"resolved": "https://registry.npmjs.org/@types/node/-/node-24.10.11.tgz",
"integrity": "sha512-/Af7O8r1frCVgOz0I62jWUtMohJ0/ZQU/ZoketltOJPZpnb17yoNc9BSoVuV9qlaIXJiPNOpsfq4ByFajSArNQ==",
"license": "MIT",
"dependencies": {
"undici-types": "~7.16.0"
}
},
"node_modules/@types/ws": {
"version": "8.18.1",
"resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.18.1.tgz",
"integrity": "sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg==",
"license": "MIT",
"dependencies": {
"@types/node": "*"
}
},
"node_modules/asynckit": {
"version": "0.4.0",
"resolved": "https://registry.npmjs.org/asynckit/-/asynckit-0.4.0.tgz",
@@ -36,9 +67,9 @@
"license": "MIT"
},
"node_modules/axios": {
"version": "1.13.2",
"resolved": "https://registry.npmjs.org/axios/-/axios-1.13.2.tgz",
"integrity": "sha512-VPk9ebNqPcy5lRGuSlKx752IlDatOjT9paPlm8A7yOuW2Fbvp4X3JznJtT4f0GzGLLiWE9W8onz51SqLYwzGaA==",
"version": "1.13.4",
"resolved": "https://registry.npmjs.org/axios/-/axios-1.13.4.tgz",
"integrity": "sha512-1wVkUaAO6WyaYtCkcYCOx12ZgpGf9Zif+qXa4n+oYzK558YryKqiL6UWwd5DqiH3VRW0GYhTZQ/vlgJrCoNQlg==",
"license": "MIT",
"dependencies": {
"follow-redirects": "^1.15.6",
@@ -233,6 +264,23 @@
"node": ">= 0.4"
}
},
"node_modules/glob": {
"version": "13.0.1",
"resolved": "https://registry.npmjs.org/glob/-/glob-13.0.1.tgz",
"integrity": "sha512-B7U/vJpE3DkJ5WXTgTpTRN63uV42DseiXXKMwG14LQBXmsdeIoHAPbU/MEo6II0k5ED74uc2ZGTC6MwHFQhF6w==",
"license": "BlueOak-1.0.0",
"dependencies": {
"minimatch": "^10.1.2",
"minipass": "^7.1.2",
"path-scurry": "^2.0.0"
},
"engines": {
"node": "20 || >=22"
},
"funding": {
"url": "https://github.com/sponsors/isaacs"
}
},
"node_modules/gopd": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/gopd/-/gopd-1.2.0.tgz",
@@ -284,6 +332,15 @@
"node": ">= 0.4"
}
},
"node_modules/lru-cache": {
"version": "11.2.5",
"resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-11.2.5.tgz",
"integrity": "sha512-vFrFJkWtJvJnD5hg+hJvVE8Lh/TcMzKnTgCWmtBipwI5yLX/iX+5UB2tfuyODF5E7k9xEzMdYgGqaSb1c0c5Yw==",
"license": "BlueOak-1.0.0",
"engines": {
"node": "20 || >=22"
}
},
"node_modules/math-intrinsics": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/math-intrinsics/-/math-intrinsics-1.1.0.tgz",
@@ -314,12 +371,77 @@
"node": ">= 0.6"
}
},
"node_modules/minimatch": {
"version": "10.1.2",
"resolved": "https://registry.npmjs.org/minimatch/-/minimatch-10.1.2.tgz",
"integrity": "sha512-fu656aJ0n2kcXwsnwnv9g24tkU5uSmOlTjd6WyyaKm2Z+h1qmY6bAjrcaIxF/BslFqbZ8UBtbJi7KgQOZD2PTw==",
"license": "BlueOak-1.0.0",
"dependencies": {
"@isaacs/brace-expansion": "^5.0.1"
},
"engines": {
"node": "20 || >=22"
},
"funding": {
"url": "https://github.com/sponsors/isaacs"
}
},
"node_modules/minipass": {
"version": "7.1.2",
"resolved": "https://registry.npmjs.org/minipass/-/minipass-7.1.2.tgz",
"integrity": "sha512-qOOzS1cBTWYF4BH8fVePDBOO9iptMnGUEZwNc/cMWnTV2nVLZ7VoNWEPHkYczZA0pdoA7dl6e7FL659nX9S2aw==",
"license": "ISC",
"engines": {
"node": ">=16 || 14 >=14.17"
}
},
"node_modules/package-json-from-dist": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/package-json-from-dist/-/package-json-from-dist-1.0.1.tgz",
"integrity": "sha512-UEZIS3/by4OC8vL3P2dTXRETpebLI2NiI5vIrjaD/5UtrkFX/tNbwjTSRAGC/+7CAo2pIcBaRgWmcBBHcsaCIw==",
"license": "BlueOak-1.0.0"
},
"node_modules/path-scurry": {
"version": "2.0.1",
"resolved": "https://registry.npmjs.org/path-scurry/-/path-scurry-2.0.1.tgz",
"integrity": "sha512-oWyT4gICAu+kaA7QWk/jvCHWarMKNs6pXOGWKDTr7cw4IGcUbW+PeTfbaQiLGheFRpjo6O9J0PmyMfQPjH71oA==",
"license": "BlueOak-1.0.0",
"dependencies": {
"lru-cache": "^11.0.0",
"minipass": "^7.1.2"
},
"engines": {
"node": "20 || >=22"
},
"funding": {
"url": "https://github.com/sponsors/isaacs"
}
},
"node_modules/proxy-from-env": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/proxy-from-env/-/proxy-from-env-1.1.0.tgz",
"integrity": "sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg==",
"license": "MIT"
},
"node_modules/rimraf": {
"version": "6.1.2",
"resolved": "https://registry.npmjs.org/rimraf/-/rimraf-6.1.2.tgz",
"integrity": "sha512-cFCkPslJv7BAXJsYlK1dZsbP8/ZNLkCAQ0bi1hf5EKX2QHegmDFEFA6QhuYJlk7UDdc+02JjO80YSOrWPpw06g==",
"license": "BlueOak-1.0.0",
"dependencies": {
"glob": "^13.0.0",
"package-json-from-dist": "^1.0.1"
},
"bin": {
"rimraf": "dist/esm/bin.mjs"
},
"engines": {
"node": "20 || >=22"
},
"funding": {
"url": "https://github.com/sponsors/isaacs"
}
},
"node_modules/typescript": {
"version": "5.9.3",
"resolved": "https://registry.npmjs.org/typescript/-/typescript-5.9.3.tgz",
@@ -338,7 +460,6 @@
"version": "7.16.0",
"resolved": "https://registry.npmjs.org/undici-types/-/undici-types-7.16.0.tgz",
"integrity": "sha512-Zz+aZWSj8LE6zoxD+xrjh4VfkIG8Ya6LvYkZqtUQGJPZjYl53ypCaUwWqo7eI0x66KBGeRo+mlBEkMSeSZ38Nw==",
"dev": true,
"license": "MIT"
}
}

View File

@@ -1,17 +1,16 @@
{
"name": "@dpu/shared",
"version": "1.0.9",
"version": "1.7.1",
"description": "",
"main": "dist/index.js",
"types": "dist/index.d.ts",
"type": "module",
"files": [
"dist"
],
"scripts": {
"build": "tsc",
"prepublishOnly": "npm run build",
"clean": "rm -rf dist",
"update": "npm update @dpu/types"
"build": "npm run clean && tsc",
"clean": "rimraf dist"
},
"keywords": [
"typescript",
@@ -27,7 +26,9 @@
"typescript": ">=4.5.0"
},
"dependencies": {
"@types/ws": "^8.18.1",
"axios": "^1.7.9",
"chalk": "^5.6.2"
"chalk": "^5.6.2",
"rimraf": "^6.1.0"
}
}

48
src/fastify.ts Normal file
View File

@@ -0,0 +1,48 @@
import type { AxiosInstance } from "axios";
export type ServiceResult<T = unknown> = {
result: T;
successful: boolean;
};
export class API_Error {
constructor(public error: string) {}
}
export abstract class BaseClient {
private axiosInstance: AxiosInstance;
constructor(axiosInstance: AxiosInstance) {
this.axiosInstance = axiosInstance;
}
getAxios(): AxiosInstance {
return this.axiosInstance;
}
}
export abstract class BaseService<T> {
private client: T;
constructor(client: T) {
this.client = client;
}
getClient(): T {
return this.client;
}
getSuccessfulResult<R = unknown>(result: R): ServiceResult<R> {
return {
result,
successful: true,
};
}
getErrorResult(error: string): ServiceResult<string> {
return {
result: error,
successful: false,
};
}
}

View File

@@ -1,3 +1,5 @@
import type { TimeBetween } from "./timehelper";
export type HomeAssistantEntity = {
entity_id: string;
state: string;
@@ -20,13 +22,14 @@ export type HomeAssistantEntity = {
export interface HomeAssistantDeskPositionResult {
raw: HomeAssistantEntity;
asBoolean: boolean;
asText: () => string;
standingTime: number;
as_boolean: boolean;
as_text: () => string;
last_changed: TimeBetween;
}
export type API_HA_DeskPosition = {
position: string;
isStanding: boolean;
standingTime: string;
is_standing: boolean;
last_changed: string;
last_changed_seconds: number;
};

8
src/homepage.ts Normal file
View File

@@ -0,0 +1,8 @@
import { type API_HA_DeskPosition } from "./homeassistant";
import { type TidalGetCurrent } from "./tidal";
export type FullInformation = {
ha_desk_position: API_HA_DeskPosition | null;
ha_temp: string | null;
tidal_current: TidalGetCurrent | null;
};

View File

@@ -1,4 +1,7 @@
export * from "./homeassistant";
export * as Logger from "./logger";
export * from "./tidal";
export * as TimeHelper from "./timehelper";
export * from "./fastify.js";
export * from "./homeassistant.js";
export * from "./homepage.js";
export * from "./logger.js";
export * from "./ws.js";
export * from "./tidal.js";
export * from "./timehelper.js";

View File

@@ -1,14 +1,25 @@
export type TidalSong = {
export type TidalGetCurrent = {
title: string;
artists: string;
artistsArray: string[];
album: string;
playingFrom: string;
status: "playing" | "paused";
url: string;
current: string;
currentInSeconds: number;
duration: string;
};
export type TidalVolume = {
durationInSeconds: number;
image: string;
icon: string;
localAlbumArt: string;
favorite: boolean;
trackId: string;
volume: number;
player: {
status: "playing" | "paused";
shuffle: boolean;
repeat: "all" | "single" | "none";
};
artist: string;
};

View File

@@ -1,11 +1,13 @@
export class TimeSpan {
private start: { hours: number; minutes: number };
private end: { hours: number; minutes: number };
private timeZone;
constructor(timeSpanStr: string) {
constructor(timeSpanStr: string, timeZone: string) {
const [startStr, endStr] = timeSpanStr.split("-");
this.start = this.parseTime(startStr);
this.end = this.parseTime(endStr);
this.timeZone = timeZone;
}
private parseTime(timeStr: string) {
@@ -16,10 +18,15 @@ export class TimeSpan {
contains(timestamp: number = Date.now()): boolean {
const date = new Date(timestamp);
const hours = date.getHours();
const minutes = date.getMinutes();
const currentMinutes = hours * 60 + minutes;
const berlinTimeStr = date.toLocaleString("de-DE", {
timeZone: this.timeZone, // "Europe/Berlin"
hour12: false,
hour: "2-digit",
minute: "2-digit",
});
const [hours, minutes] = berlinTimeStr.split(":").map(Number);
const currentMinutes = hours * 60 + minutes;
const startMinutes = this.start.hours * 60 + this.start.minutes;
const endMinutes = this.end.hours * 60 + this.end.minutes;

49
src/ws.ts Normal file
View File

@@ -0,0 +1,49 @@
import { logInfo } from "./logger.js";
import { WebSocket } from "ws";
export type WsEvent = {
type: string;
data?: unknown;
};
export type WsClientChangeCallback = (clients: number) => void;
export class WsService {
private clients: Set<WebSocket> = new Set();
private listeners: WsClientChangeCallback[] = [];
onClientChange(callback: WsClientChangeCallback): () => void {
this.listeners.push(callback);
return () => {
this.listeners = this.listeners.filter((cb) => cb !== callback);
};
}
private emitClientChange(): void {
for (const callback of this.listeners) {
callback(this.clients.size);
}
}
addClient(ws: WebSocket): void {
this.clients.add(ws);
logInfo(`Socket connected. Total clients: ${this.clients.size}`);
this.emitClientChange();
}
removeClient(ws: WebSocket): void {
this.clients.delete(ws);
logInfo(`Socket disconnected. Total clients: ${this.clients.size}`);
this.emitClientChange();
}
broadcast(message: WsEvent): void {
this.clients.forEach((socket) => {
socket.send(JSON.stringify(message));
});
}
getClientCount(): number {
return this.clients.size;
}
}

View File

@@ -1,8 +1,8 @@
{
"compilerOptions": {
"target": "ES2020",
"module": "commonjs",
"lib": ["ES2020"],
"target": "ES2022",
"module": "ES2022",
"lib": ["ES2022"],
"types": ["node"],
"declaration": true,
"declarationMap": true,