Skip to content

Commit a191ee4

Browse files
committed
fixes based on pr comments
- replaced audit event for reading channel history with document metadata read - updated description of the event - added channels and sequence into the audit event for document channel history compaction
1 parent 18caa3a commit a191ee4

4 files changed

Lines changed: 12 additions & 76 deletions

File tree

base/audit_events.go

Lines changed: 5 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -120,8 +120,7 @@ const (
120120
AuditIDDocumentImport AuditID = 55005
121121
AuditIDDocumentResync AuditID = 55006
122122
AuditIDDocumentRevoke AuditID = 55007
123-
AuditIDDocumentChannelHistory AuditID = 55008
124-
AuditIDDocumentChannelHistoryCompact AuditID = 55009
123+
AuditIDDocumentChannelHistoryCompact AuditID = 55008
125124

126125
// Document attachments events
127126
AuditIDAttachmentCreate AuditID = 55010
@@ -1161,28 +1160,13 @@ var AuditEvents = events{
11611160
FilteringPermitted: true,
11621161
EventType: eventTypeData,
11631162
},
1164-
AuditIDDocumentChannelHistory: {
1165-
Name: "Document Channel history",
1166-
Description: "A document channel history was sent to a client",
1167-
MandatoryFields: AuditFields{
1168-
AuditFieldDocID: "document id",
1169-
},
1170-
mandatoryFieldGroups: []fieldGroup{
1171-
fieldGroupAuthenticated,
1172-
fieldGroupKeyspace,
1173-
},
1174-
optionalFieldGroups: []fieldGroup{
1175-
fieldGroupRequest,
1176-
},
1177-
EnabledByDefault: false,
1178-
FilteringPermitted: true,
1179-
EventType: eventTypeData,
1180-
},
11811163
AuditIDDocumentChannelHistoryCompact: {
11821164
Name: "Document Channel history compact",
1183-
Description: "A document channel history was compacted by a client",
1165+
Description: "A document channel history was compacted by the Administrator",
11841166
MandatoryFields: AuditFields{
1185-
AuditFieldDocID: "document id",
1167+
AuditFieldDocID: "document id",
1168+
AuditFieldChannels: "channels",
1169+
AuditFieldSequence: "sequence",
11861170
},
11871171
mandatoryFieldGroups: []fieldGroup{
11881172
fieldGroupAuthenticated,

base/audit_events_fields.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,4 +86,5 @@ const (
8686
AuditFieldDocIDs = "doc_ids"
8787
AuditFieldFeedType = "feed_type"
8888
AuditFieldIncludeDocs = "include_docs"
89+
AuditFieldSequence = "seq"
8990
)

rest/audit_test.go

Lines changed: 1 addition & 53 deletions
Original file line numberDiff line numberDiff line change
@@ -2011,64 +2011,12 @@ func TestDocumentChannelHistoryCompactionAudit(t *testing.T) {
20112011
})
20122012

20132013
for _, docID := range tc.docIDs {
2014-
requireChannelHistoryCompactAuditEvent(t, output, docID)
2014+
requireDocChannelAuditEvent(t, output, base.AuditIDDocumentChannelHistoryCompact, docID)
20152015
}
20162016
})
20172017
}
20182018
}
20192019

2020-
func TestDocumentChannelHistoryAudit(t *testing.T) {
2021-
rt := createAuditLoggingRestTester(t)
2022-
defer rt.Close()
2023-
2024-
dbConfig := rt.NewDbConfig()
2025-
dbConfig.Logging = &DbLoggingConfig{
2026-
Audit: &DbAuditLoggingConfig{
2027-
Enabled: base.Ptr(true),
2028-
EnabledEvents: base.Ptr([]uint{
2029-
uint(base.AuditIDDocumentChannelHistory),
2030-
}),
2031-
},
2032-
}
2033-
RequireStatus(t, rt.CreateDatabase("db", dbConfig), http.StatusCreated)
2034-
2035-
testCases := []struct {
2036-
name string
2037-
docID string
2038-
}{
2039-
{
2040-
name: "existing doc",
2041-
docID: "existing_doc",
2042-
},
2043-
}
2044-
2045-
for _, tc := range testCases {
2046-
rt.Run(tc.name, func(t *testing.T) {
2047-
rt.CreateTestDoc(tc.docID)
2048-
2049-
output := base.AuditLogContents(t, func(t testing.TB) {
2050-
RequireStatus(t, rt.SendAdminRequest(http.MethodGet, "/{{.keyspace}}/_channel_history/"+tc.docID, ""), http.StatusOK)
2051-
})
2052-
2053-
requireChannelHistoryAuditEvent(t, output, tc.docID)
2054-
})
2055-
}
2056-
}
2057-
2058-
// requireChannelHistoryCompactAuditEvent asserts that exactly one AuditIDDocumentChannelHistoryCompact event
2059-
// was logged for the given docID.
2060-
func requireChannelHistoryCompactAuditEvent(t testing.TB, output []byte, docID string) {
2061-
t.Helper()
2062-
requireDocChannelAuditEvent(t, output, base.AuditIDDocumentChannelHistoryCompact, docID)
2063-
}
2064-
2065-
// requireChannelHistoryAuditEvent asserts that exactly one AuditIDDocumentChannelHistory event
2066-
// was logged for the given docID.
2067-
func requireChannelHistoryAuditEvent(t testing.TB, output []byte, docID string) {
2068-
t.Helper()
2069-
requireDocChannelAuditEvent(t, output, base.AuditIDDocumentChannelHistory, docID)
2070-
}
2071-
20722020
func requireDocChannelAuditEvent(t testing.TB, output []byte, eventID base.AuditID, docID string) {
20732021
t.Helper()
20742022
events := jsonLines(t, output)

rest/doc_api.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -945,7 +945,7 @@ func (h *handler) handleGetDocChannelHistory() error {
945945
return err
946946
}
947947

948-
base.Audit(h.ctx(), base.AuditIDDocumentChannelHistory, base.AuditFields{
948+
base.Audit(h.ctx(), base.AuditIDDocumentMetadataRead, base.AuditFields{
949949
base.AuditFieldDocID: docid,
950950
})
951951

@@ -988,8 +988,11 @@ func (h *handler) handleCompactDocChannelHistory() error {
988988
res := map[string][]string{
989989
"compacted_channels": channels,
990990
}
991+
991992
base.Audit(h.ctx(), base.AuditIDDocumentChannelHistoryCompact, base.AuditFields{
992-
base.AuditFieldDocID: docid,
993+
base.AuditFieldDocID: docid,
994+
base.AuditFieldChannels: channels,
995+
base.AuditFieldSequence: req.Seq,
993996
})
994997

995998
h.writeJSON(res)

0 commit comments

Comments
 (0)