Info général

Ce serveur n'est pas apte à être utilisé en tant que serveur publique ! Entre autres limitations, il n'y a aucun contrôle d'authentification. Il est donc configuré afin d'être uniquement disponible sur localhost. Ce serveur est dédié uniquement à la communication entre processus sur le même ordinateur, lorsque des codes en autres langues informatiques (Python, Julia, R) veulent accéder un nœud Constellation local.

Utilisation

Si vous voulez tout simplement utiliser Constellation avec Python ou R, veuillez installer les librairies respectives constellation-py, Constellation.jl et constellation-R (en progrès). Celles-ci se chargeront automatiquement d'installer le serveur Constellation sur votre machine, si nécessaire.

Installation globale

L'installation globale vous permet de lancer un serveur websocket Constellation de la ligne de commande. Si vous comptez simplement utiliser le serveur Constellation (y compris pour une analyse en Python, en R ou en Julia), c'est ceci ce que vous voulez.

curl https://raw.githubusercontent.com/reseau-constellation/serveur-ws/principale/installer.cjs | node -

Ligne de commande

Pour lancer le serveur : constl lancer [-p <port>] [-b]

Pour obtenir le numéro de la version : constl version

Pour obtenir de l'aide : constl -a

Utilisation dans un autre projet

Si vous voulez incorporer le serveur Constellation dans une autre librairie JavaScript, vous pouvez l'installer ainsi :

pnpm add @constl/serveur

Utilisation programmatique

Serveur

import { lancerServeur } from "@constl/serveur";

const { fermerServeur, port } = await lancerServeur();

// `port` contient maintenant le numéro de port à utiliser dans le client

// Lorsqu'on a fini :
fermerServeur();

Invoqué sans configuration, lancerServeur trouvera un port disponible sur localhost et redonnera cette valeur dans la variable port. Vous pouvez également spécifier une configuration Constellation plus précise :

import { lancerServeur } from "@constl/serveur";

const { fermerServeur, port } = await lancerServeur({
  port: 5003,
  optsConstellation: {
    dossier: "mon-dossier-constellation",  // Dossier du compte Constellation
  }
});

Client

Vous voudrez aussi probablement utiliser le client websocket qui est aussi disponible dans cette librairie.

import { lancerClient } from "@constl/serveur";

const port = 5001  // Ou une autre valeur, selon `lancerServeur`
const { client, fermerClient } = lancerClient(port);

// On peut maintenant appeler des fonctions sur le client comme s'il
// s'agissait d'un client Constellation ordinaire :
let noms = {};
const oublierNoms = await client.profil.suivreNoms(x => noms = x);

// Pour arrêter le suivi :
oublierNoms();

// Lorsqu'on a fini :
fermerClient();

Avancé : spécification client

Cette librairie vient avec son propre client websocket conforme. Une version pour Python et pour Julia sont également disponibles. Cependant, si vous voulez développer des clients pour d'autres langues informatiques, vous devrez développer un client dans la langue de votre choix. Ce client devra répondre à la spécification suivante :

Actions

Pour invoquer une action Constellation, le client devra envoyer un message de la forme suivante :

interface MessageActionPourTravailleur extends MessagePourTravailleur {
  type: "action";
  idRequête: string;  // Un identifiant unique (qui sera inclut dans le message de retour avec le résultat de la requête)
  fonction: string[];  // Le nom de la fonction Constellation, en forme de liste
  args: { [key: string]: unknown };  // Les arguments de la fonction Constellation
}

Il recevra ensuite, du serveur, un message de la forme suivante :

interface MessageActionDeTravailleur extends MessageDeTravailleur {
  type: "action";
  idRequête: string;  // Le même identifiant qu'inclus dans le message `MessageActionPourTravailleur` originalement envoyé au serveur
  résultat: unknown;  // Le résultat de la fonction
}

À titre d'exemple, la fonction suivante de l'IPA Constellation crée une nouvelle base de données.

const idBd = await client.bds.créerBd({ licence: "ODbl-1_0" })

Afin d'invoquer la même fonction par le serveur Constellation, nous enverrons un message comme suit (utilisant le module uuid pour générer un identifiant unique pour la requête). L'exemple de code est donné en TypeScript, mais pourrait être en n'importe quel langage informatique.

import { v4 as uuidv4 } from 'uuid';

const idRequête = uuidv4();

const message: MessageActionPourTravailleur = {
  type: "action",
  idRequête,
  fonction: ["bds", "créerBd"],
  args: { "licence": "ODbl-1_0" },
}

// Envoyer le message par WS au serveur sur le port connecté.

Et nous recevrons une réponse comme tel :

{
  "type": "action",
  "idRequête": "1b9d6bcd-bbfd-4b2d-9b5d-ab8dfbbd4bed",
  "résultat": "/orbitdb/..."
}

Suivis

Les fonctions qui suivent les résultats d'une requête à travers le temps, plutôt que je redonner un résultat ponctuel dans le temps, sont un peu plus compliquées. La fonction suivante suis les noms d'une variable :

const idDeMaVariable = "/orbitdb/..."  // Selon la variable qui vous intéresse ; générée par `client.variables.créerVariable`
const fOublier = await client.variables.suivreNomsVariable({ idRequête: idDeMaVariable, f: console.log });

// Annuler le suivi
await fOublier();

Pour invoquer la même fonction par le serveur, nous enverrons le message suivant :

import { v4 as uuidv4 } from 'uuid';

const idRequête = uuidv4();

const message: MessageSuivrePourTravailleur = {
  type: "suivre",
  idRequête,
  fonction: ["variables", "suivreNomsVariable"],
  args: { idRequête: idDeMaVariable },
  nomArgFonction: "f",  // Nom de l'argument correspondant à la fonction de suivi
}

// Envoyer le message par WS au serveur sur le port connecté.

Et nous recevrons une réponse comme tel lorsque le suivi est amorcé :

{
  "type": "suivrePrêt",
  "idRequête": "1b9d6bcd-bbfd-4b2d-9b5d-ab8dfbbd4bed",
}

Et des messages suiveront avec les résultats en temps réel de la recherche :

{
  "type": "suivre",
  "idRequête": "1b9d6bcd-bbfd-4b2d-9b5d-ab8dfbbd4bed",
  "résultat": { "fr": "Précipitation", "த": "பொழிவு" }
}

Pour annuler le suivi, envoyer le message suivant :

const message: MessageRetourPourTravailleur = {
  type: "retour",
  idRequête,
  fonction: "fOublier"
}

// Envoyer le message par WS au serveur sur le port connecté.

Recherches

Une recherche s'éffectue de manière similaire à un suivi, mais elle retourne également une fonction pour changer le nombre de résultats désirés.

const { fOublier, fChangerN } = await client.recherche.rechercherBdSelonNom({ nomBd: "météo", f: console.log, nRésultatsDésirés: 30 });

// Demander plus de résultats
await fChangerN(40);

// Annuler la recherche
await fOublier();

Pour invoquer la même fonction par le serveur, nous enverrons le message suivant :

import { v4 as uuidv4 } from 'uuid';

const idRequête = uuidv4();

const message: MessageSuivrePourTravailleur = {
  type: "suivre",
  idRequête,
  fonction: ["recherche", "rechercherBdSelonNom"],
  args: { nomBd: "météo", nRésultatsDésirés: 30 },
  nomArgFonction: "f",  // Nom de l'argument correspondant à la fonction de suivi
}

// Envoyer le message par WS au serveur sur le port connecté.

Et nous recevrons une réponse comme tel lorsque la recherche est amorcée :

{
  "type": "suivrePrêt",
  "idRequête": "1b9d6bcd-bbfd-4b2d-9b5d-ab8dfbbd4bed",
  "fonctions": ["fOublier", "fChangerN"]
}

Pour changer le nombre de résultats désirés, il suffit d'envoyer un message comme suit :

const message: MessageRetourPourTravailleur = {
  type: "retour",
  idRequête,
  fonction: "fChangerN",
  args: [40]
}

// Envoyer le message par WS au serveur sur le port connecté.

Erreurs

Si le serveur a des difficultés, il enverra un message d'erreur. Le champ idRequête est facultatif et sera présent si l'erreur provient spécifiquement d'une requête particulière.

{
  "type": "erreur",
  "idRequête": "1b9d6bcd-bbfd-4b2d-9b5d-ab8dfbbd4bed",
  "erreur": "Message d'erreur tel que rencontré par le serveur."
}