ろうとるがPythonを扱う、、（その20：Scapyで改ざん）

Posted at 2024-03-02

Scapyでデータを改ざんしてみる

「ろうとるがPythonを扱う、、（その19：Scapy Bridgeで遅延やパケットDrop）」の続きである。ネットワークブリッジをもうけて、そのブリッジでデータを改ざんする。

ネットワーク構成

下記のようなもの。

VirtualBoxの３つのVMを利用。中央のVM(Lubuntu)ネットワークブリッジ、両端は同一ネットワークセグメントに属する。

ソースコード

出だし

from scapy.all import *
import select

sub_data = '1234567890'

改ざん後のデータ（置き換えるもの）

Ethernetフレーム生成

def recreate_frame(eth_header, ip_packet):
    # Removal Check-Sum
    if ip_packet.haslayer(TCP):
        del ip_packet.getlayer(TCP).chksum
    if ip_packet.haslayer(UDP):
        del ip_packet.getlayer(UDP).chksum
    if ip_packet.haslayer(ICMP):
        del ip_packet.getlayer(ICMP).chksum
    del ip_packet.chksum

    # Recreation Ethernet
    result = Ether(dst=eth_header.dst, src=eth_header.src, type=eth_header.type)/IP(ip_packet.build())
    return result

改ざん後のEthernetフレーム作成
Ethernetヘッダはオリジナルのまま利用
IPレイヤ以上のチェックサム削除および再生成
下記サイト参照
- Python2 + Scapyで、Raspberry Pi 2 Model B をNAT/NAPTルータ化してみた #router_jisaku
- How to calculate a packet checksum without sending it?

メイン

前回利用した”bridge_and_sniff”ではなく、下記サイトの”select”実装を利用した。

Scapy + Python2 + I/O多重化・ブロッキングI/O系モジュールにて、Raspberry Pi 2 Model Bをブリッジ化する

### Main ###
# Layer2 socket
eth0_socket = conf.L2socket(iface='enp0s3')
eth1_socket = conf.L2socket(iface='enp0s8')

# Socket Dictionary
next_socket = {
    eth0_socket: eth1_socket,
    eth1_socket: eth0_socket,
}
while True:
    # select()
    readable_sockets, _, _ = select.select([eth0_socket, eth1_socket], [], [])

    for s in readable_sockets:
        # Data receive
        p = s.recv()

        if p:
            if p.haslayer(Raw):
                p.show()
                eth_frame = p.getlayer(Ether)
                ip_pkt = p.getlayer(IP)
                length = len(p['Raw'].load)
                m = length%10
                n = int(length/10)
                data = ''
                for i in range(n):
                    data += sub_data
                data += sub_data[0:m-1]
                data += '\n'
                p['Raw'].load = data.encode('ascii')
                ip_pkt = p.getlayer(IP)
                new_frame = recreate_frame(eth_frame, ip_pkt)
                next_socket[s].send(new_frame)
            else:
                next_socket[s].send(p.original) # そのまま送信

L2ソケットの定義（eth0_socket、eth1_socket）
ブリッジの定義（L2ソケットどうしをつなげる）
待受け（select）
データ受信（p）
改ざん対象は、TCP/UDP/ICMPなどでデータを持つもの（p.haslayer(Raw)がTrue）
EthernetヘッダおよびIPデータの取得
置き換えるデータは、出だしで定義した”sub_data”の内容
- 同じ文字数分置き換える（TCPシーケンス維持のため）
- 上述した”recreate_frame()”により、Ethernetフレーム作成
- データ送信