metastar/metamesh-plugin-tmdb
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: metastar/metamesh-plugin-tmdb:62dbe6a539ae351bcb3da2f80de6777cde2b491a
Branches Tags
metastar/metamesh-plugin-tmdb:main
metastar/metamesh-plugin-tmdb:v1.1.0 metastar/metamesh-plugin-tmdb:v1.0.5 metastar/metamesh-plugin-tmdb:v1.0.4 metastar/metamesh-plugin-tmdb:v1.0.3 metastar/metamesh-plugin-tmdb:v1.0.2 metastar/metamesh-plugin-tmdb:v1.0.1 metastar/metamesh-plugin-tmdb:v1.0.0
...
compare: metastar/metamesh-plugin-tmdb:v1.0.3
Branches Tags
metastar/metamesh-plugin-tmdb:main
metastar/metamesh-plugin-tmdb:v1.1.0 metastar/metamesh-plugin-tmdb:v1.0.5 metastar/metamesh-plugin-tmdb:v1.0.4 metastar/metamesh-plugin-tmdb:v1.0.3 metastar/metamesh-plugin-tmdb:v1.0.2 metastar/metamesh-plugin-tmdb:v1.0.1 metastar/metamesh-plugin-tmdb:v1.0.0
9 Commits
62dbe6a539 ... v1.0.3
Author SHA1 Message Date
Worph e4fcb2bfde align with metadata standard
Build and Push Docker Image / build (push) Failing after 14s
Details
2026-09-13 15:56:06 +02:00
Worph f28f7d8594 align to metadata keys doc 2026-08-30 19:48:53 +02:00
Worph bcd1eea5a2 gitattributes
Build and Push Docker Image / build (push) Failing after 13s
Details
2026-07-14 16:01:30 +02:00
Worph bee5734251 fix webdav dependencies
Build and Push Docker Image / build (push) Failing after 14s
Details
2026-07-12 19:20:15 +02:00
Worph 0d57dbeee3 add cache 2026-07-05 22:30:06 +02:00
Worph 8b42537fae improve metadata enrichement
Build and Push Docker Image / build (push) Failing after 13s
Details
2026-06-13 16:58:40 +02:00
Pierre 334133ae46 plugin detection improvment 2026-06-06 15:24:33 +02:00
Pierre f05a09a39c bugfix 2026-05-25 23:49:46 +02:00
Pierre 47d7c42631 npm to pnpm 2026-02-08 15:29:20 +01:00
15 changed files with 2346 additions and 1103 deletions
Expand all files Collapse all files
.gitattributes
+6
View File
@@ -0,0 +1,6 @@
# FIX CRLF always when developer has not set
# Linux/Mac: git config --global core.autocrlf input
# Windows: git config --global core.autocrlf true
# Auto detect text files and perform LF normalization
* text=auto
* eol=lf
.gitignore
+1
View File
@@ -3,3 +3,4 @@ dist/
*.log *.log
.env .env
.DS_Store .DS_Store
.pnpm-store
Dockerfile
+34 -8
View File
@@ -1,16 +1,42 @@
# MetaMesh Plugin: tmdb
# Fetches metadata from TMDB API
FROM node:20-slim AS builder FROM node:20-slim AS builder
WORKDIR /app
COPY package.json tsconfig.json ./ ENV PNPM_HOME="/pnpm"
RUN npm install ENV PATH="$PNPM_HOME:$PATH"
COPY src/ ./src/ RUN npm install -g corepack@latest && corepack enable
RUN npm run build
FROM node:20-slim
WORKDIR /app WORKDIR /app
COPY package.json ./
RUN npm install --omit=dev # Copy package files first for layer caching
COPY package.json pnpm-lock.yaml ./
RUN corepack install
RUN --mount=type=cache,id=pnpm,target=/pnpm/store pnpm install --frozen-lockfile
# Copy source and build
COPY tsconfig.json ./
COPY src/ ./src/
RUN pnpm run build
# Production image
FROM node:20-slim
ENV PNPM_HOME="/pnpm"
ENV PATH="$PNPM_HOME:$PATH"
RUN npm install -g corepack@latest && corepack enable
WORKDIR /app
COPY package.json pnpm-lock.yaml ./
RUN corepack install
RUN --mount=type=cache,id=pnpm,target=/pnpm/store pnpm install --frozen-lockfile --prod
COPY --from=builder /app/dist ./dist COPY --from=builder /app/dist ./dist
EXPOSE 8080 EXPOSE 8080
HEALTHCHECK --interval=30s --timeout=5s --start-period=5s --retries=3 \ HEALTHCHECK --interval=30s --timeout=5s --start-period=5s --retries=3 \
CMD node -e "require('http').get('http://localhost:8080/health', (r) => process.exit(r.statusCode === 200 ? 0 : 1))" CMD node -e "require('http').get('http://localhost:8080/health', (r) => process.exit(r.statusCode === 200 ? 0 : 1))"
CMD ["node", "dist/index.js"] CMD ["node", "dist/index.js"]
README.md
+3 -3
View File
@@ -8,7 +8,8 @@ This plugin enriches video metadata by querying the TMDB API:
- **Search by IMDB ID**: Uses existing IMDB ID for precise matching - **Search by IMDB ID**: Uses existing IMDB ID for precise matching
- **Search by title**: Falls back to title/year search - **Search by title**: Falls back to title/year search
- **Image download**: Downloads poster and backdrop images to `/files/poster/` - **Image download**: Downloads poster and backdrop images to `/files/plugin/tmdb/`
- **Alternative posters**: Lists up to 10 posters (the primary plus the best-voted alternatives, as `url` locator CIDs — nothing extra is downloaded)
- **Rich metadata**: Fetches plot, rating, genres, studios - **Rich metadata**: Fetches plot, rating, genres, studios
**Note**: This runs on the background queue as it makes external API calls. **Note**: This runs on the background queue as it makes external API calls.
@@ -26,9 +27,8 @@ This plugin enriches video metadata by querying the TMDB API:
| `rating` | Vote average | | `rating` | Vote average |
| `plot/eng` | English plot synopsis | | `plot/eng` | English plot synopsis |
| `poster` | Poster image CID | | `poster` | Poster image CID |
| `posterPath` | Poster file path | | `posters/{lang3}/{cid}` | Alternative posters key-set, `poster` among them (METADATA_KEYS.md §6) |
| `backdrop` | Backdrop image CID | | `backdrop` | Backdrop image CID |
| `backdropPath` | Backdrop file path |
| `genres` | Genre set | | `genres` | Genre set |
| `studio` | Production company set | | `studio` | Production company set |
package-lock.json
Generated
-927
View File
@@ -1,927 +0,0 @@
{
"name": "@metazla/plugin-tmdb",
"version": "1.0.0",
"lockfileVersion": 3,
"requires": true,
"packages": {
"": {
"name": "@metazla/plugin-tmdb",
"version": "1.0.0",
"dependencies": {
"axios": "^1.6.0",
"fastify": "^5.0.0"
},
"devDependencies": {
"@types/node": "^20.0.0",
"typescript": "^5.3.0"
}
},
"node_modules/@fastify/ajv-compiler": {
"version": "4.0.5",
"resolved": "https://registry.npmjs.org/@fastify/ajv-compiler/-/ajv-compiler-4.0.5.tgz",
"integrity": "sha512-KoWKW+MhvfTRWL4qrhUwAAZoaChluo0m0vbiJlGMt2GXvL4LVPQEjt8kSpHI3IBq5Rez8fg+XeH3cneztq+C7A==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"ajv": "^8.12.0",
"ajv-formats": "^3.0.1",
"fast-uri": "^3.0.0"
}
},
"node_modules/@fastify/error": {
"version": "4.2.0",
"resolved": "https://registry.npmjs.org/@fastify/error/-/error-4.2.0.tgz",
"integrity": "sha512-RSo3sVDXfHskiBZKBPRgnQTtIqpi/7zhJOEmAxCiBcM7d0uwdGdxLlsCaLzGs8v8NnxIRlfG0N51p5yFaOentQ==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT"
},
"node_modules/@fastify/fast-json-stringify-compiler": {
"version": "5.0.3",
"resolved": "https://registry.npmjs.org/@fastify/fast-json-stringify-compiler/-/fast-json-stringify-compiler-5.0.3.tgz",
"integrity": "sha512-uik7yYHkLr6fxd8hJSZ8c+xF4WafPK+XzneQDPU+D10r5X19GW8lJcom2YijX2+qtFF1ENJlHXKFM9ouXNJYgQ==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"fast-json-stringify": "^6.0.0"
}
},
"node_modules/@fastify/forwarded": {
"version": "3.0.1",
"resolved": "https://registry.npmjs.org/@fastify/forwarded/-/forwarded-3.0.1.tgz",
"integrity": "sha512-JqDochHFqXs3C3Ml3gOY58zM7OqO9ENqPo0UqAjAjH8L01fRZqwX9iLeX34//kiJubF7r2ZQHtBRU36vONbLlw==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT"
},
"node_modules/@fastify/merge-json-schemas": {
"version": "0.2.1",
"resolved": "https://registry.npmjs.org/@fastify/merge-json-schemas/-/merge-json-schemas-0.2.1.tgz",
"integrity": "sha512-OA3KGBCy6KtIvLf8DINC5880o5iBlDX4SxzLQS8HorJAbqluzLRn80UXU0bxZn7UOFhFgpRJDasfwn9nG4FG4A==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"dequal": "^2.0.3"
}
},
"node_modules/@fastify/proxy-addr": {
"version": "5.1.0",
"resolved": "https://registry.npmjs.org/@fastify/proxy-addr/-/proxy-addr-5.1.0.tgz",
"integrity": "sha512-INS+6gh91cLUjB+PVHfu1UqcB76Sqtpyp7bnL+FYojhjygvOPA9ctiD/JDKsyD9Xgu4hUhCSJBPig/w7duNajw==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"@fastify/forwarded": "^3.0.0",
"ipaddr.js": "^2.1.0"
}
},
"node_modules/@pinojs/redact": {
"version": "0.4.0",
"resolved": "https://registry.npmjs.org/@pinojs/redact/-/redact-0.4.0.tgz",
"integrity": "sha512-k2ENnmBugE/rzQfEcdWHcCY+/FM3VLzH9cYEsbdsoqrvzAKRhUZeRNhAZvB8OitQJ1TBed3yqWtdjzS6wJKBwg==",
"license": "MIT"
},
"node_modules/@types/node": {
"version": "20.19.28",
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.19.28.tgz",
"integrity": "sha512-VyKBr25BuFDzBFCK5sUM6ZXiWfqgCTwTAOK8qzGV/m9FCirXYDlmczJ+d5dXBAQALGCdRRdbteKYfJ84NGEusw==",
"dev": true,
"license": "MIT",
"dependencies": {
"undici-types": "~6.21.0"
}
},
"node_modules/abstract-logging": {
"version": "2.0.1",
"resolved": "https://registry.npmjs.org/abstract-logging/-/abstract-logging-2.0.1.tgz",
"integrity": "sha512-2BjRTZxTPvheOvGbBslFSYOUkr+SjPtOnrLP33f+VIWLzezQpZcqVg7ja3L4dBXmzzgwT+a029jRx5PCi3JuiA==",
"license": "MIT"
},
"node_modules/ajv": {
"version": "8.17.1",
"resolved": "https://registry.npmjs.org/ajv/-/ajv-8.17.1.tgz",
"integrity": "sha512-B/gBuNg5SiMTrPkC+A2+cW0RszwxYmn6VYxB/inlBStS5nx6xHIt/ehKRhIMhqusl7a8LjQoZnjCs5vhwxOQ1g==",
"license": "MIT",
"dependencies": {
"fast-deep-equal": "^3.1.3",
"fast-uri": "^3.0.1",
"json-schema-traverse": "^1.0.0",
"require-from-string": "^2.0.2"
},
"funding": {
"type": "github",
"url": "https://github.com/sponsors/epoberezkin"
}
},
"node_modules/ajv-formats": {
"version": "3.0.1",
"resolved": "https://registry.npmjs.org/ajv-formats/-/ajv-formats-3.0.1.tgz",
"integrity": "sha512-8iUql50EUR+uUcdRQ3HDqa6EVyo3docL8g5WJ3FNcWmu62IbkGUue/pEyLBW8VGKKucTPgqeks4fIU1DA4yowQ==",
"license": "MIT",
"dependencies": {
"ajv": "^8.0.0"
},
"peerDependencies": {
"ajv": "^8.0.0"
},
"peerDependenciesMeta": {
"ajv": {
"optional": true
}
}
},
"node_modules/asynckit": {
"version": "0.4.0",
"resolved": "https://registry.npmjs.org/asynckit/-/asynckit-0.4.0.tgz",
"integrity": "sha512-Oei9OH4tRh0YqU3GxhX79dM/mwVgvbZJaSNaRk+bshkj0S5cfHcgYakreBjrHwatXKbz+IoIdYLxrKim2MjW0Q==",
"license": "MIT"
},
"node_modules/atomic-sleep": {
"version": "1.0.0",
"resolved": "https://registry.npmjs.org/atomic-sleep/-/atomic-sleep-1.0.0.tgz",
"integrity": "sha512-kNOjDqAh7px0XWNI+4QbzoiR/nTkHAWNud2uvnJquD1/x5a7EQZMJT0AczqK0Qn67oY/TTQ1LbUKajZpp3I9tQ==",
"license": "MIT",
"engines": {
"node": ">=8.0.0"
}
},
"node_modules/avvio": {
"version": "9.1.0",
"resolved": "https://registry.npmjs.org/avvio/-/avvio-9.1.0.tgz",
"integrity": "sha512-fYASnYi600CsH/j9EQov7lECAniYiBFiiAtBNuZYLA2leLe9qOvZzqYHFjtIj6gD2VMoMLP14834LFWvr4IfDw==",
"license": "MIT",
"dependencies": {
"@fastify/error": "^4.0.0",
"fastq": "^1.17.1"
}
},
"node_modules/axios": {
"version": "1.13.2",
"resolved": "https://registry.npmjs.org/axios/-/axios-1.13.2.tgz",
"integrity": "sha512-VPk9ebNqPcy5lRGuSlKx752IlDatOjT9paPlm8A7yOuW2Fbvp4X3JznJtT4f0GzGLLiWE9W8onz51SqLYwzGaA==",
"license": "MIT",
"dependencies": {
"follow-redirects": "^1.15.6",
"form-data": "^4.0.4",
"proxy-from-env": "^1.1.0"
}
},
"node_modules/call-bind-apply-helpers": {
"version": "1.0.2",
"resolved": "https://registry.npmjs.org/call-bind-apply-helpers/-/call-bind-apply-helpers-1.0.2.tgz",
"integrity": "sha512-Sp1ablJ0ivDkSzjcaJdxEunN5/XvksFJ2sMBFfq6x0ryhQV/2b/KwFe21cMpmHtPOSij8K99/wSfoEuTObmuMQ==",
"license": "MIT",
"dependencies": {
"es-errors": "^1.3.0",
"function-bind": "^1.1.2"
},
"engines": {
"node": ">= 0.4"
}
},
"node_modules/combined-stream": {
"version": "1.0.8",
"resolved": "https://registry.npmjs.org/combined-stream/-/combined-stream-1.0.8.tgz",
"integrity": "sha512-FQN4MRfuJeHf7cBbBMJFXhKSDq+2kAArBlmRBvcvFE5BB1HZKXtSFASDhdlz9zOYwxh8lDdnvmMOe/+5cdoEdg==",
"license": "MIT",
"dependencies": {
"delayed-stream": "~1.0.0"
},
"engines": {
"node": ">= 0.8"
}
},
"node_modules/cookie": {
"version": "1.1.1",
"resolved": "https://registry.npmjs.org/cookie/-/cookie-1.1.1.tgz",
"integrity": "sha512-ei8Aos7ja0weRpFzJnEA9UHJ/7XQmqglbRwnf2ATjcB9Wq874VKH9kfjjirM6UhU2/E5fFYadylyhFldcqSidQ==",
"license": "MIT",
"engines": {
"node": ">=18"
},
"funding": {
"type": "opencollective",
"url": "https://opencollective.com/express"
}
},
"node_modules/delayed-stream": {
"version": "1.0.0",
"resolved": "https://registry.npmjs.org/delayed-stream/-/delayed-stream-1.0.0.tgz",
"integrity": "sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ==",
"license": "MIT",
"engines": {
"node": ">=0.4.0"
}
},
"node_modules/dequal": {
"version": "2.0.3",
"resolved": "https://registry.npmjs.org/dequal/-/dequal-2.0.3.tgz",
"integrity": "sha512-0je+qPKHEMohvfRTCEo3CrPG6cAzAYgmzKyxRiYSSDkS6eGJdyVJm7WaYA5ECaAD9wLB2T4EEeymA5aFVcYXCA==",
"license": "MIT",
"engines": {
"node": ">=6"
}
},
"node_modules/dunder-proto": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/dunder-proto/-/dunder-proto-1.0.1.tgz",
"integrity": "sha512-KIN/nDJBQRcXw0MLVhZE9iQHmG68qAVIBg9CqmUYjmQIhgij9U5MFvrqkUL5FbtyyzZuOeOt0zdeRe4UY7ct+A==",
"license": "MIT",
"dependencies": {
"call-bind-apply-helpers": "^1.0.1",
"es-errors": "^1.3.0",
"gopd": "^1.2.0"
},
"engines": {
"node": ">= 0.4"
}
},
"node_modules/es-define-property": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/es-define-property/-/es-define-property-1.0.1.tgz",
"integrity": "sha512-e3nRfgfUZ4rNGL232gUgX06QNyyez04KdjFrF+LTRoOXmrOgFKDg4BCdsjW8EnT69eqdYGmRpJwiPVYNrCaW3g==",
"license": "MIT",
"engines": {
"node": ">= 0.4"
}
},
"node_modules/es-errors": {
"version": "1.3.0",
"resolved": "https://registry.npmjs.org/es-errors/-/es-errors-1.3.0.tgz",
"integrity": "sha512-Zf5H2Kxt2xjTvbJvP2ZWLEICxA6j+hAmMzIlypy4xcBg1vKVnx89Wy0GbS+kf5cwCVFFzdCFh2XSCFNULS6csw==",
"license": "MIT",
"engines": {
"node": ">= 0.4"
}
},
"node_modules/es-object-atoms": {
"version": "1.1.1",
"resolved": "https://registry.npmjs.org/es-object-atoms/-/es-object-atoms-1.1.1.tgz",
"integrity": "sha512-FGgH2h8zKNim9ljj7dankFPcICIK9Cp5bm+c2gQSYePhpaG5+esrLODihIorn+Pe6FGJzWhXQotPv73jTaldXA==",
"license": "MIT",
"dependencies": {
"es-errors": "^1.3.0"
},
"engines": {
"node": ">= 0.4"
}
},
"node_modules/es-set-tostringtag": {
"version": "2.1.0",
"resolved": "https://registry.npmjs.org/es-set-tostringtag/-/es-set-tostringtag-2.1.0.tgz",
"integrity": "sha512-j6vWzfrGVfyXxge+O0x5sh6cvxAog0a/4Rdd2K36zCMV5eJ+/+tOAngRO8cODMNWbVRdVlmGZQL2YS3yR8bIUA==",
"license": "MIT",
"dependencies": {
"es-errors": "^1.3.0",
"get-intrinsic": "^1.2.6",
"has-tostringtag": "^1.0.2",
"hasown": "^2.0.2"
},
"engines": {
"node": ">= 0.4"
}
},
"node_modules/fast-decode-uri-component": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/fast-decode-uri-component/-/fast-decode-uri-component-1.0.1.tgz",
"integrity": "sha512-WKgKWg5eUxvRZGwW8FvfbaH7AXSh2cL+3j5fMGzUMCxWBJ3dV3a7Wz8y2f/uQ0e3B6WmodD3oS54jTQ9HVTIIg==",
"license": "MIT"
},
"node_modules/fast-deep-equal": {
"version": "3.1.3",
"resolved": "https://registry.npmjs.org/fast-deep-equal/-/fast-deep-equal-3.1.3.tgz",
"integrity": "sha512-f3qQ9oQy9j2AhBe/H9VC91wLmKBCCU/gDOnKNAYG5hswO7BLKj09Hc5HYNz9cGI++xlpDCIgDaitVs03ATR84Q==",
"license": "MIT"
},
"node_modules/fast-json-stringify": {
"version": "6.1.1",
"resolved": "https://registry.npmjs.org/fast-json-stringify/-/fast-json-stringify-6.1.1.tgz",
"integrity": "sha512-DbgptncYEXZqDUOEl4krff4mUiVrTZZVI7BBrQR/T3BqMj/eM1flTC1Uk2uUoLcWCxjT95xKulV/Lc6hhOZsBQ==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"@fastify/merge-json-schemas": "^0.2.0",
"ajv": "^8.12.0",
"ajv-formats": "^3.0.1",
"fast-uri": "^3.0.0",
"json-schema-ref-resolver": "^3.0.0",
"rfdc": "^1.2.0"
}
},
"node_modules/fast-querystring": {
"version": "1.1.2",
"resolved": "https://registry.npmjs.org/fast-querystring/-/fast-querystring-1.1.2.tgz",
"integrity": "sha512-g6KuKWmFXc0fID8WWH0jit4g0AGBoJhCkJMb1RmbsSEUNvQ+ZC8D6CUZ+GtF8nMzSPXnhiePyyqqipzNNEnHjg==",
"license": "MIT",
"dependencies": {
"fast-decode-uri-component": "^1.0.1"
}
},
"node_modules/fast-uri": {
"version": "3.1.0",
"resolved": "https://registry.npmjs.org/fast-uri/-/fast-uri-3.1.0.tgz",
"integrity": "sha512-iPeeDKJSWf4IEOasVVrknXpaBV0IApz/gp7S2bb7Z4Lljbl2MGJRqInZiUrQwV16cpzw/D3S5j5Julj/gT52AA==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "BSD-3-Clause"
},
"node_modules/fastify": {
"version": "5.6.2",
"resolved": "https://registry.npmjs.org/fastify/-/fastify-5.6.2.tgz",
"integrity": "sha512-dPugdGnsvYkBlENLhCgX8yhyGCsCPrpA8lFWbTNU428l+YOnLgYHR69hzV8HWPC79n536EqzqQtvhtdaCE0dKg==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"@fastify/ajv-compiler": "^4.0.0",
"@fastify/error": "^4.0.0",
"@fastify/fast-json-stringify-compiler": "^5.0.0",
"@fastify/proxy-addr": "^5.0.0",
"abstract-logging": "^2.0.1",
"avvio": "^9.0.0",
"fast-json-stringify": "^6.0.0",
"find-my-way": "^9.0.0",
"light-my-request": "^6.0.0",
"pino": "^10.1.0",
"process-warning": "^5.0.0",
"rfdc": "^1.3.1",
"secure-json-parse": "^4.0.0",
"semver": "^7.6.0",
"toad-cache": "^3.7.0"
}
},
"node_modules/fastq": {
"version": "1.20.1",
"resolved": "https://registry.npmjs.org/fastq/-/fastq-1.20.1.tgz",
"integrity": "sha512-GGToxJ/w1x32s/D2EKND7kTil4n8OVk/9mycTc4VDza13lOvpUZTGX3mFSCtV9ksdGBVzvsyAVLM6mHFThxXxw==",
"license": "ISC",
"dependencies": {
"reusify": "^1.0.4"
}
},
"node_modules/find-my-way": {
"version": "9.4.0",
"resolved": "https://registry.npmjs.org/find-my-way/-/find-my-way-9.4.0.tgz",
"integrity": "sha512-5Ye4vHsypZRYtS01ob/iwHzGRUDELlsoCftI/OZFhcLs1M0tkGPcXldE80TAZC5yYuJMBPJQQ43UHlqbJWiX2w==",
"license": "MIT",
"dependencies": {
"fast-deep-equal": "^3.1.3",
"fast-querystring": "^1.0.0",
"safe-regex2": "^5.0.0"
},
"engines": {
"node": ">=20"
}
},
"node_modules/follow-redirects": {
"version": "1.15.11",
"resolved": "https://registry.npmjs.org/follow-redirects/-/follow-redirects-1.15.11.tgz",
"integrity": "sha512-deG2P0JfjrTxl50XGCDyfI97ZGVCxIpfKYmfyrQ54n5FO/0gfIES8C/Psl6kWVDolizcaaxZJnTS0QSMxvnsBQ==",
"funding": [
{
"type": "individual",
"url": "https://github.com/sponsors/RubenVerborgh"
}
],
"license": "MIT",
"engines": {
"node": ">=4.0"
},
"peerDependenciesMeta": {
"debug": {
"optional": true
}
}
},
"node_modules/form-data": {
"version": "4.0.5",
"resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.5.tgz",
"integrity": "sha512-8RipRLol37bNs2bhoV67fiTEvdTrbMUYcFTiy3+wuuOnUog2QBHCZWXDRijWQfAkhBj2Uf5UnVaiWwA5vdd82w==",
"license": "MIT",
"dependencies": {
"asynckit": "^0.4.0",
"combined-stream": "^1.0.8",
"es-set-tostringtag": "^2.1.0",
"hasown": "^2.0.2",
"mime-types": "^2.1.12"
},
"engines": {
"node": ">= 6"
}
},
"node_modules/function-bind": {
"version": "1.1.2",
"resolved": "https://registry.npmjs.org/function-bind/-/function-bind-1.1.2.tgz",
"integrity": "sha512-7XHNxH7qX9xG5mIwxkhumTox/MIRNcOgDrxWsMt2pAr23WHp6MrRlN7FBSFpCpr+oVO0F744iUgR82nJMfG2SA==",
"license": "MIT",
"funding": {
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/get-intrinsic": {
"version": "1.3.0",
"resolved": "https://registry.npmjs.org/get-intrinsic/-/get-intrinsic-1.3.0.tgz",
"integrity": "sha512-9fSjSaos/fRIVIp+xSJlE6lfwhES7LNtKaCBIamHsjr2na1BiABJPo0mOjjz8GJDURarmCPGqaiVg5mfjb98CQ==",
"license": "MIT",
"dependencies": {
"call-bind-apply-helpers": "^1.0.2",
"es-define-property": "^1.0.1",
"es-errors": "^1.3.0",
"es-object-atoms": "^1.1.1",
"function-bind": "^1.1.2",
"get-proto": "^1.0.1",
"gopd": "^1.2.0",
"has-symbols": "^1.1.0",
"hasown": "^2.0.2",
"math-intrinsics": "^1.1.0"
},
"engines": {
"node": ">= 0.4"
},
"funding": {
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/get-proto": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/get-proto/-/get-proto-1.0.1.tgz",
"integrity": "sha512-sTSfBjoXBp89JvIKIefqw7U2CCebsc74kiY6awiGogKtoSGbgjYE/G/+l9sF3MWFPNc9IcoOC4ODfKHfxFmp0g==",
"license": "MIT",
"dependencies": {
"dunder-proto": "^1.0.1",
"es-object-atoms": "^1.0.0"
},
"engines": {
"node": ">= 0.4"
}
},
"node_modules/gopd": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/gopd/-/gopd-1.2.0.tgz",
"integrity": "sha512-ZUKRh6/kUFoAiTAtTYPZJ3hw9wNxx+BIBOijnlG9PnrJsCcSjs1wyyD6vJpaYtgnzDrKYRSqf3OO6Rfa93xsRg==",
"license": "MIT",
"engines": {
"node": ">= 0.4"
},
"funding": {
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/has-symbols": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/has-symbols/-/has-symbols-1.1.0.tgz",
"integrity": "sha512-1cDNdwJ2Jaohmb3sg4OmKaMBwuC48sYni5HUw2DvsC8LjGTLK9h+eb1X6RyuOHe4hT0ULCW68iomhjUoKUqlPQ==",
"license": "MIT",
"engines": {
"node": ">= 0.4"
},
"funding": {
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/has-tostringtag": {
"version": "1.0.2",
"resolved": "https://registry.npmjs.org/has-tostringtag/-/has-tostringtag-1.0.2.tgz",
"integrity": "sha512-NqADB8VjPFLM2V0VvHUewwwsw0ZWBaIdgo+ieHtK3hasLz4qeCRjYcqfB6AQrBggRKppKF8L52/VqdVsO47Dlw==",
"license": "MIT",
"dependencies": {
"has-symbols": "^1.0.3"
},
"engines": {
"node": ">= 0.4"
},
"funding": {
"url": "https://github.com/sponsors/ljharb"
}
},
"node_modules/hasown": {
"version": "2.0.2",
"resolved": "https://registry.npmjs.org/hasown/-/hasown-2.0.2.tgz",
"integrity": "sha512-0hJU9SCPvmMzIBdZFqNPXWa6dqh7WdH0cII9y+CyS8rG3nL48Bclra9HmKhVVUHyPWNH5Y7xDwAB7bfgSjkUMQ==",
"license": "MIT",
"dependencies": {
"function-bind": "^1.1.2"
},
"engines": {
"node": ">= 0.4"
}
},
"node_modules/ipaddr.js": {
"version": "2.3.0",
"resolved": "https://registry.npmjs.org/ipaddr.js/-/ipaddr.js-2.3.0.tgz",
"integrity": "sha512-Zv/pA+ciVFbCSBBjGfaKUya/CcGmUHzTydLMaTwrUUEM2DIEO3iZvueGxmacvmN50fGpGVKeTXpb2LcYQxeVdg==",
"license": "MIT",
"engines": {
"node": ">= 10"
}
},
"node_modules/json-schema-ref-resolver": {
"version": "3.0.0",
"resolved": "https://registry.npmjs.org/json-schema-ref-resolver/-/json-schema-ref-resolver-3.0.0.tgz",
"integrity": "sha512-hOrZIVL5jyYFjzk7+y7n5JDzGlU8rfWDuYyHwGa2WA8/pcmMHezp2xsVwxrebD/Q9t8Nc5DboieySDpCp4WG4A==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"dequal": "^2.0.3"
}
},
"node_modules/json-schema-traverse": {
"version": "1.0.0",
"resolved": "https://registry.npmjs.org/json-schema-traverse/-/json-schema-traverse-1.0.0.tgz",
"integrity": "sha512-NM8/P9n3XjXhIZn1lLhkFaACTOURQXjWhV4BA/RnOv8xvgqtqpAX9IO4mRQxSx1Rlo4tqzeqb0sOlruaOy3dug==",
"license": "MIT"
},
"node_modules/light-my-request": {
"version": "6.6.0",
"resolved": "https://registry.npmjs.org/light-my-request/-/light-my-request-6.6.0.tgz",
"integrity": "sha512-CHYbu8RtboSIoVsHZ6Ye4cj4Aw/yg2oAFimlF7mNvfDV192LR7nDiKtSIfCuLT7KokPSTn/9kfVLm5OGN0A28A==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "BSD-3-Clause",
"dependencies": {
"cookie": "^1.0.1",
"process-warning": "^4.0.0",
"set-cookie-parser": "^2.6.0"
}
},
"node_modules/light-my-request/node_modules/process-warning": {
"version": "4.0.1",
"resolved": "https://registry.npmjs.org/process-warning/-/process-warning-4.0.1.tgz",
"integrity": "sha512-3c2LzQ3rY9d0hc1emcsHhfT9Jwz0cChib/QN89oME2R451w5fy3f0afAhERFZAwrbDU43wk12d0ORBpDVME50Q==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT"
},
"node_modules/math-intrinsics": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/math-intrinsics/-/math-intrinsics-1.1.0.tgz",
"integrity": "sha512-/IXtbwEk5HTPyEwyKX6hGkYXxM9nbj64B+ilVJnC/R6B0pH5G4V3b0pVbL7DBj4tkhBAppbQUlf6F6Xl9LHu1g==",
"license": "MIT",
"engines": {
"node": ">= 0.4"
}
},
"node_modules/mime-db": {
"version": "1.52.0",
"resolved": "https://registry.npmjs.org/mime-db/-/mime-db-1.52.0.tgz",
"integrity": "sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg==",
"license": "MIT",
"engines": {
"node": ">= 0.6"
}
},
"node_modules/mime-types": {
"version": "2.1.35",
"resolved": "https://registry.npmjs.org/mime-types/-/mime-types-2.1.35.tgz",
"integrity": "sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw==",
"license": "MIT",
"dependencies": {
"mime-db": "1.52.0"
},
"engines": {
"node": ">= 0.6"
}
},
"node_modules/on-exit-leak-free": {
"version": "2.1.2",
"resolved": "https://registry.npmjs.org/on-exit-leak-free/-/on-exit-leak-free-2.1.2.tgz",
"integrity": "sha512-0eJJY6hXLGf1udHwfNftBqH+g73EU4B504nZeKpz1sYRKafAghwxEJunB2O7rDZkL4PGfsMVnTXZ2EjibbqcsA==",
"license": "MIT",
"engines": {
"node": ">=14.0.0"
}
},
"node_modules/pino": {
"version": "10.1.1",
"resolved": "https://registry.npmjs.org/pino/-/pino-10.1.1.tgz",
"integrity": "sha512-3qqVfpJtRQUCAOs4rTOEwLH6mwJJ/CSAlbis8fKOiMzTtXh0HN/VLsn3UWVTJ7U8DsWmxeNon2IpGb+wORXH4g==",
"license": "MIT",
"dependencies": {
"@pinojs/redact": "^0.4.0",
"atomic-sleep": "^1.0.0",
"on-exit-leak-free": "^2.1.0",
"pino-abstract-transport": "^3.0.0",
"pino-std-serializers": "^7.0.0",
"process-warning": "^5.0.0",
"quick-format-unescaped": "^4.0.3",
"real-require": "^0.2.0",
"safe-stable-stringify": "^2.3.1",
"sonic-boom": "^4.0.1",
"thread-stream": "^4.0.0"
},
"bin": {
"pino": "bin.js"
}
},
"node_modules/pino-abstract-transport": {
"version": "3.0.0",
"resolved": "https://registry.npmjs.org/pino-abstract-transport/-/pino-abstract-transport-3.0.0.tgz",
"integrity": "sha512-wlfUczU+n7Hy/Ha5j9a/gZNy7We5+cXp8YL+X+PG8S0KXxw7n/JXA3c46Y0zQznIJ83URJiwy7Lh56WLokNuxg==",
"license": "MIT",
"dependencies": {
"split2": "^4.0.0"
}
},
"node_modules/pino-std-serializers": {
"version": "7.0.0",
"resolved": "https://registry.npmjs.org/pino-std-serializers/-/pino-std-serializers-7.0.0.tgz",
"integrity": "sha512-e906FRY0+tV27iq4juKzSYPbUj2do2X2JX4EzSca1631EB2QJQUqGbDuERal7LCtOpxl6x3+nvo9NPZcmjkiFA==",
"license": "MIT"
},
"node_modules/process-warning": {
"version": "5.0.0",
"resolved": "https://registry.npmjs.org/process-warning/-/process-warning-5.0.0.tgz",
"integrity": "sha512-a39t9ApHNx2L4+HBnQKqxxHNs1r7KF+Intd8Q/g1bUh6q0WIp9voPXJ/x0j+ZL45KF1pJd9+q2jLIRMfvEshkA==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT"
},
"node_modules/proxy-from-env": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/proxy-from-env/-/proxy-from-env-1.1.0.tgz",
"integrity": "sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg==",
"license": "MIT"
},
"node_modules/quick-format-unescaped": {
"version": "4.0.4",
"resolved": "https://registry.npmjs.org/quick-format-unescaped/-/quick-format-unescaped-4.0.4.tgz",
"integrity": "sha512-tYC1Q1hgyRuHgloV/YXs2w15unPVh8qfu/qCTfhTYamaw7fyhumKa2yGpdSo87vY32rIclj+4fWYQXUMs9EHvg==",
"license": "MIT"
},
"node_modules/real-require": {
"version": "0.2.0",
"resolved": "https://registry.npmjs.org/real-require/-/real-require-0.2.0.tgz",
"integrity": "sha512-57frrGM/OCTLqLOAh0mhVA9VBMHd+9U7Zb2THMGdBUoZVOtGbJzjxsYGDJ3A9AYYCP4hn6y1TVbaOfzWtm5GFg==",
"license": "MIT",
"engines": {
"node": ">= 12.13.0"
}
},
"node_modules/require-from-string": {
"version": "2.0.2",
"resolved": "https://registry.npmjs.org/require-from-string/-/require-from-string-2.0.2.tgz",
"integrity": "sha512-Xf0nWe6RseziFMu+Ap9biiUbmplq6S9/p+7w7YXP/JBHhrUDDUhwa+vANyubuqfZWTveU//DYVGsDG7RKL/vEw==",
"license": "MIT",
"engines": {
"node": ">=0.10.0"
}
},
"node_modules/ret": {
"version": "0.5.0",
"resolved": "https://registry.npmjs.org/ret/-/ret-0.5.0.tgz",
"integrity": "sha512-I1XxrZSQ+oErkRR4jYbAyEEu2I0avBvvMM5JN+6EBprOGRCs63ENqZ3vjavq8fBw2+62G5LF5XelKwuJpcvcxw==",
"license": "MIT",
"engines": {
"node": ">=10"
}
},
"node_modules/reusify": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/reusify/-/reusify-1.1.0.tgz",
"integrity": "sha512-g6QUff04oZpHs0eG5p83rFLhHeV00ug/Yf9nZM6fLeUrPguBTkTQOdpAWWspMh55TZfVQDPaN3NQJfbVRAxdIw==",
"license": "MIT",
"engines": {
"iojs": ">=1.0.0",
"node": ">=0.10.0"
}
},
"node_modules/rfdc": {
"version": "1.4.1",
"resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.4.1.tgz",
"integrity": "sha512-q1b3N5QkRUWUl7iyylaaj3kOpIT0N2i9MqIEQXP73GVsN9cw3fdx8X63cEmWhJGi2PPCF23Ijp7ktmd39rawIA==",
"license": "MIT"
},
"node_modules/safe-regex2": {
"version": "5.0.0",
"resolved": "https://registry.npmjs.org/safe-regex2/-/safe-regex2-5.0.0.tgz",
"integrity": "sha512-YwJwe5a51WlK7KbOJREPdjNrpViQBI3p4T50lfwPuDhZnE3XGVTlGvi+aolc5+RvxDD6bnUmjVsU9n1eboLUYw==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "MIT",
"dependencies": {
"ret": "~0.5.0"
}
},
"node_modules/safe-stable-stringify": {
"version": "2.5.0",
"resolved": "https://registry.npmjs.org/safe-stable-stringify/-/safe-stable-stringify-2.5.0.tgz",
"integrity": "sha512-b3rppTKm9T+PsVCBEOUR46GWI7fdOs00VKZ1+9c1EWDaDMvjQc6tUwuFyIprgGgTcWoVHSKrU8H31ZHA2e0RHA==",
"license": "MIT",
"engines": {
"node": ">=10"
}
},
"node_modules/secure-json-parse": {
"version": "4.1.0",
"resolved": "https://registry.npmjs.org/secure-json-parse/-/secure-json-parse-4.1.0.tgz",
"integrity": "sha512-l4KnYfEyqYJxDwlNVyRfO2E4NTHfMKAWdUuA8J0yve2Dz/E/PdBepY03RvyJpssIpRFwJoCD55wA+mEDs6ByWA==",
"funding": [
{
"type": "github",
"url": "https://github.com/sponsors/fastify"
},
{
"type": "opencollective",
"url": "https://opencollective.com/fastify"
}
],
"license": "BSD-3-Clause"
},
"node_modules/semver": {
"version": "7.7.3",
"resolved": "https://registry.npmjs.org/semver/-/semver-7.7.3.tgz",
"integrity": "sha512-SdsKMrI9TdgjdweUSR9MweHA4EJ8YxHn8DFaDisvhVlUOe4BF1tLD7GAj0lIqWVl+dPb/rExr0Btby5loQm20Q==",
"license": "ISC",
"bin": {
"semver": "bin/semver.js"
},
"engines": {
"node": ">=10"
}
},
"node_modules/set-cookie-parser": {
"version": "2.7.2",
"resolved": "https://registry.npmjs.org/set-cookie-parser/-/set-cookie-parser-2.7.2.tgz",
"integrity": "sha512-oeM1lpU/UvhTxw+g3cIfxXHyJRc/uidd3yK1P242gzHds0udQBYzs3y8j4gCCW+ZJ7ad0yctld8RYO+bdurlvw==",
"license": "MIT"
},
"node_modules/sonic-boom": {
"version": "4.2.0",
"resolved": "https://registry.npmjs.org/sonic-boom/-/sonic-boom-4.2.0.tgz",
"integrity": "sha512-INb7TM37/mAcsGmc9hyyI6+QR3rR1zVRu36B0NeGXKnOOLiZOfER5SA+N7X7k3yUYRzLWafduTDvJAfDswwEww==",
"license": "MIT",
"dependencies": {
"atomic-sleep": "^1.0.0"
}
},
"node_modules/split2": {
"version": "4.2.0",
"resolved": "https://registry.npmjs.org/split2/-/split2-4.2.0.tgz",
"integrity": "sha512-UcjcJOWknrNkF6PLX83qcHM6KHgVKNkV62Y8a5uYDVv9ydGQVwAHMKqHdJje1VTWpljG0WYpCDhrCdAOYH4TWg==",
"license": "ISC",
"engines": {
"node": ">= 10.x"
}
},
"node_modules/thread-stream": {
"version": "4.0.0",
"resolved": "https://registry.npmjs.org/thread-stream/-/thread-stream-4.0.0.tgz",
"integrity": "sha512-4iMVL6HAINXWf1ZKZjIPcz5wYaOdPhtO8ATvZ+Xqp3BTdaqtAwQkNmKORqcIo5YkQqGXq5cwfswDwMqqQNrpJA==",
"license": "MIT",
"dependencies": {
"real-require": "^0.2.0"
},
"engines": {
"node": ">=20"
}
},
"node_modules/toad-cache": {
"version": "3.7.0",
"resolved": "https://registry.npmjs.org/toad-cache/-/toad-cache-3.7.0.tgz",
"integrity": "sha512-/m8M+2BJUpoJdgAHoG+baCwBT+tf2VraSfkBgl0Y00qIWt41DJ8R5B8nsEw0I58YwF5IZH6z24/2TobDKnqSWw==",
"license": "MIT",
"engines": {
"node": ">=12"
}
},
"node_modules/typescript": {
"version": "5.9.3",
"resolved": "https://registry.npmjs.org/typescript/-/typescript-5.9.3.tgz",
"integrity": "sha512-jl1vZzPDinLr9eUt3J/t7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSw==",
"dev": true,
"license": "Apache-2.0",
"bin": {
"tsc": "bin/tsc",
"tsserver": "bin/tsserver"
},
"engines": {
"node": ">=14.17"
}
},
"node_modules/undici-types": {
"version": "6.21.0",
"resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.21.0.tgz",
"integrity": "sha512-iwDZqg0QAGrg9Rav5H4n0M64c3mkR59cJ6wQp+7C4nI0gsmExaedaYLNO44eT4AtBBwjbTiGPMlt2Md0T9H9JQ==",
"dev": true,
"license": "MIT"
}
}
}
package.json
+3 -2
View File
@@ -1,10 +1,11 @@
{ {
"name": "@metazla/plugin-tmdb", "name": "@metazla/plugin-tmdb",
"version": "1.0.0", "version": "1.0.0",
"packageManager": "[email protected]",
"description": "MetaMesh plugin: Fetches metadata from TMDB API", "description": "MetaMesh plugin: Fetches metadata from TMDB API",
"type": "module", "type": "module",
"main": "dist/index.js", "main": "dist/index.js",
"scripts": { "build": "tsc", "start": "node dist/index.js" }, "scripts": { "build": "tsc", "start": "node dist/index.js", "test": "vitest run", "test:watch": "vitest" },
"dependencies": { "fastify": "^5.0.0", "axios": "^1.6.0" }, "dependencies": { "fastify": "^5.0.0", "axios": "^1.6.0" },
"devDependencies": { "@types/node": "^20.0.0", "typescript": "^5.3.0" } "devDependencies": { "@types/node": "^20.0.0", "typescript": "^5.3.0", "vitest": "^1.6.1" }
} }
pnpm-lock.yaml
Generated
+1656
View File
File diff suppressed because it is too large Load Diff
src/cid.ts
+58
View File
@@ -0,0 +1,58 @@
/**
* CID encoding helpers (METADATA_KEYS.md §2).
*/
const BASE32_ALPHABET = 'abcdefghijklmnopqrstuvwxyz234567';
/** RFC 4648 base32, lowercase, no padding, with the `b` multibase prefix. */
export function base32LowerMultibase(bytes: Uint8Array): string {
let out = 'b';
let bits = 0;
let value = 0;
for (const byte of bytes) {
value = (value << 8) | byte;
bits += 8;
while (bits >= 5) {
bits -= 5;
out += BASE32_ALPHABET[(value >> bits) & 0x1f];
}
}
if (bits > 0) {
out += BASE32_ALPHABET[(value << (5 - bits)) & 0x1f];
}
return out;
}
/** Unsigned LEB128 varint, as multiformats encodes codecs and lengths. */
function varint(value: number): number[] {
const out: number[] = [];
let n = value;
while (n >= 0x80) {
out.push((n & 0x7f) | 0x80);
n = Math.floor(n / 0x80);
}
out.push(n);
return out;
}
/** Custom multicodec of the `url` locator (METADATA_KEYS.md §2.1). */
export const URL_LOCATOR_CODEC = 0x1006;
/**
* Encode an absolute http(s) URL as a `0x1006` identity-multihash CIDv1:
* `[0x01][varint codec][0x00][varint len][utf-8 url]`, base32lower. The digest
* is the URL itself, so minting one costs no I/O. `null` for anything that is
* not an absolute http(s) URL.
*
* CROSS-BINARY CONTRACT: byte-identical to meta-feeder-sdk's `compute_url_cid`
* (`hash.rs`); both test suites pin the same vectors.
*/
export function encodeUrlCid(url: string): string | null {
const trimmed = url.trim();
if (!trimmed.startsWith('http://') && !trimmed.startsWith('https://')) {
return null;
}
const digest = Buffer.from(trimmed, 'utf8');
const header = Buffer.from([0x01, ...varint(URL_LOCATOR_CODEC), 0x00, ...varint(digest.length)]);
return base32LowerMultibase(Buffer.concat([header, digest]));
}
src/index.ts
+6 -2
View File
@@ -48,8 +48,12 @@ app.post('/recompute', async () => {
return { status: 'ok', message: 'Recompute mode enabled' }; return { status: 'ok', message: 'Recompute mode enabled' };
}); });
app.post<{ Body: ProcessRequest }>('/process', async (request, reply) => { app.post<{ Body: ProcessRequest }>('/process', async (request, reply) => {
const { taskId, cid, filePath, callbackUrl, metaCoreUrl } = request.body; // filePath is optional: TMDB resolves purely from existingMeta
if (!taskId || !cid || !filePath || !callbackUrl || !metaCoreUrl) { // (originalTitle/movieYear/videoType/imdbid produced by filename-parser) and
// writes back to `cid`. It never reads the source file. This lets the gateway
// feeders drive TMDB from parsed metadata alone, with no file on disk.
const { taskId, cid, callbackUrl, metaCoreUrl } = request.body;
if (!taskId || !cid || !callbackUrl || !metaCoreUrl) {
return reply.send({ status: 'rejected', error: 'Missing required fields' } as ProcessResponse); return reply.send({ status: 'rejected', error: 'Missing required fields' } as ProcessResponse);
} }
processFile(request.body, async (payload: CallbackPayload) => { processFile(request.body, async (payload: CallbackPayload) => {
src/plugin.ts
+302 -133
View File
@@ -9,7 +9,8 @@
* PLUGIN FILE ACCESS ARCHITECTURE * PLUGIN FILE ACCESS ARCHITECTURE
* ============================================================================ * ============================================================================
* *
* File access via WebDAV (WEBDAV_URL environment variable): * File access via WebDAV, on the meta-core named by each /process request
* (its /urls -> webdavUrlInternal; WEBDAV_URL overrides):
* - Read media files: GET /webdav/watch/... or /webdav/test/... * - Read media files: GET /webdav/watch/... or /webdav/test/...
* - Write output: PUT /webdav/plugin/tmdb/... * - Write output: PUT /webdav/plugin/tmdb/...
* - Cache: Local /cache mount (for JSON cache files) * - Cache: Local /cache mount (for JSON cache files)
@@ -18,33 +19,29 @@
* - No output mount needed on plugin containers * - No output mount needed on plugin containers
* - Consistent read/write architecture via HTTP * - Consistent read/write architecture via HTTP
* - Works in any orchestration environment * - Works in any orchestration environment
* - Posters land in the same core the CIDs are written to, always
* *
* ============================================================================ * ============================================================================
* *
* Matches old TMDBProcessor output: * Matches old TMDBProcessor output:
* - tmdbid, imdbid * - tmdbid, imdbid
* - originalTitle, movieYear, releasedate * - title, originalTitle, movieYear, releasedate
* - titles/<lang3>/<name> key-set: localized + original title + every AKA
* - plot/eng, rating * - plot/eng, rating
* - genres (add), studio (add), tags (add) * - genres (add), studio (add), tags (add)
* - poster, backdrop (CID hashes of downloaded images) * - poster, backdrop (CID hashes of downloaded images)
* - posters/{lang3}/{cid} (alternative posters as url locators, `poster` among them)
*/ */
import axios from 'axios'; import axios from 'axios';
import { statSync, openSync, readSync, closeSync } from 'fs';
import { createHash } from 'crypto'; import { createHash } from 'crypto';
import * as path from 'path'; import * as path from 'path';
import type { PluginManifest, ProcessRequest, CallbackPayload } from './types.js'; import type { PluginManifest, ProcessRequest, CallbackPayload } from './types.js';
import { MetaCoreClient } from './meta-core-client.js'; import { MetaCoreClient } from './meta-core-client.js';
import { readJson, writeJson } from './cache.js'; import { readJson, writeJson } from './cache.js';
import { createWebDAVClient, WebDAVClient } from './webdav-client.js'; import { getWebDAVClient, WebDAVClient } from './webdav-client.js';
import { base32LowerMultibase } from './cid.js';
// Initialize WebDAV client - required for plugin operation import { posterMembers } from './posters.js';
const webdavClient = createWebDAVClient();
if (webdavClient) {
console.log('[tmdb] WebDAV client initialized for file access');
} else {
console.warn('[tmdb] WARNING: WEBDAV_URL not set - plugin will not be able to write output files');
}
const IMAGE_BASE_URL = 'https://image.tmdb.org/t/p/original'; const IMAGE_BASE_URL = 'https://image.tmdb.org/t/p/original';
@@ -52,54 +49,14 @@ const IMAGE_BASE_URL = 'https://image.tmdb.org/t/p/original';
* ============================================================================ * ============================================================================
* PLUGIN OUTPUT PATH - Written via WebDAV * PLUGIN OUTPUT PATH - Written via WebDAV
* ============================================================================ * ============================================================================
* Output files (posters, backdrops) are written via WebDAV PUT requests. * Output files (posters, backdrops) are written via WebDAV PUT requests, to the
* Path: /files/plugin/tmdb/<filename> (accessible at WEBDAV_URL/plugin/tmdb/) * WebDAV of the meta-core that issued the /process call.
* Path: /files/plugin/tmdb/<filename>
* CACHE_PATH (/cache) - Local mount for plugin cache (handled by cache.ts) * CACHE_PATH (/cache) - Local mount for plugin cache (handled by cache.ts)
* ============================================================================ * ============================================================================
*/ */
const PLUGIN_OUTPUT_WEBDAV_PATH = '/files/plugin/tmdb'; const PLUGIN_OUTPUT_WEBDAV_PATH = '/files/plugin/tmdb';
/**
* Compute midhash256 CID for a file (matches meta-hash algorithm)
*
* Algorithm:
* - For files <= 1MB: Hashes entire file content + 8-byte size prefix
* - For files > 1MB: Hashes middle 1MB + 8-byte size prefix
* - Returns CIDv1 with custom codec 0x1000
*/
function computeMidHash256Sync(filePath: string): string {
const SAMPLE_SIZE = 1024 * 1024; // 1MB
// varint encoding of 0x1000 (4096) for both codec and hash function code
const MIDHASH_VARINT = Buffer.from([0x80, 0x20]);
// Get file size
const stats = statSync(filePath);
const fileSize = stats.size;
// Create size buffer (64-bit big-endian)
const sizeBuffer = Buffer.allocUnsafe(8);
sizeBuffer.writeBigUInt64BE(BigInt(fileSize), 0);
// Extract sample data
let sampleData: Buffer;
if (fileSize <= SAMPLE_SIZE) {
// Small file: read entire content
const fd = openSync(filePath, 'r');
sampleData = Buffer.allocUnsafe(fileSize);
readSync(fd, sampleData, 0, fileSize, 0);
closeSync(fd);
} else {
// Large file: read middle 1MB
const middleOffset = Math.floor((fileSize - SAMPLE_SIZE) / 2);
const fd = openSync(filePath, 'r');
sampleData = Buffer.allocUnsafe(SAMPLE_SIZE);
readSync(fd, sampleData, 0, SAMPLE_SIZE, middleOffset);
closeSync(fd);
}
return computeMidHash256FromData(fileSize, sampleData);
}
/** /**
* Compute midhash256 CID via WebDAV * Compute midhash256 CID via WebDAV
*/ */
@@ -151,33 +108,7 @@ function computeMidHash256FromData(fileSize: number, sampleData: Buffer): string
]); ]);
// Encode as base32lower with 'b' prefix (multibase) // Encode as base32lower with 'b' prefix (multibase)
const base32Chars = 'abcdefghijklmnopqrstuvwxyz234567'; return base32LowerMultibase(cidBytes);
let cid = 'b';
let bits = 0;
let value = 0;
for (const byte of cidBytes) {
value = (value << 8) | byte;
bits += 8;
while (bits >= 5) {
bits -= 5;
cid += base32Chars[(value >> bits) & 0x1f];
}
}
if (bits > 0) {
cid += base32Chars[(value << (5 - bits)) & 0x1f];
}
return cid;
}
/**
* Compute midhash256 CID for a file (auto-selects WebDAV or filesystem)
*/
async function computeMidHash256(filePath: string): Promise<string> {
if (webdavClient) {
return computeMidHash256WebDAV(webdavClient, filePath);
}
return computeMidHash256Sync(filePath);
} }
export const manifest: PluginManifest = { export const manifest: PluginManifest = {
@@ -225,6 +156,51 @@ let forceRecompute = false;
const BASE_URL = 'https://api.themoviedb.org/3'; const BASE_URL = 'https://api.themoviedb.org/3';
// ISO 639-1 → ISO 639-3 (`lang3`, the 639-2/T form where B/T differ) for the
// languages TMDB commonly returns. Unknown codes map to nothing.
const ISO639_1_TO_3: Record<string, string> = {
en: 'eng', ja: 'jpn', fr: 'fra', de: 'deu', es: 'spa', it: 'ita', ru: 'rus',
ko: 'kor', zh: 'zho', pt: 'por', nl: 'nld', sv: 'swe', no: 'nor', da: 'dan',
fi: 'fin', pl: 'pol', tr: 'tur', cs: 'ces', hu: 'hun', el: 'ell', he: 'heb',
th: 'tha', vi: 'vie', id: 'ind', uk: 'ukr', ro: 'ron', ar: 'ara', fa: 'fas',
hi: 'hin', ta: 'tam', te: 'tel', ms: 'msa', tl: 'tgl', ca: 'cat', bg: 'bul',
hr: 'hrv', sr: 'srp', sk: 'slk', sl: 'slv', et: 'est', lv: 'lav', lt: 'lit',
is: 'isl', ga: 'gle', cn: 'zho',
};
function iso639_1to3(code: string | undefined | null): string | undefined {
return code ? ISO639_1_TO_3[code.trim().toLowerCase()] : undefined;
}
// TMDB keys AKAs by MARKET (`iso_3166_1`), not language. Only markets that
// clearly imply one language are mapped; a multilingual or unknown market
// (CA, CH, BE, IN, HK, SG, …, or empty) files its AKA under `und` rather than
// guessing (METADATA_KEYS.md §3).
const MARKET_TO_LANG3: Record<string, string> = {
US: 'eng', GB: 'eng', AU: 'eng', NZ: 'eng', IE: 'eng',
FR: 'fra', DE: 'deu', AT: 'deu', ES: 'spa', MX: 'spa', AR: 'spa', CO: 'spa',
CL: 'spa', PE: 'spa', VE: 'spa', IT: 'ita', BR: 'por', PT: 'por', JP: 'jpn',
KR: 'kor', CN: 'zho', TW: 'zho', RU: 'rus', NL: 'nld', SE: 'swe', NO: 'nor',
DK: 'dan', FI: 'fin', PL: 'pol', TR: 'tur', CZ: 'ces', HU: 'hun', GR: 'ell',
IL: 'heb', TH: 'tha', VN: 'vie', ID: 'ind', UA: 'ukr', RO: 'ron', IR: 'fas',
SA: 'ara', EG: 'ara', AE: 'ara', BG: 'bul', HR: 'hrv', RS: 'srp', SK: 'slk',
SI: 'slv', EE: 'est', LV: 'lav', LT: 'lit', IS: 'isl',
};
function marketToLang3(market: string | undefined | null): string {
return (market && MARKET_TO_LANG3[market.trim().toUpperCase()]) || 'und';
}
/**
* `titles/<lang3>/<name>` key-set member key (METADATA_KEYS.md §3): trimmed,
* whitespace collapsed, `/` (the key-set separator) written as U+2215 `∕`.
* `undefined` when nothing is left to name.
*/
function titleMemberKey(lang3: string, name: string | undefined | null): string | undefined {
const clean = (name ?? '').trim().replace(/\s+/g, ' ').replace(/\//g, '\u2215');
return clean ? `titles/${lang3}/${clean}` : undefined;
}
let apiKey: string | null = null; let apiKey: string | null = null;
let isV4Token = false; let isV4Token = false;
let metadataLanguage = 'en-US'; let metadataLanguage = 'en-US';
@@ -275,7 +251,17 @@ async function findByImdbId(imdbId: string): Promise<any> {
async function getByTmdbId(tmdbId: string, mediaType: string): Promise<any> { async function getByTmdbId(tmdbId: string, mediaType: string): Promise<any> {
try { try {
const config = getAxiosConfig({ language: metadataLanguage }); // `alternative_titles` rides along so the AKAs land in `titles/*` (§3).
// `images` rides the same call too: the poster candidates for the
// `posters/{lang3}/{cid}` key-set (§6). `language` would otherwise filter
// them to one language, so widen it to the configured one, English and
// textless (`null`).
const lang1 = metadataLanguage.split('-')[0];
const config = getAxiosConfig({
language: metadataLanguage,
append_to_response: 'alternative_titles,images',
include_image_language: [...new Set([lang1, 'en'])].join(',') + ',null',
});
const response = await axios.get(`${BASE_URL}/${mediaType}/${tmdbId}`, config); const response = await axios.get(`${BASE_URL}/${mediaType}/${tmdbId}`, config);
return response.data; return response.data;
} catch { } catch {
@@ -343,14 +329,16 @@ async function downloadImageToWebDAV(
} }
/** /**
* Download and hash an image, returning its CID * Download and hash an image, returning its CID.
* *
* Images are written via WebDAV PUT to /files/plugin/tmdb/ * Images are written via WebDAV PUT to /files/plugin/tmdb/. The watcher
* The files will be picked up by meta-sort's file watcher and processed like any other file. * indexes that directory as a first-class file root, so each downloaded
* * image becomes a normal metadata entry with a midhash256 alias. The
* @returns {Promise<string | null>} The midhash256 CID of the downloaded image * editor's CID preview then resolves through standard CID resolution —
* no need to store any path in the parent file's metadata.
*/ */
async function downloadAndHashImage( async function downloadAndHashImage(
webdavClient: WebDAVClient | null,
imagePath: string, imagePath: string,
imageType: string, imageType: string,
title: string, title: string,
@@ -408,6 +396,9 @@ export async function process(
): Promise<void> { ): Promise<void> {
const startTime = Date.now(); const startTime = Date.now();
const metaCore = new MetaCoreClient(request.metaCoreUrl); const metaCore = new MetaCoreClient(request.metaCoreUrl);
// WebDAV of the very core we're enriching, so poster blobs and the poster
// CIDs we write can never point at different cores. Cached per core URL.
const webdavClient = await getWebDAVClient(request.metaCoreUrl);
try { try {
const { cid, existingMeta } = request; const { cid, existingMeta } = request;
@@ -432,8 +423,11 @@ export async function process(
return; return;
} }
// Skip if already has TMDB data (unless forceRecompute) // Skip only if FULLY enriched already (tmdbid AND poster), unless forced.
if (existingMeta?.tmdbid && !forceRecompute) { // A record carrying a tmdbid but no poster — e.g. a gateway anchor or
// jellyfin-nfo that set only the id — still runs, so the full cycle
// (poster download + plot/genres) completes via getByTmdbId below.
if (existingMeta?.tmdbid && existingMeta?.poster && !forceRecompute) {
await sendCallback({ await sendCallback({
taskId: request.taskId, taskId: request.taskId,
status: 'skipped', status: 'skipped',
@@ -444,18 +438,29 @@ export async function process(
} }
if (forceRecompute) { if (forceRecompute) {
console.log(`[tmdb] Force recompute enabled for ${request.filePath}`); console.log(`[tmdb] Force recompute enabled for ${request.filePath ?? existingMeta?.fileName ?? cid}`);
} }
// Get midhash for caching const label = request.filePath ?? existingMeta?.fileName ?? cid;
const midhash = existingMeta?.['cid_midhash256'];
// Check cache (skip if forceRecompute) // Exact-file cache, keyed by the file's byte-hash. Only records carrying
// real file bytes have `cid_midhash256`; gateway/usenet records don't —
// which is exactly why the per-tmdbid cache below exists. Stores a full
// entry now, but tolerates the legacy raw-payload format from older builds.
const midhash = existingMeta?.['cid_midhash256'];
if (midhash && !forceRecompute) { if (midhash && !forceRecompute) {
const cachedData = await readJson<any>(`${midhash}_tmdb.json`); const cached = await readJson<any>(`${midhash}_aka_tmdb.json`);
if (cachedData) { if (cached) {
console.log(`[tmdb] Using cached TMDB data for ${request.filePath}`); console.log(`[tmdb] Using byte-hash cached TMDB data for ${label}`);
await applyTmdbData(metaCore, cid, cachedData); const isEntry = cached.data !== undefined;
await applyTmdbData(
metaCore,
webdavClient,
cid,
isEntry ? cached.data : cached,
// Legacy raw payloads carry no image CIDs → let applyTmdbData recompute.
isEntry ? { posterCid: cached.posterCid, backdropCid: cached.backdropCid } : undefined
);
await sendCallback({ await sendCallback({
taskId: request.taskId, taskId: request.taskId,
status: 'completed', status: 'completed',
@@ -465,21 +470,37 @@ export async function process(
} }
} }
let tmdbData = null; // Resolve the show/movie entry, deduped per tmdbid. A record that already
// carries a tmdbid anchor (every gateway torrent/usenet hit does) takes
// the cached + single-flighted fast path, so N releases of one show share
// ONE TMDB fetch + poster seed instead of N.
let entry: TmdbCacheEntry | null = null;
const knownTmdbId = existingMeta?.tmdbid;
if (knownTmdbId) {
const mediaType =
existingMeta?.videoType === 'tvshow' || existingMeta?.videoType === 'tv'
? 'tv'
: 'movie';
entry = await resolveEntryById(webdavClient, knownTmdbId, mediaType);
}
// Fallback: no usable id → resolve by IMDB id or fuzzy title, then cache
// the result by its resolved tmdbid so later releases of the same show
// take the fast path above.
if (!entry) {
let tmdbData: any = null;
// Try by IMDB ID first
const imdbId = existingMeta?.imdbid; const imdbId = existingMeta?.imdbid;
if (imdbId) { if (imdbId) {
tmdbData = await findByImdbId(imdbId); tmdbData = await findByImdbId(imdbId);
} }
// Try by title search
if (!tmdbData) { if (!tmdbData) {
let title = existingMeta?.originalTitle || existingMeta?.fileName; let title = existingMeta?.originalTitle || existingMeta?.fileName;
const year = existingMeta?.movieYear; const year = existingMeta?.movieYear;
const videoType = existingMeta?.videoType; const videoType = existingMeta?.videoType;
// Strip trailing year from title if present (e.g., "Sintel 2010" -> "Sintel") // Strip trailing year from title if present ("Sintel 2010" -> "Sintel").
if (title && year) { if (title && year) {
const yearRegex = new RegExp(`\\s*[\\(\\[]?${year}[\\)\\]]?\\s*$`); const yearRegex = new RegExp(`\\s*[\\(\\[]?${year}[\\)\\]]?\\s*$`);
title = title.replace(yearRegex, '').trim(); title = title.replace(yearRegex, '').trim();
@@ -491,16 +512,27 @@ export async function process(
} }
if (tmdbData) { if (tmdbData) {
await applyTmdbData(metaCore, cid, tmdbData); const images = await computeImageCids(webdavClient, tmdbData);
entry = { data: tmdbData, ...images };
// Cache TMDB data for future use if (tmdbData.id) {
if (midhash) { await writeJson(tmdbCacheKey(String(tmdbData.id), mediaTypeOf(tmdbData)), entry);
await writeJson(`${midhash}_tmdb.json`, tmdbData); }
}
} }
console.log(`[tmdb] Fetched TMDB data for ${request.filePath}`); if (entry) {
await applyTmdbData(metaCore, webdavClient, cid, entry.data, {
posterCid: entry.posterCid,
backdropCid: entry.backdropCid,
});
// Keep the exact-file cache warm too, so a future re-enrichment of
// this same file skips straight to the byte-hash hit.
if (midhash) {
await writeJson(`${midhash}_aka_tmdb.json`, entry);
}
console.log(`[tmdb] Enriched ${label} (tmdbid=${entry.data.id})`);
} else { } else {
console.log(`[tmdb] No TMDB match found for ${request.filePath}`); console.log(`[tmdb] No TMDB match found for ${label}`);
} }
await sendCallback({ await sendCallback({
@@ -518,14 +550,111 @@ export async function process(
} }
} }
/** Resolved TMDB payload plus the seeded poster/backdrop CIDs, cached per
* tmdbid. Every torrent/usenet release of an episode carries the same
* `tmdbid`, and TMDB only gives us show/movie-level fields (poster, plot,
* genres — no per-episode data), so N releases can share ONE fetch + seed. */
interface TmdbCacheEntry {
data: any;
posterCid: string | null;
backdropCid: string | null;
}
// In-process single-flight: collapses concurrent resolves of the same key onto
// one promise, so a burst of same-tmdbid records that all miss the cold cache
// triggers a single TMDB fetch (no thundering herd) — the rest await it.
const tmdbEntryInflight = new Map<string, Promise<TmdbCacheEntry | null>>();
// Persistent cache filename for a resolved show/movie. Includes mediaType +
// language so a tv/movie id clash or a language switch can't return stale text.
function tmdbCacheKey(tmdbId: string, mediaType: string): string {
// `_aka`: entries written before `alternative_titles` was appended carry no
// AKAs, so the name moved to make them refetch once.
return `tmdbid_${mediaType}_${tmdbId}_${metadataLanguage}_aka_tmdb.json`;
}
// Media type from a raw TMDB payload's own shape (tv payloads carry
// name/first_air_date). Mirrors the check in applyTmdbData.
function mediaTypeOf(data: any): string {
return data?.first_air_date !== undefined ||
data?.name !== undefined ||
data?.original_name !== undefined
? 'tv'
: 'movie';
}
// Download + hash the poster/backdrop for a resolved payload. Record-independent
// (the image filename is keyed by tmdbId, so the blob dedups across records), so
// the CIDs can be computed once per show and reused for every release.
async function computeImageCids(
webdavClient: WebDAVClient | null,
data: any
): Promise<{ posterCid: string | null; backdropCid: string | null }> {
const tmdbId = data?.id ? String(data.id) : '';
const displayTitle =
data?.title || data?.name || data?.original_title || data?.original_name || 'Unknown';
const releaseDate = data?.release_date || data?.first_air_date;
const year = releaseDate ? releaseDate.split('-')[0] : undefined;
const posterCid =
data?.poster_path && tmdbId
? await downloadAndHashImage(webdavClient, data.poster_path, 'poster', displayTitle, year, tmdbId)
: null;
const backdropCid =
data?.backdrop_path && tmdbId
? await downloadAndHashImage(webdavClient, data.backdrop_path, 'backdrop', displayTitle, year, tmdbId)
: null;
return { posterCid, backdropCid };
}
// Resolve the full entry (payload + image CIDs) for a KNOWN tmdbid, served from
// the persistent per-tmdbid cache when possible and single-flighted otherwise.
// This is the hot path for gateway records (torrent + usenet), which always
// carry a `tmdbid` anchor — so N releases of one show share one TMDB fetch.
async function resolveEntryById(
webdavClient: WebDAVClient | null,
tmdbId: string,
mediaType: string
): Promise<TmdbCacheEntry | null> {
const key = tmdbCacheKey(tmdbId, mediaType);
if (!forceRecompute) {
const cached = await readJson<TmdbCacheEntry>(key);
if (cached?.data) {
return cached;
}
}
const inflight = tmdbEntryInflight.get(key);
if (inflight) {
return inflight;
}
const pending = (async (): Promise<TmdbCacheEntry | null> => {
console.log(`[tmdb] Resolving TMDB ${mediaType}/${tmdbId} (cache miss)`);
const data = await getByTmdbId(tmdbId, mediaType);
if (!data) {
return null;
}
const images = await computeImageCids(webdavClient, data);
const entry: TmdbCacheEntry = { data, ...images };
await writeJson(key, entry);
return entry;
})();
tmdbEntryInflight.set(key, pending);
try {
return await pending;
} finally {
tmdbEntryInflight.delete(key);
}
}
/** /**
* Apply TMDB data to KV store using same keys as old TMDBProcessor * Apply TMDB data to KV store using same keys as old TMDBProcessor
*/ */
async function applyTmdbData( async function applyTmdbData(
metaCore: MetaCoreClient, metaCore: MetaCoreClient,
webdavClient: WebDAVClient | null,
cid: string, cid: string,
data: any data: any,
): Promise<void> { images?: { posterCid: string | null; backdropCid: string | null }
): Promise<{ posterCid: string | null; backdropCid: string | null }> {
const metadata: Record<string, string> = {}; const metadata: Record<string, string> = {};
// Basic IDs // Basic IDs
@@ -533,6 +662,26 @@ async function applyTmdbData(
if (tmdbId) metadata.tmdbid = tmdbId; if (tmdbId) metadata.tmdbid = tmdbId;
if (data.imdb_id) metadata.imdbid = data.imdb_id; if (data.imdb_id) metadata.imdbid = data.imdb_id;
// Authoritative media type, stamped from TMDB's own payload shape. TV
// payloads carry `name`/`first_air_date`/`original_name`; movie payloads
// carry `title`/`release_date`/`original_title`. This overrides whatever the
// filename-parser guessed (`videoType`/`contentKind`), which it derives from
// a parsed season/episode — frequently absent for anime fansubs (absolute
// numbering, batch packs), the root cause of series being mislabeled films
// downstream in meta-watch. `videoType` (movie|tvshow) and `contentKind`
// (movie|episode) mirror the filename-parser's keys so consumers read one
// field regardless of the enrichment source.
const isTv =
data.first_air_date !== undefined ||
data.name !== undefined ||
data.original_name !== undefined;
metadata.videoType = isTv ? 'tvshow' : 'movie';
metadata.contentKind = isTv ? 'episode' : 'movie';
// `domain` is written in the same breath as `contentKind`
// (METADATA_KEYS.md §1) — it is the key meta-watch filters its wall on,
// and TMDB is precisely the identity graph that decides film vs tv here.
metadata.domain = isTv ? 'tv' : 'film';
// Title - store both original and localized // Title - store both original and localized
const originalTitle = data.original_title || data.original_name; const originalTitle = data.original_title || data.original_name;
const localizedTitle = data.title || data.name; const localizedTitle = data.title || data.name;
@@ -548,6 +697,23 @@ async function applyTmdbData(
metadata.originalTitle = originalTitle; metadata.originalTitle = originalTitle;
} }
// Every clean name as a `titles/<lang3>/<name>` key-set member
// (METADATA_KEYS.md §3): the localized title under the configured metadata
// language, the original title under TMDB's `original_language`, and each
// AKA under the language its market implies (`und` when it doesn't).
const addTitleMember = (lang3: string, name: string | undefined) => {
const key = titleMemberKey(lang3, name);
if (key) metadata[key] = 'true';
};
addTitleMember(iso639_1to3(metadataLanguage.split('-')[0]) ?? 'und', localizedTitle);
addTitleMember(iso639_1to3(data.original_language) ?? 'und', originalTitle);
const akas = data.alternative_titles?.titles ?? data.alternative_titles?.results;
if (Array.isArray(akas)) {
for (const aka of akas) {
addTitleMember(marketToLang3(aka?.iso_3166_1), aka?.title);
}
}
// Dates // Dates
const releaseDate = data.release_date || data.first_air_date; const releaseDate = data.release_date || data.first_air_date;
let year: string | undefined; let year: string | undefined;
@@ -562,9 +728,8 @@ async function applyTmdbData(
// Plot (in configured language) // Plot (in configured language)
if (data.overview) { if (data.overview) {
// Extract language code from metadataLanguage (e.g., 'en-US' -> 'eng') // Extract language code from metadataLanguage (e.g., 'en-US' -> 'eng')
const langCode = metadataLanguage.split('-')[0]; const langKey = iso639_1to3(metadataLanguage.split('-')[0]);
const langKey = langCode === 'en' ? 'eng' : langCode; if (langKey) metadata[`plot/${langKey}`] = data.overview;
metadata[`plot/${langKey}`] = data.overview;
// Also set as primary plot for compatibility // Also set as primary plot for compatibility
metadata['plot/eng'] = data.overview; metadata['plot/eng'] = data.overview;
} }
@@ -593,33 +758,37 @@ async function applyTmdbData(
// Add tmdb-verified tag (same as old processor) // Add tmdb-verified tag (same as old processor)
await metaCore.addToSet(cid, 'tags', 'tmdb-verified'); await metaCore.addToSet(cid, 'tags', 'tmdb-verified');
// Download poster and backdrop images to plugin output folder // Poster/backdrop CIDs. Reuse the precomputed values when the caller already
// The files will be picked up by meta-sort's file watcher and processed like any other file // seeded them (a per-tmdbid cache hit — so we don't re-download + re-hash the
if (data.poster_path && tmdbId) { // same image for every release of a show); otherwise download + hash now.
const posterCid = await downloadAndHashImage( // The image filename is keyed by tmdbId, so the blob is deduped either way —
data.poster_path, // this just also skips the WebDAV round-trips. The watcher picks the images
'poster', // up as first-class file entries, so storing the CID is all that's needed.
displayTitle, let posterCid = images ? images.posterCid : null;
year, if (!images && data.poster_path && tmdbId) {
tmdbId posterCid = await downloadAndHashImage(webdavClient, data.poster_path, 'poster', displayTitle, year, tmdbId);
); }
if (posterCid) { if (posterCid) {
await metaCore.setProperty(cid, 'poster', posterCid); await metaCore.setProperty(cid, 'poster', posterCid);
console.log(`[tmdb] Set poster CID: ${posterCid}`); console.log(`[tmdb] Set poster CID: ${posterCid}`);
// The alternatives, as the `posters/{lang3}/{cid}` key-set with `poster`
// among them (METADATA_KEYS.md §6). Leaf keys through PATCH — never
// addToSet, which writes the legacy comma-joined csv-set. Empty for a
// cached payload from before the `images` append: no backfill by design.
const members = posterMembers(data, posterCid);
if (Object.keys(members).length > 0) {
await metaCore.mergeMetadata(cid, members);
} }
} }
if (data.backdrop_path && tmdbId) { let backdropCid = images ? images.backdropCid : null;
const backdropCid = await downloadAndHashImage( if (!images && data.backdrop_path && tmdbId) {
data.backdrop_path, backdropCid = await downloadAndHashImage(webdavClient, data.backdrop_path, 'backdrop', displayTitle, year, tmdbId);
'backdrop', }
displayTitle,
year,
tmdbId
);
if (backdropCid) { if (backdropCid) {
await metaCore.setProperty(cid, 'backdrop', backdropCid); await metaCore.setProperty(cid, 'backdrop', backdropCid);
console.log(`[tmdb] Set backdrop CID: ${backdropCid}`); console.log(`[tmdb] Set backdrop CID: ${backdropCid}`);
} }
}
return { posterCid, backdropCid };
} }
src/posters.ts
+102
View File
@@ -0,0 +1,102 @@
/**
* The `posters/{lang3}/{cid}` key-set for a TMDB-enriched video record
* (METADATA_KEYS.md §6): the primary poster plus the best-voted alternatives.
*
* CROSS-BINARY CONTRACT: same ranking, cap, CDN size and language rule as the
* tmdb card feeder's `poster_member_keys`
* (`meta-feeder-tmdb/feeder-plugin/card-feeder/src/card.rs`).
*/
import { encodeUrlCid } from './cid.js';
/** Most members a record's `posters/*` key-set may carry, the primary included. */
export const MAX_POSTER_MEMBERS = 10;
/**
* CDN root + size the alternatives are referenced at. `w500`, as the card
* feeder's `poster_url`, so both writers mint the same locator for one image.
*/
export const ALT_POSTER_BASE_URL = 'https://image.tmdb.org/t/p/w500';
/** One entry of a TMDB details payload's `images.posters` (`append_to_response=images`). */
export interface TmdbImage {
file_path?: string;
iso_639_1?: string | null;
vote_average?: number;
vote_count?: number;
}
/**
* ISO 639-1 → ISO 639-3 (`lang3`), the 639-2/T form where B and T differ
* (`fra`, `deu`, `zho` — never `fre`/`ger`/`chi`). Mirrors the card feeder's
* `iso639_1_to_3` table.
*/
const ISO639_1_TO_3: Record<string, string> = {
en: 'eng', ja: 'jpn', fr: 'fra', de: 'deu', es: 'spa', it: 'ita', ru: 'rus',
ko: 'kor', zh: 'zho', pt: 'por', nl: 'nld', sv: 'swe', no: 'nor', da: 'dan',
fi: 'fin', pl: 'pol', tr: 'tur', ar: 'ara', hi: 'hin', th: 'tha', vi: 'vie',
id: 'ind', cs: 'ces', el: 'ell', he: 'heb', hu: 'hun', ro: 'ron', uk: 'ukr',
fa: 'fas', ms: 'msa', tl: 'tgl', ca: 'cat', nb: 'nob',
};
/**
* The language segment for a poster: that of the text printed on it. `zxx`
* (no linguistic content) when TMDB gives none — a textless poster — and
* `und` for a code outside the table.
*/
export function posterLang3(code: string | null | undefined): string {
const trimmed = (code ?? '').trim().toLowerCase();
if (!trimmed) return 'zxx';
return ISO639_1_TO_3[trimmed] ?? 'und';
}
function compareCandidates(a: TmdbImage, b: TmdbImage): number {
const byAverage = (b.vote_average ?? 0) - (a.vote_average ?? 0);
if (byAverage !== 0) return byAverage;
const byCount = (b.vote_count ?? 0) - (a.vote_count ?? 0);
if (byCount !== 0) return byCount;
const pa = a.file_path ?? '';
const pb = b.file_path ?? '';
return pa < pb ? -1 : pa > pb ? 1 : 0;
}
/**
* The `posters/{lang3}/{cid}` members to merge onto a record whose `poster` is
* `primaryPosterCid`. The primary is always a member, filed under the language
* of its own `images.posters` entry (`und` if TMDB did not list it); the
* alternatives follow as `url` locators, ranked by `vote_average`, then
* `vote_count`, then `file_path` (so equal payloads give equal keys), capped at
* {@link MAX_POSTER_MEMBERS} in total.
*
* Returns `{}` when the payload has no image list — a cached entry from before
* the `images` append. Without one the primary's language is unknown, and a set
* is better absent than mislabelled.
*/
export function posterMembers(data: any, primaryPosterCid: string): Record<string, 'true'> {
const candidates: TmdbImage[] = Array.isArray(data?.images?.posters) ? data.images.posters : [];
if (candidates.length === 0 || !primaryPosterCid) {
return {};
}
const primaryPath: string | undefined = data?.poster_path;
const members: Record<string, 'true'> = {};
const primary = candidates.find((img) => !!img.file_path && img.file_path === primaryPath);
const primaryLang = primary ? posterLang3(primary.iso_639_1) : 'und';
members[`posters/${primaryLang}/${primaryPosterCid}`] = 'true';
let count = 1;
const ranked = candidates
.filter((img) => typeof img.file_path === 'string' && img.file_path.trim() !== '' && img.file_path !== primaryPath)
.sort(compareCandidates);
for (const img of ranked) {
if (count >= MAX_POSTER_MEMBERS) break;
const cid = encodeUrlCid(`${ALT_POSTER_BASE_URL}/${img.file_path!.replace(/^\/+/, '')}`);
if (!cid) continue;
const key = `posters/${posterLang3(img.iso_639_1)}/${cid}`;
if (!(key in members)) {
members[key] = 'true';
count++;
}
}
return members;
}
src/types.ts
+2 -1
View File
@@ -41,7 +41,8 @@ export interface HealthResponse {
export interface ProcessRequest { export interface ProcessRequest {
taskId: string; taskId: string;
cid: string; cid: string;
filePath: string; /** Optional: TMDB never reads the source file — used only for log context. */
filePath?: string;
callbackUrl: string; callbackUrl: string;
metaCoreUrl: string; metaCoreUrl: string;
existingMeta?: Record<string, string>; existingMeta?: Record<string, string>;
src/webdav-client.ts
+54 -5
View File
@@ -136,15 +136,64 @@ export class WebDAVClient {
} }
/** /**
* Create a WebDAV client from environment variables * WebDAV client for the meta-core that drove a /process call.
*
* The endpoint is read from that core's own /urls (`webdavUrlInternal`),
* so blobs always land in the /files of the core we write metadata to. A feeder
* whose plugins run beside it but enrich a remote hub core needs no per-stack
* wiring, and it is impossible to write posters into one core while pointing
* CIDs at another.
*
* WEBDAV_URL still wins when set — an explicit override for tests and for
* topologies where the core's advertised internal URL isn't reachable from here.
*
* Resolutions are cached per meta-core URL; failures are not, so a core that is
* still starting up is retried on the next task.
*/ */
export function createWebDAVClient(): WebDAVClient | null { const clientCache = new Map<string, Promise<WebDAVClient | null>>();
const webdavUrl = process.env.WEBDAV_URL;
async function resolveWebDAVUrl(metaCoreUrl: string): Promise<string | null> {
// /urls, not /api/urls — metaCoreUrl points at the meta-core backend, whose
// discovery routes are unprefixed (same base the /meta/* writes use).
const base = metaCoreUrl.replace(/\/$/, '');
const response = await fetch(`${base}/urls`, { signal: AbortSignal.timeout(5000) });
if (!response.ok) {
throw new Error(`GET ${base}/urls failed: ${response.status} ${response.statusText}`);
}
const urls = await response.json() as { webdavUrlInternal?: string; webdavUrl?: string };
return urls.webdavUrlInternal ?? urls.webdavUrl ?? null;
}
export async function getWebDAVClient(metaCoreUrl: string): Promise<WebDAVClient | null> {
const override = process.env.WEBDAV_URL;
if (override) {
return new WebDAVClient(override);
}
let pending = clientCache.get(metaCoreUrl);
if (!pending) {
pending = resolveWebDAVUrl(metaCoreUrl).then((webdavUrl) => {
if (!webdavUrl) { if (!webdavUrl) {
console.warn('[webdav-client] WEBDAV_URL not set, WebDAV client unavailable'); console.warn(`[webdav-client] meta-core ${metaCoreUrl} advertises no WebDAV URL`);
return null; return null;
} }
console.log(`[webdav-client] Using WebDAV endpoint ${webdavUrl} (from ${metaCoreUrl})`);
return new WebDAVClient(webdavUrl); return new WebDAVClient(webdavUrl);
});
clientCache.set(metaCoreUrl, pending);
}
try {
const client = await pending;
if (!client) {
clientCache.delete(metaCoreUrl);
}
return client;
} catch (error) {
clientCache.delete(metaCoreUrl);
console.warn(`[webdav-client] Failed to resolve WebDAV URL from ${metaCoreUrl}: ${error instanceof Error ? error.message : String(error)}`);
return null;
}
} }
test/posters.test.ts
+88
View File
@@ -0,0 +1,88 @@
import { describe, expect, it } from 'vitest';
import { encodeUrlCid } from '../src/cid.js';
import { ALT_POSTER_BASE_URL, MAX_POSTER_MEMBERS, posterLang3, posterMembers, type TmdbImage } from '../src/posters.js';
const alt = (path: string) => encodeUrlCid(`${ALT_POSTER_BASE_URL}${path}`)!;
const img = (file_path: string, iso_639_1: string | null, vote_average = 0, vote_count = 0): TmdbImage => ({
file_path,
iso_639_1,
vote_average,
vote_count,
});
describe('encodeUrlCid', () => {
// Same vectors as meta-feeder-tmdb's vendored `hash.rs::url_cid_matches_pinned_vectors`.
it('matches the pinned Rust vectors', () => {
expect(encodeUrlCid('https://image.tmdb.org/t/p/w500/dqZENchTd7lp5zit1Q7Bkjzcxpi.jpg')).toBe(
'bagdcaab7nb2hi4dthixs62lnmftwkltunvsgeltpojts65bpoaxxonjqgaxwi4k2ivhgg2cumq3wy4bvpjuximkrg5bgw2t2mn4ha2jonjygo',
);
});
it('uses a two-byte length varint past 127 bytes', () => {
const long = `https://image.tmdb.org/t/p/w500/${'a'.repeat(100)}.jpg`;
expect(long.length).toBe(136);
expect(encodeUrlCid(long)).toBe(
'bagdcaaeiafuhi5dqom5c6l3jnvqwozjoorwwiyron5zgol3uf5yc65zvgayc6ylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcylbmfqwcltkobtq',
);
});
it('rejects anything but an absolute http(s) URL', () => {
expect(encodeUrlCid('/relative.jpg')).toBeNull();
expect(encodeUrlCid('ftp://example.com/x.jpg')).toBeNull();
expect(encodeUrlCid('')).toBeNull();
});
});
describe('posterLang3', () => {
it('maps to ISO 639-3, never 639-2/B', () => {
expect(posterLang3('fr')).toBe('fra');
expect(posterLang3('de')).toBe('deu');
expect(posterLang3('EN')).toBe('eng');
});
it('files a textless poster under zxx and an unknown code under und', () => {
expect(posterLang3(null)).toBe('zxx');
expect(posterLang3(undefined)).toBe('zxx');
expect(posterLang3('xx')).toBe('und');
});
});
describe('posterMembers', () => {
const PRIMARY_CID = 'bagacbabaecontentcid';
it('lists the primary under its own language, once, beside the alternatives', () => {
const data = {
poster_path: '/primary.jpg',
images: {
posters: [img('/alt-fr.jpg', 'fr', 5.5, 10), img('/primary.jpg', 'ja', 5, 3), img('/textless.jpg', null, 6, 1)],
},
};
expect(posterMembers(data, PRIMARY_CID)).toEqual({
[`posters/jpn/${PRIMARY_CID}`]: 'true',
[`posters/zxx/${alt('/textless.jpg')}`]: 'true',
[`posters/fra/${alt('/alt-fr.jpg')}`]: 'true',
});
});
it('ranks by vote_average then vote_count, and caps at ten including the primary', () => {
const posters = Array.from({ length: 15 }, (_, i) => img(`/p${String(i).padStart(2, '0')}.jpg`, 'en', i, 1));
const keys = Object.keys(posterMembers({ poster_path: '/primary.jpg', images: { posters } }, PRIMARY_CID));
expect(keys).toHaveLength(MAX_POSTER_MEMBERS);
expect(keys[0]).toBe(`posters/und/${PRIMARY_CID}`);
expect(keys[1]).toBe(`posters/eng/${alt('/p14.jpg')}`);
expect(keys).not.toContain(`posters/eng/${alt('/p05.jpg')}`);
const tie = Object.keys(
posterMembers(
{ poster_path: '/primary.jpg', images: { posters: [img('/few.jpg', null, 5, 1), img('/many.jpg', null, 5, 9)] } },
PRIMARY_CID,
),
);
expect(tie[1]).toBe(`posters/zxx/${alt('/many.jpg')}`);
});
it('writes no set when the payload has no image list', () => {
expect(posterMembers({ poster_path: '/primary.jpg' }, PRIMARY_CID)).toEqual({});
expect(posterMembers({ poster_path: '/primary.jpg', images: { posters: [] } }, PRIMARY_CID)).toEqual({});
});
});
vitest.config.ts
+9
View File
@@ -0,0 +1,9 @@
import { defineConfig } from 'vitest/config';
export default defineConfig({
test: {
globals: true,
environment: 'node',
include: ['test/**/*.test.ts'],
},
});