cowrie/wardenfiler: Store credentials for both successful and unsuccessful attempts

Format used is [{"Username": "pavel", "Password": "pass"}]. There is an additional "Type": ["AcceptedByServer"] property, used for credentials which the honeypot allowed.

All attempted credentials are first stored in a session. Then, when the session is closed, they are stored in the aggregation under the AID key (the aggregation ID (AID) "src_ip,dst_ip"). The credentials are flushed from the aggregation when the aggregation window expires. They are included in the Attempt.Login event.

With the successful login (event type Intrusion.UserCompromise), only the accepted pair of username/password is sent with that event.

cowrie/wardenfiler.py

@@ -253,7 +253,7 @@ class Output(cowrie.core.output.Output):
             if s in self.sessions:
                 self.sessions[s]["input"] = []
                 self.sessions[s]["loggedin"] = True
-                self.sessions[s]["credentials"].append({"Username": u, "Password": p, "Accepted": True})
+                self.sessions[s]["credentials"].append({"Username": u, "Password": p, "Type": ["AcceptedByServer"]})
 
         elif entry["eventid"] == "cowrie.login.failed":
             u, p = entry["username"], entry["password"]
@@ -403,7 +403,7 @@ class Output(cowrie.core.output.Output):
                         attach["ContentEncoding"] = "base64"
                     event["Attach"] = [attach]
                 if self.sessions[s]["credentials"]:
-                    accepted_creds = [ c for c in self.sessions[s]["credentials"] if "Accepted" in c ]
+                    accepted_creds = [ c for c in self.sessions[s]["credentials"] if "Type" in c and "AcceptedByServer" in c["Type"] ]
                     event["Credentials"] = list(accepted_creds)
                 self.save_event(event)