from googleapiclient.discovery import build
from oauth2client.service_account import ServiceAccountCredentials
from datetime import datetime

class GooleIndexingApi:
    URL_UPDATE = "URL_UPDATED"
    URL_DELETED = "URL_DELETED"

def __init__(self, json_key_file: str, url_list: list, req_type: int):
    scopes = ["https://www.googleapis.com/auth/indexing", "https://www.googleapis.com/auth/webmasters.readonly"]
    credentials = ServiceAccountCredentials.from_json_keyfile_name(json_key_file, scopes=scopes)
    self.service = build('indexing', 'v3', credentials=credentials)
    self.search_console = build('searchconsole', 'v1', credentials=credentials)
    self.url_list = url_list
    self.req_type = req_type
    self.sucess_count = 0
    self.fail_count = 0

def structure_urls(self) -> list:
    req_body = []
    body_type = self.URL_UPDATE if self.req_type == 1 else self.URL_DELETED
    for url in self.url_list:
        req_body.append({"url": url, "type": body_type})
    return req_body

def batch_publish(self):
    url_list = self.structure_urls()
    batch = self.service.new_batch_http_request()
    for i, url_data in enumerate(url_list):
        batch.add(self.service.urlNotifications().publish(body=url_data), request_id=str(i),
                  callback=self.batch_callback)
    batch.execute()

def check_url(self, url):
    response = self.service.urlNotifications().getMetadata(url=url).execute()
    print(response)

def get_indexing_list(self, row_limit: int, expression: str):

    site_url = 'my_domain'
    start_date = '2020-01-01'
    end_date = datetime.today().strftime('%Y-%m-%d')

    request = {
        'startDate': start_date,
        'endDate': end_date,
        'dimensions': ['page'],
        'dimensionFilterGroups': [{
            'filters': [{
                'dimension': 'page',
                'operator': 'contains',
                'expression': expression
            }]
        }],
        'rowLimit': row_limit
    }
    response = self.search_console.searchanalytics().query(siteUrl=site_url, body=request).execute()
    index_urls = [row['keys'][0] for row in response['rows']]
    print(index_urls)

def batch_callback(self, request_id, response, exception):
    if exception is not None:
        self.fail_count += 1
    else:
        url = response["urlNotificationMetadata"]["url"]
        self.sucess_count += 1

if __name__ == '__main__':
    urls = ["my_url"]
    json_key_file = "my_json_key.json"
    req_type = 0
    google_api = GooleIndexingApi(json_key_file, urls, req_type)
    google_api.batch_publish()
    for url in urls:
        google_api.check_url(url)

{                                                                                                                                                                                            
  "urlNotificationMetadata": {                                                                                                                                                               
    "url": "https://www.exp.de/"
  }
}

{
  'urlNotificationMetadata': {
    'url': 'https: //www.exp.de/', 
    'latestUpdate': { 
      'url': 'https: //www.exp.de/', 
      'type': 'URL_UPDATED', 
      'notifyTime': '2025-03-03T09:00:08.031188922Z'
    }
  }
}