## The issue: DS-5242

from __future__ import print_function

import csv
import os.path

from google.auth.transport.requests import Request
from google.oauth2.credentials import Credentials
from google_auth_oauthlib.flow import InstalledAppFlow
from googleapiclient.discovery import build
from googleapiclient.errors import HttpError

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

# The ID and range of a sample spreadsheet.
SAMPLE_SPREADSHEET_ID = '1lB5xY4DMJ7OBGu-xrhr6KlgjNybbrdQ1gHorHLG78hc'
SAMPLE_RANGE_NAME = 'Sheet1!A1:F73'


def main():
    """Shows basic usage of the Sheets API.
    Prints values from a sample spreadsheet.
    """
    creds = None
    # The file token.json 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.json'):
        creds = Credentials.from_authorized_user_file('token.json', SCOPES)
    # 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.json', 'w') as token:
            token.write(creds.to_json())

    try:
        service = build('sheets', 'v4', credentials=creds)

        # Call the Sheets API
        sheet = service.spreadsheets()
        result = sheet.values().get(spreadsheetId=SAMPLE_SPREADSHEET_ID,
                                    range=SAMPLE_RANGE_NAME).execute()
        values = result.get('values', [])

        if not values:
            print('No data found.')
            return

        with open('budget_by_fy23.csv', 'w') as csv_file:
            csv_writer = csv.writer(csv_file)
            for row in values:
                # Print columns A and E, which correspond to indices 0 and 4.
                row = [cell.replace(',','') for cell in row]
                csv_writer.writerow(row)
                print(row)
    except HttpError as err:
        print(err)


if __name__ == '__main__':
    main()

    aws_cli = 'aws s3 cp budget_by_fy23.csv s3://dev-feed-drop/AWAL/spreadsheets/budget_by_fy23.csv --profile dev'
    print(aws_cli)

    sqls = """
create or replace table budget_by_fy23 (
    stat_mnth1 string,
  client_segment string,
  budget_revenue number,
  budget_margin number,
  py_revenue number,
  py_margin number
) comment = 'Table created from Google Spreadsheet "BUDGET_BY_FY23"';

copy into budget_by_fy23
from  s3://dev-feed-drop/AWAL/spreadsheets/budget_by_fy23.csv
CREDENTIALS = (
    AWS_KEY_ID = '' 
    AWS_SECRET_KEY = ''
)
FILE_FORMAT = ( TYPE = 'csv', SKIP_HEADER = 1 )
;

"""
    print(sqls)