Skip to content

ENT-14692: Added file event types #6409

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
victormlg wants to merge 14 commits into
base: master
Choose a base branch
from
+4,089 −22
Open

ENT-14692: Added file event types #6409

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
1c8c8e9
Moved 001_vars test into 001_basics/
victormlg Oct 21, 2026
59ae932
Fixed Log message logging the number of watcher registered
victormlg Oct 21, 2026
b8a1e51
Fixed how the outcome of "then" bundles is recorded.
victormlg Oct 21, 2026
33b6db8
Added test coverage to cf-reactor
victormlg Oct 21, 2026
d09d099
Added test for the file_deleted event type
victormlg Oct 21, 2026
c1e3277
Made cf-reactor edit_line bundles
victormlg Oct 21, 2026
528ebe8
Fixed edit promises being skipped on events less than a minute apart
victormlg Oct 21, 2026
f9acb68
Added tests for all promise types inside reactor "then" bundle run on…
victormlg Oct 21, 2026
03afd79
Added file_created event type
victormlg Oct 23, 2026
cd60dd2
Added file_modified event type
victormlg Oct 23, 2026
47f0210
Added file_content_modified event type
victormlg Oct 23, 2026
1ee67c9
Added file_permissions_changed event type
victormlg Oct 23, 2026
e2e744d
Added file_owner_changed event type
victormlg Oct 23, 2026
f6543a5
Added file_size_exceeds event type
victormlg Oct 23, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions cf-agent/files_edit.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,11 @@
copy equal to the copied template file - not the
copied + edited file. */

/* The ifelapsed of the promises of edit bundles: CF_EDIT_IFELAPSED, unless the
* default ifelapsed is lower, e.g. 0 for the bundles cf-reactor runs on events,
* which may happen less than a minute apart */
#define EDIT_IFELAPSED MIN(CF_EDIT_IFELAPSED, VIFELAPSED)

typedef struct
{
char *filename;
Expand Down
8 changes: 4 additions & 4 deletions cf-agent/files_editline.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -373,7 +373,7 @@ static PromiseResult VerifyLineDeletions(EvalContext *ctx, const Promise *pp, Ed
char lockname[CF_BUFSIZE];

Attributes a = GetDeletionAttributes(ctx, pp);
a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

if (!SanityCheckDeletions(&a, pp))
{
Expand Down Expand Up @@ -453,7 +453,7 @@ static PromiseResult VerifyColumnEdits(EvalContext *ctx, const Promise *pp, Edit
char lockname[CF_BUFSIZE];

Attributes a = GetColumnAttributes(ctx, pp);
a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

if (a.column.column_separator == NULL)
{
Expand Down Expand Up @@ -547,7 +547,7 @@ static PromiseResult VerifyPatterns(EvalContext *ctx, const Promise *pp, EditCon
/* Are we working in a restricted region? */

Attributes a = GetReplaceAttributes(ctx, pp);
a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

if (!a.replace.replace_value)
{
Expand Down Expand Up @@ -733,7 +733,7 @@ static PromiseResult VerifyLineInsertions(EvalContext *ctx, const Promise *pp, E

Attributes a = GetInsertionAttributes(ctx, pp);
int allow_multi_lines = StringEqual(a.sourcetype, "preserve_all_lines");
a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

if (!SanityCheckInsertions(&a))
{
Expand Down
16 changes: 8 additions & 8 deletions cf-agent/files_editxml.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -353,7 +353,7 @@ static bool VerifyXPathBuild(EvalContext *ctx, const Attributes *attr, const Pro
CfLock thislock;
char lockname[CF_BUFSIZE], rawxpath[CF_BUFSIZE] = { 0 };

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

int ret = snprintf(rawxpath, sizeof(rawxpath), "%s",
a.xml.havebuildxpath ? a.xml.build_xpath : pp->promiser);
Expand Down Expand Up @@ -417,7 +417,7 @@ static PromiseResult VerifyTreeDeletions(EvalContext *ctx, const Attributes *att
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

if (!SanityCheckTreeDeletions(&a))
{
Expand Down Expand Up @@ -497,7 +497,7 @@ static PromiseResult VerifyTreeInsertions(EvalContext *ctx, const Attributes *at
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

PromiseResult result = PROMISE_RESULT_NOOP;
if (!SanityCheckTreeInsertions(&a, edcontext))
Expand Down Expand Up @@ -590,7 +590,7 @@ static PromiseResult VerifyAttributeDeletions(EvalContext *ctx, const Attributes
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

PromiseResult result = PROMISE_RESULT_NOOP;
if (!SanityCheckAttributeDeletions(&a))
Expand Down Expand Up @@ -673,7 +673,7 @@ static PromiseResult VerifyAttributeSet(EvalContext *ctx, const Attributes *attr
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

PromiseResult result = PROMISE_RESULT_NOOP;
if (!SanityCheckAttributeSet(&a))
Expand Down Expand Up @@ -756,7 +756,7 @@ static PromiseResult VerifyTextDeletions(EvalContext *ctx, const Attributes *att
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

PromiseResult result = PROMISE_RESULT_NOOP;
if (!SanityCheckTextDeletions(&a))
Expand Down Expand Up @@ -839,7 +839,7 @@ static PromiseResult VerifyTextSet(EvalContext *ctx, const Attributes *attr, con
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

PromiseResult result = PROMISE_RESULT_NOOP;
if (!SanityCheckTextSet(&a))
Expand Down Expand Up @@ -922,7 +922,7 @@ static PromiseResult VerifyTextInsertions(EvalContext *ctx, const Attributes *at
CfLock thislock;
char lockname[CF_BUFSIZE];

a.transaction.ifelapsed = CF_EDIT_IFELAPSED;
a.transaction.ifelapsed = EDIT_IFELAPSED;

PromiseResult result = PROMISE_RESULT_NOOP;
if (!SanityCheckTextInsertions(&a))
Expand Down
Loading
Loading