Matej Klotton | 0178d52 | 2016-11-04 11:11:44 +0100 | [diff] [blame] | 1 | import socket |
Klement Sekera | 7bb873a | 2016-11-18 07:38:42 +0100 | [diff] [blame] | 2 | import sys |
Klement Sekera | 0e3c0de | 2016-09-29 14:43:44 +0200 | [diff] [blame] | 3 | from abc import abstractmethod, ABCMeta |
Klement Sekera | 7bb873a | 2016-11-18 07:38:42 +0100 | [diff] [blame] | 4 | from cStringIO import StringIO |
| 5 | |
| 6 | |
| 7 | def ppp(headline, packet): |
| 8 | """ Return string containing the output of scapy packet.show() call. """ |
| 9 | o = StringIO() |
| 10 | old_stdout = sys.stdout |
| 11 | sys.stdout = o |
| 12 | print(headline) |
| 13 | packet.show() |
| 14 | sys.stdout = old_stdout |
| 15 | return o.getvalue() |
| 16 | |
Damjan Marion | f56b77a | 2016-10-03 19:44:57 +0200 | [diff] [blame] | 17 | |
Klement Sekera | 9225dee | 2016-12-12 08:36:58 +0100 | [diff] [blame] | 18 | def ppc(headline, capture, limit=10): |
| 19 | """ Return string containing ppp() printout for a capture. |
| 20 | |
| 21 | :param headline: printed as first line of output |
| 22 | :param capture: packets to print |
| 23 | :param limit: limit the print to # of packets |
| 24 | """ |
| 25 | if not capture: |
| 26 | return headline |
Klement Sekera | dab231a | 2016-12-21 08:50:14 +0100 | [diff] [blame] | 27 | tail = "" |
Klement Sekera | 9225dee | 2016-12-12 08:36:58 +0100 | [diff] [blame] | 28 | if limit < len(capture): |
Klement Sekera | dab231a | 2016-12-21 08:50:14 +0100 | [diff] [blame] | 29 | tail = "\nPrint limit reached, %s out of %s packets printed" % ( |
| 30 | len(capture), limit) |
| 31 | limit = len(capture) |
| 32 | body = "".join([ppp("Packet #%s:" % count, p) |
| 33 | for count, p in zip(range(0, limit), capture)]) |
| 34 | return "%s\n%s%s" % (headline, body, tail) |
Klement Sekera | 9225dee | 2016-12-12 08:36:58 +0100 | [diff] [blame] | 35 | |
| 36 | |
Klement Sekera | 0e3c0de | 2016-09-29 14:43:44 +0200 | [diff] [blame] | 37 | class NumericConstant(object): |
| 38 | __metaclass__ = ABCMeta |
| 39 | |
| 40 | desc_dict = {} |
| 41 | |
| 42 | @abstractmethod |
| 43 | def __init__(self, value): |
| 44 | self._value = value |
| 45 | |
| 46 | def __int__(self): |
| 47 | return self._value |
| 48 | |
| 49 | def __long__(self): |
| 50 | return self._value |
| 51 | |
| 52 | def __str__(self): |
| 53 | if self._value in self.desc_dict: |
| 54 | return self.desc_dict[self._value] |
| 55 | return "" |
| 56 | |
| 57 | |
Matej Klotton | 0178d52 | 2016-11-04 11:11:44 +0100 | [diff] [blame] | 58 | class Host(object): |
| 59 | """ Generic test host "connected" to VPPs interface. """ |
Damjan Marion | f56b77a | 2016-10-03 19:44:57 +0200 | [diff] [blame] | 60 | |
Klement Sekera | f62ae12 | 2016-10-11 11:47:09 +0200 | [diff] [blame] | 61 | @property |
| 62 | def mac(self): |
| 63 | """ MAC address """ |
| 64 | return self._mac |
Damjan Marion | f56b77a | 2016-10-03 19:44:57 +0200 | [diff] [blame] | 65 | |
Klement Sekera | f62ae12 | 2016-10-11 11:47:09 +0200 | [diff] [blame] | 66 | @property |
| 67 | def ip4(self): |
| 68 | """ IPv4 address """ |
| 69 | return self._ip4 |
Damjan Marion | f56b77a | 2016-10-03 19:44:57 +0200 | [diff] [blame] | 70 | |
Klement Sekera | f62ae12 | 2016-10-11 11:47:09 +0200 | [diff] [blame] | 71 | @property |
Matej Klotton | 0178d52 | 2016-11-04 11:11:44 +0100 | [diff] [blame] | 72 | def ip4n(self): |
| 73 | """ IPv4 address """ |
| 74 | return socket.inet_pton(socket.AF_INET, self._ip4) |
| 75 | |
| 76 | @property |
Klement Sekera | f62ae12 | 2016-10-11 11:47:09 +0200 | [diff] [blame] | 77 | def ip6(self): |
| 78 | """ IPv6 address """ |
| 79 | return self._ip6 |
Damjan Marion | f56b77a | 2016-10-03 19:44:57 +0200 | [diff] [blame] | 80 | |
Klement Sekera | f62ae12 | 2016-10-11 11:47:09 +0200 | [diff] [blame] | 81 | def __init__(self, mac=None, ip4=None, ip6=None): |
| 82 | self._mac = mac |
| 83 | self._ip4 = ip4 |
| 84 | self._ip6 = ip6 |