bridgedb.Storage

_escapeValue(v)

timeToStr(t)

strToTime(t)

class BridgeData(hex_key, address, or_port, distributor='unallocated', first_seen='', last_seen='')

Bases: object

Value class carrying bridge information: hex_key - The unique hex key of the given bridge address - Bridge IP address or_port - Bridge TCP port distributor - The distributor (or pseudo-distributor) through which

this bridge is being announced

first_seen - When did we first see this bridge online? last_seen - When was the last time we saw this bridge online?

class Database(sqlite_fname)

Bases: object

commit()

rollback()

close()

insertBridgeAndGetRing(bridge, setRing, seenAt, validRings, defaultPool='unallocated')

Updates info about bridge, setting ring to setRing if none was set. Also sets distributor to `defaultPool’ if the bridge was found in the database, but its distributor isn’t valid anymore.

Returns the name of the distributor the bridge is assigned to.

cleanEmailedBridges(expireBefore)

getEmailTime(addr)

setEmailTime(addr, whenMailed)

getAllBridges()

Return a list of BridgeData value classes of all bridges in the database

getBridgesForDistributor(distributor)

Return a list of BridgeData value classes of all bridges in the database that are allocated to distributor ‘distributor’

updateDistributorForHexKey(distributor, hex_key)

getWarnedEmail(addr)

setWarnedEmail(addr, warned=True, whenWarned=1437453856.676141)

cleanWarnedEmails(expireBefore)

updateIntoBridgeHistory(bh)

delBridgeHistory(fp)

getBridgeHistory(fp)

getAllBridgeHistory()

getBridgesLastUpdatedBefore(statusPublicationMillis)

openDatabase(sqlite_file)

class DBGeneratorContextManager(gen)

Bases: contextlib.GeneratorContextManager

Helper for @contextmanager decorator.

Overload __exit__() so we can call the generator many times

contextmanager(func)

Decorator to for Storage.getDB()

Define getDB() for use by with statement content manager

clearGlobalDB()

Start from scratch.

This is currently only used in unit tests.

initializeDBLock()

Create the lock

This must be called before the first database query

setDBFilename(sqlite_fname)

getDB(*args, **kwds)

Generator: Return a usable database handler

Always return a bridgedb.Storage.Database that is usable within the current thread. If a connection already exists and it was created by the current thread, then return the associated bridgedb.Storage.Database instance. Otherwise, create a new instance, blocking until the existing connection is closed, if applicable.

Note: This is a blocking call (by default), be careful about

deadlocks!

Return type:bridgedb.Storage.Database Returns:An instance of bridgedb.Storage.Database used to query the database

dbIsLocked()