# Path: wiremaps/collector/datastore.py
# class ILocalVlan(IVlan):
#     """Interface for a local VLAN"""
# 
# class IRemoteVlan(IVlan):
#     """Interface for a remote VLAN"""


from wiremaps.collector.datastore import ILocalVlan, IRemoteVlan
                         'sysname': nport.cdp.sysname,
                         'portname': nport.cdp.port,
                         'platform': nport.cdp.platform,
                         'mgmtip': nport.cdp.ip})

    def _lldp(self, txn):
        """Write LLDP related information into database"""
        txn.execute("UPDATE lldp SET deleted=CURRENT_TIMESTAMP "
                    "WHERE equipment=%(ip)s AND deleted='infinity'",
                    {'ip': self.equipment.ip})
        for port in self.equipment.ports:
            nport = self.equipment.ports[port]
            if nport.lldp is None: continue
            txn.execute("INSERT INTO lldp VALUES (%(ip)s, "
                        "%(port)s, %(mgmtip)s, %(portdesc)s, "
                        "%(sysname)s, %(sysdesc)s)",
                        {'ip': self.equipment.ip,
                         'port': port,
                         'mgmtip': nport.lldp.ip,
                         'portdesc': nport.lldp.portdesc,
                         'sysname': nport.lldp.sysname,
                         'sysdesc': nport.lldp.sysdesc})

    def _vlan(self, txn):
        """Write VLAN information into database"""
        txn.execute("UPDATE vlan SET deleted=CURRENT_TIMESTAMP "
                    "WHERE equipment=%(ip)s AND deleted='infinity'",
                    {'ip': self.equipment.ip})
        for port in self.equipment.ports:
            for vlan in self.equipment.ports[port].vlan:

# Path: wiremaps/collector/datastore.py
# class ILocalVlan(IVlan):
#     """Interface for a local VLAN"""
# 
# class IRemoteVlan(IVlan):
#     """Interface for a remote VLAN"""


# Path: wiremaps/collector/database.py
from wiremaps.collector.datastore import ILocalVlan, IRemoteVlan

                         'sysname': nport.cdp.sysname,
                         'portname': nport.cdp.port,
                         'platform': nport.cdp.platform,
                         'mgmtip': nport.cdp.ip})

    def _lldp(self, txn):
        """Write LLDP related information into database"""
        txn.execute("UPDATE lldp SET deleted=CURRENT_TIMESTAMP "
                    "WHERE equipment=%(ip)s AND deleted='infinity'",
                    {'ip': self.equipment.ip})
        for port in self.equipment.ports:
            nport = self.equipment.ports[port]
            if nport.lldp is None: continue
            txn.execute("INSERT INTO lldp VALUES (%(ip)s, "
                        "%(port)s, %(mgmtip)s, %(portdesc)s, "
                        "%(sysname)s, %(sysdesc)s)",
                        {'ip': self.equipment.ip,
                         'port': port,
                         'mgmtip': nport.lldp.ip,
                         'portdesc': nport.lldp.portdesc,
                         'sysname': nport.lldp.sysname,
                         'sysdesc': nport.lldp.sysdesc})

    def _vlan(self, txn):
        """Write VLAN information into database"""
        txn.execute("UPDATE vlan SET deleted=CURRENT_TIMESTAMP "
                    "WHERE equipment=%(ip)s AND deleted='infinity'",
                    {'ip': self.equipment.ip})
        for port in self.equipment.ports:
            for vlan in self.equipment.ports[port].vlan:

                if ILocalVlan.providedBy(vlan):