Cómo sincronizar los derechos de los usuarios (integración del servidor)

Los editores usan principalmente la integración del servidor para administrar a los lectores y sus derechos. Ante todo, usan UpdateReaderEntitlements para actualizar el registro de Google del derecho de un ID del producto para un PPID.

Nota: Se deben crear lectores con la integración de js del cliente para crear y administrar suscripciones vinculadas.

Configuración de Google Cloud

La configuración de Subscription Linking en Google Cloud incluye dos componentes principales:

1. La habilitación de la API para un proyecto determinado
2. La creación de una cuenta de servicio para acceder a la API

Cómo habilitar la API de Subscription Linking

Para usar una cuenta de servicio y administrar los derechos de un lector, un proyecto de Google Cloud debe tener habilitada la API de Subscription Linking y una cuenta de servicio de OAuth configurada correctamente. Para habilitar la API de Subscription Linking para un proyecto, navega desde el menú -> APIs y servicios -> Biblioteca y busca Subscription Linking, o visita la página directamente:

https://console.cloud.google.com/apis/library?project=gcp_project_id

Figura 1: Navegación a la biblioteca de la API y habilitación de la API para un proyecto de Google Cloud

Cómo crear una cuenta de servicio

Las cuentas de servicio se usan para permitir el acceso de tu aplicación a la API de Subscription Linking.

1. Crea una cuenta de servicio desde la consola de tu proyecto.
2. Crea credenciales para la cuenta de servicio y almacena el archivo credentials.json en una ubicación segura a la que pueda acceder tu aplicación.
3. Otorga el rol de IAM de "Administrador de vinculaciones de suscripciones" a la cuenta de servicio que creaste. Para un control detallado de las capacidades de la cuenta de servicio, puedes asignar el rol correspondiente desde la siguiente tabla:

Capacidad/rol	Administrador de vinculaciones de suscripciones	Visualizador de vinculaciones de suscripciones	Visualizador de derechos de vinculaciones de suscripciones
Obtener derechos de lector
Obtener lectores
Actualizar derechos de lector
Borrar lectores

Precaución: Las claves de cuenta de servicio son un riesgo de seguridad si no se administran de forma adecuada. Debes elegir una alternativa más segura a las claves de la cuenta de servicio siempre que sea posible. Si te debes autenticar con una clave de cuenta de servicio, eres responsable de la seguridad de la clave privada y de otras operaciones de administración, como la rotación de claves. Si quieres obtener más información, consulta las prácticas recomendadas para administrar claves de cuentas de servicio.

Cómo usar cuentas de servicio con la API de Subscription Linking

Para autenticar llamadas a la API de Subscription Linking con cuentas de servicio, usa la biblioteca cliente de googleapis (que controla automáticamente las solicitudes de access_token) o firma solicitudes directamente con la API de REST. Si usas la API de REST, primero debes obtener un access_token (a través de la biblioteca de Google Auth o con un JWT de cuenta de servicio) y, luego, incluirlo en el encabezado Authorization.

Los siguientes ejemplos de biblioteca cliente y API de REST incluyen código de muestra para llamar a getReader(), getReaderEntitlements(), updateReaderEntitlements() y deleteReader().

Nota: Para ver una demostración en vivo de todos los métodos de la API, consulta la demostración de Subscription Linking y su código.

Biblioteca cliente

En esta sección, se explica cómo usar la biblioteca cliente de googleapis en Node.js.

Solicitud de muestra

Para el campo keyFile en el constructor Auth.GoogleAuth, establece la ruta de acceso a tu clave de cuenta de servicio. Si no puedes exportar una clave de cuenta de servicio debido a la política de tu organización, puedes usar el método de credenciales predeterminadas de la cuenta (ADC). Si usas el método de ADC, no necesitas proporcionar el campo keyFile, ya que ADC buscará las credenciales por sí solo.

import {readerrevenuesubscriptionlinking_v1, Auth} from 'googleapis';
const subscriptionLinking = readerrevenuesubscriptionlinking_v1.Readerrevenuesubscriptionlinking;

class SubscriptionLinking {
  constructor() {
    this.auth = new Auth.GoogleAuth({
      keyFile: process.env.KEY_FILE,
      scopes: [
        'https://www.googleapis.com/auth/readerrevenue.subscriptionlinking.manage'
      ],
    })
  }

  init() {
    return new subscriptionLinking(
        {version: 'v1', auth: this.auth})
  }
}

const subscriptionLinkingApi = new SubscriptionLinking();
const client = subscriptionLinkingApi.init();

/**
 * Retrieves details for a specific reader associated with the publication.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader.
 * @return {Promise<object>} A promise that resolves with the reader's details
 *  from the API.
 */
async function getReader(ppid) {
  const publicationId = process.env.PUBLICATION_ID;
  return await client.publications.readers.get({
    name: `publications/${publicationId}/readers/${ppid}`,
  });
}

/**
 * Updates the entitlements for a specific reader.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader whose
 *  entitlements are being updated.
 * @return {Promise<object>} A promise that resolves with the result of the
 *  updated entitlements object.
 */
async function updateReaderEntitlements(ppid) {
  const publicationId = process.env.PUBLICATION_ID;
  const requestBody = {
    /*
    Refer to
    https://developers.google.com/news/subscribe/subscription-linking/appendix/glossary#entitlements_object
    */
    entitlements : [{
      product_id: `${publicationId}:basic`,
      subscription_token: 'abc1234',
      detail: 'This is our basic plan',
      expire_time: '2025-10-21T03:05:08.200564Z'
    }]
  };
  return await client.publications.readers.updateEntitlements({
    name: `publications/${publicationId}/readers/${ppid}/entitlements`,
    requestBody
  });
}

/**
 * Retrieves the current entitlements for a specific reader.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader.
 * @return {Promise<object>} A promise that resolves with the reader's entitlements object.
 */
async function getReaderEntitlements(ppid) {
  const publicationId = process.env.PUBLICATION_ID;
  return await client.publications.readers.getEntitlements({
    name: `publications/${publicationId}/readers/${ppid}/entitlements`
  });
}

/**
 * Deletes a specific Subscription Linkikng reader record associated with the publication.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader to be deleted.
 * @param {boolean=} forceDelete - If true, delete the user even if their
 *  entitelements are not empty
 * @return {Promise<object>} A promise that resolves upon successful deletion
 *  with an empty object ({})
 */
async function deleteReader(ppid, forceDelete = false) {
  const publicationId = process.env.PUBLICATION_ID;
  return await client.publications.readers.delete({
    name: `publications/${publicationId}/readers/${ppid}`
    force: forceDelete
  });
}

API de REST

Si quieres llamar a los extremos de la API de REST, puedes usar cualquiera de los métodos para obtener accessToken y establecer el encabezado Authorization.

1. Usa la biblioteca GoogleAuth

Para la clave credentials, puedes usar una clave de cuenta de servicio o una credencial predeterminada de la cuenta (ADC). Si eliges el método de ADC, no necesitas proporcionar el campo credentials, ya que ADC buscará las credenciales por sí solo.

import { GoogleAuth } from 'google-auth-library';
import credentialJson from 'path_to_your_json_file' with { type: 'json' };

const auth = new GoogleAuth({
    credentials: credential_json,
    scopes: [
      'https://www.googleapis.com/auth/readerrevenue.subscriptionlinking.manage'
    ]
});

async function getAccessToken() {
    const accessToken = await auth.getAccessToken();
    return accessToken;
}

2. Genera un access_token con un JWT de cuenta de servicio

import fetch from 'node-fetch';
import jwt from 'jsonwebtoken';

function getSignedJwt() {
  /*
    Either store the service account credentials string in an environmental variable
    Or implement logic to fetch it.
  */
  const key_file = process.env.CREDENTIALS_STRING

  const issueDate = new Date();
  const expireMinutes = 60;
  const offsetInSeconds = issueDate.getTimezoneOffset() * 60000;
  const expireDate = new Date(issueDate.getTime() + (expireMinutes * 60000));
  const iat = Math.floor((issueDate.getTime() + offsetInSeconds) / 1000);
  const exp = Math.floor((expireDate.getTime() + offsetInSeconds) / 1000);

  const token = {
    iss: key_file.client_email,
    iat,
    exp,
    aud: 'https://oauth2.googleapis.com/token',
    scope:'https://www.googleapis.com/auth/readerrevenue.subscriptionlinking.manage',
  }
  return jwt.sign(token, key_file.private_key, {
    algorithm: 'RS256',
    keyid: key_file.private_key_id,
  })
}

async function getAccessToken(signedJwt) {
  let body = new URLSearchParams();
  body.set('grant_type', 'urn:ietf:params:oauth:grant-type:jwt-bearer');
  body.set('assertion', signedJwt);
  const response = await fetch('https://oauth2.googleapis.com/token', {
    method: 'POST',
    headers: {'Content-Type': 'application/x-www-form-urlencoded'},
    body
  })
  const accessResponse = await response.json();
  return accessResponse.access_token;
}

Código de muestra para llamadas a la API de REST con la biblioteca de Google Auth

import { GoogleAuth } from 'google-auth-library';
import fetch from 'node-fetch'
import credentialJson from 'path_to_your_json_file' with { type: 'json' };

const BASE_SUBSCRIPTION_LINKING_API_URL='https://readerrevenuesubscriptionlinking.googleapis.com/v1';
const publicationId = process.env.PUBLICATION_ID

const auth = new GoogleAuth({
    credentials: credentialJson,
    scopes: [
      'https://www.googleapis.com/auth/readerrevenue.subscriptionlinking.manage'
    ]
});

async function getAccessToken() {
    const accessToken = await auth.getAccessToken();
    return accessToken;
}

/**
 * Retrieves details for a specific reader associated with the publication.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader.
 * @return {object} reader json for the given ppid
 */
async function getReader(ppid) {
  const endpoint = `${BASE_SUBSCRIPTION_LINKING_API_URL}/publications/${publicationId}/readers/${ppid}`;
  const accessToken = await getAccessToken();
  const response = await fetch(endpoint, {
     method: 'GET',
     headers: {
       Authorization: `Bearer ${accessToken}`,
     },
   });
  const reader = await response.json();
  return reader;
}

/**
 * Updates the entitlements for a specific reader.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader.
 * @return {object} the updated entitlements object in json.
 */
async function updateReaderEntitlements(ppid) {
  const endpoint = `${BASE_SUBSCRIPTION_LINKING_API_URL}/publications/${publicationId}/readers/${ppid}/entitlements`;
  const requestBody = {
    /*
    Refer to
    https://developers.google.com/news/subscribe/subscription-linking/appendix/glossary#entitlements_object
    */
    entitlements : [{
      product_id: `${publicationId}:basic`,
      subscription_token: 'abc1234',
      detail: 'This is our basic plan',
      expire_time: '2025-10-21T03:05:08.200564Z'
    }]
  };
  const response = await fetch(endpoint, {
     method: 'PATCH',
     headers: {
       Authorization: `Bearer ${accessToken}`,
       'Content-Type': 'application/json',
     },
     body: JSON.stringify(requestBody)
   })
  const updatedEntitlements = await response.json();
  return updatedEntitlements;
}

/**
 * Retrieves the current entitlements for a specific reader.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader.
 * @return {object} the reader's entitlements object in json.
 */
async function getReaderEntitlements(ppid) {
  const endpoint = `${BASE_SUBSCRIPTION_LINKING_API_URL}/publications/${publicationId}/readers/${ppid}/entitlements`;
  const accessToken = await getAccessToken();
  const response = await fetch(endpoint, {
     method: 'GET',
     headers: {
       Authorization: `Bearer ${accessToken}`,
     },
   });
  const entitlements = await response.json();
  return entitlements;
}

/**
 * Deletes a specific Subscription Linkikng reader record associated with the publication.
 * @async
 * @param {string} ppid - The Publisher Provided ID (ppid) for the reader.
 * @param {boolean=} forceDelete - If true, delete the user even if their
 *  entitelements are not empty
 * @return {object} returns an empty object ({}) if the delete operation is successful
 */
async function deleteReader(ppid, forceDelete = false) {
  const endpoint = `${BASE_SUBSCRIPTION_LINKING_API_URL}/publications/${publicationId}/readers/${ppid}?force=${forceDelete}`;
  const response = await fetch(endpoint, {
     method: 'DELETE',
     headers: {
       Authorization: `Bearer ${accessToken}`,
     }
   });
  const result = await response.json();
  return result;
}