import telethon
from telethon import TelegramClient, sync, functions
from telethon.tl.functions.messages import GetHistoryRequest
from telethon.tl.functions.channels import JoinChannelRequest
import gspread
from oauth2client.service_account import ServiceAccountCredentials
import time
import socks
import glob

scope = ['https://spreadsheets.google.com/feeds', 'https://www.googleapis.com/auth/drive']
creds = ServiceAccountCredentials.from_json_keyfile_name("CHeatproject-890ddda2e266.json", scope)
client = gspread.authorize(creds)

sheet = client.open("cheat").sheet1

array_of_channels = []

for i in range(sheet.row_count):
    if sheet.cell(i + 1, 1).value != '':
        array_of_channels.append([sheet.cell(i + 1, 1).value,
                                  sheet.cell(i + 1, 2).value,
                                  sheet.cell(i + 1, 3).value,
                                  0])
    else:
        break


api_id = open('app_id.dat').read().splitlines()[0]
api_hash = open('app_hash.dat').read().splitlines()[0]

post_id = 0
z = 1
while True:
    for k in glob.glob("sessions/*.session"):
        tg_client = TelegramClient(k, api_id, api_hash,
                                   )  # proxy=(socks.SOCKS5, "37.1.218.213", 10051)
        tg_client.start()
        for i in array_of_channels:
            try:
                tg_client(JoinChannelRequest(i[0]))
                entity = tg_client.get_entity(i[0])
                peer = telethon.utils.get_input_peer(entity)
                posts = tg_client(GetHistoryRequest(
                    peer=entity,
                    limit=1,
                    offset_date=None,
                    offset_id=0,
                    max_id=0,
                    min_id=0,
                    add_offset=0,
                    hash=0))
                if i[3] != posts.messages[0].id:
                    post_id = posts.messages[0].id
                    i[3] = posts.messages[0].id
                    result = tg_client(functions.messages.GetMessagesViewsRequest(
                        peer=peer,
                        id=[post_id],
                        increment=True))
                    tg_client.disconnect()
                    print(result[0])
                else:
                    continue
            except:
                continue
    time.sleep(5)