Skip to content

Commit

Permalink
Changed entry_identifier to entryIdentifier
Browse files Browse the repository at this point in the history
  • Loading branch information
chrismaddalena committed Apr 5, 2024
1 parent 2c43e21 commit 11d1fb3
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions sync.py
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ class MythicSync:
entry_identifier_query = gql(
"""
query checkEntryIdentifier($entry_identifier: String!, $oplog: bigint!){
oplogEntry(where: {oplog: {_eq: $oplog}, entry_identifier: {_eq: $entry_identifier}}, limit: 1){
oplogEntry(where: {oplog: {_eq: $oplog}, entryIdentifier: {_eq: $entry_identifier}}, limit: 1){
id
}
}
Expand Down Expand Up @@ -109,7 +109,7 @@ class MythicSync:
output: $output,
comments: $comments,
operatorName: $operatorName,
entry_identifier: $entry_identifier
entryIdentifier: $entry_identifier
}) {
returning { id }
}
Expand Down Expand Up @@ -141,7 +141,7 @@ class MythicSync:
output: $output,
comments: $comments,
operatorName: $operatorName,
entry_identifier: $entry_identifier
entryIdentifier: $entry_identifier
}) {
returning { id }
}
Expand Down Expand Up @@ -459,7 +459,7 @@ async def _create_entry(self, message: dict) -> None:
"entry_identifier": gw_message['entry_identifier'],
})
if query_result and "oplogEntry" in query_result and len(query_result["oplogEntry"]) > 0:
mythic_sync_log.info(f"Duplicate entry found based on entry_identifier, {gw_message['entry_identifier']}, not sending")
mythic_sync_log.info(f"Duplicate entry found based on entryIdentifier, {gw_message['entryIdentifier']}, not sending")
# save off id of oplog entry with this gw_message['entry_identifier'] so we don't try to send it again
self.rconn.set(entry_id, query_result["oplogEntry"][0]["id"])
return
Expand Down

0 comments on commit 11d1fb3

Please sign in to comment.