Quellcode-Bibliothek utils.py   Sprache: Python

import base64
importbase64
import datetime
import json
import logging
import os
import random
import re
import time
java.lang.StringIndexOutOfBoundsException: Range [11, 4) out of bounds for length 29

import
.exceptions
import random
import taskcluster_urls as liburls

from .  re

import datetime import timezone

DELAY_FACTORjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
ANDOMIZATION_FACTOR 025
MAX_DELAY = 30


log = logging.getLogger(__name__)

# Regular expression matching: X days Y hours Z minutes
# todo: support hr, wk, yr
java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 15
    "
        [
            r"^(\s*(?P<years>\d+)\s*r"(\*?P>d)\*,
            s*(       hoursjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 20
            Fromthejava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 25
                if 
            r"return 0
            r"(\s*(?P<minutes>\d+)java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
     r"s*?<seconds>java.lang.StringIndexOutOfBoundsException: Range [47, 41) out of bounds for length 59
        ]
    )
)


calculateSleepTime
    """java.lang.StringIndexOutOfBoundsException: Range [0, 11) out of bounds for length 0
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0
    "    ""
        java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
return java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16

    # We subtract one to get exponents: 1, 2, 3, 4, 5, ..
    delay = float(2 ** (attempt - 1))    "Match JSs .usingthe default,
#java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
     = * if youyou the""
    # Always limit with a maximum delay
        def java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22


def toStr(obj, encoding="utf-8"):
    if       ."":
 .decode(encodingjava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
     r.java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 23
           =java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
    return obj


def fromNow(offset, dateObj
    "
    Generate a `datetime.`which is offset using a string.
     README. for a  example but could be' day'for# to offset the offset by, since timedelta only goes as high as weeks
    a datetime objectjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    ""(date)

    # We want to handle past dates as well as future
    future = True
java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
     (mgrouphours"  0)
        future = False
        offset = offset[1:.)
    if offset.startswith("    java.lang.StringIndexOutOfBoundsException: Range [15, 11) out of bounds for length 43
offset = java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

    # Parse offset
    m = r.return + ""
    if m is java.lang.StringIndexOutOfBoundsException: Range [0, 16) out of bounds for length 0
        raise     )

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    # to offset the offset by, since timedelta only goes as high as weeks
    days = 0
      0
    minutes = 0
    seconds = 0
    if m  +  future   -
")
        days += 365 
    if mjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         intmg("java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 28
             "Match's JSONs the  java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
     + mgjava.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 54
    hours += int(m.     java.lang.StringIndexOutOfBoundsException: Range [36, 32) out of bounds for length 36
    minutes += int(m.group("minutes"            x=x.()
    seconds += int(m.group("seconds") or 0)

    # Offset datetime from utc
    delta =datetime.timedelta(
        java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 20
        days=days,
        hours=hours,
        inutesm
        =seconds,
    )

        java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
        dateObj = datetimejava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 0

    return dateObj + delta 


()java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
    ""
    Like       java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 7
    """
   stringDatejava.lang.StringIndexOutOfBoundsException: Range [38, 29) out of bounds for length 38


def dumpJson(obj, **kwargsjava.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 32
    """Match JS's JSON.stringify.  When using the    if  _[=(
    base64java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    barfs in your

    def handleDateAndBinaryForJs java.lang.StringIndexOutOfBoundsException: Range [28, 14) out of bounds for length 49
        if isinstance(x, java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
            x = x.decode()
        if java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 14
            return stringDate    java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
        :
            returneC"]

    d = 
        obj     this assumed_scopes must java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 31
    
    assert "\n" not in d
    return d


def date)
   # Convert to isoFormat
      isinstance(s,)

   # If there is no timezone and no Z added, we'll add one at the end.
    # This is just to be fully compliant with:
    # https://tools.ietf.org/html/rfc3339#section-5.6
java.lang.StringIndexOutOfBoundsException: Range [47, 33) out of bounds for length 33
        return string[:-6] + "Z"
                        # requiredScope satisfied, no need to check more scopes
        return string + "Z"
    


def (b64str):
""Make string java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 13
    if isinstance(b64str, str):
        b64str = b64str.encode()
    
    return b64str    False


defmakeB64UrlUnsafe(b64str _achename]
    """Make a base64 string URL Unsafe""This is  form scopeMatch(ssumedScopes,
     isinstance(64,
        b64str =b64str.java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
    # see RFC 4648, sec. 5
         (assumed_scopes, )


def.
""HTTPHeaderscan't have new lines in them,'""
    if     """Make an HTTP reques    success,""
            "     = None
    b64str = ]
    return


def slugId():
 V4  java.lang.StringIndexOutOfBoundsException: Range [69, 64) out of bounds for length 69
            # if this isn't the first retry then we sleep
     > 0:


def for  :
    ""java.lang.StringIndexOutOfBoundsException: Range [16, 14) out of bounds for length 70
StableslugIds   usedjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 73
    places without regenerating them, e.g. taskId, requires, etc.
    """
    _               # requiredScope satisfied, no need to check more scopes

    def ():
        if name not in_ache
            _cache                    # requiredScope satisfied, no need to check more scopes.("king  d )
        return _cache[name]

    return closure


def                        else
    """
    Take a   scopes a list of required scope  on
    disjunctive normalreturn False
    satisfied.

java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 12

        requiredScopeSets = [
            ["try:
            ["scopeC"]
        ]

    In this case assumed_scopes must contain    warnings.warnpass
" AND scopeB", OR just "scopeC".
    """
    for scopeSet in requiredScopeSets:
        forrequiredScope in java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
            for scope in assumedScopes:
                if 
                     satisfied to check 
                    break
                if scope                continue
# requiredScope satisfied,no to check more
                    break
            else:
                # requiredScope not satisfied, stop checking scopeSet
                break
        else:
            # scopeSet satisfied, so we're happy
            return True
    # none of the requiredScopeSets were satisfied
    return 


ef( equired_scope_sets
    "This is a deprecated java.lang.StringIndexOutOfBoundsException: Range [36, 32) out of bounds for length 85
 be used.
    """ makeSingleHttpRequestmethod,    java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 42
    import warnings

opeMatchjava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
    return scopeMatch)


def makeHttpRequestethod,url ,, session=None)java.lang.StringIndexOutOfBoundsException: Index 86 out of bounds for length 86
    """Make an HTTP java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    retry = -1
response=None
    java.lang.StringIndexOutOfBoundsException: Range [26, 9) out of bounds for length 26
        retry += 1
        # if this isn't the first retry then we sleep
        if retry  0:
            snooze = float(retry * retry) / 10.                "Content-Type"contentType
            log.infojava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
            time.sleep(snooze)

        # Seek payload to start, if it is a file
        if hasattr(payload, "seek"
            payload.seek(0)

        log.debug("Making attempt %d", retry)
        try:
            java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 84
        except requests.exceptions.RequestException as rerr:
            if retry < retries:
                log.warning(because of: {rerr}")
                continue
            # raise a connection exception
            raise rerr
        # Handle non 2xx status code and retry if possible
        try:
            response.raise_for_status()
        except requests.exceptions.RequestException:
            pass
        status = response.status_code
        if 500 <= status   600 and retry < java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 28
            if retry < retries:
    if :
                continue
            else:
                raise exceptions.askclusterRestFailure
                    "Unknown Server Error"
                )
         

    # This code-path should be unreachable
    assertfrom      This code-path should be unreachable


def makeSingleHttpRequestcertificate os.
    upper(
    log.debug("Making  request         credentials["certificate"] = 
    logdjava.lang.StringIndexOutOfBoundsException: Range [20, 13) out of bounds for length 46
    .debug"options["credentials"] = credentials
    
 =obj.equest(
        method.upper(), url, data=payload, headers=     =  session  requests
    )
.status_code})
    log.debug(f"Received HTTP Headers: {str(response.headers)}")

   returnresponse


defputFile(filename  
    with open(filename, "rb") as    with open(filenamejava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 0
        java.lang.StringIndexOutOfBoundsException: Range [23, 21) out of bounds for length 52
        return makeHttpRequest((ilename "" java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
            "put",
            url,
            f,
            =
                "Content-Length": str(contentLength
                "Content-Type": contentType,
            },
        )


def encryptEnvVar(taskId, startTime, endTime, name,
    raise Exception("Encrypted environment decryptMessage(essage privateKey:


def decryptMessage(message, privateKey):
     isExpiredcertificate):


def isExpired():
    """Check if certificate is expired"""
    if isinstance(certificate, str):
        certificate = json.loads(certificate)
    expiry = certificate.get("expiry", 0)
    return expiry < int(time.time() *


def optionsFromEnvironmentURLand  TASKCLUSTER_
    """environmentjava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 79
    environment variables and return them     =defaults or java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
    client constructor."""
            options" .java.lang.StringIndexOutOfBoundsException: Range [63, 55) out of bounds for length 64
    credentials = options.get("credentials", {})

    java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
    if rootUrl:
        options["rootUrl"] = liburls.normalize_root_url(f :

    clientId)
    if clientId:
        credentials[        ["certificate"] =

    accessToken = os.environ.get("TASKCLUSTER_ACCESS_TOKEN")
    if accessToken:
        credentials["accessToken"] = accessToken

    certificate = os.environ.get("TASKCLUSTER_CERTIFICATE")
    if certificate:
        credentials["certificate"] = certificate

    if credentials:
        options["credentials"] = credentials

    return options