Mise à jour de 'package.json'

README.md

@@ -1,42 +1,3 @@
-# Auto Import YouTube
+# PeerTube plugin Quickstart
 
-## Config
+See https://docs.joinpeertube.org/#/contribute-plugins?id=write-a-plugintheme
-
-To use this plugin, you need to give some valid admins credential inside the plugin's settings.
-
-After this you have to specify some YouTube Channel who need to be bind with a PeerTube Channel.
-For this you have to use this format inside the plugins's setting. Into `URL list of Youtube channel to synchronize`'s text area. :
-
-```json
-[
-   {
-       "address":"https://www.youtube.com/feeds/videos.xml?channel_id=${MyYouTubeChannelID}",
-       "channelId":"MyPeertubeChannelId"
-   } ,
-   ...
-]
-```
-
-This an array of object who's in this format :
-
-```ts
-type SettingsContent = {
-  address: string;
-  channelId: string;
-  timeloop?: number;
-};
-```
-
-### address
-
-For exemple, to the Youtube channel : `https://www.youtube.com/channel/YouTube`, the channel id is `UCBR8-60-B28hp2BmDPdntcQ`. You can get it when you're clicking in the channel button on the video player. (He's not Highlighted by YouTube. Cheer Up !)  
-So you need to specify the following address inside your configuration : `https://www.youtube.com/feeds/videos.xml?channel_id=UCBR8-60-B28hp2BmDPdntcQ`.
-
-### channelId
-
-The peertube's channel id is a number associated to a peertube's channel. He's unique per channel inside a same instance.
-
-### timeloop
-
-It's represent the time between two update of the videos list.  
-It's not needful to specify the timeloop. The default value is set to 5 minutes.

lib/peertubeRequester.ts

@@ -1,10 +1,13 @@
+// import { ImplementableApi } from './implementableApi';
 // Api request lib
-import fetch, { Headers } from "node-fetch";
+import fetch, { FetchError, Headers } from "node-fetch";
 import { URL, URLSearchParams } from "url";
+import FormData from "form-data";
+// import dedent from "ts-dedent";
 
 namespace PeerTubeRequester {
   export type Config = {
-    domainName: string | URL;
+    domain_name: string | URL;
     username: string;
     password: string;
   };
@@ -16,30 +19,45 @@ type UploadInstruction = {
   targetUrl: string;
 };
 
+type ClientToken = {
+  client_id: string;
+  client_secret: string;
+  grant_type: "password";
+  response_type: "code";
+  username: string;
+  password: string;
+};
+
+type UserToken = {
+  access_token: string;
+  token_type: string;
+  expires_in: string;
+  refresh_token: string;
+};
+
 class PeerTubeRequester {
-  readonly domainName: URL;
+  readonly domain_name: URL;
   readonly username: string;
   readonly password: string;
 
   constructor(readonly config: PeerTubeRequester.Config) {
-    this.domainName = new URL("/", config.domainName);
+    this.domain_name = new URL("/", config.domain_name);
     this.username = config.username;
     this.password = config.password;
   }
 
-  async requestAuthToken(): Promise<any> {
+  async apiRequest(message: UploadInstruction): Promise<void> {
     let response = await fetch(
-      new URL(`/api/v1/oauth-clients/local`, this.domainName)
+      new URL(`/api/v1/oauth-clients/local`, this.domain_name)
     );
     if (!response.ok) {
-      throw new Error("Cannot get client credentials : " + response.statusText); // CRASH
+      throw new Error(response.statusText); // CRASH
     }
-    const { client_id: clientId, client_secret: clientSecret } =
+    const { client_id, client_secret } = await response.json();
-      await response.json();
 
-    const clientInfo: { [key: string]: string } = {
+    const client_info: { [key: string]: string } = {
-      client_id: clientId,
+      client_id,
-      client_secret: clientSecret,
+      client_secret,
       grant_type: "password",
       response_type: "code",
       username: this.username,
@@ -47,28 +65,25 @@ class PeerTubeRequester {
     };
 
     let myParams = new URLSearchParams();
-    for (const key in clientInfo) myParams.append(key, clientInfo[key]);
+    for (const key in client_info) myParams.append(key, client_info[key]);
 
-    response = await fetch(new URL(`/api/v1/users/token`, this.domainName), {
+    response = await fetch(new URL(`/api/v1/users/token`, this.domain_name), {
       method: "post",
       body: myParams,
     });
     if (!response.ok) {
-      throw new Error("Cannot get access Token : " + response.statusText); // CRASH
+      throw new Error(response.statusText); // CRASH
     }
-    const { access_token: accessToken } = await response.json();
+    const { access_token } = await response.json();
-    return accessToken;
-  }
 
-  async uploadFromUrl(message: UploadInstruction): Promise<void> {
+    // Upload
-    const accessToken = await this.requestAuthToken();
     const myUploadForm = new URLSearchParams();
     const myHeader = new Headers();
-    myHeader.append("Authorization", `Bearer ${accessToken}`);
+    myHeader.append("Authorization", `Bearer ${access_token}`);
     for (const key in message) myUploadForm.append(key, message[key]);
 
-    const response = await fetch(
+    response = await fetch(
-      new URL("/api/v1/videos/imports", this.domainName),
+      new URL(`/api/v1/videos/imports`, this.domain_name),
       {
         method: "post",
         headers: myHeader,
@@ -80,9 +95,9 @@ class PeerTubeRequester {
       switch (response.status) {
         case 400:
           throw new Error(
-            `Bad or malformed request. Probably because your target URL (from Youtube?) was not accepted by the API.\
+            `Your target URL was not accepted by the API.\
-                        The target URL you attempted to pass: ${message.targetUrl}.
+                        Actualy it's : ${message.targetUrl}
-                        Response from the server: ${response.statusText}`
+                        ${response.statusText}`
           );
           break;
         case 403:
@@ -90,15 +105,15 @@ class PeerTubeRequester {
           break;
         case 409:
           throw new Error(
-            `Oops, your instance did not allowed the HTTPS import.\
+            `Oops, your instance had not allowed the HTTPS import.\
                         Contact your administrator.
                         ${response.statusText}`
           );
           break;
         default:
           throw new Error(
-            `Oh, you encountered an undocumented issues.\
+            `Oh, you resolved an undocumented issues.\
-                        Please create an issue to the plugin project.
+                        Please report this on the git if you have the time.
                         ERROR: ${response.statusText}`
           );
           break;

package-lock.json

@@ -1,16 +1,15 @@
 {
   "name": "peertube-plugin-auto-import-ytb",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
-      "version": "0.0.1",
+      "version": "0.0.2",
       "dependencies": {
         "@types/node-fetch": "^2.5.11",
         "form-data": "^4.0.0",
-        "listener-rss": "^0.0.3",
+        "listener-rss-agregator": "git+https://zeteo.me/gitea/Outils-PeerTube/listener-rss-agregators#1b36afbb34",
-        "listener-rss-aggregator": "^0.0.5",
         "node-fetch": "^2.6.1"
       },
       "devDependencies": {
@@ -399,10 +398,11 @@
         "rss-parser": "^3.11.0"
       }
     },
-    "node_modules/listener-rss-aggregator": {
+    "node_modules/listener-rss-agregator": {
-      "version": "0.0.5",
+      "version": "0.0.3",
-      "resolved": "https://registry.npmjs.org/listener-rss-aggregator/-/listener-rss-aggregator-0.0.5.tgz",
+      "resolved": "git+https://zeteo.me/gitea/Outils-PeerTube/listener-rss-agregators#1b36afbb344112c3827b5bcea92e1cc60bd8cf6a",
-      "integrity": "sha512-0QE7kkzurjsWr4gNAJ4X+C7UFSyaVuYq2mKYXZ3shvyj81kULpBgFZSg/70MZkUoqixgWQ5P8oxyztRDOP78tw==",
+      "hasInstallScript": true,
+      "license": "MIT",
       "dependencies": {
         "@databases/sqlite": "^3.0.0",
         "listener-rss": "^0.0.3"
@@ -799,9 +799,9 @@
       }
     },
     "node_modules/tar": {
-      "version": "4.4.14",
+      "version": "4.4.13",
-      "resolved": "https://registry.npmjs.org/tar/-/tar-4.4.14.tgz",
+      "resolved": "https://registry.npmjs.org/tar/-/tar-4.4.13.tgz",
-      "integrity": "sha512-ouN3XcSWYOAHmXZ+P4NEFJvqXL50To9OZBSQNNP30vBUFJFZZ0PLX15fnwupv6azfxMUfUDUr2fhYw4zGAEPcg==",
+      "integrity": "sha512-w2VwSrBoHa5BsSyH+KxEqeQBAllHhccyMFVHtGtdMpF4W7IRWfZjFiQceJPChOeTsSDVUpER2T8FA93pr0L+QA==",
       "dependencies": {
         "chownr": "^1.1.1",
         "fs-minipass": "^1.2.5",
@@ -1270,10 +1270,9 @@
         "rss-parser": "^3.11.0"
       }
     },
-    "listener-rss-aggregator": {
+    "listener-rss-agregator": {
-      "version": "0.0.5",
+      "version": "git+https://zeteo.me/gitea/Outils-PeerTube/listener-rss-agregators#1b36afbb344112c3827b5bcea92e1cc60bd8cf6a",
-      "resolved": "https://registry.npmjs.org/listener-rss-aggregator/-/listener-rss-aggregator-0.0.5.tgz",
+      "from": "listener-rss-agregator@git+https://zeteo.me/gitea/Outils-PeerTube/listener-rss-agregators#1b36afbb34",
-      "integrity": "sha512-0QE7kkzurjsWr4gNAJ4X+C7UFSyaVuYq2mKYXZ3shvyj81kULpBgFZSg/70MZkUoqixgWQ5P8oxyztRDOP78tw==",
       "requires": {
         "@databases/sqlite": "^3.0.0",
         "listener-rss": "^0.0.3"
@@ -1605,9 +1604,9 @@
       "integrity": "sha1-PFMZQukIwml8DsNEhYwobHygpgo="
     },
     "tar": {
-      "version": "4.4.14",
+      "version": "4.4.13",
-      "resolved": "https://registry.npmjs.org/tar/-/tar-4.4.14.tgz",
+      "resolved": "https://registry.npmjs.org/tar/-/tar-4.4.13.tgz",
-      "integrity": "sha512-ouN3XcSWYOAHmXZ+P4NEFJvqXL50To9OZBSQNNP30vBUFJFZZ0PLX15fnwupv6azfxMUfUDUr2fhYw4zGAEPcg==",
+      "integrity": "sha512-w2VwSrBoHa5BsSyH+KxEqeQBAllHhccyMFVHtGtdMpF4W7IRWfZjFiQceJPChOeTsSDVUpER2T8FA93pr0L+QA==",
       "requires": {
         "chownr": "^1.1.1",
         "fs-minipass": "^1.2.5",

package.json

@@ -1,9 +1,9 @@
 {
   "name": "peertube-plugin-auto-import-ytb",
-  "description": "Peertube plugin to auto import videos from a youtube channel to a local peertube channel",
+  "description": "PeerTube plugin quickstart",
   "version": "0.0.2",
   "author": "AmauryJOLY",
-  "bugs": "https://zeteo.me/gitea/Outils-PeerTube/peertube-plugin-auto-import-ytb/issues",
+  "bugs": "https://framagit.org/framasoft/peertube/peertube-plugin-quickstart/issues",
   "clientScripts": [],
   "css": [],
   "devDependencies": {
@@ -13,7 +13,7 @@
   "engine": {
     "peertube": ">=3.2.0"
   },
-  "homepage": "https://zeteo.me/gitea/Outils-PeerTube/peertube-plugin-auto-import-ytb",
+  "homepage": "https://framagit.org/framasoft/peertube/peertube-plugin-quickstart",
   "keywords": [
     "peertube",
     "plugin"
@@ -24,6 +24,7 @@
     "README.md"
   ],
   "scripts": {
+    "prepack": "npm i && npm run build",
     "predeploy": "npm run build",
     "deploy": "bash ./scripts/deploy.sh",
     "build": "tsc"
@@ -33,8 +34,7 @@
   "dependencies": {
     "@types/node-fetch": "^2.5.11",
     "form-data": "^4.0.0",
-    "listener-rss-aggregator": "^0.0.5",
+    "listener-rss-agregator": "git+https://zeteo.me/gitea/Outils-PeerTube/listener-rss-agregators#1b36afbb34",
-    "listener-rss": "^0.0.3",
     "node-fetch": "^2.6.1"
   }
 }

src/main.ts

@@ -1,158 +1,113 @@
-import { ListenerRssAggregator } from "listener-rss-aggregator";
+import { ListenerRssAggregator } from "listener-rss-agregator";
-import { ListenerRss } from "listener-rss";
+import { ListenerRss } from "listener-rss";
-import { PeerTubeRequester } from "../lib/peertubeRequester";
+import { PeerTubeRequester } from "../lib/peertubeRequester";
-
+
-type ListenerData = ListenerRss.Config & {
+type ListenerData = ListenerRss.Config & {
-  address: string;
+  address: string;
-  channelId: string;
+  channelId: string;
-};
+};
-
+
-let myManager: ListenerRssAggregator;
+let myManager: ListenerRssAggregator;
-let listenersDataBinding = new Map<string, ListenerData>();
+let listenersDataBinding = new Map<string, ListenerData>();
-let logger: any;
+let logger: any;
-let peertube: PeerTubeRequester | undefined = undefined;
+let peertube: PeerTubeRequester;
-let goodPeertubeCredential: boolean = false;
+
-
+import * as path from "path";
-import * as path from "path";
+import fs from "fs";
-import fs from "fs";
+
-
+async function register({
-async function register({
+  registerSetting,
-  registerSetting,
+  settingsManager,
-  settingsManager,
+  peertubeHelpers,
-  peertubeHelpers,
+}: any) {
-}: any) {
+  const basePath = peertubeHelpers.plugin.getDataDirectoryPath();
-  const basePath = peertubeHelpers.plugin.getDataDirectoryPath();
+  logger = peertubeHelpers.logger;
-  logger = peertubeHelpers.logger;
+
-
+  registerSetting({
-  registerSetting({
+    name: "ytb-urls",
-    name: "ytb-urls",
+    label: "liste des urls youtube a auto-importer",
-    label: "URL list of Youtube channel to synchronize",
+    type: "input-textarea",
-    type: "input-textarea",
+  });
-  });
+
-
+  logger.warn("setting register");
-  registerSetting({
+  fs.appendFileSync(path.join(basePath, "/storage.bd"), "");
-    name: "admin-name",
+
-    label: "Admin Username",
+  const configAggregator = await ListenerRssAggregator.instantiateAggregator(
-    type: "input",
+    path.join(basePath, "/storage.bd")
-  });
+  );
-
+  myManager = new ListenerRssAggregator(configAggregator);
-  registerSetting({
+
-    name: "admin-password",
+  peertube = new PeerTubeRequester({
-    label: "Admin Password",
+    domain_name: "http://localhost:9000",
-    type: "input-password",
+    username: "root",
-  });
+    password: "test",
-
+  });
-  logger.debug("setting register");
+
-  fs.appendFileSync(path.join(basePath, "/storage.bd"), "");
+  logger.warn("Aggregator created");
-
+
-  const configAggregator = await ListenerRssAggregator.instantiateAggregator(
+  const inputs = await settingsManager.getSetting("ytb-urls");
-    path.join(basePath, "/storage.bd")
+  if (inputs) await addListeners(inputs);
-  );
+
-  myManager = new ListenerRssAggregator(configAggregator);
+  logger.warn("Config loaded");
-
+
-  logger.debug("Aggregator created");
+  settingsManager.onSettingsChange(async (settings: any) => {
-
+    await addListeners(settings["ytb-urls"]);
-  const settingYtbUrls = await settingsManager.getSetting("ytb-urls");
+  });
-  if (settingYtbUrls) await addListeners(settingYtbUrls);
+
-
+  myManager.on("newEntries", (entries: any) => {
-  const settingCredentials: any = await settingsManager.getSettings([
+    const datas = listenersDataBinding.get(entries.addressListener);
-    "admin-name",
+    if (!datas) return;
-    "admin-password",
+
-  ]);
+    logger.warn(
-
+      "Nouvelles entrées détéctées: " +
-  if (settingCredentials["admin-name"] && settingCredentials["admin-password"])
+        JSON.stringify(entries) +
-    apiRequestInitializer({
+        " de " +
-      domainName: peertubeHelpers.config.getWebserverUrl(),
+        datas.channelId
-      username: settingCredentials["admin-name"],
+    );
-      password: settingCredentials["admin-password"],
+    for (const item of entries.items)
-    });
+      peertube.apiRequest({
-  logger.debug("Actual config loaded");
+        channelId: datas.channelId,
-
+        targetUrl: item.link,
-  settingsManager.onSettingsChange(async (settings: any) => {
+      });
-    if (
+  });
-      !peertube ||
+}
-      peertube.username != settings["admin-name"] ||
+
-      peertube.password != settings["admin-password"]
+async function addListeners(listenerInput: string) {
-    )
+  let listeners: ListenerData[];
-      apiRequestInitializer({
+  try {
-        domainName: peertubeHelpers.config.getWebserverUrl(),
+    listeners = JSON.parse(listenerInput);
-        username: settings["admin-name"],
+  } catch {
-        password: settings["admin-password"],
+    logger.warn("Erreur: malformé");
-      });
+    return;
-
+  }
-    await addListeners(settings["ytb-urls"]);
+  let newListeners = listeners.filter(
-  });
+    (item) => !listenersDataBinding.has(item.address)
-
+  );
-  myManager.on("newEntries", async (entries: any) => {
+  let removedUrls = Array.from(listenersDataBinding.keys()).filter(
-    const datas = listenersDataBinding.get(entries.addressListener);
+    (url) => !listeners.some((listener) => listener.address === url)
-    if (!datas) return;
+  );
-
+
-    logger.debug(
+  for (const newItem of newListeners) {
-      "New entries detected from channel #%i: %s",
+    listenersDataBinding.set(newItem.address, newItem);
-      datas.channelId,
+  }
-      JSON.stringify(entries)
+  for (const removedUrl of removedUrls) {
-    );
+    listenersDataBinding.delete(removedUrl);
-    for (const item of entries.items)
+  }
-      if (peertube)
+
-        await peertube.uploadFromUrl({
+  myManager.stopAll();
-          channelId: datas.channelId,
+  await myManager.saveOverride(listeners);
-          targetUrl: item.link,
+
-        });
+  if (logger) logger.warn("Configuration modifiée: " + listenerInput);
-      else {
+
-        logger.warn("Bad credential provides. New entries Skipped.");
+  myManager.startAll();
-      }
+}
-  });
+
-}
+async function unregister() {
-
+  myManager.stopAll();
-async function apiRequestInitializer(data: PeerTubeRequester.Config) {
+  return;
-  peertube = new PeerTubeRequester(data);
+}
-
+
-  try {
+module.exports = {
-    await peertube.requestAuthToken();
+  register,
-    goodPeertubeCredential = true;
+  unregister,
-    logger.debug("credential ok");
+};
-  } catch (error) {
-    logger.warn("Error during the credential validation : " + error);
-    peertube = undefined;
-    goodPeertubeCredential = false;
-  }
-}
-
-async function addListeners(listenerInput: string) {
-  let listeners: ListenerData[];
-  try {
-    listeners = JSON.parse(listenerInput);
-  } catch {
-    logger.error("Malformed URL");
-    return;
-  }
-  let newListeners = listeners.filter(
-    (item) => !listenersDataBinding.has(item.address)
-  );
-  let removedUrls = Array.from(listenersDataBinding.keys()).filter(
-    (url) => !listeners.some((listener) => listener.address === url)
-  );
-
-  for (const newItem of newListeners) {
-    listenersDataBinding.set(newItem.address, newItem);
-  }
-  for (const removedUrl of removedUrls) {
-    listenersDataBinding.delete(removedUrl);
-  }
-
-  myManager.stopAll();
-  await myManager.saveOverride(listeners);
-
-  if (logger) logger.debug("Configuration changed: " + listenerInput);
-
-  if (goodPeertubeCredential) myManager.startAll();
-}
-
-async function unregister() {
-  myManager.stopAll();
-}
-
-module.exports = {
-  register,
-  unregister,
-};