Mercurial > prosody-hg

comparison plugins/mod_s2s.lua @ 14142:5aacae4b2ccf

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Merge 13.0->trunk
author Matthew Wild <mwild1@gmail.com>
date Fri, 17 Apr 2026 17:47:01 +0100
parents c1469296190d 18d364587db5
children b6b09dace24b
comparison
equal deleted inserted replaced
14138:c1469296190d 14142:5aacae4b2ccf
930 end 930 end
931 931
932 function listener.onconnect(conn) 932 function listener.onconnect(conn)
933 conn:setoption("keepalive", opt_keepalives); 933 conn:setoption("keepalive", opt_keepalives);
934 local session = sessions[conn]; 934 local session = sessions[conn];
935 local event_data = { session = session, conn = conn };
935 if not session then -- New incoming connection 936 if not session then -- New incoming connection
936 session = s2s_new_incoming(conn); 937 session = s2s_new_incoming(conn);
937 sessions[conn] = session; 938 sessions[conn] = session;
938 session.log("debug", "Incoming s2s connection"); 939 session.log("debug", "Incoming s2s connection");
939 module:fire_event("s2sin-connected", { session = session }) 940 module:fire_event("s2sin-connected", event_data)
940 initialize_session(session); 941 initialize_session(session);
941 m_accepted_tcp_connections:with_labels():add(1) 942 m_accepted_tcp_connections:with_labels():add(1)
942 else -- Outgoing session connected 943 else -- Outgoing session connected
943 module:fire_event("s2sout-connected", { session = session }) 944 module:fire_event("s2sout-connected", event_data)
944 session:open_stream(session.from_host, session.to_host); 945 session:open_stream(session.from_host, session.to_host);
945 end 946 end
946 module:fire_event("s2s-connected", { session = session, conn = conn }) 947 module:fire_event("s2s-connected", event_data)
947 session.ip = conn:ip(); 948 session.ip = conn:ip();
948 end 949 end
949 950
950 function listener.onincoming(conn, data) 951 function listener.onincoming(conn, data)
951 local session = sessions[conn]; 952 local session = sessions[conn];