diff options
author | Mark Haines <mark.haines@matrix.org> | 2016-05-05 13:42:44 +0100 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2016-05-05 13:42:44 +0100 |
commit | 9c272da05fcf51534aaa877647bc3b82bf841cf3 (patch) | |
tree | b4ad76ff6acd5d5e38907208065689fb37c42e4c /synapse/storage/openid.py | |
parent | Merge pull request #762 from matrix-org/erikj/report_event (diff) | |
download | synapse-9c272da05fcf51534aaa877647bc3b82bf841cf3.tar.xz |
Add an openidish mechanism for proving to third parties that you own a given user_id
Diffstat (limited to 'synapse/storage/openid.py')
-rw-r--r-- | synapse/storage/openid.py | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/synapse/storage/openid.py b/synapse/storage/openid.py new file mode 100644 index 0000000000..5dabb607bd --- /dev/null +++ b/synapse/storage/openid.py @@ -0,0 +1,32 @@ +from ._base import SQLBaseStore + + +class OpenIdStore(SQLBaseStore): + def insert_open_id_token(self, token, ts_valid_until_ms, user_id): + return self._simple_insert( + table="open_id_tokens", + values={ + "token": token, + "ts_valid_until_ms": ts_valid_until_ms, + "user_id": user_id, + }, + desc="insert_open_id_token" + ) + + def get_user_id_for_open_id_token(self, token, ts_now_ms): + def get_user_id_for_token_txn(txn): + sql = ( + "SELECT user_id FROM open_id_tokens" + " WHERE token = ? AND ? <= ts_valid_until_ms" + ) + + txn.execute(sql, (token, ts_now_ms)) + + rows = txn.fetchall() + if not rows: + return None + else: + return rows[0][0] + return self.runInteraction( + "get_user_id_for_token", get_user_id_for_token_txn + ) |