Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 | 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 14x 14x 14x 14x 14x 8x 8x 5x 5x 14x 1x 1x 1x 42x 42x 42x 38x 38x 10x 10x 4x 4x 42x | /* ** MQTT+ -- MQTT Communication Patterns ** Copyright (c) 2018-2026 Dr. Ralf S. Engelschall <rse@engelschall.com> ** ** Permission is hereby granted, free of charge, to any person obtaining ** a copy of this software and associated documentation files (the ** "Software"), to deal in the Software without restriction, including ** without limitation the rights to use, copy, modify, merge, publish, ** distribute, sublicense, and/or sell copies of the Software, and to ** permit persons to whom the Software is furnished to do so, subject to ** the following conditions: ** ** The above copyright notice and this permission notice shall be included ** in all copies or substantial portions of the Software. ** ** THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, ** EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF ** MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. ** IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY ** CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, ** TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE ** SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ /* internal requirements */ import type { APISchema } from "./mqtt-plus-api" import { TimerTrait } from "./mqtt-plus-timer" /* Meta trait with meta information management */ export class MetaTrait<T extends APISchema = APISchema> extends TimerTrait<T> { /* internal state */ private _meta = new Map<string, any>() /* set/delete/retrieve meta information */ meta (): Record<string, any> meta (key: string): any meta (key: string, value: any): void meta (...args: [ key?: string, value?: any ]): Record<string, any> | any | void { const [key, value] = args if (args.length === 0) return Object.fromEntries(this._meta) else if (args.length === 1) return this._meta.get(key!) else if (value === undefined || value === null) this._meta.delete(key!) else this._meta.set(key!, value) } /* determine meta store */ protected metaStore (extra?: Record<string, any>): Record<string, any> | undefined { const extraEmpty = (extra === undefined || Object.keys(extra).length === 0) if (this._meta.size === 0 && extraEmpty) return undefined else if (this._meta.size > 0 && extraEmpty) return Object.fromEntries(this._meta) else if (this._meta.size === 0 && !extraEmpty) return extra else return { ...Object.fromEntries(this._meta), ...extra } } } |