aboutsummaryrefslogtreecommitdiffstats
path: root/hommaexceli_py/sheets_client.py
blob: 1dd741c81ad37267d6f725183de2b33424dfd105 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
import pickle
import os.path
from os import getenv
from datetime import date
from dataclasses import dataclass
from googleapiclient.discovery import build
from google_auth_oauthlib.flow import InstalledAppFlow
from google.auth.transport.requests import Request


@dataclass
class SheetsRow:
    interval: str
    name: str
    last_done: str


# If modifying these scopes, delete the file token.pickle.
SCOPES = ["https://www.googleapis.com/auth/spreadsheets.readonly"]


def _get_or_default(list, index, default=""):
    try:
        return list[index]
    except IndexError:
        return default


def _row_to_dataclass(values):
    interval = _get_or_default(values, 0, "")
    name = _get_or_default(values, 1, "")

    today = date.today()
    last_done = _get_or_default(values, 2, today.strftime("%Y-%m-%d"))
    return SheetsRow(interval, name, last_done)


def authenticate_and_fetch_sheets_data():
    creds = None
    # The file token.pickle stores the user's access and refresh tokens, and is
    # created automatically when the authorization flow completes for the first
    # time.
    if os.path.exists("token.pickle"):
        with open("token.pickle", "rb") as token:
            creds = pickle.load(token)
    # If there are no (valid) credentials available, let the user log in.
    if not creds or not creds.valid:
        if creds and creds.expired and creds.refresh_token:
            creds.refresh(Request())
        else:
            flow = InstalledAppFlow.from_client_secrets_file("credentials.json", SCOPES)
            creds = flow.run_local_server(port=0)
        # Save the credentials for the next run
        with open("token.pickle", "wb") as token:
            pickle.dump(creds, token)

    service = build("sheets", "v4", credentials=creds)

    # Call the Sheets API
    sheet = service.spreadsheets()
    result = (
        sheet.values()
        .get(
            spreadsheetId=getenv("SHEETS_SPREADSHEET_ID"),
            range=getenv("SHEETS_RANGE"),
        )
        .execute()
    )

    rows = result.get("values", [])
    return map(_row_to_dataclass, rows)