| 52 | | |
|---|
| 53 | | /* |
|---|
| 54 | | |
|---|
| 55 | | don't forget to create these fn's in your surfnet ids database. |
|---|
| 56 | | |
|---|
| 57 | | |
|---|
| 58 | | CREATE PROCEDURAL LANGUAGE plpgsql; |
|---|
| 59 | | |
|---|
| 60 | | CREATE FUNCTION surfnet_attack_add(integer, inet, integer, inet, integer, macaddr, inet) RETURNS integer |
|---|
| 61 | | AS $_$DECLARE |
|---|
| 62 | | p_severity ALIAS FOR $1; |
|---|
| 63 | | p_attackerip ALIAS FOR $2; |
|---|
| 64 | | p_attackerport ALIAS FOR $3; |
|---|
| 65 | | p_decoyip ALIAS FOR $4; |
|---|
| 66 | | p_decoyport ALIAS FOR $5; |
|---|
| 67 | | p_hwa ALIAS FOR $6; |
|---|
| 68 | | p_localhost ALIAS FOR $7; |
|---|
| 69 | | m_attackid INTEGER; |
|---|
| 70 | | m_sensorid INTEGER; |
|---|
| 71 | | BEGIN |
|---|
| 72 | | |
|---|
| 73 | | SELECT INTO m_sensorid surfnet_sensorid_get(p_localhost); |
|---|
| 74 | | SELECT INTO m_attackid surfnet_attack_add_by_id(p_severity, |
|---|
| 75 | | p_attackerip, p_attackerport, p_decoyip, |
|---|
| 76 | | p_decoyport, p_hwa, m_sensorid); |
|---|
| 77 | | |
|---|
| 78 | | return m_attackid; |
|---|
| 79 | | END$_$ |
|---|
| 80 | | LANGUAGE plpgsql; |
|---|
| 81 | | |
|---|
| 82 | | |
|---|
| 83 | | CREATE FUNCTION surfnet_attack_add_by_id(integer, inet, integer, inet, integer, macaddr, integer) RETURNS integer |
|---|
| 84 | | AS $_$DECLARE |
|---|
| 85 | | p_severity ALIAS FOR $1; |
|---|
| 86 | | p_attackerip ALIAS FOR $2; |
|---|
| 87 | | p_attackerport ALIAS FOR $3; |
|---|
| 88 | | p_decoyip ALIAS FOR $4; |
|---|
| 89 | | p_decoyport ALIAS FOR $5; |
|---|
| 90 | | p_hwa ALIAS FOR $6; |
|---|
| 91 | | p_sensorid ALIAS FOR $7; |
|---|
| 92 | | m_attackid INTEGER; |
|---|
| 93 | | BEGIN |
|---|
| 94 | | INSERT INTO attacks |
|---|
| 95 | | (severity, |
|---|
| 96 | | timestamp, |
|---|
| 97 | | dest, |
|---|
| 98 | | dport, |
|---|
| 99 | | source, |
|---|
| 100 | | sport, |
|---|
| 101 | | sensorid, |
|---|
| 102 | | src_mac) |
|---|
| 103 | | VALUES |
|---|
| 104 | | (p_severity, |
|---|
| 105 | | extract(epoch from current_timestamp(0))::integer, |
|---|
| 106 | | p_attackerip, |
|---|
| 107 | | p_attackerport, |
|---|
| 108 | | p_decoyip, |
|---|
| 109 | | p_decoyport, |
|---|
| 110 | | p_sensorid, |
|---|
| 111 | | p_hwa); |
|---|
| 112 | | |
|---|
| 113 | | SELECT INTO m_attackid currval('attacks_id_seq'); |
|---|
| 114 | | return m_attackid; |
|---|
| 115 | | END$_$ |
|---|
| 116 | | LANGUAGE plpgsql; |
|---|
| 117 | | |
|---|
| 118 | | |
|---|
| 119 | | |
|---|
| 120 | | CREATE FUNCTION surfnet_attack_update_severity(integer, integer) RETURNS void |
|---|
| 121 | | AS $_$DECLARE |
|---|
| 122 | | p_attackid ALIAS FOR $1; |
|---|
| 123 | | p_severity ALIAS FOR $2; |
|---|
| 124 | | BEGIN |
|---|
| 125 | | UPDATE attacks SET severity = p_severity WHERE id = p_attackid; |
|---|
| 126 | | return; |
|---|
| 127 | | END;$_$ |
|---|
| 128 | | LANGUAGE plpgsql; |
|---|
| 129 | | |
|---|
| 130 | | |
|---|
| 131 | | CREATE FUNCTION surfnet_detail_add(integer, inet, integer, character varying) RETURNS void |
|---|
| 132 | | AS $_$DECLARE |
|---|
| 133 | | p_attackid ALIAS FOR $1; |
|---|
| 134 | | p_localhost ALIAS FOR $2; |
|---|
| 135 | | p_type ALIAS FOR $3; |
|---|
| 136 | | p_data ALIAS FOR $4; |
|---|
| 137 | | |
|---|
| 138 | | m_sensorid INTEGER; |
|---|
| 139 | | BEGIN |
|---|
| 140 | | SELECT INTO m_sensorid surfnet_sensorid_get(p_localhost); |
|---|
| 141 | | |
|---|
| 142 | | INSERT INTO details |
|---|
| 143 | | (attackid,sensorid,type,text) |
|---|
| 144 | | VALUES |
|---|
| 145 | | (p_attackid,m_sensorid,p_type,p_data); |
|---|
| 146 | | END$_$ |
|---|
| 147 | | LANGUAGE plpgsql; |
|---|
| 148 | | |
|---|
| 149 | | |
|---|
| 150 | | CREATE FUNCTION surfnet_detail_add_by_id(integer, integer, integer, character varying) RETURNS void |
|---|
| 151 | | AS $_$DECLARE |
|---|
| 152 | | p_attackid ALIAS FOR $1; |
|---|
| 153 | | m_sensorid ALIAS FOR $2; |
|---|
| 154 | | p_type ALIAS FOR $3; |
|---|
| 155 | | p_data ALIAS FOR $4; |
|---|
| 156 | | BEGIN |
|---|
| 157 | | INSERT INTO details |
|---|
| 158 | | (attackid,sensorid,type,text) |
|---|
| 159 | | VALUES |
|---|
| 160 | | (p_attackid,m_sensorid,p_type,p_data); |
|---|
| 161 | | END$_$ |
|---|
| 162 | | LANGUAGE plpgsql; |
|---|
| 163 | | |
|---|
| 164 | | |
|---|
| 165 | | CREATE FUNCTION surfnet_detail_add_download(inet, inet, character varying, character varying) RETURNS void |
|---|
| 166 | | AS $_$DECLARE |
|---|
| 167 | | p_remotehost ALIAS FOR $1; |
|---|
| 168 | | p_localhost ALIAS FOR $2; |
|---|
| 169 | | p_url ALIAS FOR $3; |
|---|
| 170 | | p_hash ALIAS FOR $4; |
|---|
| 171 | | |
|---|
| 172 | | m_sensorid INTEGER; |
|---|
| 173 | | m_attackid INTEGER; |
|---|
| 174 | | BEGIN |
|---|
| 175 | | SELECT INTO m_sensorid surfnet_sensorid_get(p_localhost); |
|---|
| 176 | | SELECT INTO m_attackid surfnet_attack_add_by_id(32,p_remotehost, 0, |
|---|
| 177 | | p_localhost, 0, |
|---|
| 178 | | NULL,m_sensorid); |
|---|
| 179 | | |
|---|
| 180 | | PERFORM surfnet_detail_add_by_id(m_attackid, |
|---|
| 181 | | m_sensorid,4,p_url); |
|---|
| 182 | | PERFORM surfnet_detail_add_by_id(m_attackid, |
|---|
| 183 | | m_sensorid,8,p_hash); |
|---|
| 184 | | |
|---|
| 185 | | return; |
|---|
| 186 | | END; $_$ |
|---|
| 187 | | LANGUAGE plpgsql; |
|---|
| 188 | | |
|---|
| 189 | | |
|---|
| 190 | | CREATE FUNCTION surfnet_detail_add_offer(inet, inet, character varying) RETURNS void |
|---|
| 191 | | AS $_$DECLARE |
|---|
| 192 | | p_remotehost ALIAS FOR $1; |
|---|
| 193 | | p_localhost ALIAS FOR $2; |
|---|
| 194 | | p_url ALIAS FOR $3; |
|---|
| 195 | | |
|---|
| 196 | | m_sensorid INTEGER; |
|---|
| 197 | | m_attackid INTEGER; |
|---|
| 198 | | BEGIN |
|---|
| 199 | | SELECT INTO m_sensorid surfnet_sensorid_get(p_localhost); |
|---|
| 200 | | SELECT INTO m_attackid surfnet_attack_add_by_id(16,p_remotehost, 0, |
|---|
| 201 | | p_localhost, 0, |
|---|
| 202 | | NULL,m_sensorid); |
|---|
| 203 | | |
|---|
| 204 | | PERFORM surfnet_detail_add_by_id(m_attackid, |
|---|
| 205 | | m_sensorid,4,p_url); |
|---|
| 206 | | return; |
|---|
| 207 | | END; $_$ |
|---|
| 208 | | LANGUAGE plpgsql; |
|---|
| 209 | | |
|---|
| 210 | | |
|---|
| 211 | | CREATE FUNCTION surfnet_sensorid_get(inet) RETURNS integer |
|---|
| 212 | | AS $_$DECLARE |
|---|
| 213 | | p_localhost ALIAS FOR $1; |
|---|
| 214 | | m_sensorid INTEGER; |
|---|
| 215 | | BEGIN |
|---|
| 216 | | SELECT INTO m_sensorid id FROM sensors WHERE tapip = p_localhost; |
|---|
| 217 | | return m_sensorid; |
|---|
| 218 | | END |
|---|
| 219 | | $_$ |
|---|
| 220 | | LANGUAGE plpgsql; |
|---|
| 221 | | |
|---|
| 222 | | |
|---|
| 223 | | */ |
|---|