iframe-proxy | Sunbelt Computer Software

History

222 lines (175 loc) · 6.08 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

# Pyrogram - Telegram MTProto API Client Library for Python

# This file is part of Pyrogram.

# Pyrogram is free software: you can redistribute it and/or modify

# it under the terms of the GNU Lesser General Public License as published

# by the Free Software Foundation, either version 3 of the License, or

# (at your option) any later version.

# Pyrogram is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

# GNU Lesser General Public License for more details.

# You should have received a copy of the GNU Lesser General Public License

# along with Pyrogram. If not, see <http://www.gnu.org/licenses/>.

import inspect

import sqlite3

import time

from typing import List, Tuple, Any

from pyrogram import raw

from .storage import Storage

from .. import utils

# language=SQLite

SCHEMA = """

CREATE TABLE sessions

(

dc_id INTEGER PRIMARY KEY,

api_id INTEGER,

test_mode INTEGER,

auth_key BLOB,

date INTEGER NOT NULL,

user_id INTEGER,

is_bot INTEGER

);

CREATE TABLE peers

(

id INTEGER PRIMARY KEY,

access_hash INTEGER,

type INTEGER NOT NULL,

username TEXT,

phone_number TEXT,

last_update_on INTEGER NOT NULL DEFAULT (CAST(STRFTIME('%s', 'now') AS INTEGER))

);

CREATE TABLE version

(

number INTEGER PRIMARY KEY

);

CREATE INDEX idx_peers_id ON peers (id);

CREATE INDEX idx_peers_username ON peers (username);

CREATE INDEX idx_peers_phone_number ON peers (phone_number);

CREATE TRIGGER trg_peers_last_update_on

AFTER UPDATE

ON peers

BEGIN

UPDATE peers

SET last_update_on = CAST(STRFTIME('%s', 'now') AS INTEGER)

WHERE id = NEW.id;

END;

"""

def get_input_peer(peer_id: int, access_hash: int, peer_type: str):

if peer_type in ["user", "bot"]:

return raw.types.InputPeerUser(

user_id=peer_id,

access_hash=access_hash

)

if peer_type == "group":

return raw.types.InputPeerChat(

chat_id=-peer_id

)

if peer_type in ["channel", "supergroup"]:

return raw.types.InputPeerChannel(

channel_id=utils.get_channel_id(peer_id),

access_hash=access_hash

)

raise ValueError(f"Invalid peer type: {peer_type}")

class SQLiteStorage(Storage):

VERSION = 3

USERNAME_TTL = 8 * 60 * 60

def __init__(self, name: str):

super().__init__(name)

self.conn = None # type: sqlite3.Connection

def create(self):

with self.conn:

self.conn.executescript(SCHEMA)

self.conn.execute(

"INSERT INTO version VALUES (?)",

(self.VERSION,)

)

self.conn.execute(

"INSERT INTO sessions VALUES (?, ?, ?, ?, ?, ?, ?)",

(2, None, None, None, 0, None, None)

)

async def open(self):

raise NotImplementedError

async def save(self):

await self.date(int(time.time()))

self.conn.commit()

async def close(self):

self.conn.close()

async def delete(self):

raise NotImplementedError

async def update_peers(self, peers: List[Tuple[int, int, str, str, str]]):

self.conn.executemany(

"REPLACE INTO peers (id, access_hash, type, username, phone_number)"

"VALUES (?, ?, ?, ?, ?)",

peers

)

async def get_peer_by_id(self, peer_id: int):

r = self.conn.execute(

"SELECT id, access_hash, type FROM peers WHERE id = ?",

(peer_id,)

).fetchone()

if r is None:

raise KeyError(f"ID not found: {peer_id}")

return get_input_peer(*r)

async def get_peer_by_username(self, username: str):

r = self.conn.execute(

"SELECT id, access_hash, type, last_update_on FROM peers WHERE username = ?"

"ORDER BY last_update_on DESC",

(username,)

).fetchone()

if r is None:

raise KeyError(f"Username not found: {username}")

if abs(time.time() - r[3]) > self.USERNAME_TTL:

raise KeyError(f"Username expired: {username}")

return get_input_peer(*r[:3])

async def get_peer_by_phone_number(self, phone_number: str):

r = self.conn.execute(

"SELECT id, access_hash, type FROM peers WHERE phone_number = ?",

(phone_number,)

).fetchone()

if r is None:

raise KeyError(f"Phone number not found: {phone_number}")

return get_input_peer(*r)

def _get(self):

attr = inspect.stack()[2].function

return self.conn.execute(

f"SELECT {attr} FROM sessions"

).fetchone()[0]

def _set(self, value: Any):

attr = inspect.stack()[2].function

with self.conn:

self.conn.execute(

f"UPDATE sessions SET {attr} = ?",

(value,)

)

def _accessor(self, value: Any = object):

return self._get() if value == object else self._set(value)

async def dc_id(self, value: int = object):

return self._accessor(value)

async def api_id(self, value: int = object):

return self._accessor(value)

async def test_mode(self, value: bool = object):

return self._accessor(value)

async def auth_key(self, value: bytes = object):

return self._accessor(value)

async def date(self, value: int = object):

return self._accessor(value)

async def user_id(self, value: int = object):

return self._accessor(value)

async def is_bot(self, value: bool = object):

return self._accessor(value)

def version(self, value: int = object):

if value == object:

return self.conn.execute(

"SELECT number FROM version"

).fetchone()[0]

else:

with self.conn:

self.conn.execute(

"UPDATE version SET number = ?",

(value,)

)

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

sqlite_storage.py

Latest commit

History

sqlite_storage.py

File metadata and controls