sr_post.h

/* vim:set ft=c ts=2 sw=2 sts=2 et cindent: */

#ifndef SR_POST_H
#define SR_POST_H 1

/*
 * Usage info after license block.
 *
 * This code is by Peter Silva copyright (c) 2017 part of MetPX.
 * copyright is to the Government of Canada. code is GPL.
 *
 * based on a amqp_sendstring from rabbitmq-c package
 * the original license is below:
 */

/* 
  Minimal c implementation to allow posting of sr_post(7) messages.

  call an sr_context_init to set things up.
  then sr_post will post files,
  then sr_close to tear the connection down.

  there is an all in one function: connect_and_post that does all of the above.

 */

#include "sr_context.h"
#include "sr_consume.h"

/* 
 * um... set variable during rm' events to trigger an rmdir instead of a file unlink.
 */
extern int rmdir_in_progress;

void v03encode(char *message_body, struct sr_context *sr_c, struct sr_message_s *m);
/* 
   fill the message body with a v03 encoded representation of the given message, in the given context.
 */

void realpath_adjust(struct sr_log_context_s *logctx, const char *input_path, char *output_path, signed int adjust);
/*
 * apply the realpath function as specified by the adjustment.
 * == 0 - apply it to the whole path, but if that fails (say, for a broken link) the back retry with -1.
 *
 * when adjust is non-zero, examine a subset of elements in the path, denoted by a number of slashes. 
 *  < 0 - negative values... start from the right, so -1 means the directory immediately containing the file.
 *  > 0 - positive values... start from the left. so 3 means apply realpath to first three elements of the path.
 *
 */

void sr_post_message(struct sr_context *sr_c, struct sr_message_s *m);
/* 
   post the given message using the established context.
   (posts over an existing connection.)
*/

void sr_post(struct sr_context *sr_c, const char *fn, struct stat *sb);
/* 
   post the given file name using the established context.
   (posts over an existing connection.)

   The struct stat is normally the result of lstat(fn,sb);
   sr_post reads:  st_size, st_atim, st_mtim, and st_mode.
   those fields are used to build the advertisement.

   if passed sb=NULL, then the sr_post generates an 'R' (remove) message
   for the named file.

 */

void sr_post_rename(struct sr_context *sr_c, const char *oldname, const char *newname);
/* 
   post rename results in a post for removal of the old name, and creation of the new name.

 */

int sr_post_init(struct sr_context *sr_c);
 /*
    At beginning of posting session, initialize (involves declaring an exchange.)
  */

int sr_post_cleanup(struct sr_context *sr_c);
 /*
    Clean up broker resources declared by post_init (deletes an exchange.)
  */

#endif