workato / custom_connector_docs Goto Github PK

authorization: {
  type: "oauth2",

  authorization_url: lambda do |connection|
    scopes = [
      "https://www.googleapis.com/auth/admin.reports.audit.readonly",
      "https://www.googleapis.com/auth/admin.reports.usage.readonly",
      "https://www.googleapis.com/auth/admin.directory.user.readonly"
    ].join(" ")

    "https://accounts.google.com/o/oauth2/auth?client_id=" \
    "#{connection['client_id']}&response_type=code&scope=#{scopes}" \
    "&access_type=offline&include_granted_scopes=true&prompt=consent"
  end,

  acquire: lambda do |connection, auth_code, redirect_uri|
    response = post("https://accounts.google.com/o/oauth2/token").
      payload(client_id: connection["client_id"],
              client_secret: connection["client_secret"],
              grant_type: "authorization_code",
              code: auth_code,
              redirect_uri: redirect_uri).
      request_format_www_form_urlencoded
    [response, nil, nil]
  end,

  refresh: lambda do |connection, refresh_token|
    post("https://accounts.google.com/o/oauth2/token").
      payload(client_id: connection["client_id"],
              client_secret: connection["client_secret"],
              grant_type: "refresh_token",
              refresh_token: refresh_token).
      request_format_www_form_urlencoded
  end,

  refresh_on: [401],

  detect_on: [/"errors"\:\s*\[/],

  apply: lambda do |_connection, access_token|
    headers("Authorization" => "Bearer #{access_token}")
  end
},

base_uri: lambda do |_connection|
  "https://www.googleapis.com"
end