tokono.ma
A music player that connects to your cloud/distributed storage.
chore: adjust paths
+1
-16
deno.jsonc
+1
-16
deno.jsonc
···
55
"@testing/": "./src/testing/",
56
"@tests/": "./tests/",
57
58
-
"@common/": "./src/common/",
59
-
"@components/": "./src/components/",
60
-
"@definitions/": "./src/definitions/",
61
-
"@styles/": "./src/styles/",
62
-
"@themes/": "./src/themes/",
63
-
"@vendor/": "./src/vendor/",
64
-
65
-
// Diffuse prefix paths
66
-
"@diffuse/foundation": "./src/common/facets/foundation.js",
67
-
68
-
"@diffuse/common/": "./src/common/",
69
-
"@diffuse/components/": "./src/components/",
70
-
"@diffuse/definitions/": "./src/definitions/",
71
-
"@diffuse/styles/": "./src/styles/",
72
-
"@diffuse/themes/": "./src/themes/",
73
-
"@diffuse/vendor/": "./src/vendor/",
74
75
// Build
76
"@atcute/lex-cli": "npm:@atcute/lex-cli@^2.5.3",
+1
-1
docs/plans/https-directory-listing.md
+1
-1
docs/plans/https-directory-listing.md
+2
-2
src/common/element.js
+2
-2
src/common/element.js
···
1
import QS from "query-string";
2
import { html, render } from "lit-html";
3
4
-
import { effect, signal } from "@common/signal.js";
5
import { rpc, workerLink, workerProxy, workerTunnel } from "./worker.js";
6
import { RpcChannel } from "./worker/rpc-channel.js";
7
···
489
* with the correct type based on the element module given.
490
*
491
* ```
492
-
* import * as QueryEngine from "@components/engine/query/element.js"
493
*
494
* const instance = component(QueryEngine)
495
* ```
···
1
import QS from "query-string";
2
import { html, render } from "lit-html";
3
4
+
import { effect, signal } from "~/common/signal.js";
5
import { rpc, workerLink, workerProxy, workerTunnel } from "./worker.js";
6
import { RpcChannel } from "./worker/rpc-channel.js";
7
···
489
* with the correct type based on the element module given.
490
*
491
* ```
492
+
* import * as QueryEngine from "~/components/engine/query/element.js"
493
*
494
* const instance = component(QueryEngine)
495
* ```
+16
-16
src/common/facets/foundation.js
+16
-16
src/common/facets/foundation.js
···
1
-
import ArtworkProcessor from "@components/processor/artwork/element.js";
2
-
import AudioEngine from "@components/engine/audio/element.js";
3
-
import AutoQueueOrchestrator from "@components/orchestrator/auto-queue/element.js";
4
-
import Queue from "@components/engine/queue/element.js";
5
-
import InputOrchestrator from "@components/orchestrator/input/element.js";
6
-
import OutputOrchestrator from "@components/orchestrator/output/element.js";
7
-
import MetadataProcessor from "@components/processor/metadata/element.js";
8
-
import ProcessTracksOrchestrator from "@components/orchestrator/process-tracks/element.js";
9
-
import QueueAudioOrchestrator from "@components/orchestrator/queue-audio/element.js";
10
-
import RepeatShuffleEngine from "@components/engine/repeat-shuffle/element.js";
11
-
import SearchProcessor from "@components/processor/search/element.js";
12
-
import ScopeEngine from "@components/engine/scope/element.js";
13
-
import ScopedTracksOrchestrator from "@components/orchestrator/scoped-tracks/element.js";
14
-
import FavouritesOrchestrator from "@components/orchestrator/favourites/element.js";
15
-
import MediaSessionOrchestrator from "@components/orchestrator/media-session/element.js";
16
-
import SourcesOrchestrator from "@components/orchestrator/sources/element.js";
17
18
/**
19
* @import { DiffuseElement } from "@toko/diffuse/common/element.js";
···
1
+
import ArtworkProcessor from "~/components/processor/artwork/element.js";
2
+
import AudioEngine from "~/components/engine/audio/element.js";
3
+
import AutoQueueOrchestrator from "~/components/orchestrator/auto-queue/element.js";
4
+
import Queue from "~/components/engine/queue/element.js";
5
+
import InputOrchestrator from "~/components/orchestrator/input/element.js";
6
+
import OutputOrchestrator from "~/components/orchestrator/output/element.js";
7
+
import MetadataProcessor from "~/components/processor/metadata/element.js";
8
+
import ProcessTracksOrchestrator from "~/components/orchestrator/process-tracks/element.js";
9
+
import QueueAudioOrchestrator from "~/components/orchestrator/queue-audio/element.js";
10
+
import RepeatShuffleEngine from "~/components/engine/repeat-shuffle/element.js";
11
+
import SearchProcessor from "~/components/processor/search/element.js";
12
+
import ScopeEngine from "~/components/engine/scope/element.js";
13
+
import ScopedTracksOrchestrator from "~/components/orchestrator/scoped-tracks/element.js";
14
+
import FavouritesOrchestrator from "~/components/orchestrator/favourites/element.js";
15
+
import MediaSessionOrchestrator from "~/components/orchestrator/media-session/element.js";
16
+
import SourcesOrchestrator from "~/components/orchestrator/sources/element.js";
17
18
/**
19
* @import { DiffuseElement } from "@toko/diffuse/common/element.js";
+1
-1
src/common/facets/utils.js
+1
-1
src/common/facets/utils.js
+3
-3
src/common/loader.js
+3
-3
src/common/loader.js
+2
-2
src/common/playlist.js
+2
-2
src/common/playlist.js
+1
-1
src/common/themes/utils.js
+1
-1
src/common/themes/utils.js
+1
-1
src/common/track.js
+1
-1
src/common/track.js
+1
-1
src/common/utils.js
+1
-1
src/common/utils.js
+3
-3
src/components/configurator/input/element.js
+3
-3
src/components/configurator/input/element.js
+5
-5
src/components/configurator/input/worker.js
+5
-5
src/components/configurator/input/worker.js
···
1
import * as URI from "fast-uri";
2
3
-
import { groupTracksPerScheme, groupUrisPerScheme } from "@common/utils.js";
4
-
import { ostiary, rpc, workerProxy } from "@common/worker.js";
5
6
/**
7
-
* @import {Track} from "@definitions/types.d.ts";
8
-
* @import {GroupConsult, InputActions} from "@components/input/types.d.ts"
9
-
* @import {ActionsWithTunnel, ProxiedActions} from "@common/worker.d.ts"
10
*/
11
12
////////////////////////////////////////////
···
1
import * as URI from "fast-uri";
2
3
+
import { groupTracksPerScheme, groupUrisPerScheme } from "~/common/utils.js";
4
+
import { ostiary, rpc, workerProxy } from "~/common/worker.js";
5
6
/**
7
+
* @import {Track} from "~/definitions/types.d.ts";
8
+
* @import {GroupConsult, InputActions} from "~/components/input/types.d.ts"
9
+
* @import {ActionsWithTunnel, ProxiedActions} from "~/common/worker.d.ts"
10
*/
11
12
////////////////////////////////////////////
+5
-5
src/components/configurator/output/element.js
+5
-5
src/components/configurator/output/element.js
···
1
-
import { BroadcastableDiffuseElement } from "@common/element.js";
2
-
import { batch, computed, signal } from "@common/signal.js";
3
4
/**
5
-
* @import {DiffuseElement} from "@common/element.js"
6
-
* @import {Facet, PlaylistItem, Theme, Track} from "@definitions/types.d.ts"
7
-
* @import {OutputManagerDeputy, OutputElement} from "@components/output/types.d.ts"
8
*
9
* @import {OutputConfiguratorElement} from "./types.d.ts"
10
*/
···
1
+
import { BroadcastableDiffuseElement } from "~/common/element.js";
2
+
import { batch, computed, signal } from "~/common/signal.js";
3
4
/**
5
+
* @import {DiffuseElement} from "~/common/element.js"
6
+
* @import {Facet, PlaylistItem, Theme, Track} from "~/definitions/types.d.ts"
7
+
* @import {OutputManagerDeputy, OutputElement} from "~/components/output/types.d.ts"
8
*
9
* @import {OutputConfiguratorElement} from "./types.d.ts"
10
*/
+2
-2
src/components/configurator/output/types.d.ts
+2
-2
src/components/configurator/output/types.d.ts
+4
-4
src/components/engine/audio/element.js
+4
-4
src/components/engine/audio/element.js
···
1
import { keyed } from "lit-html/directives/keyed.js";
2
3
-
import { BroadcastableDiffuseElement, nothing } from "@common/element.js";
4
-
import { computed, signal, untracked } from "@common/signal.js";
5
6
/**
7
* @import {Actions, Audio, AudioState, AudioStateReadOnly, LoadingState} from "./types.d.ts"
8
-
* @import {RenderArg} from "@common/element.d.ts"
9
-
* @import {SignalReader} from "@common/signal.d.ts"
10
*/
11
12
////////////////////////////////////////////
···
1
import { keyed } from "lit-html/directives/keyed.js";
2
3
+
import { BroadcastableDiffuseElement, nothing } from "~/common/element.js";
4
+
import { computed, signal, untracked } from "~/common/signal.js";
5
6
/**
7
* @import {Actions, Audio, AudioState, AudioStateReadOnly, LoadingState} from "./types.d.ts"
8
+
* @import {RenderArg} from "~/common/element.d.ts"
9
+
* @import {SignalReader} from "~/common/signal.d.ts"
10
*/
11
12
////////////////////////////////////////////
+1
-1
src/components/engine/audio/types.d.ts
+1
-1
src/components/engine/audio/types.d.ts
+4
-4
src/components/engine/queue/element.js
+4
-4
src/components/engine/queue/element.js
+1
-1
src/components/engine/queue/types.d.ts
+1
-1
src/components/engine/queue/types.d.ts
+3
-3
src/components/engine/queue/worker.js
+3
-3
src/components/engine/queue/worker.js
+2
-2
src/components/engine/repeat-shuffle/element.js
+2
-2
src/components/engine/repeat-shuffle/element.js
+2
-2
src/components/engine/scope/element.js
+2
-2
src/components/engine/scope/element.js
+1
-1
src/components/input/common.js
+1
-1
src/components/input/common.js
+5
-5
src/components/input/https/common.js
+5
-5
src/components/input/https/common.js
···
1
-
import { cachedConsult } from "@components/input/common.js";
2
3
/**
4
-
* @import {Track} from "@definitions/types.d.ts"
5
*/
6
7
/**
···
14
* ```ts
15
* import { expect } from "@std/expect";
16
* import { groupTracksByHost } from "./common.js";
17
-
* import type { Track } from "@definitions/types.d.ts";
18
*
19
* const tracks: Track[] = [
20
* {
···
44
* ```ts
45
* import { expect } from "@std/expect";
46
* import { groupTracksByHost } from "./common.js";
47
-
* import type { Track } from "@definitions/types.d.ts";
48
*
49
* const tracks: Track[] = [
50
* {
···
121
* ```ts
122
* import { expect } from "@std/expect";
123
* import { hostsFromTracks } from "./common.js";
124
-
* import type { Track } from "@definitions/types.d.ts";
125
*
126
* const tracks: Track[] = [
127
* {
···
1
+
import { cachedConsult } from "~/components/input/common.js";
2
3
/**
4
+
* @import {Track} from "~/definitions/types.d.ts"
5
*/
6
7
/**
···
14
* ```ts
15
* import { expect } from "@std/expect";
16
* import { groupTracksByHost } from "./common.js";
17
+
* import type { Track } from "~/definitions/types.d.ts";
18
*
19
* const tracks: Track[] = [
20
* {
···
44
* ```ts
45
* import { expect } from "@std/expect";
46
* import { groupTracksByHost } from "./common.js";
47
+
* import type { Track } from "~/definitions/types.d.ts";
48
*
49
* const tracks: Track[] = [
50
* {
···
121
* ```ts
122
* import { expect } from "@std/expect";
123
* import { hostsFromTracks } from "./common.js";
124
+
* import type { Track } from "~/definitions/types.d.ts";
125
*
126
* const tracks: Track[] = [
127
* {
+4
-4
src/components/input/https/element.js
+4
-4
src/components/input/https/element.js
···
1
-
import { DiffuseElement } from "@common/element.js";
2
import { SCHEME } from "./constants.js";
3
import { hostsFromTracks } from "./common.js";
4
5
/**
6
-
* @import {InputActions, InputSchemeProvider} from "@components/input/types.d.ts"
7
-
* @import {ProxiedActions} from "@common/worker.d.ts"
8
-
* @import {Track} from "@definitions/types.d.ts"
9
*/
10
11
////////////////////////////////////////////
···
1
+
import { DiffuseElement } from "~/common/element.js";
2
import { SCHEME } from "./constants.js";
3
import { hostsFromTracks } from "./common.js";
4
5
/**
6
+
* @import {InputActions, InputSchemeProvider} from "~/components/input/types.d.ts"
7
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
8
+
* @import {Track} from "~/definitions/types.d.ts"
9
*/
10
11
////////////////////////////////////////////
+3
-3
src/components/input/https/worker.js
+3
-3
src/components/input/https/worker.js
···
1
-
import { ostiary, rpc } from "@common/worker.js";
2
-
import { detach as detachUtil, groupKey } from "@components/input/common.js";
3
4
import {
5
consultHostCached,
···
10
import { SCHEME } from "./constants.js";
11
12
/**
13
-
* @import { InputActions as Actions, ConsultGrouping } from "@components/input/types.d.ts";
14
*/
15
16
////////////////////////////////////////////
···
1
+
import { ostiary, rpc } from "~/common/worker.js";
2
+
import { detach as detachUtil, groupKey } from "~/components/input/common.js";
3
4
import {
5
consultHostCached,
···
10
import { SCHEME } from "./constants.js";
11
12
/**
13
+
* @import { InputActions as Actions, ConsultGrouping } from "~/components/input/types.d.ts";
14
*/
15
16
////////////////////////////////////////////
+3
-3
src/components/input/local/common.js
+3
-3
src/components/input/local/common.js
···
1
import * as IDB from "idb-keyval";
2
import * as URI from "fast-uri";
3
4
-
import { isAudioFile } from "@components/input/common.js";
5
-
import { safeDecodeURIComponent } from "@common/utils.js";
6
import { IDB_HANDLES, SCHEME } from "./constants.js";
7
8
/**
9
-
* @import { Track } from "@definitions/types.d.ts"
10
*/
11
12
////////////////////////////////////////////
···
1
import * as IDB from "idb-keyval";
2
import * as URI from "fast-uri";
3
4
+
import { isAudioFile } from "~/components/input/common.js";
5
+
import { safeDecodeURIComponent } from "~/common/utils.js";
6
import { IDB_HANDLES, SCHEME } from "./constants.js";
7
8
/**
9
+
* @import { Track } from "~/definitions/types.d.ts"
10
*/
11
12
////////////////////////////////////////////
+4
-4
src/components/input/local/element.js
+4
-4
src/components/input/local/element.js
···
1
import * as TID from "@atcute/tid";
2
-
import { DiffuseElement } from "@common/element.js";
3
import { SCHEME } from "./constants.js";
4
import {
5
buildURI,
···
9
} from "./common.js";
10
11
/**
12
-
* @import {InputActions, InputSchemeProvider} from "@components/input/types.d.ts"
13
-
* @import {ProxiedActions} from "@common/worker.d.ts"
14
-
* @import {Track} from "@definitions/types.d.ts"
15
*/
16
17
////////////////////////////////////////////
···
1
import * as TID from "@atcute/tid";
2
+
import { DiffuseElement } from "~/common/element.js";
3
import { SCHEME } from "./constants.js";
4
import {
5
buildURI,
···
9
} from "./common.js";
10
11
/**
12
+
* @import {InputActions, InputSchemeProvider} from "~/components/input/types.d.ts"
13
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
14
+
* @import {Track} from "~/definitions/types.d.ts"
15
*/
16
17
////////////////////////////////////////////
+4
-4
src/components/input/local/worker.js
+4
-4
src/components/input/local/worker.js
···
1
import * as TID from "@atcute/tid";
2
-
import { ostiary, rpc } from "@common/worker.js";
3
-
import { groupKey } from "@components/input/common.js";
4
import {
5
buildURI,
6
enumerateAudioFiles,
···
14
import { SCHEME } from "./constants.js";
15
16
/**
17
-
* @import { InputActions as Actions, ConsultGrouping } from "@components/input/types.d.ts";
18
-
* @import { Track } from "@definitions/types.d.ts"
19
*/
20
21
////////////////////////////////////////////
···
1
import * as TID from "@atcute/tid";
2
+
import { ostiary, rpc } from "~/common/worker.js";
3
+
import { groupKey } from "~/components/input/common.js";
4
import {
5
buildURI,
6
enumerateAudioFiles,
···
14
import { SCHEME } from "./constants.js";
15
16
/**
17
+
* @import { InputActions as Actions, ConsultGrouping } from "~/components/input/types.d.ts";
18
+
* @import { Track } from "~/definitions/types.d.ts"
19
*/
20
21
////////////////////////////////////////////
+3
-3
src/components/input/opensubsonic/common.js
+3
-3
src/components/input/opensubsonic/common.js
···
2
import QS from "query-string";
3
4
import { SCHEME } from "./constants.js";
5
-
import { cachedConsult } from "@components/input/common.js";
6
-
import { safeDecodeURIComponent } from "@common/utils.js";
7
import { SubsonicAPIWithoutFetch } from "./class.js";
8
9
/**
10
* @import {Child} from "subsonic-api"
11
-
* @import {Track} from "@definitions/types.d.ts";
12
* @import {Server} from "./types.d.ts";
13
*/
14
···
2
import QS from "query-string";
3
4
import { SCHEME } from "./constants.js";
5
+
import { cachedConsult } from "~/components/input/common.js";
6
+
import { safeDecodeURIComponent } from "~/common/utils.js";
7
import { SubsonicAPIWithoutFetch } from "./class.js";
8
9
/**
10
* @import {Child} from "subsonic-api"
11
+
* @import {Track} from "~/definitions/types.d.ts";
12
* @import {Server} from "./types.d.ts";
13
*/
14
+4
-4
src/components/input/opensubsonic/element.js
+4
-4
src/components/input/opensubsonic/element.js
···
1
-
import { DiffuseElement } from "@common/element.js";
2
import { SCHEME } from "./constants.js";
3
import { buildURI, serversFromTracks } from "./common.js";
4
5
/**
6
-
* @import {InputActions, InputSchemeProvider} from "@components/input/types.d.ts"
7
-
* @import {ProxiedActions} from "@common/worker.d.ts"
8
-
* @import {Track} from "@definitions/types.d.ts"
9
*/
10
11
////////////////////////////////////////////
···
1
+
import { DiffuseElement } from "~/common/element.js";
2
import { SCHEME } from "./constants.js";
3
import { buildURI, serversFromTracks } from "./common.js";
4
5
/**
6
+
* @import {InputActions, InputSchemeProvider} from "~/components/input/types.d.ts"
7
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
8
+
* @import {Track} from "~/definitions/types.d.ts"
9
*/
10
11
////////////////////////////////////////////
+4
-4
src/components/input/opensubsonic/worker.js
+4
-4
src/components/input/opensubsonic/worker.js
···
1
import * as TID from "@atcute/tid";
2
-
import { ostiary, rpc } from "@common/worker.js";
3
4
import { SCHEME } from "./constants.js";
5
import {
6
removeUndefinedValuesFromRecord,
7
safeDecodeURIComponent,
8
-
} from "@common/utils.js";
9
import { detach as detachUtil, groupKey } from "../common.js";
10
import {
11
autoTypeToTrackKind,
···
20
21
/**
22
* @import {Child, SubsonicAPI} from "subsonic-api"
23
-
* @import {Track} from "@definitions/types.d.ts";
24
-
* @import {ConsultGrouping, InputActions as Actions} from "@components/input/types.d.ts";
25
* @import {Server} from "./types.d.ts"
26
*/
27
···
1
import * as TID from "@atcute/tid";
2
+
import { ostiary, rpc } from "~/common/worker.js";
3
4
import { SCHEME } from "./constants.js";
5
import {
6
removeUndefinedValuesFromRecord,
7
safeDecodeURIComponent,
8
+
} from "~/common/utils.js";
9
import { detach as detachUtil, groupKey } from "../common.js";
10
import {
11
autoTypeToTrackKind,
···
20
21
/**
22
* @import {Child, SubsonicAPI} from "subsonic-api"
23
+
* @import {Track} from "~/definitions/types.d.ts";
24
+
* @import {ConsultGrouping, InputActions as Actions} from "~/components/input/types.d.ts";
25
* @import {Server} from "./types.d.ts"
26
*/
27
+3
-3
src/components/input/s3/common.js
+3
-3
src/components/input/s3/common.js
···
3
import * as URI from "fast-uri";
4
import QS from "query-string";
5
6
-
import { cachedConsult } from "@components/input/common.js";
7
-
import { safeDecodeURIComponent } from "@common/utils.js";
8
import { ENCODINGS, IDB_BUCKETS, SCHEME } from "./constants.js";
9
10
/**
11
-
* @import { Track } from "@definitions/types.d.ts";
12
* @import { Bucket } from "./types.d.ts";
13
*/
14
···
3
import * as URI from "fast-uri";
4
import QS from "query-string";
5
6
+
import { cachedConsult } from "~/components/input/common.js";
7
+
import { safeDecodeURIComponent } from "~/common/utils.js";
8
import { ENCODINGS, IDB_BUCKETS, SCHEME } from "./constants.js";
9
10
/**
11
+
* @import { Track } from "~/definitions/types.d.ts";
12
* @import { Bucket } from "./types.d.ts";
13
*/
14
+1
-1
src/components/input/s3/constants.js
+1
-1
src/components/input/s3/constants.js
+4
-4
src/components/input/s3/element.js
+4
-4
src/components/input/s3/element.js
···
1
-
import { DiffuseElement } from "@common/element.js";
2
import { SCHEME } from "./constants.js";
3
import { bucketsFromTracks, buildURI } from "./common.js";
4
5
/**
6
-
* @import {InputActions, InputSchemeProvider} from "@components/input/types.d.ts"
7
-
* @import {ProxiedActions} from "@common/worker.d.ts"
8
-
* @import {Track} from "@definitions/types.d.ts"
9
* @import {Demo} from "./types.d.ts"
10
*/
11
···
1
+
import { DiffuseElement } from "~/common/element.js";
2
import { SCHEME } from "./constants.js";
3
import { bucketsFromTracks, buildURI } from "./common.js";
4
5
/**
6
+
* @import {InputActions, InputSchemeProvider} from "~/components/input/types.d.ts"
7
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
8
+
* @import {Track} from "~/definitions/types.d.ts"
9
* @import {Demo} from "./types.d.ts"
10
*/
11
+1
-1
src/components/input/s3/types.d.ts
+1
-1
src/components/input/s3/types.d.ts
+4
-4
src/components/input/s3/worker.js
+4
-4
src/components/input/s3/worker.js
···
1
import * as TID from "@atcute/tid";
2
-
import { ostiary, rpc } from "@common/worker.js";
3
import {
4
detach as detachUtil,
5
groupKey,
6
isAudioFile,
7
-
} from "@components/input/common.js";
8
import {
9
bucketId,
10
buildURI,
···
17
import { SCHEME } from "./constants.js";
18
19
/**
20
-
* @import { InputActions as Actions, ConsultGrouping } from "@components/input/types.d.ts";
21
-
* @import { Track } from "@definitions/types.d.ts"
22
* @import { Bucket, Demo } from "./types.d.ts"
23
*/
24
···
1
import * as TID from "@atcute/tid";
2
+
import { ostiary, rpc } from "~/common/worker.js";
3
import {
4
detach as detachUtil,
5
groupKey,
6
isAudioFile,
7
+
} from "~/components/input/common.js";
8
import {
9
bucketId,
10
buildURI,
···
17
import { SCHEME } from "./constants.js";
18
19
/**
20
+
* @import { InputActions as Actions, ConsultGrouping } from "~/components/input/types.d.ts";
21
+
* @import { Track } from "~/definitions/types.d.ts"
22
* @import { Bucket, Demo } from "./types.d.ts"
23
*/
24
+3
-3
src/components/input/types.d.ts
+3
-3
src/components/input/types.d.ts
+6
-6
src/components/orchestrator/auto-queue/element.js
+6
-6
src/components/orchestrator/auto-queue/element.js
···
1
-
import { BroadcastableDiffuseElement, query } from "@common/element.js";
2
3
/**
4
-
* @import {DiffuseElement} from "@common/element.js";
5
-
* @import {SignalReader} from "@common/signal.d.ts";
6
-
* @import {Track} from "@definitions/types.d.ts"
7
-
* @import RepeatShuffleEngine from "@components/engine/repeat-shuffle/element.js"
8
*/
9
10
////////////////////////////////////////////
···
32
// Super
33
super.connectedCallback();
34
35
-
/** @type {import("@components/engine/queue/element.js").CLASS} */
36
const queue = query(this, "queue-engine-selector");
37
38
/** @type {RepeatShuffleEngine} */
···
1
+
import { BroadcastableDiffuseElement, query } from "~/common/element.js";
2
3
/**
4
+
* @import {DiffuseElement} from "~/common/element.js";
5
+
* @import {SignalReader} from "~/common/signal.d.ts";
6
+
* @import {Track} from "~/definitions/types.d.ts"
7
+
* @import RepeatShuffleEngine from "~/components/engine/repeat-shuffle/element.js"
8
*/
9
10
////////////////////////////////////////////
···
32
// Super
33
super.connectedCallback();
34
35
+
/** @type {import("~/components/engine/queue/element.js").CLASS} */
36
const queue = query(this, "queue-engine-selector");
37
38
/** @type {RepeatShuffleEngine} */
+3
-3
src/components/orchestrator/favourites/common.js
+3
-3
src/components/orchestrator/favourites/common.js
···
1
import * as TID from "@atcute/tid";
2
3
/**
4
-
* @import {PlaylistItem, Track} from "@definitions/types.d.ts"
5
*/
6
7
/**
···
37
/**
38
* Filter playlist items that belong to the favourites playlist.
39
*
40
-
* @param {import("@definitions/types.d.ts").PlaylistItem[]} playlistItems
41
-
* @returns {import("@definitions/types.d.ts").PlaylistItem[]}
42
*/
43
export function filterFavourites(playlistItems) {
44
return playlistItems.filter((item) => item.playlist === "Favourites");
···
1
import * as TID from "@atcute/tid";
2
3
/**
4
+
* @import {PlaylistItem, Track} from "~/definitions/types.d.ts"
5
*/
6
7
/**
···
37
/**
38
* Filter playlist items that belong to the favourites playlist.
39
*
40
+
* @param {import("~/definitions/types.d.ts").PlaylistItem[]} playlistItems
41
+
* @returns {import("~/definitions/types.d.ts").PlaylistItem[]}
42
*/
43
export function filterFavourites(playlistItems) {
44
return playlistItems.filter((item) => item.playlist === "Favourites");
+6
-6
src/components/orchestrator/favourites/element.js
+6
-6
src/components/orchestrator/favourites/element.js
···
1
-
import { BroadcastableDiffuseElement, query } from "@common/element.js";
2
-
import { match as matchPlaylistItem } from "@common/playlist.js";
3
-
import { computed, signal } from "@common/signal.js";
4
import { filterFavourites } from "./common.js";
5
6
/**
7
-
* @import {Track} from "@definitions/types.d.ts"
8
-
* @import {ProxiedActions} from "@common/worker.d.ts"
9
-
* @import {OutputElement} from "@components/output/types.d.ts"
10
* @import {Actions} from "./types.d.ts"
11
*/
12
···
1
+
import { BroadcastableDiffuseElement, query } from "~/common/element.js";
2
+
import { match as matchPlaylistItem } from "~/common/playlist.js";
3
+
import { computed, signal } from "~/common/signal.js";
4
import { filterFavourites } from "./common.js";
5
6
/**
7
+
* @import {Track} from "~/definitions/types.d.ts"
8
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
9
+
* @import {OutputElement} from "~/components/output/types.d.ts"
10
* @import {Actions} from "./types.d.ts"
11
*/
12
+1
-1
src/components/orchestrator/favourites/types.d.ts
+1
-1
src/components/orchestrator/favourites/types.d.ts
+2
-2
src/components/orchestrator/favourites/worker.js
+2
-2
src/components/orchestrator/favourites/worker.js
+8
-8
src/components/orchestrator/input/element.js
+8
-8
src/components/orchestrator/input/element.js
···
1
-
import { DiffuseElement } from "@common/element.js";
2
3
-
import "@components/configurator/input/element.js";
4
-
import "@components/input/https/element.js";
5
-
import "@components/input/local/element.js";
6
-
import "@components/input/opensubsonic/element.js";
7
-
import "@components/input/s3/element.js";
8
9
/**
10
-
* @import {RenderArg} from "@common/element.d.ts"
11
-
* @import {InputActions, InputElement} from "@components/input/types.d.ts"
12
*/
13
14
////////////////////////////////////////////
···
1
+
import { DiffuseElement } from "~/common/element.js";
2
3
+
import "~/components/configurator/input/element.js";
4
+
import "~/components/input/https/element.js";
5
+
import "~/components/input/local/element.js";
6
+
import "~/components/input/opensubsonic/element.js";
7
+
import "~/components/input/s3/element.js";
8
9
/**
10
+
* @import {RenderArg} from "~/common/element.d.ts"
11
+
* @import {InputActions, InputElement} from "~/components/input/types.d.ts"
12
*/
13
14
////////////////////////////////////////////
+6
-6
src/components/orchestrator/media-session/element.js
+6
-6
src/components/orchestrator/media-session/element.js
···
2
BroadcastableDiffuseElement,
3
query,
4
queryOptional,
5
-
} from "@common/element.js";
6
7
/**
8
-
* @import {OutputElement} from "@components/output/types.d.ts"
9
-
* @import {Artwork} from "@components/processor/artwork/types.d.ts"
10
-
* @import ArtworkProcessor from "@components/processor/artwork/element.js"
11
*/
12
13
////////////////////////////////////////////
···
38
39
if (!("mediaSession" in navigator)) return;
40
41
-
/** @type {import("@components/engine/audio/element.js").CLASS} */
42
this.audio = query(this, "audio-engine-selector");
43
44
-
/** @type {import("@components/engine/queue/element.js").CLASS} */
45
this.queue = query(this, "queue-engine-selector");
46
47
/** @type {OutputElement | null} */
···
2
BroadcastableDiffuseElement,
3
query,
4
queryOptional,
5
+
} from "~/common/element.js";
6
7
/**
8
+
* @import {OutputElement} from "~/components/output/types.d.ts"
9
+
* @import {Artwork} from "~/components/processor/artwork/types.d.ts"
10
+
* @import ArtworkProcessor from "~/components/processor/artwork/element.js"
11
*/
12
13
////////////////////////////////////////////
···
38
39
if (!("mediaSession" in navigator)) return;
40
41
+
/** @type {import("~/components/engine/audio/element.js").CLASS} */
42
this.audio = query(this, "audio-engine-selector");
43
44
+
/** @type {import("~/components/engine/queue/element.js").CLASS} */
45
this.queue = query(this, "queue-engine-selector");
46
47
/** @type {OutputElement | null} */
+15
-13
src/components/orchestrator/output/element.js
+15
-13
src/components/orchestrator/output/element.js
···
1
import { ifDefined } from "lit-html/directives/if-defined.js";
2
-
import { DEFAULT_GROUP, DiffuseElement } from "@common/element.js";
3
4
-
import "@components/configurator/output/element.js";
5
-
import "@components/transformer/output/refiner/default/element.js";
6
7
/**
8
-
* @import {RenderArg} from "@common/element.d.ts"
9
-
* @import {OutputElement} from "@components/output/types.d.ts"
10
-
* @import {OutputConfiguratorElement} from "@components/configurator/output/types.d.ts"
11
*/
12
13
////////////////////////////////////////////
···
42
newlyActicated.forEach((id) => {
43
switch (id) {
44
case "do-output__dc-output__local": {
45
-
import("@components/output/polymorphic/indexed-db/element.js");
46
-
import("@components/transformer/output/string/json/element.js");
47
break;
48
}
49
case "do-output__dc-output__atproto": {
50
-
import("@components/output/raw/atproto/element.js");
51
import(
52
-
"@components/transformer/output/raw/atproto-sync/element.js"
53
);
54
import(
55
-
"@components/transformer/output/refiner/track-uri-passkey/element.js"
56
);
57
break;
58
}
59
case "do-output__dc-output__s3": {
60
-
import("@components/output/bytes/s3/element.js");
61
-
import("@components/transformer/output/bytes/dasl-sync/element.js");
62
break;
63
}
64
}
···
1
import { ifDefined } from "lit-html/directives/if-defined.js";
2
+
import { DEFAULT_GROUP, DiffuseElement } from "~/common/element.js";
3
4
+
import "~/components/configurator/output/element.js";
5
+
import "~/components/transformer/output/refiner/default/element.js";
6
7
/**
8
+
* @import {RenderArg} from "~/common/element.d.ts"
9
+
* @import {OutputElement} from "~/components/output/types.d.ts"
10
+
* @import {OutputConfiguratorElement} from "~/components/configurator/output/types.d.ts"
11
*/
12
13
////////////////////////////////////////////
···
42
newlyActicated.forEach((id) => {
43
switch (id) {
44
case "do-output__dc-output__local": {
45
+
import("~/components/output/polymorphic/indexed-db/element.js");
46
+
import("~/components/transformer/output/string/json/element.js");
47
break;
48
}
49
case "do-output__dc-output__atproto": {
50
+
import("~/components/output/raw/atproto/element.js");
51
import(
52
+
"~/components/transformer/output/raw/atproto-sync/element.js"
53
);
54
import(
55
+
"~/components/transformer/output/refiner/track-uri-passkey/element.js"
56
);
57
break;
58
}
59
case "do-output__dc-output__s3": {
60
+
import("~/components/output/bytes/s3/element.js");
61
+
import(
62
+
"~/components/transformer/output/bytes/dasl-sync/element.js"
63
+
);
64
break;
65
}
66
}
+7
-7
src/components/orchestrator/process-tracks/element.js
+7
-7
src/components/orchestrator/process-tracks/element.js
···
1
-
import { BroadcastableDiffuseElement, query } from "@common/element.js";
2
-
import { signal, untracked } from "@common/signal.js";
3
-
import { listen } from "@common/worker.js";
4
5
/**
6
-
* @import {ProxiedActions} from "@common/worker.d.ts"
7
-
* @import {InputElement} from "@components/input/types.d.ts"
8
-
* @import {OutputElement} from "@components/output/types.d.ts"
9
*
10
* @import {Actions, Progress} from "./types.d.ts"
11
*/
···
86
/** @type {OutputElement} */
87
const output = query(this, "output-selector");
88
89
-
/** @type {import("@components/processor/metadata/element.js").CLASS} */
90
const metadataProcessor = query(this, "metadata-processor-selector");
91
92
// Assign to self
···
1
+
import { BroadcastableDiffuseElement, query } from "~/common/element.js";
2
+
import { signal, untracked } from "~/common/signal.js";
3
+
import { listen } from "~/common/worker.js";
4
5
/**
6
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
7
+
* @import {InputElement} from "~/components/input/types.d.ts"
8
+
* @import {OutputElement} from "~/components/output/types.d.ts"
9
*
10
* @import {Actions, Progress} from "./types.d.ts"
11
*/
···
86
/** @type {OutputElement} */
87
const output = query(this, "output-selector");
88
89
+
/** @type {import("~/components/processor/metadata/element.js").CLASS} */
90
const metadataProcessor = query(this, "metadata-processor-selector");
91
92
// Assign to self
+1
-1
src/components/orchestrator/process-tracks/types.d.ts
+1
-1
src/components/orchestrator/process-tracks/types.d.ts
+7
-7
src/components/orchestrator/process-tracks/worker.js
+7
-7
src/components/orchestrator/process-tracks/worker.js
···
1
import deepDiff from "@fry69/deep-diff";
2
3
-
import { effect, signal } from "@common/signal.js";
4
-
import { announce, ostiary, rpc, workerProxy } from "@common/worker.js";
5
6
/**
7
-
* @import {Track} from "@definitions/types.d.ts"
8
-
* @import {ActionsWithTunnel, ProxiedActions} from "@common/worker.d.ts"
9
-
* @import {InputActions} from "@components/input/types.d.ts"
10
-
* @import {Actions as MetadataProcessorActions} from "@components/processor/metadata/types.d.ts"
11
*
12
* @import {Actions} from "./types.d.ts"
13
*/
···
16
// STATE
17
////////////////////////////////////////////
18
19
-
/** @type {import("@common/signal.d.ts").Signal<{processed: number, total: number}>} */
20
const $progress = signal({ processed: 0, total: 0 }, {
21
compare: (a, b) => !deepDiff(a, b),
22
});
···
1
import deepDiff from "@fry69/deep-diff";
2
3
+
import { effect, signal } from "~/common/signal.js";
4
+
import { announce, ostiary, rpc, workerProxy } from "~/common/worker.js";
5
6
/**
7
+
* @import {Track} from "~/definitions/types.d.ts"
8
+
* @import {ActionsWithTunnel, ProxiedActions} from "~/common/worker.d.ts"
9
+
* @import {InputActions} from "~/components/input/types.d.ts"
10
+
* @import {Actions as MetadataProcessorActions} from "~/components/processor/metadata/types.d.ts"
11
*
12
* @import {Actions} from "./types.d.ts"
13
*/
···
16
// STATE
17
////////////////////////////////////////////
18
19
+
/** @type {import("~/common/signal.d.ts").Signal<{processed: number, total: number}>} */
20
const $progress = signal({ processed: 0, total: 0 }, {
21
compare: (a, b) => !deepDiff(a, b),
22
});
+7
-7
src/components/orchestrator/queue-audio/element.js
+7
-7
src/components/orchestrator/queue-audio/element.js
···
1
-
import { BroadcastableDiffuseElement, query } from "@common/element.js";
2
-
import { untracked } from "@common/signal.js";
3
4
/**
5
-
* @import {InputElement} from "@components/input/types.d.ts"
6
-
* @import {OutputElement} from "@components/output/types.d.ts"
7
-
* @import RepeatShuffleEngine from "@components/engine/repeat-shuffle/element.js"
8
*/
9
10
////////////////////////////////////////////
···
35
// Super
36
super.connectedCallback();
37
38
-
/** @type {import("@components/engine/audio/element.js").CLASS} */
39
this.audio = query(this, "audio-engine-selector");
40
41
/** @type {InputElement} */
···
44
/** @type {OutputElement} */
45
this.output = query(this, "output-selector");
46
47
-
/** @type {import("@components/engine/queue/element.js").CLASS} */
48
this.queue = query(this, "queue-engine-selector");
49
50
/** @type {RepeatShuffleEngine} */
···
1
+
import { BroadcastableDiffuseElement, query } from "~/common/element.js";
2
+
import { untracked } from "~/common/signal.js";
3
4
/**
5
+
* @import {InputElement} from "~/components/input/types.d.ts"
6
+
* @import {OutputElement} from "~/components/output/types.d.ts"
7
+
* @import RepeatShuffleEngine from "~/components/engine/repeat-shuffle/element.js"
8
*/
9
10
////////////////////////////////////////////
···
35
// Super
36
super.connectedCallback();
37
38
+
/** @type {import("~/components/engine/audio/element.js").CLASS} */
39
this.audio = query(this, "audio-engine-selector");
40
41
/** @type {InputElement} */
···
44
/** @type {OutputElement} */
45
this.output = query(this, "output-selector");
46
47
+
/** @type {import("~/components/engine/queue/element.js").CLASS} */
48
this.queue = query(this, "queue-engine-selector");
49
50
/** @type {RepeatShuffleEngine} */
+10
-10
src/components/orchestrator/scoped-tracks/element.js
+10
-10
src/components/orchestrator/scoped-tracks/element.js
···
2
BroadcastableDiffuseElement,
3
query,
4
queryOptional,
5
-
} from "@common/element.js";
6
-
import { batch, computed, signal } from "@common/signal.js";
7
-
import { filterByPlaylist } from "@common/playlist.js";
8
9
/**
10
-
* @import {Track} from "@definitions/types.d.ts"
11
-
* @import {InputElement} from "@components/input/types.d.ts"
12
-
* @import {OutputElement} from "@components/output/types.d.ts"
13
*/
14
15
////////////////////////////////////////////
···
25
#output = signal(/** @type {OutputElement | null} */ (null));
26
27
#scope = signal(
28
-
/** @type {import("@components/engine/scope/element.js").CLASS | null} */ (null),
29
);
30
31
#search = signal(
32
-
/** @type {import("@components/processor/search/element.js").CLASS | null} */ (null),
33
);
34
35
#selectedPlaylistItems = computed(() => {
···
113
/** @type {OutputElement} */
114
const output = query(this, "output-selector");
115
116
-
/** @type {import("@components/processor/search/element.js").CLASS} */
117
const search = query(this, "search-processor-selector");
118
119
-
/** @type {import("@components/engine/scope/element.js").CLASS | null} */
120
const scope = queryOptional(this, "scope-engine-selector");
121
122
// Assign to self
···
2
BroadcastableDiffuseElement,
3
query,
4
queryOptional,
5
+
} from "~/common/element.js";
6
+
import { batch, computed, signal } from "~/common/signal.js";
7
+
import { filterByPlaylist } from "~/common/playlist.js";
8
9
/**
10
+
* @import {Track} from "~/definitions/types.d.ts"
11
+
* @import {InputElement} from "~/components/input/types.d.ts"
12
+
* @import {OutputElement} from "~/components/output/types.d.ts"
13
*/
14
15
////////////////////////////////////////////
···
25
#output = signal(/** @type {OutputElement | null} */ (null));
26
27
#scope = signal(
28
+
/** @type {import("~/components/engine/scope/element.js").CLASS | null} */ (null),
29
);
30
31
#search = signal(
32
+
/** @type {import("~/components/processor/search/element.js").CLASS | null} */ (null),
33
);
34
35
#selectedPlaylistItems = computed(() => {
···
113
/** @type {OutputElement} */
114
const output = query(this, "output-selector");
115
116
+
/** @type {import("~/components/processor/search/element.js").CLASS} */
117
const search = query(this, "search-processor-selector");
118
119
+
/** @type {import("~/components/engine/scope/element.js").CLASS | null} */
120
const scope = queryOptional(this, "scope-engine-selector");
121
122
// Assign to self
+5
-5
src/components/orchestrator/sources/element.js
+5
-5
src/components/orchestrator/sources/element.js
···
1
-
import { BroadcastableDiffuseElement, query } from "@common/element.js";
2
-
import { groupTracksPerScheme } from "@common/utils.js";
3
-
import { signal } from "@common/signal.js";
4
5
/**
6
-
* @import {InputElement, Source} from "@components/input/types.d.ts"
7
-
* @import {OutputElement} from "@components/output/types.d.ts"
8
*/
9
10
////////////////////////////////////////////
···
1
+
import { BroadcastableDiffuseElement, query } from "~/common/element.js";
2
+
import { groupTracksPerScheme } from "~/common/utils.js";
3
+
import { signal } from "~/common/signal.js";
4
5
/**
6
+
* @import {InputElement, Source} from "~/components/input/types.d.ts"
7
+
* @import {OutputElement} from "~/components/output/types.d.ts"
8
*/
9
10
////////////////////////////////////////////
+3
-3
src/components/output/bytes/s3/element.js
+3
-3
src/components/output/bytes/s3/element.js
···
1
import * as IDB from "idb-keyval";
2
3
-
import { computed, signal } from "@common/signal.js";
4
import { BroadcastedOutputElement, outputManager } from "../../common.js";
5
6
const STORAGE_PREFIX = "diffuse/output/bytes/s3";
7
8
/**
9
-
* @import {ProxiedActions} from "@common/worker.d.ts"
10
* @import {OutputElement, OutputManager} from "../../types.d.ts"
11
-
* @import {Bucket} from "@components/input/s3/types.d.ts"
12
* @import {S3OutputElement, S3OutputWorkerActions} from "./types.d.ts"
13
*/
14
···
1
import * as IDB from "idb-keyval";
2
3
+
import { computed, signal } from "~/common/signal.js";
4
import { BroadcastedOutputElement, outputManager } from "../../common.js";
5
6
const STORAGE_PREFIX = "diffuse/output/bytes/s3";
7
8
/**
9
+
* @import {ProxiedActions} from "~/common/worker.d.ts"
10
* @import {OutputElement, OutputManager} from "../../types.d.ts"
11
+
* @import {Bucket} from "~/components/input/s3/types.d.ts"
12
* @import {S3OutputElement, S3OutputWorkerActions} from "./types.d.ts"
13
*/
14
+2
-2
src/components/output/bytes/s3/types.d.ts
+2
-2
src/components/output/bytes/s3/types.d.ts
+8
-4
src/components/output/bytes/s3/worker.js
+8
-4
src/components/output/bytes/s3/worker.js
···
1
-
import { createClient } from "@components/input/s3/common.js";
2
-
import { ostiary, rpc } from "@common/worker.js";
3
4
import { OBJECT_PREFIX } from "./constants.js";
5
···
17
export async function get({ bucket, name }) {
18
const client = createClient(bucket);
19
const path = bucket.path.replace(/(^\/+|\/+$)/g, "");
20
-
const key = path ? `${path}/${OBJECT_PREFIX}${name}` : `${OBJECT_PREFIX}${name}`;
21
22
try {
23
const response = await client.getObject(key);
···
34
export async function put({ bucket, data, name }) {
35
const client = createClient(bucket);
36
const path = bucket.path.replace(/(^\/+|\/+$)/g, "");
37
-
const key = path ? `${path}/${OBJECT_PREFIX}${name}` : `${OBJECT_PREFIX}${name}`;
38
39
await client.putObject(key, data);
40
}
···
1
+
import { createClient } from "~/components/input/s3/common.js";
2
+
import { ostiary, rpc } from "~/common/worker.js";
3
4
import { OBJECT_PREFIX } from "./constants.js";
5
···
17
export async function get({ bucket, name }) {
18
const client = createClient(bucket);
19
const path = bucket.path.replace(/(^\/+|\/+$)/g, "");
20
+
const key = path
21
+
? `${path}/${OBJECT_PREFIX}${name}`
22
+
: `${OBJECT_PREFIX}${name}`;
23
24
try {
25
const response = await client.getObject(key);
···
36
export async function put({ bucket, data, name }) {
37
const client = createClient(bucket);
38
const path = bucket.path.replace(/(^\/+|\/+$)/g, "");
39
+
const key = path
40
+
? `${path}/${OBJECT_PREFIX}${name}`
41
+
: `${OBJECT_PREFIX}${name}`;
42
43
await client.putObject(key, data);
44
}
+5
-5
src/components/output/common.js
+5
-5
src/components/output/common.js
···
1
-
import { BroadcastableDiffuseElement } from "@common/element.js";
2
-
import { batch, computed, effect, signal, untracked } from "@common/signal.js";
3
-
import { strictEquality } from "@common/compare.js";
4
5
/**
6
-
* @import {Facet, PlaylistItem, Theme, Track} from "@definitions/types.d.ts"
7
-
* @import {SignalReader, SignalWriter} from "@common/signal.d.ts";
8
* @import {OutputManager, OutputManagerProperties} from "./types.d.ts"
9
*/
10
···
1
+
import { BroadcastableDiffuseElement } from "~/common/element.js";
2
+
import { batch, computed, effect, signal, untracked } from "~/common/signal.js";
3
+
import { strictEquality } from "~/common/compare.js";
4
5
/**
6
+
* @import {Facet, PlaylistItem, Theme, Track} from "~/definitions/types.d.ts"
7
+
* @import {SignalReader, SignalWriter} from "~/common/signal.d.ts";
8
* @import {OutputManager, OutputManagerProperties} from "./types.d.ts"
9
*/
10
+7
-3
src/components/output/raw/atproto/element.js
+7
-3
src/components/output/raw/atproto/element.js
···
1
import { Client, ClientResponseError, ok } from "@atcute/client";
2
import * as TID from "@atcute/tid";
3
4
-
import { computed, signal } from "@common/signal.js";
5
import { BroadcastedOutputElement, outputManager } from "../../common.js";
6
7
import {
···
14
} from "./oauth.js";
15
16
/**
17
-
* @import {PlaylistItemBundle, TrackBundle} from "@definitions/types.d.ts"
18
* @import {OutputManager} from "../../types.d.ts"
19
* @import {ATProtoOutputElement} from "./types.d.ts"
20
*/
···
331
* @param {Array<{ id: string }>} data
332
* @param {{ deleteBatchSize?: number, upsertBatchSize?: number }} [options]
333
*/
334
-
async #putRecords(collection, data, { deleteBatchSize = 100, upsertBatchSize = deleteBatchSize } = {}) {
335
const rpc = this.#rpc;
336
if (!rpc || !this.#did.value) return;
337
···
1
import { Client, ClientResponseError, ok } from "@atcute/client";
2
import * as TID from "@atcute/tid";
3
4
+
import { computed, signal } from "~/common/signal.js";
5
import { BroadcastedOutputElement, outputManager } from "../../common.js";
6
7
import {
···
14
} from "./oauth.js";
15
16
/**
17
+
* @import {PlaylistItemBundle, TrackBundle} from "~/definitions/types.d.ts"
18
* @import {OutputManager} from "../../types.d.ts"
19
* @import {ATProtoOutputElement} from "./types.d.ts"
20
*/
···
331
* @param {Array<{ id: string }>} data
332
* @param {{ deleteBatchSize?: number, upsertBatchSize?: number }} [options]
333
*/
334
+
async #putRecords(
335
+
collection,
336
+
data,
337
+
{ deleteBatchSize = 100, upsertBatchSize = deleteBatchSize } = {},
338
+
) {
339
const rpc = this.#rpc;
340
if (!rpc || !this.#did.value) return;
341
+1
-1
src/components/output/raw/atproto/types.d.ts
+1
-1
src/components/output/raw/atproto/types.d.ts
+3
-3
src/components/output/types.d.ts
+3
-3
src/components/output/types.d.ts
···
1
-
import type { Signal, SignalReader } from "@common/signal.d.ts";
2
-
import type { DiffuseElement } from "@common/element.js";
3
import type {
4
Facet,
5
PlaylistItem,
6
Theme,
7
Track,
8
-
} from "@definitions/types.d.ts";
9
10
export type OutputElement<Encoding = null> =
11
& DiffuseElement
···
1
+
import type { Signal, SignalReader } from "~/common/signal.d.ts";
2
+
import type { DiffuseElement } from "~/common/element.js";
3
import type {
4
Facet,
5
PlaylistItem,
6
Theme,
7
Track,
8
+
} from "~/definitions/types.d.ts";
9
10
export type OutputElement<Encoding = null> =
11
& DiffuseElement
+1
-1
src/components/processor/artwork/constants.js
+1
-1
src/components/processor/artwork/constants.js
+2
-2
src/components/processor/artwork/element.js
+2
-2
src/components/processor/artwork/element.js
+1
-1
src/components/processor/artwork/types.d.ts
+1
-1
src/components/processor/artwork/types.d.ts
+1
-1
src/components/processor/artwork/worker.js
+1
-1
src/components/processor/artwork/worker.js
+2
-2
src/components/processor/metadata/common.js
+2
-2
src/components/processor/metadata/common.js
···
3
import { HttpClient } from "@tokenizer/http";
4
import { tokenizer as rangeTokenizer } from "@tokenizer/range";
5
6
-
import { removeUndefinedValuesFromRecord } from "@common/utils.js";
7
8
/**
9
-
* @import { TrackStats, TrackTags } from "@definitions/types.d.ts";
10
* @import { Extraction, Urls } from "./types.d.ts";
11
*/
12
···
3
import { HttpClient } from "@tokenizer/http";
4
import { tokenizer as rangeTokenizer } from "@tokenizer/range";
5
6
+
import { removeUndefinedValuesFromRecord } from "~/common/utils.js";
7
8
/**
9
+
* @import { TrackStats, TrackTags } from "~/definitions/types.d.ts";
10
* @import { Extraction, Urls } from "./types.d.ts";
11
*/
12
+2
-2
src/components/processor/metadata/element.js
+2
-2
src/components/processor/metadata/element.js
+1
-1
src/components/processor/metadata/types.d.ts
+1
-1
src/components/processor/metadata/types.d.ts
+1
-1
src/components/processor/metadata/worker.js
+1
-1
src/components/processor/metadata/worker.js
+4
-4
src/components/processor/search/element.js
+4
-4
src/components/processor/search/element.js
+2
-2
src/components/processor/search/types.d.ts
+2
-2
src/components/processor/search/types.d.ts
+3
-3
src/components/processor/search/worker.js
+3
-3
src/components/processor/search/worker.js
···
3
// import { pluginQPS } from "@orama/plugin-qps";
4
5
import { SCHEMA } from "./constants.js";
6
-
import { announce, ostiary, rpc } from "@common/worker.js";
7
-
import { effect, signal } from "@common/signal.js";
8
9
/**
10
* @import {SearchParams} from "@orama/orama";
11
*
12
-
* @import {Track} from "@definitions/types.d.ts"
13
* @import {Actions, Schema} from "./types.d.ts"
14
*/
15
···
3
// import { pluginQPS } from "@orama/plugin-qps";
4
5
import { SCHEMA } from "./constants.js";
6
+
import { announce, ostiary, rpc } from "~/common/worker.js";
7
+
import { effect, signal } from "~/common/signal.js";
8
9
/**
10
* @import {SearchParams} from "@orama/orama";
11
*
12
+
* @import {Track} from "~/definitions/types.d.ts"
13
* @import {Actions, Schema} from "./types.d.ts"
14
*/
15
+4
-3
src/components/transformer/output/base.js
+4
-3
src/components/transformer/output/base.js
···
1
-
import { BroadcastableDiffuseElement, query } from "@common/element.js";
2
-
import { computed, signal } from "@common/signal.js";
3
4
/**
5
* @import { OutputElement, OutputManagerDeputy } from "../../output/types.d.ts"
···
67
return this.output.signal()?.playlistItems?.collection();
68
}),
69
loaded: () => {
70
-
return this.output.signal()?.playlistItems?.loaded() ?? Promise.resolve();
71
},
72
reload: () => {
73
return this.output.signal()?.playlistItems?.reload() ??
···
1
+
import { BroadcastableDiffuseElement, query } from "~/common/element.js";
2
+
import { computed, signal } from "~/common/signal.js";
3
4
/**
5
* @import { OutputElement, OutputManagerDeputy } from "../../output/types.d.ts"
···
67
return this.output.signal()?.playlistItems?.collection();
68
}),
69
loaded: () => {
70
+
return this.output.signal()?.playlistItems?.loaded() ??
71
+
Promise.resolve();
72
},
73
reload: () => {
74
return this.output.signal()?.playlistItems?.reload() ??
+6
-6
src/components/transformer/output/bytes/automerge/element.js
+6
-6
src/components/transformer/output/bytes/automerge/element.js
···
2
import { ifDefined } from "lit-html/directives/if-defined.js";
3
import { isUint8Array } from "iso-base/utils";
4
5
-
import "@components/output/polymorphic/indexed-db/element.js";
6
7
-
import { computed, signal } from "@common/signal.js";
8
import {
9
recursivelyCloneRecords,
10
removeUndefinedValuesFromRecord,
11
-
} from "@common/utils.js";
12
import { OutputTransformer } from "../../base.js";
13
import {
14
INITIAL_FACETS_DOCUMENT,
···
18
} from "./constants.js";
19
20
/**
21
-
* @import { RenderArg } from "@common/element.d.ts"
22
-
* @import { SignalReader } from "@common/signal.d.ts";
23
-
* @import { OutputElement } from "@components/output/types.d.ts";
24
*/
25
26
/**
···
2
import { ifDefined } from "lit-html/directives/if-defined.js";
3
import { isUint8Array } from "iso-base/utils";
4
5
+
import "~/components/output/polymorphic/indexed-db/element.js";
6
7
+
import { computed, signal } from "~/common/signal.js";
8
import {
9
recursivelyCloneRecords,
10
removeUndefinedValuesFromRecord,
11
+
} from "~/common/utils.js";
12
import { OutputTransformer } from "../../base.js";
13
import {
14
INITIAL_FACETS_DOCUMENT,
···
18
} from "./constants.js";
19
20
/**
21
+
* @import { RenderArg } from "~/common/element.d.ts"
22
+
* @import { SignalReader } from "~/common/signal.d.ts";
23
+
* @import { OutputElement } from "~/components/output/types.d.ts";
24
*/
25
26
/**
+1
-1
src/components/transformer/output/bytes/automerge/types.d.ts
+1
-1
src/components/transformer/output/bytes/automerge/types.d.ts
+9
-9
src/components/transformer/output/bytes/dasl-sync/element.js
+9
-9
src/components/transformer/output/bytes/dasl-sync/element.js
···
2
import { ifDefined } from "lit-html/directives/if-defined.js";
3
import deepDiff from "@fry69/deep-diff";
4
5
-
import "@components/output/polymorphic/indexed-db/element.js";
6
7
-
import * as CID from "@common/cid.js";
8
-
import { diff, strictEquality } from "@common/compare.js";
9
-
import { computed, signal } from "@common/signal.js";
10
-
import { compareTimestamps } from "@common/utils.js";
11
import { OutputTransformer } from "../../base.js";
12
-
import { promiseLoadedState } from "@components/output/common.js";
13
14
/**
15
-
* @import { SignalReader } from "@common/signal.d.ts";
16
-
* @import { RenderArg } from "@common/element.d.ts"
17
-
* @import { OutputElement } from "@components/output/types.d.ts"
18
*
19
* @import { Container } from "./types.d.ts"
20
*/
···
2
import { ifDefined } from "lit-html/directives/if-defined.js";
3
import deepDiff from "@fry69/deep-diff";
4
5
+
import "~/components/output/polymorphic/indexed-db/element.js";
6
7
+
import * as CID from "~/common/cid.js";
8
+
import { diff, strictEquality } from "~/common/compare.js";
9
+
import { computed, signal } from "~/common/signal.js";
10
+
import { compareTimestamps } from "~/common/utils.js";
11
import { OutputTransformer } from "../../base.js";
12
+
import { promiseLoadedState } from "~/components/output/common.js";
13
14
/**
15
+
* @import { SignalReader } from "~/common/signal.d.ts";
16
+
* @import { RenderArg } from "~/common/element.d.ts"
17
+
* @import { OutputElement } from "~/components/output/types.d.ts"
18
*
19
* @import { Container } from "./types.d.ts"
20
*/
+3
-3
src/components/transformer/output/bytes/json/element.js
+3
-3
src/components/transformer/output/bytes/json/element.js
+5
-5
src/components/transformer/output/raw/atproto-sync/element.js
+5
-5
src/components/transformer/output/raw/atproto-sync/element.js
···
1
import { ifDefined } from "lit-html/directives/if-defined.js";
2
3
-
import "@components/output/polymorphic/indexed-db/element.js";
4
5
-
import { computed, signal } from "@common/signal.js";
6
import { OutputTransformer } from "../../base.js";
7
import { promiseLoadedState } from "@toko/diffuse/components/output/common.js";
8
9
/**
10
-
* @import { RenderArg } from "@common/element.d.ts"
11
-
* @import { OutputElement } from "@components/output/types.d.ts"
12
-
* @import { ATProtoOutputElement } from "@components/output/raw/atproto/types.d.ts"
13
*/
14
15
const COLLECTIONS = /** @type {const} */ ([
···
1
import { ifDefined } from "lit-html/directives/if-defined.js";
2
3
+
import "~/components/output/polymorphic/indexed-db/element.js";
4
5
+
import { computed, signal } from "~/common/signal.js";
6
import { OutputTransformer } from "../../base.js";
7
import { promiseLoadedState } from "@toko/diffuse/components/output/common.js";
8
9
/**
10
+
* @import { RenderArg } from "~/common/element.d.ts"
11
+
* @import { OutputElement } from "~/components/output/types.d.ts"
12
+
* @import { ATProtoOutputElement } from "~/components/output/raw/atproto/types.d.ts"
13
*/
14
15
const COLLECTIONS = /** @type {const} */ ([
+1
-1
src/components/transformer/output/refiner/default/element.js
+1
-1
src/components/transformer/output/refiner/default/element.js
+2
-2
src/components/transformer/output/refiner/track-uri-passkey/element.js
+2
-2
src/components/transformer/output/refiner/track-uri-passkey/element.js
+2
-2
src/components/transformer/output/string/json/element.js
+2
-2
src/components/transformer/output/string/json/element.js
+1
-1
src/facets/examples/generate-playlist.inline.js
+1
-1
src/facets/examples/generate-playlist.inline.js
+2
-2
src/facets/examples/now-playing.inline.js
+2
-2
src/facets/examples/now-playing.inline.js
+7
-7
src/facets/index.js
+7
-7
src/facets/index.js
···
11
12
import * as TID from "@atcute/tid";
13
14
-
import * as CID from "@common/cid.js";
15
-
import foundation from "@common/facets/foundation.js";
16
-
import { effect, signal } from "@common/signal.js";
17
-
import { facetFromURI } from "@common/facets/utils.js";
18
-
import { nothing } from "@common/element.js";
19
-
import { loadURI } from "@common/loader.js";
20
21
/**
22
-
* @import {Facet} from "@definitions/types.d.ts"
23
*/
24
25
////////////////////////////////////////////
···
11
12
import * as TID from "@atcute/tid";
13
14
+
import * as CID from "~/common/cid.js";
15
+
import foundation from "~/common/facets/foundation.js";
16
+
import { effect, signal } from "~/common/signal.js";
17
+
import { facetFromURI } from "~/common/facets/utils.js";
18
+
import { nothing } from "~/common/element.js";
19
+
import { loadURI } from "~/common/loader.js";
20
21
/**
22
+
* @import {Facet} from "~/definitions/types.d.ts"
23
*/
24
25
////////////////////////////////////////////
+2
-2
src/facets/l/index.js
+2
-2
src/facets/l/index.js
+1
-8
src/facets/l/index.vto
+1
-8
src/facets/l/index.vto
···
22
<script type="importmap">
23
{
24
"imports": {
25
-
"@diffuse/foundation": "./common/facets/foundation.js",
26
-
27
-
"@diffuse/common/": "./common/",
28
-
"@diffuse/components/": "./components/",
29
-
"@diffuse/definitions/": "./definitions/",
30
-
"@diffuse/styles/": "./styles/",
31
-
"@diffuse/themes/": "./themes/",
32
-
"@diffuse/vendor/": "./vendor/",
33
34
"@atcute/tid": "./vendor/@atcute/tid/index.js",
35
"@awesome.me/webawesome/dist/": "./vendor/@awesome.me/webawesome/",
+3
-3
src/facets/tools/auto-queue.inline.js
+3
-3
src/facets/tools/auto-queue.inline.js
+4
-2
src/facets/tools/v3-import.inline.js
+4
-2
src/facets/tools/v3-import.inline.js
···
1
import * as TID from "@atcute/tid";
2
-
import foundation from "@diffuse/foundation";
3
4
/**
5
-
* @import {PlaylistItem, Track} from "@diffuse/definitions/types.d.ts"
6
*/
7
8
// Setup
···
103
104
try {
105
const now = new Date().toISOString();
106
const existing = output.playlistItems.collection() ?? [];
107
const existingPlaylistNames = new Set(existing.map((p) => p.playlist));
108
···
1
import * as TID from "@atcute/tid";
2
+
import foundation from "~/common/facets/foundation.js";
3
4
/**
5
+
* @import {PlaylistItem, Track} from "~/definitions/types.d.ts"
6
*/
7
8
// Setup
···
103
104
try {
105
const now = new Date().toISOString();
106
+
107
+
/** @type {any[]} */
108
const existing = output.playlistItems.collection() ?? [];
109
const existingPlaylistNames = new Set(existing.map((p) => p.playlist));
110
+7
-7
src/index.js
+7
-7
src/index.js
···
1
-
import { GROUP } from "@common/facets/foundation.js";
2
3
-
import { effect } from "@common/signal.js";
4
5
-
import InputConfigurator from "@components/configurator/input/element.js";
6
-
import MetadataProcessor from "@components/processor/metadata/element.js";
7
-
import OutputOrchestrator from "@components/orchestrator/output/element.js";
8
-
import ProcessTracksOrchestrator from "@components/orchestrator/process-tracks/element.js";
9
-
import S3Input from "@components/input/s3/element.js";
10
11
// Add components to DOM
12
const s3 = new S3Input();
···
1
+
import { GROUP } from "~/common/facets/foundation.js";
2
3
+
import { effect } from "~/common/signal.js";
4
5
+
import InputConfigurator from "~/components/configurator/input/element.js";
6
+
import MetadataProcessor from "~/components/processor/metadata/element.js";
7
+
import OutputOrchestrator from "~/components/orchestrator/output/element.js";
8
+
import ProcessTracksOrchestrator from "~/components/orchestrator/process-tracks/element.js";
9
+
import S3Input from "~/components/input/s3/element.js";
10
11
// Add components to DOM
12
const s3 = new S3Input();
+1
-1
src/testing/index.vto
+1
-1
src/testing/index.vto
+2
-2
src/testing/output.js
+2
-2
src/testing/output.js
+1
-1
src/testing/sample/tracks.js
+1
-1
src/testing/sample/tracks.js
+11
-11
src/themes/blur/artwork-controller/element.js
+11
-11
src/themes/blur/artwork-controller/element.js
···
9
DiffuseElement,
10
query,
11
whenElementsDefined,
12
-
} from "@common/element.js";
13
14
-
import { trackArtworkCacheId } from "@common/utils.js";
15
-
import { computed, signal, untracked } from "@common/signal.js";
16
17
/**
18
-
* @import {RenderArg} from "@common/element.d.ts"
19
*
20
-
* @import {InputElement} from "@components/input/types.d.ts"
21
-
* @import {OutputElement} from "@components/output/types.d.ts"
22
-
* @import {Artwork} from "@components/processor/artwork/types.d.ts"
23
-
* @import AudioEngine from "@components/engine/audio/element.js"
24
-
* @import QueueEngine from "@components/engine/queue/element.js"
25
-
* @import ArtworkProcessor from "@components/processor/artwork/element.js"
26
-
* @import FavouritesOrchestrator from "@components/orchestrator/favourites/element.js"
27
*/
28
29
class ArtworkController extends DiffuseElement {
···
9
DiffuseElement,
10
query,
11
whenElementsDefined,
12
+
} from "~/common/element.js";
13
14
+
import { trackArtworkCacheId } from "~/common/utils.js";
15
+
import { computed, signal, untracked } from "~/common/signal.js";
16
17
/**
18
+
* @import {RenderArg} from "~/common/element.d.ts"
19
*
20
+
* @import {InputElement} from "~/components/input/types.d.ts"
21
+
* @import {OutputElement} from "~/components/output/types.d.ts"
22
+
* @import {Artwork} from "~/components/processor/artwork/types.d.ts"
23
+
* @import AudioEngine from "~/components/engine/audio/element.js"
24
+
* @import QueueEngine from "~/components/engine/queue/element.js"
25
+
* @import ArtworkProcessor from "~/components/processor/artwork/element.js"
26
+
* @import FavouritesOrchestrator from "~/components/orchestrator/favourites/element.js"
27
*/
28
29
class ArtworkController extends DiffuseElement {
+2
-2
src/themes/blur/artwork-controller/facet.inline.js
+2
-2
src/themes/blur/artwork-controller/facet.inline.js
+6
-6
src/themes/index.js
+6
-6
src/themes/index.js
···
9
10
import * as TID from "@atcute/tid";
11
12
-
import * as CID from "@common/cid.js";
13
-
import foundation from "@common/facets/foundation.js";
14
-
import { effect, signal } from "@common/signal.js";
15
-
import { themeFromURI } from "@common/themes/utils.js";
16
-
import { loadURI } from "@common/loader.js";
17
18
/**
19
-
* @import {Theme} from "@definitions/types.d.ts"
20
*/
21
22
////////////////////////////////////////////
···
9
10
import * as TID from "@atcute/tid";
11
12
+
import * as CID from "~/common/cid.js";
13
+
import foundation from "~/common/facets/foundation.js";
14
+
import { effect, signal } from "~/common/signal.js";
15
+
import { themeFromURI } from "~/common/themes/utils.js";
16
+
import { loadURI } from "~/common/loader.js";
17
18
/**
19
+
* @import {Theme} from "~/definitions/types.d.ts"
20
*/
21
22
////////////////////////////////////////////
+2
-2
src/themes/l/index.js
+2
-2
src/themes/l/index.js
+4
-4
src/themes/l/index.vto
+4
-4
src/themes/l/index.vto
+15
-11
src/themes/webamp/browser/element.js
+15
-11
src/themes/webamp/browser/element.js
···
1
-
import { DiffuseElement, query, whenElementsDefined } from "@common/element.js";
2
-
import { computed, signal, untracked } from "@common/signal.js";
3
-
import * as Playlist from "@common/playlist.js";
4
5
/**
6
-
* @import {RenderArg} from "@common/element.d.ts"
7
-
* @import {SignalReader} from "@common/signal.d.ts";
8
-
* @import {Track} from "@definitions/types.d.ts"
9
-
* @import {OutputElement} from "@components/output/types.d.ts"
10
*/
11
12
const ROW_HEIGHT = 14;
···
29
);
30
31
$queue = signal(
32
-
/** @type {import("@components/engine/queue/element.js").CLASS | undefined} */ (undefined),
33
);
34
35
$scope = signal(
36
-
/** @type {import("@components/engine/scope/element.js").CLASS | undefined} */ (undefined),
37
);
38
39
$highlightedTrack = signal(/** @type {string | null} */ (null));
···
83
/** @type {DiffuseElement & { tracks: SignalReader<Track[]> }} */
84
const provider = query(this, "tracks-selector");
85
86
-
/** @type {import("@components/engine/queue/element.js").CLASS} */
87
const queue = query(this, "queue-engine-selector");
88
89
-
/** @type {import("@components/engine/scope/element.js").CLASS} */
90
const scope = query(this, "scope-engine-selector");
91
92
// Wait for the above dependencies to be defined, then render again.
···
1
+
import {
2
+
DiffuseElement,
3
+
query,
4
+
whenElementsDefined,
5
+
} from "~/common/element.js";
6
+
import { computed, signal, untracked } from "~/common/signal.js";
7
+
import * as Playlist from "~/common/playlist.js";
8
9
/**
10
+
* @import {RenderArg} from "~/common/element.d.ts"
11
+
* @import {SignalReader} from "~/common/signal.d.ts";
12
+
* @import {Track} from "~/definitions/types.d.ts"
13
+
* @import {OutputElement} from "~/components/output/types.d.ts"
14
*/
15
16
const ROW_HEIGHT = 14;
···
33
);
34
35
$queue = signal(
36
+
/** @type {import("~/components/engine/queue/element.js").CLASS | undefined} */ (undefined),
37
);
38
39
$scope = signal(
40
+
/** @type {import("~/components/engine/scope/element.js").CLASS | undefined} */ (undefined),
41
);
42
43
$highlightedTrack = signal(/** @type {string | null} */ (null));
···
87
/** @type {DiffuseElement & { tracks: SignalReader<Track[]> }} */
88
const provider = query(this, "tracks-selector");
89
90
+
/** @type {import("~/components/engine/queue/element.js").CLASS} */
91
const queue = query(this, "queue-engine-selector");
92
93
+
/** @type {import("~/components/engine/scope/element.js").CLASS} */
94
const scope = query(this, "scope-engine-selector");
95
96
// Wait for the above dependencies to be defined, then render again.
+2
-2
src/themes/webamp/browser/facet.inline.js
+2
-2
src/themes/webamp/browser/facet.inline.js
+18
-18
src/themes/webamp/configurators/input/element.js
+18
-18
src/themes/webamp/configurators/input/element.js
···
5
nothing,
6
query,
7
queryOptional,
8
-
} from "@common/element.js";
9
-
import { signal } from "@common/signal.js";
10
11
-
import { buildURI as buildOpenSubsonicURI } from "@components/input/opensubsonic/common.js";
12
-
import { buildURI as buildS3URI } from "@components/input/s3/common.js";
13
14
-
import { SCHEME as HTTPS_SCHEME } from "@components/input/https/constants.js";
15
-
import { SCHEME as LOCAL_SCHEME } from "@components/input/local/constants.js";
16
-
import { SCHEME as OPENSUBSONIC_SCHEME } from "@components/input/opensubsonic/constants.js";
17
-
import { SCHEME as S3_SCHEME } from "@components/input/s3/constants.js";
18
19
import { highlightTableEntry } from "../../common/ui.js";
20
21
/**
22
-
* @import {RenderArg} from "@common/element.d.ts"
23
-
* @import {Track} from "@definitions/types.d.ts"
24
-
* @import {InputElement} from "@components/input/types.d.ts"
25
-
* @import {OutputElement} from "@components/output/types.d.ts"
26
*
27
-
* @import {Server as OpenSubsonicServer} from "@components/input/opensubsonic/types.d.ts"
28
-
* @import {Bucket as S3Bucket} from "@components/input/s3/types.d.ts"
29
*/
30
31
class InputConfig extends DiffuseElement {
···
45
);
46
47
$sourcesOrchestrator = signal(
48
-
/** @type {import("@components/orchestrator/sources/element.js").CLASS | undefined} */ (undefined),
49
);
50
51
$processTracksOrchestrator = signal(
52
-
/** @type {import("@components/orchestrator/process-tracks/element.js").CLASS | undefined} */ (undefined),
53
);
54
55
$tab = signal("overview");
···
68
/** @type {OutputElement} */
69
const output = query(this, "output-selector");
70
71
-
/** @type {import("@components/orchestrator/sources/element.js").CLASS} */
72
const sourcesOrchestrator = query(this, "sources-orchestrator-selector");
73
74
-
/** @type {import("@components/orchestrator/process-tracks/element.js").CLASS | null} */
75
const processTracksOrchestrator = queryOptional(
76
this,
77
"process-tracks-orchestrator-selector",
···
5
nothing,
6
query,
7
queryOptional,
8
+
} from "~/common/element.js";
9
+
import { signal } from "~/common/signal.js";
10
11
+
import { buildURI as buildOpenSubsonicURI } from "~/components/input/opensubsonic/common.js";
12
+
import { buildURI as buildS3URI } from "~/components/input/s3/common.js";
13
14
+
import { SCHEME as HTTPS_SCHEME } from "~/components/input/https/constants.js";
15
+
import { SCHEME as LOCAL_SCHEME } from "~/components/input/local/constants.js";
16
+
import { SCHEME as OPENSUBSONIC_SCHEME } from "~/components/input/opensubsonic/constants.js";
17
+
import { SCHEME as S3_SCHEME } from "~/components/input/s3/constants.js";
18
19
import { highlightTableEntry } from "../../common/ui.js";
20
21
/**
22
+
* @import {RenderArg} from "~/common/element.d.ts"
23
+
* @import {Track} from "~/definitions/types.d.ts"
24
+
* @import {InputElement} from "~/components/input/types.d.ts"
25
+
* @import {OutputElement} from "~/components/output/types.d.ts"
26
*
27
+
* @import {Server as OpenSubsonicServer} from "~/components/input/opensubsonic/types.d.ts"
28
+
* @import {Bucket as S3Bucket} from "~/components/input/s3/types.d.ts"
29
*/
30
31
class InputConfig extends DiffuseElement {
···
45
);
46
47
$sourcesOrchestrator = signal(
48
+
/** @type {import("~/components/orchestrator/sources/element.js").CLASS | undefined} */ (undefined),
49
);
50
51
$processTracksOrchestrator = signal(
52
+
/** @type {import("~/components/orchestrator/process-tracks/element.js").CLASS | undefined} */ (undefined),
53
);
54
55
$tab = signal("overview");
···
68
/** @type {OutputElement} */
69
const output = query(this, "output-selector");
70
71
+
/** @type {import("~/components/orchestrator/sources/element.js").CLASS} */
72
const sourcesOrchestrator = query(this, "sources-orchestrator-selector");
73
74
+
/** @type {import("~/components/orchestrator/process-tracks/element.js").CLASS | null} */
75
const processTracksOrchestrator = queryOptional(
76
this,
77
"process-tracks-orchestrator-selector",
+2
-2
src/themes/webamp/configurators/input/facet.inline.js
+2
-2
src/themes/webamp/configurators/input/facet.inline.js
+12
-12
src/themes/webamp/configurators/output/element.js
+12
-12
src/themes/webamp/configurators/output/element.js
···
1
-
import { DiffuseElement, nothing, query } from "@common/element.js";
2
-
import { signal } from "@common/signal.js";
3
4
-
import { NAME as ATPROTO_NAME } from "@components/output/raw/atproto/element.js";
5
-
import { NAME as S3_NAME } from "@components/output/bytes/s3/element.js";
6
7
-
import { NAME as PASSKEY_NAME } from "@components/transformer/output/refiner/track-uri-passkey/element.js";
8
9
/**
10
-
* @import {ATProtoOutputElement} from "@components/output/raw/atproto/types.d.ts"
11
*
12
-
* @import {Bucket as S3Bucket} from "@components/input/s3/types.d.ts"
13
-
* @import {S3OutputElement} from "@components/output/bytes/s3/types.d.ts"
14
*
15
-
* @import {OutputElement} from "@components/output/types.d.ts"
16
-
* @import {OutputConfiguratorElement} from "@components/configurator/output/types.d.ts"
17
-
* @import TrackUriPasskeyTransformer from "@components/transformer/output/refiner/track-uri-passkey/element.js";
18
*
19
-
* @import {RenderArg} from "@common/element.d.ts"
20
*/
21
22
/**
···
1
+
import { DiffuseElement, nothing, query } from "~/common/element.js";
2
+
import { signal } from "~/common/signal.js";
3
4
+
import { NAME as ATPROTO_NAME } from "~/components/output/raw/atproto/element.js";
5
+
import { NAME as S3_NAME } from "~/components/output/bytes/s3/element.js";
6
7
+
import { NAME as PASSKEY_NAME } from "~/components/transformer/output/refiner/track-uri-passkey/element.js";
8
9
/**
10
+
* @import {ATProtoOutputElement} from "~/components/output/raw/atproto/types.d.ts"
11
*
12
+
* @import {Bucket as S3Bucket} from "~/components/input/s3/types.d.ts"
13
+
* @import {S3OutputElement} from "~/components/output/bytes/s3/types.d.ts"
14
*
15
+
* @import {OutputElement} from "~/components/output/types.d.ts"
16
+
* @import {OutputConfiguratorElement} from "~/components/configurator/output/types.d.ts"
17
+
* @import TrackUriPasskeyTransformer from "~/components/transformer/output/refiner/track-uri-passkey/element.js";
18
*
19
+
* @import {RenderArg} from "~/common/element.d.ts"
20
*/
21
22
/**
+2
-2
src/themes/webamp/configurators/output/facet.inline.js
+2
-2
src/themes/webamp/configurators/output/facet.inline.js
+16
-16
src/themes/webamp/index.js
+16
-16
src/themes/webamp/index.js
···
1
-
import "@components/engine/scope/element.js";
2
-
import "@components/input/opensubsonic/element.js";
3
-
import "@components/input/s3/element.js";
4
-
import "@components/orchestrator/input/element.js";
5
-
import "@components/orchestrator/output/element.js";
6
-
import "@components/orchestrator/process-tracks/element.js";
7
-
import "@components/orchestrator/sources/element.js";
8
-
import "@components/processor/metadata/element.js";
9
10
-
import * as Input from "@components/configurator/input/element.js";
11
-
import * as Queue from "@components/engine/queue/element.js";
12
-
import * as Search from "@components/processor/search/element.js";
13
-
import * as ScopedTracks from "@components/orchestrator/scoped-tracks/element.js";
14
15
-
import { component } from "@common/element.js";
16
-
import { effect, untracked } from "@common/signal.js";
17
18
import "./browser/element.js";
19
import "./configurators/input/element.js";
···
24
import WebampElement from "./webamp/element.js";
25
26
/**
27
-
* @import {OutputElement} from "@components/output/types.d.ts"
28
-
* @import {Track} from "@definitions/types.d.ts"
29
*/
30
31
const input = component(Input);
···
1
+
import "~/components/engine/scope/element.js";
2
+
import "~/components/input/opensubsonic/element.js";
3
+
import "~/components/input/s3/element.js";
4
+
import "~/components/orchestrator/input/element.js";
5
+
import "~/components/orchestrator/output/element.js";
6
+
import "~/components/orchestrator/process-tracks/element.js";
7
+
import "~/components/orchestrator/sources/element.js";
8
+
import "~/components/processor/metadata/element.js";
9
10
+
import * as Input from "~/components/configurator/input/element.js";
11
+
import * as Queue from "~/components/engine/queue/element.js";
12
+
import * as Search from "~/components/processor/search/element.js";
13
+
import * as ScopedTracks from "~/components/orchestrator/scoped-tracks/element.js";
14
15
+
import { component } from "~/common/element.js";
16
+
import { effect, untracked } from "~/common/signal.js";
17
18
import "./browser/element.js";
19
import "./configurators/input/element.js";
···
24
import WebampElement from "./webamp/element.js";
25
26
/**
27
+
* @import {OutputElement} from "~/components/output/types.d.ts"
28
+
* @import {Track} from "~/definitions/types.d.ts"
29
*/
30
31
const input = component(Input);
+1
-1
src/themes/webamp/webamp/element.js
+1
-1
src/themes/webamp/webamp/element.js
+18
-15
src/themes/webamp/window-manager/element.js
+18
-15
src/themes/webamp/window-manager/element.js
···
1
-
import { DiffuseElement } from "@common/element.js";
2
-
import { signal } from "@common/signal.js";
3
import { debounceMicrotask } from "@vicary/debounce-microtask";
4
5
-
import WindowElement from "../window/element.js"
6
7
/**
8
-
* @import {RenderArg} from "@common/element.d.ts"
9
*/
10
11
////////////////////////////////////////////
···
17
super();
18
this.attachShadow({ mode: "open" });
19
20
-
this.focusOnWindow = this.focusOnWindow.bind(this)
21
-
this.windowMoveStart = this.windowMoveStart.bind(this)
22
}
23
24
// SIGNALS
···
58
super.disconnectedCallback();
59
60
this.root().removeEventListener("mousedown", this.focusOnWindow);
61
-
this.root().removeEventListener("dtw-window-start-move", this.windowMoveStart);
62
63
document.body.removeEventListener(
64
"mousedown",
···
98
*/
99
async setWindowStatuses(activeId) {
100
await customElements.whenDefined("dtw-window");
101
-
this.activateWindow(activeId)
102
}
103
104
/**
···
140
* @param {string | null} activeId
141
*/
142
activateWindow(activeId) {
143
-
this.querySelectorAll("dtw-window").forEach(w => {
144
-
if (w instanceof WindowElement === false) return
145
146
if (activeId && w.id === activeId) {
147
w.activate();
148
} else {
149
w.deactivate();
150
}
151
-
})
152
}
153
154
/**
155
* @param {string} id
156
*/
157
toggleWindow(id) {
158
-
const w = this.querySelector(`dtw-window#${id}`)
159
-
if (w instanceof WindowElement === false) return
160
161
-
w.toggleAttribute("open")
162
163
if (w.hasAttribute("open")) {
164
-
this.activateWindow(id)
165
this.#lastZindex++;
166
w.style.zIndex = this.#lastZindex.toString();
167
}
···
1
+
import { DiffuseElement } from "~/common/element.js";
2
+
import { signal } from "~/common/signal.js";
3
import { debounceMicrotask } from "@vicary/debounce-microtask";
4
5
+
import WindowElement from "../window/element.js";
6
7
/**
8
+
* @import {RenderArg} from "~/common/element.d.ts"
9
*/
10
11
////////////////////////////////////////////
···
17
super();
18
this.attachShadow({ mode: "open" });
19
20
+
this.focusOnWindow = this.focusOnWindow.bind(this);
21
+
this.windowMoveStart = this.windowMoveStart.bind(this);
22
}
23
24
// SIGNALS
···
58
super.disconnectedCallback();
59
60
this.root().removeEventListener("mousedown", this.focusOnWindow);
61
+
this.root().removeEventListener(
62
+
"dtw-window-start-move",
63
+
this.windowMoveStart,
64
+
);
65
66
document.body.removeEventListener(
67
"mousedown",
···
101
*/
102
async setWindowStatuses(activeId) {
103
await customElements.whenDefined("dtw-window");
104
+
this.activateWindow(activeId);
105
}
106
107
/**
···
143
* @param {string | null} activeId
144
*/
145
activateWindow(activeId) {
146
+
this.querySelectorAll("dtw-window").forEach((w) => {
147
+
if (w instanceof WindowElement === false) return;
148
149
if (activeId && w.id === activeId) {
150
w.activate();
151
} else {
152
w.deactivate();
153
}
154
+
});
155
}
156
157
/**
158
* @param {string} id
159
*/
160
toggleWindow(id) {
161
+
const w = this.querySelector(`dtw-window#${id}`);
162
+
if (w instanceof WindowElement === false) return;
163
164
+
w.toggleAttribute("open");
165
166
if (w.hasAttribute("open")) {
167
+
this.activateWindow(id);
168
this.#lastZindex++;
169
w.style.zIndex = this.#lastZindex.toString();
170
}
+2
-2
src/themes/webamp/window/element.js
+2
-2
src/themes/webamp/window/element.js
+4
-4
tests/components/engine/queue/test.ts
+4
-4
tests/components/engine/queue/test.ts
···
7
describe("components/engine/queue", () => {
8
it("adds tracks", async () => {
9
const items = await testWeb(async () => {
10
-
const QueueEngine = await import("@components/engine/queue/element.js");
11
const engine = new QueueEngine.CLASS();
12
13
document.body.append(engine);
···
26
27
it("pools + fills tracks and shifts the queue", async () => {
28
const item = await testWeb(async () => {
29
-
const QueueEngine = await import("@components/engine/queue/element.js");
30
const engine = new QueueEngine.CLASS();
31
32
document.body.append(engine);
···
45
46
it("[shared worker] adds tracks and shifts + unshifts the queue", async () => {
47
const item = await testWeb(async () => {
48
-
const QueueEngine = await import("@components/engine/queue/element.js");
49
const engine = new QueueEngine.CLASS();
50
engine.setAttribute("group", "tests");
51
···
66
67
it("[shared worker] has the correct past", async () => {
68
const item = await testWeb(async () => {
69
-
const QueueEngine = await import("@components/engine/queue/element.js");
70
const engine = new QueueEngine.CLASS();
71
engine.setAttribute("group", "tests");
72
···
7
describe("components/engine/queue", () => {
8
it("adds tracks", async () => {
9
const items = await testWeb(async () => {
10
+
const QueueEngine = await import("~/components/engine/queue/element.js");
11
const engine = new QueueEngine.CLASS();
12
13
document.body.append(engine);
···
26
27
it("pools + fills tracks and shifts the queue", async () => {
28
const item = await testWeb(async () => {
29
+
const QueueEngine = await import("~/components/engine/queue/element.js");
30
const engine = new QueueEngine.CLASS();
31
32
document.body.append(engine);
···
45
46
it("[shared worker] adds tracks and shifts + unshifts the queue", async () => {
47
const item = await testWeb(async () => {
48
+
const QueueEngine = await import("~/components/engine/queue/element.js");
49
const engine = new QueueEngine.CLASS();
50
engine.setAttribute("group", "tests");
51
···
66
67
it("[shared worker] has the correct past", async () => {
68
const item = await testWeb(async () => {
69
+
const QueueEngine = await import("~/components/engine/queue/element.js");
70
const engine = new QueueEngine.CLASS();
71
engine.setAttribute("group", "tests");
72
+7
-7
tests/components/input/https/test.ts
+7
-7
tests/components/input/https/test.ts
···
2
import { expect } from "@std/expect";
3
4
import { testWeb } from "@tests/common/index.ts";
5
-
import type { Track } from "@definitions/types.d.ts";
6
7
describe("components/input/https", () => {
8
it("resolves HTTPS URI to same URL", async () => {
9
const resolved = await testWeb(async () => {
10
-
const HttpsInput = await import("@components/input/https/element.js");
11
const input = new HttpsInput.CLASS();
12
document.body.append(input);
13
···
24
25
it("provides sources list from tracks", async () => {
26
const sources = await testWeb(async () => {
27
-
const HttpsInput = await import("@components/input/https/element.js");
28
const input = new HttpsInput.CLASS();
29
document.body.append(input);
30
···
53
54
it("consult returns undetermined for scheme only", async () => {
55
const result = await testWeb(async () => {
56
-
const HttpsInput = await import("@components/input/https/element.js");
57
const input = new HttpsInput.CLASS();
58
document.body.append(input);
59
···
68
69
it("detaches all HTTPS tracks when given scheme", async () => {
70
const remaining = await testWeb(async () => {
71
-
const HttpsInput = await import("@components/input/https/element.js");
72
const input = new HttpsInput.CLASS();
73
document.body.append(input);
74
···
96
97
it("detaches tracks from specific domain", async () => {
98
const remaining = await testWeb(async () => {
99
-
const HttpsInput = await import("@components/input/https/element.js");
100
const input = new HttpsInput.CLASS();
101
document.body.append(input);
102
···
136
137
it("has correct SCHEME property", async () => {
138
const scheme = await testWeb(async () => {
139
-
const HttpsInput = await import("@components/input/https/element.js");
140
const input = new HttpsInput.CLASS();
141
document.body.append(input);
142
···
2
import { expect } from "@std/expect";
3
4
import { testWeb } from "@tests/common/index.ts";
5
+
import type { Track } from "~/definitions/types.d.ts";
6
7
describe("components/input/https", () => {
8
it("resolves HTTPS URI to same URL", async () => {
9
const resolved = await testWeb(async () => {
10
+
const HttpsInput = await import("~/components/input/https/element.js");
11
const input = new HttpsInput.CLASS();
12
document.body.append(input);
13
···
24
25
it("provides sources list from tracks", async () => {
26
const sources = await testWeb(async () => {
27
+
const HttpsInput = await import("~/components/input/https/element.js");
28
const input = new HttpsInput.CLASS();
29
document.body.append(input);
30
···
53
54
it("consult returns undetermined for scheme only", async () => {
55
const result = await testWeb(async () => {
56
+
const HttpsInput = await import("~/components/input/https/element.js");
57
const input = new HttpsInput.CLASS();
58
document.body.append(input);
59
···
68
69
it("detaches all HTTPS tracks when given scheme", async () => {
70
const remaining = await testWeb(async () => {
71
+
const HttpsInput = await import("~/components/input/https/element.js");
72
const input = new HttpsInput.CLASS();
73
document.body.append(input);
74
···
96
97
it("detaches tracks from specific domain", async () => {
98
const remaining = await testWeb(async () => {
99
+
const HttpsInput = await import("~/components/input/https/element.js");
100
const input = new HttpsInput.CLASS();
101
document.body.append(input);
102
···
136
137
it("has correct SCHEME property", async () => {
138
const scheme = await testWeb(async () => {
139
+
const HttpsInput = await import("~/components/input/https/element.js");
140
const input = new HttpsInput.CLASS();
141
document.body.append(input);
142
+16
-16
tests/components/orchestrator/favourites/test.ts
+16
-16
tests/components/orchestrator/favourites/test.ts
···
8
it("includes tracks", async () => {
9
const favourites = await testWeb(async () => {
10
const Output = await import(
11
-
"@components/configurator/output/element.js"
12
);
13
const Favourites = await import(
14
-
"@components/orchestrator/favourites/element.js"
15
);
16
const { tracks } = await import("@testing/sample/tracks.js");
17
···
39
it("includes multiple tracks", async () => {
40
const favourites = await testWeb(async () => {
41
const Output = await import(
42
-
"@components/configurator/output/element.js"
43
);
44
const Favourites = await import(
45
-
"@components/orchestrator/favourites/element.js"
46
);
47
const { tracks } = await import("@testing/sample/tracks.js");
48
···
72
it("does not include duplicate tracks", async () => {
73
const favourites = await testWeb(async () => {
74
const Output = await import(
75
-
"@components/configurator/output/element.js"
76
);
77
const Favourites = await import(
78
-
"@components/orchestrator/favourites/element.js"
79
);
80
const { tracks } = await import("@testing/sample/tracks.js");
81
···
102
it("does not include duplicate tracks with different casing", async () => {
103
const favourites = await testWeb(async () => {
104
const Output = await import(
105
-
"@components/configurator/output/element.js"
106
);
107
const Favourites = await import(
108
-
"@components/orchestrator/favourites/element.js"
109
);
110
const { tracks } = await import("@testing/sample/tracks.js");
111
···
139
it("expels tracks", async () => {
140
const favourites = await testWeb(async () => {
141
const Output = await import(
142
-
"@components/configurator/output/element.js"
143
);
144
const Favourites = await import(
145
-
"@components/orchestrator/favourites/element.js"
146
);
147
const { tracks } = await import("@testing/sample/tracks.js");
148
···
171
it("expels tracks with different casing", async () => {
172
const favourites = await testWeb(async () => {
173
const Output = await import(
174
-
"@components/configurator/output/element.js"
175
);
176
const Favourites = await import(
177
-
"@components/orchestrator/favourites/element.js"
178
);
179
const { tracks } = await import("@testing/sample/tracks.js");
180
···
208
it("toggles tracks", async () => {
209
const result = await testWeb(async () => {
210
const Output = await import(
211
-
"@components/configurator/output/element.js"
212
);
213
const Favourites = await import(
214
-
"@components/orchestrator/favourites/element.js"
215
);
216
const { tracks } = await import("@testing/sample/tracks.js");
217
···
247
it("toggles mixed tracks (some already favourited)", async () => {
248
const favourites = await testWeb(async () => {
249
const Output = await import(
250
-
"@components/configurator/output/element.js"
251
);
252
const Favourites = await import(
253
-
"@components/orchestrator/favourites/element.js"
254
);
255
const { tracks } = await import("@testing/sample/tracks.js");
256
···
8
it("includes tracks", async () => {
9
const favourites = await testWeb(async () => {
10
const Output = await import(
11
+
"~/components/configurator/output/element.js"
12
);
13
const Favourites = await import(
14
+
"~/components/orchestrator/favourites/element.js"
15
);
16
const { tracks } = await import("@testing/sample/tracks.js");
17
···
39
it("includes multiple tracks", async () => {
40
const favourites = await testWeb(async () => {
41
const Output = await import(
42
+
"~/components/configurator/output/element.js"
43
);
44
const Favourites = await import(
45
+
"~/components/orchestrator/favourites/element.js"
46
);
47
const { tracks } = await import("@testing/sample/tracks.js");
48
···
72
it("does not include duplicate tracks", async () => {
73
const favourites = await testWeb(async () => {
74
const Output = await import(
75
+
"~/components/configurator/output/element.js"
76
);
77
const Favourites = await import(
78
+
"~/components/orchestrator/favourites/element.js"
79
);
80
const { tracks } = await import("@testing/sample/tracks.js");
81
···
102
it("does not include duplicate tracks with different casing", async () => {
103
const favourites = await testWeb(async () => {
104
const Output = await import(
105
+
"~/components/configurator/output/element.js"
106
);
107
const Favourites = await import(
108
+
"~/components/orchestrator/favourites/element.js"
109
);
110
const { tracks } = await import("@testing/sample/tracks.js");
111
···
139
it("expels tracks", async () => {
140
const favourites = await testWeb(async () => {
141
const Output = await import(
142
+
"~/components/configurator/output/element.js"
143
);
144
const Favourites = await import(
145
+
"~/components/orchestrator/favourites/element.js"
146
);
147
const { tracks } = await import("@testing/sample/tracks.js");
148
···
171
it("expels tracks with different casing", async () => {
172
const favourites = await testWeb(async () => {
173
const Output = await import(
174
+
"~/components/configurator/output/element.js"
175
);
176
const Favourites = await import(
177
+
"~/components/orchestrator/favourites/element.js"
178
);
179
const { tracks } = await import("@testing/sample/tracks.js");
180
···
208
it("toggles tracks", async () => {
209
const result = await testWeb(async () => {
210
const Output = await import(
211
+
"~/components/configurator/output/element.js"
212
);
213
const Favourites = await import(
214
+
"~/components/orchestrator/favourites/element.js"
215
);
216
const { tracks } = await import("@testing/sample/tracks.js");
217
···
247
it("toggles mixed tracks (some already favourited)", async () => {
248
const favourites = await testWeb(async () => {
249
const Output = await import(
250
+
"~/components/configurator/output/element.js"
251
);
252
const Favourites = await import(
253
+
"~/components/orchestrator/favourites/element.js"
254
);
255
const { tracks } = await import("@testing/sample/tracks.js");
256
+3
-3
tests/components/processor/search/test.ts
+3
-3
tests/components/processor/search/test.ts
···
8
it("finds tracks by album", async () => {
9
const results = await testWeb(async () => {
10
const SearchProcessor = await import(
11
-
"@components/processor/search/element.js"
12
);
13
const processor = new SearchProcessor.CLASS();
14
···
28
it("finds tracks by artist", async () => {
29
const results = await testWeb(async () => {
30
const SearchProcessor = await import(
31
-
"@components/processor/search/element.js"
32
);
33
const processor = new SearchProcessor.CLASS();
34
···
48
it("finds tracks by title", async () => {
49
const results = await testWeb(async () => {
50
const SearchProcessor = await import(
51
-
"@components/processor/search/element.js"
52
);
53
const processor = new SearchProcessor.CLASS();
54
···
8
it("finds tracks by album", async () => {
9
const results = await testWeb(async () => {
10
const SearchProcessor = await import(
11
+
"~/components/processor/search/element.js"
12
);
13
const processor = new SearchProcessor.CLASS();
14
···
28
it("finds tracks by artist", async () => {
29
const results = await testWeb(async () => {
30
const SearchProcessor = await import(
31
+
"~/components/processor/search/element.js"
32
);
33
const processor = new SearchProcessor.CLASS();
34
···
48
it("finds tracks by title", async () => {
49
const results = await testWeb(async () => {
50
const SearchProcessor = await import(
51
+
"~/components/processor/search/element.js"
52
);
53
const processor = new SearchProcessor.CLASS();
54