/*-------------------------------------------------------------------------
 *
 * replorigindesc.c
 *   rmgr descriptor routines for replication/logical/origin.c
 *
 * Portions Copyright (c) 2015-2025, PostgreSQL Global Development Group
 *
 *
 * IDENTIFICATION
 *   src/backend/access/rmgrdesc/replorigindesc.c
 *
 *-------------------------------------------------------------------------
 */
#include "postgres.h"

#include "replication/origin.h"

void
replorigin_desc(StringInfo buf, XLogReaderState *record)
{
 char    *rec = XLogRecGetData(record);
 uint8  info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;

 switch (info)
 {
  case XLOG_REPLORIGIN_SET:
   {
    xl_replorigin_set *xlrec;

    xlrec = (xl_replorigin_set *) rec;

    appendStringInfo(buf, "set %u; lsn %X/%X; force: %d",
         xlrec->node_id,
         LSN_FORMAT_ARGS(xlrec->remote_lsn),
         xlrec->force);
    break;
   }
  case XLOG_REPLORIGIN_DROP:
   {
    xl_replorigin_drop *xlrec;

    xlrec = (xl_replorigin_drop *) rec;

    appendStringInfo(buf, "drop %u", xlrec->node_id);
    break;
   }
 }
}

const char *
replorigin_identify(uint8 info)
{
 switch (info)
 {
  case XLOG_REPLORIGIN_SET:
   return "SET";
  case XLOG_REPLORIGIN_DROP:
   return "DROP";
  default:
   return NULL;
 }
}